Documentation ¶
Index ¶
- Constants
- Variables
- func NewReader(metrics []telegraf.Metric, serializer *Serializer) io.Reader
- type FieldError
- type FieldSortOrder
- type FieldTypeSupport
- type MetricError
- type Serializer
- func (s *Serializer) Serialize(m telegraf.Metric) ([]byte, error)
- func (s *Serializer) SerializeBatch(metrics []telegraf.Metric) ([]byte, error)
- func (s *Serializer) SetFieldSortOrder(order FieldSortOrder)
- func (s *Serializer) SetFieldTypeSupport(typeSupport FieldTypeSupport)
- func (s *Serializer) SetMaxLineBytes(bytes int)
- func (s *Serializer) Write(w io.Writer, m telegraf.Metric) (int, error)
Constants ¶
View Source
const MaxInt64 = int64(^uint64(0) >> 1)
Variables ¶
View Source
var ( NeedMoreSpace = "need more space" InvalidName = "invalid name" NoFields = "no serializable fields" )
Functions ¶
func NewReader ¶
func NewReader(metrics []telegraf.Metric, serializer *Serializer) io.Reader
NewReader creates a new reader over the given metrics.
Types ¶
type FieldError ¶
type FieldError struct {
// contains filtered or unexported fields
}
FieldError is an error causing a field to be unserializable.
func (FieldError) Error ¶
func (e FieldError) Error() string
type FieldSortOrder ¶
type FieldSortOrder int
const ( NoSortFields FieldSortOrder = iota SortFields )
type FieldTypeSupport ¶
type FieldTypeSupport int
const (
UintSupport FieldTypeSupport = 1 << iota
)
type MetricError ¶
type MetricError struct {
// contains filtered or unexported fields
}
MetricError is an error causing an entire metric to be unserializable.
func (MetricError) Error ¶
func (e MetricError) Error() string
type Serializer ¶
type Serializer struct {
// contains filtered or unexported fields
}
Serializer is a serializer for line protocol.
func NewSerializer ¶
func NewSerializer() *Serializer
func (*Serializer) Serialize ¶
func (s *Serializer) Serialize(m telegraf.Metric) ([]byte, error)
Serialize writes the telegraf.Metric to a byte slice. May produce multiple lines of output if longer than maximum line length. Lines are terminated with a newline (LF) char.
func (*Serializer) SerializeBatch ¶
func (s *Serializer) SerializeBatch(metrics []telegraf.Metric) ([]byte, error)
SerializeBatch writes the slice of metrics and returns a byte slice of the results. The returned byte slice may contain multiple lines of data.
func (*Serializer) SetFieldSortOrder ¶
func (s *Serializer) SetFieldSortOrder(order FieldSortOrder)
func (*Serializer) SetFieldTypeSupport ¶
func (s *Serializer) SetFieldTypeSupport(typeSupport FieldTypeSupport)
func (*Serializer) SetMaxLineBytes ¶
func (s *Serializer) SetMaxLineBytes(bytes int)
Click to show internal directories.
Click to hide internal directories.