porderer

package
v0.0.0-...-7fbf1d1 Latest Latest
Warning

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

Go to latest
Published: Jun 3, 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_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.

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.

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.

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 (*ClusterNodeServiceStepRequest) Reset

func (x *ClusterNodeServiceStepRequest) Reset()

func (*ClusterNodeServiceStepRequest) 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 (*ClusterNodeServiceStepResponse) Reset

func (x *ClusterNodeServiceStepResponse) Reset()

func (*ClusterNodeServiceStepResponse) 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) Enum

func (ConsensusType_State) EnumDescriptor deprecated

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

Deprecated: Use ConsensusType_State.Descriptor instead.

func (ConsensusType_State) Number

func (ConsensusType_State) String

func (x ConsensusType_State) String() string

func (ConsensusType_State) Type

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 (*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) Enum

func (SeekInfo_SeekBehavior) EnumDescriptor deprecated

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

Deprecated: Use SeekInfo_SeekBehavior.Descriptor instead.

func (SeekInfo_SeekBehavior) Number

func (SeekInfo_SeekBehavior) String

func (x SeekInfo_SeekBehavior) String() string

func (SeekInfo_SeekBehavior) Type

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) Enum

func (SeekInfo_SeekContentType) EnumDescriptor deprecated

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

Deprecated: Use SeekInfo_SeekContentType.Descriptor instead.

func (SeekInfo_SeekContentType) Number

func (SeekInfo_SeekContentType) String

func (x SeekInfo_SeekContentType) String() string

func (SeekInfo_SeekContentType) Type

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) Enum

func (SeekInfo_SeekErrorResponse) EnumDescriptor deprecated

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

Deprecated: Use SeekInfo_SeekErrorResponse.Descriptor instead.

func (SeekInfo_SeekErrorResponse) Number

func (SeekInfo_SeekErrorResponse) String

func (SeekInfo_SeekErrorResponse) Type

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) Deliver

type UnimplementedBlockAttestationsServer

type UnimplementedBlockAttestationsServer struct {
}

UnimplementedBlockAttestationsServer can be embedded to have forward compatible implementations.

func (*UnimplementedBlockAttestationsServer) BlockAttestations

type UnimplementedClusterNodeServiceServer

type UnimplementedClusterNodeServiceServer struct {
}

UnimplementedClusterNodeServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedClusterNodeServiceServer) Step

type UnimplementedClusterServer

type UnimplementedClusterServer struct {
}

UnimplementedClusterServer can be embedded to have forward compatible implementations.

func (*UnimplementedClusterServer) Step

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL