Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterLcServiceServer(s grpc.ServiceRegistrar, srv LcServiceServer)
- type Data
- func (*Data) Descriptor() ([]byte, []int)deprecated
- func (x *Data) GetData() []byte
- func (x *Data) GetDbName() string
- func (x *Data) GetKey() string
- func (x *Data) GetMsgID() int64
- func (x *Data) GetOperation() string
- func (x *Data) GetTableName() string
- func (*Data) ProtoMessage()
- func (x *Data) ProtoReflect() protoreflect.Message
- func (x *Data) Reset()
- func (x *Data) String() string
- type DataValue
- func (*DataValue) Descriptor() ([]byte, []int)deprecated
- func (x *DataValue) GetName() string
- func (x *DataValue) GetType() string
- func (x *DataValue) GetValue() []byte
- func (*DataValue) ProtoMessage()
- func (x *DataValue) ProtoReflect() protoreflect.Message
- func (x *DataValue) Reset()
- func (x *DataValue) String() string
- type Features
- func (*Features) Descriptor() ([]byte, []int)deprecated
- func (x *Features) GetBuildTime() string
- func (x *Features) GetComponent() string
- func (x *Features) GetFeat() []string
- func (x *Features) GetVersion() string
- func (x *Features) Map() map[string]bool
- func (*Features) ProtoMessage()
- func (x *Features) ProtoReflect() protoreflect.Message
- func (x *Features) Reset()
- func (x *Features) String() string
- type ItemExt
- func (*ItemExt) Descriptor() ([]byte, []int)deprecated
- func (x *ItemExt) GetApikeyRevoked() *timestamp.Timestamp
- func (x *ItemExt) GetItem() *schema.Entry
- func (x *ItemExt) GetLedgerName() string
- func (x *ItemExt) GetTimestamp() *timestamp.Timestamp
- func (*ItemExt) ProtoMessage()
- func (x *ItemExt) ProtoReflect() protoreflect.Message
- func (x *ItemExt) Reset()
- func (x *ItemExt) String() string
- type ItemExtList
- type LcServiceClient
- type LcServiceServer
- type LcService_SendDataClient
- type LcService_SendDataServer
- type LcService_StreamExecAllClient
- type LcService_StreamExecAllServer
- type LcService_StreamGetClient
- type LcService_StreamGetServer
- type LcService_StreamHistoryClient
- type LcService_StreamHistoryServer
- type LcService_StreamScanClient
- type LcService_StreamScanServer
- type LcService_StreamSetClient
- type LcService_StreamSetServer
- type LcService_StreamVerifiableGetClient
- type LcService_StreamVerifiableGetServer
- type LcService_StreamVerifiableSetClient
- type LcService_StreamVerifiableSetServer
- type LcService_StreamZScanClient
- type LcService_StreamZScanServer
- type ReportOptions
- func (*ReportOptions) Descriptor() ([]byte, []int)deprecated
- func (x *ReportOptions) GetPayload() *TamperReport
- func (x *ReportOptions) GetSignature() *schema.Signature
- func (*ReportOptions) ProtoMessage()
- func (x *ReportOptions) ProtoReflect() protoreflect.Message
- func (x *ReportOptions) Reset()
- func (x *ReportOptions) String() string
- type Response
- func (*Response) Descriptor() ([]byte, []int)deprecated
- func (x *Response) GetMsg() string
- func (x *Response) GetMsgID() int64
- func (x *Response) GetState() *schema.ImmutableState
- func (x *Response) GetStatus() int32
- func (x *Response) GetVerifiableTx() *schema.VerifiableTx
- func (*Response) ProtoMessage()
- func (x *Response) ProtoReflect() protoreflect.Message
- func (x *Response) Reset()
- func (x *Response) String() string
- type TamperReport
- func (*TamperReport) Descriptor() ([]byte, []int)deprecated
- func (x *TamperReport) GetIndex() uint64
- func (x *TamperReport) GetKey() []byte
- func (x *TamperReport) GetRoot() []byte
- func (*TamperReport) ProtoMessage()
- func (x *TamperReport) ProtoReflect() protoreflect.Message
- func (x *TamperReport) Reset()
- func (x *TamperReport) String() string
- type UnimplementedLcServiceServer
- func (UnimplementedLcServiceServer) CurrentState(context.Context, *empty.Empty) (*schema.ImmutableState, error)
- func (UnimplementedLcServiceServer) ExecAll(context.Context, *schema.ExecAllRequest) (*schema.TxMetadata, error)
- func (UnimplementedLcServiceServer) Feats(context.Context, *empty.Empty) (*Features, error)
- func (UnimplementedLcServiceServer) Get(context.Context, *schema.KeyRequest) (*schema.Entry, error)
- func (UnimplementedLcServiceServer) GetAll(context.Context, *schema.KeyListRequest) (*schema.Entries, error)
- func (UnimplementedLcServiceServer) Health(context.Context, *empty.Empty) (*schema.HealthResponse, error)
- func (UnimplementedLcServiceServer) History(context.Context, *schema.HistoryRequest) (*schema.Entries, error)
- func (UnimplementedLcServiceServer) HistoryExt(context.Context, *schema.HistoryRequest) (*ItemExtList, error)
- func (UnimplementedLcServiceServer) ReportTamper(context.Context, *ReportOptions) (*empty.Empty, error)
- func (UnimplementedLcServiceServer) Scan(context.Context, *schema.ScanRequest) (*schema.Entries, error)
- func (UnimplementedLcServiceServer) SendData(LcService_SendDataServer) error
- func (UnimplementedLcServiceServer) Set(context.Context, *schema.SetRequest) (*schema.TxMetadata, error)
- func (UnimplementedLcServiceServer) StreamExecAll(LcService_StreamExecAllServer) error
- func (UnimplementedLcServiceServer) StreamGet(*schema.KeyRequest, LcService_StreamGetServer) error
- func (UnimplementedLcServiceServer) StreamHistory(*schema.HistoryRequest, LcService_StreamHistoryServer) error
- func (UnimplementedLcServiceServer) StreamScan(*schema.ScanRequest, LcService_StreamScanServer) error
- func (UnimplementedLcServiceServer) StreamSet(LcService_StreamSetServer) error
- func (UnimplementedLcServiceServer) StreamVerifiableGet(*schema.VerifiableGetRequest, LcService_StreamVerifiableGetServer) error
- func (UnimplementedLcServiceServer) StreamVerifiableSet(LcService_StreamVerifiableSetServer) error
- func (UnimplementedLcServiceServer) StreamZScan(*schema.ZScanRequest, LcService_StreamZScanServer) error
- func (UnimplementedLcServiceServer) VerifiableGet(context.Context, *schema.VerifiableGetRequest) (*schema.VerifiableEntry, error)
- func (UnimplementedLcServiceServer) VerifiableGetExt(context.Context, *schema.VerifiableGetRequest) (*VerifiableItemExt, error)
- func (UnimplementedLcServiceServer) VerifiableSet(context.Context, *schema.VerifiableSetRequest) (*schema.VerifiableTx, error)
- func (UnimplementedLcServiceServer) VerifiableZAdd(context.Context, *schema.VerifiableZAddRequest) (*schema.VerifiableTx, error)
- func (UnimplementedLcServiceServer) ZAdd(context.Context, *schema.ZAddRequest) (*schema.TxMetadata, error)
- func (UnimplementedLcServiceServer) ZScan(context.Context, *schema.ZScanRequest) (*schema.ZEntries, error)
- func (UnimplementedLcServiceServer) ZScanExt(context.Context, *schema.ZScanRequest) (*ZItemExtList, error)
- type UnsafeLcServiceServer
- type VerifiableItemExt
- func (*VerifiableItemExt) Descriptor() ([]byte, []int)deprecated
- func (x *VerifiableItemExt) GetApikeyRevoked() *timestamp.Timestamp
- func (x *VerifiableItemExt) GetItem() *schema.VerifiableEntry
- func (x *VerifiableItemExt) GetLedgerName() string
- func (x *VerifiableItemExt) GetTimestamp() *timestamp.Timestamp
- func (*VerifiableItemExt) ProtoMessage()
- func (x *VerifiableItemExt) ProtoReflect() protoreflect.Message
- func (x *VerifiableItemExt) Reset()
- func (x *VerifiableItemExt) String() string
- type ZItemExt
- func (*ZItemExt) Descriptor() ([]byte, []int)deprecated
- func (x *ZItemExt) GetApikeyRevoked() *timestamp.Timestamp
- func (x *ZItemExt) GetItem() *schema.ZEntry
- func (x *ZItemExt) GetLedgerName() string
- func (x *ZItemExt) GetTimestamp() *timestamp.Timestamp
- func (*ZItemExt) ProtoMessage()
- func (x *ZItemExt) ProtoReflect() protoreflect.Message
- func (x *ZItemExt) Reset()
- func (x *ZItemExt) String() string
- type ZItemExtList
Constants ¶
const FeatBoM = "bom"
Variables ¶
var File_lc_proto protoreflect.FileDescriptor
var LcService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "lc.schema.LcService", HandlerType: (*LcServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Set", Handler: _LcService_Set_Handler, }, { MethodName: "Get", Handler: _LcService_Get_Handler, }, { MethodName: "VerifiableSet", Handler: _LcService_VerifiableSet_Handler, }, { MethodName: "VerifiableGet", Handler: _LcService_VerifiableGet_Handler, }, { MethodName: "GetAll", Handler: _LcService_GetAll_Handler, }, { MethodName: "ExecAll", Handler: _LcService_ExecAll_Handler, }, { MethodName: "Scan", Handler: _LcService_Scan_Handler, }, { MethodName: "History", Handler: _LcService_History_Handler, }, { MethodName: "ZAdd", Handler: _LcService_ZAdd_Handler, }, { MethodName: "VerifiableZAdd", Handler: _LcService_VerifiableZAdd_Handler, }, { MethodName: "ZScan", Handler: _LcService_ZScan_Handler, }, { MethodName: "CurrentState", Handler: _LcService_CurrentState_Handler, }, { MethodName: "Health", Handler: _LcService_Health_Handler, }, { MethodName: "ReportTamper", Handler: _LcService_ReportTamper_Handler, }, { MethodName: "VerifiableGetExt", Handler: _LcService_VerifiableGetExt_Handler, }, { MethodName: "ZScanExt", Handler: _LcService_ZScanExt_Handler, }, { MethodName: "HistoryExt", Handler: _LcService_HistoryExt_Handler, }, { MethodName: "Feats", Handler: _LcService_Feats_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "SendData", Handler: _LcService_SendData_Handler, ServerStreams: true, ClientStreams: true, }, { StreamName: "streamGet", Handler: _LcService_StreamGet_Handler, ServerStreams: true, }, { StreamName: "streamSet", Handler: _LcService_StreamSet_Handler, ClientStreams: true, }, { StreamName: "streamVerifiableGet", Handler: _LcService_StreamVerifiableGet_Handler, ServerStreams: true, }, { StreamName: "streamVerifiableSet", Handler: _LcService_StreamVerifiableSet_Handler, ClientStreams: true, }, { StreamName: "streamScan", Handler: _LcService_StreamScan_Handler, ServerStreams: true, }, { StreamName: "streamZScan", Handler: _LcService_StreamZScan_Handler, ServerStreams: true, }, { StreamName: "streamHistory", Handler: _LcService_StreamHistory_Handler, ServerStreams: true, }, { StreamName: "streamExecAll", Handler: _LcService_StreamExecAll_Handler, ClientStreams: true, }, }, Metadata: "lc.proto", }
LcService_ServiceDesc is the grpc.ServiceDesc for LcService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterLcServiceServer ¶
func RegisterLcServiceServer(s grpc.ServiceRegistrar, srv LcServiceServer)
Types ¶
type Data ¶
type Data struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` MsgID int64 `protobuf:"varint,2,opt,name=msgID,proto3" json:"msgID,omitempty"` DbName string `protobuf:"bytes,3,opt,name=dbName,proto3" json:"dbName,omitempty"` TableName string `protobuf:"bytes,4,opt,name=tableName,proto3" json:"tableName,omitempty"` Operation string `protobuf:"bytes,5,opt,name=operation,proto3" json:"operation,omitempty"` Data []byte `protobuf:"bytes,6,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*Data) Descriptor
deprecated
func (*Data) GetOperation ¶
func (*Data) GetTableName ¶
func (*Data) ProtoMessage ¶
func (*Data) ProtoMessage()
func (*Data) ProtoReflect ¶
func (x *Data) ProtoReflect() protoreflect.Message
type DataValue ¶
type DataValue struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*DataValue) Descriptor
deprecated
func (*DataValue) ProtoMessage ¶
func (*DataValue) ProtoMessage()
func (*DataValue) ProtoReflect ¶
func (x *DataValue) ProtoReflect() protoreflect.Message
type Features ¶ added in v0.9.2
type Features struct { Feat []string `protobuf:"bytes,1,rep,name=feat,proto3" json:"feat,omitempty"` Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` BuildTime string `protobuf:"bytes,3,opt,name=buildTime,proto3" json:"buildTime,omitempty"` Component string `protobuf:"bytes,4,opt,name=component,proto3" json:"component,omitempty"` // contains filtered or unexported fields }
func (*Features) Descriptor
deprecated
added in
v0.9.2
func (*Features) GetBuildTime ¶ added in v0.9.2
func (*Features) GetComponent ¶ added in v0.9.2
func (*Features) GetVersion ¶ added in v0.9.2
func (*Features) ProtoMessage ¶ added in v0.9.2
func (*Features) ProtoMessage()
func (*Features) ProtoReflect ¶ added in v0.9.2
func (x *Features) ProtoReflect() protoreflect.Message
type ItemExt ¶
type ItemExt struct { Item *schema.Entry `protobuf:"bytes,1,opt,name=item,proto3" json:"item,omitempty"` Timestamp *timestamp.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` ApikeyRevoked *timestamp.Timestamp `protobuf:"bytes,3,opt,name=apikeyRevoked,proto3" json:"apikeyRevoked,omitempty"` LedgerName string `protobuf:"bytes,4,opt,name=ledgerName,proto3" json:"ledgerName,omitempty"` // contains filtered or unexported fields }
func (*ItemExt) Descriptor
deprecated
func (*ItemExt) GetApikeyRevoked ¶ added in v0.9.2
func (*ItemExt) GetLedgerName ¶ added in v0.9.2
func (*ItemExt) GetTimestamp ¶
func (*ItemExt) ProtoMessage ¶
func (*ItemExt) ProtoMessage()
func (*ItemExt) ProtoReflect ¶
func (x *ItemExt) ProtoReflect() protoreflect.Message
type ItemExtList ¶
type ItemExtList struct { Items []*ItemExt `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"` // contains filtered or unexported fields }
func (*ItemExtList) Descriptor
deprecated
func (*ItemExtList) Descriptor() ([]byte, []int)
Deprecated: Use ItemExtList.ProtoReflect.Descriptor instead.
func (*ItemExtList) GetItems ¶
func (x *ItemExtList) GetItems() []*ItemExt
func (*ItemExtList) ProtoMessage ¶
func (*ItemExtList) ProtoMessage()
func (*ItemExtList) ProtoReflect ¶
func (x *ItemExtList) ProtoReflect() protoreflect.Message
func (*ItemExtList) Reset ¶
func (x *ItemExtList) Reset()
func (*ItemExtList) String ¶
func (x *ItemExtList) String() string
type LcServiceClient ¶
type LcServiceClient interface { // immudb primitives // setters and getters Set(ctx context.Context, in *schema.SetRequest, opts ...grpc.CallOption) (*schema.TxMetadata, error) Get(ctx context.Context, in *schema.KeyRequest, opts ...grpc.CallOption) (*schema.Entry, error) VerifiableSet(ctx context.Context, in *schema.VerifiableSetRequest, opts ...grpc.CallOption) (*schema.VerifiableTx, error) VerifiableGet(ctx context.Context, in *schema.VerifiableGetRequest, opts ...grpc.CallOption) (*schema.VerifiableEntry, error) // batch GetAll(ctx context.Context, in *schema.KeyListRequest, opts ...grpc.CallOption) (*schema.Entries, error) ExecAll(ctx context.Context, in *schema.ExecAllRequest, opts ...grpc.CallOption) (*schema.TxMetadata, error) // scanners Scan(ctx context.Context, in *schema.ScanRequest, opts ...grpc.CallOption) (*schema.Entries, error) History(ctx context.Context, in *schema.HistoryRequest, opts ...grpc.CallOption) (*schema.Entries, error) ZAdd(ctx context.Context, in *schema.ZAddRequest, opts ...grpc.CallOption) (*schema.TxMetadata, error) VerifiableZAdd(ctx context.Context, in *schema.VerifiableZAddRequest, opts ...grpc.CallOption) (*schema.VerifiableTx, error) ZScan(ctx context.Context, in *schema.ZScanRequest, opts ...grpc.CallOption) (*schema.ZEntries, error) // mixed CurrentState(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*schema.ImmutableState, error) Health(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*schema.HealthResponse, error) // ledger compliance extensions ReportTamper(ctx context.Context, in *ReportOptions, opts ...grpc.CallOption) (*empty.Empty, error) SendData(ctx context.Context, opts ...grpc.CallOption) (LcService_SendDataClient, error) // ledger compliance extensions - items extended with additional properties managed by LC backend (date) VerifiableGetExt(ctx context.Context, in *schema.VerifiableGetRequest, opts ...grpc.CallOption) (*VerifiableItemExt, error) ZScanExt(ctx context.Context, in *schema.ZScanRequest, opts ...grpc.CallOption) (*ZItemExtList, error) HistoryExt(ctx context.Context, in *schema.HistoryRequest, opts ...grpc.CallOption) (*ItemExtList, error) Feats(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Features, error) // streams StreamGet(ctx context.Context, in *schema.KeyRequest, opts ...grpc.CallOption) (LcService_StreamGetClient, error) StreamSet(ctx context.Context, opts ...grpc.CallOption) (LcService_StreamSetClient, error) StreamVerifiableGet(ctx context.Context, in *schema.VerifiableGetRequest, opts ...grpc.CallOption) (LcService_StreamVerifiableGetClient, error) StreamVerifiableSet(ctx context.Context, opts ...grpc.CallOption) (LcService_StreamVerifiableSetClient, error) StreamScan(ctx context.Context, in *schema.ScanRequest, opts ...grpc.CallOption) (LcService_StreamScanClient, error) StreamZScan(ctx context.Context, in *schema.ZScanRequest, opts ...grpc.CallOption) (LcService_StreamZScanClient, error) StreamHistory(ctx context.Context, in *schema.HistoryRequest, opts ...grpc.CallOption) (LcService_StreamHistoryClient, error) StreamExecAll(ctx context.Context, opts ...grpc.CallOption) (LcService_StreamExecAllClient, error) }
LcServiceClient is the client API for LcService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewLcServiceClient ¶
func NewLcServiceClient(cc grpc.ClientConnInterface) LcServiceClient
type LcServiceServer ¶
type LcServiceServer interface { // immudb primitives // setters and getters Set(context.Context, *schema.SetRequest) (*schema.TxMetadata, error) Get(context.Context, *schema.KeyRequest) (*schema.Entry, error) VerifiableSet(context.Context, *schema.VerifiableSetRequest) (*schema.VerifiableTx, error) VerifiableGet(context.Context, *schema.VerifiableGetRequest) (*schema.VerifiableEntry, error) // batch GetAll(context.Context, *schema.KeyListRequest) (*schema.Entries, error) ExecAll(context.Context, *schema.ExecAllRequest) (*schema.TxMetadata, error) // scanners Scan(context.Context, *schema.ScanRequest) (*schema.Entries, error) History(context.Context, *schema.HistoryRequest) (*schema.Entries, error) ZAdd(context.Context, *schema.ZAddRequest) (*schema.TxMetadata, error) VerifiableZAdd(context.Context, *schema.VerifiableZAddRequest) (*schema.VerifiableTx, error) ZScan(context.Context, *schema.ZScanRequest) (*schema.ZEntries, error) // mixed CurrentState(context.Context, *empty.Empty) (*schema.ImmutableState, error) Health(context.Context, *empty.Empty) (*schema.HealthResponse, error) // ledger compliance extensions ReportTamper(context.Context, *ReportOptions) (*empty.Empty, error) SendData(LcService_SendDataServer) error // ledger compliance extensions - items extended with additional properties managed by LC backend (date) VerifiableGetExt(context.Context, *schema.VerifiableGetRequest) (*VerifiableItemExt, error) ZScanExt(context.Context, *schema.ZScanRequest) (*ZItemExtList, error) HistoryExt(context.Context, *schema.HistoryRequest) (*ItemExtList, error) Feats(context.Context, *empty.Empty) (*Features, error) // streams StreamGet(*schema.KeyRequest, LcService_StreamGetServer) error StreamSet(LcService_StreamSetServer) error StreamVerifiableGet(*schema.VerifiableGetRequest, LcService_StreamVerifiableGetServer) error StreamVerifiableSet(LcService_StreamVerifiableSetServer) error StreamScan(*schema.ScanRequest, LcService_StreamScanServer) error StreamZScan(*schema.ZScanRequest, LcService_StreamZScanServer) error StreamHistory(*schema.HistoryRequest, LcService_StreamHistoryServer) error StreamExecAll(LcService_StreamExecAllServer) error // contains filtered or unexported methods }
LcServiceServer is the server API for LcService service. All implementations must embed UnimplementedLcServiceServer for forward compatibility
type LcService_StreamExecAllClient ¶ added in v0.9.2
type LcService_StreamExecAllClient interface { Send(*schema.Chunk) error CloseAndRecv() (*schema.TxMetadata, error) grpc.ClientStream }
type LcService_StreamExecAllServer ¶ added in v0.9.2
type LcService_StreamExecAllServer interface { SendAndClose(*schema.TxMetadata) error Recv() (*schema.Chunk, error) grpc.ServerStream }
type LcService_StreamGetClient ¶ added in v0.9.2
type LcService_StreamGetClient interface { Recv() (*schema.Chunk, error) grpc.ClientStream }
type LcService_StreamGetServer ¶ added in v0.9.2
type LcService_StreamGetServer interface { Send(*schema.Chunk) error grpc.ServerStream }
type LcService_StreamHistoryClient ¶ added in v0.9.2
type LcService_StreamHistoryClient interface { Recv() (*schema.Chunk, error) grpc.ClientStream }
type LcService_StreamHistoryServer ¶ added in v0.9.2
type LcService_StreamHistoryServer interface { Send(*schema.Chunk) error grpc.ServerStream }
type LcService_StreamScanClient ¶ added in v0.9.2
type LcService_StreamScanClient interface { Recv() (*schema.Chunk, error) grpc.ClientStream }
type LcService_StreamScanServer ¶ added in v0.9.2
type LcService_StreamScanServer interface { Send(*schema.Chunk) error grpc.ServerStream }
type LcService_StreamSetClient ¶ added in v0.9.2
type LcService_StreamSetClient interface { Send(*schema.Chunk) error CloseAndRecv() (*schema.TxMetadata, error) grpc.ClientStream }
type LcService_StreamSetServer ¶ added in v0.9.2
type LcService_StreamSetServer interface { SendAndClose(*schema.TxMetadata) error Recv() (*schema.Chunk, error) grpc.ServerStream }
type LcService_StreamVerifiableGetClient ¶ added in v0.9.2
type LcService_StreamVerifiableGetClient interface { Recv() (*schema.Chunk, error) grpc.ClientStream }
type LcService_StreamVerifiableGetServer ¶ added in v0.9.2
type LcService_StreamVerifiableGetServer interface { Send(*schema.Chunk) error grpc.ServerStream }
type LcService_StreamVerifiableSetClient ¶ added in v0.9.2
type LcService_StreamVerifiableSetClient interface { Send(*schema.Chunk) error CloseAndRecv() (*schema.VerifiableTx, error) grpc.ClientStream }
type LcService_StreamVerifiableSetServer ¶ added in v0.9.2
type LcService_StreamVerifiableSetServer interface { SendAndClose(*schema.VerifiableTx) error Recv() (*schema.Chunk, error) grpc.ServerStream }
type LcService_StreamZScanClient ¶ added in v0.9.2
type LcService_StreamZScanClient interface { Recv() (*schema.Chunk, error) grpc.ClientStream }
type LcService_StreamZScanServer ¶ added in v0.9.2
type LcService_StreamZScanServer interface { Send(*schema.Chunk) error grpc.ServerStream }
type ReportOptions ¶
type ReportOptions struct { Payload *TamperReport `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"` Signature *schema.Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"` // contains filtered or unexported fields }
func (*ReportOptions) Descriptor
deprecated
func (*ReportOptions) Descriptor() ([]byte, []int)
Deprecated: Use ReportOptions.ProtoReflect.Descriptor instead.
func (*ReportOptions) GetPayload ¶
func (x *ReportOptions) GetPayload() *TamperReport
func (*ReportOptions) GetSignature ¶
func (x *ReportOptions) GetSignature() *schema.Signature
func (*ReportOptions) ProtoMessage ¶
func (*ReportOptions) ProtoMessage()
func (*ReportOptions) ProtoReflect ¶
func (x *ReportOptions) ProtoReflect() protoreflect.Message
func (*ReportOptions) Reset ¶
func (x *ReportOptions) Reset()
func (*ReportOptions) String ¶
func (x *ReportOptions) String() string
type Response ¶
type Response struct { Status int32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` MsgID int64 `protobuf:"varint,3,opt,name=msgID,proto3" json:"msgID,omitempty"` VerifiableTx *schema.VerifiableTx `protobuf:"bytes,4,opt,name=VerifiableTx,proto3" json:"VerifiableTx,omitempty"` State *schema.ImmutableState `protobuf:"bytes,5,opt,name=state,proto3" json:"state,omitempty"` // contains filtered or unexported fields }
func (*Response) Descriptor
deprecated
func (*Response) GetState ¶ added in v0.9.1
func (x *Response) GetState() *schema.ImmutableState
func (*Response) GetVerifiableTx ¶ added in v0.9.1
func (x *Response) GetVerifiableTx() *schema.VerifiableTx
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
func (*Response) ProtoReflect ¶
func (x *Response) ProtoReflect() protoreflect.Message
type TamperReport ¶
type TamperReport struct { Index uint64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"` Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` Root []byte `protobuf:"bytes,3,opt,name=root,proto3" json:"root,omitempty"` // contains filtered or unexported fields }
func (*TamperReport) Descriptor
deprecated
func (*TamperReport) Descriptor() ([]byte, []int)
Deprecated: Use TamperReport.ProtoReflect.Descriptor instead.
func (*TamperReport) GetIndex ¶
func (x *TamperReport) GetIndex() uint64
func (*TamperReport) GetKey ¶
func (x *TamperReport) GetKey() []byte
func (*TamperReport) GetRoot ¶
func (x *TamperReport) GetRoot() []byte
func (*TamperReport) ProtoMessage ¶
func (*TamperReport) ProtoMessage()
func (*TamperReport) ProtoReflect ¶
func (x *TamperReport) ProtoReflect() protoreflect.Message
func (*TamperReport) Reset ¶
func (x *TamperReport) Reset()
func (*TamperReport) String ¶
func (x *TamperReport) String() string
type UnimplementedLcServiceServer ¶
type UnimplementedLcServiceServer struct { }
UnimplementedLcServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedLcServiceServer) CurrentState ¶ added in v0.9.1
func (UnimplementedLcServiceServer) CurrentState(context.Context, *empty.Empty) (*schema.ImmutableState, error)
func (UnimplementedLcServiceServer) ExecAll ¶ added in v0.9.1
func (UnimplementedLcServiceServer) ExecAll(context.Context, *schema.ExecAllRequest) (*schema.TxMetadata, error)
func (UnimplementedLcServiceServer) Get ¶
func (UnimplementedLcServiceServer) Get(context.Context, *schema.KeyRequest) (*schema.Entry, error)
func (UnimplementedLcServiceServer) GetAll ¶ added in v0.9.1
func (UnimplementedLcServiceServer) GetAll(context.Context, *schema.KeyListRequest) (*schema.Entries, error)
func (UnimplementedLcServiceServer) Health ¶
func (UnimplementedLcServiceServer) Health(context.Context, *empty.Empty) (*schema.HealthResponse, error)
func (UnimplementedLcServiceServer) History ¶
func (UnimplementedLcServiceServer) History(context.Context, *schema.HistoryRequest) (*schema.Entries, error)
func (UnimplementedLcServiceServer) HistoryExt ¶
func (UnimplementedLcServiceServer) HistoryExt(context.Context, *schema.HistoryRequest) (*ItemExtList, error)
func (UnimplementedLcServiceServer) ReportTamper ¶
func (UnimplementedLcServiceServer) ReportTamper(context.Context, *ReportOptions) (*empty.Empty, error)
func (UnimplementedLcServiceServer) Scan ¶
func (UnimplementedLcServiceServer) Scan(context.Context, *schema.ScanRequest) (*schema.Entries, error)
func (UnimplementedLcServiceServer) SendData ¶
func (UnimplementedLcServiceServer) SendData(LcService_SendDataServer) error
func (UnimplementedLcServiceServer) Set ¶
func (UnimplementedLcServiceServer) Set(context.Context, *schema.SetRequest) (*schema.TxMetadata, error)
func (UnimplementedLcServiceServer) StreamExecAll ¶ added in v0.9.2
func (UnimplementedLcServiceServer) StreamExecAll(LcService_StreamExecAllServer) error
func (UnimplementedLcServiceServer) StreamGet ¶ added in v0.9.2
func (UnimplementedLcServiceServer) StreamGet(*schema.KeyRequest, LcService_StreamGetServer) error
func (UnimplementedLcServiceServer) StreamHistory ¶ added in v0.9.2
func (UnimplementedLcServiceServer) StreamHistory(*schema.HistoryRequest, LcService_StreamHistoryServer) error
func (UnimplementedLcServiceServer) StreamScan ¶ added in v0.9.2
func (UnimplementedLcServiceServer) StreamScan(*schema.ScanRequest, LcService_StreamScanServer) error
func (UnimplementedLcServiceServer) StreamSet ¶ added in v0.9.2
func (UnimplementedLcServiceServer) StreamSet(LcService_StreamSetServer) error
func (UnimplementedLcServiceServer) StreamVerifiableGet ¶ added in v0.9.2
func (UnimplementedLcServiceServer) StreamVerifiableGet(*schema.VerifiableGetRequest, LcService_StreamVerifiableGetServer) error
func (UnimplementedLcServiceServer) StreamVerifiableSet ¶ added in v0.9.2
func (UnimplementedLcServiceServer) StreamVerifiableSet(LcService_StreamVerifiableSetServer) error
func (UnimplementedLcServiceServer) StreamZScan ¶ added in v0.9.2
func (UnimplementedLcServiceServer) StreamZScan(*schema.ZScanRequest, LcService_StreamZScanServer) error
func (UnimplementedLcServiceServer) VerifiableGet ¶ added in v0.9.1
func (UnimplementedLcServiceServer) VerifiableGet(context.Context, *schema.VerifiableGetRequest) (*schema.VerifiableEntry, error)
func (UnimplementedLcServiceServer) VerifiableGetExt ¶ added in v0.9.1
func (UnimplementedLcServiceServer) VerifiableGetExt(context.Context, *schema.VerifiableGetRequest) (*VerifiableItemExt, error)
func (UnimplementedLcServiceServer) VerifiableSet ¶ added in v0.9.1
func (UnimplementedLcServiceServer) VerifiableSet(context.Context, *schema.VerifiableSetRequest) (*schema.VerifiableTx, error)
func (UnimplementedLcServiceServer) VerifiableZAdd ¶ added in v0.9.1
func (UnimplementedLcServiceServer) VerifiableZAdd(context.Context, *schema.VerifiableZAddRequest) (*schema.VerifiableTx, error)
func (UnimplementedLcServiceServer) ZAdd ¶
func (UnimplementedLcServiceServer) ZAdd(context.Context, *schema.ZAddRequest) (*schema.TxMetadata, error)
func (UnimplementedLcServiceServer) ZScan ¶
func (UnimplementedLcServiceServer) ZScan(context.Context, *schema.ZScanRequest) (*schema.ZEntries, error)
func (UnimplementedLcServiceServer) ZScanExt ¶
func (UnimplementedLcServiceServer) ZScanExt(context.Context, *schema.ZScanRequest) (*ZItemExtList, error)
type UnsafeLcServiceServer ¶ added in v0.9.2
type UnsafeLcServiceServer interface {
// contains filtered or unexported methods
}
UnsafeLcServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LcServiceServer will result in compilation errors.
type VerifiableItemExt ¶ added in v0.9.1
type VerifiableItemExt struct { Item *schema.VerifiableEntry `protobuf:"bytes,1,opt,name=item,proto3" json:"item,omitempty"` Timestamp *timestamp.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` ApikeyRevoked *timestamp.Timestamp `protobuf:"bytes,3,opt,name=apikeyRevoked,proto3" json:"apikeyRevoked,omitempty"` LedgerName string `protobuf:"bytes,4,opt,name=ledgerName,proto3" json:"ledgerName,omitempty"` // contains filtered or unexported fields }
func (*VerifiableItemExt) Descriptor
deprecated
added in
v0.9.1
func (*VerifiableItemExt) Descriptor() ([]byte, []int)
Deprecated: Use VerifiableItemExt.ProtoReflect.Descriptor instead.
func (*VerifiableItemExt) GetApikeyRevoked ¶ added in v0.9.2
func (x *VerifiableItemExt) GetApikeyRevoked() *timestamp.Timestamp
func (*VerifiableItemExt) GetItem ¶ added in v0.9.1
func (x *VerifiableItemExt) GetItem() *schema.VerifiableEntry
func (*VerifiableItemExt) GetLedgerName ¶ added in v0.9.2
func (x *VerifiableItemExt) GetLedgerName() string
func (*VerifiableItemExt) GetTimestamp ¶ added in v0.9.1
func (x *VerifiableItemExt) GetTimestamp() *timestamp.Timestamp
func (*VerifiableItemExt) ProtoMessage ¶ added in v0.9.1
func (*VerifiableItemExt) ProtoMessage()
func (*VerifiableItemExt) ProtoReflect ¶ added in v0.9.1
func (x *VerifiableItemExt) ProtoReflect() protoreflect.Message
func (*VerifiableItemExt) Reset ¶ added in v0.9.1
func (x *VerifiableItemExt) Reset()
func (*VerifiableItemExt) String ¶ added in v0.9.1
func (x *VerifiableItemExt) String() string
type ZItemExt ¶
type ZItemExt struct { Item *schema.ZEntry `protobuf:"bytes,1,opt,name=item,proto3" json:"item,omitempty"` Timestamp *timestamp.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` ApikeyRevoked *timestamp.Timestamp `protobuf:"bytes,3,opt,name=apikeyRevoked,proto3" json:"apikeyRevoked,omitempty"` LedgerName string `protobuf:"bytes,4,opt,name=ledgerName,proto3" json:"ledgerName,omitempty"` // contains filtered or unexported fields }
func (*ZItemExt) Descriptor
deprecated
func (*ZItemExt) GetApikeyRevoked ¶ added in v0.9.2
func (*ZItemExt) GetLedgerName ¶ added in v0.9.2
func (*ZItemExt) GetTimestamp ¶
func (*ZItemExt) ProtoMessage ¶
func (*ZItemExt) ProtoMessage()
func (*ZItemExt) ProtoReflect ¶
func (x *ZItemExt) ProtoReflect() protoreflect.Message
type ZItemExtList ¶
type ZItemExtList struct { Items []*ZItemExt `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"` // contains filtered or unexported fields }
func (*ZItemExtList) Descriptor
deprecated
func (*ZItemExtList) Descriptor() ([]byte, []int)
Deprecated: Use ZItemExtList.ProtoReflect.Descriptor instead.
func (*ZItemExtList) GetItems ¶
func (x *ZItemExtList) GetItems() []*ZItemExt
func (*ZItemExtList) ProtoMessage ¶
func (*ZItemExtList) ProtoMessage()
func (*ZItemExtList) ProtoReflect ¶
func (x *ZItemExtList) ProtoReflect() protoreflect.Message
func (*ZItemExtList) Reset ¶
func (x *ZItemExtList) Reset()
func (*ZItemExtList) String ¶
func (x *ZItemExtList) String() string