message

Documentation

Index

• func PropagateChefAction(out chan<- ChefAction, msg *ChefAction)
• func PropagateChefRun(out chan<- ChefRun, msg *ChefRun)
• type ChefAction
  • func NewChefAction(ctx context.Context, action *chef.Action, err chan<- error) ChefAction
  • func (chefAction *ChefAction) ClockProcessingTime() int64
  • func (chefAction ChefAction) FinishProcessing(err error)
• type ChefActionPipe
• type ChefRun
  • func NewChefRun(ctx context.Context, run *chef.Run, err chan<- error) ChefRun
  • func (chefRun *ChefRun) ClockProcessingTime() int64
  • func (chefRun *ChefRun) FinishProcessing(err error)
• type ChefRunPipe

Functions

func PropagateChefAction

func PropagateChefAction(out chan<- ChefAction, msg *ChefAction)

func PropagateChefRun

func PropagateChefRun(out chan<- ChefRun, msg *ChefRun)

Types

type ChefAction

type ChefAction struct {
	ID                 uuid.UUID
	QueueTime          time.Time
	Action             *chef.Action
	InternalChefAction backend.InternalChefAction
	BulkableRequests   []elastic.BulkableRequest
	Ctx                context.Context
	// contains filtered or unexported fields
}

func NewChefAction

func NewChefAction(ctx context.Context, action *chef.Action, err chan<- error) ChefAction

func (*ChefAction) ClockProcessingTime

func (chefAction *ChefAction) ClockProcessingTime() int64

ClockProcessingTime will return the time that has passed (in milliseconds) since the message got started until 'Now()'

Useful to check the time that messages take to go through the pipeline

func (ChefAction) FinishProcessing

func (chefAction ChefAction) FinishProcessing(err error)

type ChefActionPipe

type ChefActionPipe func(<-chan ChefAction) <-chan ChefAction

type ChefRun

type ChefRun struct {
	ID               uuid.UUID
	QueueTime        time.Time
	Run              chef.Run
	Node             backend.Node
	NodeRun          backend.Run
	NodeAttribute    backend.NodeAttribute
	NodeRunDateInfo  backend.NodeRunDateInfo
	BulkableRequests []elastic.BulkableRequest
	Platform         string
	Ctx              context.Context
	// contains filtered or unexported fields
}

func NewChefRun

func NewChefRun(ctx context.Context, run *chef.Run, err chan<- error) ChefRun

func (*ChefRun) ClockProcessingTime

func (chefRun *ChefRun) ClockProcessingTime() int64

ClockProcessingTime will return the time that has passed (in milliseconds) since the message got started until 'Now()'

Useful to check the time that messages take to go through the pipeline

func (*ChefRun) FinishProcessing

func (chefRun *ChefRun) FinishProcessing(err error)

type ChefRunPipe

type ChefRunPipe func(<-chan ChefRun) <-chan ChefRun