task-tower - GitLite

KO | EN

gitlite — search

#javascript #hacktoberfest #golang #android #rust #nodejs #macos #java #awesome #cli #kubernetes #awesome-list #mcp #openai

task-tower

(★ 51)

No description available.

파일 탐색기

최종 버전 다운로드 (.zip)

- - go.yml
- - pipeline.go
  - stage.go
- - main.go
- - main.go
- config.yml
- release-config.yml
- docker-compose.yml
- Dockerfile-controller
- Dockerfile-worker
- - add-nuget
  - add-to-sln
  - create-classlib
  - create-sln
- - configuration.go
  - yml-configuration.go
- - ConfigurationConsts.go
  - Message.go
- - DockerContainer.go
- - controller-client.go
  - controller.go
  - rest-controller.go
- - executor.go
  - map-executor.go
- - message-queue.go
  - rabbitmq-queue.go
- - mongodb-repository.go
  - postgres-repository.go
  - process-repository.go
- - pipeline-service.go
  - process-service.go
- - forEach.go
  - proces.go
- - rest-worker.go
  - worker.go
- controller.http
- main_test.go
.dockerignore
.gitignore
build.ps1
build.sh
dwas-controller
go.mod
go.sum
install.ps1
install.sh
main
Makefile
README.md

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

*DRAFT*

---

**Opis**

<p align="center">
  <img src="https://github.com/PiotrFerenc/mash2/assets/30370747/27230488-59c6-48e5-8def-8f345c0ac38e" alt="logo" width="400"/>
</p>
<div style="text-align: justify;">

