poolCfg

Documentation

Index

• type Config
  • func InitConfig(options ...Option) *Config
  • func NewDefaultConfig() *Config
• type Option
  • func WithConnectorHandler(connectorHandler connector.Handler) Option
  • func WithDiscovery(discovery discovery.Discovery) Option
  • func WithLogger(logger logger.LoggerInterface) Option
  • func WithPoolChanSize(chanSize int) Option
  • func WithPoolSendChanTimeout(sendChanTimeout time.Duration) Option
• type PoolConfig

Types

type Config

type Config struct {
	Logger logger.LoggerInterface

	PoolConfig *PoolConfig `json:"pool_config"`
}

func InitConfig

func InitConfig(options ...Option) *Config

func NewDefaultConfig

func NewDefaultConfig() *Config

type Option

type Option func(c *Config)

func WithConnectorHandler

func WithConnectorHandler(connectorHandler connector.Handler) Option

func WithDiscovery

func WithDiscovery(discovery discovery.Discovery) Option

func WithLogger

func WithLogger(logger logger.LoggerInterface) Option

func WithPoolChanSize

func WithPoolChanSize(chanSize int) Option

func WithPoolSendChanTimeout

func WithPoolSendChanTimeout(sendChanTimeout time.Duration) Option

type PoolConfig

type PoolConfig struct {
	SendChanTimeout  time.Duration       `json:"send_chan_timeout"`
	ChanSize         int                 `json:"chan_size"`
	Discovery        discovery.Discovery `json:"-"`
	ConnectorHandler connector.Handler   `json:"-"`
}