jobutils

Documentation

Index

• func WaitByChan(f func()) chan struct{}
• type JobGroup
  • func NewJobGroup(tokens int, enterTimeout time.Duration) *JobGroup
  • func (group *JobGroup) Enter(ctx context.Context) bool
  • func (group *JobGroup) EnterPro(ctx context.Context, enterTimeout time.Duration) bool
  • func (group *JobGroup) Exit()
  • func (group *JobGroup) Tokens() JobTokens
  • func (group *JobGroup) Wait()
• type JobTokens
  • func NewJobTokens(n int) JobTokens
  • func (tokens JobTokens) Acquire(ctx context.Context, timeout time.Duration) bool
  • func (tokens JobTokens) Lefts() int
  • func (tokens JobTokens) Release()
  • func (tokens JobTokens) Totals() int
  • func (tokens JobTokens) Useds() int
• type SmartHandler
  • func (handler *SmartHandler) Call()
  • func (handler *SmartHandler) Dup() *SmartHandler
  • func (handler *SmartHandler) WithAsync(async bool) *SmartHandler
  • func (handler *SmartHandler) WithConcurrentcy(n int) *SmartHandler
  • func (handler *SmartHandler) WithCtx(ctx context.Context) *SmartHandler
  • func (handler *SmartHandler) WithDeadline(deadline time.Duration) *SmartHandler
  • func (handler *SmartHandler) WithDelay(delay time.Duration) *SmartHandler
  • func (handler *SmartHandler) WithIdent(ident string) *SmartHandler
  • func (handler *SmartHandler) WithInterval(interval time.Duration) *SmartHandler
  • func (handler *SmartHandler) WithMerge(merge bool) *SmartHandler
• type SmartHandlerPtr
• type SmartHandlers
  • func (handlers SmartHandlers) Append(more ...*SmartHandler) SmartHandlers
  • func (handlers SmartHandlers) Call()
  • func (handlers SmartHandlers) Purge(f func(*SmartHandler) bool) SmartHandlers
  • func (handlers SmartHandlers) PurgeByIdent(ident string) SmartHandlers
• type SmartHandlersMappingByString
• type TopicBroker
  • func NewTopicBroker() *TopicBroker
  • func (broker *TopicBroker) Publish(topic string)
  • func (broker *TopicBroker) Subscribe(topic string, callback func()) *TopicBrokerSubscribing
  • func (broker *TopicBroker) Unsubscribe(topic string)
  • func (broker *TopicBroker) UnsubscribeByIdent(topic string, ident string)
• type TopicBrokerSubscribing
  • func (subscribing *TopicBrokerSubscribing) Done() *TopicBroker
  • func (subscribing *TopicBrokerSubscribing) WithAsync(async bool) *TopicBrokerSubscribing
  • func (subscribing *TopicBrokerSubscribing) WithConcurrentcy(n int) *TopicBrokerSubscribing
  • func (subscribing *TopicBrokerSubscribing) WithCtx(ctx context.Context) *TopicBrokerSubscribing
  • func (subscribing *TopicBrokerSubscribing) WithDeadline(deadline time.Duration) *TopicBrokerSubscribing
  • func (subscribing *TopicBrokerSubscribing) WithDelay(delay time.Duration) *TopicBrokerSubscribing
  • func (subscribing *TopicBrokerSubscribing) WithIdent(ident string) *TopicBrokerSubscribing
  • func (subscribing *TopicBrokerSubscribing) WithInterval(interval time.Duration) *TopicBrokerSubscribing
  • func (subscribing *TopicBrokerSubscribing) WithMerge(merge bool) *TopicBrokerSubscribing

Functions

func WaitByChan

func WaitByChan(f func()) chan struct{}

Types

type JobGroup

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

func NewJobGroup

func NewJobGroup(tokens int, enterTimeout time.Duration) *JobGroup

func (*JobGroup) Enter

func (group *JobGroup) Enter(ctx context.Context) bool

func (*JobGroup) EnterPro

func (group *JobGroup) EnterPro(ctx context.Context, enterTimeout time.Duration) bool

func (*JobGroup) Exit

func (group *JobGroup) Exit()

func (*JobGroup) Tokens

func (group *JobGroup) Tokens() JobTokens

func (*JobGroup) Wait

func (group *JobGroup) Wait()

type JobTokens

type JobTokens chan struct{}

func NewJobTokens

func NewJobTokens(n int) JobTokens

