outbox

Documentation

Index

• func Listen(ctx context.Context, url string, callback Batcher) error
• type Batcher
• type Message
• type SNSAPI
• type SNSBatcher
  • func NewSNSBatcher(client SNSAPI, prefix string) *SNSBatcher
  • func (b *SNSBatcher) DeadLetter(ctx context.Context, message *dante_tpb.DeadMessage) error
  • func (b *SNSBatcher) SendBatch(ctx context.Context, destination string, msgs []*Message) error

Functions

func Listen

func Listen(ctx context.Context, url string, callback Batcher) error

Types

type Batcher

type Batcher interface {
	SendBatch(ctx context.Context, destination string, messages []*Message) error
}

type Message

type Message struct {
	ID      string
	Message []byte
	Headers map[string][]string
}

type SNSAPI

type SNSAPI interface {
	PublishBatch(ctx context.Context, params *sns.PublishBatchInput, optFns ...func(*sns.Options)) (*sns.PublishBatchOutput, error)
	Publish(ctx context.Context, params *sns.PublishInput, optFns ...func(*sns.Options)) (*sns.PublishOutput, error)
}

type SNSBatcher

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

func NewSNSBatcher

func NewSNSBatcher(client SNSAPI, prefix string) *SNSBatcher

func (*SNSBatcher) DeadLetter

func (b *SNSBatcher) DeadLetter(ctx context.Context, message *dante_tpb.DeadMessage) error

func (*SNSBatcher) SendBatch

func (b *SNSBatcher) SendBatch(ctx context.Context, destination string, msgs []*Message) error