publisher

Documentation

Index

• func BuildBulkActionPublisher(client backend.Client) message.ChefActionPipe
• func BuildBulkRunPublisher(client backend.Client) message.ChefRunPipe
• func BuildChefAction(client backend.Client, numberOfPublishers int) message.ChefActionPipe
• func BuildChefRun(client backend.Client, numberOfPublishers int) message.ChefRunPipe
• func BuildNodeManagerPublisher(nodeManagerClient manager.NodeManagerServiceClient) message.ChefRunPipe
• func ChefAction(in <-chan message.ChefAction, client backend.Client, ...)
• func ChefRun(in <-chan message.ChefRun, client backend.Client, out chan<- message.ChefRun, ...)

Functions

func BuildBulkActionPublisher

func BuildBulkActionPublisher(client backend.Client) message.ChefActionPipe

func BuildBulkRunPublisher

func BuildBulkRunPublisher(client backend.Client) message.ChefRunPipe

func BuildChefAction

func BuildChefAction(client backend.Client, numberOfPublishers int) message.ChefActionPipe

BuildChefAction Builds the publishers

func BuildChefRun

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

BuildChefRun Builds the publishers

func BuildNodeManagerPublisher

func BuildNodeManagerPublisher(nodeManagerClient manager.NodeManagerServiceClient) message.ChefRunPipe

func ChefAction

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

ChefAction The Chef action publisher pipe. This stores the chef action information in the datastore.

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.