storage

package
v0.0.0-...-6b4a898 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 8, 2021 License: GPL-3.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Storage

type Storage interface {
	Parser(b []byte) error
	Writer(p interface{}) error
	NewPoint(
		name string,
		labels map[string]string,
		values map[string]interface{},
		timestamp time.Time,
	) interface{}
	Close() error
}

type StorageInfluxDB

type StorageInfluxDB struct {
	MaxBatchSize uint
	// contains filtered or unexported fields
}

func NewStorageInfluxDB

func NewStorageInfluxDB(addr, db, auth string, batchSize uint) (*StorageInfluxDB, error)

func (*StorageInfluxDB) Close

func (si *StorageInfluxDB) Close() error

func (*StorageInfluxDB) NewPoint

func (si *StorageInfluxDB) NewPoint(
	name string,
	labels map[string]string,
	values map[string]interface{},
	timestamp time.Time,
) interface{}

func (*StorageInfluxDB) Parser

func (si *StorageInfluxDB) Parser(b []byte) error

func (*StorageInfluxDB) Writer

func (si *StorageInfluxDB) Writer(p interface{}) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL