cnctest

package
v0.0.11 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type LcClientMock

type LcClientMock struct {
	grpcclient.LcClient
	ConsistencyCheckF func(ctx context.Context) (*grpcclient.ConsistencyCheckResponse, error)
	IsConnectedF      func() bool
	FeatsF            func(ctx context.Context) (*schema.Features, error)
	HealthF           func(ctx context.Context) (*immuschema.HealthResponse, error)
}

func (*LcClientMock) Connect

func (cm *LcClientMock) Connect() (err error)

func (*LcClientMock) ConsistencyCheck

func (cm *LcClientMock) ConsistencyCheck(ctx context.Context) (*grpcclient.ConsistencyCheckResponse, error)

func (*LcClientMock) CurrentState

func (cm *LcClientMock) CurrentState(ctx context.Context) (*immuschema.ImmutableState, error)

func (*LcClientMock) ExecAll

func (*LcClientMock) Feats

func (cm *LcClientMock) Feats(ctx context.Context) (*schema.Features, error)

func (*LcClientMock) Get

func (cm *LcClientMock) Get(ctx context.Context, key []byte) (*immuschema.Entry, error)

func (*LcClientMock) GetAll

func (*LcClientMock) GetAt

func (cm *LcClientMock) GetAt(ctx context.Context, key []byte, tx uint64) (*immuschema.Entry, error)

func (*LcClientMock) GetFile

func (cm *LcClientMock) GetFile(ctx context.Context, key []byte, filePath string) (*immuschema.Entry, error)

func (*LcClientMock) Health

func (*LcClientMock) History

func (*LcClientMock) HistoryExt

func (cm *LcClientMock) HistoryExt(ctx context.Context, options *immuschema.HistoryRequest) (sl *schema.ItemExtList, err error)

func (*LcClientMock) IsConnected

func (cm *LcClientMock) IsConnected() bool

func (*LcClientMock) Scan

func (*LcClientMock) Set

func (cm *LcClientMock) Set(ctx context.Context, key []byte, value []byte) (*immuschema.TxHeader, error)

func (*LcClientMock) SetAll

func (*LcClientMock) SetFile

func (cm *LcClientMock) SetFile(ctx context.Context, key []byte, filePath string) (*immuschema.TxHeader, error)

func (*LcClientMock) SetMulti

func (*LcClientMock) SetServerSigningPubKey

func (cm *LcClientMock) SetServerSigningPubKey(key *ecdsa.PublicKey)

func (*LcClientMock) StreamExecAll

func (cm *LcClientMock) StreamExecAll(ctx context.Context, req *stream.ExecAllRequest) (*immuschema.TxHeader, error)

func (*LcClientMock) StreamGet

func (*LcClientMock) StreamHistory

func (cm *LcClientMock) StreamHistory(ctx context.Context, req *immuschema.HistoryRequest) (*immuschema.Entries, error)

func (*LcClientMock) StreamScan

func (cm *LcClientMock) StreamScan(ctx context.Context, req *immuschema.ScanRequest) (*immuschema.Entries, error)

func (*LcClientMock) StreamSet

func (cm *LcClientMock) StreamSet(ctx context.Context, kvs []*stream.KeyValue) (*immuschema.TxHeader, error)

func (*LcClientMock) StreamVerifiedGet

func (cm *LcClientMock) StreamVerifiedGet(ctx context.Context, req *immuschema.VerifiableGetRequest) (*immuschema.Entry, error)

func (*LcClientMock) StreamVerifiedSet

func (cm *LcClientMock) StreamVerifiedSet(ctx context.Context, kvs []*stream.KeyValue) (*immuschema.TxHeader, error)

func (*LcClientMock) StreamZScan

func (*LcClientMock) VCNSetArtifacts

func (*LcClientMock) VerifiedGet

func (cm *LcClientMock) VerifiedGet(ctx context.Context, key []byte) (*immuschema.Entry, error)

func (*LcClientMock) VerifiedGetAt

func (cm *LcClientMock) VerifiedGetAt(ctx context.Context, key []byte, tx uint64) (*immuschema.Entry, error)

func (*LcClientMock) VerifiedGetExt

func (cm *LcClientMock) VerifiedGetExt(ctx context.Context, key []byte) (*schema.VerifiableItemExt, error)

func (*LcClientMock) VerifiedGetExtAt

func (cm *LcClientMock) VerifiedGetExtAt(ctx context.Context, key []byte, tx uint64) (itemExt *schema.VerifiableItemExt, err error)

func (*LcClientMock) VerifiedGetExtAtMulti

func (cm *LcClientMock) VerifiedGetExtAtMulti(ctx context.Context, keys [][]byte, txs []uint64) (itemsExt []*schema.VerifiableItemExt, errs []string, err error)

func (*LcClientMock) VerifiedGetExtSince

func (cm *LcClientMock) VerifiedGetExtSince(ctx context.Context, key []byte, tx uint64) (*schema.VerifiableItemExt, error)

func (*LcClientMock) VerifiedGetSince

func (cm *LcClientMock) VerifiedGetSince(ctx context.Context, key []byte, tx uint64) (*immuschema.Entry, error)

func (*LcClientMock) VerifiedSet

func (cm *LcClientMock) VerifiedSet(ctx context.Context, key []byte, value []byte) (*immuschema.TxHeader, error)

func (*LcClientMock) ZScan

func (*LcClientMock) ZScanExt

func (cm *LcClientMock) ZScanExt(ctx context.Context, options *immuschema.ZScanRequest) (*schema.ZItemExtList, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL