Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterAtomicBroadcastServer(s grpc.ServiceRegistrar, srv AtomicBroadcastServer)
- func RegisterClusterNodeServiceServer(s grpc.ServiceRegistrar, srv ClusterNodeServiceServer)
- func RegisterClusterServer(s grpc.ServiceRegistrar, srv ClusterServer)
- type AtomicBroadcastClient
- type AtomicBroadcastServer
- type AtomicBroadcast_BroadcastClient
- type AtomicBroadcast_BroadcastServer
- type AtomicBroadcast_DeliverClient
- type AtomicBroadcast_DeliverServer
- type BatchSize
- func (*BatchSize) Descriptor() ([]byte, []int)deprecated
- func (x *BatchSize) GetAbsoluteMaxBytes() uint32
- func (x *BatchSize) GetMaxMessageCount() uint32
- func (x *BatchSize) GetPreferredMaxBytes() uint32
- func (*BatchSize) ProtoMessage()
- func (x *BatchSize) ProtoReflect() protoreflect.Message
- func (x *BatchSize) Reset()
- func (x *BatchSize) String() string
- type BatchTimeout
- type BroadcastResponse
- func (*BroadcastResponse) Descriptor() ([]byte, []int)deprecated
- func (x *BroadcastResponse) GetInfo() string
- func (x *BroadcastResponse) GetStatus() common.Status
- func (*BroadcastResponse) ProtoMessage()
- func (x *BroadcastResponse) ProtoReflect() protoreflect.Message
- func (x *BroadcastResponse) Reset()
- func (x *BroadcastResponse) String() string
- type ChannelRestrictions
- func (*ChannelRestrictions) Descriptor() ([]byte, []int)deprecated
- func (x *ChannelRestrictions) GetMaxCount() uint64
- func (*ChannelRestrictions) ProtoMessage()
- func (x *ChannelRestrictions) ProtoReflect() protoreflect.Message
- func (x *ChannelRestrictions) Reset()
- func (x *ChannelRestrictions) String() string
- type ClusterClient
- type ClusterNodeServiceClient
- type ClusterNodeServiceServer
- type ClusterNodeServiceStepRequest
- func (*ClusterNodeServiceStepRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ClusterNodeServiceStepRequest) GetNodeAuthrequest() *NodeAuthRequest
- func (x *ClusterNodeServiceStepRequest) GetNodeConrequest() *NodeConsensusRequest
- func (x *ClusterNodeServiceStepRequest) GetNodeTranrequest() *NodeTransactionOrderRequest
- func (m *ClusterNodeServiceStepRequest) GetPayload() isClusterNodeServiceStepRequest_Payload
- func (*ClusterNodeServiceStepRequest) ProtoMessage()
- func (x *ClusterNodeServiceStepRequest) ProtoReflect() protoreflect.Message
- func (x *ClusterNodeServiceStepRequest) Reset()
- func (x *ClusterNodeServiceStepRequest) String() string
- type ClusterNodeServiceStepRequest_NodeAuthrequest
- type ClusterNodeServiceStepRequest_NodeConrequest
- type ClusterNodeServiceStepRequest_NodeTranrequest
- type ClusterNodeServiceStepResponse
- func (*ClusterNodeServiceStepResponse) Descriptor() ([]byte, []int)deprecated
- func (m *ClusterNodeServiceStepResponse) GetPayload() isClusterNodeServiceStepResponse_Payload
- func (x *ClusterNodeServiceStepResponse) GetTranorderRes() *TransactionOrderResponse
- func (*ClusterNodeServiceStepResponse) ProtoMessage()
- func (x *ClusterNodeServiceStepResponse) ProtoReflect() protoreflect.Message
- func (x *ClusterNodeServiceStepResponse) Reset()
- func (x *ClusterNodeServiceStepResponse) String() string
- type ClusterNodeServiceStepResponse_TranorderRes
- type ClusterNodeService_StepClient
- type ClusterNodeService_StepServer
- type ClusterServer
- type Cluster_StepClient
- type Cluster_StepServer
- type ConsensusRequest
- func (*ConsensusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ConsensusRequest) GetChannel() string
- func (x *ConsensusRequest) GetMetadata() []byte
- func (x *ConsensusRequest) GetPayload() []byte
- func (*ConsensusRequest) ProtoMessage()
- func (x *ConsensusRequest) ProtoReflect() protoreflect.Message
- func (x *ConsensusRequest) Reset()
- func (x *ConsensusRequest) String() string
- type ConsensusType
- func (*ConsensusType) Descriptor() ([]byte, []int)deprecated
- func (x *ConsensusType) GetMetadata() []byte
- func (x *ConsensusType) GetState() ConsensusType_State
- func (x *ConsensusType) GetType() string
- func (*ConsensusType) ProtoMessage()
- func (x *ConsensusType) ProtoReflect() protoreflect.Message
- func (x *ConsensusType) Reset()
- func (x *ConsensusType) String() string
- type ConsensusType_State
- func (ConsensusType_State) Descriptor() protoreflect.EnumDescriptor
- func (x ConsensusType_State) Enum() *ConsensusType_State
- func (ConsensusType_State) EnumDescriptor() ([]byte, []int)deprecated
- func (x ConsensusType_State) Number() protoreflect.EnumNumber
- func (x ConsensusType_State) String() string
- func (ConsensusType_State) Type() protoreflect.EnumType
- type DeliverResponse
- func (*DeliverResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeliverResponse) GetBlock() *common.Block
- func (x *DeliverResponse) GetStatus() common.Status
- func (m *DeliverResponse) GetType() isDeliverResponse_Type
- func (*DeliverResponse) ProtoMessage()
- func (x *DeliverResponse) ProtoReflect() protoreflect.Message
- func (x *DeliverResponse) Reset()
- func (x *DeliverResponse) String() string
- type DeliverResponse_Block
- type DeliverResponse_Status
- type KafkaBrokersdeprecated
- type NodeAuthRequest
- func (*NodeAuthRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NodeAuthRequest) GetChannel() string
- func (x *NodeAuthRequest) GetFromId() uint64
- func (x *NodeAuthRequest) GetSessionBinding() []byte
- func (x *NodeAuthRequest) GetSignature() []byte
- func (x *NodeAuthRequest) GetTimestamp() *timestamppb.Timestamp
- func (x *NodeAuthRequest) GetToId() uint64
- func (x *NodeAuthRequest) GetVersion() uint32
- func (*NodeAuthRequest) ProtoMessage()
- func (x *NodeAuthRequest) ProtoReflect() protoreflect.Message
- func (x *NodeAuthRequest) Reset()
- func (x *NodeAuthRequest) String() string
- type NodeConsensusRequest
- func (*NodeConsensusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NodeConsensusRequest) GetMetadata() []byte
- func (x *NodeConsensusRequest) GetPayload() []byte
- func (*NodeConsensusRequest) ProtoMessage()
- func (x *NodeConsensusRequest) ProtoReflect() protoreflect.Message
- func (x *NodeConsensusRequest) Reset()
- func (x *NodeConsensusRequest) String() string
- type NodeTransactionOrderRequest
- func (*NodeTransactionOrderRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NodeTransactionOrderRequest) GetLastValidationSeq() uint64
- func (x *NodeTransactionOrderRequest) GetPayload() *common.Envelope
- func (*NodeTransactionOrderRequest) ProtoMessage()
- func (x *NodeTransactionOrderRequest) ProtoReflect() protoreflect.Message
- func (x *NodeTransactionOrderRequest) Reset()
- func (x *NodeTransactionOrderRequest) String() string
- type SeekInfo
- func (*SeekInfo) Descriptor() ([]byte, []int)deprecated
- func (x *SeekInfo) GetBehavior() SeekInfo_SeekBehavior
- func (x *SeekInfo) GetContentType() SeekInfo_SeekContentType
- func (x *SeekInfo) GetErrorResponse() SeekInfo_SeekErrorResponse
- func (x *SeekInfo) GetStart() *SeekPosition
- func (x *SeekInfo) GetStop() *SeekPosition
- func (*SeekInfo) ProtoMessage()
- func (x *SeekInfo) ProtoReflect() protoreflect.Message
- func (x *SeekInfo) Reset()
- func (x *SeekInfo) String() string
- type SeekInfo_SeekBehavior
- func (SeekInfo_SeekBehavior) Descriptor() protoreflect.EnumDescriptor
- func (x SeekInfo_SeekBehavior) Enum() *SeekInfo_SeekBehavior
- func (SeekInfo_SeekBehavior) EnumDescriptor() ([]byte, []int)deprecated
- func (x SeekInfo_SeekBehavior) Number() protoreflect.EnumNumber
- func (x SeekInfo_SeekBehavior) String() string
- func (SeekInfo_SeekBehavior) Type() protoreflect.EnumType
- type SeekInfo_SeekContentType
- func (SeekInfo_SeekContentType) Descriptor() protoreflect.EnumDescriptor
- func (x SeekInfo_SeekContentType) Enum() *SeekInfo_SeekContentType
- func (SeekInfo_SeekContentType) EnumDescriptor() ([]byte, []int)deprecated
- func (x SeekInfo_SeekContentType) Number() protoreflect.EnumNumber
- func (x SeekInfo_SeekContentType) String() string
- func (SeekInfo_SeekContentType) Type() protoreflect.EnumType
- type SeekInfo_SeekErrorResponse
- func (SeekInfo_SeekErrorResponse) Descriptor() protoreflect.EnumDescriptor
- func (x SeekInfo_SeekErrorResponse) Enum() *SeekInfo_SeekErrorResponse
- func (SeekInfo_SeekErrorResponse) EnumDescriptor() ([]byte, []int)deprecated
- func (x SeekInfo_SeekErrorResponse) Number() protoreflect.EnumNumber
- func (x SeekInfo_SeekErrorResponse) String() string
- func (SeekInfo_SeekErrorResponse) Type() protoreflect.EnumType
- type SeekNewest
- type SeekNextCommit
- type SeekOldest
- type SeekPosition
- func (*SeekPosition) Descriptor() ([]byte, []int)deprecated
- func (x *SeekPosition) GetNewest() *SeekNewest
- func (x *SeekPosition) GetNextCommit() *SeekNextCommit
- func (x *SeekPosition) GetOldest() *SeekOldest
- func (x *SeekPosition) GetSpecified() *SeekSpecified
- func (m *SeekPosition) GetType() isSeekPosition_Type
- func (*SeekPosition) ProtoMessage()
- func (x *SeekPosition) ProtoReflect() protoreflect.Message
- func (x *SeekPosition) Reset()
- func (x *SeekPosition) String() string
- type SeekPosition_Newest
- type SeekPosition_NextCommit
- type SeekPosition_Oldest
- type SeekPosition_Specified
- type SeekSpecified
- type StepRequest
- func (*StepRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StepRequest) GetConsensusRequest() *ConsensusRequest
- func (m *StepRequest) GetPayload() isStepRequest_Payload
- func (x *StepRequest) GetSubmitRequest() *SubmitRequest
- func (*StepRequest) ProtoMessage()
- func (x *StepRequest) ProtoReflect() protoreflect.Message
- func (x *StepRequest) Reset()
- func (x *StepRequest) String() string
- type StepRequest_ConsensusRequest
- type StepRequest_SubmitRequest
- type StepResponse
- func (*StepResponse) Descriptor() ([]byte, []int)deprecated
- func (m *StepResponse) GetPayload() isStepResponse_Payload
- func (x *StepResponse) GetSubmitRes() *SubmitResponse
- func (*StepResponse) ProtoMessage()
- func (x *StepResponse) ProtoReflect() protoreflect.Message
- func (x *StepResponse) Reset()
- func (x *StepResponse) String() string
- type StepResponse_SubmitRes
- type SubmitRequest
- func (*SubmitRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SubmitRequest) GetChannel() string
- func (x *SubmitRequest) GetLastValidationSeq() uint64
- func (x *SubmitRequest) GetPayload() *common.Envelope
- func (*SubmitRequest) ProtoMessage()
- func (x *SubmitRequest) ProtoReflect() protoreflect.Message
- func (x *SubmitRequest) Reset()
- func (x *SubmitRequest) String() string
- type SubmitResponse
- func (*SubmitResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SubmitResponse) GetChannel() string
- func (x *SubmitResponse) GetInfo() string
- func (x *SubmitResponse) GetStatus() common.Status
- func (*SubmitResponse) ProtoMessage()
- func (x *SubmitResponse) ProtoReflect() protoreflect.Message
- func (x *SubmitResponse) Reset()
- func (x *SubmitResponse) String() string
- type TransactionOrderResponse
- func (*TransactionOrderResponse) Descriptor() ([]byte, []int)deprecated
- func (x *TransactionOrderResponse) GetChannel() string
- func (x *TransactionOrderResponse) GetInfo() string
- func (x *TransactionOrderResponse) GetStatus() common.Status
- func (x *TransactionOrderResponse) GetTxId() string
- func (*TransactionOrderResponse) ProtoMessage()
- func (x *TransactionOrderResponse) ProtoReflect() protoreflect.Message
- func (x *TransactionOrderResponse) Reset()
- func (x *TransactionOrderResponse) String() string
- type UnimplementedAtomicBroadcastServer
- type UnimplementedClusterNodeServiceServer
- type UnimplementedClusterServer
- type UnsafeAtomicBroadcastServer
- type UnsafeClusterNodeServiceServer
- type UnsafeClusterServer
Constants ¶
const ( AtomicBroadcast_Broadcast_FullMethodName = "/orderer.AtomicBroadcast/Broadcast" AtomicBroadcast_Deliver_FullMethodName = "/orderer.AtomicBroadcast/Deliver" )
const (
ClusterNodeService_Step_FullMethodName = "/orderer.ClusterNodeService/Step"
)
const (
Cluster_Step_FullMethodName = "/orderer.Cluster/Step"
)
Variables ¶
var ( SeekInfo_SeekBehavior_name = map[int32]string{ 0: "BLOCK_UNTIL_READY", 1: "FAIL_IF_NOT_READY", } SeekInfo_SeekBehavior_value = map[string]int32{ "BLOCK_UNTIL_READY": 0, "FAIL_IF_NOT_READY": 1, } )
Enum value maps for SeekInfo_SeekBehavior.
var ( SeekInfo_SeekErrorResponse_name = map[int32]string{ 0: "STRICT", 1: "BEST_EFFORT", } SeekInfo_SeekErrorResponse_value = map[string]int32{ "STRICT": 0, "BEST_EFFORT": 1, } )
Enum value maps for SeekInfo_SeekErrorResponse.
var ( SeekInfo_SeekContentType_name = map[int32]string{ 0: "BLOCK", 1: "HEADER_WITH_SIG", } SeekInfo_SeekContentType_value = map[string]int32{ "BLOCK": 0, "HEADER_WITH_SIG": 1, } )
Enum value maps for SeekInfo_SeekContentType.
var ( ConsensusType_State_name = map[int32]string{ 0: "STATE_NORMAL", 1: "STATE_MAINTENANCE", } ConsensusType_State_value = map[string]int32{ "STATE_NORMAL": 0, "STATE_MAINTENANCE": 1, } )
Enum value maps for ConsensusType_State.
var AtomicBroadcast_ServiceDesc = grpc.ServiceDesc{ ServiceName: "orderer.AtomicBroadcast", HandlerType: (*AtomicBroadcastServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "Broadcast", Handler: _AtomicBroadcast_Broadcast_Handler, ServerStreams: true, ClientStreams: true, }, { StreamName: "Deliver", Handler: _AtomicBroadcast_Deliver_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "orderer/ab.proto", }
AtomicBroadcast_ServiceDesc is the grpc.ServiceDesc for AtomicBroadcast service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var ClusterNodeService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "orderer.ClusterNodeService", HandlerType: (*ClusterNodeServiceServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "Step", Handler: _ClusterNodeService_Step_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "orderer/clusterserver.proto", }
ClusterNodeService_ServiceDesc is the grpc.ServiceDesc for ClusterNodeService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Cluster_ServiceDesc = grpc.ServiceDesc{ ServiceName: "orderer.Cluster", HandlerType: (*ClusterServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "Step", Handler: _Cluster_Step_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "orderer/cluster.proto", }
Cluster_ServiceDesc is the grpc.ServiceDesc for Cluster service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_orderer_ab_proto protoreflect.FileDescriptor
var File_orderer_cluster_proto protoreflect.FileDescriptor
var File_orderer_clusterserver_proto protoreflect.FileDescriptor
var File_orderer_configuration_proto protoreflect.FileDescriptor
Functions ¶
func RegisterAtomicBroadcastServer ¶
func RegisterAtomicBroadcastServer(s grpc.ServiceRegistrar, srv AtomicBroadcastServer)
func RegisterClusterNodeServiceServer ¶ added in v0.3.0
func RegisterClusterNodeServiceServer(s grpc.ServiceRegistrar, srv ClusterNodeServiceServer)
func RegisterClusterServer ¶
func RegisterClusterServer(s grpc.ServiceRegistrar, srv ClusterServer)
Types ¶
type AtomicBroadcastClient ¶
type AtomicBroadcastClient interface { // broadcast receives a reply of Acknowledgement for each common.Envelope in order, indicating success or type of failure Broadcast(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[common.Envelope, BroadcastResponse], error) // deliver first requires an Envelope of type DELIVER_SEEK_INFO with Payload data as a mashaled SeekInfo message, then a stream of block replies is received. Deliver(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[common.Envelope, DeliverResponse], error) }
AtomicBroadcastClient is the client API for AtomicBroadcast 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 NewAtomicBroadcastClient ¶
func NewAtomicBroadcastClient(cc grpc.ClientConnInterface) AtomicBroadcastClient
type AtomicBroadcastServer ¶
type AtomicBroadcastServer interface { // broadcast receives a reply of Acknowledgement for each common.Envelope in order, indicating success or type of failure Broadcast(grpc.BidiStreamingServer[common.Envelope, BroadcastResponse]) error // deliver first requires an Envelope of type DELIVER_SEEK_INFO with Payload data as a mashaled SeekInfo message, then a stream of block replies is received. Deliver(grpc.BidiStreamingServer[common.Envelope, DeliverResponse]) error }
AtomicBroadcastServer is the server API for AtomicBroadcast service. All implementations should embed UnimplementedAtomicBroadcastServer for forward compatibility.
type AtomicBroadcast_BroadcastClient ¶
type AtomicBroadcast_BroadcastClient = grpc.BidiStreamingClient[common.Envelope, BroadcastResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type AtomicBroadcast_BroadcastServer ¶
type AtomicBroadcast_BroadcastServer = grpc.BidiStreamingServer[common.Envelope, BroadcastResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type AtomicBroadcast_DeliverClient ¶
type AtomicBroadcast_DeliverClient = grpc.BidiStreamingClient[common.Envelope, DeliverResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type AtomicBroadcast_DeliverServer ¶
type AtomicBroadcast_DeliverServer = grpc.BidiStreamingServer[common.Envelope, DeliverResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type BatchSize ¶
type BatchSize struct { // Simply specified as number of messages for now, in the future // we may want to allow this to be specified by size in bytes MaxMessageCount uint32 `protobuf:"varint,1,opt,name=max_message_count,json=maxMessageCount,proto3" json:"max_message_count,omitempty"` // The byte count of the serialized messages in a batch cannot // exceed this value. AbsoluteMaxBytes uint32 `protobuf:"varint,2,opt,name=absolute_max_bytes,json=absoluteMaxBytes,proto3" json:"absolute_max_bytes,omitempty"` // The byte count of the serialized messages in a batch should not // exceed this value. PreferredMaxBytes uint32 `protobuf:"varint,3,opt,name=preferred_max_bytes,json=preferredMaxBytes,proto3" json:"preferred_max_bytes,omitempty"` // contains filtered or unexported fields }
func (*BatchSize) Descriptor
deprecated
func (*BatchSize) GetAbsoluteMaxBytes ¶
func (*BatchSize) GetMaxMessageCount ¶
func (*BatchSize) GetPreferredMaxBytes ¶
func (*BatchSize) ProtoMessage ¶
func (*BatchSize) ProtoMessage()
func (*BatchSize) ProtoReflect ¶
func (x *BatchSize) ProtoReflect() protoreflect.Message
type BatchTimeout ¶
type BatchTimeout struct { // Any duration string parseable by ParseDuration(): // https://golang.org/pkg/time/#ParseDuration Timeout string `protobuf:"bytes,1,opt,name=timeout,proto3" json:"timeout,omitempty"` // contains filtered or unexported fields }
func (*BatchTimeout) Descriptor
deprecated
func (*BatchTimeout) Descriptor() ([]byte, []int)
Deprecated: Use BatchTimeout.ProtoReflect.Descriptor instead.
func (*BatchTimeout) GetTimeout ¶
func (x *BatchTimeout) GetTimeout() string
func (*BatchTimeout) ProtoMessage ¶
func (*BatchTimeout) ProtoMessage()
func (*BatchTimeout) ProtoReflect ¶
func (x *BatchTimeout) ProtoReflect() protoreflect.Message
func (*BatchTimeout) Reset ¶
func (x *BatchTimeout) Reset()
func (*BatchTimeout) String ¶
func (x *BatchTimeout) String() string
type BroadcastResponse ¶
type BroadcastResponse struct { // Status code, which may be used to programatically respond to success/failure Status common.Status `protobuf:"varint,1,opt,name=status,proto3,enum=common.Status" json:"status,omitempty"` // Info string which may contain additional information about the status returned Info string `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"` // contains filtered or unexported fields }
func (*BroadcastResponse) Descriptor
deprecated
func (*BroadcastResponse) Descriptor() ([]byte, []int)
Deprecated: Use BroadcastResponse.ProtoReflect.Descriptor instead.
func (*BroadcastResponse) GetInfo ¶
func (x *BroadcastResponse) GetInfo() string
func (*BroadcastResponse) GetStatus ¶
func (x *BroadcastResponse) GetStatus() common.Status
func (*BroadcastResponse) ProtoMessage ¶
func (*BroadcastResponse) ProtoMessage()
func (*BroadcastResponse) ProtoReflect ¶
func (x *BroadcastResponse) ProtoReflect() protoreflect.Message
func (*BroadcastResponse) Reset ¶
func (x *BroadcastResponse) Reset()
func (*BroadcastResponse) String ¶
func (x *BroadcastResponse) String() string
type ChannelRestrictions ¶
type ChannelRestrictions struct { MaxCount uint64 `protobuf:"varint,1,opt,name=max_count,json=maxCount,proto3" json:"max_count,omitempty"` // The max count of channels to allow to be created, a value of 0 indicates no limit // contains filtered or unexported fields }
ChannelRestrictions is the mssage which conveys restrictions on channel creation for an orderer
func (*ChannelRestrictions) Descriptor
deprecated
func (*ChannelRestrictions) Descriptor() ([]byte, []int)
Deprecated: Use ChannelRestrictions.ProtoReflect.Descriptor instead.
func (*ChannelRestrictions) GetMaxCount ¶
func (x *ChannelRestrictions) GetMaxCount() uint64
func (*ChannelRestrictions) ProtoMessage ¶
func (*ChannelRestrictions) ProtoMessage()
func (*ChannelRestrictions) ProtoReflect ¶
func (x *ChannelRestrictions) ProtoReflect() protoreflect.Message
func (*ChannelRestrictions) Reset ¶
func (x *ChannelRestrictions) Reset()
func (*ChannelRestrictions) String ¶
func (x *ChannelRestrictions) String() string
type ClusterClient ¶
type ClusterClient interface { // Step passes an implementation-specific message to another cluster member. Step(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[StepRequest, StepResponse], error) }
ClusterClient is the client API for Cluster 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.
Cluster defines communication between cluster members.
func NewClusterClient ¶
func NewClusterClient(cc grpc.ClientConnInterface) ClusterClient
type ClusterNodeServiceClient ¶ added in v0.3.0
type ClusterNodeServiceClient interface { // Step passes an implementation-specific message to another cluster member. Step(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[ClusterNodeServiceStepRequest, ClusterNodeServiceStepResponse], error) }
ClusterNodeServiceClient is the client API for ClusterNodeService 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.
Service ClusterNodeService defines communication between cluster members.
func NewClusterNodeServiceClient ¶ added in v0.3.0
func NewClusterNodeServiceClient(cc grpc.ClientConnInterface) ClusterNodeServiceClient
type ClusterNodeServiceServer ¶ added in v0.3.0
type ClusterNodeServiceServer interface { // Step passes an implementation-specific message to another cluster member. Step(grpc.BidiStreamingServer[ClusterNodeServiceStepRequest, ClusterNodeServiceStepResponse]) error }
ClusterNodeServiceServer is the server API for ClusterNodeService service. All implementations should embed UnimplementedClusterNodeServiceServer for forward compatibility.
Service ClusterNodeService defines communication between cluster members.
type ClusterNodeServiceStepRequest ¶ added in v0.3.0
type ClusterNodeServiceStepRequest struct { // Types that are assignable to Payload: // // *ClusterNodeServiceStepRequest_NodeConrequest // *ClusterNodeServiceStepRequest_NodeTranrequest // *ClusterNodeServiceStepRequest_NodeAuthrequest Payload isClusterNodeServiceStepRequest_Payload `protobuf_oneof:"payload"` // contains filtered or unexported fields }
ClusterNodeServiceStepRequest wraps a message that is sent to a cluster member.
func (*ClusterNodeServiceStepRequest) Descriptor
deprecated
added in
v0.3.0
func (*ClusterNodeServiceStepRequest) Descriptor() ([]byte, []int)
Deprecated: Use ClusterNodeServiceStepRequest.ProtoReflect.Descriptor instead.
func (*ClusterNodeServiceStepRequest) GetNodeAuthrequest ¶ added in v0.3.0
func (x *ClusterNodeServiceStepRequest) GetNodeAuthrequest() *NodeAuthRequest
func (*ClusterNodeServiceStepRequest) GetNodeConrequest ¶ added in v0.3.0
func (x *ClusterNodeServiceStepRequest) GetNodeConrequest() *NodeConsensusRequest
func (*ClusterNodeServiceStepRequest) GetNodeTranrequest ¶ added in v0.3.0
func (x *ClusterNodeServiceStepRequest) GetNodeTranrequest() *NodeTransactionOrderRequest
func (*ClusterNodeServiceStepRequest) GetPayload ¶ added in v0.3.0
func (m *ClusterNodeServiceStepRequest) GetPayload() isClusterNodeServiceStepRequest_Payload
func (*ClusterNodeServiceStepRequest) ProtoMessage ¶ added in v0.3.0
func (*ClusterNodeServiceStepRequest) ProtoMessage()
func (*ClusterNodeServiceStepRequest) ProtoReflect ¶ added in v0.3.0
func (x *ClusterNodeServiceStepRequest) ProtoReflect() protoreflect.Message
func (*ClusterNodeServiceStepRequest) Reset ¶ added in v0.3.0
func (x *ClusterNodeServiceStepRequest) Reset()
func (*ClusterNodeServiceStepRequest) String ¶ added in v0.3.0
func (x *ClusterNodeServiceStepRequest) String() string
type ClusterNodeServiceStepRequest_NodeAuthrequest ¶ added in v0.3.0
type ClusterNodeServiceStepRequest_NodeAuthrequest struct { // Auth authentiates the member that initiated the stream NodeAuthrequest *NodeAuthRequest `protobuf:"bytes,3,opt,name=node_authrequest,json=nodeAuthrequest,proto3,oneof"` }
type ClusterNodeServiceStepRequest_NodeConrequest ¶ added in v0.3.0
type ClusterNodeServiceStepRequest_NodeConrequest struct { // node_conrequest is a consensus specific message between the cluster memebers. NodeConrequest *NodeConsensusRequest `protobuf:"bytes,1,opt,name=node_conrequest,json=nodeConrequest,proto3,oneof"` }
type ClusterNodeServiceStepRequest_NodeTranrequest ¶ added in v0.3.0
type ClusterNodeServiceStepRequest_NodeTranrequest struct { // node_tranrequest is a relay of a transaction. NodeTranrequest *NodeTransactionOrderRequest `protobuf:"bytes,2,opt,name=node_tranrequest,json=nodeTranrequest,proto3,oneof"` }
type ClusterNodeServiceStepResponse ¶ added in v0.3.0
type ClusterNodeServiceStepResponse struct { // Types that are assignable to Payload: // // *ClusterNodeServiceStepResponse_TranorderRes Payload isClusterNodeServiceStepResponse_Payload `protobuf_oneof:"payload"` // contains filtered or unexported fields }
ClusterNodeServiceStepResponse is a message received from a cluster member.
func (*ClusterNodeServiceStepResponse) Descriptor
deprecated
added in
v0.3.0
func (*ClusterNodeServiceStepResponse) Descriptor() ([]byte, []int)
Deprecated: Use ClusterNodeServiceStepResponse.ProtoReflect.Descriptor instead.
func (*ClusterNodeServiceStepResponse) GetPayload ¶ added in v0.3.0
func (m *ClusterNodeServiceStepResponse) GetPayload() isClusterNodeServiceStepResponse_Payload
func (*ClusterNodeServiceStepResponse) GetTranorderRes ¶ added in v0.3.0
func (x *ClusterNodeServiceStepResponse) GetTranorderRes() *TransactionOrderResponse
func (*ClusterNodeServiceStepResponse) ProtoMessage ¶ added in v0.3.0
func (*ClusterNodeServiceStepResponse) ProtoMessage()
func (*ClusterNodeServiceStepResponse) ProtoReflect ¶ added in v0.3.0
func (x *ClusterNodeServiceStepResponse) ProtoReflect() protoreflect.Message
func (*ClusterNodeServiceStepResponse) Reset ¶ added in v0.3.0
func (x *ClusterNodeServiceStepResponse) Reset()
func (*ClusterNodeServiceStepResponse) String ¶ added in v0.3.0
func (x *ClusterNodeServiceStepResponse) String() string
type ClusterNodeServiceStepResponse_TranorderRes ¶ added in v0.3.0
type ClusterNodeServiceStepResponse_TranorderRes struct {
TranorderRes *TransactionOrderResponse `protobuf:"bytes,1,opt,name=tranorder_res,json=tranorderRes,proto3,oneof"`
}
type ClusterNodeService_StepClient ¶ added in v0.3.0
type ClusterNodeService_StepClient = grpc.BidiStreamingClient[ClusterNodeServiceStepRequest, ClusterNodeServiceStepResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type ClusterNodeService_StepServer ¶ added in v0.3.0
type ClusterNodeService_StepServer = grpc.BidiStreamingServer[ClusterNodeServiceStepRequest, ClusterNodeServiceStepResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type ClusterServer ¶
type ClusterServer interface { // Step passes an implementation-specific message to another cluster member. Step(grpc.BidiStreamingServer[StepRequest, StepResponse]) error }
ClusterServer is the server API for Cluster service. All implementations should embed UnimplementedClusterServer for forward compatibility.
Cluster defines communication between cluster members.
type Cluster_StepClient ¶
type Cluster_StepClient = grpc.BidiStreamingClient[StepRequest, StepResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type Cluster_StepServer ¶
type Cluster_StepServer = grpc.BidiStreamingServer[StepRequest, StepResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type ConsensusRequest ¶
type ConsensusRequest struct { Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"` Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"` Metadata []byte `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"` // contains filtered or unexported fields }
ConsensusRequest is a consensus specific message sent to a cluster member.
func (*ConsensusRequest) Descriptor
deprecated
func (*ConsensusRequest) Descriptor() ([]byte, []int)
Deprecated: Use ConsensusRequest.ProtoReflect.Descriptor instead.
func (*ConsensusRequest) GetChannel ¶
func (x *ConsensusRequest) GetChannel() string
func (*ConsensusRequest) GetMetadata ¶
func (x *ConsensusRequest) GetMetadata() []byte
func (*ConsensusRequest) GetPayload ¶
func (x *ConsensusRequest) GetPayload() []byte
func (*ConsensusRequest) ProtoMessage ¶
func (*ConsensusRequest) ProtoMessage()
func (*ConsensusRequest) ProtoReflect ¶
func (x *ConsensusRequest) ProtoReflect() protoreflect.Message
func (*ConsensusRequest) Reset ¶
func (x *ConsensusRequest) Reset()
func (*ConsensusRequest) String ¶
func (x *ConsensusRequest) String() string
type ConsensusType ¶
type ConsensusType struct { // The consensus type: "solo" or "etcdraft". Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` // Opaque metadata, dependent on the consensus type. Metadata []byte `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"` // The state signals the ordering service to go into maintenance mode, typically for consensus-type migration. State ConsensusType_State `protobuf:"varint,3,opt,name=state,proto3,enum=orderer.ConsensusType_State" json:"state,omitempty"` // contains filtered or unexported fields }
func (*ConsensusType) Descriptor
deprecated
func (*ConsensusType) Descriptor() ([]byte, []int)
Deprecated: Use ConsensusType.ProtoReflect.Descriptor instead.
func (*ConsensusType) GetMetadata ¶
func (x *ConsensusType) GetMetadata() []byte
func (*ConsensusType) GetState ¶
func (x *ConsensusType) GetState() ConsensusType_State
func (*ConsensusType) GetType ¶
func (x *ConsensusType) GetType() string
func (*ConsensusType) ProtoMessage ¶
func (*ConsensusType) ProtoMessage()
func (*ConsensusType) ProtoReflect ¶
func (x *ConsensusType) ProtoReflect() protoreflect.Message
func (*ConsensusType) Reset ¶
func (x *ConsensusType) Reset()
func (*ConsensusType) String ¶
func (x *ConsensusType) String() string
type ConsensusType_State ¶
type ConsensusType_State int32
State defines the orderer mode of operation, typically for consensus-type migration. NORMAL is during normal operation, when consensus-type migration is not, and can not, take place. MAINTENANCE is when the consensus-type can be changed.
const ( ConsensusType_STATE_NORMAL ConsensusType_State = 0 ConsensusType_STATE_MAINTENANCE ConsensusType_State = 1 )
func (ConsensusType_State) Descriptor ¶
func (ConsensusType_State) Descriptor() protoreflect.EnumDescriptor
func (ConsensusType_State) Enum ¶
func (x ConsensusType_State) Enum() *ConsensusType_State
func (ConsensusType_State) EnumDescriptor
deprecated
func (ConsensusType_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use ConsensusType_State.Descriptor instead.
func (ConsensusType_State) Number ¶
func (x ConsensusType_State) Number() protoreflect.EnumNumber
func (ConsensusType_State) String ¶
func (x ConsensusType_State) String() string
func (ConsensusType_State) Type ¶
func (ConsensusType_State) Type() protoreflect.EnumType
type DeliverResponse ¶
type DeliverResponse struct { // Types that are assignable to Type: // // *DeliverResponse_Status // *DeliverResponse_Block Type isDeliverResponse_Type `protobuf_oneof:"Type"` // contains filtered or unexported fields }
func (*DeliverResponse) Descriptor
deprecated
func (*DeliverResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeliverResponse.ProtoReflect.Descriptor instead.
func (*DeliverResponse) GetBlock ¶
func (x *DeliverResponse) GetBlock() *common.Block
func (*DeliverResponse) GetStatus ¶
func (x *DeliverResponse) GetStatus() common.Status
func (*DeliverResponse) GetType ¶
func (m *DeliverResponse) GetType() isDeliverResponse_Type
func (*DeliverResponse) ProtoMessage ¶
func (*DeliverResponse) ProtoMessage()
func (*DeliverResponse) ProtoReflect ¶
func (x *DeliverResponse) ProtoReflect() protoreflect.Message
func (*DeliverResponse) Reset ¶
func (x *DeliverResponse) Reset()
func (*DeliverResponse) String ¶
func (x *DeliverResponse) String() string
type DeliverResponse_Block ¶
type DeliverResponse_Status ¶
type KafkaBrokers
deprecated
type KafkaBrokers struct { // Each broker here should be identified using the (IP|host):port notation, // e.g. 127.0.0.1:7050, or localhost:7050 are valid entries Brokers []string `protobuf:"bytes,1,rep,name=brokers,proto3" json:"brokers,omitempty"` // contains filtered or unexported fields }
Carries a list of bootstrap brokers, i.e. this is not the exclusive set of brokers an ordering service
Deprecated: Marked as deprecated in orderer/configuration.proto.
func (*KafkaBrokers) Descriptor
deprecated
func (*KafkaBrokers) Descriptor() ([]byte, []int)
Deprecated: Use KafkaBrokers.ProtoReflect.Descriptor instead.
func (*KafkaBrokers) GetBrokers ¶
func (x *KafkaBrokers) GetBrokers() []string
func (*KafkaBrokers) ProtoMessage ¶
func (*KafkaBrokers) ProtoMessage()
func (*KafkaBrokers) ProtoReflect ¶
func (x *KafkaBrokers) ProtoReflect() protoreflect.Message
func (*KafkaBrokers) Reset ¶
func (x *KafkaBrokers) Reset()
func (*KafkaBrokers) String ¶
func (x *KafkaBrokers) String() string
type NodeAuthRequest ¶ added in v0.3.0
type NodeAuthRequest struct { // version represents the fields on which the signature is computed Version uint32 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"` // signature is verifiable using the initiator's public key Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"` // timestamp indicates the freshness of the request; expected to be within the margin // of the responsder's local time Timestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // from_id is the numerical identifier of the initiator of the connection FromId uint64 `protobuf:"varint,4,opt,name=from_id,json=fromId,proto3" json:"from_id,omitempty"` // to_id is the numerical identifier of the node that is being connected to ToId uint64 `protobuf:"varint,5,opt,name=to_id,json=toId,proto3" json:"to_id,omitempty"` // session_binding is verifiable using application level protocol SessionBinding []byte `protobuf:"bytes,6,opt,name=session_binding,json=sessionBinding,proto3" json:"session_binding,omitempty"` Channel string `protobuf:"bytes,7,opt,name=channel,proto3" json:"channel,omitempty"` // contains filtered or unexported fields }
NodeAuthRequest for authenticate the stream between the cluster members
func (*NodeAuthRequest) Descriptor
deprecated
added in
v0.3.0
func (*NodeAuthRequest) Descriptor() ([]byte, []int)
Deprecated: Use NodeAuthRequest.ProtoReflect.Descriptor instead.
func (*NodeAuthRequest) GetChannel ¶ added in v0.3.0
func (x *NodeAuthRequest) GetChannel() string
func (*NodeAuthRequest) GetFromId ¶ added in v0.3.0
func (x *NodeAuthRequest) GetFromId() uint64
func (*NodeAuthRequest) GetSessionBinding ¶ added in v0.3.0
func (x *NodeAuthRequest) GetSessionBinding() []byte
func (*NodeAuthRequest) GetSignature ¶ added in v0.3.0
func (x *NodeAuthRequest) GetSignature() []byte
func (*NodeAuthRequest) GetTimestamp ¶ added in v0.3.0
func (x *NodeAuthRequest) GetTimestamp() *timestamppb.Timestamp
func (*NodeAuthRequest) GetToId ¶ added in v0.3.0
func (x *NodeAuthRequest) GetToId() uint64
func (*NodeAuthRequest) GetVersion ¶ added in v0.3.0
func (x *NodeAuthRequest) GetVersion() uint32
func (*NodeAuthRequest) ProtoMessage ¶ added in v0.3.0
func (*NodeAuthRequest) ProtoMessage()
func (*NodeAuthRequest) ProtoReflect ¶ added in v0.3.0
func (x *NodeAuthRequest) ProtoReflect() protoreflect.Message
func (*NodeAuthRequest) Reset ¶ added in v0.3.0
func (x *NodeAuthRequest) Reset()
func (*NodeAuthRequest) String ¶ added in v0.3.0
func (x *NodeAuthRequest) String() string
type NodeConsensusRequest ¶ added in v0.3.0
type NodeConsensusRequest struct { Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"` Metadata []byte `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"` // contains filtered or unexported fields }
NodeConsensusRequest is a consensus specific message sent to a cluster member.
func (*NodeConsensusRequest) Descriptor
deprecated
added in
v0.3.0
func (*NodeConsensusRequest) Descriptor() ([]byte, []int)
Deprecated: Use NodeConsensusRequest.ProtoReflect.Descriptor instead.
func (*NodeConsensusRequest) GetMetadata ¶ added in v0.3.0
func (x *NodeConsensusRequest) GetMetadata() []byte
func (*NodeConsensusRequest) GetPayload ¶ added in v0.3.0
func (x *NodeConsensusRequest) GetPayload() []byte
func (*NodeConsensusRequest) ProtoMessage ¶ added in v0.3.0
func (*NodeConsensusRequest) ProtoMessage()
func (*NodeConsensusRequest) ProtoReflect ¶ added in v0.3.0
func (x *NodeConsensusRequest) ProtoReflect() protoreflect.Message
func (*NodeConsensusRequest) Reset ¶ added in v0.3.0
func (x *NodeConsensusRequest) Reset()
func (*NodeConsensusRequest) String ¶ added in v0.3.0
func (x *NodeConsensusRequest) String() string
type NodeTransactionOrderRequest ¶ added in v0.3.0
type NodeTransactionOrderRequest struct { // last_validation_seq denotes the last configuration sequence at which the // sender validated this message. LastValidationSeq uint64 `protobuf:"varint,1,opt,name=last_validation_seq,json=lastValidationSeq,proto3" json:"last_validation_seq,omitempty"` // content is the fabric transaction // that is forwarded to the cluster member. Payload *common.Envelope `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"` // contains filtered or unexported fields }
NodeTransactionOrderRequest wraps a transaction to be sent for ordering.
func (*NodeTransactionOrderRequest) Descriptor
deprecated
added in
v0.3.0
func (*NodeTransactionOrderRequest) Descriptor() ([]byte, []int)
Deprecated: Use NodeTransactionOrderRequest.ProtoReflect.Descriptor instead.
func (*NodeTransactionOrderRequest) GetLastValidationSeq ¶ added in v0.3.0
func (x *NodeTransactionOrderRequest) GetLastValidationSeq() uint64
func (*NodeTransactionOrderRequest) GetPayload ¶ added in v0.3.0
func (x *NodeTransactionOrderRequest) GetPayload() *common.Envelope
func (*NodeTransactionOrderRequest) ProtoMessage ¶ added in v0.3.0
func (*NodeTransactionOrderRequest) ProtoMessage()
func (*NodeTransactionOrderRequest) ProtoReflect ¶ added in v0.3.0
func (x *NodeTransactionOrderRequest) ProtoReflect() protoreflect.Message
func (*NodeTransactionOrderRequest) Reset ¶ added in v0.3.0
func (x *NodeTransactionOrderRequest) Reset()
func (*NodeTransactionOrderRequest) String ¶ added in v0.3.0
func (x *NodeTransactionOrderRequest) String() string
type SeekInfo ¶
type SeekInfo struct { Start *SeekPosition `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"` // The position to start the deliver from Stop *SeekPosition `protobuf:"bytes,2,opt,name=stop,proto3" json:"stop,omitempty"` // The position to stop the deliver Behavior SeekInfo_SeekBehavior `protobuf:"varint,3,opt,name=behavior,proto3,enum=orderer.SeekInfo_SeekBehavior" json:"behavior,omitempty"` // The behavior when a missing block is encountered ErrorResponse SeekInfo_SeekErrorResponse `` // How to respond to errors reported to the deliver service /* 141-byte string literal not displayed */ ContentType SeekInfo_SeekContentType `` // Defines what type of content to deliver in response to a request /* 133-byte string literal not displayed */ // contains filtered or unexported fields }
SeekInfo specifies the range of requested blocks to return If the start position is not found, an error is immediately returned Otherwise, blocks are returned until a missing block is encountered, then behavior is dictated by the SeekBehavior specified.
func (*SeekInfo) Descriptor
deprecated
func (*SeekInfo) GetBehavior ¶
func (x *SeekInfo) GetBehavior() SeekInfo_SeekBehavior
func (*SeekInfo) GetContentType ¶ added in v0.3.0
func (x *SeekInfo) GetContentType() SeekInfo_SeekContentType
func (*SeekInfo) GetErrorResponse ¶
func (x *SeekInfo) GetErrorResponse() SeekInfo_SeekErrorResponse
func (*SeekInfo) GetStart ¶
func (x *SeekInfo) GetStart() *SeekPosition
func (*SeekInfo) GetStop ¶
func (x *SeekInfo) GetStop() *SeekPosition
func (*SeekInfo) ProtoMessage ¶
func (*SeekInfo) ProtoMessage()
func (*SeekInfo) ProtoReflect ¶
func (x *SeekInfo) ProtoReflect() protoreflect.Message
type SeekInfo_SeekBehavior ¶
type SeekInfo_SeekBehavior int32
If BLOCK_UNTIL_READY is specified, the reply will block until the requested blocks are available, if FAIL_IF_NOT_READY is specified, the reply will return an error indicating that the block is not found. To request that all blocks be returned indefinitely as they are created, behavior should be set to BLOCK_UNTIL_READY and the stop should be set to specified with a number of MAX_UINT64
const ( SeekInfo_BLOCK_UNTIL_READY SeekInfo_SeekBehavior = 0 SeekInfo_FAIL_IF_NOT_READY SeekInfo_SeekBehavior = 1 )
func (SeekInfo_SeekBehavior) Descriptor ¶
func (SeekInfo_SeekBehavior) Descriptor() protoreflect.EnumDescriptor
func (SeekInfo_SeekBehavior) Enum ¶
func (x SeekInfo_SeekBehavior) Enum() *SeekInfo_SeekBehavior
func (SeekInfo_SeekBehavior) EnumDescriptor
deprecated
func (SeekInfo_SeekBehavior) EnumDescriptor() ([]byte, []int)
Deprecated: Use SeekInfo_SeekBehavior.Descriptor instead.
func (SeekInfo_SeekBehavior) Number ¶
func (x SeekInfo_SeekBehavior) Number() protoreflect.EnumNumber
func (SeekInfo_SeekBehavior) String ¶
func (x SeekInfo_SeekBehavior) String() string
func (SeekInfo_SeekBehavior) Type ¶
func (SeekInfo_SeekBehavior) Type() protoreflect.EnumType
type SeekInfo_SeekContentType ¶ added in v0.3.0
type SeekInfo_SeekContentType int32
SeekContentType indicates what type of content to deliver in response to a request. If BLOCK is specified, the orderer will stream blocks back to the peer. This is the default behavior. If HEADER_WITH_SIG is specified, the orderer will stream only a the header and the signature, and the payload field will be set to nil. This allows the requester to ascertain that the respective signed block exists in the orderer (or cluster of orderers).
const ( SeekInfo_BLOCK SeekInfo_SeekContentType = 0 SeekInfo_HEADER_WITH_SIG SeekInfo_SeekContentType = 1 )
func (SeekInfo_SeekContentType) Descriptor ¶ added in v0.3.0
func (SeekInfo_SeekContentType) Descriptor() protoreflect.EnumDescriptor
func (SeekInfo_SeekContentType) Enum ¶ added in v0.3.0
func (x SeekInfo_SeekContentType) Enum() *SeekInfo_SeekContentType
func (SeekInfo_SeekContentType) EnumDescriptor
deprecated
added in
v0.3.0
func (SeekInfo_SeekContentType) EnumDescriptor() ([]byte, []int)
Deprecated: Use SeekInfo_SeekContentType.Descriptor instead.
func (SeekInfo_SeekContentType) Number ¶ added in v0.3.0
func (x SeekInfo_SeekContentType) Number() protoreflect.EnumNumber
func (SeekInfo_SeekContentType) String ¶ added in v0.3.0
func (x SeekInfo_SeekContentType) String() string
func (SeekInfo_SeekContentType) Type ¶ added in v0.3.0
func (SeekInfo_SeekContentType) Type() protoreflect.EnumType
type SeekInfo_SeekErrorResponse ¶
type SeekInfo_SeekErrorResponse int32
SeekErrorTolerance indicates to the server how block provider errors should be tolerated. By default, if the deliver service detects a problem in the underlying block source (typically, in the orderer, a consenter error), it will begin to reject deliver requests. This is to prevent a client from waiting for blocks from an orderer which is stuck in an errored state. This is almost always the desired behavior and clients should stick with the default STRICT checking behavior. However, in some scenarios, particularly when attempting to recover from a crash or other corruption, it's desirable to force an orderer to respond with blocks on a best effort basis, even if the backing consensus implementation is in an errored state. In this case, set the SeekErrorResponse to BEST_EFFORT to ignore the consenter errors.
const ( SeekInfo_STRICT SeekInfo_SeekErrorResponse = 0 SeekInfo_BEST_EFFORT SeekInfo_SeekErrorResponse = 1 )
func (SeekInfo_SeekErrorResponse) Descriptor ¶
func (SeekInfo_SeekErrorResponse) Descriptor() protoreflect.EnumDescriptor
func (SeekInfo_SeekErrorResponse) Enum ¶
func (x SeekInfo_SeekErrorResponse) Enum() *SeekInfo_SeekErrorResponse
func (SeekInfo_SeekErrorResponse) EnumDescriptor
deprecated
func (SeekInfo_SeekErrorResponse) EnumDescriptor() ([]byte, []int)
Deprecated: Use SeekInfo_SeekErrorResponse.Descriptor instead.
func (SeekInfo_SeekErrorResponse) Number ¶
func (x SeekInfo_SeekErrorResponse) Number() protoreflect.EnumNumber
func (SeekInfo_SeekErrorResponse) String ¶
func (x SeekInfo_SeekErrorResponse) String() string
func (SeekInfo_SeekErrorResponse) Type ¶
func (SeekInfo_SeekErrorResponse) Type() protoreflect.EnumType
type SeekNewest ¶
type SeekNewest struct {
// contains filtered or unexported fields
}
func (*SeekNewest) Descriptor
deprecated
func (*SeekNewest) Descriptor() ([]byte, []int)
Deprecated: Use SeekNewest.ProtoReflect.Descriptor instead.
func (*SeekNewest) ProtoMessage ¶
func (*SeekNewest) ProtoMessage()
func (*SeekNewest) ProtoReflect ¶
func (x *SeekNewest) ProtoReflect() protoreflect.Message
func (*SeekNewest) Reset ¶
func (x *SeekNewest) Reset()
func (*SeekNewest) String ¶
func (x *SeekNewest) String() string
type SeekNextCommit ¶
type SeekNextCommit struct {
// contains filtered or unexported fields
}
SeekNextCommit refers to the next block that will be committed
func (*SeekNextCommit) Descriptor
deprecated
func (*SeekNextCommit) Descriptor() ([]byte, []int)
Deprecated: Use SeekNextCommit.ProtoReflect.Descriptor instead.
func (*SeekNextCommit) ProtoMessage ¶
func (*SeekNextCommit) ProtoMessage()
func (*SeekNextCommit) ProtoReflect ¶
func (x *SeekNextCommit) ProtoReflect() protoreflect.Message
func (*SeekNextCommit) Reset ¶
func (x *SeekNextCommit) Reset()
func (*SeekNextCommit) String ¶
func (x *SeekNextCommit) String() string
type SeekOldest ¶
type SeekOldest struct {
// contains filtered or unexported fields
}
func (*SeekOldest) Descriptor
deprecated
func (*SeekOldest) Descriptor() ([]byte, []int)
Deprecated: Use SeekOldest.ProtoReflect.Descriptor instead.
func (*SeekOldest) ProtoMessage ¶
func (*SeekOldest) ProtoMessage()
func (*SeekOldest) ProtoReflect ¶
func (x *SeekOldest) ProtoReflect() protoreflect.Message
func (*SeekOldest) Reset ¶
func (x *SeekOldest) Reset()
func (*SeekOldest) String ¶
func (x *SeekOldest) String() string
type SeekPosition ¶
type SeekPosition struct { // Types that are assignable to Type: // // *SeekPosition_Newest // *SeekPosition_Oldest // *SeekPosition_Specified // *SeekPosition_NextCommit Type isSeekPosition_Type `protobuf_oneof:"Type"` // contains filtered or unexported fields }
func (*SeekPosition) Descriptor
deprecated
func (*SeekPosition) Descriptor() ([]byte, []int)
Deprecated: Use SeekPosition.ProtoReflect.Descriptor instead.
func (*SeekPosition) GetNewest ¶
func (x *SeekPosition) GetNewest() *SeekNewest
func (*SeekPosition) GetNextCommit ¶
func (x *SeekPosition) GetNextCommit() *SeekNextCommit
func (*SeekPosition) GetOldest ¶
func (x *SeekPosition) GetOldest() *SeekOldest
func (*SeekPosition) GetSpecified ¶
func (x *SeekPosition) GetSpecified() *SeekSpecified
func (*SeekPosition) GetType ¶
func (m *SeekPosition) GetType() isSeekPosition_Type
func (*SeekPosition) ProtoMessage ¶
func (*SeekPosition) ProtoMessage()
func (*SeekPosition) ProtoReflect ¶
func (x *SeekPosition) ProtoReflect() protoreflect.Message
func (*SeekPosition) Reset ¶
func (x *SeekPosition) Reset()
func (*SeekPosition) String ¶
func (x *SeekPosition) String() string
type SeekPosition_Newest ¶
type SeekPosition_Newest struct {
Newest *SeekNewest `protobuf:"bytes,1,opt,name=newest,proto3,oneof"`
}
type SeekPosition_NextCommit ¶
type SeekPosition_NextCommit struct {
NextCommit *SeekNextCommit `protobuf:"bytes,4,opt,name=next_commit,json=nextCommit,proto3,oneof"`
}
type SeekPosition_Oldest ¶
type SeekPosition_Oldest struct {
Oldest *SeekOldest `protobuf:"bytes,2,opt,name=oldest,proto3,oneof"`
}
type SeekPosition_Specified ¶
type SeekPosition_Specified struct {
Specified *SeekSpecified `protobuf:"bytes,3,opt,name=specified,proto3,oneof"`
}
type SeekSpecified ¶
type SeekSpecified struct { Number uint64 `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"` // contains filtered or unexported fields }
func (*SeekSpecified) Descriptor
deprecated
func (*SeekSpecified) Descriptor() ([]byte, []int)
Deprecated: Use SeekSpecified.ProtoReflect.Descriptor instead.
func (*SeekSpecified) GetNumber ¶
func (x *SeekSpecified) GetNumber() uint64
func (*SeekSpecified) ProtoMessage ¶
func (*SeekSpecified) ProtoMessage()
func (*SeekSpecified) ProtoReflect ¶
func (x *SeekSpecified) ProtoReflect() protoreflect.Message
func (*SeekSpecified) Reset ¶
func (x *SeekSpecified) Reset()
func (*SeekSpecified) String ¶
func (x *SeekSpecified) String() string
type StepRequest ¶
type StepRequest struct { // Types that are assignable to Payload: // // *StepRequest_ConsensusRequest // *StepRequest_SubmitRequest Payload isStepRequest_Payload `protobuf_oneof:"payload"` // contains filtered or unexported fields }
StepRequest wraps a message that is sent to a cluster member.
func (*StepRequest) Descriptor
deprecated
func (*StepRequest) Descriptor() ([]byte, []int)
Deprecated: Use StepRequest.ProtoReflect.Descriptor instead.
func (*StepRequest) GetConsensusRequest ¶
func (x *StepRequest) GetConsensusRequest() *ConsensusRequest
func (*StepRequest) GetPayload ¶
func (m *StepRequest) GetPayload() isStepRequest_Payload
func (*StepRequest) GetSubmitRequest ¶
func (x *StepRequest) GetSubmitRequest() *SubmitRequest
func (*StepRequest) ProtoMessage ¶
func (*StepRequest) ProtoMessage()
func (*StepRequest) ProtoReflect ¶
func (x *StepRequest) ProtoReflect() protoreflect.Message
func (*StepRequest) Reset ¶
func (x *StepRequest) Reset()
func (*StepRequest) String ¶
func (x *StepRequest) String() string
type StepRequest_ConsensusRequest ¶
type StepRequest_ConsensusRequest struct { // consensus_request is a consensus specific message. ConsensusRequest *ConsensusRequest `protobuf:"bytes,1,opt,name=consensus_request,json=consensusRequest,proto3,oneof"` }
type StepRequest_SubmitRequest ¶
type StepRequest_SubmitRequest struct { // submit_request is a relay of a transaction. SubmitRequest *SubmitRequest `protobuf:"bytes,2,opt,name=submit_request,json=submitRequest,proto3,oneof"` }
type StepResponse ¶
type StepResponse struct { // Types that are assignable to Payload: // // *StepResponse_SubmitRes Payload isStepResponse_Payload `protobuf_oneof:"payload"` // contains filtered or unexported fields }
StepResponse is a message received from a cluster member.
func (*StepResponse) Descriptor
deprecated
func (*StepResponse) Descriptor() ([]byte, []int)
Deprecated: Use StepResponse.ProtoReflect.Descriptor instead.
func (*StepResponse) GetPayload ¶
func (m *StepResponse) GetPayload() isStepResponse_Payload
func (*StepResponse) GetSubmitRes ¶
func (x *StepResponse) GetSubmitRes() *SubmitResponse
func (*StepResponse) ProtoMessage ¶
func (*StepResponse) ProtoMessage()
func (*StepResponse) ProtoReflect ¶
func (x *StepResponse) ProtoReflect() protoreflect.Message
func (*StepResponse) Reset ¶
func (x *StepResponse) Reset()
func (*StepResponse) String ¶
func (x *StepResponse) String() string
type StepResponse_SubmitRes ¶
type StepResponse_SubmitRes struct {
SubmitRes *SubmitResponse `protobuf:"bytes,1,opt,name=submit_res,json=submitRes,proto3,oneof"`
}
type SubmitRequest ¶
type SubmitRequest struct { Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"` // last_validation_seq denotes the last // configuration sequence at which the // sender validated this message. LastValidationSeq uint64 `protobuf:"varint,2,opt,name=last_validation_seq,json=lastValidationSeq,proto3" json:"last_validation_seq,omitempty"` // content is the fabric transaction // that is forwarded to the cluster member. Payload *common.Envelope `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"` // contains filtered or unexported fields }
SubmitRequest wraps a transaction to be sent for ordering.
func (*SubmitRequest) Descriptor
deprecated
func (*SubmitRequest) Descriptor() ([]byte, []int)
Deprecated: Use SubmitRequest.ProtoReflect.Descriptor instead.
func (*SubmitRequest) GetChannel ¶
func (x *SubmitRequest) GetChannel() string
func (*SubmitRequest) GetLastValidationSeq ¶
func (x *SubmitRequest) GetLastValidationSeq() uint64
func (*SubmitRequest) GetPayload ¶
func (x *SubmitRequest) GetPayload() *common.Envelope
func (*SubmitRequest) ProtoMessage ¶
func (*SubmitRequest) ProtoMessage()
func (*SubmitRequest) ProtoReflect ¶
func (x *SubmitRequest) ProtoReflect() protoreflect.Message
func (*SubmitRequest) Reset ¶
func (x *SubmitRequest) Reset()
func (*SubmitRequest) String ¶
func (x *SubmitRequest) String() string
type SubmitResponse ¶
type SubmitResponse struct { Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"` // Status code, which may be used to programatically respond to success/failure. Status common.Status `protobuf:"varint,2,opt,name=status,proto3,enum=common.Status" json:"status,omitempty"` // Info string which may contain additional information about the returned status. Info string `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"` // contains filtered or unexported fields }
SubmitResponse returns a success or failure status to the sender.
func (*SubmitResponse) Descriptor
deprecated
func (*SubmitResponse) Descriptor() ([]byte, []int)
Deprecated: Use SubmitResponse.ProtoReflect.Descriptor instead.
func (*SubmitResponse) GetChannel ¶
func (x *SubmitResponse) GetChannel() string
func (*SubmitResponse) GetInfo ¶
func (x *SubmitResponse) GetInfo() string
func (*SubmitResponse) GetStatus ¶
func (x *SubmitResponse) GetStatus() common.Status
func (*SubmitResponse) ProtoMessage ¶
func (*SubmitResponse) ProtoMessage()
func (*SubmitResponse) ProtoReflect ¶
func (x *SubmitResponse) ProtoReflect() protoreflect.Message
func (*SubmitResponse) Reset ¶
func (x *SubmitResponse) Reset()
func (*SubmitResponse) String ¶
func (x *SubmitResponse) String() string
type TransactionOrderResponse ¶ added in v0.3.0
type TransactionOrderResponse struct { Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"` TxId string `protobuf:"bytes,2,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"` // Status code, which may be used to programatically respond to success/failure. Status common.Status `protobuf:"varint,3,opt,name=status,proto3,enum=common.Status" json:"status,omitempty"` // Info string which may contain additional information about the returned status. Info string `protobuf:"bytes,4,opt,name=info,proto3" json:"info,omitempty"` // contains filtered or unexported fields }
TransactionOrderResponse returns a success or failure status to the sender.
func (*TransactionOrderResponse) Descriptor
deprecated
added in
v0.3.0
func (*TransactionOrderResponse) Descriptor() ([]byte, []int)
Deprecated: Use TransactionOrderResponse.ProtoReflect.Descriptor instead.
func (*TransactionOrderResponse) GetChannel ¶ added in v0.3.0
func (x *TransactionOrderResponse) GetChannel() string
func (*TransactionOrderResponse) GetInfo ¶ added in v0.3.0
func (x *TransactionOrderResponse) GetInfo() string
func (*TransactionOrderResponse) GetStatus ¶ added in v0.3.0
func (x *TransactionOrderResponse) GetStatus() common.Status
func (*TransactionOrderResponse) GetTxId ¶ added in v0.3.0
func (x *TransactionOrderResponse) GetTxId() string
func (*TransactionOrderResponse) ProtoMessage ¶ added in v0.3.0
func (*TransactionOrderResponse) ProtoMessage()
func (*TransactionOrderResponse) ProtoReflect ¶ added in v0.3.0
func (x *TransactionOrderResponse) ProtoReflect() protoreflect.Message
func (*TransactionOrderResponse) Reset ¶ added in v0.3.0
func (x *TransactionOrderResponse) Reset()
func (*TransactionOrderResponse) String ¶ added in v0.3.0
func (x *TransactionOrderResponse) String() string
type UnimplementedAtomicBroadcastServer ¶
type UnimplementedAtomicBroadcastServer struct{}
UnimplementedAtomicBroadcastServer should be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedAtomicBroadcastServer) Broadcast ¶
func (UnimplementedAtomicBroadcastServer) Broadcast(grpc.BidiStreamingServer[common.Envelope, BroadcastResponse]) error
func (UnimplementedAtomicBroadcastServer) Deliver ¶
func (UnimplementedAtomicBroadcastServer) Deliver(grpc.BidiStreamingServer[common.Envelope, DeliverResponse]) error
type UnimplementedClusterNodeServiceServer ¶ added in v0.3.0
type UnimplementedClusterNodeServiceServer struct{}
UnimplementedClusterNodeServiceServer should be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
type UnimplementedClusterServer ¶
type UnimplementedClusterServer struct{}
UnimplementedClusterServer should be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedClusterServer) Step ¶
func (UnimplementedClusterServer) Step(grpc.BidiStreamingServer[StepRequest, StepResponse]) error
type UnsafeAtomicBroadcastServer ¶
type UnsafeAtomicBroadcastServer interface {
// contains filtered or unexported methods
}
UnsafeAtomicBroadcastServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AtomicBroadcastServer will result in compilation errors.
type UnsafeClusterNodeServiceServer ¶ added in v0.3.0
type UnsafeClusterNodeServiceServer interface {
// contains filtered or unexported methods
}
UnsafeClusterNodeServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ClusterNodeServiceServer will result in compilation errors.
type UnsafeClusterServer ¶
type UnsafeClusterServer interface {
// contains filtered or unexported methods
}
UnsafeClusterServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ClusterServer will result in compilation errors.