Documentation ¶
Index ¶
- func NewBufconnServer(options *server.Options) *bufconnServer
- type BuffDialer
- type ServerMock
- func (s *ServerMock) ChangePassword(ctx context.Context, req *schema.ChangePasswordRequest) (*empty.Empty, error)
- func (s *ServerMock) ChangePermission(ctx context.Context, req *schema.ChangePermissionRequest) (*empty.Empty, error)
- func (s *ServerMock) CleanIndex(ctx context.Context, req *empty.Empty) (*empty.Empty, error)
- func (s *ServerMock) Count(ctx context.Context, req *schema.KeyPrefix) (*schema.EntryCount, error)
- func (s *ServerMock) CountAll(ctx context.Context, req *empty.Empty) (*schema.EntryCount, error)
- func (s *ServerMock) CreateDatabase(ctx context.Context, req *schema.Database) (*empty.Empty, error)
- func (s *ServerMock) CreateUser(ctx context.Context, req *schema.CreateUserRequest) (*empty.Empty, error)
- func (s *ServerMock) CurrentState(ctx context.Context, req *empty.Empty) (*schema.ImmutableState, error)
- func (s *ServerMock) DatabaseList(ctx context.Context, req *empty.Empty) (*schema.DatabaseListResponse, error)
- func (s *ServerMock) DescribeTable(ctx context.Context, req *schema.Table) (*schema.SQLQueryResult, error)
- func (s *ServerMock) ExecAll(ctx context.Context, req *schema.ExecAllRequest) (*schema.TxMetadata, error)
- func (s *ServerMock) Get(ctx context.Context, req *schema.KeyRequest) (*schema.Entry, error)
- func (s *ServerMock) GetAll(ctx context.Context, req *schema.KeyListRequest) (*schema.Entries, error)
- func (s *ServerMock) Health(ctx context.Context, req *empty.Empty) (*schema.HealthResponse, error)
- func (s *ServerMock) History(ctx context.Context, req *schema.HistoryRequest) (*schema.Entries, error)
- func (s *ServerMock) Initialize() error
- func (s *ServerMock) ListTables(ctx context.Context, req *empty.Empty) (*schema.SQLQueryResult, error)
- func (s *ServerMock) ListUsers(ctx context.Context, req *empty.Empty) (*schema.UserList, error)
- func (s *ServerMock) Login(ctx context.Context, req *schema.LoginRequest) (*schema.LoginResponse, error)
- func (s *ServerMock) Logout(ctx context.Context, req *empty.Empty) (*empty.Empty, error)
- func (s *ServerMock) SQLExec(ctx context.Context, req *schema.SQLExecRequest) (*schema.SQLExecResult, error)
- func (s *ServerMock) SQLQuery(ctx context.Context, req *schema.SQLQueryRequest) (*schema.SQLQueryResult, error)
- func (s *ServerMock) Scan(ctx context.Context, req *schema.ScanRequest) (*schema.Entries, error)
- func (s *ServerMock) Set(ctx context.Context, req *schema.SetRequest) (*schema.TxMetadata, error)
- func (s *ServerMock) SetActiveUser(ctx context.Context, req *schema.SetActiveUserRequest) (*empty.Empty, error)
- func (s *ServerMock) SetReference(ctx context.Context, req *schema.ReferenceRequest) (*schema.TxMetadata, error)
- func (s *ServerMock) Stop() error
- func (s *ServerMock) StreamExecAll(allServer schema.ImmuService_StreamExecAllServer) error
- func (s *ServerMock) StreamGet(request *schema.KeyRequest, getServer schema.ImmuService_StreamGetServer) error
- func (s *ServerMock) StreamHistory(request *schema.HistoryRequest, ...) error
- func (s *ServerMock) StreamScan(request *schema.ScanRequest, scanServer schema.ImmuService_StreamScanServer) error
- func (s *ServerMock) StreamSet(setServer schema.ImmuService_StreamSetServer) error
- func (s *ServerMock) StreamVerifiableGet(request *schema.VerifiableGetRequest, ...) error
- func (s *ServerMock) StreamVerifiableSet(vSetServer schema.ImmuService_StreamVerifiableSetServer) error
- func (s *ServerMock) StreamZScan(request *schema.ZScanRequest, zscanServer schema.ImmuService_StreamZScanServer) error
- func (s *ServerMock) TxById(ctx context.Context, req *schema.TxRequest) (*schema.Tx, error)
- func (s *ServerMock) TxScan(ctx context.Context, req *schema.TxScanRequest) (*schema.TxList, error)
- func (s *ServerMock) UpdateAuthConfig(ctx context.Context, req *schema.AuthConfig) (*empty.Empty, error)
- func (s *ServerMock) UpdateMTLSConfig(ctx context.Context, req *schema.MTLSConfig) (*empty.Empty, error)
- func (s *ServerMock) UseDatabase(ctx context.Context, req *schema.Database) (*schema.UseDatabaseReply, error)
- func (s *ServerMock) UseSnapshot(ctx context.Context, req *schema.UseSnapshotRequest) (*empty.Empty, error)
- func (s *ServerMock) VerifiableGet(ctx context.Context, req *schema.VerifiableGetRequest) (*schema.VerifiableEntry, error)
- func (s *ServerMock) VerifiableSQLGet(ctx context.Context, req *schema.VerifiableSQLGetRequest) (*schema.VerifiableSQLEntry, error)
- func (s *ServerMock) VerifiableSet(ctx context.Context, req *schema.VerifiableSetRequest) (*schema.VerifiableTx, error)
- func (s *ServerMock) VerifiableSetReference(ctx context.Context, req *schema.VerifiableReferenceRequest) (*schema.VerifiableTx, error)
- func (s *ServerMock) VerifiableTxById(ctx context.Context, req *schema.VerifiableTxRequest) (*schema.VerifiableTx, error)
- func (s *ServerMock) VerifiableZAdd(ctx context.Context, req *schema.VerifiableZAddRequest) (*schema.VerifiableTx, error)
- func (s *ServerMock) ZAdd(ctx context.Context, req *schema.ZAddRequest) (*schema.TxMetadata, error)
- func (s *ServerMock) ZScan(ctx context.Context, req *schema.ZScanRequest) (*schema.ZEntries, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewBufconnServer ¶
Types ¶
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 (*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 (*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) 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) Login ¶ added in v0.9.1
func (s *ServerMock) Login(ctx context.Context, req *schema.LoginRequest) (*schema.LoginResponse, 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) 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) 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)
Click to show internal directories.
Click to hide internal directories.