internal

Documentation

Index

• type RegistryConnDetails
  • func NewRegistryConnDetails(registry, user, pwd string, logger log.Logger) *RegistryConnDetails
  • func (r *RegistryConnDetails) NewClient() (*client.Client, error)
• type Worker
  • func NewWorker(client pb.WorkflowServiceClient, regConn *RegistryConnDetails, ...) *Worker
  • func (w *Worker) ProcessWorkflowActions(ctx context.Context, workerID string) error
• type WorkflowMetadata

Types

type RegistryConnDetails

type RegistryConnDetails struct {
	// contains filtered or unexported fields
}

RegistryConnDetails are the connection details for accessing a Docker registry and logging activities

func NewRegistryConnDetails

func NewRegistryConnDetails(registry, user, pwd string, logger log.Logger) *RegistryConnDetails

NewRegistryConnDetails creates a new RegistryConnDetails

func (*RegistryConnDetails) NewClient

func (r *RegistryConnDetails) NewClient() (*client.Client, error)

NewClient uses the RegistryConnDetails to create a new Docker Client

type Worker

type Worker struct {
	// contains filtered or unexported fields
}

Worker details provide all the context needed to run a

func NewWorker

func NewWorker(client pb.WorkflowServiceClient, regConn *RegistryConnDetails, logger log.Logger, registry string, retries int, retryInterval time.Duration, maxFileSize int64) *Worker

NewWorker creates a new Worker, creating a new Docker registry client

func (*Worker) ProcessWorkflowActions

func (w *Worker) ProcessWorkflowActions(ctx context.Context, workerID string) error

ProcessWorkflowActions gets all Workflow contexts and processes their actions

type WorkflowMetadata

type WorkflowMetadata struct {
	WorkerID  string    `json:"workerID"`
	Action    string    `json:"actionName"`
	Task      string    `json:"taskName"`
	UpdatedAt time.Time `json:"updatedAt"`
	SHA       string    `json:"sha256"`
}

WorkflowMetadata is the metadata related to workflow data