SetString sets the value of a string property in the Parameters map of the Process object. Parameters: name: The name of the property to be set. v

Close closes the RabbitMQ channel associated with the RabbitClient instance. It uses the underlying RabbitMQ channel's Close() method to close the cha

StartContainer starts a Docker container with the specified image name, environment variables, volume bindings, and context. Parameters: imageName:

addTask publishes a message to the specified queue using the RabbitMQ client. It marshals the provided message to JSON format and sets the message pro

`waitingForTask` returns a channel of amqp.Delivery that receives messages from the specified queue. It uses the RabbitMQ client's `Consume` method to

GetInternalName returns the internal name of a property by concatenating the camelCase version of the current step's name with the provided propertyNa

ProcessTasks processes tasks from the message queue by getting the tasks using getTasksFunc, and then calling processTasks to process each task using

CreateActionMap takes a pointer to a Config struct as input parameter. It creates and returns a map of actions. The keys of the map are the names of t

CreateRabbitMqMessageQueue creates a new RabbitMQ message queue based on the given configuration. It establishes a connection, creates the necessary q

addToQueue adds a task to the message queue as either a success or failure. If the given error is not nil, it adds the task as a failure, otherwise it

BuildImage builds a Docker image using the specified Dockerfile path, image name, and context. Parameters: dockerfilePath: The path to the Dockerfi

Connect establishes a connection to the RabbitMQ server and initializes a RabbitClient. It uses the underlying establishConnection function to establi

ConnectRabbitMQ establishes a connection to the RabbitMQ server using the provided credentials and returns the connection and any error that occurred

CreateAddNumbers This is a function that initializes an instance of the addnumbers struct. It returns a pointer to the addnumbers instance. This is us

CreateMapExecutor creates and starts an executor that consumes tasks from the given message queue and executes them. It takes a MessageQueue and a map

CreateOnFailFunc creates a function of type OnMessageReceivedFunc that logs the failure of a process, marks the process as failed in the service, and

CreateOnFinishFunc creates a function of type OnMessageReceivedFunc that logs the successful completion of a process, marks the process as done in the

CreateOnSuccessFunc creates a function of type OnMessageReceivedFunc that processes the given process, queue, and service based on the logic provided

CreatePipelineService creates a PipelineService instance by initializing the queue, processService, and starting a goroutine to watch for messages. It

CreatePostgresRepository takes a DatabaseConfig and returns a ProcessRepository that interacts with a PostgreSQL database. The function establishes a

CreateProcessService creates a new instance of ProcessService with the given repository.

CreateRestWorker creates a new RestWorker with the given executor. It takes an executor.Executor as a parameter and returns a Worker.

MapForeachBody maps a ForeachBody object to a ForeachBody object with additional fields.

MapToForeachStep maps a ForeachTask to a ForeachStep. Parameters: step: The ForeachTask to be mapped. Returns: ForeachStep: The mapped ForeachSt

MapToForeachSteps maps a slice of ForeachTasks to a slice of ForeachSteps. Parameters: steps: The slice of ForeachTasks to be mapped. Returns: [

MapToStep maps a ForeachStep to a Step. Parameters: forEachStep: The ForeachStep to be mapped. Returns: *Step: A pointer to the mapped Step.

NewFolder returns the concatenated path and a new UUID string, separated by a slash. Parameters: path: The base path to concatenate with the UUID s

NewProcessFromPipeline creates a new Process object from the given Pipeline object. Parameters: pipeline: The Pipeline object used to create the Pr

NewRabbitMQClient creates a new RabbitMQ client based on the provided connection. It establishes a channel using the connection and returns the create

RemoveContainer removes a Docker container with the specified container ID and context. Parameters: containerId: The ID of the container to be remo

SetInt sets the value of an integer property in the Parameters map of the Process object. Parameters: name: The name of the property to be set. va

createQueues creates the necessary queues based on the provided configuration. It iterates over the list of queue names in the configuration and calls

establishConnection establishes a connection to the RabbitMQ server using the provided credentials and creates a RabbitClient with the connection. It

executeHandler is a handler function that takes a controller instance as a parameter and returns a function that has a gin.Context as its parameter. T

getByIdHandler is a handler function that retrieves a process by its ID and returns the status of the process. It takes a controller instance as a par

processTasks processes tasks from the message queue by receiving tasks from the tasks channel. It unmarshals each task message and calls the taskFunc

unmarshal unmarshals the body of an amqp.Delivery into a types.Process struct. It takes an amqp.Delivery as input parameter and returns a types.Proces

unmarshalMessage unmarshals a byte array into a pointer to a types.Process object. It returns the unmarshaled message and any error that occurred duri

watchForMessages is a function that listens for messages from the message queue and processes them using the provided onSuccess, onFail, onFinish, and

AddTaskAsFailed addTask adds a task to the specified queue using the RabbitMQ client. It marshals the message to JSON format and publishes it to the q

AddTaskAsFinished adds a task to the specified queue as a finished task using the RabbitMQ client. It calls the addTask method with the configuration'

AddTaskAsSuccess adds a task to the specified queue as a successful task using the RabbitMQ client. It calls the addTask method with the configuration

AddTaskToQueue adds a task to the specified queue using the RabbitMQ client. It calls the addTask method with the configuration's QueueRunPipe queue n

CreateControllerClient creates a ControllerClient using the provided ControllerConfig.

CreateMongoDbRepository initializes a new MongoDB repository for process entities.

CreateQueue creates a new queue with the specified name using the RabbitMQ client. It uses the underlying RabbitClient's CreateQueue method to perform

CreateQueue creates a new queue with the specified name using the RabbitMQ client. It uses the underlying RabbitClient's QueueDeclare method to perfor

Execute executes the given pipeline by sending a POST request to the specified URL with the pipeline data. It returns the process ID if the execution

Execute executes the action by getting a string value from the `text` property of the `pipeline` parameter, logging the value, and returning the `pipe

Execute performs the execution of the gitClone action. It clones a Git repository from the provided URL using the git.PlainClone function. The cloned

Execute receives a message of type types.Process and performs a Git commit operation. It retrieves the repository path and commit message from the mes

Execute performs the archive to file action. It takes a Process message as input, extracts the file path and archive file name properties from the mes