server

Documentation

Index

• Constants
• type Membership
• type Server
  • func New(conf config.Func, monitor monitor.Monitor, cluster cluster.Membership, ...) *Server
  • func (s *Server) Close(monitor monitor.Monitor)
  • func (s *Server) Describe(ctx context.Context, _ *talaria.DescribeRequest) (*talaria.DescribeResponse, error)
  • func (s *Server) DescribeTable(ctx context.Context, request *talaria.DescribeTableRequest) (*talaria.DescribeTableResponse, error)
  • func (s *Server) GetNodes(ctx context.Context, request *talaria.GetNodesRequest) (*talaria.GetNodesResponse, error)
  • func (s *Server) GetRows(ctx context.Context, request *talaria.GetRowsRequest) (*talaria.GetRowsResponse, error)
  • func (s *Server) GetSplits(ctx context.Context, request *talaria.GetSplitsRequest) (*talaria.GetSplitsResponse, error)
  • func (s *Server) Ingest(ctx context.Context, request *talaria.IngestRequest) (*talaria.IngestResponse, error)
  • func (s *Server) IngestWithTable(ctx context.Context, request *talaria.IngestWithTableRequest) (*talaria.IngestResponse, error)
  • func (s *Server) Listen(ctx context.Context, prestoPort, grpcPort int32) error
  • func (s *Server) Members() []string
  • func (s *Server) PrestoGetIndexSplits(schemaTableName *presto.PrestoThriftSchemaTableName, indexColumnNames []string, ...) (*presto.PrestoThriftSplitBatch, error)
  • func (s *Server) PrestoGetRows(splitID *presto.PrestoThriftId, columns []string, maxBytes int64, ...) (*presto.PrestoThriftPageResult, error)
  • func (s *Server) PrestoGetSplits(schemaTableName *presto.PrestoThriftSchemaTableName, ...) (*presto.PrestoThriftSplitBatch, error)
  • func (s *Server) PrestoGetTableMetadata(schemaTableName *presto.PrestoThriftSchemaTableName) (*presto.PrestoThriftNullableTableMetadata, error)
  • func (s *Server) PrestoListSchemaNames() ([]string, error)
  • func (s *Server) PrestoListTables(schemaNameOrNull *presto.PrestoThriftNullableSchemaName) ([]*presto.PrestoThriftSchemaTableName, error)
• type SplitID
• type Storage

Constants

const Name = "proto"

This custom codec provides vtprotobuf helpers for dependencies.

Types

type Membership

type Membership interface {
	Members() []string
}

Membership represents a contract required for recovering cluster information.

type Server

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

Server represents the talaria server which should implement presto thrift interface.

func New

func New(conf config.Func, monitor monitor.Monitor, cluster cluster.Membership, tables ...table.Table) *Server

New creates a new talaria server.

func (*Server) Close

func (s *Server) Close(monitor monitor.Monitor)

Close closes the server and related resources.

func (*Server) Describe

func (s *Server) Describe(ctx context.Context, _ *talaria.DescribeRequest) (*talaria.DescribeResponse, error)

Describe returns the list of schema/table combinations and the metadata

func (*Server) DescribeTable

func (s *Server) DescribeTable(ctx context.Context, request *talaria.DescribeTableRequest) (*talaria.DescribeTableResponse, error)

DescribeTable returns the columns and metadata for a table in schema(logical; ex: data)

func (*Server) GetNodes

func (s *Server) GetNodes(ctx context.Context, request *talaria.GetNodesRequest) (*talaria.GetNodesResponse, error)

GetNodes returns the members list of talaria cluster.

func (*Server) GetRows

func (s *Server) GetRows(ctx context.Context, request *talaria.GetRowsRequest) (*talaria.GetRowsResponse, error)

GetRows returns the rows for a particular split

func (*Server) GetSplits

func (s *Server) GetSplits(ctx context.Context, request *talaria.GetSplitsRequest) (*talaria.GetSplitsResponse, error)

GetSplits returns the list of splits for a particular table/filter combination

func (*Server) Ingest

func (s *Server) Ingest(ctx context.Context, request *talaria.IngestRequest) (*talaria.IngestResponse, error)

Ingest implements ingress.IngressServer

func (*Server) IngestWithTable

func (s *Server) IngestWithTable(ctx context.Context, request *talaria.IngestWithTableRequest) (*talaria.IngestResponse, error)

func (*Server) Listen

func (s *Server) Listen(ctx context.Context, prestoPort, grpcPort int32) error

Listen starts listening on presto RPC & gRPC.

func (*Server) Members

func (s *Server) Members() []string

Members returns the nodes joining the talaria cluster.

func (*Server) PrestoGetIndexSplits

func (s *Server) PrestoGetIndexSplits(schemaTableName *presto.PrestoThriftSchemaTableName, indexColumnNames []string, outputColumnNames []string, keys *presto.PrestoThriftPageResult, outputConstraint *presto.PrestoThriftTupleDomain, maxSplitCount int32, nextToken *presto.PrestoThriftNullableToken) (*presto.PrestoThriftSplitBatch, error)

PrestoGetIndexSplits returns a batch of index splits for the given batch of keys.

func (*Server) PrestoGetRows

func (s *Server) PrestoGetRows(splitID *presto.PrestoThriftId, columns []string, maxBytes int64, nextToken *presto.PrestoThriftNullableToken) (*presto.PrestoThriftPageResult, error)

PrestoGetRows returns a batch of rows for the given split.

func (*Server) PrestoGetSplits

func (s *Server) PrestoGetSplits(schemaTableName *presto.PrestoThriftSchemaTableName, desiredColumns *presto.PrestoThriftNullableColumnSet, outputConstraint *presto.PrestoThriftTupleDomain, maxSplitCount int32, nextToken *presto.PrestoThriftNullableToken) (*presto.PrestoThriftSplitBatch, error)

PrestoGetSplits returns a batch of splits.

func (*Server) PrestoGetTableMetadata

func (s *Server) PrestoGetTableMetadata(schemaTableName *presto.PrestoThriftSchemaTableName) (*presto.PrestoThriftNullableTableMetadata, error)

PrestoGetTableMetadata returns metadata for a given table.

func (*Server) PrestoListSchemaNames

func (s *Server) PrestoListSchemaNames() ([]string, error)

PrestoListSchemaNames returns available schema names.

func (*Server) PrestoListTables

func (s *Server) PrestoListTables(schemaNameOrNull *presto.PrestoThriftNullableSchemaName) ([]*presto.PrestoThriftSchemaTableName, error)

PrestoListTables returns tables for the given schema name.

type SplitID

type SplitID struct {
	Table string // The name of the table
	Split []byte // The encoded split key
}

SplitID represents a split key along with the table name

type Storage

type Storage interface {
	io.Closer
	Append(key, value []byte, ttl time.Duration) error
	Range(seek, until []byte, f func(key, value []byte) bool) error
}

Storage represents an eventlog storage contract.