pkg

type Arn struct {
	Partition string
	Service   string
	Region    string
	Account   string
	Resource  string
	Endpoint  string
}

type ConsumerCallbacks struct {
	OnMessageProcessed func()
	OnMessageFailed    func(err error)
	OnMessageRetried   func()
	OnConnectionChange func(state string)
}

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

type RetryItem struct {
	LastAttempt time.Time
	Count       int
}