Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // helper for testing purposes NoopHandleFn = func(configProtocol protocol.ConfigProtocol, c cache.Cache, parentDefinition integration.Definition) {} )
Functions ¶
This section is empty.
Types ¶
type Entry ¶
type Entry struct { Definition integration.Definition Databind databind.YAMLConfig }
type HandleFn ¶
type HandleFn func(cfgProtocol protocol.ConfigProtocol, c cache.Cache, parentDefinition integration.Definition)
func NewHandleFn ¶
func NewHandleFn(configProtocolQueue chan<- Entry, terminateDefinitionQueue chan<- string, 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.
Click to show internal directories.
Click to hide internal directories.