util

Documentation

Index

• func AppendFile(path string, data []byte) error
• func CreateDockerConnector(org, id string, args ...interface{}) *harness.Connector
• func CreateFolder(path string) error
• func CreateGithubConnector(org, id, username, token string) *harness.Connector
• func CreateGitlabConnector(org, id, username, token string) *harness.Connector
• func CreateSecret(org, project, identifier, desc, data string) *harness.Secret
• func CreateSecretOrg(org, identifier, data string) *harness.Secret
• func DeleteDirsExcept(rootPath, exceptFilePath string) error
• func GetJson(data any) ([]byte, error)
• func GetRepoDirFromRepoSlug(repoSlug string) string
• func IsErrConflict(err error) bool
• func JoinPaths(elem ...string) string
• func Unzip(src string, dest string) error
• func WriteFile(path string, prJson []byte) error
• func ZipFolder(source, destination string) error
• type DockerConnectorOptions
• type Result
• type Task
• type TaskPool
  • func NewTaskPool(ctx context.Context, maxParallelism int) *TaskPool
  • func (tp *TaskPool) ForceShutdown()
  • func (tp *TaskPool) MarkResultRead()
  • func (tp *TaskPool) Shutdown()
  • func (tp *TaskPool) Start() error
  • func (tp *TaskPool) Submit(task *Task)
• type Worker
  • func NewWorker(id int, taskCh chan *Task, resultCh chan *Result, Wg *sync.WaitGroup) *Worker
  • func (w *Worker) Start(ctx context.Context) error

Functions

func AppendFile

func AppendFile(path string, data []byte) error

func CreateDockerConnector

func CreateDockerConnector(org, id string, args ...interface{}) *harness.Connector

CreateDockerConnector helper function to create a docker connector

func CreateFolder

func CreateFolder(path string) error

func CreateGithubConnector

func CreateGithubConnector(org, id, username, token string) *harness.Connector

CreateGithubConnector helper function to create a github connector

func CreateGitlabConnector

func CreateGitlabConnector(org, id, username, token string) *harness.Connector

CreateGitlabConnector helper function to create a GitHub connector

func CreateSecret

func CreateSecret(org, project, identifier, desc, data string) *harness.Secret

func CreateSecretOrg

func CreateSecretOrg(org, identifier, data string) *harness.Secret

CreateSecretOrg helper function to create an org secret.

func DeleteDirsExcept

func DeleteDirsExcept(rootPath, exceptFilePath string) error

DeleteDirsExcept deletes all directories in the specified path except for the specified file's path.

func GetJson

func GetJson(data any) ([]byte, error)

func GetRepoDirFromRepoSlug

func GetRepoDirFromRepoSlug(repoSlug string) string

func IsErrConflict

func IsErrConflict(err error) bool

IsErrConflict helper function return true if the codeerror message indicate the resource already exists.

func JoinPaths

func JoinPaths(elem ...string) string

Join joins any number of path elements into a single path, separating them with slashes. Empty elements are ignored.

func Unzip

func Unzip(src string, dest string) error

func WriteFile

func WriteFile(path string, prJson []byte) error

func ZipFolder

func ZipFolder(source, destination string) error

ZipFolder zips the contents of the specified folder and saves the zip file to the specified destination.

Types

type DockerConnectorOptions

type DockerConnectorOptions struct {
	Username string
	Password string
	URL      string
}

type Result

type Result struct {
	ID   int
	Data any
	Err  error
}

Result represents the result of a task.

type Task

type Task struct {
	ID      int
	Execute func(ctx context.Context) (any, error)
}

Task represents a task to be executed.

type TaskPool

type TaskPool struct {
	MaxParallelism int
	TaskCh         chan *Task
	ResultCh       chan *Result
	Wg             *sync.WaitGroup

	Cancel context.CancelFunc
	// contains filtered or unexported fields
}

TaskPool represents a pool of workers that can execute tasks concurrently.

func NewTaskPool

func NewTaskPool(ctx context.Context, maxParallelism int) *TaskPool

NewTaskPool creates a new job pool.

func (*TaskPool) ForceShutdown

func (tp *TaskPool) ForceShutdown()

func (*TaskPool) MarkResultRead

func (tp *TaskPool) MarkResultRead()

func (*TaskPool) Shutdown

func (tp *TaskPool) Shutdown()

Shutdown gracefully shuts down the thread pool

func (*TaskPool) Start

func (tp *TaskPool) Start() error

Start starts the thread pool with the specified number of workers.

func (*TaskPool) Submit

func (tp *TaskPool) Submit(task *Task)

Submit submits a task to the thread pool.

type Worker

type Worker struct {
	ID       int
	TaskCh   chan *Task
	ResultCh chan *Result
	Wg       *sync.WaitGroup
}

Worker represents a worker that executes tasks.

func NewWorker

func NewWorker(id int, taskCh chan *Task, resultCh chan *Result, Wg *sync.WaitGroup) *Worker

NewWorker creates a new worker.

func (*Worker) Start

func (w *Worker) Start(ctx context.Context) error

Start starts the worker to listen for tasks and execute them.