store

Documentation

Index

• type InfluxDBClient
  • func NewInfluxDBClient(addr string, username string, password string, db string) *InfluxDBClient
  • func (idc *InfluxDBClient) Get(cmd string) (res []client.Result, err error)
  • func (idc *InfluxDBClient) RecordEventToInflux(e *api_v1.Event)
  • func (idc *InfluxDBClient) Write(measurement string, tags map[string]string, fields map[string]interface{}, ...)
• type RabbitMQClient
  • func NewRabbitMQClient(conf config.Config) (*RabbitMQClient, error)
  • func (rmc *RabbitMQClient) Close()
  • func (rmc *RabbitMQClient) Publish(msgBody []byte)

Types

type InfluxDBClient

type InfluxDBClient struct {
	// contains filtered or unexported fields
}

func NewInfluxDBClient

func NewInfluxDBClient(addr string, username string, password string, db string) *InfluxDBClient

func (*InfluxDBClient) Get

func (idc *InfluxDBClient) Get(cmd string) (res []client.Result, err error)

func (*InfluxDBClient) RecordEventToInflux

func (idc *InfluxDBClient) RecordEventToInflux(e *api_v1.Event)

func (*InfluxDBClient) Write

func (idc *InfluxDBClient) Write(measurement string, tags map[string]string, fields map[string]interface{}, t time.Time)

type RabbitMQClient

type RabbitMQClient struct {
	// contains filtered or unexported fields
}

func NewRabbitMQClient

func NewRabbitMQClient(conf config.Config) (*RabbitMQClient, error)

func (*RabbitMQClient) Close

func (rmc *RabbitMQClient) Close()

func (*RabbitMQClient) Publish

func (rmc *RabbitMQClient) Publish(msgBody []byte)