v2

Documentation

Index

• Constants
• Variables
• type EvaluationEventCount
• type EventStorage
  • func NewEventStorage(querier bqquerier.Client, dataset string, logger *zap.Logger) EventStorage
• type ExperimentResultStorage
  • func NewExperimentResultStorage(qe mysql.QueryExecer) ExperimentResultStorage
• type GoalEventCount
• type MAUSummaryStorage
  • func NewMAUSummaryStorage(qe mysql.QueryExecer) MAUSummaryStorage
• type UserCountStorage
  • func NewUserCountStorage(qe mysql.QueryExecer) UserCountStorage

Constants

const (
	DataTypeEvaluationEvent = "evaluation_event"
	DataTypeGoalEvent       = "goal_event"
	EvaluationCountSQLFile  = "sql/evaluation_count.sql"
	GoalCountSQLFile        = "sql/goal_count.sql"
)

Variables

var ErrExperimentResultNotFound = errors.New("experimentResult: experiment result not found")

Types

type EvaluationEventCount

type EvaluationEventCount struct {
	VariationID     string
	EvaluationUser  int64
	EvaluationTotal int64
}

type EventStorage

type EventStorage interface {
	QueryEvaluationCount(
		ctx context.Context,
		environmentId string,
		startAt, endAt time.Time,
		featureID string,
		featureVersion int32,
	) ([]*EvaluationEventCount, error)
	QueryGoalCount(
		ctx context.Context,
		environmentId string,
		startAt, endAt time.Time,
		goalID, featureID string,
		featureVersion int32,
	) ([]*GoalEventCount, error)
}

func NewEventStorage

func NewEventStorage(querier bqquerier.Client, dataset string, logger *zap.Logger) EventStorage

type ExperimentResultStorage

type ExperimentResultStorage interface {
	GetExperimentResult(ctx context.Context, id, environmentId string) (*domain.ExperimentResult, error)
}

func NewExperimentResultStorage

func NewExperimentResultStorage(qe mysql.QueryExecer) ExperimentResultStorage

type GoalEventCount

type GoalEventCount struct {
	VariationID       string
	GoalUser          int64
	GoalTotal         int64
	GoalValueTotal    float64
	GoalValueMean     float64
	GoalValueVariance float64
}

type MAUSummaryStorage

type MAUSummaryStorage interface {
	UpsertMAUSummary(
		ctx context.Context,
		mauSummary *eventcounter.MAUSummary,
	) error
}

func NewMAUSummaryStorage

func NewMAUSummaryStorage(qe mysql.QueryExecer) MAUSummaryStorage

type UserCountStorage

type UserCountStorage interface {
	GetMAUCount(
		ctx context.Context,
		environmentId, yearMonth string,
	) (int64, int64, error)
	GetMAUCounts(
		ctx context.Context,
		yearMonth string,
	) ([]*proto.MAUSummary, error)
	GetMAUCountsGroupBySourceID(
		ctx context.Context,
		yearMonth string,
	) ([]*proto.MAUSummary, error)
}

func NewUserCountStorage

func NewUserCountStorage(qe mysql.QueryExecer) UserCountStorage