 Documentation
      ¶
      Documentation
      ¶
    
    
  
    
  
    Index ¶
- Constants
- func ConvertToFloat64(v interface{}) (float64, error)
- func UnixMilli(t time.Time) int64
- type Bucketpoint
- type Client
- func (self *Client) Create(md MetricDefinition, o ...Modifier) (bool, error)
- func (self *Client) Definition(t MetricType, id string, o ...Modifier) (*MetricDefinition, error)
- func (self *Client) Definitions(o ...Modifier) ([]*MetricDefinition, error)
- func (self *Client) DeleteTags(t MetricType, id string, tags map[string]string, o ...Modifier) error
- func (self *Client) ReadBuckets(t MetricType, o ...Modifier) ([]*Bucketpoint, error)
- func (self *Client) ReadMetric(t MetricType, id string, o ...Modifier) ([]*Datapoint, error)
- func (self *Client) Send(o ...Modifier) (*http.Response, error)
- func (self *Client) Tags(t MetricType, id string, o ...Modifier) (map[string]string, error)
- func (self *Client) UpdateTags(t MetricType, id string, tags map[string]string, o ...Modifier) error
- func (self *Client) Url(method string, e ...Endpoint) Modifier
- func (self *Client) Write(metrics []MetricHeader, o ...Modifier) error
 
- type Datapoint
- type Endpoint
- type Filter
- func BucketsFilter(buckets int) Filter
- func EndTimeFilter(endTime time.Time) Filter
- func IdFilter(regexp string) Filter
- func Param(k string, v string) Filter
- func PercentilesFilter(percentiles []float64) Filter
- func StartTimeFilter(startTime time.Time) Filter
- func TagsFilter(t map[string]string) Filter
- func TypeFilter(t MetricType) Filter
 
- type HawkularClient
- type HawkularClientError
- type HawkularError
- type MetricDefinition
- type MetricHeader
- type MetricType
- type Modifier
- type Parameters
- type Percentile
- type SortKey
Constants ¶
      View Source
      
  
const ( Gauge = iota Availability Counter Generic )
Variables ¶
This section is empty.
Functions ¶
func ConvertToFloat64 ¶
Types ¶
type Bucketpoint ¶
type Bucketpoint struct {
	Start       int64        `json:"start"`
	End         int64        `json:"end"`
	Min         float64      `json:"min"`
	Max         float64      `json:"max"`
	Avg         float64      `json:"avg"`
	Median      float64      `json:"median"`
	Empty       bool         `json:"empty"`
	Samples     int64        `json:"samples"`
	Percentiles []Percentile `json:"percentiles"`
}
    TODO Fix the Start & End to return a time.Time
type Client ¶
func NewHawkularClient ¶
func NewHawkularClient(p Parameters) (*Client, error)
func (*Client) Create ¶
func (self *Client) Create(md MetricDefinition, o ...Modifier) (bool, error)
Create new Definition
func (*Client) Definition ¶
func (self *Client) Definition(t MetricType, id string, o ...Modifier) (*MetricDefinition, error)
Return a single definition
func (*Client) Definitions ¶
func (self *Client) Definitions(o ...Modifier) ([]*MetricDefinition, error)
Fetch definitions
func (*Client) DeleteTags ¶
func (self *Client) DeleteTags(t MetricType, id string, tags map[string]string, o ...Modifier) error
Delete given tags from the definition
func (*Client) ReadBuckets ¶
func (self *Client) ReadBuckets(t MetricType, o ...Modifier) ([]*Bucketpoint, error)
TODO ReadMetrics should be equal also, to read new tagsFilter aggregation..
func (*Client) ReadMetric ¶
Read data from the server
func (*Client) UpdateTags ¶
func (self *Client) UpdateTags(t MetricType, id string, tags map[string]string, o ...Modifier) error
Update tags
type Datapoint ¶
type Datapoint struct {
	Timestamp int64             `json:"timestamp"`
	Value     interface{}       `json:"value"`
	Tags      map[string]string `json:"tags,omitempty"`
}
    Value should be convertible to float64 for numeric values Timestamp is milliseconds since epoch
type Endpoint ¶
func DataEndpoint ¶
func DataEndpoint() Endpoint
func SingleMetricEndpoint ¶
func TagEndpoint ¶
func TagEndpoint() Endpoint
func TagsEndpoint ¶
func TypeEndpoint ¶
func TypeEndpoint(t MetricType) Endpoint
type Filter ¶
func BucketsFilter ¶
func EndTimeFilter ¶
func PercentilesFilter ¶
func StartTimeFilter ¶
func TagsFilter ¶
func TypeFilter ¶
func TypeFilter(t MetricType) Filter
type HawkularClientError ¶
type HawkularClientError struct {
	Code int
	// contains filtered or unexported fields
}
    More detailed error
func (*HawkularClientError) Error ¶
func (self *HawkularClientError) Error() string
type HawkularError ¶
type HawkularError struct {
	ErrorMsg string `json:"errorMsg"`
}
    type MetricDefinition ¶
type MetricHeader ¶
type MetricHeader struct {
	Tenant string      `json:"-"`
	Type   MetricType  `json:"-"`
	Id     string      `json:"id"`
	Data   []Datapoint `json:"data"`
}
    type MetricType ¶
type MetricType int
MetricType restrictions
func (MetricType) MarshalJSON ¶
func (self MetricType) MarshalJSON() ([]byte, error)
func (MetricType) String ¶
func (self MetricType) String() string
func (*MetricType) UnmarshalJSON ¶
func (self *MetricType) UnmarshalJSON(b []byte) error
Custom unmarshaller
type Parameters ¶
type Percentile ¶
type SortKey ¶
type SortKey struct {
	Tenant string
	Type   MetricType
}
     Click to show internal directories. 
   Click to hide internal directories.