storage

Documentation

Index

• type EvalEventWriter
  • func NewEvalEventWriter(q writer.Writer, size int) EvalEventWriter
• type GoalEventWriter
  • func NewGoalEventWriter(q writer.Writer, size int) GoalEventWriter
• type Storage
  • func NewStorage(logger *zap.Logger, register metrics.Registerer) Storage

Types

type EvalEventWriter

type EvalEventWriter interface {
	AppendRows(ctx context.Context, events []*epproto.EvaluationEvent) (map[string]bool, error)
}

func NewEvalEventWriter

func NewEvalEventWriter(q writer.Writer, size int) EvalEventWriter

type GoalEventWriter

type GoalEventWriter interface {
	AppendRows(ctx context.Context, events []*epproto.GoalEvent) (map[string]bool, error)
}

func NewGoalEventWriter

func NewGoalEventWriter(q writer.Writer, size int) GoalEventWriter

type Storage

type Storage interface {
	SaveGetEvaluationLatencyMetricsEvent(tag, status string, duration time.Duration)
	SaveGetEvaluationSizeMetricsEvent(tag, status string, sizeByte int32)
	SaveTimeoutErrorCountMetricsEvent(tag string)
	SaveInternalErrorCountMetricsEvent(tag string)
	SaveLatencyMetricsEvent(tag, status, sdkVersion string, api eventproto.ApiId, duration time.Duration)
	SaveSizeMetricsEvent(tag, status, sdkVersion string, api eventproto.ApiId, sizeByte int32)
	SaveTimeoutErrorMetricsEvent(tag, sdkVersion string, api eventproto.ApiId)
	SaveInternalErrorMetricsEvent(tag, sdkVersion string, api eventproto.ApiId)
	SaveNetworkErrorMetricsEvent(tag, sdkVersion string, api eventproto.ApiId)
	SaveInternalSdkErrorMetricsEvent(tag, sdkVersion string, api eventproto.ApiId)
}

func NewStorage

func NewStorage(logger *zap.Logger, register metrics.Registerer) Storage