Documentation ¶
Index ¶
- Variables
- func NewPersister(updater Updater, mysqlClient mysql.Client, client *pubsub.Client, ...) *persister
- type Option
- func WithCheckInterval(interval time.Duration) Option
- func WithFlushInterval(i time.Duration) Option
- func WithFlushSize(s int) Option
- func WithFlushTimeout(timeout time.Duration) Option
- func WithLogger(l *zap.Logger) Option
- func WithMaxMPS(mps int) Option
- func WithMetrics(r metrics.Registerer) Option
- func WithNumWorkers(n int) Option
- type Updater
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrAutoOpsRuleNotFound = errors.New("eventpersister: auto ops rule not found") ErrFeatureEmptyList = errors.New("eventpersister: list feature returned empty") ErrFeatureVersionNotFound = errors.New("eventpersister: feature version not found") ErrNoExperiments = errors.New("eventpersister: no experiments") ErrNothingToLink = errors.New("eventpersister: nothing to link") ErrUnexpectedMessageType = errors.New("eventpersister: unexpected message type") )
Functions ¶
Types ¶
type Option ¶
type Option func(*options)
func WithCheckInterval ¶ added in v0.4.0
func WithFlushInterval ¶
func WithFlushSize ¶
func WithFlushTimeout ¶
func WithLogger ¶
func WithMaxMPS ¶
func WithMetrics ¶
func WithMetrics(r metrics.Registerer) Option
func WithNumWorkers ¶
type Updater ¶
type Updater interface {
UpdateUserCounts(ctx context.Context, events environmentEventMap) map[string]bool
}
func NewEvalUserCountUpdater ¶
func NewEvalUserCountUpdater( ctx context.Context, featureClient featureclient.Client, autoOpsClient aoclient.Client, eventCounterCache cachev3.EventCounterCache, autoOpsRulesCache cachev3.AutoOpsRulesCache, logger *zap.Logger, ) Updater
func NewGoalUserCountUpdater ¶
func NewGoalUserCountUpdater( ctx context.Context, featureClient featureclient.Client, autoOpsClient aoclient.Client, eventCounterCache cachev3.EventCounterCache, autoOpsRulesCache cachev3.AutoOpsRulesCache, logger *zap.Logger, ) Updater
Click to show internal directories.
Click to hide internal directories.