porderer

package
v0.0.0-...-51fbea3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 22, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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.

View Source 
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.

View Source 
var (
	SeekInfo_SeekContentType_name = map[int32]string{
		0: "BLOCK",
		1: "HEADER_WITHSIG",
	}
	SeekInfo_SeekContentType_value = map[string]int32{
		"BLOCK":          0,
		"HEADER_WITHSIG": 1,
	}
)

Enum value maps for SeekInfo_SeekContentType.

View Source 
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.

View Source 
var File_ab_proto protoreflect.FileDescriptor
View Source 
var File_blockattestation_proto protoreflect.FileDescriptor
View Source 
var File_cluster_proto protoreflect.FileDescriptor
View Source 
var File_clusterserver_proto protoreflect.FileDescriptor
View Source 
var File_configuration_proto protoreflect.FileDescriptor

Functions

func RegisterAtomicBroadcastServer 

func RegisterAtomicBroadcastServer(s *grpc.Server, srv AtomicBroadcastServer)

func RegisterBlockAttestationsServer 

func RegisterBlockAttestationsServer(s *grpc.Server, srv BlockAttestationsServer)

func RegisterClusterNodeServiceServer 

func RegisterClusterNodeServiceServer(s *grpc.Server, srv ClusterNodeServiceServer)

func RegisterClusterServer 

func RegisterClusterServer(s *grpc.Server, srv ClusterServer)

Types

type AtomicBroadcastClient 

type AtomicBroadcastClient interface {
	// Broadcast 方法接收一个流式的 pcommon.Envelope 消息流，每个消息代表一个要广播的交易或请求。
	// 返回一个流式的 BroadcastResponse 消息流，其中每个消息对应于 Broadcast 方法接收到的 pcommon.Envelope
	// 消息的响应，表示成功或失败的信息。
	Broadcast(ctx context.Context, opts ...grpc.CallOption) (AtomicBroadcast_BroadcastClient, error)
	// Deliver 方法首先接收一个流式的 pcommon.Envelope 消息流，该消息流中包含一个类型为 DELIVER_SEEK_INFO 的
	// Envelope，其中的 Payload 数据是一个序列化后的 SeekInfo 消息。然后，该方法返回一个流式的 DeliverResponse
	// 消息流，其中包含了按顺序发送的区块回复。返回一个流式的 DeliverResponse 消息流，其中每个消息对应于根据接收
	// 到的 DELIVER_SEEK_INFO 消息请求的区块内容。
	Deliver(ctx context.Context, opts ...grpc.CallOption) (AtomicBroadcast_DeliverClient, error)
}

AtomicBroadcastClient is the client API for AtomicBroadcast service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewAtomicBroadcastClient 

func NewAtomicBroadcastClient(cc grpc.ClientConnInterface) AtomicBroadcastClient

type AtomicBroadcastServer 

type AtomicBroadcastServer interface {
	// Broadcast 方法接收一个流式的 pcommon.Envelope 消息流，每个消息代表一个要广播的交易或请求。
	// 返回一个流式的 BroadcastResponse 消息流，其中每个消息对应于 Broadcast 方法接收到的 pcommon.Envelope
	// 消息的响应，表示成功或失败的信息。
	Broadcast(AtomicBroadcast_BroadcastServer) error
	// Deliver 方法首先接收一个流式的 pcommon.Envelope 消息流，该消息流中包含一个类型为 DELIVER_SEEK_INFO 的
	// Envelope，其中的 Payload 数据是一个序列化后的 SeekInfo 消息。然后，该方法返回一个流式的 DeliverResponse
	// 消息流，其中包含了按顺序发送的区块回复。返回一个流式的 DeliverResponse 消息流，其中每个消息对应于根据接收
	// 到的 DELIVER_SEEK_INFO 消息请求的区块内容。
	Deliver(AtomicBroadcast_DeliverServer) error
}

AtomicBroadcastServer is the server API for AtomicBroadcast service.

type AtomicBroadcast_BroadcastClient 

type AtomicBroadcast_BroadcastClient interface {
	Send(*pcommon.Envelope) error
	Recv() (*BroadcastResponse, error)
	grpc.ClientStream
}

type AtomicBroadcast_BroadcastServer 

type AtomicBroadcast_BroadcastServer interface {
	Send(*BroadcastResponse) error
	Recv() (*pcommon.Envelope, error)
	grpc.ServerStream
}

type AtomicBroadcast_DeliverClient 

type AtomicBroadcast_DeliverClient interface {
	Send(*pcommon.Envelope) error
	Recv() (*DeliverResponse, error)
	grpc.ClientStream
}

type AtomicBroadcast_DeliverServer 

type AtomicBroadcast_DeliverServer interface {
	Send(*DeliverResponse) error
	Recv() (*pcommon.Envelope, error)
	grpc.ServerStream
}

type BatchSize 

