pkg

Dec 24, 2025

Changes in this version

+ func IsRetryableError(err error) bool

+ func NewClient() (kubernetes.Interface, *rest.Config, error)

+ func NewClientWithConfig(kubeConfig []byte) (kubernetes.Interface, *rest.Config, error)

+ func RunConsumer(rootCtx context.Context, config *v1.Config) error

+ func RunConsumerWithCallbacks(rootCtx context.Context, config *v1.Config, callbacks *ConsumerCallbacks) error

+ type Arn struct

+ Account string

+ Endpoint string

+ Partition string

+ Region string

+ Resource string

+ Service string

+ func ParseArn(s string) (Arn, error)

+ func (arn Arn) ToQueueURL() string

+ type ConsumerCallbacks struct

+ OnConnectionChange func(state string)

+ OnMessageFailed func(err error)

+ OnMessageProcessed func()

+ OnMessageRetried func()

+ type RetryCache struct

+ func NewRetryCache() *RetryCache

+ func (rc *RetryCache) GetBackoff(ctx context.Context, messageID string, retry *v1.Retry) *time.Duration

+ func (rc *RetryCache) Remove(ctx context.Context, messageID string)

+ type RetryItem struct

+ Count int

+ LastAttempt time.Time