func (JobTokens) Acquire

func (tokens JobTokens) Acquire(ctx context.Context, timeout time.Duration) bool

func (JobTokens) Lefts

func (tokens JobTokens) Lefts() int

func (JobTokens) Release

func (tokens JobTokens) Release()

func (JobTokens) Totals

func (tokens JobTokens) Totals() int

func (JobTokens) Useds

func (tokens JobTokens) Useds() int

type SmartHandler

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

func (*SmartHandler) Call

func (handler *SmartHandler) Call()

func (*SmartHandler) Dup

func (handler *SmartHandler) Dup() *SmartHandler

func (*SmartHandler) WithAsync

func (handler *SmartHandler) WithAsync(async bool) *SmartHandler

func (*SmartHandler) WithConcurrentcy

func (handler *SmartHandler) WithConcurrentcy(n int) *SmartHandler

func (*SmartHandler) WithCtx

func (handler *SmartHandler) WithCtx(ctx context.Context) *SmartHandler

func (*SmartHandler) WithDeadline

func (handler *SmartHandler) WithDeadline(deadline time.Duration) *SmartHandler

func (*SmartHandler) WithDelay

func (handler *SmartHandler) WithDelay(delay time.Duration) *SmartHandler

func (*SmartHandler) WithIdent

func (handler *SmartHandler) WithIdent(ident string) *SmartHandler

func (*SmartHandler) WithInterval

func (handler *SmartHandler) WithInterval(interval time.Duration) *SmartHandler

func (*SmartHandler) WithMerge

func (handler *SmartHandler) WithMerge(merge bool) *SmartHandler

type SmartHandlerPtr

type SmartHandlerPtr = *SmartHandler

type SmartHandlers

type SmartHandlers []*SmartHandler

func (SmartHandlers) Append

func (handlers SmartHandlers) Append(more ...*SmartHandler) SmartHandlers

func (SmartHandlers) Call

func (handlers SmartHandlers) Call()

func (SmartHandlers) Purge

func (handlers SmartHandlers) Purge(f func(*SmartHandler) bool) SmartHandlers

func (SmartHandlers) PurgeByIdent

func (handlers SmartHandlers) PurgeByIdent(ident string) SmartHandlers

type SmartHandlersMappingByString

type SmartHandlersMappingByString map[string]SmartHandlers

type TopicBroker

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

func NewTopicBroker

func NewTopicBroker() *TopicBroker

func (*TopicBroker) Publish

func (broker *TopicBroker) Publish(topic string)

func (*TopicBroker) Subscribe

func (broker *TopicBroker) Subscribe(topic string, callback func()) *TopicBrokerSubscribing

func (*TopicBroker) Unsubscribe

func (broker *TopicBroker) Unsubscribe(topic string)

func (*TopicBroker) UnsubscribeByIdent

func (broker *TopicBroker) UnsubscribeByIdent(topic string, ident string)

type TopicBrokerSubscribing

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

func (*TopicBrokerSubscribing) Done

func (subscribing *TopicBrokerSubscribing) Done() *TopicBroker

func (*TopicBrokerSubscribing) WithAsync

func (subscribing *TopicBrokerSubscribing) WithAsync(async bool) *TopicBrokerSubscribing

func (*TopicBrokerSubscribing) WithConcurrentcy

func (subscribing *TopicBrokerSubscribing) WithConcurrentcy(n int) *TopicBrokerSubscribing

func (*TopicBrokerSubscribing) WithCtx

func (subscribing *TopicBrokerSubscribing) WithCtx(ctx context.Context) *TopicBrokerSubscribing

func (*TopicBrokerSubscribing) WithDeadline

func (subscribing *TopicBrokerSubscribing) WithDeadline(deadline time.Duration) *TopicBrokerSubscribing

func (*TopicBrokerSubscribing) WithDelay

func (subscribing *TopicBrokerSubscribing) WithDelay(delay time.Duration) *TopicBrokerSubscribing

func (*TopicBrokerSubscribing) WithIdent

func (subscribing *TopicBrokerSubscribing) WithIdent(ident string) *TopicBrokerSubscribing

func (*TopicBrokerSubscribing) WithInterval

func (subscribing *TopicBrokerSubscribing) WithInterval(interval time.Duration) *TopicBrokerSubscribing

func (*TopicBrokerSubscribing) WithMerge

func (subscribing *TopicBrokerSubscribing) WithMerge(merge bool) *TopicBrokerSubscribing