stream

Documentation

Index

• func NewBackend(logger logger.Logger, cfg *frames.BackendConfig, framesConfig *frames.Config) (frames.DataBackend, error)
• type Backend
  • func (b *Backend) Create(request *frames.CreateRequest) error
  • func (b *Backend) Delete(request *frames.DeleteRequest) error
  • func (b *Backend) Exec(request *frames.ExecRequest) error
  • func (b *Backend) Read(request *frames.ReadRequest) (frames.FrameIterator, error)
  • func (b *Backend) Write(request *frames.WriteRequest) (frames.FrameAppender, error)

Functions

func NewBackend

func NewBackend(logger logger.Logger, cfg *frames.BackendConfig, framesConfig *frames.Config) (frames.DataBackend, error)

NewBackend return a new v3io stream backend

Types

type Backend

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

Backend is a tsdb backend

func (*Backend) Create

func (b *Backend) Create(request *frames.CreateRequest) error

Create creates a table

func (*Backend) Delete

func (b *Backend) Delete(request *frames.DeleteRequest) error

Delete deletes a table or part of it

func (*Backend) Exec

func (b *Backend) Exec(request *frames.ExecRequest) error

Exec executes a command

func (*Backend) Read

func (b *Backend) Read(request *frames.ReadRequest) (frames.FrameIterator, error)

func (*Backend) Write

func (b *Backend) Write(request *frames.WriteRequest) (frames.FrameAppender, error)