clienttest

package
v0.9.0-RC1 Latest Latest
Warning

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

 Go to latest Published: Dec 22, 2020 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Overview

Package clienttest ...

Package clienttest ...

Package clienttest ...

Package clienttest ...

Package clienttest ...

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type HomedirServiceMock 

type HomedirServiceMock struct {
	client.HomedirService
	WriteFileToUserHomeDirF    func(content []byte, pathToFile string) error
	FileExistsInUserHomeDirF   func(pathToFile string) (bool, error)
	ReadFileFromUserHomeDirF   func(pathToFile string) (string, error)
	DeleteFileFromUserHomeDirF func(pathToFile string) error
}

HomedirServiceMock ...

func DefaultHomedirServiceMock 

func DefaultHomedirServiceMock() *HomedirServiceMock

DefaultHomedirServiceMock ...

func (*HomedirServiceMock) DeleteFileFromUserHomeDir 

func (h *HomedirServiceMock) DeleteFileFromUserHomeDir(pathToFile string) error

DeleteFileFromUserHomeDir ...

func (*HomedirServiceMock) FileExistsInUserHomeDir 

func (h *HomedirServiceMock) FileExistsInUserHomeDir(pathToFile string) (bool, error)

FileExistsInUserHomeDir ...

func (*HomedirServiceMock) ReadFileFromUserHomeDir 

func (h *HomedirServiceMock) ReadFileFromUserHomeDir(pathToFile string) (string, error)

ReadFileFromUserHomeDir ...

func (*HomedirServiceMock) WriteFileToUserHomeDir 

func (h *HomedirServiceMock) WriteFileToUserHomeDir(content []byte, pathToFile string) error

WriteFileToUserHomeDir ...

type ImmuClientMock 

type ImmuClientMock struct {
	immuclient.ImmuClient

	GetOptionsF           func() *client.Options
	IsConnectedF          func() bool
	HealthCheckF          func(context.Context) error
	WaitForHealthCheckF   func(context.Context) error
	ConnectF              func(context.Context) (*grpc.ClientConn, error)
	DisconnectF           func() error
	LoginF                func(context.Context, []byte, []byte) (*schema.LoginResponse, error)
	LogoutF               func(context.Context) error
	VerifiedGetF          func(context.Context, []byte, ...grpc.CallOption) (*schema.Entry, error)
	VerifiedSetF          func(context.Context, []byte, []byte) (*schema.TxMetadata, error)
	SetF                  func(context.Context, []byte, []byte) (*schema.TxMetadata, error)
	SetReferenceF         func(context.Context, []byte, []byte, uint64) (*schema.TxMetadata, error)
	VerifiedSetReferenceF func(context.Context, []byte, []byte, uint64) (*schema.TxMetadata, error)
	ZAddF                 func(context.Context, []byte, float64, []byte, uint64) (*schema.TxMetadata, error)
	VerifiedZAddF         func(context.Context, []byte, float64, []byte, uint64) (*schema.TxMetadata, error)
	HistoryF              func(context.Context, *schema.HistoryRequest) (*schema.Entries, error)
	UseDatabaseF          func(context.Context, *schema.Database) (*schema.UseDatabaseReply, error)
	DumpF                 func(context.Context, io.WriteSeeker) (int64, error)
	CurrentStateF         func(context.Context) (*schema.ImmutableState, error)
	TxByIDF               func(context.Context, uint64) (*schema.Tx, error)
	GetF                  func(context.Context, []byte) (*schema.Entry, error)
	VerifiedTxByIDF       func(context.Context, uint64) (*schema.Tx, error)
	ListUsersF            func(context.Context) (*schema.UserList, error)
	SetActiveUserF        func(context.Context, *schema.SetActiveUserRequest) error
	ChangePermissionF     func(context.Context, schema.PermissionAction, string, string, uint32) error
	ZScanF                func(context.Context, *schema.ZScanRequest) (*schema.ZEntries, error)
	ScanF                 func(context.Context, *schema.ScanRequest) (*schema.Entries, error)
	CountF                func(context.Context, []byte) (*schema.EntryCount, error)
	CreateDatabaseF       func(context.Context, *schema.Database) error
	DatabaseListF         func(context.Context) (*schema.DatabaseListResponse, error)
	ChangePasswordF       func(context.Context, []byte, []byte, []byte) error
	CreateUserF           func(context.Context, []byte, []byte, uint32, string) error
}

