servertest

package
v1.0.5 Latest Latest
Warning

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

 Go to latest Published: Aug 2, 2021 License: Apache-2.0 Imports: 11 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewBufconnServer 

func NewBufconnServer(options *server.Options) *bufconnServer

Types

type BuffDialer 

type BuffDialer func(context.Context, string) (net.Conn, error)

type ServerMock added in v0.9.1 

type ServerMock struct {
	Srv *server.ImmuServer

	PostSetFn           func(context.Context, *schema.SetRequest, *schema.TxMetadata, error) (*schema.TxMetadata, error)
	PostVerifiableSetFn func(context.Context, *schema.VerifiableSetRequest, *schema.VerifiableTx, error) (*schema.VerifiableTx, error)

	PostSetReferenceFn           func(context.Context, *schema.ReferenceRequest, *schema.TxMetadata, error) (*schema.TxMetadata, error)
	PostVerifiableSetReferenceFn func(context.Context, *schema.VerifiableReferenceRequest, *schema.VerifiableTx, error) (*schema.VerifiableTx, error)

	PostZAddFn           func(context.Context, *schema.ZAddRequest, *schema.TxMetadata, error) (*schema.TxMetadata, error)
	PostVerifiableZAddFn func(context.Context, *schema.VerifiableZAddRequest, *schema.VerifiableTx, error) (*schema.VerifiableTx, error)

	PostExecAllFn func(context.Context, *schema.ExecAllRequest, *schema.TxMetadata, error) (*schema.TxMetadata, error)

	GetDbIndexFromCtx func(context.Context, string) (int64, error)
}

func (*ServerMock) ChangePassword added in v0.9.1 

func (s *ServerMock) ChangePassword(ctx context.Context, req *schema.ChangePasswordRequest) (*empty.Empty, error)

func (*ServerMock) ChangePermission added in v0.9.1 

func (s *ServerMock) ChangePermission(ctx context.Context, req *schema.ChangePermissionRequest) (*empty.Empty, error)

func (*ServerMock) CleanIndex added in v0.9.1 

func (s *ServerMock) CleanIndex(ctx context.Context, req *empty.Empty) (*empty.Empty, error)

func (*ServerMock) CompactIndex added in v1.0.5 

func (s *ServerMock) CompactIndex(ctx context.Context, req *empty.Empty) (*empty.Empty, error)

func (*ServerMock) Count added in v0.9.1 

func (s *ServerMock) Count(ctx context.Context, req *schema.KeyPrefix) (*schema.EntryCount, error)

func (*ServerMock) CountAll added in v0.9.1 

func (s *ServerMock) CountAll(ctx context.Context, req *empty.Empty) (*schema.EntryCount, error)

func (*ServerMock) CreateDatabase added in v0.9.1 

func (s *ServerMock) CreateDatabase(ctx context.Context, req *schema.Database) (*empty.Empty, error)

func (*ServerMock) CreateDatabaseWith added in v1.0.5 

func (s *ServerMock) CreateDatabaseWith(ctx context.Context, req *schema.DatabaseSettings) (*empty.Empty, error)

func (*ServerMock) CreateUser added in v0.9.1 

func (s *ServerMock) CreateUser(ctx context.Context, req *schema.CreateUserRequest) (*empty.Empty, error)

func (*ServerMock) CurrentState added in v0.9.1 

func (s *ServerMock) CurrentState(ctx context.Context, req *empty.Empty) (*schema.ImmutableState, error)

func (*ServerMock) DatabaseList added in v0.9.1 

func (s *ServerMock) DatabaseList(ctx context.Context, req *empty.Empty) (*schema.DatabaseListResponse, error)

func (*ServerMock) DescribeTable added in v1.0.0 

func (s *ServerMock) DescribeTable(ctx context.Context, req *schema.Table) (*schema.SQLQueryResult, error)

func (*ServerMock) ExecAll added in v0.9.1 

