server

package
v0.0.0-...-3903214 Latest Latest
Warning

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

 Go to latest Published: Apr 6, 2021 License: Apache-2.0 Imports: 43 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CorsHandler 

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

CorsHandler adds Cors Header if `cors` config is set.

func (CorsHandler) ServeHTTP 

func (h CorsHandler) ServeHTTP(w http.ResponseWriter, req *http.Request)

type IDriver 

type IDriver interface {
	// OpenCtx opens an IContext with connection id, client capability, collation, dbname and optionally the tls state.
	// OpenCtx(connID uint64, capability uint32, collation uint8, dbname string, tlsState *tls.ConnectionState) (QueryCtx, error)
	OpenCtx(connID uint64, dbname string) (QueryCtx, error)
}

IDriver opens IContext.

type PreparedStatement 

type PreparedStatement interface {
	// ID returns statement ID
	ID() int

	// Execute executes the statement.
	Execute(context.Context, ...interface{}) (ResultSet, error)

	// AppendParam appends parameter to the statement.
	AppendParam(paramID int, data []byte) error

	// NumParams returns number of parameters.
	NumParams() int

	// BoundParams returns bound parameters.
	BoundParams() [][]byte

	// SetParamsType sets type for parameters.
	SetParamsType([]byte)

	// GetParamsType returns the type for parameters.
	GetParamsType() []byte

	// StoreResultSet stores ResultSet for subsequent stmt fetching
	StoreResultSet(rs ResultSet)

	// GetResultSet gets ResultSet associated this statement
	GetResultSet() ResultSet

	// Reset removes all bound parameters.
	Reset()

	// Close closes the statement.
	Close() error
}

PreparedStatement is the interface to use a prepared statement.

type QueryCtx 

type QueryCtx interface {
	// CurrentDB returns current DB.
	CurrentDB() string

	GetSession() session.Session

	// SetValue saves a value associated with this context for key.
	SetValue(key fmt.Stringer, value interface{})

	// Close closes the QueryCtx.
	Close() error
}

QueryCtx is the interface to execute command.

type RPCServer 

type RPCServer struct {
	tspb.TablestoreAdminServer
	tspb.TablestoreServer
	// contains filtered or unexported fields
}

RPCServer implements tablestore gRPC server

func NewRPCServer 

func NewRPCServer(s *Server) *RPCServer

NewRPCServer xxx

func (*RPCServer) AddColumn 

func (rs *RPCServer) AddColumn(ctx context.Context, req *tspb.AddColumnRequest) (*tspb.AddColumnResponse, error)

func (*RPCServer) AlterTable 

func (rs *RPCServer) AlterTable(ctx context.Context, req *tspb.AlterTableRequest) (*tspb.AlterTableResponse, error)

AlterTable xxx

func (*RPCServer) BatchCreateSessions 

func (rs *RPCServer) BatchCreateSessions(ctx context.Context, req *tspb.BatchCreateSessionsRequest) (*tspb.BatchCreateSessionsResponse, error)

BatchCreateSessions creates multiple new sessions.

func (*RPCServer) BeginTransaction 

func (rs *RPCServer) BeginTransaction(ctx context.Context, req *tspb.BeginTransactionRequest) (*tspb.Transaction, error)

BeginTransaction begins a new transaction. This step can often be skipped:

func (*RPCServer) Close 

func (rs *RPCServer) Close()

func (*RPCServer) Commit 

func (rs *RPCServer) Commit(ctx context.Context, req *tspb.CommitRequest) (*tspb.CommitResponse, error)

Commit commits a transaction. The request includes the mutations to be applied to rows in the database.

`Commit` might return an `ABORTED` error. This can occur at any time; commonly, the cause is conflicts with concurrent transactions. However, it can also happen for a variety of other reasons. If `Commit` returns `ABORTED`, the caller should re-attempt the transaction from the beginning, re-using the same session.

func (*RPCServer) CreateDatabase 

func (rs *RPCServer) CreateDatabase(ctx context.Context, req *tspb.CreateDatabaseRequest) (*tspb.CreateDatabaseResponse, error)

CreateDatabase xxx

func (*RPCServer) CreateIndex 

func (rs *RPCServer) CreateIndex(ctx context.Context, req *tspb.CreateIndexRequest) (*tspb.CreateIndexResponse, error)

CreateIndex xxx

func (*RPCServer) CreateSession 

func (rs *RPCServer) CreateSession(ctx context.Context, req *tspb.CreateSessionRequest) (*tspb.Session, error)

CreateSession Creates a new session.

func (*RPCServer) CreateTable 

func (rs *RPCServer) CreateTable(ctx context.Context, req *tspb.CreateTableRequest) (*tspb.CreateTableResponse, error)

CreateTable xxx

func (*RPCServer) DeleteDatabase 

func (rs *RPCServer) DeleteDatabase(ctx context.Context, req *tspb.DeleteDatabaseRequest) (*tspb.DeleteDatabaseResponse, error)

DeleteDatabase xxx

func (*RPCServer) DeleteSession 

func (rs *RPCServer) DeleteSession(ctx context.Context, req *tspb.DeleteSessionRequest) (*emptypb.Empty, error)

