querytee

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

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

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

type FanOutHandlerConfig struct {
	Backends                      []*ProxyBackend
	Codec                         queryrangebase.Codec
	GoldfishManager               goldfish.Manager
	Logger                        log.Logger
	Metrics                       *ProxyMetrics
	RouteName                     string
	Comparator                    comparator.ResponsesComparator
	InstrumentCompares            bool
	RoutingMode                   RoutingMode
	RaceTolerance                 time.Duration
	AddRoutingDecisionsToWarnings bool
}

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

type HandlerFactoryConfig struct {
	Backends                      []*ProxyBackend
	Codec                         queryrangebase.Codec
	GoldfishManager               goldfish.Manager
	InstrumentCompares            bool
	RoutingMode                   RoutingMode
	Logger                        log.Logger
	Metrics                       *ProxyMetrics
	RaceTolerance                 time.Duration
	SkipFanOutWhenNotSampling     bool
	SplitStart                    flagext.Time
	SplitLag                      time.Duration
	SplitRetentionDays            int64
	AddRoutingDecisionsToWarnings bool
}

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

type NonDecodableResponse struct {
	StatusCode int
	Body       []byte
}

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

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

type ProxyConfig struct {
	ServerServicePort              int
	BackendEndpoints               string
	BackendReadTimeout             time.Duration
	CompareResponses               bool
	DisableBackendReadProxy        string
	ValueComparisonTolerance       float64
	UseRelativeError               bool
	PassThroughNonRegisteredRoutes bool
	SkipRecentSamples              time.Duration
	SkipSamplesBefore              flagext.Time
	RequestURLFilter               *regexp.Regexp
	InstrumentCompares             bool
	SkipFanOutWhenNotSampling      bool
	Goldfish                       goldfish.Config

	Routing RoutingConfig
}

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

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

type ResponsesComparator interface {
	Compare(expected, actual []byte, queryEvaluationTime time.Time) (*ComparisonSummary, error)
}

type Route struct {
	Path               string
	RouteName          string
	Methods            []string
	ResponseComparator comparator.ResponsesComparator
}

type RoutingConfig struct {
	Mode          RoutingMode
	V1Preferred   string
	V2Preferred   string
	RaceTolerance time.Duration

	// SplitStart is the start date of data available in v2 (dataobjs) storage.
	// Queries for data before this date will only go to the v1 backend.
	// If not set, assume v2 data is always available.
	//
	// When splitting queries will be split into up to three parts:
	// 1. Data before SplitStart -> split goes to the v1 backend only
	// 2. Data between SplitStart and (now - SplitLag) -> split goes to both v1 and v2 backends
	// 3. Data after (now - SplitLag) -> split goes to the v1 backend only
	SplitStart flagext.Time

	// SplitLag is the minimum age of data to route to v2.
	// Data newer than (now - SplitLag) will only go to the v1 backend.
	// When set to 0, query splitting is disabled.
	SplitLag time.Duration

	// SplitRetentionDays is the lifecycle of data objects in days.
	// If set, data in v2 storage is considered available only for retention days.
	// Queries for data before the retention period will go to the v1 backend.
	// When both SplitStart and SplitRetentionDays are set, the more restrictive of the two will
	// determine v2 data availability.
	SplitRetentionDays int64

	// AddRoutingDecisionsToWarnings controls whether routing decisions are added
	// as warnings to query responses. When enabled, responses will include
	// warnings indicating which backend handled the query and how it was routed.
	AddRoutingDecisionsToWarnings bool
}

type RoutingMode string

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

type SplittingHandlerConfig struct {
	Codec                         queryrangebase.Codec
	FanOutHandler                 queryrangebase.Handler
	GoldfishManager               goldfish.Manager
	V1Backend                     *ProxyBackend
	SkipFanoutWhenNotSampling     bool
	RoutingMode                   RoutingMode
	SplitStart                    time.Time
	SplitLag                      time.Duration
	SplitRetentionDays            int64
	AddRoutingDecisionsToWarnings bool
}