Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
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 ¶ added in v0.0.2
func (b *SNSBatcher) DeadLetter(ctx context.Context, message *dante_tpb.DeadMessage) error
Click to show internal directories.
Click to hide internal directories.