types

type BackendV2 struct {
	GroupName           string                 `mapstructure:"groupName"`
	Protocol            string                 `mapstructure:"protocol"`
	LBMethod            string                 `mapstructure:"lbMethod"` // Valid: rr/roundrobin, broadcast/all
	Servers             []string               `mapstructure:"servers"`
	Timeouts            *Timeouts              `mapstructure:"timeouts"`
	ConcurrencyLimit    *int                   `mapstructure:"concurrencyLimit"`
	KeepAliveInterval   *time.Duration         `mapstructure:"keepAliveInterval"`
	MaxIdleConnsPerHost *int                   `mapstructure:"maxIdleConnsPerHost"`
	MaxTries            *int                   `mapstructure:"maxTries"`
	MaxBatchSize        int                    `mapstructure:"maxBatchSize"`
	BackendOptions      map[string]interface{} `mapstructure:"backendOptions"`
}

type BackendsV2 struct {
	Backends                  []BackendV2   `mapstructure:"backends"`
	MaxIdleConnsPerHost       int           `mapstructure:"maxIdleConnsPerHost"`
	ConcurrencyLimitPerServer int           `mapstructure:"concurrencyLimit"`
	Timeouts                  Timeouts      `mapstructure:"timeouts"`
	KeepAliveInterval         time.Duration `mapstructure:"keepAliveInterval"`
	MaxTries                  int           `mapstructure:"maxTries"`
	MaxBatchSize              int           `mapstructure:"maxBatchSize"`
}

type CapabilityRequestV3 struct {
	protov3.CapabilityRequest
}

type CarbonSearch struct {
	Backend string `mapstructure:"backend"`
	Prefix  string `mapstructure:"prefix"`
}

type CarbonSearchV2 struct {
	BackendsV2
	Prefix string `mapstructure:"prefix"`
}

type Fetcher func(ctx context.Context, logger *zap.Logger, client ServerClient, reqs interface{}, resCh chan ServerFetcherResponse)

type LBMethod int

type MultiFetchRequestV3 struct {
	protov3.MultiFetchRequest
}

type MultiGlobRequestV3 struct {
	protov3.MultiGlobRequest
}

type MultiMetricsInfoV3 struct {
	protov3.MultiMetricsInfoRequest
}

type Request interface {
	Marshal() ([]byte, error)
	LogInfo() interface{}
}

type ServerClient interface {
	Name() string
	Backends() []string
	MaxMetricsPerRequest() int

	Fetch(ctx context.Context, request *protov3.MultiFetchRequest) (*protov3.MultiFetchResponse, *Stats, *errors.Errors)
	Find(ctx context.Context, request *protov3.MultiGlobRequest) (*protov3.MultiGlobResponse, *Stats, *errors.Errors)
	Info(ctx context.Context, request *protov3.MultiMetricsInfoRequest) (*protov3.ZipperInfoResponse, *Stats, *errors.Errors)

	List(ctx context.Context) (*protov3.ListMetricsResponse, *Stats, *errors.Errors)
	Stats(ctx context.Context) (*protov3.MetricDetailsResponse, *Stats, *errors.Errors)

	ProbeTLDs(ctx context.Context) ([]string, *errors.Errors)

	TagNames(ctx context.Context, query string, limit int64) ([]string, *errors.Errors)
	TagValues(ctx context.Context, query string, limit int64) ([]string, *errors.Errors)

	Children() []ServerClient
}

type ServerFetchResponse struct {
	Server   string
	Response *protov3.MultiFetchResponse
	Stats    *Stats
	Err      *errors.Errors
}

type ServerFetcherResponse interface {
	Self() interface{}
	MergeI(second ServerFetcherResponse) *errors.Errors
	Errors() *errors.Errors
	GetServer() string
}

type ServerFindResponse struct {
	Server   string
	Response *protov3.MultiGlobResponse
	Stats    *Stats
	Err      *errors.Errors
}

type ServerInfoResponse struct {
	Server   string
	Response *protov3.ZipperInfoResponse
	Stats    *Stats
	Err      *errors.Errors
}

type ServerResponse struct {
	Server   string
	Response []byte
}

type ServerTagResponse struct {
	Server   string
	Response []string
	Err      *errors.Errors
}

type Stats struct {
	Timeouts          int64
	FindErrors        int64
	RenderErrors      int64
	InfoErrors        int64
	SearchRequests    int64
	SearchCacheHits   int64
	SearchCacheMisses int64
	ZipperRequests    int64
	TotalMetricsCount int64

	MemoryUsage int64

	CacheMisses int64
	CacheHits   int64

	Servers       []string
	FailedServers []string
}

type Timeouts struct {
	Find    time.Duration `yaml:"find"`
	Render  time.Duration `yaml:"render"`
	Connect time.Duration `yaml:"connect"`
}