[![Go](https://github.com/PiotrFerenc/mash2/actions/workflows/go.yml/badge.svg?branch=main)](https://github.com/PiotrFerenc/mash2/actions/workflows/go.yml)

[![Quality Gate Status](https://sonarcloud.io/api/project_badges/measure?project=PiotrFerenc_mash2&metric=alert_status)](https://sonarcloud.io/summary/new_code?id=PiotrFerenc_mash2)

![100 - commitów](https://img.shields.io/badge/100-commitów-2ea44f?logo=go)

# Task tower

Task Tower is a tool for automating distributed tasks, utilizing pipelines with isolated processing steps in Docker containers, which allows users to easily scale and modify processes without impacting the entire infrastructure.
 
</div>

## Benefits

- Flexibility in task management
- Process isolation
- Increased operational efficiency
- Ease of integration and collaboration

## How it works

```mermaid
sequenceDiagram
    participant a as API
    participant c as Controller
    participant q as Queue
    participant w1 as Worker 1 
    participant w2 as Worker 2
    participant w3 as Worker 3

a->>c: API Call Request
    c->>a: Response: Pipeline Added to Queue
    c->>q: Add new task: Action1
    q->>w1: Assign Action1 to Worker 1
    w1->>q: Action1 Completed
    q->>c: Notify Controller: Action1 Done
    c->>q: Add new task: Action2
    q->>w2: Assign Action2 to Worker 2
    w2->>q: Action2 Completed
    q->>c: Notify Controller: Action2 Done
    c->>q: Add new task: Action3
    q->>w3: Assign Action3 to Worker 3
    w3->>q: Action3 Completed
    q->>c: Notify Controller: Action3 Done
    c->>q: Add new task: Action4
    q->>w1: Assign Action4 to Worker 1
    w1->>q: Action4 Completed
    q->>c: Notify Controller: Action4 Done
```
The diagram shows the interactions between different participants in a task processing system. The API receives a request from a user and sends a response that the task has been added to the queue by the controller. Then, the controller adds a new task, labeled Action1, to the queue. The queue assigns this task to Worker 1, who, after completing it, informs the queue that it's done. The queue then notifies the controller that Action1 is complete. The process repeats for the next tasks, Action2 and Action3, which are assigned to Worker 2 and Worker 3, respectively. Each of these tasks is completed and reported as finished to the controller by the respective workers. Finally, Action4 is added to the queue, assigned again to Worker 1, who completes the task and reports its completion. The queue again informs the controller that the task is done.

## Installation 
Linux:
```shell
wget https://raw.githubusercontent.com/PiotrFerenc/mash2/main/install.sh && chmod +x install.sh && ./install.sh
```

Windows:
```shell
Invoke-WebRequest -Uri "https://raw.githubusercontent.com/PiotrFerenc/mash2/main/install.ps1" -OutFile "install.ps1"; .\install.[s1
```

## Build

### requirements

- [MAKE](https://www.gnu.org/software/make/)
- [docker](https://docs.docker.com/engine/install/)
- [docker-compose](https://docs.docker.com/compose/install/)
- [GO](https://go.dev/doc/install)

Linux:
```shell
wget https://raw.githubusercontent.com/PiotrFerenc/mash2/main/build.sh && chmod +x build.sh && ./build.sh
```

Windows:
```powershell
Invoke-WebRequest -Uri "https://raw.githubusercontent.com/PiotrFerenc/mash2/main/build.ps1" -OutFile "build.ps1"; Set-ExecutionPolicy -Scope Process -ExecutionPolicy Bypass -Force; ./build.ps1
```

## Usage

```shell
curl -X POST localhost:5000/execute -H "Content-Type: application/json" -d '{
    "Parameters": {
        "console.text": "hallo word"
    },
    "Tasks": [
        {
            "Sequence": 1,
            "Name": "log",
            "Action": "console"
        }
    ]
}'
```

or
```shell

echo '{
    "Parameters": {
        "console.text": "hallo word"
    },
    "Tasks": [
        {
            "Sequence": 1,
            "Name": "log",
            "Action": "console"
        }
    ]
}' > request.json

curl -X POST localhost:5000/execute -H "Content-Type: application/json" -d @request.json
```
or

[C#](https://github.com/PiotrFerenc/mash2/wiki/C%23), [Go](https://github.com/PiotrFerenc/mash2/wiki/Go), [Rust](https://github.com/PiotrFerenc/mash2/wiki/Rust), [Java](https://github.com/PiotrFerenc/mash2/wiki/Java), [Typescript](https://github.com/PiotrFerenc/mash2/wiki/TypeScript), [PHP](https://github.com/PiotrFerenc/mash2/wiki/PHP), [COBOL](https://github.com/PiotrFerenc/mash2/wiki/COBOL), [Erlang](https://github.com/PiotrFerenc/mash2/wiki/Erlang), [Python](https://github.com/PiotrFerenc/mash2/wiki/Python), [Ruby](https://github.com/PiotrFerenc/mash2/wiki/Ruby), [Scala](https://github.com/PiotrFerenc/mash2/wiki/Scala)

## Actions

## Action: git-clone

**Description:** Clones a git repository to a local path.

**Inputs:**
- **url (text, required):** URL of the git repository to clone.  
  *Display Name:* Git Repository URL

**Outputs:**
- **path (text, required):** Local path where the repository will be cloned to.  
  *Display Name:* Destination Path

---

## Action: git-commit

**Description:** Creates a commit in the git repository.

**Inputs:**
- **path (text, required):** Path to the Git repository.  
  *Display Name:* Repository Path
- **process (text, required):** Message for the Git commit.  
  *Display Name:* Commit Message

**Outputs:**
- **id (text, required):** ID of the Git commit.  
  *Display Name:* Commit ID

---

## Action: git-branch

**Description:** Creates a new branch in the git repository.

**Inputs:**
- **repoPath (text, required):** The path to the local Git repository where the new branch will be created.  
  *Display Name:* Repository Path
- **branchName (text, required):** The name of the new branch to create in the Git repository.  
  *Display Name:* Branch Name

---

## Action: docker-run

**Description:** Runs a Docker container.

**Inputs:**
- **image (text, required):** The name of the Docker image to use.  
  *Display Name:* Image Name
- **e (text, required):** The environment variables for the Docker container.  
  *Display Name:* Environment Variables
- **v (text, required):** Volume.  
  *Display Name:* Environment Variables

**Outputs:**
- **id (text):** The unique identifier for the Docker container.  
  *Display Name:* Container ID

---

## Action: file-append

**Description:** Appends content to a file.

**Inputs:**
- **fileName (text, required):** The name of the file to which content is being appended.  
  *Display Name:* File Name
- **content (text, required):** The content to be appended to the file.  
  *Display Name:* Content

**Outputs:**
- **appendFilePath (text):** The path of the file to which the content will be appended.  
  *Display Name:* Append File Path

---

## Action: console

**Description:** Displays text in the console.

**Inputs:**
- **text (text, required):** Text to display.  
  *Display Name:*

---

## Action: add-numbers

**Description:** Adds two numbers.

**Inputs:**
- **a (number, required):** First number to be added.  
  *Display Name:* Number A
- **b (number, required):** Second number to be added.  
  *Display Name:* Number B

**Outputs:**
- **c (number):** The result of addition.  
  *Display Name:* Sum

---

## Action: file-create

**Description:** Creates a file with the provided content.

**Inputs:**
- **fileName (text, required):** The name of the file.  
  *Display Name:* File Name
- **content (text, required):** The content to be written to the file.  
  *Display Name:* File Content

**Outputs:**
- **createdFilePath (text):** The path where the new file was created.  
  *Display Name:* Created File Path

---

## Action: file-delete

**Description:** Deletes a file.

**Inputs:**
- **fileName (text, required):** Name of the file to be deleted.  
  *Display Name:* File Name

## Todo 1.0
- [x] Application Programming Interface (API)
- [ ] Monitoring and Logging
- [x] Triggering Tasks
- [x] Handling Distributed Tasks
- [x] Error Management
- [x] Extensibility
- [x] Configuration

## Todo: 2.0
- [ ] CLI
  - prompt
  - list
  - run
- [ ] User Interface (UI)
- [ ] Scheduling
- [ ] Dependency Management of Tasks
- [ ] Retry Mechanisms
- [ ] Security
- [ ] Integration with External Services and Applications

## STATISTICS

[![Bugs](https://sonarcloud.io/api/project_badges/measure?project=PiotrFerenc_mash2&metric=bugs)](https://sonarcloud.io/summary/new_code?id=PiotrFerenc_mash2) [![Code Smells](https://sonarcloud.io/api/project_badges/measure?project=PiotrFerenc_mash2&metric=code_smells)](https://sonarcloud.io/summary/new_code?id=PiotrFerenc_mash2) [![Coverage](https://sonarcloud.io/api/project_badges/measure?project=PiotrFerenc_mash2&metric=coverage)](https://sonarcloud.io/summary/new_code?id=PiotrFerenc_mash2) [![Duplicated Lines (%)](https://sonarcloud.io/api/project_badges/measure?project=PiotrFerenc_mash2&metric=duplicated_lines_density)](https://sonarcloud.io/summary/new_code?id=PiotrFerenc_mash2) [![Lines of Code](https://sonarcloud.io/api/project_badges/measure?project=PiotrFerenc_mash2&metric=ncloc)](https://sonarcloud.io/summary/new_code?id=PiotrFerenc_mash2) [![Reliability Rating](https://sonarcloud.io/api/project_badges/measure?project=PiotrFerenc_mash2&metric=reliability_rating)](https://sonarcloud.io/summary/new_code?id=PiotrFerenc_mash2) [![Security Rating](https://sonarcloud.io/api/project_badges/measure?project=PiotrFerenc_mash2&metric=security_rating)](https://sonarcloud.io/summary/new_code?id=PiotrFerenc_mash2)  [![Technical Debt](https://sonarcloud.io/api/project_badges/measure?project=PiotrFerenc_mash2&metric=sqale_index)](https://sonarcloud.io/summary/new_code?id=PiotrFerenc_mash2) [![Maintainability Rating](https://sonarcloud.io/api/project_badges/measure?project=PiotrFerenc_mash2&metric=sqale_rating)](https://sonarcloud.io/summary/new_code?id=PiotrFerenc_mash2) [![Vulnerabilities](https://sonarcloud.io/api/project_badges/measure?project=PiotrFerenc_mash2&metric=vulnerabilities)](https://sonarcloud.io/summary/new_code?id=PiotrFerenc_mash2)

## License