ImmuClientMock ...

func (*ImmuClientMock) ChangePassword 

func (icm *ImmuClientMock) ChangePassword(ctx context.Context, user []byte, oldPass []byte, newPass []byte) error

ChangePassword ...

func (*ImmuClientMock) ChangePermission 

func (icm *ImmuClientMock) ChangePermission(ctx context.Context, action schema.PermissionAction, username string, database string, permissions uint32) error

ChangePermission ...

func (*ImmuClientMock) Connect 

func (icm *ImmuClientMock) Connect(ctx context.Context) (clientConn *grpc.ClientConn, err error)

Connect ...

func (*ImmuClientMock) Count 

func (icm *ImmuClientMock) Count(ctx context.Context, prefix []byte) (*schema.EntryCount, error)

Count ...

func (*ImmuClientMock) CreateDatabase 

func (icm *ImmuClientMock) CreateDatabase(ctx context.Context, db *schema.Database) error

CreateDatabase ...

func (*ImmuClientMock) CreateUser 

func (icm *ImmuClientMock) CreateUser(ctx context.Context, user []byte, pass []byte, permission uint32, databasename string) error

CreateUser ...

func (*ImmuClientMock) CurrentState added in v0.9.0 

func (icm *ImmuClientMock) CurrentState(ctx context.Context) (*schema.ImmutableState, error)

CurrentState ...

func (*ImmuClientMock) DatabaseList 

func (icm *ImmuClientMock) DatabaseList(ctx context.Context) (*schema.DatabaseListResponse, error)

DatabaseList ...

func (*ImmuClientMock) Disconnect 

func (icm *ImmuClientMock) Disconnect() error

Disconnect ...

func (*ImmuClientMock) Dump 

func (icm *ImmuClientMock) Dump(ctx context.Context, writer io.WriteSeeker) (int64, error)

Dump ...

func (*ImmuClientMock) Get 

func (icm *ImmuClientMock) Get(ctx context.Context, key []byte) (*schema.Entry, error)

Get ...

func (*ImmuClientMock) GetOptions 

func (icm *ImmuClientMock) GetOptions() *client.Options

GetOptions ...

func (*ImmuClientMock) HealthCheck 

func (icm *ImmuClientMock) HealthCheck(ctx context.Context) error

HealthCheck ...

func (*ImmuClientMock) History 

func (icm *ImmuClientMock) History(ctx context.Context, options *schema.HistoryRequest) (*schema.Entries, error)

History ...

func (*ImmuClientMock) IsConnected 

func (icm *ImmuClientMock) IsConnected() bool

IsConnected ...

func (*ImmuClientMock) ListUsers 

func (icm *ImmuClientMock) ListUsers(ctx context.Context) (*schema.UserList, error)

ListUsers ...

func (*ImmuClientMock) Login 

func (icm *ImmuClientMock) Login(ctx context.Context, user []byte, pass []byte) (*schema.LoginResponse, error)

Login ...

func (*ImmuClientMock) Logout 

func (icm *ImmuClientMock) Logout(ctx context.Context) error

Logout ...

func (*ImmuClientMock) Scan 

func (icm *ImmuClientMock) Scan(ctx context.Context, request *schema.ScanRequest) (*schema.Entries, error)

Scan ...

func (*ImmuClientMock) Set 

func (icm *ImmuClientMock) Set(ctx context.Context, key []byte, value []byte) (*schema.TxMetadata, error)

Set ...

func (*ImmuClientMock) SetActiveUser 

func (icm *ImmuClientMock) SetActiveUser(ctx context.Context, u *schema.SetActiveUserRequest) error

SetActiveUser ...

func (*ImmuClientMock) SetReference added in v0.9.0 

func (icm *ImmuClientMock) SetReference(ctx context.Context, reference []byte, key []byte, tx uint64) (*schema.TxMetadata, error)

SetReference ...

func (*ImmuClientMock) TxByID added in v0.9.0 

func (icm *ImmuClientMock) TxByID(ctx context.Context, ID uint64) (*schema.Tx, error)

