cmdrequest

Documentation

Index

• Variables
• type HandleFn
  • func NewHandleFn(definitionQueue chan<- integration.Definition, il integration.InstancesLookup, ...) HandleFn

Variables

var (
	// helper for testing purposes
	NoopHandleFn = func(protocol.CmdRequestV1) {}
)

Types

type HandleFn

type HandleFn func(protocol.CmdRequestV1)

func NewHandleFn

func NewHandleFn(definitionQueue chan<- integration.Definition, il integration.InstancesLookup, logger log.Entry) HandleFn

NewHandleFn creates a handler func that runs every command within the request batch independently. Each command is run in parallel and won't depend on the results of the other ones.