ActionRunner

Documentation

Index

• type ActionArgs
• type ActionDescriptor
• type ActionIdentifier
  • func GetActionIds(descs []ActionDescriptor) []ActionIdentifier
• type ActionRunner
  • func New(ctx context.Context, actionsDb *actiondb.ActionDb) (runner ActionRunner)
  • func (runner ActionRunner) Cancel()
  • func (runner ActionRunner) Chan() chan ActionArgs
  • func (runner ActionRunner) Done() <-chan struct{}
  • func (runner ActionRunner) Wait()
• type UnixUserInfo

Types

type ActionArgs

type ActionArgs struct {
	Logger *slog.Logger
	Action ActionDescriptor
}

type ActionDescriptor

type ActionDescriptor struct {
	ActionIdentifier
	Action config.Action `json:"-"`
}

type ActionIdentifier

type ActionIdentifier struct {
	Index      int    `json:"actionIdx"`
	Project    string `json:"project"`
	PipeId     string `json:"pipeId"`
	DeliveryId string `json:"-"`
}

func GetActionIds

func GetActionIds(descs []ActionDescriptor) []ActionIdentifier

type ActionRunner

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

func New

func New(ctx context.Context, actionsDb *actiondb.ActionDb) (runner ActionRunner)

func (ActionRunner) Cancel

func (runner ActionRunner) Cancel()

func (ActionRunner) Chan

func (runner ActionRunner) Chan() chan ActionArgs

func (ActionRunner) Done

func (runner ActionRunner) Done() <-chan struct{}

func (ActionRunner) Wait

func (runner ActionRunner) Wait()

type UnixUserInfo

type UnixUserInfo struct {
	Uid uint32
	Gid uint32
}