option

Documentation

Index

• type Option
  • func WithLogger(logger *log.Logger) *Option
  • func WithMaxIdleWorkerDuration(maxIdleWorkerDuration time.Duration) *Option
  • func WithMaxWorkCount(maxWorkCount int) *Option
  • func WithTimeout(timeout time.Duration) *Option
• type PiplineWorkingOption
  • func DefaultOption() *PiplineWorkingOption
  • func (o *PiplineWorkingOption) GetLogger() *log.Logger
  • func (o *PiplineWorkingOption) GetMaxIdleWorkerDuration() time.Duration
  • func (o *PiplineWorkingOption) GetMaxWorkCount() int
  • func (o *PiplineWorkingOption) GetTimeOutDuration() time.Duration

Types

type Option

type Option struct {
	Apply func(option *PiplineWorkingOption)
}

Option 选项

func WithLogger

func WithLogger(logger *log.Logger) *Option

WithLogger 设置日志

func WithMaxIdleWorkerDuration

func WithMaxIdleWorkerDuration(maxIdleWorkerDuration time.Duration) *Option

WithMaxIdleWorkerDuration 设置最大的空闲时间

func WithMaxWorkCount

func WithMaxWorkCount(maxWorkCount int) *Option

WithMaxWorkCount 设置最大的工作数量

func WithTimeout

func WithTimeout(timeout time.Duration) *Option

WithTimeout 设置超时时间

type PiplineWorkingOption

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

PiplineWorkingOption 工作池配置

func DefaultOption

func DefaultOption() *PiplineWorkingOption

DefaultOption 获取默认配置

func (*PiplineWorkingOption) GetLogger

func (o *PiplineWorkingOption) GetLogger() *log.Logger

GetLogger 获取日志

func (*PiplineWorkingOption) GetMaxIdleWorkerDuration

func (o *PiplineWorkingOption) GetMaxIdleWorkerDuration() time.Duration

GetMaxIdleWorkerDuration 获取最大的空闲时间

func (*PiplineWorkingOption) GetMaxWorkCount

func (o *PiplineWorkingOption) GetMaxWorkCount() int

GetMaxWorkCount 获取最大的工作数量

func (*PiplineWorkingOption) GetTimeOutDuration

func (o *PiplineWorkingOption) GetTimeOutDuration() time.Duration

GetTimeOutDuration 获取超时时间