pluginaws

Documentation

Index

• Constants
• func NewS3Config() (*aws.Config, error)
• func NewSession() (*session.Session, error)
• type SqsClient
  • func NewSqsClient(logger *log.Logger) (*SqsClient, error)
  • func (sc *SqsClient) PublishToQueue(data []*types.Message) error

Constants

const (
	MaxAwsRequestLengthBytes = 262_144 // 256KB
	MaxSQSBatchSize          = 10
)

const (
	MaxMessageBodyLengthBytes = 100_00 // ~100KB
)

Functions

func NewS3Config

func NewS3Config() (*aws.Config, error)

func NewSession

func NewSession() (*session.Session, error)

Types

type SqsClient

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

func NewSqsClient

func NewSqsClient(logger *log.Logger) (*SqsClient, error)

func (*SqsClient) PublishToQueue

func (sc *SqsClient) PublishToQueue(data []*types.Message) error