subscriberconfig

Documentation

Overview

Package subscriberconfig owns subscriber defaults and validation shared by the runtime registry and persistence layer.

Index

• Constants
• type Options
  • func Normalize(options Options) Options
• type Parsed
  • func Parse(options Options) (Parsed, error)
• type RetryPolicy

Constants

const (
	MaximumDeliveryLease = 12 * time.Hour
)

Types

type Options

type Options struct {
	MaxAttempts        int
	VisibilityDuration string
	DequeueBatchSize   int
	RetryPolicy        RetryPolicy
}

func Normalize

func Normalize(options Options) Options

type Parsed

type Parsed struct {
	MaxAttempts        int
	VisibilityDuration time.Duration
	DequeueBatchSize   int
	RetryInitialDelay  time.Duration
	RetryMaxDelay      time.Duration
	RetryMultiplier    float64
	RetryJitter        float64
}

func Parse

func Parse(options Options) (Parsed, error)

type RetryPolicy

type RetryPolicy struct {
	InitialDelay  string
	MaxDelay      string
	Multiplier    float64
	Jitter        float64
	DisableJitter bool
}