gosnowth

May 19, 2023

Changes in this version

type FindTagsResult

+ Estimate bool

Mar 21, 2023

Changes in this version

+ type PromQLMetadataQuery struct

+ AccountID string

+ Limit string

+ Metric string

type SnowthClient

+ func (sc *SnowthClient) PromQLMetadataQuery(query *PromQLMetadataQuery, nodes ...*SnowthNode) (*PromQLResponse, error)

+ func (sc *SnowthClient) PromQLMetadataQueryContext(ctx context.Context, query *PromQLMetadataQuery, nodes ...*SnowthNode) (*PromQLResponse, error)

Mar 21, 2023

Changes in this version

+ func ConvertSeriesSelector(selector string) (string, error)

+ type PromQLLabelQuery struct

+ AccountID string

+ End string

+ Match []string

+ Start string

+ type PromQLSeriesQuery struct

+ AccountID string

+ End string

+ Match []string

+ Start string

type SnowthClient

+ func (sc *SnowthClient) PromQLLabelQuery(query *PromQLLabelQuery, nodes ...*SnowthNode) (*PromQLResponse, error)

+ func (sc *SnowthClient) PromQLLabelQueryContext(ctx context.Context, query *PromQLLabelQuery, nodes ...*SnowthNode) (*PromQLResponse, error)

+ func (sc *SnowthClient) PromQLLabelValuesQuery(label string, query *PromQLLabelQuery, nodes ...*SnowthNode) (*PromQLResponse, error)

+ func (sc *SnowthClient) PromQLLabelValuesQueryContext(ctx context.Context, label string, query *PromQLLabelQuery, ...) (*PromQLResponse, error)

+ func (sc *SnowthClient) PromQLSeriesQuery(query *PromQLSeriesQuery, nodes ...*SnowthNode) (*PromQLResponse, error)

+ func (sc *SnowthClient) PromQLSeriesQueryContext(ctx context.Context, query *PromQLSeriesQuery, nodes ...*SnowthNode) (*PromQLResponse, error)

Mar 14, 2023

Changes in this version

+ type PromQLInstantQuery struct

+ AccountID string

+ Query string

+ Time string

+ Timeout string

type SnowthClient

+ func (sc *SnowthClient) PromQLInstantQuery(query *PromQLInstantQuery, nodes ...*SnowthNode) (*PromQLResponse, error)

+ func (sc *SnowthClient) PromQLInstantQueryContext(ctx context.Context, query *PromQLInstantQuery, nodes ...*SnowthNode) (*PromQLResponse, error)

Mar 9, 2023

Changes in this version

type Config

+ DenyHosts []string

Feb 21, 2023

Changes in this version

+ type PromQLError struct

+ Data map[string]interface{}

+ Err string

+ ErrorType string

+ Status string

+ Warnings []string

+ func (pe *PromQLError) Error() string

+ func (pe *PromQLError) String() string

Jun 9, 2020

Changes in this version

+ func ReplaceInf(b []byte) []byte

Apr 30, 2020

Changes in this version

type Config

+ func (c *Config) SetConnectRetries(num int64)

+ func (c *Config) SetRetries(num int64)

Sep 20, 2019

Changes in this version

+ type CAQLErrorArgs struct

+ AccountID int64

+ Debug byte

+ End int64

+ Expansion []string

+ Format string

+ ID int64

+ IgnoreDurationLimits bool

+ Method string

+ MinPrefill int64

+ Period int64

+ PrepareResults string

+ Query string

+ Start int64

+ Timeout int64

+ type CAQLUserError struct

+ Message string

Sep 16, 2019

Changes in this version

type RollupAllValue

+ Count int64

+ Counter float64

+ Counter2 float64

+ Counter2Stddev float64

+ CounterStddev float64

+ Derivative float64

+ Derivative2 float64

+ Derivative2Stddev float64

+ DerivativeStddev float64

+ Stddev float64

+ Value float64

Jun 26, 2019

Changes in this version

type SnowthClient

+ func (sc *SnowthClient) SetWatchFunc(f func(n *SnowthNode))

Mar 12, 2019

Changes in this version

+ const FlatbufferContentType

type Config

+ func (c *Config) MarshalJSON() ([]byte, error)

+ func (c *Config) SetDialTimeout(t time.Duration) error

