senders

Documentation

Index

• type BeanstalkdSender
  • func (c *BeanstalkdSender) SendEvent(ev interfaces.IncomingEventInterface, dv interfaces.DestinationInterface) error
• type ConsoleEventSender
  • func (c *ConsoleEventSender) SendEvent(ev interfaces.IncomingEventInterface, dv interfaces.DestinationInterface) error
• type HTTPEventSender
  • func (c *HTTPEventSender) SendEvent(ev interfaces.IncomingEventInterface, dv interfaces.DestinationInterface) error
• type HTTPProxyEventSender
  • func (c *HTTPProxyEventSender) SendEvent(ev interfaces.IncomingEventInterface, dv interfaces.DestinationInterface) error
• type HTTPProxyResponse
• type HTTPResponse
• type SqsSender
  • func NewSqsSender(defaultAwsConfig aws.Config) *SqsSender
  • func (s *SqsSender) GetClient(dv interfaces.DestinationInterface) aws_sqsiface.SQSAPI
  • func (s *SqsSender) SendEvent(ev interfaces.IncomingEventInterface, dv interfaces.DestinationInterface) error

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

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

func (c *HTTPProxyEventSender) SendEvent(ev interfaces.IncomingEventInterface, dv interfaces.DestinationInterface) error

SendEvent - #HTTPProxyEventSender SendEvent

type HTTPProxyResponse

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

type SqsSender struct {
	interfaces.EventSenderInterface
	DefaultClient        aws_sqsiface.SQSAPI
	DestinationClientMap map[string]aws_sqsiface.SQSAPI
}

SqsSender - Send Event to AWS SQS

func NewSqsSender

func NewSqsSender(defaultAwsConfig aws.Config) *SqsSender

func (*SqsSender) GetClient

func (s *SqsSender) GetClient(dv interfaces.DestinationInterface) aws_sqsiface.SQSAPI

func (*SqsSender) SendEvent

func (s *SqsSender) SendEvent(ev interfaces.IncomingEventInterface, dv interfaces.DestinationInterface) error

SendEvent - Send incoming event into SQS queue