pipeline

Documentation

Index

• Variables
• type ChefActionPipeline
  • func NewChefActionPipeline(client backend.Client, authzClient authz.ProjectsServiceClient, ...) ChefActionPipeline
  • func (caPipeline *ChefActionPipeline) Close()
  • func (caPipeline *ChefActionPipeline) GetTotalMessages() int64
  • func (caPipeline *ChefActionPipeline) Run(ctx context.Context, action *chef.Action, errc chan<- error) error
• type ChefRunPipeline
  • func NewChefRunPipeline(client backend.Client, authzClient authz.ProjectsServiceClient, ...) ChefRunPipeline
  • func (crPipeline *ChefRunPipeline) Close()
  • func (crPipeline *ChefRunPipeline) GetTotalMessages() int64
  • func (crPipeline *ChefRunPipeline) Run(ctx context.Context, run *chef.Run, errc chan<- error) error

Variables

var ErrQueueFull = errors.New("Message rejected because queue is full")

Types

type ChefActionPipeline

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

ChefActionPipeline pipeline to process Chef actions from client or server

func NewChefActionPipeline

func NewChefActionPipeline(client backend.Client, authzClient authz.ProjectsServiceClient,
	configMgmtClient cfgmgmt.CfgMgmtServiceClient, eventFeedServiceClient event_feed.EventFeedServiceClient,
	messageBufferSize, maxNumberOfBundledActionMsgs int) ChefActionPipeline

NewChefActionPipeline Create a new chef action pipeline

func (*ChefActionPipeline) Close

func (caPipeline *ChefActionPipeline) Close()

Close the Pipeline and do all clean up

func (*ChefActionPipeline) GetTotalMessages

func (caPipeline *ChefActionPipeline) GetTotalMessages() int64

func (*ChefActionPipeline) Run

func (caPipeline *ChefActionPipeline) Run(ctx context.Context, action *chef.Action, errc chan<- error) error

Run a chef client action through the pipeline

type ChefRunPipeline

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

ChefRunPipeline pipeline to process Chef client runs

func NewChefRunPipeline

func NewChefRunPipeline(client backend.Client, authzClient authz.ProjectsServiceClient,
	nodeMgrClient manager.NodeManagerServiceClient,
	chefIngestRunPipelineConfig serveropts.ChefIngestRunPipelineConfig,
	messageBufferSize int) ChefRunPipeline

NewChefRunPipeline Create a new chef run pipeline

func (*ChefRunPipeline) Close

func (crPipeline *ChefRunPipeline) Close()

Close the Pipeline and do all clean up

func (*ChefRunPipeline) GetTotalMessages

func (crPipeline *ChefRunPipeline) GetTotalMessages() int64

func (*ChefRunPipeline) Run

func (crPipeline *ChefRunPipeline) Run(ctx context.Context, run *chef.Run, errc chan<- error) error

Run a chef client run through the pipeline