+ func (c *Config) SetDiscover(d bool)

+ func (c *Config) SetServers(servers ...string) error

+ func (c *Config) SetTimeout(t time.Duration) error

+ func (c *Config) SetWatchInterval(i time.Duration) error

+ func (c *Config) UnmarshalJSON(b []byte) error

type FindTagsItem

+ Category string

+ CheckName string

+ type RollupValues struct

+ Timestamp int64

+ Value float64

+ func (rv *RollupValues) UnmarshalJSON(b []byte) error

type SnowthClient

+ func (sc *SnowthClient) GetTopoRingInfo(hash string, node *SnowthNode) (*TopoRing, error)

+ func (sc *SnowthClient) GetTopoRingInfoContext(ctx context.Context, hash string, node *SnowthNode) (*TopoRing, error)

+ type TopoRing struct

+ NumberNodes int

+ VirtualNodes []TopoRingDetail

+ XMLName xml.Name

+ type TopoRingDetail struct

+ ID string

+ IDX int

+ Location float64

+ XMLName xml.Name

type Topology

+ NumberNodes int

type TopologyNode

+ NumberNodes int

Feb 15, 2023

Changes in this version

+ const Df4FlatbufferAccept

+ const FetchFlatbufferContentType

+ const MetriclistFlatbufferContentType

+ type CAQLError struct

+ Arguments map[string]interface{}

+ Locals []string

+ Method string

+ Status string

+ Success bool

+ Trace []string

+ UserError map[string]interface{}

+ func (ce *CAQLError) Error() string

+ func (ce *CAQLError) Message() string

+ func (ce *CAQLError) String() string

+ type CAQLQuery struct

+ AccountID int64

+ Debug byte

+ End int64

+ Expansion []string

+ Explain bool

+ Format string

+ ID int64

+ IgnoreDurationLimits bool

+ Method string

+ MinPrefill int64

+ Period int64

+ PrepareResults string

+ Query string

+ Start int64

+ Timeout int64

+ type CheckTags map[string][]string

+ type Config struct

+ ConnectRetries int64

+ CtxKeyTraceID interface{}

+ DialTimeout time.Duration

+ Discover bool

+ Retries int64

+ Servers []string

+ Timeout time.Duration

+ WatchInterval time.Duration

+ func NewConfig(servers ...string) *Config

+ type DF4Data []interface

+ func (d *DF4Data) NullEmpty()

+ func (dd *DF4Data) Histogram() []*map[string]int64

+ func (dd *DF4Data) Numeric() []*float64

+ func (dd *DF4Data) Text() []*string

+ type DF4Head struct

+ Count int64

+ Error []string

+ Explain json.RawMessage

+ Period int64

+ Start int64

+ Warning []string

+ func (h *DF4Head) MarshalJSON() ([]byte, error)

+ func (h *DF4Head) UnmarshalJSON(b []byte) error

+ type DF4Meta struct

+ Kind string

+ Label string

+ Tags []string

+ type DF4Response struct

+ Data []DF4Data

+ Head DF4Head

+ Meta []DF4Meta

+ Query string

+ Ver string

+ func (dr *DF4Response) Copy() *DF4Response

+ type ExtParam struct

+ Name string

+ Value string

+ type ExtensionParam struct

+ AliasList []string

+ Default interface{}

+ Description string

+ Name string

+ Optional bool

+ Type string

+ type Features struct

+ FeatureFlags bool

+ HistogramDynamicRollups bool

+ HistogramStore bool

+ NNTSecondOrder bool

+ NNTStore bool

+ TextStore bool

+ func (f *Features) UnmarshalJSON(b []byte) error

+ type FetchQuery struct

+ Count int64

+ Period time.Duration

+ Reduce []FetchReduce

+ Start time.Time

+ Streams []FetchStream

+ func (fq *FetchQuery) MarshalJSON() ([]byte, error)

+ func (fq *FetchQuery) Timestamp() string

+ func (fq *FetchQuery) UnmarshalJSON(b []byte) error

+ type FetchReduce struct

+ Label string

+ Method string

+ MethodParams []string

+ type FetchStream struct

+ Kind string

+ Label string

+ Name string

+ Transform string

+ TransformParams []string

+ UUID string

+ type FileSystemDetails struct

+ FreeMB float64

+ ID uint64

