broker

Documentation

Index

• type Config
• type Event
• type MemoryBroker
  • func NewMemoryBroker() (*MemoryBroker, error)
  • func (mb *MemoryBroker) SendEvent(event Event) error
• type NoneBroker
  • func NewNoneBroker() *NoneBroker
  • func (n *NoneBroker) Close()
  • func (n *NoneBroker) SendEvent(event Event) error
• type RabbitMQClient
  • func NewRabbitMqClient(cfg Config) (*RabbitMQClient, error)
  • func (mq *RabbitMQClient) Close()
  • func (mq *RabbitMQClient) SendEvent(event Event) error
• type SQSClient
  • func NewSQSClient(cfg Config, region string) (*SQSClient, error)
  • func (svc *SQSClient) Close()
  • func (svc *SQSClient) SendEvent(event Event) error

Types

type Config

type Config = config.BrokerConfig

type Event

type Event = models.Event

type MemoryBroker

type MemoryBroker struct {
	Events map[string][]Event
}

func NewMemoryBroker

func NewMemoryBroker() (*MemoryBroker, error)

func (*MemoryBroker) SendEvent

func (mb *MemoryBroker) SendEvent(event Event) error

type NoneBroker

type NoneBroker struct{}

func NewNoneBroker

func NewNoneBroker() *NoneBroker

func (*NoneBroker) Close

func (n *NoneBroker) Close()

func (*NoneBroker) SendEvent

func (n *NoneBroker) SendEvent(event Event) error

type RabbitMQClient

type RabbitMQClient struct {
	// contains filtered or unexported fields
}

func NewRabbitMqClient

func NewRabbitMqClient(cfg Config) (*RabbitMQClient, error)

func (*RabbitMQClient) Close

func (mq *RabbitMQClient) Close()

func (*RabbitMQClient) SendEvent

func (mq *RabbitMQClient) SendEvent(event Event) error

type SQSClient

type SQSClient struct {
	// contains filtered or unexported fields
}

func NewSQSClient

func NewSQSClient(cfg Config, region string) (*SQSClient, error)

func (*SQSClient) Close

func (svc *SQSClient) Close()

Don't do anything, just keep compatibility.

func (*SQSClient) SendEvent

func (svc *SQSClient) SendEvent(event Event) error