processor

Documentation

Index

• Constants
• Variables
• 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
• type Processors
  • func NewProcessors(r metrics.Registerer) *Processors
  • func (p *Processors) GetProcessorByName(name string) (subscriber.Processor, error)
  • func (p *Processors) RegisterProcessor(name string, processor subscriber.Processor)

Constants

const (
	DomainEventInformerName           = "domainEventInformer"
	EvaluationCountEventPersisterName = "evaluationCountEventPersister"
	SegmentUserPersisterName          = "segmentUserPersister"
	UserEventPersisterName            = "userEventPersister"
)

Variables

var (
	ErrUnexpectedMessageType = errors.New("eventpersister: unexpected message type")
	ErrAutoOpsRulesNotFound  = errors.New("eventpersister: auto ops rules not found")
	ErrExperimentNotFound    = errors.New("eventpersister: experiment not found")
	ErrNoAutoOpsRules        = errors.New("eventpersister: no auto ops rules")
	ErrNoExperiments         = errors.New("eventpersister: no experiments")
	ErrNothingToLink         = errors.New("eventpersister: nothing to link")
	ErrReasonNil             = errors.New("eventpersister: reason is nil")
)

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

Functions

func NewDomainEventInformer

func NewDomainEventInformer(
	environmentClient environmentclient.Client,
	sender sender.Sender,
	logger *zap.Logger,
) subscriber.Processor

func NewEvaluationCountEventPersister

func NewEvaluationCountEventPersister(
	ctx context.Context,
	config interface{},
	mysqlClient mysql.Client,
	evaluationCountCacher cache.MultiGetDeleteCountCache,
	logger *zap.Logger,
) (subscriber.Processor, error)

func NewSegmentUserPersister

func NewSegmentUserPersister(
	config interface{},
	batchClient btclient.Client,
	mysqlClient mysql.Client,
	logger *zap.Logger,
) (subscriber.Processor, error)

func NewUserEventPersister

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

Types

type EvaluationCountEventPersisterConfig

type EvaluationCountEventPersisterConfig struct {
	FlushSize          int `json:"flushSize"`
	FlushInterval      int `json:"flushInterval"`
	WriteCacheInterval int `json:"writeCacheInterval"`
}

type Processors

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

func NewProcessors

func NewProcessors(r metrics.Registerer) *Processors

func (*Processors) GetProcessorByName

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

func (*Processors) RegisterProcessor

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