m3db

Documentation

Index

• Constants
• type Client
  • func NewClient(cfg M3dbSection) (*Client, error)
  • func (s *Client) Close() error
  • func (p *Client) GetInstance(metric, endpoint string, tags map[string]string) []string
  • func (p *Client) Push2Queue(items []*dataobj.MetricValue)
  • func (p *Client) QueryData(inputs []dataobj.QueryData) []*dataobj.TsdbQueryResponse
  • func (p *Client) QueryDataForUI(input dataobj.QueryDataForUI) []*dataobj.TsdbQueryResponse
  • func (p *Client) QueryIndexByClude(inputs []dataobj.CludeRecv) (ret []dataobj.XcludeResp)
  • func (p *Client) QueryIndexByFullTags(inputs []dataobj.IndexByFullTagsRecv) ([]dataobj.IndexByFullTagsResp, int)
  • func (p *Client) QueryMetrics(input dataobj.EndpointsRecv) *dataobj.MetricResp
  • func (p *Client) QueryTagPairs(input dataobj.EndpointMetricRecv) []dataobj.IndexTagkvResp
• type M3dbSection

Constants

const (
	NID_NAME      = "__nid__"
	ENDPOINT_NAME = "__endpoint__"
	METRIC_NAME   = "__name__"
	SERIES_LIMIT  = 1000
	DOCS_LIMIT    = 100
	MAX_PONINTS   = 720
)

Types

type Client

type Client struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewClient

func NewClient(cfg M3dbSection) (*Client, error)

func (*Client) Close

func (s *Client) Close() error

func (*Client) GetInstance

func (p *Client) GetInstance(metric, endpoint string, tags map[string]string) []string

GetInstance: && (metric) (endpoint) (&& tags...) return: backend list which store the series

func (*Client) Push2Queue

func (p *Client) Push2Queue(items []*dataobj.MetricValue)

Push2Queue: push Metrics with values into m3.dbnode

func (*Client) QueryData

func (p *Client) QueryData(inputs []dataobj.QueryData) []*dataobj.TsdbQueryResponse

QueryData: || (|| endpoints...) (&& tags...)

func (*Client) QueryDataForUI

func (p *Client) QueryDataForUI(input dataobj.QueryDataForUI) []*dataobj.TsdbQueryResponse

QueryDataForUi: && (metric) (|| endpoints...) (&& tags...)

func (*Client) QueryIndexByClude

func (p *Client) QueryIndexByClude(inputs []dataobj.CludeRecv) (ret []dataobj.XcludeResp)

QueryIndexByClude: || (&& (|| endpoints...) (metric) (|| include...) (&& exclude..)) return all the tags that matches

func (*Client) QueryIndexByFullTags

func (p *Client) QueryIndexByFullTags(inputs []dataobj.IndexByFullTagsRecv) ([]dataobj.IndexByFullTagsResp, int)

QueryIndexByFullTags: && (|| endpoints...) (metric) (&& Tagkv...) return all the tags that matches

func (*Client) QueryMetrics

func (p *Client) QueryMetrics(input dataobj.EndpointsRecv) *dataobj.MetricResp

QueryMetrics: || (&& (endpoint)) (counter)... return all the values that tag == __name__

func (*Client) QueryTagPairs

func (p *Client) QueryTagPairs(input dataobj.EndpointMetricRecv) []dataobj.IndexTagkvResp

QueryTagPairs: && (|| endpoints...) (|| metrics...) return all the tags that matches

type M3dbSection

type M3dbSection struct {
	Name            string               `yaml:"name"`
	Enabled         bool                 `yaml:"enabled"`
	Namespace       string               `yaml:"namespace"`
	DaysLimit       int                  `yaml:"daysLimit"`
	SeriesLimit     int                  `yaml:"seriesLimit"`
	DocsLimit       int                  `yaml:"docsLimit"`
	MinStep         int                  `yaml:"minStep"`
	MaxSeriesPoints int                  `yaml:"maxSeriesPoints"`
	Config          client.Configuration `yaml:",inline"`
	Timeout         int                  `yaml:"timeout"`
	// contains filtered or unexported fields
}