pluginaws

Documentation

Index

• Constants
• func NewS3Config() (*aws.Config, error)
• func NewSession() (*session.Session, error)
• type CustomRetryer
  • func (r CustomRetryer) MaxRetries() int
  • func (r CustomRetryer) RetryRules(req *request.Request) time.Duration
  • func (r CustomRetryer) ShouldRetry(req *request.Request) bool
• 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 CustomRetryer

type CustomRetryer struct {
	client.DefaultRetryer
}

func (CustomRetryer) MaxRetries

func (r CustomRetryer) MaxRetries() int

func (CustomRetryer) RetryRules

func (r CustomRetryer) RetryRules(req *request.Request) time.Duration

func (CustomRetryer) ShouldRetry

func (r CustomRetryer) ShouldRetry(req *request.Request) bool

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