gaws

Documentation

Index

• Variables
• type GlueSchemaRegistry
  • func (g GlueSchemaRegistry) GetBaseLocation() string
  • func (g GlueSchemaRegistry) GetSchemaDefinition(schemaName string, version int) (string, error)
  • func (g GlueSchemaRegistry) IsUsingLatestSchema() bool
• type SnsSqsConfig
  • func (c SnsSqsConfig) GetFailedPollingBackoff() time.Duration
  • func (c SnsSqsConfig) GetMaxBatchPollingRetries() int
  • func (c SnsSqsConfig) GetMaxNumberOfMessagesPolled() int32
  • func (c SnsSqsConfig) GetVisibilityTimeout() int32
  • func (c SnsSqsConfig) GetWaitTimeSeconds() int32

Variables

var ErrCannotUnmarshalSnsMessage = errors.New("gluon: Cannot unmarshal AWS SNS message")

Types

type GlueSchemaRegistry

type GlueSchemaRegistry struct {
	Client           *glue.Client
	RegistryName     string
	UseLatestVersion bool
}

func (GlueSchemaRegistry) GetBaseLocation

func (g GlueSchemaRegistry) GetBaseLocation() string

func (GlueSchemaRegistry) GetSchemaDefinition

func (g GlueSchemaRegistry) GetSchemaDefinition(schemaName string, version int) (string, error)

func (GlueSchemaRegistry) IsUsingLatestSchema

func (g GlueSchemaRegistry) IsUsingLatestSchema() bool

type SnsSqsConfig

type SnsSqsConfig struct {
	AwsConfig                 aws.Config
	AccountID                 string
	SnsClient                 *sns.Client
	SqsClient                 *sqs.Client
	CustomSqsEndpoint         string
	MaxNumberOfMessagesPolled int32
	VisibilityTimeout         int32
	WaitTimeSeconds           int32
	MaxBatchPollingRetries    int
	FailedPollingBackoff      time.Duration
}

func (SnsSqsConfig) GetFailedPollingBackoff

func (c SnsSqsConfig) GetFailedPollingBackoff() time.Duration

func (SnsSqsConfig) GetMaxBatchPollingRetries

func (c SnsSqsConfig) GetMaxBatchPollingRetries() int

func (SnsSqsConfig) GetMaxNumberOfMessagesPolled

func (c SnsSqsConfig) GetMaxNumberOfMessagesPolled() int32

func (SnsSqsConfig) GetVisibilityTimeout

func (c SnsSqsConfig) GetVisibilityTimeout() int32

func (SnsSqsConfig) GetWaitTimeSeconds

func (c SnsSqsConfig) GetWaitTimeSeconds() int32