DeleteSession ends a session, releasing server resources associated with it. This will asynchronously trigger cancellation of any operations that are running with this session.

func (*RPCServer) DropIndex 

func (rs *RPCServer) DropIndex(ctx context.Context, req *tspb.DropIndexRequest) (*tspb.DropIndexResponse, error)

DropIndex xxx

func (*RPCServer) DropTable 

func (rs *RPCServer) DropTable(ctx context.Context, req *tspb.DropTableRequest) (*tspb.DropTableResponse, error)

DropTable xxx

func (*RPCServer) GetSession 

func (rs *RPCServer) GetSession(ctx context.Context, req *tspb.GetSessionRequest) (*tspb.Session, error)

GetSession gets a session. Returns NOT_FOUND if the session does not exist. This is mainly useful for determining whether a session is still alive.

func (*RPCServer) ListDatabase 

func (rs *RPCServer) ListDatabase(ctx context.Context, req *tspb.ListDatabaseRequest) (*tspb.ListDatabaseResponse, error)

func (*RPCServer) ListSessions 

func (rs *RPCServer) ListSessions(ctx context.Context, req *tspb.ListSessionsRequest) (*tspb.ListSessionsResponse, error)

ListSessions lists all sessions in a given database.

func (*RPCServer) ListTables 

func (rs *RPCServer) ListTables(ctx context.Context,
	req *tspb.ListTableByDatabaseRequest) (*tspb.ListTableByDatabaseResponse, error)

func (*RPCServer) Mutate 

func (rs *RPCServer) Mutate(ctx context.Context, req *tspb.MutationRequest) (*tspb.MutationResponse, error)

Mutate mutate request

func (*RPCServer) Read 

func (rs *RPCServer) Read(ctx context.Context, req *tspb.ReadRequest) (*tspb.ResultSet, error)

Read reads rows from the database using key lookups and scans, as a simple key/value style alternative to

func (*RPCServer) Rollback 

func (rs *RPCServer) Rollback(ctx context.Context, req *tspb.RollbackRequest) (*emptypb.Empty, error)

Rollback xxx

func (*RPCServer) Run 

func (rs *RPCServer) Run()

func (*RPCServer) SparseRead 

func (rs *RPCServer) SparseRead(ctx context.Context, req *tspb.SparseReadRequest) (*tspb.ResultSet, error)

SparseRead reads rows from the database using key lookups and scans, as a simple key/value style alternative to

func (*RPCServer) SparseScan 

func (rs *RPCServer) SparseScan(ctx context.Context, req *tspb.SparseScanRequest) (*tspb.ResultSet, error)

SparseScan reads rows from the database using key lookups and scans, as a simple key/value style alternative to

func (*RPCServer) StreamingRead 

func (rs *RPCServer) StreamingRead(req *tspb.ReadRequest, stream tspb.Tablestore_StreamingReadServer) error

StreamingRead xxx

func (*RPCServer) StreamingSparseRead 

func (rs *RPCServer) StreamingSparseRead(req *tspb.SparseReadRequest, stream tspb.Tablestore_StreamingSparseReadServer) error

StreamingSparseRead xxx

func (*RPCServer) StreamingSparseScan 

func (rs *RPCServer) StreamingSparseScan(req *tspb.SparseScanRequest, stream tspb.Tablestore_StreamingSparseScanServer) error

StreamingSparseScan xxx

type ResultSet 

type ResultSet interface {
	// Columns() []*ColumnInfo
	NewChunk() *chunk.Chunk
	Next(context.Context, *chunk.Chunk) error
	StoreFetchedRows(rows []chunk.Row)
	GetFetchedRows() []chunk.Row
	Close() error
}

ResultSet is the result set of an query.

type Server 

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

Server is the GRPC Server

func NewServer 

func NewServer(cfg *config.Config, driver IDriver) (*Server, error)

NewServer return a new Server

func (*Server) Chore 

func (s *Server) Chore()

func (*Server) Close 

func (s *Server) Close()

func (*Server) Config 

func (s *Server) Config() *config.Config

func (*Server) Run 

func (s *Server) Run() error

Run runs the server.

type ZettaContext 

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

ZettaContext implements QueryCtx

func (*ZettaContext) Close 

func (zc *ZettaContext) Close() error

func (*ZettaContext) CurrentDB 

func (zc *ZettaContext) CurrentDB() string

func (*ZettaContext) Execute 

func (zc *ZettaContext) Execute(ctx context.Context, query interface{}) ([]ResultSet, error)

func (*ZettaContext) GetSession 

func (zc *ZettaContext) GetSession() session.Session

func (*ZettaContext) SetValue 

func (zc *ZettaContext) SetValue(key fmt.Stringer, value interface{})

type ZettaDriver 

type ZettaDriver struct {
	Store kv.Storage
}

ZettaDriver implements IDriver.

func NewZettaDriver 

func NewZettaDriver(store kv.Storage) *ZettaDriver

NewZettaDriver creates a new ZettaDriver

func (*ZettaDriver) OpenCtx 

func (zd *ZettaDriver) OpenCtx(connId uint64, dbname string) (QueryCtx, error)

OpenCtx xxx

Source Files

View all Source files

Directories

Path Synopsis
hbase

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.