Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BeanstalkdSender ¶
type BeanstalkdSender struct {
interfaces.EventSenderInterface
}
BeanstalkdSender - Send Event to beanstalkd
func (*BeanstalkdSender) SendEvent ¶
func (c *BeanstalkdSender) SendEvent(ev interfaces.IncomingEventInterface, dv interfaces.DestinationInterface) error
SendEvent - #BeanstalkdSender SendEvent
type ConsoleEventSender ¶
type ConsoleEventSender struct{}
ConsoleEventSender - Present Event in console
func (*ConsoleEventSender) SendEvent ¶
func (c *ConsoleEventSender) SendEvent(ev interfaces.IncomingEventInterface, dv interfaces.DestinationInterface) error
SendEvent - #ConsoleEventSender SendEvent
type HTTPEventSender ¶
type HTTPEventSender struct {
interfaces.EventSenderInterface
}
HTTPEventSender - Send Event through HTTP
func (*HTTPEventSender) SendEvent ¶
func (c *HTTPEventSender) SendEvent(ev interfaces.IncomingEventInterface, dv interfaces.DestinationInterface) error
SendEvent - #HttpEventSender SendEvent
type HTTPProxyEventSender ¶ added in v1.2.0
type HTTPProxyEventSender struct {
interfaces.EventSenderInterface
}
HTTPProxyEventSender - Send Event through HTTP with payload only Different from HTTPEventSender, which parses the whole event body in order to pass event meta data to destinations, HTTPProxyEventSender only parses payload for general usage of third party API calls.
func (*HTTPProxyEventSender) SendEvent ¶ added in v1.2.0
func (c *HTTPProxyEventSender) SendEvent(ev interfaces.IncomingEventInterface, dv interfaces.DestinationInterface) error
SendEvent - #HTTPProxyEventSender SendEvent
type HTTPProxyResponse ¶ added in v1.2.0
type HTTPProxyResponse struct {
// contains filtered or unexported fields
}
HTTPProxyResponse - HTTP Response
type HTTPResponse ¶
type HTTPResponse struct {
// contains filtered or unexported fields
}
HTTPResponse - HTTP Response
type SqsSender ¶ added in v1.2.0
type SqsSender struct {
interfaces.EventSenderInterface
DefaultClient aws_sqsiface.SQSAPI
DestinationClientMap map[string]aws_sqsiface.SQSAPI
}
SqsSender - Send Event to AWS SQS
func NewSqsSender ¶ added in v1.2.0
func (*SqsSender) GetClient ¶ added in v1.2.0
func (s *SqsSender) GetClient(dv interfaces.DestinationInterface) aws_sqsiface.SQSAPI
func (*SqsSender) SendEvent ¶ added in v1.2.0
func (s *SqsSender) SendEvent(ev interfaces.IncomingEventInterface, dv interfaces.DestinationInterface) error
SendEvent - Send incoming event into SQS queue
Source Files