type BatchSize struct {
	MaxMessageCount   uint32 `protobuf:"varint,1,opt,name=max_message_count,json=maxMessageCount,proto3" json:"max_message_count,omitempty"`
	AbsoluteMaxBytes  uint32 `protobuf:"varint,2,opt,name=absolute_max_bytes,json=absoluteMaxBytes,proto3" json:"absolute_max_bytes,omitempty"`
	PreferredMaxBytes uint32 `protobuf:"varint,3,opt,name=preferred_max_bytes,json=preferredMaxBytes,proto3" json:"preferred_max_bytes,omitempty"`
	// contains filtered or unexported fields
}

BatchSize 结构体用于定义批处理的大小限制

func (*BatchSize) Descriptor deprecated 

func (*BatchSize) Descriptor() ([]byte, []int)

Deprecated: Use BatchSize.ProtoReflect.Descriptor instead.

func (*BatchSize) GetAbsoluteMaxBytes 

func (x *BatchSize) GetAbsoluteMaxBytes() uint32

func (*BatchSize) GetMaxMessageCount 

func (x *BatchSize) GetMaxMessageCount() uint32

func (*BatchSize) GetPreferredMaxBytes 

func (x *BatchSize) GetPreferredMaxBytes() uint32

func (*BatchSize) ProtoMessage 

func (*BatchSize) ProtoMessage()

func (*BatchSize) ProtoReflect 

func (x *BatchSize) ProtoReflect() protoreflect.Message

func (*BatchSize) Reset 

func (x *BatchSize) Reset()

func (*BatchSize) String 

func (x *BatchSize) String() string

type BatchTimeout 

