Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterSignerServer(s grpc.ServiceRegistrar, srv SignerServer)
- type BatchRetrieveReply
- func (*BatchRetrieveReply) Descriptor() ([]byte, []int)deprecated
- func (x *BatchRetrieveReply) GetEncodedSlice() []*Slices
- func (*BatchRetrieveReply) ProtoMessage()
- func (x *BatchRetrieveReply) ProtoReflect() protoreflect.Message
- func (x *BatchRetrieveReply) Reset()
- func (x *BatchRetrieveReply) String() string
- type BatchRetrieveRequest
- func (*BatchRetrieveRequest) Descriptor() ([]byte, []int)deprecated
- func (x *BatchRetrieveRequest) GetRequests() []*RetrieveRequest
- func (*BatchRetrieveRequest) ProtoMessage()
- func (x *BatchRetrieveRequest) ProtoReflect() protoreflect.Message
- func (x *BatchRetrieveRequest) Reset()
- func (x *BatchRetrieveRequest) String() string
- type BatchSignReply
- type BatchSignRequest
- func (*BatchSignRequest) Descriptor() ([]byte, []int)deprecated
- func (x *BatchSignRequest) GetRequests() []*SignRequest
- func (*BatchSignRequest) ProtoMessage()
- func (x *BatchSignRequest) ProtoReflect() protoreflect.Message
- func (x *BatchSignRequest) Reset()
- func (x *BatchSignRequest) String() string
- type Empty
- type RetrieveRequest
- func (*RetrieveRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RetrieveRequest) GetEpoch() uint64
- func (x *RetrieveRequest) GetQuorumId() uint64
- func (x *RetrieveRequest) GetRowIndexes() []uint32
- func (x *RetrieveRequest) GetStorageRoot() []byte
- func (*RetrieveRequest) ProtoMessage()
- func (x *RetrieveRequest) ProtoReflect() protoreflect.Message
- func (x *RetrieveRequest) Reset()
- func (x *RetrieveRequest) String() string
- type SignRequest
- func (*SignRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SignRequest) GetEncodedSlice() [][]byte
- func (x *SignRequest) GetEpoch() uint64
- func (x *SignRequest) GetErasureCommitment() []byte
- func (x *SignRequest) GetQuorumId() uint64
- func (x *SignRequest) GetStorageRoot() []byte
- func (*SignRequest) ProtoMessage()
- func (x *SignRequest) ProtoReflect() protoreflect.Message
- func (x *SignRequest) Reset()
- func (x *SignRequest) String() string
- type SignerClient
- type SignerServer
- type Slices
- type StatusReply
- type UnimplementedSignerServer
- func (UnimplementedSignerServer) BatchRetrieve(context.Context, *BatchRetrieveRequest) (*BatchRetrieveReply, error)
- func (UnimplementedSignerServer) BatchSign(context.Context, *BatchSignRequest) (*BatchSignReply, error)
- func (UnimplementedSignerServer) GetStatus(context.Context, *Empty) (*StatusReply, error)
- type UnsafeSignerServer
Constants ¶
const ( Signer_BatchSign_FullMethodName = "/signer.Signer/BatchSign" Signer_BatchRetrieve_FullMethodName = "/signer.Signer/BatchRetrieve" Signer_GetStatus_FullMethodName = "/signer.Signer/GetStatus" )
Variables ¶
var File_signer_proto protoreflect.FileDescriptor
var Signer_ServiceDesc = grpc.ServiceDesc{ ServiceName: "signer.Signer", HandlerType: (*SignerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "BatchSign", Handler: _Signer_BatchSign_Handler, }, { MethodName: "BatchRetrieve", Handler: _Signer_BatchRetrieve_Handler, }, { MethodName: "GetStatus", Handler: _Signer_GetStatus_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "signer.proto", }
Signer_ServiceDesc is the grpc.ServiceDesc for Signer service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterSignerServer ¶
func RegisterSignerServer(s grpc.ServiceRegistrar, srv SignerServer)
Types ¶
type BatchRetrieveReply ¶
type BatchRetrieveReply struct { // required encoded slices EncodedSlice []*Slices `protobuf:"bytes,1,rep,name=encoded_slice,json=encodedSlice,proto3" json:"encoded_slice,omitempty"` // contains filtered or unexported fields }
func (*BatchRetrieveReply) Descriptor
deprecated
func (*BatchRetrieveReply) Descriptor() ([]byte, []int)
Deprecated: Use BatchRetrieveReply.ProtoReflect.Descriptor instead.
func (*BatchRetrieveReply) GetEncodedSlice ¶
func (x *BatchRetrieveReply) GetEncodedSlice() []*Slices
func (*BatchRetrieveReply) ProtoMessage ¶
func (*BatchRetrieveReply) ProtoMessage()
func (*BatchRetrieveReply) ProtoReflect ¶
func (x *BatchRetrieveReply) ProtoReflect() protoreflect.Message
func (*BatchRetrieveReply) Reset ¶
func (x *BatchRetrieveReply) Reset()
func (*BatchRetrieveReply) String ¶
func (x *BatchRetrieveReply) String() string
type BatchRetrieveRequest ¶
type BatchRetrieveRequest struct { Requests []*RetrieveRequest `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"` // contains filtered or unexported fields }
func (*BatchRetrieveRequest) Descriptor
deprecated
func (*BatchRetrieveRequest) Descriptor() ([]byte, []int)
Deprecated: Use BatchRetrieveRequest.ProtoReflect.Descriptor instead.
func (*BatchRetrieveRequest) GetRequests ¶
func (x *BatchRetrieveRequest) GetRequests() []*RetrieveRequest
func (*BatchRetrieveRequest) ProtoMessage ¶
func (*BatchRetrieveRequest) ProtoMessage()
func (*BatchRetrieveRequest) ProtoReflect ¶
func (x *BatchRetrieveRequest) ProtoReflect() protoreflect.Message
func (*BatchRetrieveRequest) Reset ¶
func (x *BatchRetrieveRequest) Reset()
func (*BatchRetrieveRequest) String ¶
func (x *BatchRetrieveRequest) String() string
type BatchSignReply ¶
type BatchSignReply struct { // signatures for requests Signatures [][]byte `protobuf:"bytes,1,rep,name=signatures,proto3" json:"signatures,omitempty"` // contains filtered or unexported fields }
func (*BatchSignReply) Descriptor
deprecated
func (*BatchSignReply) Descriptor() ([]byte, []int)
Deprecated: Use BatchSignReply.ProtoReflect.Descriptor instead.
func (*BatchSignReply) GetSignatures ¶
func (x *BatchSignReply) GetSignatures() [][]byte
func (*BatchSignReply) ProtoMessage ¶
func (*BatchSignReply) ProtoMessage()
func (*BatchSignReply) ProtoReflect ¶
func (x *BatchSignReply) ProtoReflect() protoreflect.Message
func (*BatchSignReply) Reset ¶
func (x *BatchSignReply) Reset()
func (*BatchSignReply) String ¶
func (x *BatchSignReply) String() string
type BatchSignRequest ¶
type BatchSignRequest struct { Requests []*SignRequest `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"` // contains filtered or unexported fields }
func (*BatchSignRequest) Descriptor
deprecated
func (*BatchSignRequest) Descriptor() ([]byte, []int)
Deprecated: Use BatchSignRequest.ProtoReflect.Descriptor instead.
func (*BatchSignRequest) GetRequests ¶
func (x *BatchSignRequest) GetRequests() []*SignRequest
func (*BatchSignRequest) ProtoMessage ¶
func (*BatchSignRequest) ProtoMessage()
func (*BatchSignRequest) ProtoReflect ¶
func (x *BatchSignRequest) ProtoReflect() protoreflect.Message
func (*BatchSignRequest) Reset ¶
func (x *BatchSignRequest) Reset()
func (*BatchSignRequest) String ¶
func (x *BatchSignRequest) String() string
type Empty ¶
type Empty struct {
// contains filtered or unexported fields
}
func (*Empty) Descriptor
deprecated
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) ProtoReflect ¶
func (x *Empty) ProtoReflect() protoreflect.Message
type RetrieveRequest ¶
type RetrieveRequest struct { // epoch number of DASigners internal contract Epoch uint64 `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"` // quorum id of DASigners internal contract QuorumId uint64 `protobuf:"varint,2,opt,name=quorum_id,json=quorumId,proto3" json:"quorum_id,omitempty"` // merkle root of data StorageRoot []byte `protobuf:"bytes,3,opt,name=storage_root,json=storageRoot,proto3" json:"storage_root,omitempty"` // required row indexes RowIndexes []uint32 `protobuf:"varint,4,rep,packed,name=row_indexes,json=rowIndexes,proto3" json:"row_indexes,omitempty"` // contains filtered or unexported fields }
func (*RetrieveRequest) Descriptor
deprecated
func (*RetrieveRequest) Descriptor() ([]byte, []int)
Deprecated: Use RetrieveRequest.ProtoReflect.Descriptor instead.
func (*RetrieveRequest) GetEpoch ¶
func (x *RetrieveRequest) GetEpoch() uint64
func (*RetrieveRequest) GetQuorumId ¶
func (x *RetrieveRequest) GetQuorumId() uint64
func (*RetrieveRequest) GetRowIndexes ¶
func (x *RetrieveRequest) GetRowIndexes() []uint32
func (*RetrieveRequest) GetStorageRoot ¶
func (x *RetrieveRequest) GetStorageRoot() []byte
func (*RetrieveRequest) ProtoMessage ¶
func (*RetrieveRequest) ProtoMessage()
func (*RetrieveRequest) ProtoReflect ¶
func (x *RetrieveRequest) ProtoReflect() protoreflect.Message
func (*RetrieveRequest) Reset ¶
func (x *RetrieveRequest) Reset()
func (*RetrieveRequest) String ¶
func (x *RetrieveRequest) String() string
type SignRequest ¶
type SignRequest struct { // epoch number of DASigners internal contract Epoch uint64 `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"` // quorum id of DASigners internal contract QuorumId uint64 `protobuf:"varint,2,opt,name=quorum_id,json=quorumId,proto3" json:"quorum_id,omitempty"` // erasure commitment generated by encoder ErasureCommitment []byte `protobuf:"bytes,3,opt,name=erasure_commitment,json=erasureCommitment,proto3" json:"erasure_commitment,omitempty"` // merkle root of data StorageRoot []byte `protobuf:"bytes,4,opt,name=storage_root,json=storageRoot,proto3" json:"storage_root,omitempty"` // encoded slices of data EncodedSlice [][]byte `protobuf:"bytes,5,rep,name=encoded_slice,json=encodedSlice,proto3" json:"encoded_slice,omitempty"` // contains filtered or unexported fields }
func (*SignRequest) Descriptor
deprecated
func (*SignRequest) Descriptor() ([]byte, []int)
Deprecated: Use SignRequest.ProtoReflect.Descriptor instead.
func (*SignRequest) GetEncodedSlice ¶
func (x *SignRequest) GetEncodedSlice() [][]byte
func (*SignRequest) GetEpoch ¶
func (x *SignRequest) GetEpoch() uint64
func (*SignRequest) GetErasureCommitment ¶
func (x *SignRequest) GetErasureCommitment() []byte
func (*SignRequest) GetQuorumId ¶
func (x *SignRequest) GetQuorumId() uint64
func (*SignRequest) GetStorageRoot ¶
func (x *SignRequest) GetStorageRoot() []byte
func (*SignRequest) ProtoMessage ¶
func (*SignRequest) ProtoMessage()
func (*SignRequest) ProtoReflect ¶
func (x *SignRequest) ProtoReflect() protoreflect.Message
func (*SignRequest) Reset ¶
func (x *SignRequest) Reset()
func (*SignRequest) String ¶
func (x *SignRequest) String() string
type SignerClient ¶
type SignerClient interface { // This API accepts rows of encoded blobs to sign from clients. The node will verify the blobs existance in `DAEntrance` contract and validate the received rows. BatchSign(ctx context.Context, in *BatchSignRequest, opts ...grpc.CallOption) (*BatchSignReply, error) // This retrieves the requested encoded rows from the DA node database. BatchRetrieve(ctx context.Context, in *BatchRetrieveRequest, opts ...grpc.CallOption) (*BatchRetrieveReply, error) GetStatus(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*StatusReply, error) }
SignerClient is the client API for Signer 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 NewSignerClient ¶
func NewSignerClient(cc grpc.ClientConnInterface) SignerClient
type SignerServer ¶
type SignerServer interface { // This API accepts rows of encoded blobs to sign from clients. The node will verify the blobs existance in `DAEntrance` contract and validate the received rows. BatchSign(context.Context, *BatchSignRequest) (*BatchSignReply, error) // This retrieves the requested encoded rows from the DA node database. BatchRetrieve(context.Context, *BatchRetrieveRequest) (*BatchRetrieveReply, error) GetStatus(context.Context, *Empty) (*StatusReply, error) // contains filtered or unexported methods }
SignerServer is the server API for Signer service. All implementations must embed UnimplementedSignerServer for forward compatibility
type Slices ¶
type Slices struct { EncodedSlice [][]byte `protobuf:"bytes,1,rep,name=encoded_slice,json=encodedSlice,proto3" json:"encoded_slice,omitempty"` // contains filtered or unexported fields }
func (*Slices) Descriptor
deprecated
func (*Slices) GetEncodedSlice ¶
func (*Slices) ProtoMessage ¶
func (*Slices) ProtoMessage()
func (*Slices) ProtoReflect ¶
func (x *Slices) ProtoReflect() protoreflect.Message
type StatusReply ¶
type StatusReply struct { StatusCode uint64 `protobuf:"varint,1,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"` // contains filtered or unexported fields }
func (*StatusReply) Descriptor
deprecated
func (*StatusReply) Descriptor() ([]byte, []int)
Deprecated: Use StatusReply.ProtoReflect.Descriptor instead.
func (*StatusReply) GetStatusCode ¶
func (x *StatusReply) GetStatusCode() uint64
func (*StatusReply) ProtoMessage ¶
func (*StatusReply) ProtoMessage()
func (*StatusReply) ProtoReflect ¶
func (x *StatusReply) ProtoReflect() protoreflect.Message
func (*StatusReply) Reset ¶
func (x *StatusReply) Reset()
func (*StatusReply) String ¶
func (x *StatusReply) String() string
type UnimplementedSignerServer ¶
type UnimplementedSignerServer struct { }
UnimplementedSignerServer must be embedded to have forward compatible implementations.
func (UnimplementedSignerServer) BatchRetrieve ¶
func (UnimplementedSignerServer) BatchRetrieve(context.Context, *BatchRetrieveRequest) (*BatchRetrieveReply, error)
func (UnimplementedSignerServer) BatchSign ¶
func (UnimplementedSignerServer) BatchSign(context.Context, *BatchSignRequest) (*BatchSignReply, error)
func (UnimplementedSignerServer) GetStatus ¶
func (UnimplementedSignerServer) GetStatus(context.Context, *Empty) (*StatusReply, error)
type UnsafeSignerServer ¶
type UnsafeSignerServer interface {
// contains filtered or unexported methods
}
UnsafeSignerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SignerServer will result in compilation errors.