func (s *ServerMock) ExecAll(ctx context.Context, req *schema.ExecAllRequest) (*schema.TxMetadata, error)

func (*ServerMock) ExportTx added in v1.0.5 

func (s *ServerMock) ExportTx(req *schema.TxRequest, txsServer schema.ImmuService_ExportTxServer) error

func (*ServerMock) Get added in v0.9.1 

func (s *ServerMock) Get(ctx context.Context, req *schema.KeyRequest) (*schema.Entry, error)

func (*ServerMock) GetAll added in v0.9.1 

func (s *ServerMock) GetAll(ctx context.Context, req *schema.KeyListRequest) (*schema.Entries, error)

func (*ServerMock) Health added in v0.9.1 

func (s *ServerMock) Health(ctx context.Context, req *empty.Empty) (*schema.HealthResponse, error)

func (*ServerMock) History added in v0.9.1 

func (s *ServerMock) History(ctx context.Context, req *schema.HistoryRequest) (*schema.Entries, error)

func (*ServerMock) Initialize added in v0.9.2 

func (s *ServerMock) Initialize() error

func (*ServerMock) ListTables added in v1.0.0 

func (s *ServerMock) ListTables(ctx context.Context, req *empty.Empty) (*schema.SQLQueryResult, error)

func (*ServerMock) ListUsers added in v0.9.1 

func (s *ServerMock) ListUsers(ctx context.Context, req *empty.Empty) (*schema.UserList, error)

func (*ServerMock) Login added in v0.9.1 

func (s *ServerMock) Login(ctx context.Context, req *schema.LoginRequest) (*schema.LoginResponse, error)

func (*ServerMock) Logout added in v0.9.1 

func (s *ServerMock) Logout(ctx context.Context, req *empty.Empty) (*empty.Empty, error)

func (*ServerMock) ReplicateTx added in v1.0.5 

func (s *ServerMock) ReplicateTx(replicateTxServer schema.ImmuService_ReplicateTxServer) error

func (*ServerMock) SQLExec added in v1.0.0 

func (s *ServerMock) SQLExec(ctx context.Context, req *schema.SQLExecRequest) (*schema.SQLExecResult, error)

func (*ServerMock) SQLQuery added in v1.0.0 

func (s *ServerMock) SQLQuery(ctx context.Context, req *schema.SQLQueryRequest) (*schema.SQLQueryResult, error)

func (*ServerMock) Scan added in v0.9.1 

func (s *ServerMock) Scan(ctx context.Context, req *schema.ScanRequest) (*schema.Entries, error)

func (*ServerMock) Set added in v0.9.1 

func (s *ServerMock) Set(ctx context.Context, req *schema.SetRequest) (*schema.TxMetadata, error)

func (*ServerMock) SetActiveUser added in v0.9.1 

func (s *ServerMock) SetActiveUser(ctx context.Context, req *schema.SetActiveUserRequest) (*empty.Empty, error)

func (*ServerMock) SetReference added in v0.9.1 

func (s *ServerMock) SetReference(ctx context.Context, req *schema.ReferenceRequest) (*schema.TxMetadata, error)

func (*ServerMock) Stop added in v0.9.2 

func (s *ServerMock) Stop() error

func (*ServerMock) StreamExecAll added in v0.9.2 

func (s *ServerMock) StreamExecAll(allServer schema.ImmuService_StreamExecAllServer) error

func (*ServerMock) StreamGet added in v0.9.2 

func (s *ServerMock) StreamGet(request *schema.KeyRequest, getServer schema.ImmuService_StreamGetServer) error

func (*ServerMock) StreamHistory added in v0.9.2 

func (s *ServerMock) StreamHistory(request *schema.HistoryRequest, historyServer schema.ImmuService_StreamHistoryServer) error

func (*ServerMock) StreamScan added in v0.9.2 

func (s *ServerMock) StreamScan(request *schema.ScanRequest, scanServer schema.ImmuService_StreamScanServer) error

