influxdb

Documentation

Index

• type InfluxDBLogBackendRepository
  • func New(influxDBClient *influxdb_conn.Connection, expireDuration time.Duration) (*InfluxDBLogBackendRepository, error)
  • func (inf *InfluxDBLogBackendRepository) Fetch(logName string, tagFilterMap map[string]string, start, end time.Time) ([]interface{}, error)
  • func (inf *InfluxDBLogBackendRepository) FetchAll(logName string, tagFilterMap map[string]string) ([]interface{}, error)
  • func (inf *InfluxDBLogBackendRepository) ForceFlush() error
  • func (inf *InfluxDBLogBackendRepository) Write(logName string, tagMap map[string]string, data string, eventTime time.Time) error

Types

type InfluxDBLogBackendRepository

type InfluxDBLogBackendRepository struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func New

func New(
	influxDBClient *influxdb_conn.Connection,
	expireDuration time.Duration,
) (*InfluxDBLogBackendRepository, error)

func (*InfluxDBLogBackendRepository) Fetch

func (inf *InfluxDBLogBackendRepository) Fetch(
	logName string, tagFilterMap map[string]string, start, end time.Time,
) ([]interface{}, error)

func (*InfluxDBLogBackendRepository) FetchAll

func (inf *InfluxDBLogBackendRepository) FetchAll(
	logName string, tagFilterMap map[string]string,
) ([]interface{}, error)

func (*InfluxDBLogBackendRepository) ForceFlush

func (inf *InfluxDBLogBackendRepository) ForceFlush() error

func (*InfluxDBLogBackendRepository) Write

func (inf *InfluxDBLogBackendRepository) Write(
	logName string, tagMap map[string]string, data string,
	eventTime time.Time,
) error