pipeline

Documentation

Index

• type ChefActionPipeline
  • func NewChefActionPipeline(client backend.Client, authzClient iam_v2.ProjectsClient) ChefActionPipeline
  • func (caPipeline *ChefActionPipeline) Close()
  • func (caPipeline *ChefActionPipeline) GetTotalMessages() int64
  • func (caPipeline *ChefActionPipeline) Run(action *chef.Action, errc chan<- error)
• type ChefRunPipeline
  • func NewChefRunPipeline(client backend.Client, authzClient iam_v2.ProjectsClient, ...) ChefRunPipeline
  • func (crPipeline *ChefRunPipeline) Close()
  • func (crPipeline *ChefRunPipeline) GetTotalMessages() int64
  • func (crPipeline *ChefRunPipeline) Run(run *chef.Run, errc chan<- error)

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 iam_v2.ProjectsClient) 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(action *chef.Action, errc chan<- 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 iam_v2.ProjectsClient, nodeMgrClient manager.NodeManagerServiceClient) 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(run *chef.Run, errc chan<- error)

Run a chef client run through the pipeline