tspoint

Documentation

Index

• type RawPoint
  • func SinkTransform(ctx api.StreamContext, data any, options *WriteOptions) ([]*RawPoint, error)
• type WriteOptions
  • func (o *WriteOptions) Validate() error
  • func (o *WriteOptions) ValidateTagTemplates(ctx api.StreamContext) error

Types

type RawPoint

type RawPoint struct {
	Fields map[string]any
	Tags   map[string]string
	Tt     time.Time
	Ts     int64
}

func SinkTransform

func SinkTransform(ctx api.StreamContext, data any, options *WriteOptions) ([]*RawPoint, error)

type WriteOptions

type WriteOptions struct {
	PrecisionStr string `json:"precision"`

	Tags        map[string]string `json:"tags"`
	TsFieldName string            `json:"tsFieldName"`
}

func (*WriteOptions) Validate

func (o *WriteOptions) Validate() error

func (*WriteOptions) ValidateTagTemplates

func (o *WriteOptions) ValidateTagTemplates(ctx api.StreamContext) error