type BatchTimeout struct {

	// Timeout 字段可以接受任何可以被 ParseDuration() 函数解析的持续时间
	// 字符串。这个字段用于指定批处理操作的超时时间，以确保在超时之前完成批
	// 处理操作。
	Timeout string `protobuf:"bytes,1,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

BatchTimeout 结构体用于定义批处理的超时时间。

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 BlockAttestation 

type BlockAttestation struct {

	// Header 表示区块的头部信息，包括区块的版本、哈希值和时间戳等。
	Header *pcommon.BlockHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// Metadata 表示区块的元数据信息，例如区块的交易数量、交易元数据等。
	Metadata *pcommon.BlockMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

BlockAttestation 结构体包含了两个字段 Header 和 Metadata，用于表示区块的证明信息。

func (*BlockAttestation) Descriptor deprecated 

func (*BlockAttestation) Descriptor() ([]byte, []int)

Deprecated: Use BlockAttestation.ProtoReflect.Descriptor instead.

func (*BlockAttestation) GetHeader 

func (x *BlockAttestation) GetHeader() *pcommon.BlockHeader

func (*BlockAttestation) GetMetadata 

func (x *BlockAttestation) GetMetadata() *pcommon.BlockMetadata

func (*BlockAttestation) ProtoMessage 

func (*BlockAttestation) ProtoMessage()

func (*BlockAttestation) ProtoReflect 

func (x *BlockAttestation) ProtoReflect() protoreflect.Message

func (*BlockAttestation) Reset 

func (x *BlockAttestation) Reset()

func (*BlockAttestation) String 

func (x *BlockAttestation) String() string

type BlockAttestationResponse 

type BlockAttestationResponse struct {

	// Types that are assignable to Type:
	//
	//	*BlockAttestationResponse_Status
	//	*BlockAttestationResponse_BlockAttestation
	Type isBlockAttestationResponse_Type `protobuf_oneof:"Type"`
	// contains filtered or unexported fields
}

BlockAttestationResponse 结构体表示对区块证明的响应。

func (*BlockAttestationResponse) Descriptor deprecated 

func (*BlockAttestationResponse) Descriptor() ([]byte, []int)

Deprecated: Use BlockAttestationResponse.ProtoReflect.Descriptor instead.

func (*BlockAttestationResponse) GetBlockAttestation 

func (x *BlockAttestationResponse) GetBlockAttestation() *BlockAttestation

func (*BlockAttestationResponse) GetStatus 

func (x *BlockAttestationResponse) GetStatus() pcommon.Status

func (*BlockAttestationResponse) GetType 

func (m *BlockAttestationResponse) GetType() isBlockAttestationResponse_Type

func (*BlockAttestationResponse) ProtoMessage 

func (*BlockAttestationResponse) ProtoMessage()

func (*BlockAttestationResponse) ProtoReflect 

func (x *BlockAttestationResponse) ProtoReflect() protoreflect.Message

func (*BlockAttestationResponse) Reset 

func (x *BlockAttestationResponse) Reset()

func (*BlockAttestationResponse) String 

func (x *BlockAttestationResponse) String() string

type BlockAttestationResponse_BlockAttestation 

type BlockAttestationResponse_BlockAttestation struct {
	// BlockAttestation 表示区块的证明信息。
	BlockAttestation *BlockAttestation `protobuf:"bytes,2,opt,name=block_attestation,json=blockAttestation,proto3,oneof"`
}

type BlockAttestationResponse_Status 

type BlockAttestationResponse_Status struct {
	// Status 表示区块证明的响应状态。
	Status pcommon.Status `protobuf:"varint,1,opt,name=status,proto3,enum=pcommon.Status,oneof"`
}

type BlockAttestationsClient 

type BlockAttestationsClient interface {
	// BlockAttestations
	//
	//  1. 区块认证：当节点（peer）收到一个区块的认证请求时，它会调用该 gRPC 服务来处理请求。
	//     区块认证是指对一个新收到的区块进行验证和认证，以确保该区块的有效性和一致性。
	//
	//  2. 传递区块认证结果：该服务返回一个流的区块认证响应，可以提供实时的认证结果信息。这对
	//     于其他节点或组件来说非常有用，因为它们可以及时了解到区块认证的进展和结果，以便进行后续操作。
	BlockAttestations(ctx context.Context, in *pcommon.Envelope, opts ...grpc.CallOption) (BlockAttestations_BlockAttestationsClient, error)
}

BlockAttestationsClient is the client API for BlockAttestations service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewBlockAttestationsClient 

func NewBlockAttestationsClient(cc grpc.ClientConnInterface) BlockAttestationsClient

type BlockAttestationsServer 

type BlockAttestationsServer interface {
	// BlockAttestations
	//
	//  1. 区块认证：当节点（peer）收到一个区块的认证请求时，它会调用该 gRPC 服务来处理请求。
	//     区块认证是指对一个新收到的区块进行验证和认证，以确保该区块的有效性和一致性。
	//
	//  2. 传递区块认证结果：该服务返回一个流的区块认证响应，可以提供实时的认证结果信息。这对
	//     于其他节点或组件来说非常有用，因为它们可以及时了解到区块认证的进展和结果，以便进行后续操作。
	BlockAttestations(*pcommon.Envelope, BlockAttestations_BlockAttestationsServer) error
}

BlockAttestationsServer is the server API for BlockAttestations service.

type BlockAttestations_BlockAttestationsClient 

type BlockAttestations_BlockAttestationsClient interface {
	Recv() (*BlockAttestationResponse, error)
	grpc.ClientStream
}

type BlockAttestations_BlockAttestationsServer 

type BlockAttestations_BlockAttestationsServer interface {
	Send(*BlockAttestationResponse) error
	grpc.ServerStream
}

type BroadcastResponse 

type BroadcastResponse struct {

	// Status 用于表示响应状态码，可以用于在程序中对成功或失败做出响应。
	Status pcommon.Status `protobuf:"varint,1,opt,name=status,proto3,enum=pcommon.Status" json:"status,omitempty"`
	// Info 一个信息字符串，包含有关返回状态的附加信息。
	Info string `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

BroadcastResponse 这是一个用于广播响应的消息结构体。

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() pcommon.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 字段指定了所能创建的最大通道数量，如果值为 0，则表示没有限制。
	// 这个字段用于定义排序者允许创建的通道数量的最大限制，以控制网络中通道的
	// 数量。
	MaxCount uint64 `protobuf:"varint,1,opt,name=max_count,json=maxCount,proto3" json:"max_count,omitempty"`
	// contains filtered or unexported fields
}

ChannelRestrictions 结构体用于传达有关排序者对通道创建的限制。

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(ctx context.Context, opts ...grpc.CallOption) (Cluster_StepClient, error)
}

ClusterClient is the client API for Cluster service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewClusterClient 

func NewClusterClient(cc grpc.ClientConnInterface) ClusterClient

type ClusterNodeServiceClient 

type ClusterNodeServiceClient interface {
	Step(ctx context.Context, opts ...grpc.CallOption) (ClusterNodeService_StepClient, error)
}

ClusterNodeServiceClient is the client API for ClusterNodeService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewClusterNodeServiceClient 

func NewClusterNodeServiceClient(cc grpc.ClientConnInterface) ClusterNodeServiceClient

type ClusterNodeServiceServer 

type ClusterNodeServiceServer interface {
	Step(ClusterNodeService_StepServer) error
}

ClusterNodeServiceServer is the server API for ClusterNodeService service.

type ClusterNodeServiceStepRequest 

