handlers

Documentation

Index

• type BuildkiteSFNWorker
  • func New(cfg *config.Config, sess *session.Session, buildkiteAPI bk.API) *BuildkiteSFNWorker
  • func (bkw *BuildkiteSFNWorker) HandlerCheckJob(ctx context.Context, evt *bk.WorkflowData) (*bk.WorkflowData, error)
  • func (bkw *BuildkiteSFNWorker) HandlerCompletedJob(ctx context.Context, evt *bk.WorkflowData) (*bk.WorkflowData, error)
  • func (bkw *BuildkiteSFNWorker) HandlerSubmitJob(ctx context.Context, evt *bk.WorkflowData) (*bk.WorkflowData, error)

Types

type BuildkiteSFNWorker

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

BuildkiteSFNWorker handler for lambda events

func New

func New(cfg *config.Config, sess *session.Session, buildkiteAPI bk.API) *BuildkiteSFNWorker

New create a new handler

func (*BuildkiteSFNWorker) HandlerCheckJob

func (bkw *BuildkiteSFNWorker) HandlerCheckJob(ctx context.Context, evt *bk.WorkflowData) (*bk.WorkflowData, error)

HandlerCheckJob process the step function check job event

func (*BuildkiteSFNWorker) HandlerCompletedJob

func (bkw *BuildkiteSFNWorker) HandlerCompletedJob(ctx context.Context, evt *bk.WorkflowData) (*bk.WorkflowData, error)

HandlerCompletedJob process the step function event for completed jobs

func (*BuildkiteSFNWorker) HandlerSubmitJob

func (bkw *BuildkiteSFNWorker) HandlerSubmitJob(ctx context.Context, evt *bk.WorkflowData) (*bk.WorkflowData, error)

HandlerSubmitJob process the step function submit job event