Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type InfluxServer ¶
type InfluxServer struct {
// contains filtered or unexported fields
}
func NewInfluxServer ¶
func NewInfluxServer(st *SeriesTable) *InfluxServer
func (*InfluxServer) Close ¶
func (is *InfluxServer) Close() error
func (*InfluxServer) Open ¶
func (is *InfluxServer) Open() error
type PointsConverter ¶
type PointsConverter struct {
// contains filtered or unexported fields
}
func NewPointsConverter ¶
func NewPointsConverter(st *SeriesTable) *PointsConverter
func (*PointsConverter) WritePoints ¶
func (pc *PointsConverter) WritePoints(p *cluster.WritePointsRequest) error
type Series ¶
type Series struct {
// contains filtered or unexported fields
}
func NewSeries ¶
func NewSeries(name SeriesName, tags SeriesTags) *Series
type SeriesName ¶
type SeriesName string
type SeriesTable ¶
func NewSeriesTable ¶
func NewSeriesTable() *SeriesTable
func (*SeriesTable) Insert ¶
func (st *SeriesTable) Insert(series *Series) error
func (*SeriesTable) Series ¶
func (st *SeriesTable) Series(key SeriesKey) *Series
type SeriesTags ¶
Click to show internal directories.
Click to hide internal directories.