Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

processor

package

Go to main page

Versions in this module

v0

v0.4.6

Jul 23, 2024

Changes in this version

+ const MetricsEventPersisterName

+ var ErrInvalidDuration = errors.New("metricsevent persister: invalid duration")

+ var ErrUnknownApiId = errors.New("metricsevent persister: unknown api id")

+ var ErrUnknownEvent = errors.New("metricsevent persister: unknown metrics event")

+ func NewMetricsEventPersister(registerer metrics.Registerer, logger *zap.Logger) subscriber.Processor

v0.4.5

Jun 13, 2024

Changes in this version

+ const AuditLogPersisterName

+ const EvaluationCountEventDWHPersisterName

+ const EvaluationCountEventOPSPersisterName

+ const GoalCountEventDWHPersisterName

+ const GoalCountEventOPSPersisterName

+ const PushSenderName

+ var ErrAutoOpsRuleNotFound = errors.New("eventpersister: auto ops rule not found")

+ var ErrEvaluationCountInvalidConfig = errors.New("evaluation count: invalid config")

+ var ErrEvaluationEventIssuedAfterExperimentEnded = errors.New("eventpersister: evaluation event issued after experiment ended")

+ var ErrEvaluationsAreEmpty = errors.New("eventpersister: evaluations are empty")

+ var ErrEventsDWHPersisterInvalidConfig = errors.New("eventpersister: invalid config")

+ var ErrEventsOPSPersisterInvalidConfig = errors.New("eventpersister: invalid config")

+ var ErrFailedToEvaluateUser = errors.New("eventpersister: failed to evaluate user")

+ var ErrFeatureEmptyList = errors.New("eventpersister: list feature returned empty")

+ var ErrFeatureVersionNotFound = errors.New("eventpersister: feature version not found")

+ var ErrSegmentExceededMaxUserIDLength = fmt.Errorf("segment: max user id length allowed is %d", maxUserIDLength)

+ var ErrSegmentInUse = errors.New("segment: segment is in use")

+ var ErrSegmentInvalidConfig = errors.New("segment: invalid config")

+ var ErrUserEventInvalidConfig = errors.New("user event: invalid config")

+ func NewAuditLogPersister(config interface{}, mysqlClient mysql.Client, logger *zap.Logger) (subscriber.Processor, error)

+ func NewEventsDWHPersister(ctx context.Context, config interface{}, mysqlClient mysql.Client, ...) (subscriber.Processor, error)

+ func NewEventsOPSPersister(ctx context.Context, config interface{}, mysqlClient mysql.Client, ...) (subscriber.Processor, error)

+ func NewPushSender(pushClient pushclient.Client, featureClient featureclient.Client, ...) subscriber.Processor

+ type Updater interface

+ UpdateUserCounts func(ctx context.Context, events environmentEventOPSMap) map[string]bool

+ func NewEvalUserCountUpdater(ctx context.Context, featureClient featureclient.Client, ...) Updater

+ func NewGoalUserCountUpdater(ctx context.Context, featureClient featureclient.Client, ...) Updater

+ type Writer interface

+ Write func(ctx context.Context, evt environmentEventDWHMap) map[string]bool

+ func NewEvalEventWriter(ctx context.Context, l *zap.Logger, exClient ec.Client, ...) (Writer, error)

+ func NewGoalEventWriter(ctx context.Context, l *zap.Logger, exClient ec.Client, ftClient ft.Client, ...) (Writer, error)

v0.4.4

May 31, 2024

v0.4.3

May 31, 2024

v0.4.2

May 29, 2024

v0.4.1

May 29, 2024

Changes in this version

+ const DomainEventInformerName

+ const EvaluationCountEventPersisterName

+ const SegmentUserPersisterName

+ const UserEventPersisterName

+ var ErrAutoOpsRulesNotFound = errors.New("eventpersister: auto ops rules not found")

+ var ErrExperimentNotFound = errors.New("eventpersister: experiment not found")

+ var ErrNoAutoOpsRules = errors.New("eventpersister: no auto ops rules")

+ var ErrNoExperiments = errors.New("eventpersister: no experiments")

+ var ErrNothingToLink = errors.New("eventpersister: nothing to link")

+ var ErrReasonNil = errors.New("eventpersister: reason is nil")

+ var ErrUnexpectedMessageType = errors.New("eventpersister: unexpected message type")

+ var ErrUnknownSourceType = errors.New("batch-server: domain-event-informer unknown source type")

+ func NewDomainEventInformer(environmentClient environmentclient.Client, sender sender.Sender, ...) subscriber.Processor

+ func NewEvaluationCountEventPersister(ctx context.Context, config interface{}, mysqlClient mysql.Client, ...) (subscriber.Processor, error)

+ func NewSegmentUserPersister(config interface{}, batchClient btclient.Client, mysqlClient mysql.Client, ...) (subscriber.Processor, error)

+ func NewUserEventPersister(config interface{}, mysqlClient mysql.Client, logger *zap.Logger) (subscriber.Processor, error)

+ type EvaluationCountEventPersisterConfig struct

+ FlushInterval int

+ FlushSize int

+ WriteCacheInterval int

+ type Processors struct

+ func NewProcessors(r metrics.Registerer) *Processors

+ func (p *Processors) GetProcessorByName(name string) (subscriber.Processor, error)

+ func (p *Processors) RegisterProcessor(name string, processor subscriber.Processor)