Documentation ¶
Index ¶
- type LcClientMock
- func (cm *LcClientMock) Connect() (err error)
- func (cm *LcClientMock) ConsistencyCheck(ctx context.Context) (*grpcclient.ConsistencyCheckResponse, error)
- func (cm *LcClientMock) CurrentState(ctx context.Context) (*immuschema.ImmutableState, error)
- func (cm *LcClientMock) ExecAll(ctx context.Context, in *immuschema.ExecAllRequest) (*immuschema.TxHeader, error)
- func (cm *LcClientMock) Feats(ctx context.Context) (*schema.Features, error)
- func (cm *LcClientMock) Get(ctx context.Context, key []byte) (*immuschema.Entry, error)
- func (cm *LcClientMock) GetAll(ctx context.Context, in *immuschema.KeyListRequest) (*immuschema.Entries, error)
- func (cm *LcClientMock) GetAt(ctx context.Context, key []byte, tx uint64) (*immuschema.Entry, error)
- func (cm *LcClientMock) GetFile(ctx context.Context, key []byte, filePath string) (*immuschema.Entry, error)
- func (cm *LcClientMock) Health(ctx context.Context) (*immuschema.HealthResponse, error)
- func (cm *LcClientMock) History(ctx context.Context, req *immuschema.HistoryRequest) (*immuschema.Entries, error)
- func (cm *LcClientMock) HistoryExt(ctx context.Context, options *immuschema.HistoryRequest) (sl *schema.ItemExtList, err error)
- func (cm *LcClientMock) IsConnected() bool
- func (cm *LcClientMock) Scan(ctx context.Context, req *immuschema.ScanRequest) (*immuschema.Entries, error)
- func (cm *LcClientMock) Set(ctx context.Context, key []byte, value []byte) (*immuschema.TxHeader, error)
- func (cm *LcClientMock) SetAll(ctx context.Context, kvList *immuschema.SetRequest) (*immuschema.TxHeader, error)
- func (cm *LcClientMock) SetFile(ctx context.Context, key []byte, filePath string) (*immuschema.TxHeader, error)
- func (cm *LcClientMock) SetMulti(ctx context.Context, req *schema.SetMultiRequest) (*schema.SetMultiResponse, error)
- func (cm *LcClientMock) SetServerSigningPubKey(key *ecdsa.PublicKey)
- func (cm *LcClientMock) StreamExecAll(ctx context.Context, req *stream.ExecAllRequest) (*immuschema.TxHeader, error)
- func (cm *LcClientMock) StreamGet(ctx context.Context, k *immuschema.KeyRequest) (*immuschema.Entry, error)
- func (cm *LcClientMock) StreamHistory(ctx context.Context, req *immuschema.HistoryRequest) (*immuschema.Entries, error)
- func (cm *LcClientMock) StreamScan(ctx context.Context, req *immuschema.ScanRequest) (*immuschema.Entries, error)
- func (cm *LcClientMock) StreamSet(ctx context.Context, kvs []*stream.KeyValue) (*immuschema.TxHeader, error)
- func (cm *LcClientMock) StreamVerifiedGet(ctx context.Context, req *immuschema.VerifiableGetRequest) (*immuschema.Entry, error)
- func (cm *LcClientMock) StreamVerifiedSet(ctx context.Context, kvs []*stream.KeyValue) (*immuschema.TxHeader, error)
- func (cm *LcClientMock) StreamZScan(ctx context.Context, req *immuschema.ZScanRequest) (*immuschema.ZEntries, error)
- func (cm *LcClientMock) VCNSetArtifacts(ctx context.Context, req *schema.VCNArtifactsRequest) (*schema.VCNArtifactsResponse, error)
- func (cm *LcClientMock) VerifiedGet(ctx context.Context, key []byte) (*immuschema.Entry, error)
- func (cm *LcClientMock) VerifiedGetAt(ctx context.Context, key []byte, tx uint64) (*immuschema.Entry, error)
- func (cm *LcClientMock) VerifiedGetExt(ctx context.Context, key []byte) (*schema.VerifiableItemExt, error)
- func (cm *LcClientMock) VerifiedGetExtAt(ctx context.Context, key []byte, tx uint64) (itemExt *schema.VerifiableItemExt, err error)
- func (cm *LcClientMock) VerifiedGetExtAtMulti(ctx context.Context, keys [][]byte, txs []uint64) (itemsExt []*schema.VerifiableItemExt, errs []string, err error)
- func (cm *LcClientMock) VerifiedGetExtSince(ctx context.Context, key []byte, tx uint64) (*schema.VerifiableItemExt, error)
- func (cm *LcClientMock) VerifiedGetSince(ctx context.Context, key []byte, tx uint64) (*immuschema.Entry, error)
- func (cm *LcClientMock) VerifiedSet(ctx context.Context, key []byte, value []byte) (*immuschema.TxHeader, error)
- func (cm *LcClientMock) ZScan(ctx context.Context, req *immuschema.ZScanRequest) (*immuschema.ZEntries, error)
- func (cm *LcClientMock) ZScanExt(ctx context.Context, options *immuschema.ZScanRequest) (*schema.ZItemExtList, error)
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 (cm *LcClientMock) ExecAll(ctx context.Context, in *immuschema.ExecAllRequest) (*immuschema.TxHeader, error)
func (*LcClientMock) Get ¶
func (cm *LcClientMock) Get(ctx context.Context, key []byte) (*immuschema.Entry, error)
func (*LcClientMock) GetAll ¶
func (cm *LcClientMock) GetAll(ctx context.Context, in *immuschema.KeyListRequest) (*immuschema.Entries, error)
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 (cm *LcClientMock) Health(ctx context.Context) (*immuschema.HealthResponse, error)
func (*LcClientMock) History ¶
func (cm *LcClientMock) History(ctx context.Context, req *immuschema.HistoryRequest) (*immuschema.Entries, error)
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 (cm *LcClientMock) Scan(ctx context.Context, req *immuschema.ScanRequest) (*immuschema.Entries, error)
func (*LcClientMock) Set ¶
func (cm *LcClientMock) Set(ctx context.Context, key []byte, value []byte) (*immuschema.TxHeader, error)
func (*LcClientMock) SetAll ¶
func (cm *LcClientMock) SetAll(ctx context.Context, kvList *immuschema.SetRequest) (*immuschema.TxHeader, error)
func (*LcClientMock) SetFile ¶
func (cm *LcClientMock) SetFile(ctx context.Context, key []byte, filePath string) (*immuschema.TxHeader, error)
func (*LcClientMock) SetMulti ¶
func (cm *LcClientMock) SetMulti(ctx context.Context, req *schema.SetMultiRequest) (*schema.SetMultiResponse, error)
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 (cm *LcClientMock) StreamGet(ctx context.Context, k *immuschema.KeyRequest) (*immuschema.Entry, error)
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 (cm *LcClientMock) StreamZScan(ctx context.Context, req *immuschema.ZScanRequest) (*immuschema.ZEntries, error)
func (*LcClientMock) VCNSetArtifacts ¶
func (cm *LcClientMock) VCNSetArtifacts(ctx context.Context, req *schema.VCNArtifactsRequest) (*schema.VCNArtifactsResponse, error)
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 (cm *LcClientMock) ZScan(ctx context.Context, req *immuschema.ZScanRequest) (*immuschema.ZEntries, error)
func (*LcClientMock) ZScanExt ¶
func (cm *LcClientMock) ZScanExt(ctx context.Context, options *immuschema.ZScanRequest) (*schema.ZItemExtList, error)
Click to show internal directories.
Click to hide internal directories.