+ TotalMB float64

+ type FindTagsCount struct

+ Count int64

+ Estimate bool

+ type FindTagsItem struct

+ AccountID int64

+ Activity [][]int64

+ CheckTags []string

+ Latest *FindTagsLatest

+ MetricName string

+ Type string

+ UUID string

+ type FindTagsLatest struct

+ Histogram []FindTagsLatestHistogram

+ Numeric []FindTagsLatestNumeric

+ Text []FindTagsLatestText

+ type FindTagsLatestHistogram struct

+ Time int64

+ Value *string

+ func (ftl *FindTagsLatestHistogram) MarshalJSON() ([]byte, error)

+ func (ftl *FindTagsLatestHistogram) UnmarshalJSON(b []byte) error

+ type FindTagsLatestNumeric struct

+ Time int64

+ Value *float64

+ func (ftl *FindTagsLatestNumeric) MarshalJSON() ([]byte, error)

+ func (ftl *FindTagsLatestNumeric) UnmarshalJSON(b []byte) error

+ type FindTagsLatestText struct

+ Time int64

+ Value *string

+ func (ftl *FindTagsLatestText) MarshalJSON() ([]byte, error)

+ func (ftl *FindTagsLatestText) UnmarshalJSON(b []byte) error

+ type FindTagsOptions struct

+ Activity int64

+ CountOnly int64

+ End time.Time

+ EndStr string

+ Latest int64

+ Limit int64

+ Start time.Time

+ StartStr string

+ type FindTagsResult struct

+ Count int64

+ FindCount *FindTagsCount

+ Items []FindTagsItem

+ type Gossip []GossipDetail

+ type GossipDetail struct

+ Age float64

+ CurrentTopo string

+ ID string

+ Latency GossipLatency

+ NextTopo string

+ Time float64

+ TopoState string

+ type GossipLatency map[string]string

+ type GraphiteDatapoints struct

+ From int64

+ Series map[string][]*float64

+ Step int64

+ To int64

+ type GraphiteLookup struct

+ End int64

+ Names []string

+ Start int64

+ type GraphiteMetric struct

+ Data map[string]string

+ Leaf bool

+ Name string

+ type GraphiteOptions struct

+ Limit int64

+ type HistogramData struct

+ AccountID int64

+ CheckName string

+ Histogram *circonusllhist.Histogram

+ ID string

+ Metric string

+ Offset int64

+ Period int64

+ type HistogramValue struct

+ Data map[string]int64

+ Period time.Duration

+ Time time.Time

+ func (hv *HistogramValue) MarshalJSON() ([]byte, error)

+ func (hv *HistogramValue) Timestamp() string

+ func (hv *HistogramValue) UnmarshalJSON(b []byte) error

+ type IRONdbPutResponse struct

+ Errors uint64

+ Misdirected uint64

+ Records uint64

+ Updated uint64

+ type Logger interface

+ Debugf func(format string, args ...interface{})

+ Errorf func(format string, args ...interface{})

+ Infof func(format string, args ...interface{})

+ Warnf func(format string, args ...interface{})

+ type LuaExtension struct

+ Description string

+ Documentation string

+ Man string

+ Method string

+ Name string

+ Params map[string]*ExtensionParam

+ ParseJSONPayload bool

+ type LuaExtensions map[string]*LuaExtension

+ func (le *LuaExtensions) UnmarshalJSON(b []byte) error

+ type MetricName struct

+ CanonicalName string

+ MeasurementTags []Tag

+ Name string

+ StreamTags []Tag

+ func NewMetricName() *MetricName

+ func ParseMetricName(name string) (*MetricName, error)

+ type MetricParser struct

+ func NewMetricParser(r io.Reader) *MetricParser

+ func (mp *MetricParser) Parse() (*MetricName, error)

+ type ModifyTags struct

+ Add []string

+ Remove []string

+ type NNTAllValue struct

+ Count int64

+ Counter int64

+ Counter2 int64

+ Counter2StdDev int64

+ CounterStdDev int64

+ Derivative int64

+ Derivative2 int64

+ Derivative2StdDev int64

+ DerivativeStdDev int64

+ StdDev int64

+ Time time.Time

+ Value int64

+ type NNTAllValueResponse struct

+ Data []NNTAllValue

+ func (nv *NNTAllValueResponse) UnmarshalJSON(b []byte) error

