concurrencyCfg

Documentation

Index

• type ConcurrencyConfig
• type Config
  • func InitConfig(options ...Option) *Config
  • func NewDefaultConfig() *Config
• type Option
  • func WithConcurrencyChanNum(chanNum int) Option
  • func WithConcurrencyChanSize(chanSize int) Option
  • func WithConcurrencyFn(fn func(ctx context.Context, p define.Packet)) Option
  • func WithConcurrencySendChanTimeout(sendChanTimeout time.Duration) Option
  • func WithLogger(logger logger.LoggerInterface) Option

Types

type ConcurrencyConfig

type ConcurrencyConfig struct {
	SendChanTimeout time.Duration `json:"send_chan_timeout"`
	ChanSize        int           `json:"chan_size"`
	ChanNum         int           `json:"chan_num"`
}

type Config

type Config struct {
	Logger logger.LoggerInterface

	ConcurrencyFn     func(ctx context.Context, p define.Packet) `json:"-"`
	ConcurrencyConfig *ConcurrencyConfig                         `json:"concurrency_config"`
}

func InitConfig

func InitConfig(options ...Option) *Config

func NewDefaultConfig

func NewDefaultConfig() *Config

type Option

type Option func(c *Config)

func WithConcurrencyChanNum

func WithConcurrencyChanNum(chanNum int) Option

func WithConcurrencyChanSize

func WithConcurrencyChanSize(chanSize int) Option

func WithConcurrencyFn

func WithConcurrencyFn(fn func(ctx context.Context, p define.Packet)) Option

func WithConcurrencySendChanTimeout

func WithConcurrencySendChanTimeout(sendChanTimeout time.Duration) Option

func WithLogger

func WithLogger(logger logger.LoggerInterface) Option