asyncworkflow

Documentation

Index

• type ConsumerManager
  • func NewConsumerManager(logger log.Logger, metricsClient metrics.Client, domainCache cache.DomainCache, ...) *ConsumerManager
  • func (c *ConsumerManager) Start()
  • func (c *ConsumerManager) Stop()
• type ConsumerManagerOptions
  • func WithEmitConsumerCountMetrifFn(fn func(int)) ConsumerManagerOptions
  • func WithEnabledPropertyFn(enabledFn dynamicconfig.BoolPropertyFn) ConsumerManagerOptions
  • func WithRefreshInterval(interval time.Duration) ConsumerManagerOptions
  • func WithTimeSource(timeSrc clock.TimeSource) ConsumerManagerOptions

Types

type ConsumerManager

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

func NewConsumerManager

func NewConsumerManager(
	logger log.Logger,
	metricsClient metrics.Client,
	domainCache cache.DomainCache,
	queueProvider queue.Provider,
	frontendClient frontend.Client,
	options ...ConsumerManagerOptions,
) *ConsumerManager

func (*ConsumerManager) Start

func (c *ConsumerManager) Start()

func (*ConsumerManager) Stop

func (c *ConsumerManager) Stop()

type ConsumerManagerOptions

type ConsumerManagerOptions func(*ConsumerManager)

func WithEmitConsumerCountMetrifFn

func WithEmitConsumerCountMetrifFn(fn func(int)) ConsumerManagerOptions

func WithEnabledPropertyFn

func WithEnabledPropertyFn(enabledFn dynamicconfig.BoolPropertyFn) ConsumerManagerOptions

func WithRefreshInterval

func WithRefreshInterval(interval time.Duration) ConsumerManagerOptions

func WithTimeSource

func WithTimeSource(timeSrc clock.TimeSource) ConsumerManagerOptions