+ type NNTData struct

+ Count int64

+ Counter int64

+ CounterStdDev int64

+ Derivative int64

+ DerivativeStdDev int64

+ ID string

+ Metric string

+ Offset int64

+ Parts Parts

+ StdDev int64

+ Value int64

+ type NNTPartsData struct

+ Count int64

+ Counter int64

+ CounterStdDev int64

+ Derivative int64

+ DerivativeStdDev int64

+ StdDev int64

+ Value int64

+ type NNTValue struct

+ Time time.Time

+ Value int64

+ type NNTValueResponse struct

+ Data []NNTValue

+ func (nv *NNTValueResponse) UnmarshalJSON(b []byte) error

+ type NodeState struct

+ Application string

+ AvgPeerLag float64

+ BaseRollup uint64

+ Current string

+ Features Features

+ Histogram Rollup

+ Identity string

+ MaxPeerLag float64

+ NNT Rollup

+ NNTBS *Rollup

+ NNTCacheSize uint64

+ Next string

+ RUsageInBlock uint64

+ RUsageMajFLT uint64

+ RUsageMaxRSS uint64

+ RUsageMinFLT uint64

+ RUsageMsgRcv uint64

+ RUsageMsgSnd uint64

+ RUsageNSignals uint64

+ RUsageNSwap uint64

+ RUsageNivcSW uint64

+ RUsageNvcSW uint64

+ RUsageOuBlock uint64

+ RUsageSTime float64

+ RUsageUTime float64

+ Rollups []uint64

+ Text Rollup

+ Version string

+ type NumericAllValue struct

+ Count int64

+ Counter int64

+ Counter2 int64

+ Counter2StdDev int64

+ CounterStdDev int64

+ Derivative int64

+ Derivative2 int64

+ Derivative2StdDev int64

+ DerivativeStdDev int64

+ StdDev int64

+ Time time.Time

+ Value int64

+ type NumericAllValueResponse struct

+ Data []NumericAllValue

+ func (nv *NumericAllValueResponse) UnmarshalJSON(b []byte) error

+ type NumericParts struct

+ Data []NumericPartsData

+ Period int64

+ func (p *NumericParts) MarshalJSON() ([]byte, error)

+ type NumericPartsData struct

+ Count int64

+ Counter int64

+ CounterStdDev int64

+ Derivative int64

+ DerivativeStdDev int64

+ StdDev int64

+ Value int64

+ type NumericValue struct

+ Time time.Time

+ Value int64

+ type NumericValueResponse struct

+ Data []NumericValue

+ func (nv *NumericValueResponse) UnmarshalJSON(b []byte) error

+ type NumericWrite struct

+ Count int64

+ Counter int64

+ CounterStdDev int64

+ Derivative int64

+ DerivativeStdDev int64

+ ID string

+ Metric string

+ Offset int64

+ Parts NumericParts

+ StdDev int64

+ Value int64

+ type Parts struct

+ Data []NNTPartsData

+ Period int64

+ func (p *Parts) MarshalJSON() ([]byte, error)

+ type PromQLRangeQuery struct

+ AccountID string

+ End string

+ Query string

+ Start string

+ Step string

+ Timeout string

+ type PromQLResponse struct

+ Data map[string]interface{}

+ Error string

+ ErrorType string

+ Status string

+ Warnings []string

+ type RawNumericValue struct

+ Time time.Time

+ Value float64

+ type RawNumericValueResponse struct

+ Data []RawNumericValue

+ func (rv *RawNumericValueResponse) UnmarshalJSON(b []byte) error

+ type RebuildActivityRequest struct

+ Metric string

+ UUID string

+ type Rollup struct

+ Aggregate RollupDetails

+ RollupList []uint64

+ func (r *Rollup) UnmarshalJSON(b []byte) error

+ type RollupAllData struct

+ Count int64

+ Counter float64

+ Counter2 float64

+ Counter2Stddev float64

+ CounterStddev float64

+ Derivative float64

+ Derivative2 float64

+ Derivative2Stddev float64

+ DerivativeStddev float64

+ Stddev float64

+ Value float64

+ type RollupAllValue struct

+ Data *RollupAllData

+ Time time.Time

+ func (rv *RollupAllValue) MarshalJSON() ([]byte, error)