TxByID ...

func (*ImmuClientMock) UseDatabase 

func (icm *ImmuClientMock) UseDatabase(ctx context.Context, d *schema.Database) (*schema.UseDatabaseReply, error)

UseDatabase ...

func (*ImmuClientMock) VerifiedGet added in v0.9.0 

func (icm *ImmuClientMock) VerifiedGet(ctx context.Context, key []byte, opts ...grpc.CallOption) (*schema.Entry, error)

VerifiedGet ...

func (*ImmuClientMock) VerifiedSet added in v0.9.0 

func (icm *ImmuClientMock) VerifiedSet(ctx context.Context, key []byte, value []byte) (*schema.TxMetadata, error)

VerifiedSet ...

func (*ImmuClientMock) VerifiedSetReference added in v0.9.0 

func (icm *ImmuClientMock) VerifiedSetReference(ctx context.Context, reference []byte, key []byte, tx uint64) (*schema.TxMetadata, error)

VerifiedSetReference ...

func (*ImmuClientMock) VerifiedTxByID added in v0.9.0 

func (icm *ImmuClientMock) VerifiedTxByID(ctx context.Context, tx uint64) (*schema.Tx, error)

VerifiedTxByID ...

func (*ImmuClientMock) VerifiedZAdd added in v0.9.0 

func (icm *ImmuClientMock) VerifiedZAdd(ctx context.Context, set []byte, score float64, key []byte, tx uint64) (*schema.TxMetadata, error)

SafeZAdd ...

func (*ImmuClientMock) WaitForHealthCheck 

func (icm *ImmuClientMock) WaitForHealthCheck(ctx context.Context) (err error)

WaitForHealthCheck ...

func (*ImmuClientMock) ZAdd 

func (icm *ImmuClientMock) ZAdd(ctx context.Context, set []byte, score float64, key []byte, tx uint64) (*schema.TxMetadata, error)

ZAdd ...

func (*ImmuClientMock) ZScan 

func (icm *ImmuClientMock) ZScan(ctx context.Context, request *schema.ZScanRequest) (*schema.ZEntries, error)

ZScan ...

type PasswordReaderMock 

type PasswordReaderMock struct {
	ReadF func(msg string) ([]byte, error)
}

PasswordReaderMock ...

func (*PasswordReaderMock) Read 

func (pr *PasswordReaderMock) Read(msg string) ([]byte, error)

type TerminalReaderMock 

type TerminalReaderMock struct {
	Counter             int
	Responses           []string
	ReadFromTerminalYNF func(string) (string, error)
}

TerminalReaderMock ...

func (*TerminalReaderMock) ReadFromTerminalYN 

func (t *TerminalReaderMock) ReadFromTerminalYN(def string) (selected string, err error)

ReadFromTerminalYN ...

type TokenServiceMock added in v0.7.1 

type TokenServiceMock struct {
	client.TokenService
	GetTokenF       func() (string, error)
	SetTokenF       func(database string, token string) error
	IsTokenPresentF func() (bool, error)
	DeleteTokenF    func() error
}

func DefaultTokenServiceMock added in v0.7.1 

func DefaultTokenServiceMock() *TokenServiceMock

DefaultHomedirServiceMock ...

func (TokenServiceMock) DeleteToken added in v0.7.1 

func (ts TokenServiceMock) DeleteToken() error

func (TokenServiceMock) GetDatabase added in v0.7.1 

func (ts TokenServiceMock) GetDatabase() (string, error)

func (TokenServiceMock) GetToken added in v0.7.1 

func (ts TokenServiceMock) GetToken() (string, error)

func (TokenServiceMock) IsTokenPresent added in v0.7.1 

func (ts TokenServiceMock) IsTokenPresent() (bool, error)

func (TokenServiceMock) SetToken added in v0.7.1 

func (ts TokenServiceMock) SetToken(database string, token string) error

func (TokenServiceMock) WithHds added in v0.7.1 

func (ts TokenServiceMock) WithHds(hds client.HomedirService) client.TokenService

func (TokenServiceMock) WithTokenFileName added in v0.7.1 

func (ts TokenServiceMock) WithTokenFileName(tfn string) client.TokenService

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.