config

package

v1.0.1 Latest Latest Go to latest Published: Apr 24, 2024 License: Apache-2.0 Imports: 3 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/alibaba/schedulerx-worker-go

Links

Open Source Insights

Documentation ¶

Index ¶

func InitWorkerConfig(cfg *WorkerConfig)
type Option
type WorkerConfig
- func GetWorkerConfig() *WorkerConfig
- func NewWorkerConfig(opts ...Option) *WorkerConfig

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func InitWorkerConfig ¶

func InitWorkerConfig(cfg *WorkerConfig)

Types ¶

type Option ¶

type Option func(*WorkerConfig)

func WithBroadcastDispatchRetryTimes ¶ added in v0.0.2

func WithBroadcastDispatchRetryTimes(broadcastDispatchRetryTimes int32) Option

func WithDisableBroadcastMasterExec ¶ added in v0.0.2

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 ¶ added in v1.0.0

func WithGrpcPort(port int32) Option

func WithIface ¶ added in v1.0.0

func WithIface(iface 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 ¶ added in v0.0.2

func WithMapMasterStatusCheckInterval(mapMasterStatusCheckInterval time.Duration) Option

func WithQueueSize ¶ added in v1.0.1

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 ¶ added in v0.0.2

func (w *WorkerConfig) BroadcastDispatchRetryTimes() int32

func (*WorkerConfig) BroadcastMasterExecEnable ¶ added in v0.0.2

func (w *WorkerConfig) BroadcastMasterExecEnable() bool

func (*WorkerConfig) GrpcPort ¶ added in v1.0.0

func (w *WorkerConfig) GrpcPort() int32

func (*WorkerConfig) Iface ¶ added in v1.0.0

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) 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 ¶ added in v0.0.2

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

func (*WorkerConfig) QueueSize ¶ added in v1.0.1

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

Source Files ¶

View all Source files

worker_config.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL