tsdb

Documentation

Index

• func NewBackend(logger logger.Logger, v3ioContext v3io.Context, cfg *frames.BackendConfig, ...) (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) (frames.Frame, error)
  • func (b *Backend) GetAdapter(session *frames.Session, password string, token string, path string) (*tsdb.V3ioAdapter, error)
  • func (b *Backend) GetQuerier(session *frames.Session, password string, token string, path string) (*pquerier.V3ioQuerier, 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, v3ioContext v3io.Context, cfg *frames.BackendConfig, framesConfig *frames.Config) (frames.DataBackend, error)

NewBackend returns a new TSDB 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 TSDB 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) (frames.Frame, error)

Exec executes a command

func (*Backend) GetAdapter

func (b *Backend) GetAdapter(session *frames.Session, password string, token string, path string) (*tsdb.V3ioAdapter, error)

GetAdapter returns an adapter

func (*Backend) GetQuerier

func (b *Backend) GetQuerier(session *frames.Session, password string, token string, path string) (*pquerier.V3ioQuerier, error)

GetQuerier returns a querier

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)