structs

Documentation

Index

• type DSoptions
• type DataOperations
• type Downsample
• type FilterValueOperation
• type Key
• type Merge
• type RateOperation
• type Settings
• type SettingsHTTP
• type SettingsUDP
• type TSDBfilter
• type TSDBquery
• type TSDBqueryPayload
  • func (query TSDBqueryPayload) Validate() gobol.Error
• type TSDBrateOptions
• type TsLog
• type TsQuery
  • func (query *TsQuery) GetRe() *regexp.Regexp
  • func (query *TsQuery) Validate() gobol.Error

Types

type DSoptions

type DSoptions struct {
	Downsample string `json:"approximation"`
	Unit       string `json:"unit"`
	Value      int    `json:"value"`
	Fill       string
}

type DataOperations

type DataOperations struct {
	Downsample  Downsample
	Merge       string
	Rate        RateOperation
	Order       []string
	FilterValue FilterValueOperation
}

type Downsample

type Downsample struct {
	Enabled     bool      `json:"enabled"`
	PointLimit  bool      `json:"pointLimit"`
	TotalPoints int       `json:"totalPoints"`
	Options     DSoptions `json:"options"`
}

type FilterValueOperation

type FilterValueOperation struct {
	Enabled  bool
	BoolOper string
	Value    float64
}

type Key

type Key struct {
	TSid string `json:"tsid"`
}

type Merge

type Merge struct {
	Option string `json:"option"`
	Keys   []Key  `json:"keys"`
}

type RateOperation

type RateOperation struct {
	Enabled bool
	Options TSDBrateOptions
}

type Settings

type Settings struct {
	ReadConsistency         []string
	WriteConsisteny         []string
	BoltPath                string
	MaxTimeseries           int
	MaxConcurrentTimeseries int
	MaxConcurrentReads      int
	LogQueryTSthreshold     int
	MaxConcurrentPoints     int
	MaxConcurrentBulks      int
	MaxMetaBulkSize         int
	MetaBufferSize          int
	MetaSaveInterval        string
	CompactionStrategy      string
	HTTPserver              SettingsHTTP
	UDPserver               SettingsUDP
	UDPserverV2             SettingsUDP
	Cassandra               cassandra.Settings
	TTL                     struct {
		Max int
	}
	Logs struct {
		General saw.Settings
		Stats   saw.Settings
	}
	Stats     snitch.Settings
	StatsFile struct {
		Path string
	}
	ElasticSearch struct {
		Cluster rubber.Settings
		Index   string
	}
	Probe struct {
		Threshold float64
	}
}

type SettingsHTTP

type SettingsHTTP struct {
	Path string
	Port string
	Bind string
}

type SettingsUDP

type SettingsUDP struct {
	Port       string
	ReadBuffer int
}

type TSDBfilter

type TSDBfilter struct {
	Ftype   string `json:"type"`
	Tagk    string `json:"tagk"`
	Filter  string `json:"filter"`
	GroupBy bool   `json:"groupBy"`
}

type TSDBquery

type TSDBquery struct {
	Aggregator  string            `json:"aggregator"`
	Downsample  string            `json:"downsample,omitempty"`
	Metric      string            `json:"metric"`
	Tags        map[string]string `json:"tags"`
	Rate        bool              `json:"rate,omitempty"`
	RateOptions TSDBrateOptions   `json:"rateOptions,omitempty"`
	Order       []string          `json:"order,omitempty"`
	FilterValue string            `json:"filterValue,omitempty"`
	Filters     []TSDBfilter      `json:"filters,omitempty"`
}

type TSDBqueryPayload

type TSDBqueryPayload struct {
	Start        int64       `json:"start,omitempty"`
	End          int64       `json:"end,omitempty"`
	Relative     string      `json:"relative,omitempty"`
	Queries      []TSDBquery `json:"queries"`
	ShowTSUIDs   bool        `json:"showTSUIDs"`
	MsResolution bool        `json:"msResolution"`
}

func (TSDBqueryPayload) Validate

func (query TSDBqueryPayload) Validate() gobol.Error

type TSDBrateOptions

type TSDBrateOptions struct {
	Counter    bool   `json:"counter"`
	CounterMax *int64 `json:"counterMax,omitempty"`
	ResetValue int64  `json:"resetValue,omitempty"`
}

type TsLog

type TsLog struct {
	General *logrus.Logger
	Stats   *logrus.Logger
}

type TsQuery

type TsQuery struct {
	Downsample Downsample       `json:"downsample"`
	Start      int64            `json:"start"`
	End        int64            `json:"end"`
	Keys       []Key            `json:"keys"`
	Merge      map[string]Merge `json:"merge"`
	Text       []Key            `json:"text"`
	TextSearch string           `json:"textSearch"`
	// contains filtered or unexported fields
}

func (*TsQuery) GetRe

func (query *TsQuery) GetRe() *regexp.Regexp

func (*TsQuery) Validate

func (query *TsQuery) Validate() gobol.Error