Documentation
¶
Index ¶
- func Init(producer *kafka.Producer)
- func NewTsDbReader(ctx context.Context, options ...func(any)) (def.TsdbReader, error)
- func NewTsDbWriter(ctx context.Context, options ...func(any)) (def.TsdbWriter, error)
- func WithBucket(bucket string) func(any)
- func WithEndpoint(endpoint string) func(any)
- func WithField(k string, v any) func(any)
- func WithFields(fields map[string]any) func(any)
- func WithMetric(measurement string) func(any)
- func WithOrg(org string) func(any)
- func WithTag(k, v string) func(any)
- func WithTags(tags map[string]string) func(any)
- func WithToken(token string) func(any)
- type Metric
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewTsDbReader ¶ added in v0.0.12
func NewTsDbWriter ¶ added in v0.0.11
func WithBucket ¶ added in v0.0.11
func WithEndpoint ¶ added in v0.0.11
func WithFields ¶ added in v0.0.11
func WithMetric ¶ added in v0.0.11
Types ¶
Click to show internal directories.
Click to hide internal directories.