bus

Documentation

Index

• func AddSource(parameters *api.PublishEventParameters) (resp *api.SendEventParameters, err error)
• func Init(sourceID string, targetURL string)
• func InitEventSender(clientProvider httptools.HTTPClientProvider, ...)
• func SendEvent(req *api.SendEventParameters, traceHeaders *map[string]string, ...) (*api.SendEventResponse, error)

Functions

func AddSource

func AddSource(parameters *api.PublishEventParameters) (resp *api.SendEventParameters, err error)

AddSource adds the "source" related data to the incoming request

func Init

func Init(sourceID string, targetURL string)

Init should be used to initialize the "source" related configuration data

func InitEventSender

func InitEventSender(clientProvider httptools.HTTPClientProvider, requestProvider httptools.HTTPRequestProvider)

InitEventSender initializes an internal httpClientProvider and httpRequestProvider

func SendEvent

func SendEvent(req *api.SendEventParameters, traceHeaders *map[string]string,
	forwardHeaders *map[string][]string) (*api.SendEventResponse, error)

SendEvent sends the incoming request to the Sender