timeseries

Documentation

Index

• type Config
• type Membership
• type Table
  • func New(cluster Membership, monitor monitor.Monitor, store storage.Storage, cfg Config) *Table
  • func (t *Table) Append(block block.Block) error
  • func (t *Table) Close() error
  • func (t *Table) GetRows(splitID []byte, requestedColumns []string, maxBytes int64) (result *table.PageResult, err error)
  • func (t *Table) GetSplits(desiredColumns []string, outputConstraint *presto.PrestoThriftTupleDomain, ...) ([]table.Split, error)
  • func (t *Table) Name() string
  • func (t *Table) Schema() (typeof.Schema, error)

Types

type Config

type Config struct {
	Name   string
	TTL    int64
	HashBy string
	SortBy string
	Schema func() *typeof.Schema
}

Config represents the configuration of the storage

type Membership

type Membership interface {
	Members() []string
}

Membership represents a contract required for recovering cluster information.

type Table

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

Table represents a timeseries table.

func New

func New(cluster Membership, monitor monitor.Monitor, store storage.Storage, cfg Config) *Table

New creates a new table implementation.

func (*Table) Append

func (t *Table) Append(block block.Block) error

Append appends a block to the store.

func (*Table) Close

func (t *Table) Close() error

Close implements io.Closer interface.

func (*Table) GetRows

func (t *Table) GetRows(splitID []byte, requestedColumns []string, maxBytes int64) (result *table.PageResult, err error)

GetRows retrieves the data

func (*Table) GetSplits

func (t *Table) GetSplits(desiredColumns []string, outputConstraint *presto.PrestoThriftTupleDomain, maxSplitCount int) ([]table.Split, error)

GetSplits retrieves the splits

func (*Table) Name

func (t *Table) Name() string

Name returns the name of the table.

func (*Table) Schema

func (t *Table) Schema() (typeof.Schema, error)

Schema retrieves the metadata for the table