data

Documentation

Index

• Variables
• type CHResponse
  • func (c *CHResponse) ToMultiFetchResponseV2() (*v2pb.MultiFetchResponse, error)
  • func (c *CHResponse) ToMultiFetchResponseV3() (*v3pb.MultiFetchResponse, error)
• type CHResponses
  • func EmptyResponse() CHResponses
  • func (cc *CHResponses) ToMultiFetchResponseV2() (*v2pb.MultiFetchResponse, error)
  • func (cc *CHResponses) ToMultiFetchResponseV3() (*v3pb.MultiFetchResponse, error)
• type Data
  • func (d *Data) GetAggregation(id uint32) (string, error)
  • func (d *Data) GetStep(id uint32) (uint32, error)
• type MultiTarget
  • func MFRToMultiTarget(v3Request *v3pb.MultiFetchRequest) MultiTarget
  • func (m *MultiTarget) Fetch(ctx context.Context, cfg *config.Config, chContext string) (CHResponses, error)
• type Targets
• type TimeFrame

Variables

var ErrSetStepTimeout = errors.New("unexpected error, setStep timeout")

var ReadUvarint = clickhouse.ReadUvarint

ReadUvarint reads unsigned int with variable length

Types

type CHResponse

type CHResponse struct {
	Data  *Data
	From  int64
	Until int64
}

CHResponse contains the parsed Data and From/Until timestamps

func (*CHResponse) ToMultiFetchResponseV2

func (c *CHResponse) ToMultiFetchResponseV2() (*v2pb.MultiFetchResponse, error)

ToMultiFetchResponseV2 returns protobuf v2pb.MultiFetchResponse message for given CHResponse

func (*CHResponse) ToMultiFetchResponseV3

func (c *CHResponse) ToMultiFetchResponseV3() (*v3pb.MultiFetchResponse, error)

ToMultiFetchResponseV3 returns protobuf v3pb.MultiFetchResponse message for given CHResponse

type CHResponses

type CHResponses []CHResponse

CHResponses is a slice of CHResponse

func EmptyResponse

func EmptyResponse() CHResponses

EmptyResponse returns an CHResponses with one element containing emptyData for the following encoding

func (*CHResponses) ToMultiFetchResponseV2

func (cc *CHResponses) ToMultiFetchResponseV2() (*v2pb.MultiFetchResponse, error)

ToMultiFetchResponseV2 returns protobuf v2pb.MultiFetchResponse message for given CHResponses

func (*CHResponses) ToMultiFetchResponseV3

func (cc *CHResponses) ToMultiFetchResponseV3() (*v3pb.MultiFetchResponse, error)

ToMultiFetchResponseV3 returns protobuf v3pb.MultiFetchResponse message for given CHResponses

type Data

type Data struct {
	*point.Points
	AM *alias.Map
	// contains filtered or unexported fields
}

Data stores parsed response from ClickHouse server

func (*Data) GetAggregation

func (d *Data) GetAggregation(id uint32) (string, error)

GetAggregation returns the generic whisper compatible name for an aggregation of metric with ID id

func (*Data) GetStep

func (d *Data) GetStep(id uint32) (uint32, error)

GetStep returns the commonStep for all points or, if unset, step for metric ID id

type MultiTarget

type MultiTarget map[TimeFrame]*Targets

MultiTarget is a map of TimeFrame keys and targets slice of strings values

func MFRToMultiTarget

func MFRToMultiTarget(v3Request *v3pb.MultiFetchRequest) MultiTarget

func (*MultiTarget) Fetch

func (m *MultiTarget) Fetch(ctx context.Context, cfg *config.Config, chContext string) (CHResponses, error)

Fetch fetches the parsed ClickHouse data returns CHResponses

type Targets

type Targets struct {
	// List contains queried metrics, e.g. [metric.{name1,name2}, metric.name[3-9]]
	List []string
	// AM stores found expanded metrics
	AM *alias.Map
	// contains filtered or unexported fields
}

Targets represents requested metrics

type TimeFrame

type TimeFrame struct {
	From          int64
	Until         int64
	MaxDataPoints int64
}

TimeFrame contains information about fetch request time conditions