config

type BufferConfiguration struct {
	OnFullStrategy        *buffer.OnFullStrategy `yaml:"onFullStrategy"`
	MaxBufferSize         *int                   `yaml:"maxBufferSize"`
	MaxMessageSize        *int                   `yaml:"maxMessageSize"`
	CloseCheckInterval    *time.Duration         `yaml:"closeCheckInterval"`
	DropOldestInterval    *time.Duration         `yaml:"dropOldestInterval"`
	ScanBatchSize         *int                   `yaml:"scanBatchSize"`
	AllowedSpilloverRatio *float64               `yaml:"allowedSpilloverRatio"`
	CleanupRetry          *retry.Configuration   `yaml:"cleanupRetry"`
}

type ConnectionConfiguration struct {
	NumConnections     *int                 `yaml:"numConnections"`
	DialTimeout        *time.Duration       `yaml:"dialTimeout"`
	WriteTimeout       *time.Duration       `yaml:"writeTimeout"`
	KeepAlivePeriod    *time.Duration       `yaml:"keepAlivePeriod"`
	ResetDelay         *time.Duration       `yaml:"resetDelay"`
	Retry              *retry.Configuration `yaml:"retry"`
	FlushInterval      *time.Duration       `yaml:"flushInterval"`
	WriteBufferSize    *int                 `yaml:"writeBufferSize"`
	ReadBufferSize     *int                 `yaml:"readBufferSize"`
	AbortOnServerClose *bool                `yaml:"abortOnServerClose"`
	ForcedFlushTimeout *time.Duration       `yaml:"forcedFlushTimeout"`
	// ContextDialer specifies a custom dialer to use when creating TCP connections to the consumer.
	// See writer.ConnectionOptions.ContextDialer for details.
	ContextDialer xnet.ContextDialerFn `yaml:"-"` // not serializable
}

type ProducerConfiguration struct {
	Buffer BufferConfiguration `yaml:"buffer"`
	Writer WriterConfiguration `yaml:"writer"`
}

type StaticMessageRetryConfiguration struct {
	Backoff []time.Duration `yaml:"backoff"`
}

type WriterConfiguration struct {
	TopicName                 string                         `yaml:"topicName" validate:"nonzero"`
	TopicServiceOverride      kv.OverrideConfiguration       `yaml:"topicServiceOverride"`
	TopicWatchInitTimeout     *time.Duration                 `yaml:"topicWatchInitTimeout"`
	PlacementOptions          placement.Configuration        `yaml:"placement"`
	PlacementServiceOverride  services.OverrideConfiguration `yaml:"placementServiceOverride"`
	PlacementWatchInitTimeout *time.Duration                 `yaml:"placementWatchInitTimeout"`
	// MessagePool configuration is deprecated for producer side.
	MessagePool                       *pool.ObjectPoolConfiguration `yaml:"messagePool"`
	MessageQueueNewWritesScanInterval *time.Duration                `yaml:"messageQueueNewWritesScanInterval"`
	MessageQueueFullScanInterval      *time.Duration                `yaml:"messageQueueFullScanInterval"`
	MessageQueueScanBatchSize         *int                          `yaml:"messageQueueScanBatchSize"`
	InitialAckMapSize                 *int                          `yaml:"initialAckMapSize"`
	CloseCheckInterval                *time.Duration                `yaml:"closeCheckInterval"`
	AckErrorRetry                     *retry.Configuration          `yaml:"ackErrorRetry"`
	Encoder                           *proto.Configuration          `yaml:"encoder"`
	Decoder                           *proto.Configuration          `yaml:"decoder"`
	Connection                        *ConnectionConfiguration      `yaml:"connection"`

	// StaticMessageRetry configs a static message retry policy.
	StaticMessageRetry *StaticMessageRetryConfiguration `yaml:"staticMessageRetry"`
	// MessageRetry configs a algorithmic retry policy.
	// Only one of the retry configuration should be used.
	MessageRetry *retry.Configuration `yaml:"messageRetry"`

	// IgnoreCutoffCutover allows producing writes ignoring cutoff/cutover timestamp.
	// Must be in sync with AggregatorConfiguration.WritesIgnoreCutoffCutover.
	IgnoreCutoffCutover bool `yaml:"ignoreCutoffCutover"`
	// WithoutConsumerScope drops the consumer tag from the metrics. For large m3msg deployments the consumer tag can
	// add a lot of cardinality to the metrics.
	WithoutConsumerScope bool `yaml:"withoutConsumerScope"`

	// MessageWriterGracefulCloseKVOverride configures KV override for the graceful close key.
	MessageWriterGracefulCloseKVOverride kv.OverrideConfiguration `yaml:"messageWriterGracefulCloseKVOverride"`
	// MessageWriterGracefulCloseKey is the KV key for message writer graceful close setting.
	// When false (default), writers will auto-ack messages on close for fast shutdown.
	// When true, writers will wait for messages to be sent and acknowledged before closing.
	MessageWriterGracefulCloseKey string `yaml:"messageWriterGracefulCloseKey"`
}