Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterVerifierServer(s grpc.ServiceRegistrar, srv VerifierServer)
- type Batch
- type Response
- func (*Response) Descriptor() ([]byte, []int)deprecated
- func (x *Response) GetRef() *protocoordinatorservice.TxRef
- func (x *Response) GetStatus() protoblocktx.Status
- func (*Response) ProtoMessage()
- func (x *Response) ProtoReflect() protoreflect.Message
- func (x *Response) Reset()
- func (x *Response) String() string
- type ResponseBatch
- type Tx
- type UnimplementedVerifierServer
- type UnsafeVerifierServer
- type Update
- func (*Update) Descriptor() ([]byte, []int)deprecated
- func (x *Update) GetConfig() *protoblocktx.ConfigTransaction
- func (x *Update) GetNamespacePolicies() *protoblocktx.NamespacePolicies
- func (*Update) ProtoMessage()
- func (x *Update) ProtoReflect() protoreflect.Message
- func (x *Update) Reset()
- func (x *Update) String() string
- type VerifierClient
- type VerifierServer
- type Verifier_StartStreamClient
- type Verifier_StartStreamServer
Constants ¶
const (
Verifier_StartStream_FullMethodName = "/protosigverifierservice.Verifier/StartStream"
)
Variables ¶
var File_api_protosigverifierservice_verifier_proto protoreflect.FileDescriptor
var Verifier_ServiceDesc = grpc.ServiceDesc{ ServiceName: "protosigverifierservice.Verifier", HandlerType: (*VerifierServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "StartStream", Handler: _Verifier_StartStream_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "api/protosigverifierservice/verifier.proto", }
Verifier_ServiceDesc is the grpc.ServiceDesc for Verifier service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterVerifierServer ¶
func RegisterVerifierServer(s grpc.ServiceRegistrar, srv VerifierServer)
Types ¶
type Batch ¶ added in v0.1.6
type Batch struct { Update *Update `protobuf:"bytes,1,opt,name=update,proto3,oneof" json:"update,omitempty"` Requests []*Tx `protobuf:"bytes,2,rep,name=requests,proto3" json:"requests,omitempty"` // contains filtered or unexported fields }
func (*Batch) Descriptor
deprecated
added in
v0.1.6
func (*Batch) GetRequests ¶ added in v0.1.6
func (*Batch) ProtoMessage ¶ added in v0.1.6
func (*Batch) ProtoMessage()
func (*Batch) ProtoReflect ¶ added in v0.1.6
func (x *Batch) ProtoReflect() protoreflect.Message
type Response ¶
type Response struct { Ref *protocoordinatorservice.TxRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"` Status protoblocktx.Status `protobuf:"varint,2,opt,name=status,proto3,enum=protoblocktx.Status" json:"status,omitempty"` // contains filtered or unexported fields }
func (*Response) Descriptor
deprecated
func (*Response) GetRef ¶ added in v0.1.6
func (x *Response) GetRef() *protocoordinatorservice.TxRef
func (*Response) GetStatus ¶
func (x *Response) GetStatus() protoblocktx.Status
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
func (*Response) ProtoReflect ¶
func (x *Response) ProtoReflect() protoreflect.Message
type ResponseBatch ¶
type ResponseBatch struct { Responses []*Response `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"` // contains filtered or unexported fields }
func (*ResponseBatch) Descriptor
deprecated
func (*ResponseBatch) Descriptor() ([]byte, []int)
Deprecated: Use ResponseBatch.ProtoReflect.Descriptor instead.
func (*ResponseBatch) GetResponses ¶
func (x *ResponseBatch) GetResponses() []*Response
func (*ResponseBatch) ProtoMessage ¶
func (*ResponseBatch) ProtoMessage()
func (*ResponseBatch) ProtoReflect ¶
func (x *ResponseBatch) ProtoReflect() protoreflect.Message
func (*ResponseBatch) Reset ¶
func (x *ResponseBatch) Reset()
func (*ResponseBatch) String ¶
func (x *ResponseBatch) String() string
type Tx ¶ added in v0.1.6
type Tx struct { Ref *protocoordinatorservice.TxRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"` Tx *protoblocktx.Tx `protobuf:"bytes,2,opt,name=tx,proto3" json:"tx,omitempty"` // contains filtered or unexported fields }
func (*Tx) Descriptor
deprecated
added in
v0.1.6
func (*Tx) GetRef ¶ added in v0.1.6
func (x *Tx) GetRef() *protocoordinatorservice.TxRef
func (*Tx) GetTx ¶ added in v0.1.6
func (x *Tx) GetTx() *protoblocktx.Tx
func (*Tx) ProtoMessage ¶ added in v0.1.6
func (*Tx) ProtoMessage()
func (*Tx) ProtoReflect ¶ added in v0.1.6
func (x *Tx) ProtoReflect() protoreflect.Message
type UnimplementedVerifierServer ¶
type UnimplementedVerifierServer struct { }
UnimplementedVerifierServer must be embedded to have forward compatible implementations.
func (UnimplementedVerifierServer) StartStream ¶
func (UnimplementedVerifierServer) StartStream(Verifier_StartStreamServer) error
type UnsafeVerifierServer ¶
type UnsafeVerifierServer interface {
// contains filtered or unexported methods
}
UnsafeVerifierServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to VerifierServer will result in compilation errors.
type Update ¶
type Update struct { Config *protoblocktx.ConfigTransaction `protobuf:"bytes,1,opt,name=config,proto3,oneof" json:"config,omitempty"` NamespacePolicies *protoblocktx.NamespacePolicies `protobuf:"bytes,2,opt,name=namespace_policies,json=namespacePolicies,proto3,oneof" json:"namespace_policies,omitempty"` // contains filtered or unexported fields }
func (*Update) Descriptor
deprecated
func (*Update) GetConfig ¶
func (x *Update) GetConfig() *protoblocktx.ConfigTransaction
func (*Update) GetNamespacePolicies ¶
func (x *Update) GetNamespacePolicies() *protoblocktx.NamespacePolicies
func (*Update) ProtoMessage ¶
func (*Update) ProtoMessage()
func (*Update) ProtoReflect ¶
func (x *Update) ProtoReflect() protoreflect.Message
type VerifierClient ¶
type VerifierClient interface {
StartStream(ctx context.Context, opts ...grpc.CallOption) (Verifier_StartStreamClient, error)
}
VerifierClient is the client API for Verifier 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 NewVerifierClient ¶
func NewVerifierClient(cc grpc.ClientConnInterface) VerifierClient
type VerifierServer ¶
type VerifierServer interface { StartStream(Verifier_StartStreamServer) error // contains filtered or unexported methods }
VerifierServer is the server API for Verifier service. All implementations must embed UnimplementedVerifierServer for forward compatibility
type Verifier_StartStreamClient ¶
type Verifier_StartStreamClient interface { Send(*Batch) error Recv() (*ResponseBatch, error) grpc.ClientStream }
type Verifier_StartStreamServer ¶
type Verifier_StartStreamServer interface { Send(*ResponseBatch) error Recv() (*Batch, error) grpc.ServerStream }