ledger

Documentation

Index

• type Client
  • func (c *Client) CreateMeasurement(meter *Meter, timestamp string, units float64) error
  • func (c *Client) ListMeters() ([]*Meter, error)
  • func (c *Client) PostMeasurementList(measurements *MeasurementList) error
• type Measurement
• type MeasurementList
• type Meter
  • func (m *Meter) Name() string
• type MeterList

Types

type Client

type Client struct {
	Scheme     string
	Host       string
	ClusterKey string
}

func (*Client) CreateMeasurement

func (c *Client) CreateMeasurement(meter *Meter, timestamp string, units float64) error

func (*Client) ListMeters

func (c *Client) ListMeters() ([]*Meter, error)

func (*Client) PostMeasurementList

func (c *Client) PostMeasurementList(measurements *MeasurementList) error

This uses the proxy, which utilizes the queue

type Measurement

type Measurement struct {
	MeterID   int64   `json:"meter_id,omitempty"`
	MeterName string  `json:"meter_name,omitempty"`
	Value     float64 `json:"value"`
	Time      string  `json:"time"`
}

type MeasurementList

type MeasurementList struct {
	Namespace    string            `json:"namespace,omitempty"`
	Pod          string            `json:"pod,omitempty"`
	Labels       map[string]string `json:"labels,omitempty"`
	Measurements []*Measurement    `json:"measurements,omitempty"`
}

type Meter

type Meter struct {
	ID              int64  `json:"id"`
	Type            string `json:"meter_type"`
	Value           string `json:"value"`
	TimespanMinutes int64  `json:"timespan_minutes"`
}

func (*Meter) Name

func (m *Meter) Name() string

type MeterList

type MeterList struct {
	Meters []*Meter `json:"meters"`
}