Help us shape the future of Go! Take the 2026 Go Developer Survey

server

package
v1.6.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 1, 2023 License: MIT Imports: 29 Imported by: 0

Documentation

Index

Constants

View Source 
const Name = "proto"

This custom codec provides vtprotobuf helpers for dependencies.

Variables

This section is empty.

Functions

This section is empty.

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 added in v1.6.1 

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 added in v1.6.1 

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 added in v1.6.1 

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 added in v1.6.1 

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.

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.