config

Documentation

Index

• func InitWorkerConfig(cfg *WorkerConfig)
• type Option
  • func WithBroadcastDispatchRetryTimes(broadcastDispatchRetryTimes int32) Option
  • func WithDisableBroadcastMasterExec() Option
  • func WithDisableMapMasterFailover() Option
  • func WithEnableDispatchSecondDelayStandalone() Option
  • func WithEnableSecondDelayIntervalMS() Option
  • func WithEnableShareContainerPool() Option
  • func WithGrpcPort(port int32) Option
  • func WithIface(iface string) Option
  • func WithLabel(label string) Option
  • func WithMapMasterDispatcherSize(mapMasterDispatcherSize int32) Option
  • func WithMapMasterPageSize(mapMasterPageSize int32) Option
  • func WithMapMasterQueueSize(mapMasterQueueSize int32) Option
  • func WithMapMasterStatusCheckInterval(mapMasterStatusCheckInterval time.Duration) Option
  • func WithQueueSize(queueSize int32) Option
  • func WithSharePoolSize(sharePoolSize int32) Option
  • func WithTaskBodySizeMax(taskBodySizeMax int32) Option
  • func WithWorkerMapPageSize(workerMapPageSize int32) Option
  • func WithWorkerParallelTaskMaxSize(workerParallelTaskMaxSize int32) Option
• type WorkerConfig
  • func GetWorkerConfig() *WorkerConfig
  • func NewWorkerConfig(opts ...Option) *WorkerConfig
  • func (w *WorkerConfig) BroadcastDispatchRetryTimes() int32
  • func (w *WorkerConfig) BroadcastMasterExecEnable() bool
  • func (w *WorkerConfig) GrpcPort() int32
  • func (w *WorkerConfig) Iface() string
  • func (w *WorkerConfig) IsDispatchSecondDelayStandalone() bool
  • func (w *WorkerConfig) IsMapMasterFailover() bool
  • func (w *WorkerConfig) IsSecondDelayIntervalMS() bool
  • func (w *WorkerConfig) IsShareContainerPool() bool
  • func (w *WorkerConfig) Label() string
  • func (w *WorkerConfig) MapMasterDispatcherSize() int32
  • func (w *WorkerConfig) MapMasterPageSize() int32
  • func (w *WorkerConfig) MapMasterQueueSize() int32
  • func (w *WorkerConfig) MapMasterStatusCheckInterval() time.Duration
  • func (w *WorkerConfig) QueueSize() int32
  • func (w *WorkerConfig) SharePoolSize() int32
  • func (w *WorkerConfig) TaskBodySizeMax() int32
  • func (w *WorkerConfig) WorkerMapPageSize() int32
  • func (w *WorkerConfig) WorkerParallelTaskMaxSize() int32

Functions

func InitWorkerConfig

func InitWorkerConfig(cfg *WorkerConfig)

Types

type Option

type Option func(*WorkerConfig)

func WithBroadcastDispatchRetryTimes

func WithBroadcastDispatchRetryTimes(broadcastDispatchRetryTimes int32) Option

func WithDisableBroadcastMasterExec

func WithDisableBroadcastMasterExec() Option

func WithDisableMapMasterFailover

func WithDisableMapMasterFailover() Option

func WithEnableDispatchSecondDelayStandalone

func WithEnableDispatchSecondDelayStandalone() Option

func WithEnableSecondDelayIntervalMS

func WithEnableSecondDelayIntervalMS() Option

func WithEnableShareContainerPool

func WithEnableShareContainerPool() Option

func WithGrpcPort

func WithGrpcPort(port int32) Option

func WithIface

func WithIface(iface string) Option

func WithLabel

func WithLabel(label string) Option

func WithMapMasterDispatcherSize

func WithMapMasterDispatcherSize(mapMasterDispatcherSize int32) Option

func WithMapMasterPageSize

func WithMapMasterPageSize(mapMasterPageSize int32) Option

func WithMapMasterQueueSize

func WithMapMasterQueueSize(mapMasterQueueSize int32) Option

func WithMapMasterStatusCheckInterval

func WithMapMasterStatusCheckInterval(mapMasterStatusCheckInterval time.Duration) Option

func WithQueueSize

func WithQueueSize(queueSize int32) Option

func WithSharePoolSize

func WithSharePoolSize(sharePoolSize int32) Option

func WithTaskBodySizeMax

func WithTaskBodySizeMax(taskBodySizeMax int32) Option

func WithWorkerMapPageSize

func WithWorkerMapPageSize(workerMapPageSize int32) Option

func WithWorkerParallelTaskMaxSize

func WithWorkerParallelTaskMaxSize(workerParallelTaskMaxSize int32) Option

type WorkerConfig

type WorkerConfig struct {
	// contains filtered or unexported fields
}

func GetWorkerConfig

func GetWorkerConfig() *WorkerConfig

func NewWorkerConfig

func NewWorkerConfig(opts ...Option) *WorkerConfig

func (*WorkerConfig) BroadcastDispatchRetryTimes

func (w *WorkerConfig) BroadcastDispatchRetryTimes() int32

func (*WorkerConfig) BroadcastMasterExecEnable

func (w *WorkerConfig) BroadcastMasterExecEnable() bool

func (*WorkerConfig) GrpcPort

func (w *WorkerConfig) GrpcPort() int32

func (*WorkerConfig) Iface

func (w *WorkerConfig) Iface() string

func (*WorkerConfig) IsDispatchSecondDelayStandalone

func (w *WorkerConfig) IsDispatchSecondDelayStandalone() bool

func (*WorkerConfig) IsMapMasterFailover

func (w *WorkerConfig) IsMapMasterFailover() bool

func (*WorkerConfig) IsSecondDelayIntervalMS

func (w *WorkerConfig) IsSecondDelayIntervalMS() bool

func (*WorkerConfig) IsShareContainerPool

func (w *WorkerConfig) IsShareContainerPool() bool

func (*WorkerConfig) Label

func (w *WorkerConfig) Label() string

func (*WorkerConfig) MapMasterDispatcherSize

func (w *WorkerConfig) MapMasterDispatcherSize() int32

func (*WorkerConfig) MapMasterPageSize

func (w *WorkerConfig) MapMasterPageSize() int32

func (*WorkerConfig) MapMasterQueueSize

func (w *WorkerConfig) MapMasterQueueSize() int32

func (*WorkerConfig) MapMasterStatusCheckInterval

func (w *WorkerConfig) MapMasterStatusCheckInterval() time.Duration

func (*WorkerConfig) QueueSize

func (w *WorkerConfig) QueueSize() int32

func (*WorkerConfig) SharePoolSize

func (w *WorkerConfig) SharePoolSize() int32

func (*WorkerConfig) TaskBodySizeMax

func (w *WorkerConfig) TaskBodySizeMax() int32

func (*WorkerConfig) WorkerMapPageSize

func (w *WorkerConfig) WorkerMapPageSize() int32

func (*WorkerConfig) WorkerParallelTaskMaxSize

func (w *WorkerConfig) WorkerParallelTaskMaxSize() int32