Documentation
¶
Index ¶
- Variables
- func InitApplication(name string, config interface{}) error
- func InitTransport(name string, config interface{}) (string, error)
- func RunApplications(ctx context.Context, wg *sync.WaitGroup, done chan bool)
- func RunTransports(ctx context.Context, wg *sync.WaitGroup, done chan bool, report bool)
- func SetEventBusBlocking(block bool)
- func SetLogger(l *logging.Logger)
- func SetPluginDir(path string)
- func SetTransportHandlers(name string, handlerBlocks []struct{ ... }) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // ErrAppNotReceiver return if application plugin does not implement any receiver. In this case, it will receive no messages from the internal buses ErrAppNotReceiver = errors.New("application plugin does not implement either application.MetricReceiver or application.EventReceiver") )
errors
Functions ¶
func InitApplication ¶
InitApplication initialize application plugin with configuration
func InitTransport ¶
InitTransport load tranpsort binary and initialize with config
func RunApplications ¶
RunApplications spins off application processes
func RunTransports ¶
RunTransports spins off tranpsort + handler processes
func SetEventBusBlocking ¶
func SetEventBusBlocking(block bool)
SetBlockingEventBus set the correct event bus publish function
func SetPluginDir ¶
func SetPluginDir(path string)
SetPluginDir set directory path containing plugin binaries
func SetTransportHandlers ¶
func SetTransportHandlers(name string, handlerBlocks []struct { Name string `validate:"required"` Config interface{} }) error
SetTransportHandlers load handlers binaries for transport
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.