+ func (rv *RollupAllValue) Timestamp() string

+ func (rv *RollupAllValue) UnmarshalJSON(b []byte) error

+ type RollupDetails struct

+ ExtendCalls uint64

+ FilesSystem FileSystemDetails

+ GetCalls uint64

+ GetCount uint64

+ GetElapsedUS uint64

+ GetProxyCalls uint64

+ PutCalls uint64

+ PutElapsedUS uint64

+ type RollupEntries map[string]RollupDetails

+ type RollupValue struct

+ Time time.Time

+ Value *float64

+ func (rv *RollupValue) MarshalJSON() ([]byte, error)

+ func (rv *RollupValue) Timestamp() string

+ func (rv *RollupValue) UnmarshalJSON(b []byte) error

+ type SnowthClient struct

+ func NewClient(ctx context.Context, cfg *Config) (*SnowthClient, error)

+ func NewSnowthClient(discover bool, addrs ...string) (*SnowthClient, error)

+ func (sc *SnowthClient) ActivateNodes(nodes ...*SnowthNode)

+ func (sc *SnowthClient) ActivateTopology(hash string, node *SnowthNode) error

+ func (sc *SnowthClient) ActivateTopologyContext(ctx context.Context, hash string, node *SnowthNode) error

+ func (sc *SnowthClient) AddNodes(nodes ...*SnowthNode)

+ func (sc *SnowthClient) ConnectRetries() int64

+ func (sc *SnowthClient) DeactivateNodes(nodes ...*SnowthNode)

+ func (sc *SnowthClient) DeleteCheckTags(checkUUID string, nodes ...*SnowthNode) error

+ func (sc *SnowthClient) DeleteCheckTagsContext(ctx context.Context, checkUUID string, nodes ...*SnowthNode) error

+ func (sc *SnowthClient) DoRequest(node *SnowthNode, method string, url string, body io.Reader, ...) (io.Reader, http.Header, error)

+ func (sc *SnowthClient) DoRequestContext(ctx context.Context, node *SnowthNode, method string, url string, ...) (io.Reader, http.Header, error)

+ func (sc *SnowthClient) ExecLuaExtension(name string, params []ExtParam, nodes ...*SnowthNode) (map[string]interface{}, error)

+ func (sc *SnowthClient) ExecLuaExtensionContext(ctx context.Context, name string, params []ExtParam, nodes ...*SnowthNode) (map[string]interface{}, error)

+ func (sc *SnowthClient) FetchValues(q *FetchQuery, nodes ...*SnowthNode) (*DF4Response, error)

+ func (sc *SnowthClient) FetchValuesContext(ctx context.Context, q *FetchQuery, nodes ...*SnowthNode) (*DF4Response, error)

+ func (sc *SnowthClient) FetchValuesFb(node *SnowthNode, q *fetch.FetchT) (*fetch.DF4T, error)

+ func (sc *SnowthClient) FetchValuesFbContext(ctx context.Context, node *SnowthNode, q *fetch.FetchT) (*fetch.DF4T, error)

+ func (sc *SnowthClient) FindMetricNodeIDs(uuid, metric string) []string

+ func (sc *SnowthClient) FindTagCats(accountID int64, query string, nodes ...*SnowthNode) ([]string, error)

+ func (sc *SnowthClient) FindTagCatsContext(ctx context.Context, accountID int64, query string, nodes ...*SnowthNode) ([]string, error)

+ func (sc *SnowthClient) FindTagVals(accountID int64, query, category string, nodes ...*SnowthNode) ([]string, error)

+ func (sc *SnowthClient) FindTagValsContext(ctx context.Context, accountID int64, query, category string, ...) ([]string, error)

+ func (sc *SnowthClient) FindTags(accountID int64, query string, options *FindTagsOptions, nodes ...*SnowthNode) (*FindTagsResult, error)

+ func (sc *SnowthClient) FindTagsContext(ctx context.Context, accountID int64, query string, options *FindTagsOptions, ...) (*FindTagsResult, error)

+ func (sc *SnowthClient) GetActiveNode(idsets ...[]string) *SnowthNode

+ func (sc *SnowthClient) GetCAQLQuery(q *CAQLQuery, nodes ...*SnowthNode) (*DF4Response, error)

