publisher

Documentation

Index

• func BuildBulkRunPublisher(client backend.Client, maxNumberOfBundledRunMsgs int) message.ChefRunPipe
• func BuildChefRun(client backend.Client, numberOfPublishers int) message.ChefRunPipe
• func BuildConfigMgmtPublisher(client cfgmgmt.CfgMgmtServiceClient, numPublishers int) message.ChefActionPipe
• func BuildEventPublisher(eventFeedServiceClient event_feed.EventFeedServiceClient, numPublishers int) message.ChefActionPipe
• func BuildMsgDistributor(childPipeBuilder message.ChefRunPipe, numProcessors, childPipeInboxSize int) message.ChefRunPipe
• func BuildNodeManagerPublisher(nodeManagerClient manager.NodeManagerServiceClient, numPublishers int) message.ChefRunPipe
• func ChefRun(in <-chan message.ChefRun, client backend.Client, out chan<- message.ChefRun, ...)
• func ChefRunDateInfo(in <-chan message.ChefRun, client backend.Client, out chan<- message.ChefRun, ...)

Functions

func BuildBulkRunPublisher

func BuildBulkRunPublisher(client backend.Client, maxNumberOfBundledRunMsgs int) message.ChefRunPipe

func BuildChefRun

func BuildChefRun(client backend.Client, numberOfPublishers int) message.ChefRunPipe

BuildChefRun Builds the publishers

func BuildConfigMgmtPublisher

func BuildConfigMgmtPublisher(client cfgmgmt.CfgMgmtServiceClient, numPublishers int) message.ChefActionPipe

func BuildEventPublisher

func BuildEventPublisher(
	eventFeedServiceClient event_feed.EventFeedServiceClient, numPublishers int) message.ChefActionPipe

func BuildMsgDistributor

func BuildMsgDistributor(childPipeBuilder message.ChefRunPipe, numProcessors,
	childPipeInboxSize int) message.ChefRunPipe

BuildMsgDistributor a message distributor that sends all messages to the first child pipe until it is full then start sending messages to the next child pipe in the line. When all the pipes are full the thread waits and then checks to pipes again until it can place the message in a child pipe.

func BuildNodeManagerPublisher

func BuildNodeManagerPublisher(nodeManagerClient manager.NodeManagerServiceClient, numPublishers int) message.ChefRunPipe

func ChefRun

func ChefRun(in <-chan message.ChefRun, client backend.Client, out chan<- message.ChefRun, number int)

ChefRun The Chef run publisher pipe. This stores the chef run information in the datastore.

func ChefRunDateInfo

func ChefRunDateInfo(in <-chan message.ChefRun, client backend.Client, out chan<- message.ChefRun, number int)

ChefRunDateInfo The Chef run publisher pipe. This stores the chef run date information in the datastore.