Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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)
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)
Click to show internal directories.
Click to hide internal directories.