processor

Documentation

Index

• Variables
• func BuildActionProjectTagger(authzClient authz.ProjectsServiceClient) message.ChefActionPipe
• func BuildChefActionPerform(client backend.Client) message.ChefActionPipe
• func BuildRunMsgToBulkRequestTransformer(client backend.Client) message.ChefRunPipe
• func BuildRunProjectTagger(authzClient authz.ProjectsServiceClient) message.ChefRunPipe
• func BuildTransmogrify(numProcessors int) message.ChefRunPipe
• func ChefActionTransmogrify(in <-chan message.ChefAction) <-chan message.ChefAction
• func ChefRunCorrections(in <-chan message.ChefRun) <-chan message.ChefRun
• func ChefRunTransmogrify(in <-chan message.ChefRun, out chan<- message.ChefRun, number int)
• func CountActions(counter *int64) message.ChefActionPipe
• func CountRuns(counter *int64) message.ChefRunPipe
• func MessageValidator(in <-chan message.ChefRun) <-chan message.ChefRun
• func ProcessNodeDelete(ctx context.Context, action *chef.Action, client backend.Client) (int, error)

Variables

var StartedAt = time.Now()

StartedAt time will be a constant to know at what time the service was started

Functions

func BuildActionProjectTagger

func BuildActionProjectTagger(authzClient authz.ProjectsServiceClient) message.ChefActionPipe

BuildActionProjectTagger - Build a project tagger for Chef Actions

func BuildChefActionPerform

func BuildChefActionPerform(client backend.Client) message.ChefActionPipe

func BuildRunMsgToBulkRequestTransformer

func BuildRunMsgToBulkRequestTransformer(client backend.Client) message.ChefRunPipe

func BuildRunProjectTagger

func BuildRunProjectTagger(authzClient authz.ProjectsServiceClient) message.ChefRunPipe

BuildRunProjectTagger - Build a project tagger for CCRs

func BuildTransmogrify

func BuildTransmogrify(numProcessors int) message.ChefRunPipe

BuildTransmogrify Builds the Transmogrify Processor(s)

func ChefActionTransmogrify

func ChefActionTransmogrify(in <-chan message.ChefAction) <-chan message.ChefAction

ChefActionTransmogrify translates an action protobuf into an InternalChefAction struct

func ChefRunCorrections

func ChefRunCorrections(in <-chan message.ChefRun) <-chan message.ChefRun

ChefRunCorrections - This processor makes updates and corrections to the raw data from the chef run message.

func ChefRunTransmogrify

func ChefRunTransmogrify(in <-chan message.ChefRun, out chan<- message.ChefRun, number int)

func CountActions

func CountActions(counter *int64) message.ChefActionPipe

CountActions

func CountRuns

func CountRuns(counter *int64) message.ChefRunPipe

CountRuns

func MessageValidator

func MessageValidator(in <-chan message.ChefRun) <-chan message.ChefRun

MessageValidator - Validate the message before it moves further in the pipeline.

func ProcessNodeDelete

func ProcessNodeDelete(ctx context.Context, action *chef.Action, client backend.Client) (int, error)

ProcessNodeDelete