func (*ServerMock) StreamSet added in v0.9.2 

func (s *ServerMock) StreamSet(setServer schema.ImmuService_StreamSetServer) error

func (*ServerMock) StreamVerifiableGet added in v0.9.2 

func (s *ServerMock) StreamVerifiableGet(request *schema.VerifiableGetRequest, getServer schema.ImmuService_StreamVerifiableGetServer) error

func (*ServerMock) StreamVerifiableSet added in v0.9.2 

func (s *ServerMock) StreamVerifiableSet(vSetServer schema.ImmuService_StreamVerifiableSetServer) error

func (*ServerMock) StreamZScan added in v0.9.2 

func (s *ServerMock) StreamZScan(request *schema.ZScanRequest, zscanServer schema.ImmuService_StreamZScanServer) error

func (*ServerMock) TxById added in v0.9.1 

func (s *ServerMock) TxById(ctx context.Context, req *schema.TxRequest) (*schema.Tx, error)

func (*ServerMock) TxScan added in v0.9.1 

func (s *ServerMock) TxScan(ctx context.Context, req *schema.TxScanRequest) (*schema.TxList, error)

func (*ServerMock) UpdateAuthConfig added in v0.9.1 

func (s *ServerMock) UpdateAuthConfig(ctx context.Context, req *schema.AuthConfig) (*empty.Empty, error)

func (*ServerMock) UpdateDatabase added in v1.0.5 

func (s *ServerMock) UpdateDatabase(ctx context.Context, req *schema.DatabaseSettings) (*empty.Empty, error)

func (*ServerMock) UpdateMTLSConfig added in v0.9.1 

func (s *ServerMock) UpdateMTLSConfig(ctx context.Context, req *schema.MTLSConfig) (*empty.Empty, error)

func (*ServerMock) UseDatabase added in v0.9.1 

func (s *ServerMock) UseDatabase(ctx context.Context, req *schema.Database) (*schema.UseDatabaseReply, error)

func (*ServerMock) UseSnapshot added in v1.0.0 

func (s *ServerMock) UseSnapshot(ctx context.Context, req *schema.UseSnapshotRequest) (*empty.Empty, error)

func (*ServerMock) VerifiableGet added in v0.9.1 

func (s *ServerMock) VerifiableGet(ctx context.Context, req *schema.VerifiableGetRequest) (*schema.VerifiableEntry, error)

func (*ServerMock) VerifiableSQLGet added in v1.0.0 

func (s *ServerMock) VerifiableSQLGet(ctx context.Context, req *schema.VerifiableSQLGetRequest) (*schema.VerifiableSQLEntry, error)

func (*ServerMock) VerifiableSet added in v0.9.1 

func (s *ServerMock) VerifiableSet(ctx context.Context, req *schema.VerifiableSetRequest) (*schema.VerifiableTx, error)

func (*ServerMock) VerifiableSetReference added in v0.9.1 

func (s *ServerMock) VerifiableSetReference(ctx context.Context, req *schema.VerifiableReferenceRequest) (*schema.VerifiableTx, error)

func (*ServerMock) VerifiableTxById added in v0.9.1 

func (s *ServerMock) VerifiableTxById(ctx context.Context, req *schema.VerifiableTxRequest) (*schema.VerifiableTx, error)

func (*ServerMock) VerifiableZAdd added in v0.9.1 

func (s *ServerMock) VerifiableZAdd(ctx context.Context, req *schema.VerifiableZAddRequest) (*schema.VerifiableTx, error)

func (*ServerMock) ZAdd added in v0.9.1 

func (s *ServerMock) ZAdd(ctx context.Context, req *schema.ZAddRequest) (*schema.TxMetadata, error)

func (*ServerMock) ZScan added in v0.9.1 

func (s *ServerMock) ZScan(ctx context.Context, req *schema.ZScanRequest) (*schema.ZEntries, error)

Source Files

View all Source files

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.