congroup

README

congroup

Documentation

Index

• Constants
• type AddOpt
  • func AddOption() *AddOpt
  • func (o *AddOpt) GetLabel() string
  • func (o *AddOpt) SetLabel(l string) *AddOpt
• type ConGroup
  • func New(ctx context.Context, opts ...*NewOpt) *ConGroup
  • func (g *ConGroup) Add(h Handler, opts ...*AddOpt)
  • func (g *ConGroup) Wait() error
• type Handler
• type NewOpt
  • func NewOption() *NewOpt
  • func (o *NewOpt) GetMaxConcurrency() uint
  • func (o *NewOpt) SetMaxConcurrency(c uint) *NewOpt

Constants

const (
	DefaultConcurrency = 10
)

Types

type AddOpt

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

func AddOption

func AddOption() *AddOpt

func (*AddOpt) GetLabel

func (o *AddOpt) GetLabel() string

func (*AddOpt) SetLabel

func (o *AddOpt) SetLabel(l string) *AddOpt

SetLabel 对任务设置label，用于tracing时的区分

type ConGroup

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

func New

func New(ctx context.Context, opts ...*NewOpt) *ConGroup

func (*ConGroup) Add

func (g *ConGroup) Add(h Handler, opts ...*AddOpt)

func (*ConGroup) Wait

func (g *ConGroup) Wait() error

type Handler

type Handler func(context.Context) error

type NewOpt

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

func NewOption

func NewOption() *NewOpt

func (*NewOpt) GetMaxConcurrency

func (o *NewOpt) GetMaxConcurrency() uint

func (*NewOpt) SetMaxConcurrency

func (o *NewOpt) SetMaxConcurrency(c uint) *NewOpt

SetMaxConcurrency 设置执行handler时的最大并发数，大于0有效，默认DefaultConcurrency