carrier

type Config struct {
	Boat struct {
		NamePrefix string        `mapstructure:"name-prefix"`
		AckWait    time.Duration `mapstructure:"ack-wait"`
	}
	Consumer struct {
		Concurrency      int
		Topic            string
		RetryTopic       string        `mapstructure:"retry-topic"`
		RetryConcurrency int           `mapstructure:"retry-concurrency"`
		RetryDelay       time.Duration `mapstructure:"retry-delay"`
		MaxRetries       int64         `mapstructure:"max-retries"`
		DLQTopic         string        `mapstructure:"dlq-topic"`
	}
	Platform struct {
		Names            []string
		MaxOfflineCounts map[string]int `mapstructure:"max-offline-counts"`
	}
	Offline struct {
		BatchCount int64 `mapstructure:"batch-count"`
		Expire     time.Duration
	}
	// contains filtered or unexported fields
}