influx

Documentation

Index

• Variables
• func NewInflux(logger logger.Logger) bindings.OutputBinding
• type Influx
  • func (i *Influx) Close() error
  • func (i *Influx) GetComponentMetadata() map[string]string
  • func (i *Influx) Init(_ context.Context, 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.New("invalid operation type. Expected " + string(queryOperation) + " or " + string(bindings.CreateOperation))
	ErrMetadataMissing         = errors.New("metadata required")
	ErrMetadataRawNotFound     = errors.New("required metadata not set: " + 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) GetComponentMetadata

func (i *Influx) GetComponentMetadata() map[string]string

GetComponentMetadata returns the metadata of the component.

func (*Influx) Init

func (i *Influx) Init(_ context.Context, 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.