senders

Documentation

Index

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

Types

type BeanstalkdSender

type BeanstalkdSender struct {
	StatsdClient *statsd.Client
}

BeanstalkdSender - Send Event to beanstalkd

func (*BeanstalkdSender) SendEvent

func (c *BeanstalkdSender) SendEvent(ctx context.Context, ev interfaces.IncomingEventInterface, dv interfaces.DestinationInterface) (err error)

SendEvent - #BeanstalkdSender SendEvent

type ConsoleEventSender

type ConsoleEventSender struct{}

ConsoleEventSender - Present Event in console

func (*ConsoleEventSender) SendEvent

func (c *ConsoleEventSender) SendEvent(ctx context.Context, ev interfaces.IncomingEventInterface, dv interfaces.DestinationInterface) error

SendEvent - #ConsoleEventSender SendEvent

type HTTPEventSender

type HTTPEventSender struct{}

HTTPEventSender - Send Event through HTTP

func (*HTTPEventSender) SendEvent

func (c *HTTPEventSender) SendEvent(ctx context.Context, ev interfaces.IncomingEventInterface, dv interfaces.DestinationInterface) (err error)

type HTTPProxyEventSender

type HTTPProxyEventSender struct{}

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(ctx context.Context, ev interfaces.IncomingEventInterface, dv interfaces.DestinationInterface) (err error)

type SqsSender

type SqsSender struct {
	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(ctx context.Context, ev interfaces.IncomingEventInterface, dv interfaces.DestinationInterface) (err error)

SendEvent - Send incoming event into SQS queue