+ func (sc *SnowthClient) GetCAQLQueryContext(ctx context.Context, q *CAQLQuery, nodes ...*SnowthNode) (*DF4Response, error)

+ func (sc *SnowthClient) GetCheckTags(checkUUID string, nodes ...*SnowthNode) (CheckTags, error)

+ func (sc *SnowthClient) GetCheckTagsContext(ctx context.Context, checkUUID string, nodes ...*SnowthNode) (CheckTags, error)

+ func (sc *SnowthClient) GetGossipInfo(nodes ...*SnowthNode) (*Gossip, error)

+ func (sc *SnowthClient) GetGossipInfoContext(ctx context.Context, nodes ...*SnowthNode) (*Gossip, error)

+ func (sc *SnowthClient) GetLuaExtensions(nodes ...*SnowthNode) (LuaExtensions, error)

+ func (sc *SnowthClient) GetLuaExtensionsContext(ctx context.Context, nodes ...*SnowthNode) (LuaExtensions, error)

+ func (sc *SnowthClient) GetNodeState(nodes ...*SnowthNode) (*NodeState, error)

+ func (sc *SnowthClient) GetNodeStateContext(ctx context.Context, nodes ...*SnowthNode) (*NodeState, error)

+ func (sc *SnowthClient) GetStats(nodes ...*SnowthNode) (*Stats, error)

+ func (sc *SnowthClient) GetStatsContext(ctx context.Context, nodes ...*SnowthNode) (*Stats, error)

+ func (sc *SnowthClient) GetStatsNodeContext(ctx context.Context, node *SnowthNode) (*Stats, error)

+ func (sc *SnowthClient) GetTopologyInfo(nodes ...*SnowthNode) (*Topology, error)

+ func (sc *SnowthClient) GetTopologyInfoContext(ctx context.Context, nodes ...*SnowthNode) (*Topology, error)

+ func (sc *SnowthClient) GraphiteFindMetrics(accountID int64, prefix, query string, options *GraphiteOptions, ...) ([]GraphiteMetric, error)

+ func (sc *SnowthClient) GraphiteFindMetricsContext(ctx context.Context, accountID int64, prefix, query string, ...) ([]GraphiteMetric, error)

+ func (sc *SnowthClient) GraphiteFindTags(accountID int64, prefix, query string, options *GraphiteOptions, ...) ([]GraphiteMetric, error)

+ func (sc *SnowthClient) GraphiteFindTagsContext(ctx context.Context, accountID int64, prefix, query string, ...) ([]GraphiteMetric, error)

+ func (sc *SnowthClient) GraphiteGetDatapoints(accountID int64, prefix string, lookup *GraphiteLookup, ...) (*GraphiteDatapoints, error)

+ func (sc *SnowthClient) GraphiteGetDatapointsContext(ctx context.Context, accountID int64, prefix string, lookup *GraphiteLookup, ...) (*GraphiteDatapoints, error)

+ func (sc *SnowthClient) ListActiveNodes() []*SnowthNode

+ func (sc *SnowthClient) ListInactiveNodes() []*SnowthNode

+ func (sc *SnowthClient) LoadTopology(hash string, t *Topology, nodes ...*SnowthNode) error

+ func (sc *SnowthClient) LoadTopologyContext(ctx context.Context, hash string, t *Topology, node *SnowthNode) error

+ func (sc *SnowthClient) LocateMetric(uuid string, metric string, node ...*SnowthNode) ([]TopologyNode, error)

+ func (sc *SnowthClient) LocateMetricContext(ctx context.Context, uuid string, metric string, node ...*SnowthNode) ([]TopologyNode, error)

+ func (sc *SnowthClient) LocateMetricRemote(uuid string, metric string, node *SnowthNode) ([]TopologyNode, error)

+ func (sc *SnowthClient) LocateMetricRemoteContext(ctx context.Context, uuid string, metric string, node *SnowthNode) ([]TopologyNode, error)

+ func (sc *SnowthClient) LogDebugf(format string, args ...interface{})

+ func (sc *SnowthClient) LogErrorf(format string, args ...interface{})

+ func (sc *SnowthClient) LogInfof(format string, args ...interface{})

+ func (sc *SnowthClient) LogWarnf(format string, args ...interface{})

+ func (sc *SnowthClient) PromQLRangeQuery(query *PromQLRangeQuery, nodes ...*SnowthNode) (*PromQLResponse, error)

