types

Documentation

Index

• Variables
• func MergeFetchResponses(m1, m2 *protov3.FetchResponse) *errors.Errors
• type BackendV2
  • func (b *BackendV2) FillDefaults()
• type BackendsV2
• type CarbonSearch
• type CarbonSearchV2
• type LBMethod
  • func (m *LBMethod) FromString(method string) error
  • func (m LBMethod) MarshalJSON() ([]byte, error)
  • func (m *LBMethod) UnmarshalJSON(data []byte) error
  • func (m *LBMethod) UnmarshalYAML(unmarshal func(interface{}) error) error
• type ServerClient
• type ServerFetchResponse
  • func (first *ServerFetchResponse) Merge(second *ServerFetchResponse)
• type ServerFindResponse
  • func (first *ServerFindResponse) Merge(second *ServerFindResponse) *errors.Errors
• type ServerInfoResponse
• type ServerResponse
• type Stats
  • func (s *Stats) Merge(stats *Stats)
• type Timeouts

Variables

var EmptyMsg = &empty.Empty{}

var ErrFailedToFetchFmt = "failed to fetch data from server group %v, code %v, body %v"

var ErrMaxTriesExceeded = errors.New("max tries exceeded")

var ErrNoMetricsFetched = errors.New("no metrics in the Response")

var ErrNoResponseFetched = errors.New("no responses fetched from upstream")

var ErrNonFatalErrors = errors.New("response contains non-fatal errors")

var ErrNotFound = errors.New("metric not found")

var ErrNotImplementedYet = errors.New("this feature is not implemented yet")

var ErrResponseLengthMismatch = errors.New("response length mismatch")

var ErrResponseStartTimeMismatch = errors.New("response start time mismatch")

var ErrTimeoutExceeded = errors.New("timeout while fetching Response")

var ErrUnknownLBMethodFmt = "unknown lb method: '%v', supported: %v"

Functions

func MergeFetchResponses

func MergeFetchResponses(m1, m2 *protov3.FetchResponse) *errors.Errors

Types

type BackendV2

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"`
	MaxGlobs            int            `mapstructure:"maxGlobs"`
}

func (*BackendV2) FillDefaults

func (b *BackendV2) FillDefaults()

type BackendsV2

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"`
	MaxGlobs                  int           `mapstructure:"maxGlobs"`
}

type CarbonSearch

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

CarbonSearch is a structure that contains carbonsearch related configuration bits

type CarbonSearchV2

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

type LBMethod

type LBMethod int

const (
	RoundRobinLB LBMethod = iota
	BroadcastLB
)

func (*LBMethod) FromString

func (m *LBMethod) FromString(method string) error

func (LBMethod) MarshalJSON

func (m LBMethod) MarshalJSON() ([]byte, error)

func (*LBMethod) UnmarshalJSON

func (m *LBMethod) UnmarshalJSON(data []byte) error

func (*LBMethod) UnmarshalYAML

func (m *LBMethod) UnmarshalYAML(unmarshal func(interface{}) error) error

type ServerClient

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)
}

type ServerFetchResponse

type ServerFetchResponse struct {
	Server       string
	ResponsesMap map[string][]protov3.FetchResponse
	Response     *protov3.MultiFetchResponse
	Stats        *Stats
	Err          *errors.Errors
}

func (*ServerFetchResponse) Merge

func (first *ServerFetchResponse) Merge(second *ServerFetchResponse)

type ServerFindResponse

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

func (*ServerFindResponse) Merge

func (first *ServerFindResponse) Merge(second *ServerFindResponse) *errors.Errors

type ServerInfoResponse

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

type ServerResponse

type ServerResponse struct {
	Server   string
	Response []byte
}

type Stats

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

	MemoryUsage int64

	CacheMisses int64
	CacheHits   int64

	Servers       []string
	FailedServers []string
}

Stats provides zipper-related statistics

func (*Stats) Merge

func (s *Stats) Merge(stats *Stats)

type Timeouts

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

Timeouts is a global structure that contains configuration for zipper Timeouts