message

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
}

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

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
}

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