+ func (sc *SnowthClient) PromQLRangeQueryContext(ctx context.Context, query *PromQLRangeQuery, nodes ...*SnowthNode) (*PromQLResponse, error)

+ func (sc *SnowthClient) ReadHistogramValues(uuid, metric string, period time.Duration, start, end time.Time, ...) ([]HistogramValue, error)

+ func (sc *SnowthClient) ReadHistogramValuesContext(ctx context.Context, uuid, metric string, period time.Duration, ...) ([]HistogramValue, error)

+ func (sc *SnowthClient) ReadNNTAllValues(start, end time.Time, period int64, id, metric string, nodes ...*SnowthNode) ([]NNTAllValue, error)

+ func (sc *SnowthClient) ReadNNTAllValuesContext(ctx context.Context, start, end time.Time, period int64, id, metric string, ...) ([]NNTAllValue, error)

+ func (sc *SnowthClient) ReadNNTValues(start, end time.Time, period int64, t, id, metric string, nodes ...*SnowthNode) ([]NNTValue, error)

+ func (sc *SnowthClient) ReadNNTValuesContext(ctx context.Context, start, end time.Time, period int64, t, id, metric string, ...) ([]NNTValue, error)

+ func (sc *SnowthClient) ReadNumericAllValues(start, end time.Time, period int64, id, metric string, nodes ...*SnowthNode) ([]NumericAllValue, error)

+ func (sc *SnowthClient) ReadNumericAllValuesContext(ctx context.Context, start, end time.Time, period int64, id, metric string, ...) ([]NumericAllValue, error)

+ func (sc *SnowthClient) ReadNumericValues(start, end time.Time, period int64, t, id, metric string, nodes ...*SnowthNode) ([]NumericValue, error)

+ func (sc *SnowthClient) ReadNumericValuesContext(ctx context.Context, start, end time.Time, period int64, t, id, metric string, ...) ([]NumericValue, error)

+ func (sc *SnowthClient) ReadRawNumericValues(start time.Time, end time.Time, uuid string, metric string, ...) ([]RawNumericValue, error)

+ func (sc *SnowthClient) ReadRawNumericValuesContext(ctx context.Context, start, end time.Time, uuid, metric string, ...) ([]RawNumericValue, error)

+ func (sc *SnowthClient) ReadRollupAllValues(uuid, metric string, period time.Duration, start, end time.Time, ...) ([]RollupAllValue, error)

+ func (sc *SnowthClient) ReadRollupAllValuesContext(ctx context.Context, uuid, metric string, period time.Duration, ...) ([]RollupAllValue, error)

+ func (sc *SnowthClient) ReadRollupValues(uuid, metric string, period time.Duration, start, end time.Time, ...) ([]RollupValue, error)

+ func (sc *SnowthClient) ReadRollupValuesContext(ctx context.Context, uuid, metric string, period time.Duration, ...) ([]RollupValue, error)

+ func (sc *SnowthClient) ReadTextValues(uuid, metric string, start, end time.Time, nodes ...*SnowthNode) ([]TextValue, error)

+ func (sc *SnowthClient) ReadTextValuesContext(ctx context.Context, uuid, metric string, start, end time.Time, ...) ([]TextValue, error)

+ func (sc *SnowthClient) RebuildActivity(node *SnowthNode, rebuildRequest []RebuildActivityRequest) (*IRONdbPutResponse, error)

+ func (sc *SnowthClient) RebuildActivityContext(ctx context.Context, node *SnowthNode, rebuildRequest []RebuildActivityRequest) (*IRONdbPutResponse, error)

+ func (sc *SnowthClient) Retries() int64

+ func (sc *SnowthClient) SetConnectRetries(num int64)

+ func (sc *SnowthClient) SetLog(log Logger)

+ func (sc *SnowthClient) SetRequestFunc(f func(r *http.Request) error)

+ func (sc *SnowthClient) SetRetries(num int64)

+ func (sc *SnowthClient) SetWatchInterval(d time.Duration)

+ func (sc *SnowthClient) Topology() (*Topology, error)

+ func (sc *SnowthClient) UpdateCheckTags(checkUUID string, tags []string, nodes ...*SnowthNode) (int64, error)