type ClusterNodeServiceStepRequest struct {

	// Types that are assignable to Payload:
	//
	//	*ClusterNodeServiceStepRequest_NodeConsensusReq
	//	*ClusterNodeServiceStepRequest_NodeTransactionReq
	//	*ClusterNodeServiceStepRequest_NodeAuthReq
	Payload isClusterNodeServiceStepRequest_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

ClusterNodeServiceStepRequest 用于封装发送给 cluster 成员的请求，其中的 Payload 字段， 定义了三种可能的消息：NodeConsensusRequest、NodeTransactionOrderRequest、NodeAuthRequest。

func (*ClusterNodeServiceStepRequest) Descriptor deprecated 

func (*ClusterNodeServiceStepRequest) Descriptor() ([]byte, []int)

Deprecated: Use ClusterNodeServiceStepRequest.ProtoReflect.Descriptor instead.

func (*ClusterNodeServiceStepRequest) GetNodeAuthReq 

func (x *ClusterNodeServiceStepRequest) GetNodeAuthReq() *NodeAuthRequest

func (*ClusterNodeServiceStepRequest) GetNodeConsensusReq 

func (x *ClusterNodeServiceStepRequest) GetNodeConsensusReq() *NodeConsensusRequest

func (*ClusterNodeServiceStepRequest) GetNodeTransactionReq 

func (x *ClusterNodeServiceStepRequest) GetNodeTransactionReq() *NodeTransactionOrderRequest

func (*ClusterNodeServiceStepRequest) GetPayload 

func (m *ClusterNodeServiceStepRequest) GetPayload() isClusterNodeServiceStepRequest_Payload

func (*ClusterNodeServiceStepRequest) ProtoMessage 

func (*ClusterNodeServiceStepRequest) ProtoMessage()

func (*ClusterNodeServiceStepRequest) ProtoReflect 

func (x *ClusterNodeServiceStepRequest) ProtoReflect() protoreflect.Message

func (*ClusterNodeServiceStepRequest) Reset 

func (x *ClusterNodeServiceStepRequest) Reset()

func (*ClusterNodeServiceStepRequest) String 

func (x *ClusterNodeServiceStepRequest) String() string

type ClusterNodeServiceStepRequest_NodeAuthReq 

type ClusterNodeServiceStepRequest_NodeAuthReq struct {
	// NodeAuthReq 用于对发起 stream 流的成员进行身份验证的请求。
	NodeAuthReq *NodeAuthRequest `protobuf:"bytes,3,opt,name=node_auth_req,json=nodeAuthReq,proto3,oneof"`
}

type ClusterNodeServiceStepRequest_NodeConsensusReq 

type ClusterNodeServiceStepRequest_NodeConsensusReq struct {
	// NodeConsensusReq 用于在 cluster 成员之间发送共识请求。
	NodeConsensusReq *NodeConsensusRequest `protobuf:"bytes,1,opt,name=node_consensus_req,json=nodeConsensusReq,proto3,oneof"`
}

type ClusterNodeServiceStepRequest_NodeTransactionReq 

type ClusterNodeServiceStepRequest_NodeTransactionReq struct {
	// NodeTransactionOrderReq 用于传递交易的消息。
	NodeTransactionReq *NodeTransactionOrderRequest `protobuf:"bytes,2,opt,name=node_transaction_req,json=nodeTransactionReq,proto3,oneof"`
}

type ClusterNodeServiceStepResponse 

type ClusterNodeServiceStepResponse struct {

	// Types that are assignable to Payload:
	//
	//	*ClusterNodeServiceStepResponse_TransactionOrderRes
	Payload isClusterNodeServiceStepResponse_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

ClusterNodeServiceStepResponse 这个消息结构体用于接收来自 cluster 成员的响应，其中的 Payload 字段 只定义了一种可能的消息：TransactionOrderResponse。

func (*ClusterNodeServiceStepResponse) Descriptor deprecated 

func (*ClusterNodeServiceStepResponse) Descriptor() ([]byte, []int)

Deprecated: Use ClusterNodeServiceStepResponse.ProtoReflect.Descriptor instead.

func (*ClusterNodeServiceStepResponse) GetPayload 

func (m *ClusterNodeServiceStepResponse) GetPayload() isClusterNodeServiceStepResponse_Payload

func (*ClusterNodeServiceStepResponse) GetTransactionOrderRes 

func (x *ClusterNodeServiceStepResponse) GetTransactionOrderRes() *TransactionOrderResponse

func (*ClusterNodeServiceStepResponse) ProtoMessage 

func (*ClusterNodeServiceStepResponse) ProtoMessage()

func (*ClusterNodeServiceStepResponse) ProtoReflect 

func (x *ClusterNodeServiceStepResponse) ProtoReflect() protoreflect.Message

func (*ClusterNodeServiceStepResponse) Reset 

func (x *ClusterNodeServiceStepResponse) Reset()

func (*ClusterNodeServiceStepResponse) String 

func (x *ClusterNodeServiceStepResponse) String() string

type ClusterNodeServiceStepResponse_TransactionOrderRes 

type ClusterNodeServiceStepResponse_TransactionOrderRes struct {
	// TransactionOrderRes 处理交易的响应消息。
	TransactionOrderRes *TransactionOrderResponse `protobuf:"bytes,1,opt,name=transaction_order_res,json=transactionOrderRes,proto3,oneof"`
}

type ClusterNodeService_StepClient 

type ClusterNodeService_StepClient interface {
	Send(*ClusterNodeServiceStepRequest) error
	Recv() (*ClusterNodeServiceStepResponse, error)
	grpc.ClientStream
}

type ClusterNodeService_StepServer 

type ClusterNodeService_StepServer interface {
	Send(*ClusterNodeServiceStepResponse) error
	Recv() (*ClusterNodeServiceStepRequest, error)
	grpc.ServerStream
}

type ClusterServer 

type ClusterServer interface {
	Step(Cluster_StepServer) error
}

ClusterServer is the server API for Cluster service.

type Cluster_StepClient 

type Cluster_StepClient interface {
	Send(*StepRequest) error
	Recv() (*StepResponse, error)
	grpc.ClientStream
}

type Cluster_StepServer 

type Cluster_StepServer interface {
	Send(*StepResponse) error
	Recv() (*StepRequest, error)
	grpc.ServerStream
}

type ConsensusRequest 

type ConsensusRequest struct {

	// Channel 表示消息所属的通道。
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	// Payload 用于携带共识数据的有效载荷。
	Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// Metadata 用于携带与共识相关的元数据。
	Metadata []byte `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

ConsensusRequest 用于共识算法中的消息传递，它将包含共识相关数据的有效载荷和数据发送给集群成员。

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 {
	Type     string              `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Metadata []byte              `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	State    ConsensusType_State `protobuf:"varint,3,opt,name=state,proto3,enum=porderer.ConsensusType_State" json:"state,omitempty"`
	// contains filtered or unexported fields
}

ConsensusType 结构体用于定义共识类型和相关元数据。

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
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
}

DeliverResponse 通过该消息结构，orderer 可以根据请求的不同情况返回不同类型的响应， 包括状态信息和区块内容。这样可以使交付服务更加灵活和具有针对性，满足不同客户端的需求。

func (*DeliverResponse) Descriptor deprecated 

func (*DeliverResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeliverResponse.ProtoReflect.Descriptor instead.

func (*DeliverResponse) GetBlock 

func (x *DeliverResponse) GetBlock() *pcommon.Block

func (*DeliverResponse) GetStatus 

func (x *DeliverResponse) GetStatus() pcommon.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_Block struct {
	// Block 用于返回交付请求中请求的区块内容。
	Block *pcommon.Block `protobuf:"bytes,2,opt,name=block,proto3,oneof"`
}

type DeliverResponse_Status 

type DeliverResponse_Status struct {
	// Status 用于返回交付请求的状态，这个字段通常包含有关请求处理结果的信息，例如
	// 成功与否、错误代码等。
	Status pcommon.Status `protobuf:"varint,1,opt,name=status,proto3,enum=pcommon.Status,oneof"`
}

type NodeAuthRequest 

type NodeAuthRequest struct {

	// Version 表示计算签名的字段版本。
	Version uint32 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	// Signature 可以使用发起者的公钥进行验证的签名。
	Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// Timestamp 指示请求的新鲜度，预期在响应者的本地时间范围。
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// FromId 表示连接发起者的数值标识符。
	FromId uint64 `protobuf:"varint,4,opt,name=from_id,json=fromId,proto3" json:"from_id,omitempty"`
	// ToId 表示正在连接的节点的数值标识符。
	ToId uint64 `protobuf:"varint,5,opt,name=to_id,json=toId,proto3" json:"to_id,omitempty"`
	// SessionBinding 可以使用应用级协议进行验证的会话绑定。
	SessionBinding []byte `protobuf:"bytes,6,opt,name=session_binding,json=sessionBinding,proto3" json:"session_binding,omitempty"`
	// Channel 表示连接所属的通道。
	Channel string `protobuf:"bytes,7,opt,name=channel,proto3" json:"channel,omitempty"`
	// contains filtered or unexported fields
}

NodeAuthRequest 用于在 cluster 成员之间验证 stream 流。

func (*NodeAuthRequest) Descriptor deprecated 

func (*NodeAuthRequest) Descriptor() ([]byte, []int)

Deprecated: Use NodeAuthRequest.ProtoReflect.Descriptor instead.

func (*NodeAuthRequest) GetChannel 

func (x *NodeAuthRequest) GetChannel() string

func (*NodeAuthRequest) GetFromId 

func (x *NodeAuthRequest) GetFromId() uint64

func (*NodeAuthRequest) GetSessionBinding 

func (x *NodeAuthRequest) GetSessionBinding() []byte

func (*NodeAuthRequest) GetSignature 

func (x *NodeAuthRequest) GetSignature() []byte

func (*NodeAuthRequest) GetTimestamp 

func (x *NodeAuthRequest) GetTimestamp() *timestamppb.Timestamp

func (*NodeAuthRequest) GetToId 

func (x *NodeAuthRequest) GetToId() uint64

func (*NodeAuthRequest) GetVersion 

func (x *NodeAuthRequest) GetVersion() uint32

func (*NodeAuthRequest) ProtoMessage 

func (*NodeAuthRequest) ProtoMessage()

func (*NodeAuthRequest) ProtoReflect 

func (x *NodeAuthRequest) ProtoReflect() protoreflect.Message

func (*NodeAuthRequest) Reset 

func (x *NodeAuthRequest) Reset()

func (*NodeAuthRequest) String 

func (x *NodeAuthRequest) String() string

type NodeConsensusRequest 

type NodeConsensusRequest struct {

	// Payload 用于传输共识消息的具体内容。
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// Metadata 用于传输与共识相关的元数据。
	Metadata []byte `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

NodeConsensusRequest 这是一个特定于共识的消息，用于发送给 cluster 成员。

func (*NodeConsensusRequest) Descriptor deprecated 

func (*NodeConsensusRequest) Descriptor() ([]byte, []int)

Deprecated: Use NodeConsensusRequest.ProtoReflect.Descriptor instead.

func (*NodeConsensusRequest) GetMetadata 

func (x *NodeConsensusRequest) GetMetadata() []byte

func (*NodeConsensusRequest) GetPayload 

func (x *NodeConsensusRequest) GetPayload() []byte

func (*NodeConsensusRequest) ProtoMessage 

func (*NodeConsensusRequest) ProtoMessage()

func (*NodeConsensusRequest) ProtoReflect 

func (x *NodeConsensusRequest) ProtoReflect() protoreflect.Message

func (*NodeConsensusRequest) Reset 

func (x *NodeConsensusRequest) Reset()

func (*NodeConsensusRequest) String 

func (x *NodeConsensusRequest) String() string

type NodeTransactionOrderRequest 

type NodeTransactionOrderRequest struct {

	// LastValidationSeq 表示发送者验证此消息的最后配置序列。
	LastValidationSeq uint64 `protobuf:"varint,1,opt,name=last_validation_seq,json=lastValidationSeq,proto3" json:"last_validation_seq,omitempty"`
	// Payload 包含要转发给 cluster 成员的交易。
	Payload *pcommon.Envelope `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

NodeTransactionOrderRequest 用于包装需要进行排序的交易。

func (*NodeTransactionOrderRequest) Descriptor deprecated 

func (*NodeTransactionOrderRequest) Descriptor() ([]byte, []int)

Deprecated: Use NodeTransactionOrderRequest.ProtoReflect.Descriptor instead.

func (*NodeTransactionOrderRequest) GetLastValidationSeq 

func (x *NodeTransactionOrderRequest) GetLastValidationSeq() uint64

func (*NodeTransactionOrderRequest) GetPayload 

func (x *NodeTransactionOrderRequest) GetPayload() *pcommon.Envelope

func (*NodeTransactionOrderRequest) ProtoMessage 

func (*NodeTransactionOrderRequest) ProtoMessage()

func (*NodeTransactionOrderRequest) ProtoReflect 

func (x *NodeTransactionOrderRequest) ProtoReflect() protoreflect.Message

func (*NodeTransactionOrderRequest) Reset 

func (x *NodeTransactionOrderRequest) Reset()

func (*NodeTransactionOrderRequest) String 

func (x *NodeTransactionOrderRequest) String() string

type SeekInfo 

type SeekInfo struct {

	// Start 指定交付开始的位置。
	Start *SeekPosition `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	// Stop 指定交付结束的位置。
	Stop *SeekPosition `protobuf:"bytes,2,opt,name=stop,proto3" json:"stop,omitempty"`
	// Behavior 指定遇到缺失区块时的行为。
	Behavior SeekInfo_SeekBehavior `protobuf:"varint,3,opt,name=behavior,proto3,enum=porderer.SeekInfo_SeekBehavior" json:"behavior,omitempty"`
	// ErrorResponse 指定如何响应交付服务报告的错误。
	ErrorResponse SeekInfo_SeekErrorResponse `` /* 142-byte string literal not displayed */
	// ContentType 指定响应请求时传递的内容类型。
	ContentType SeekInfo_SeekContentType `` /* 134-byte string literal not displayed */
	// contains filtered or unexported fields
}

SeekInfo 该消息结构体可能被用在一个区块链项目中，用于请求和控制区块的传递和处理。 它的功能包括指定请求的区块范围、定义遇到缺失区块时的行为、处理区块提供者错误以及 指定传递的内容类型。通过使用这个消息结构体，可以更灵活地控制区块的传递和处理过程。

func (*SeekInfo) Descriptor deprecated 

func (*SeekInfo) Descriptor() ([]byte, []int)

Deprecated: Use SeekInfo.ProtoReflect.Descriptor instead.

func (*SeekInfo) GetBehavior 

func (x *SeekInfo) GetBehavior() SeekInfo_SeekBehavior

func (*SeekInfo) GetContentType 

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

func (*SeekInfo) Reset 

func (x *SeekInfo) Reset()

func (*SeekInfo) String 

func (x *SeekInfo) String() string

type SeekInfo_SeekBehavior 

type SeekInfo_SeekBehavior int32

SeekBehavior 指定当遇到缺失的区块时的行为。 

const (
	// BLOCK_UNTIL_READY 在请求的区块可用之前阻塞回复。
	SeekInfo_BLOCK_UNTIL_READY SeekInfo_SeekBehavior = 0
	// FAIL_IF_NOT_READY 如果请求的区块不可用，则立马返回错误。
	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 

type SeekInfo_SeekContentType int32

SeekContentType 指示响应请求时传递的内容类型。 

const (
	// BLOCK 传递完整的区块。
	SeekInfo_BLOCK SeekInfo_SeekContentType = 0
	// HEADER_WITHSIG 只传递区块头和签名，不包含有效载荷，用于验证区块是否存在。
	SeekInfo_HEADER_WITHSIG SeekInfo_SeekContentType = 1
)

func (SeekInfo_SeekContentType) Descriptor 

func (SeekInfo_SeekContentType) Descriptor() protoreflect.EnumDescriptor

func (SeekInfo_SeekContentType) Enum 

func (x SeekInfo_SeekContentType) Enum() *SeekInfo_SeekContentType

func (SeekInfo_SeekContentType) EnumDescriptor deprecated 

func (SeekInfo_SeekContentType) EnumDescriptor() ([]byte, []int)

Deprecated: Use SeekInfo_SeekContentType.Descriptor instead.

func (SeekInfo_SeekContentType) Number 

func (x SeekInfo_SeekContentType) Number() protoreflect.EnumNumber

func (SeekInfo_SeekContentType) String 

func (x SeekInfo_SeekContentType) String() string

func (SeekInfo_SeekContentType) Type 

func (SeekInfo_SeekContentType) Type() protoreflect.EnumType

type SeekInfo_SeekErrorResponse 

type SeekInfo_SeekErrorResponse int32

SeekErrorResponse 指示服务器如何容忍区块提供者产生的错误。 

const (
	// STRICT 严格模式，当检测到 orderer 出现问题时，则拒绝交付请求。
	SeekInfo_STRICT SeekInfo_SeekErrorResponse = 0
	// BEST_EFFORT 尽力而为模式，如果共识过程处于错误状态，也会尽力响应区块请求。
	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
}

SeekNewest 这是一个用于请求最新数据的消息结构体。该结构体不含任何 字段。

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 用于指示下一个将被提交的区块，它没有任何字段，用于向 系统发出请求以获取即将提交的下一个区块的信息。

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
}

SeekOldest 这是一个用于请求最旧数据的消息结构体。该结构体不含任何 字段。

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
}

SeekPosition 结构体可以根据需要选择不同的子消息类型来请求不同类型的数据。

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 用于请求最新数据。
	Newest *SeekNewest `protobuf:"bytes,1,opt,name=newest,proto3,oneof"`
}

type SeekPosition_NextCommit 

type SeekPosition_NextCommit struct {
	// NextCommit 用于请求下一个将被提交的区块。
	NextCommit *SeekNextCommit `protobuf:"bytes,4,opt,name=next_commit,json=nextCommit,proto3,oneof"`
}

type SeekPosition_Oldest 

type SeekPosition_Oldest struct {
	// Oldest 用于请求最旧的数据。
	Oldest *SeekOldest `protobuf:"bytes,2,opt,name=oldest,proto3,oneof"`
}

type SeekPosition_Specified 

type SeekPosition_Specified struct {
	// Specified 用于请求指定数据。
	Specified *SeekSpecified `protobuf:"bytes,3,opt,name=specified,proto3,oneof"`
}

type SeekSpecified 

type SeekSpecified struct {

	// Number 用于指定请求的特定数据。
	Number uint64 `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"`
	// contains filtered or unexported fields
}

SeekSpecified 这是一个用于请求指定数据的消息结构体。

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_ConsensusReq
	//	*StepRequest_SubmitReqt
	Payload isStepRequest_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

StepRequest 用于发送共识请求和转发交易请求。

func (*StepRequest) Descriptor deprecated 

func (*StepRequest) Descriptor() ([]byte, []int)

Deprecated: Use StepRequest.ProtoReflect.Descriptor instead.

func (*StepRequest) GetConsensusReq 

func (x *StepRequest) GetConsensusReq() *ConsensusRequest

func (*StepRequest) GetPayload 

func (m *StepRequest) GetPayload() isStepRequest_Payload

func (*StepRequest) GetSubmitReqt 

func (x *StepRequest) GetSubmitReqt() *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_ConsensusReq 

type StepRequest_ConsensusReq struct {
	// ConsensusReq 用于传递共识相关的请求。
	ConsensusReq *ConsensusRequest `protobuf:"bytes,1,opt,name=consensus_req,json=consensusReq,proto3,oneof"`
}

type StepRequest_SubmitReqt 

type StepRequest_SubmitReqt struct {
	// SubmitReq 用于转发交易请求，当一个节点收到一个交易时，它将该交易封装在 SubmitRequest 中，并发送给
	// 其他节点进行处理和验证。
	SubmitReqt *SubmitRequest `protobuf:"bytes,2,opt,name=submit_reqt,json=submitReqt,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 用于接收交易处理结果。

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
	// 中，并发送给相关的节点。
	SubmitRes *SubmitResponse `protobuf:"bytes,1,opt,name=submit_res,json=submitRes,proto3,oneof"`
}

type SubmitRequest 

type SubmitRequest struct {

	// Channel 表示交易所属的通道。
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	// LastValidationSeq 表示发送者验证该消息时的最后配置序列号。
	LastValidationSeq uint64 `protobuf:"varint,2,opt,name=last_validation_seq,json=lastValidationSeq,proto3" json:"last_validation_seq,omitempty"`
	// Payload 封装了要转发给 cluster 成员的交易。
	Payload *pcommon.Envelope `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

SubmitRequest 用于将待排序的交易发送给排序服务进行处理和排序。

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() *pcommon.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 表示交易处理响应消息所属的通道。
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	// Status 指示交易处理结果是成功还是失败。
	Status pcommon.Status `protobuf:"varint,2,opt,name=status,proto3,enum=pcommon.Status" json:"status,omitempty"`
	// Info 是一个字符串，包含交易处理结果的其他附加信息。
	Info string `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

SubmitResponse 用于返回交易处理结果。

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() pcommon.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 

type TransactionOrderResponse struct {

	// Channel 表示交易所属的通道。
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	// TxId 交易的 ID。
	TxId string `protobuf:"bytes,2,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"`
	// Status 交易处理结果的状态码。
	Status pcommon.Status `protobuf:"varint,3,opt,name=status,proto3,enum=pcommon.Status" json:"status,omitempty"`
	// Info 包含有关交易处理结果的附加信息。
	Info string `protobuf:"bytes,4,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

TransactionOrderResponse 用于向交易发送方反馈交易处理结果的信息。

func (*TransactionOrderResponse) Descriptor deprecated 

func (*TransactionOrderResponse) Descriptor() ([]byte, []int)

Deprecated: Use TransactionOrderResponse.ProtoReflect.Descriptor instead.

func (*TransactionOrderResponse) GetChannel 

func (x *TransactionOrderResponse) GetChannel() string

func (*TransactionOrderResponse) GetInfo 

func (x *TransactionOrderResponse) GetInfo() string

func (*TransactionOrderResponse) GetStatus 

func (x *TransactionOrderResponse) GetStatus() pcommon.Status

func (*TransactionOrderResponse) GetTxId 

func (x *TransactionOrderResponse) GetTxId() string

func (*TransactionOrderResponse) ProtoMessage 

func (*TransactionOrderResponse) ProtoMessage()

func (*TransactionOrderResponse) ProtoReflect 

func (x *TransactionOrderResponse) ProtoReflect() protoreflect.Message

func (*TransactionOrderResponse) Reset 

func (x *TransactionOrderResponse) Reset()

func (*TransactionOrderResponse) String 

func (x *TransactionOrderResponse) String() string

type UnimplementedAtomicBroadcastServer 

type UnimplementedAtomicBroadcastServer struct {
}

UnimplementedAtomicBroadcastServer can be embedded to have forward compatible implementations.

func (*UnimplementedAtomicBroadcastServer) Broadcast 

func (*UnimplementedAtomicBroadcastServer) Broadcast(AtomicBroadcast_BroadcastServer) error

func (*UnimplementedAtomicBroadcastServer) Deliver 

func (*UnimplementedAtomicBroadcastServer) Deliver(AtomicBroadcast_DeliverServer) error

type UnimplementedBlockAttestationsServer 

type UnimplementedBlockAttestationsServer struct {
}

UnimplementedBlockAttestationsServer can be embedded to have forward compatible implementations.

func (*UnimplementedBlockAttestationsServer) BlockAttestations 

func (*UnimplementedBlockAttestationsServer) BlockAttestations(*pcommon.Envelope, BlockAttestations_BlockAttestationsServer) error

type UnimplementedClusterNodeServiceServer 

type UnimplementedClusterNodeServiceServer struct {
}

UnimplementedClusterNodeServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedClusterNodeServiceServer) Step 

func (*UnimplementedClusterNodeServiceServer) Step(ClusterNodeService_StepServer) error

type UnimplementedClusterServer 

type UnimplementedClusterServer struct {
}

UnimplementedClusterServer can be embedded to have forward compatible implementations.

func (*UnimplementedClusterServer) Step 

func (*UnimplementedClusterServer) Step(Cluster_StepServer) error

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.