influx

Documentation

Index

• Variables
• func NewInflux(logger logger.Logger) bindings.OutputBinding
• type Influx
  • func (i *Influx) Close() error
  • func (i *Influx) Init(metadata bindings.Metadata) error
  • func (i *Influx) Invoke(ctx context.Context, req *bindings.InvokeRequest) (*bindings.InvokeResponse, error)
  • func (i *Influx) Operations() []bindings.OperationKind

Variables

var (
	ErrInvalidRequestData      = errors.New("Influx Error: Cannot convert request data")
	ErrCannotWriteRecord       = errors.New("Influx Error: Cannot write point")
	ErrInvalidRequestOperation = errors.Errorf("invalid operation type. Expected %s or %s", queryOperation, bindings.CreateOperation)
	ErrMetadataMissing         = errors.New("metadata required")
	ErrMetadataRawNotFound     = errors.Errorf("required metadata not set: %s", rawQueryKey)
)

Functions

func NewInflux

func NewInflux(logger logger.Logger) bindings.OutputBinding

NewInflux returns a new kafka binding instance.

Types

type Influx

type Influx struct {
	// contains filtered or unexported fields
}

Influx allows writing to InfluxDB.

func (*Influx) Close

func (i *Influx) Close() error

func (*Influx) Init

func (i *Influx) Init(metadata bindings.Metadata) error

Init does metadata parsing and connection establishment.

func (*Influx) Invoke

func (i *Influx) Invoke(ctx context.Context, req *bindings.InvokeRequest) (*bindings.InvokeResponse, error)

Invoke called on supported operations.

func (*Influx) Operations

func (i *Influx) Operations() []bindings.OperationKind

Operations returns supported operations.