+ func (sc *SnowthClient) UpdateCheckTagsContext(ctx context.Context, checkUUID string, tags []string, nodes ...*SnowthNode) (int64, error)

+ func (sc *SnowthClient) WatchAndUpdate(ctx context.Context)

+ func (sc *SnowthClient) WriteHistogram(data []HistogramData, nodes ...*SnowthNode) error

+ func (sc *SnowthClient) WriteHistogramContext(ctx context.Context, data []HistogramData, nodes ...*SnowthNode) error

+ func (sc *SnowthClient) WriteNNT(data []NNTData, nodes ...*SnowthNode) error

+ func (sc *SnowthClient) WriteNNTBSFlatbuffer(merge *nntbs.NNTMergeT, builder *flatbuffers.Builder, nodes ...*SnowthNode) error

+ func (sc *SnowthClient) WriteNNTBSFlatbufferContext(ctx context.Context, merge *nntbs.NNTMergeT, builder *flatbuffers.Builder, ...) error

+ func (sc *SnowthClient) WriteNNTContext(ctx context.Context, data []NNTData, nodes ...*SnowthNode) error

+ func (sc *SnowthClient) WriteNumeric(data []NumericWrite, nodes ...*SnowthNode) error

+ func (sc *SnowthClient) WriteNumericContext(ctx context.Context, data []NumericWrite, nodes ...*SnowthNode) error

+ func (sc *SnowthClient) WriteRaw(data io.Reader, fb bool, dataPoints uint64, nodes ...*SnowthNode) (*IRONdbPutResponse, error)

+ func (sc *SnowthClient) WriteRawContext(ctx context.Context, data io.Reader, fb bool, dataPoints uint64, ...) (*IRONdbPutResponse, error)

+ func (sc *SnowthClient) WriteRawMetricList(metricList *noit.MetricListT, builder *flatbuffers.Builder, ...) (*IRONdbPutResponse, error)

+ func (sc *SnowthClient) WriteRawMetricListContext(ctx context.Context, metricList *noit.MetricListT, ...) (*IRONdbPutResponse, error)

+ func (sc *SnowthClient) WriteText(data []TextData, nodes ...*SnowthNode) error

+ func (sc *SnowthClient) WriteTextContext(ctx context.Context, data []TextData, nodes ...*SnowthNode) error

+ type SnowthNode struct

+ func (sn *SnowthNode) GetCurrentTopology() string

+ func (sn *SnowthNode) GetURL() *url.URL

+ func (sn *SnowthNode) SemVer() string

+ type Stats map[string]interface

+ func (ns *Stats) CurrentTopology() string

+ func (ns *Stats) Identity() string

+ func (ns *Stats) NextTopology() string

+ func (ns *Stats) SemVer() string

+ type Tag struct

+ Category string

+ Value string

+ type TextData struct

+ ID string

+ Metric string

+ Offset string

+ Value string

+ type TextValue struct

+ Time time.Time

+ Value *string

+ type TextValueResponse []TextValue

+ func (tvr *TextValueResponse) UnmarshalJSON(b []byte) error

+ type TopoSide uint8

+ func (i *TopoSide) UnmarshalXMLAttr(attr xml.Attr) error

+ func (i TopoSide) MarshalXMLAttr(name xml.Name) (xml.Attr, error)

+ type Topology struct

+ Hash string

+ Nodes []TopologyNode

+ OldWriteCopies uint8

+ WriteCopies uint8

+ XMLName xml.Name

+ func TopologyLoadXML(xml string) (*Topology, error)

+ func (topo *Topology) Find(s string) ([]TopologyNode, error)

+ func (topo *Topology) FindMetric(uuid, metric string) ([]TopologyNode, error)

+ func (topo *Topology) FindMetricN(uuid, metric string, n int) ([]TopologyNode, error)

+ func (topo *Topology) FindMetricNodeIDs(uuid, metric string) ([]string, error)

+ func (topo *Topology) FindN(s string, n int) ([]TopologyNode, error)

+ func (topo *Topology) Len() int

+ func (topo *Topology) Less(i, j int) bool

+ func (topo *Topology) Swap(i, j int)

+ type TopologyNode struct

+ APIPort uint16

+ Address string

+ ID string

+ Port uint16

+ Side TopoSide

+ Weight uint16

+ WriteCopies uint8

+ XMLName xml.Name