pgossip

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: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	PullMsgType_name = map[int32]string{
		0: "UNDEFINED",
		1: "BLOCK_MSG",
		2: "IDENTITY_MSG",
	}
	PullMsgType_value = map[string]int32{
		"UNDEFINED":    0,
		"BLOCK_MSG":    1,
		"IDENTITY_MSG": 2,
	}
)

Enum value maps for PullMsgType.

View Source 
var (
	GossipMessage_Tag_name = map[int32]string{
		0: "UNDEFINED",
		1: "EMPTY",
		2: "ORG_ONLY",
		3: "CHAN_ONLY",
		4: "CHAN_AND_ORG",
		5: "CHAN_OR_ORG",
	}
	GossipMessage_Tag_value = map[string]int32{
		"UNDEFINED":    0,
		"EMPTY":        1,
		"ORG_ONLY":     2,
		"CHAN_ONLY":    3,
		"CHAN_AND_ORG": 4,
		"CHAN_OR_ORG":  5,
	}
)

Enum value maps for GossipMessage_Tag.

View Source 
var File_message_proto protoreflect.FileDescriptor

Functions

func RegisterGossipServer 

func RegisterGossipServer(s *grpc.Server, srv GossipServer)

Types

type Acknowledgement 

type Acknowledgement struct {

	// Error 响应中可能包含的错误信息。
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

Acknowledgement 结构体用于发送对某个操作的确认或响应，其中可能包含错误信息。

func (*Acknowledgement) Descriptor deprecated 

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

Deprecated: Use Acknowledgement.ProtoReflect.Descriptor instead.

func (*Acknowledgement) GetError 

func (x *Acknowledgement) GetError() string

func (*Acknowledgement) ProtoMessage 

func (*Acknowledgement) ProtoMessage()

func (*Acknowledgement) ProtoReflect 

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

func (*Acknowledgement) Reset 

func (x *Acknowledgement) Reset()

func (*Acknowledgement) String 

func (x *Acknowledgement) String() string

type AliveMessage 

type AliveMessage struct {

	// Member 用于描述对等体的成员身份和状态。
	Membership *Member `protobuf:"bytes,1,opt,name=membership,proto3" json:"membership,omitempty"`
	// Timestamp 用于表示消息的事件信息，包括逻辑事件的增量数和序列号。
	Timestamp *PeerTime `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Identity 对等体的身份信息。
	Identity []byte `protobuf:"bytes,4,opt,name=identity,proto3" json:"identity,omitempty"`
	// contains filtered or unexported fields
}

AliveMessage 用于通知远程对等体存在和活动的信息。

func (*AliveMessage) Descriptor deprecated 

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

Deprecated: Use AliveMessage.ProtoReflect.Descriptor instead.

func (*AliveMessage) GetIdentity 

func (x *AliveMessage) GetIdentity() []byte

func (*AliveMessage) GetMembership 

func (x *AliveMessage) GetMembership() *Member

func (*AliveMessage) GetTimestamp 

func (x *AliveMessage) GetTimestamp() *PeerTime

func (*AliveMessage) ProtoMessage 

func (*AliveMessage) ProtoMessage()

func (*AliveMessage) ProtoReflect 

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

func (*AliveMessage) Reset 

func (x *AliveMessage) Reset()

func (*AliveMessage) String 

func (x *AliveMessage) String() string

type Chaincode 

type Chaincode struct {

	// Name 链码的名称。
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Version 链码的版本号。
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// Metadata 链码的元数据信息。
	Metadata []byte `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

Chaincode 结构体表示安装在一个对等体上的链码信息。

func (*Chaincode) Descriptor deprecated 

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

Deprecated: Use Chaincode.ProtoReflect.Descriptor instead.

func (*Chaincode) GetMetadata 

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

func (*Chaincode) GetName 

func (x *Chaincode) GetName() string

func (*Chaincode) GetVersion 

func (x *Chaincode) GetVersion() string

func (*Chaincode) ProtoMessage 

func (*Chaincode) ProtoMessage()

func (*Chaincode) ProtoReflect 

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

func (*Chaincode) Reset 

func (x *Chaincode) Reset()

func (*Chaincode) String 

func (x *Chaincode) String() string

type ConnEstablish 

type ConnEstablish struct {

	// PkiId 用于证明对等体的身份。
	PkiId []byte `protobuf:"bytes,1,opt,name=pki_id,json=pkiId,proto3" json:"pki_id,omitempty"`
	// Identity 对等体的身份信息。
	Identity []byte `protobuf:"bytes,2,opt,name=identity,proto3" json:"identity,omitempty"`
	// TlsCertHash TLS 证书的哈希值，用于验证对等体的 TLS 证书。
	TlsCertHash []byte `protobuf:"bytes,3,opt,name=tls_cert_hash,json=tlsCertHash,proto3" json:"tls_cert_hash,omitempty"`
	// Probe 探测标志，指示是否进行连接探测。
	Probe bool `protobuf:"varint,4,opt,name=probe,proto3" json:"probe,omitempty"`
	// contains filtered or unexported fields
}

ConnEstablish 该结构体用于在建立连接时使用，当一个对等体连接到另一个对等体时，它会通过 发送这个消息来证明自己的身份。

func (*ConnEstablish) Descriptor deprecated 

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

Deprecated: Use ConnEstablish.ProtoReflect.Descriptor instead.

func (*ConnEstablish) GetIdentity 

func (x *ConnEstablish) GetIdentity() []byte

func (*ConnEstablish) GetPkiId 

func (x *ConnEstablish) GetPkiId() []byte

func (*ConnEstablish) GetProbe 

func (x *ConnEstablish) GetProbe() bool

func (*ConnEstablish) GetTlsCertHash 

func (x *ConnEstablish) GetTlsCertHash() []byte

func (*ConnEstablish) ProtoMessage 

func (*ConnEstablish) ProtoMessage()

func (*ConnEstablish) ProtoReflect 

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

func (*ConnEstablish) Reset 

func (x *ConnEstablish) Reset()

func (*ConnEstablish) String 

func (x *ConnEstablish) String() string

type DataDigest 

type DataDigest struct {

	// Nonce 用于标识消息的唯一性。
	Nonce uint64 `protobuf:"varint,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
	// Digests 数据摘要列表，包含了接收对等体所拥有的数据项。
	Digests [][]byte `protobuf:"bytes,2,rep,name=digests,proto3" json:"digests,omitempty"`
	// MsgType 指示消息的目的和类型。
	MsgType PullMsgType `protobuf:"varint,3,opt,name=msg_type,json=msgType,proto3,enum=pgossip.PullMsgType" json:"msg_type,omitempty"`
	// contains filtered or unexported fields
}

DataDigest 结构体用于从接收对等体发送到发起对等体，包含了接收对等体拥有的数据项的摘要信息。

func (*DataDigest) Descriptor deprecated 

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

Deprecated: Use DataDigest.ProtoReflect.Descriptor instead.

func (*DataDigest) GetDigests 

func (x *DataDigest) GetDigests() [][]byte

func (*DataDigest) GetMsgType 

func (x *DataDigest) GetMsgType() PullMsgType

func (*DataDigest) GetNonce 

func (x *DataDigest) GetNonce() uint64

func (*DataDigest) ProtoMessage 

func (*DataDigest) ProtoMessage()

func (*DataDigest) ProtoReflect 

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

func (*DataDigest) Reset 

func (x *DataDigest) Reset()

func (*DataDigest) String 

func (x *DataDigest) String() string

type DataMessage 

type DataMessage struct {

	// Payload 有效负载，用于包含一个完整的区块。
	Payload *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

DataMessage 结构体包含一个完整的区块。

func (*DataMessage) Descriptor deprecated 

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

Deprecated: Use DataMessage.ProtoReflect.Descriptor instead.

func (*DataMessage) GetPayload 

func (x *DataMessage) GetPayload() *Payload

func (*DataMessage) ProtoMessage 

func (*DataMessage) ProtoMessage()

func (*DataMessage) ProtoReflect 

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

func (*DataMessage) Reset 

func (x *DataMessage) Reset()

func (*DataMessage) String 

func (x *DataMessage) String() string

type DataRequest 

type DataRequest struct {

	// Nonce 用于标识消息的唯一性。
	Nonce uint64 `protobuf:"varint,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
	// Digests 数据摘要列表，用于请求远程对等体的特定数据块。
	Digests [][]byte `protobuf:"bytes,2,rep,name=digests,proto3" json:"digests,omitempty"`
	// MsgType 指示消息的目的和类型。
	MsgType PullMsgType `protobuf:"varint,3,opt,name=msg_type,json=msgType,proto3,enum=pgossip.PullMsgType" json:"msg_type,omitempty"`
	// contains filtered or unexported fields
}

DataRequest 结构体用于发起对等体向远程对等体请求特定数据块的消息。

func (*DataRequest) Descriptor deprecated 

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

Deprecated: Use DataRequest.ProtoReflect.Descriptor instead.

func (*DataRequest) GetDigests 

func (x *DataRequest) GetDigests() [][]byte

func (*DataRequest) GetMsgType 

func (x *DataRequest) GetMsgType() PullMsgType

func (*DataRequest) GetNonce 

func (x *DataRequest) GetNonce() uint64

func (*DataRequest) ProtoMessage 

func (*DataRequest) ProtoMessage()

func (*DataRequest) ProtoReflect 

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

func (*DataRequest) Reset 

func (x *DataRequest) Reset()

func (*DataRequest) String 

func (x *DataRequest) String() string

type DataUpdate 

type DataUpdate struct {

	// Nonce 用于确保消息的唯一性。
	Nonce uint64 `protobuf:"varint,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
	// Data 一个 Envelope 类型的数组，用于存储数据。
	Data []*Envelope `protobuf:"bytes,2,rep,name=data,proto3" json:"data,omitempty"`
	// MsgType 标识消息的类型。
	MsgType PullMsgType `protobuf:"varint,3,opt,name=msg_type,json=msgType,proto3,enum=pgossip.PullMsgType" json:"msg_type,omitempty"`
	// contains filtered or unexported fields
}

DataUpdate 用于在数据传输过程中从接收方向发起方发送数据更新的最后一条消息。

func (*DataUpdate) Descriptor deprecated 

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

Deprecated: Use DataUpdate.ProtoReflect.Descriptor instead.

func (*DataUpdate) GetData 

func (x *DataUpdate) GetData() []*Envelope

func (*DataUpdate) GetMsgType 

func (x *DataUpdate) GetMsgType() PullMsgType

func (*DataUpdate) GetNonce 

func (x *DataUpdate) GetNonce() uint64

func (*DataUpdate) ProtoMessage 

func (*DataUpdate) ProtoMessage()

func (*DataUpdate) ProtoReflect 

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

func (*DataUpdate) Reset 

func (x *DataUpdate) Reset()

func (*DataUpdate) String 

func (x *DataUpdate) String() string

type Empty 

type Empty struct {
	// contains filtered or unexported fields
}

Empty 一个空消息，用于 Ping 请求。

func (*Empty) Descriptor deprecated 

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

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

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

type Envelope 

type Envelope struct {

	// Payload 字段用于存储要传输的数据，以字节形式表示。
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// Signature 字段用于存储对 Payload 进行签名的结果。
	Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// SecretEnvelope 字段用于存储 SecretEnvelope 结构体的实例，用于在某些情况下对数据进行加密和保护。
	SecretEnvelope *SecretEnvelope `protobuf:"bytes,3,opt,name=secret_envelope,json=secretEnvelope,proto3" json:"secret_envelope,omitempty"`
	// contains filtered or unexported fields
}

Envelope 结构体用于封装数据和签名。

func (*Envelope) Descriptor deprecated 

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

Deprecated: Use Envelope.ProtoReflect.Descriptor instead.

func (*Envelope) GetPayload 

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

func (*Envelope) GetSecretEnvelope 

func (x *Envelope) GetSecretEnvelope() *SecretEnvelope

func (*Envelope) GetSignature 

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

func (*Envelope) ProtoMessage 

func (*Envelope) ProtoMessage()

func (*Envelope) ProtoReflect 

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

func (*Envelope) Reset 

func (x *Envelope) Reset()

func (*Envelope) String 

func (x *Envelope) String() string

type GossipClient 

type GossipClient interface {
	// GossipStream 这是一个双向的 gRPC 流，用于节点之间的消息传递。每个节点可以通过该流发送消息给其他节点，
	// 并接收来自其他节点的消息。这样可以实现节点之间的信息同步和传递。
	GossipStream(ctx context.Context, opts ...grpc.CallOption) (Gossip_GossipStreamClient, error)
	// Ping 这是一个用于探测远程节点存活状态的功能。一个节点可以向其他节点发送 Ping 请求，如果对方节点响应了
	// Ping 请求，说明该节点是存活的。
	Ping(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
}

GossipClient is the client API for Gossip service.

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

func NewGossipClient 

func NewGossipClient(cc grpc.ClientConnInterface) GossipClient

type GossipHello 

type GossipHello struct {

	// Nonce 用于标识消息的唯一性。
	Nonce uint64 `protobuf:"varint,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
	// Metadata 存储元数据信息。
	Metadata []byte `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// MsgType 指示消息的类型和目的。
	MsgType PullMsgType `protobuf:"varint,3,opt,name=msg_type,json=msgType,proto3,enum=pgossip.PullMsgType" json:"msg_type,omitempty"`
	// contains filtered or unexported fields
}

GossipHello 结构体用于在对等体之间同步数据时使用。

func (*GossipHello) Descriptor deprecated 

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

Deprecated: Use GossipHello.ProtoReflect.Descriptor instead.

func (*GossipHello) GetMetadata 

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

func (*GossipHello) GetMsgType 

func (x *GossipHello) GetMsgType() PullMsgType

func (*GossipHello) GetNonce 

func (x *GossipHello) GetNonce() uint64

func (*GossipHello) ProtoMessage 

func (*GossipHello) ProtoMessage()

func (*GossipHello) ProtoReflect 

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

func (*GossipHello) Reset 

func (x *GossipHello) Reset()

func (*GossipHello) String 

func (x *GossipHello) String() string

type GossipMessage 

type GossipMessage struct {

	// Nonce 用于测试的字段。
	Nonce uint64 `protobuf:"varint,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
	// Channel 用于标识消息所属的通道。当此字段被设置成空时，则代表此消息是跨通道的。
	Channel []byte            `protobuf:"bytes,2,opt,name=channel,proto3" json:"channel,omitempty"`
	Tag     GossipMessage_Tag `protobuf:"varint,3,opt,name=tag,proto3,enum=pgossip.GossipMessage_Tag" json:"tag,omitempty"`
	// Content 用于指定 GossipMessage 消息的具体内容。
	//
	// Types that are assignable to Content:
	//
	//	*GossipMessage_AliveMsg
	//	*GossipMessage_MemReq
	//	*GossipMessage_MemRes
	//	*GossipMessage_DataMsg
	//	*GossipMessage_Hello
	//	*GossipMessage_DataDig
	//	*GossipMessage_DataReq
	//	*GossipMessage_DataUpdate
	//	*GossipMessage_Empty
	//	*GossipMessage_ConnEstablish
	//	*GossipMessage_StateInfo
	//	*GossipMessage_StateInfoSnapshot
	//	*GossipMessage_StateInfoPullReq
	//	*GossipMessage_RemoteStateReq
	//	*GossipMessage_RemoteStateRes
	//	*GossipMessage_LeadershipMsg
	//	*GossipMessage_PeerIdentity
	//	*GossipMessage_Ack
	//	*GossipMessage_RemotePvtDataReq
	//	*GossipMessage_RemotePvtDataRes
	//	*GossipMessage_PrivateDataMsg
	Content isGossipMessage_Content `protobuf_oneof:"content"`
	// contains filtered or unexported fields
}

GossipMessage 结构体用于组装在 P2P 网络中传输的消息。

func (*GossipMessage) Descriptor deprecated 

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

Deprecated: Use GossipMessage.ProtoReflect.Descriptor instead.

func (*GossipMessage) GetAck 

func (x *GossipMessage) GetAck() *Acknowledgement

func (*GossipMessage) GetAliveMsg 

func (x *GossipMessage) GetAliveMsg() *AliveMessage

func (*GossipMessage) GetChannel 

func (x *GossipMessage) GetChannel() []byte

func (*GossipMessage) GetConnEstablish 

func (x *GossipMessage) GetConnEstablish() *ConnEstablish

func (*GossipMessage) GetContent 

func (m *GossipMessage) GetContent() isGossipMessage_Content

func (*GossipMessage) GetDataDig 

func (x *GossipMessage) GetDataDig() *DataDigest

func (*GossipMessage) GetDataMsg 

func (x *GossipMessage) GetDataMsg() *DataMessage

func (*GossipMessage) GetDataReq 

func (x *GossipMessage) GetDataReq() *DataRequest

func (*GossipMessage) GetDataUpdate 

func (x *GossipMessage) GetDataUpdate() *DataUpdate

func (*GossipMessage) GetEmpty 

func (x *GossipMessage) GetEmpty() *Empty

func (*GossipMessage) GetHello 

func (x *GossipMessage) GetHello() *GossipHello

func (*GossipMessage) GetLeadershipMsg 

func (x *GossipMessage) GetLeadershipMsg() *LeadershipMessage

func (*GossipMessage) GetMemReq 

func (x *GossipMessage) GetMemReq() *MembershipRequest

func (*GossipMessage) GetMemRes 

func (x *GossipMessage) GetMemRes() *MembershipResponse

func (*GossipMessage) GetNonce 

func (x *GossipMessage) GetNonce() uint64

func (*GossipMessage) GetPeerIdentity 

func (x *GossipMessage) GetPeerIdentity() *PeerIdentity

func (*GossipMessage) GetPrivateDataMsg 

func (x *GossipMessage) GetPrivateDataMsg() *PrivateDataMessage

func (*GossipMessage) GetRemotePvtDataReq 

func (x *GossipMessage) GetRemotePvtDataReq() *RemotePvtDataRequest

func (*GossipMessage) GetRemotePvtDataRes 

func (x *GossipMessage) GetRemotePvtDataRes() *RemotePvtDataResponse

func (*GossipMessage) GetRemoteStateReq 

func (x *GossipMessage) GetRemoteStateReq() *RemoteStateRequest

func (*GossipMessage) GetRemoteStateRes 

func (x *GossipMessage) GetRemoteStateRes() *RemoteStateResponse

func (*GossipMessage) GetStateInfo 

func (x *GossipMessage) GetStateInfo() *StateInfo

func (*GossipMessage) GetStateInfoPullReq 

func (x *GossipMessage) GetStateInfoPullReq() *StateInfoPullRequest

func (*GossipMessage) GetStateInfoSnapshot 

func (x *GossipMessage) GetStateInfoSnapshot() *StateInfoSnapshot

func (*GossipMessage) GetTag 

func (x *GossipMessage) GetTag() GossipMessage_Tag

func (*GossipMessage) ProtoMessage 

func (*GossipMessage) ProtoMessage()

func (*GossipMessage) ProtoReflect 

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

func (*GossipMessage) Reset 

func (x *GossipMessage) Reset()

func (*GossipMessage) String 

func (x *GossipMessage) String() string

type GossipMessage_Ack 

type GossipMessage_Ack struct {
	// Ack 用于确认接收到的消息。
	Ack *Acknowledgement `protobuf:"bytes,21,opt,name=ack,proto3,oneof"`
}

type GossipMessage_AliveMsg 

type GossipMessage_AliveMsg struct {
	// AliveMsg 成员身份验证消息。
	AliveMsg *AliveMessage `protobuf:"bytes,4,opt,name=alive_msg,json=aliveMsg,proto3,oneof"`
}

type GossipMessage_ConnEstablish 

type GossipMessage_ConnEstablish struct {
	// ConnEstablish 用于建立连接的消息。
	ConnEstablish *ConnEstablish `protobuf:"bytes,13,opt,name=conn_establish,json=connEstablish,proto3,oneof"`
}

type GossipMessage_DataDig 

type GossipMessage_DataDig struct {
	// DataDigest 分类账的数据摘要。
	DataDig *DataDigest `protobuf:"bytes,9,opt,name=data_dig,json=dataDig,proto3,oneof"`
}

type GossipMessage_DataMsg 

type GossipMessage_DataMsg struct {
	// DataMsg 包含账本区块的消息。
	DataMsg *DataMessage `protobuf:"bytes,7,opt,name=data_msg,json=dataMsg,proto3,oneof"`
}

type GossipMessage_DataReq 

type GossipMessage_DataReq struct {
	// DataReq 请求分类账数据的消息。
	DataReq *DataRequest `protobuf:"bytes,10,opt,name=data_req,json=dataReq,proto3,oneof"`
}

type GossipMessage_DataUpdate 

type GossipMessage_DataUpdate struct {
	// DataUpdate 分类账数据更新消息。
	DataUpdate *DataUpdate `protobuf:"bytes,11,opt,name=data_update,json=dataUpdate,proto3,oneof"`
}

type GossipMessage_Empty 

type GossipMessage_Empty struct {
	// Empty 空消息，用于 Ping 测试。
	Empty *Empty `protobuf:"bytes,12,opt,name=empty,proto3,oneof"`
}

type GossipMessage_Hello 

type GossipMessage_Hello struct {
	// Hello 用于问候对等方的消息。
	Hello *GossipHello `protobuf:"bytes,8,opt,name=hello,proto3,oneof"`
}

type GossipMessage_LeadershipMsg 

type GossipMessage_LeadershipMsg struct {
	// LeadershipMsg 用于指示对等体成为领导者的意图。
	LeadershipMsg *LeadershipMessage `protobuf:"bytes,19,opt,name=leadership_msg,json=leadershipMsg,proto3,oneof"`
}

type GossipMessage_MemReq 

type GossipMessage_MemReq struct {
	// MemReq 用于发送成员请求。
	MemReq *MembershipRequest `protobuf:"bytes,5,opt,name=mem_req,json=memReq,proto3,oneof"`
}

type GossipMessage_MemRes 

type GossipMessage_MemRes struct {
	// MemRes 用于响应成员请求。
	MemRes *MembershipResponse `protobuf:"bytes,6,opt,name=mem_res,json=memRes,proto3,oneof"`
}

type GossipMessage_PeerIdentity 

type GossipMessage_PeerIdentity struct {
	// PeerIdentity 用于了解对等方的证书。
	PeerIdentity *PeerIdentity `protobuf:"bytes,20,opt,name=peer_identity,json=peerIdentity,proto3,oneof"`
}

type GossipMessage_PrivateDataMsg 

type GossipMessage_PrivateDataMsg struct {
	// PrivateDataMsg 用于封装私有数据，用于在背书之后分发私有读写集。
	PrivateDataMsg *PrivateDataMessage `protobuf:"bytes,24,opt,name=private_data_msg,json=privateDataMsg,proto3,oneof"`
}

type GossipMessage_RemotePvtDataReq 

type GossipMessage_RemotePvtDataReq struct {
	// RemotePvtDataReq 用于请求私有数据。
	RemotePvtDataReq *RemotePvtDataRequest `protobuf:"bytes,22,opt,name=remote_pvt_data_req,json=remotePvtDataReq,proto3,oneof"`
}

type GossipMessage_RemotePvtDataRes 

type GossipMessage_RemotePvtDataRes struct {
	// RemotePvtDataRes 用于响应私有数据请求。
	RemotePvtDataRes *RemotePvtDataResponse `protobuf:"bytes,23,opt,name=remote_pvt_data_res,json=remotePvtDataRes,proto3,oneof"`
}

type GossipMessage_RemoteStateReq 

type GossipMessage_RemoteStateReq struct {
	// RemoteStateReq 从远程对等方请求一组区块。
	RemoteStateReq *RemoteStateRequest `protobuf:"bytes,17,opt,name=remote_state_req,json=remoteStateReq,proto3,oneof"`
}

type GossipMessage_RemoteStateRes 

type GossipMessage_RemoteStateRes struct {
	// RemoteStateRes 向远程对等方发送一组区块。
	RemoteStateRes *RemoteStateResponse `protobuf:"bytes,18,opt,name=remote_state_res,json=remoteStateRes,proto3,oneof"`
}

type GossipMessage_StateInfo 

type GossipMessage_StateInfo struct {
	// StateInfo 关于状态信息的消息。
	StateInfo *StateInfo `protobuf:"bytes,14,opt,name=state_info,json=stateInfo,proto3,oneof"`
}

type GossipMessage_StateInfoPullReq 

type GossipMessage_StateInfoPullReq struct {
	// StateInfoPullReq 请求状态信息的请求消息。
	StateInfoPullReq *StateInfoPullRequest `protobuf:"bytes,16,opt,name=state_info_pull_req,json=stateInfoPullReq,proto3,oneof"`
}

type GossipMessage_StateInfoSnapshot 

type GossipMessage_StateInfoSnapshot struct {
	// StateInfoSnapshot 关于状态信息的一组消息，一般用于状态同步。
	StateInfoSnapshot *StateInfoSnapshot `protobuf:"bytes,15,opt,name=state_info_snapshot,json=stateInfoSnapshot,proto3,oneof"`
}

type GossipMessage_Tag 

type GossipMessage_Tag int32

Tag 枚举类型，用于确定允许将消息转发给哪些对等方。 

const (
	// UNDEFINED 未定义的标签。
	GossipMessage_UNDEFINED GossipMessage_Tag = 0
	// EMPTY 空标签，表示消息不需要转发给任何对等方。
	GossipMessage_EMPTY GossipMessage_Tag = 1
	// ORG_ONLY 只对组织内的对等方转发消息。
	GossipMessage_ORG_ONLY GossipMessage_Tag = 2
	// CHAN_ONLY 只对通道内的对等方转发消息。
	GossipMessage_CHAN_ONLY GossipMessage_Tag = 3
	// CHAN_AND_ORG 对通道内和组织内的对等方转发消息。
	GossipMessage_CHAN_AND_ORG GossipMessage_Tag = 4
	// CHAN_OR_ORG 对通道内的对等方或组织内的对等方转发消息。
	GossipMessage_CHAN_OR_ORG GossipMessage_Tag = 5
)

func (GossipMessage_Tag) Descriptor 

func (GossipMessage_Tag) Descriptor() protoreflect.EnumDescriptor

func (GossipMessage_Tag) Enum 

func (x GossipMessage_Tag) Enum() *GossipMessage_Tag

func (GossipMessage_Tag) EnumDescriptor deprecated 

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

Deprecated: Use GossipMessage_Tag.Descriptor instead.

func (GossipMessage_Tag) Number 

func (x GossipMessage_Tag) Number() protoreflect.EnumNumber

func (GossipMessage_Tag) String 

func (x GossipMessage_Tag) String() string

func (GossipMessage_Tag) Type 

func (GossipMessage_Tag) Type() protoreflect.EnumType

type GossipServer 

type GossipServer interface {
	// GossipStream 这是一个双向的 gRPC 流，用于节点之间的消息传递。每个节点可以通过该流发送消息给其他节点，
	// 并接收来自其他节点的消息。这样可以实现节点之间的信息同步和传递。
	GossipStream(Gossip_GossipStreamServer) error
	// Ping 这是一个用于探测远程节点存活状态的功能。一个节点可以向其他节点发送 Ping 请求，如果对方节点响应了
	// Ping 请求，说明该节点是存活的。
	Ping(context.Context, *Empty) (*Empty, error)
}

GossipServer is the server API for Gossip service.

type Gossip_GossipStreamClient 

type Gossip_GossipStreamClient interface {
	Send(*Envelope) error
	Recv() (*Envelope, error)
	grpc.ClientStream
}

type Gossip_GossipStreamServer 

type Gossip_GossipStreamServer interface {
	Send(*Envelope) error
	Recv() (*Envelope, error)
	grpc.ServerStream
}

type LeadershipMessage 

type LeadershipMessage struct {

	// PkiId 是一个字节数组，用于表示公钥基础设施的标识。
	PkiId []byte `protobuf:"bytes,1,opt,name=pki_id,json=pkiId,proto3" json:"pki_id,omitempty"`
	// Timestamp 用于表示消息的时间戳。
	Timestamp *PeerTime `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// IsDeclaration 用于指示此消息是否为声明自己是 leader 的消息。
	IsDeclaration bool `protobuf:"varint,3,opt,name=is_declaration,json=isDeclaration,proto3" json:"is_declaration,omitempty"`
	// contains filtered or unexported fields
}

LeadershipMessage 包含了领导者信息的相关内容。

func (*LeadershipMessage) Descriptor deprecated 

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

Deprecated: Use LeadershipMessage.ProtoReflect.Descriptor instead.

func (*LeadershipMessage) GetIsDeclaration 

func (x *LeadershipMessage) GetIsDeclaration() bool

func (*LeadershipMessage) GetPkiId 

func (x *LeadershipMessage) GetPkiId() []byte

func (*LeadershipMessage) GetTimestamp 

func (x *LeadershipMessage) GetTimestamp() *PeerTime

func (*LeadershipMessage) ProtoMessage 

func (*LeadershipMessage) ProtoMessage()

func (*LeadershipMessage) ProtoReflect 

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

func (*LeadershipMessage) Reset 

func (x *LeadershipMessage) Reset()

func (*LeadershipMessage) String 

func (x *LeadershipMessage) String() string

type Member 

type Member struct {

	// Endpoint 成员的网络端点信息。
	Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// Metadata 成员的元数据。
	Metadata []byte `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// PkiId 标识成员。
	PkiId []byte `protobuf:"bytes,3,opt,name=pki_id,json=pkiId,proto3" json:"pki_id,omitempty"`
	// contains filtered or unexported fields
}

Member 成员信息。

func (*Member) Descriptor deprecated 

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

Deprecated: Use Member.ProtoReflect.Descriptor instead.

func (*Member) GetEndpoint 

func (x *Member) GetEndpoint() string

func (*Member) GetMetadata 

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

func (*Member) GetPkiId 

func (x *Member) GetPkiId() []byte

func (*Member) ProtoMessage 

func (*Member) ProtoMessage()

func (*Member) ProtoReflect 

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

func (*Member) Reset 

func (x *Member) Reset()

func (*Member) String 

func (x *Member) String() string

type MembershipRequest 

type MembershipRequest struct {

	// SelfInformation 字段包含了关于自身的信息。
	SelfInformation *Envelope `protobuf:"bytes,1,opt,name=self_information,json=selfInformation,proto3" json:"self_information,omitempty"`
	// contains filtered or unexported fields
}

MembershipRequest 该结构体用于向远程对等体请求成员信息。

func (*MembershipRequest) Descriptor deprecated 

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

Deprecated: Use MembershipRequest.ProtoReflect.Descriptor instead.

func (*MembershipRequest) GetSelfInformation 

func (x *MembershipRequest) GetSelfInformation() *Envelope

func (*MembershipRequest) ProtoMessage 

func (*MembershipRequest) ProtoMessage()

func (*MembershipRequest) ProtoReflect 

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

func (*MembershipRequest) Reset 

func (x *MembershipRequest) Reset()

func (*MembershipRequest) String 

func (x *MembershipRequest) String() string

type MembershipResponse 

type MembershipResponse struct {

	// Alive 存活的成员列表，包含一组 Envelope，每个 Envelope 包含有关存活成员的信息。
	Alive []*Envelope `protobuf:"bytes,1,rep,name=alive,proto3" json:"alive,omitempty"`
	// Dead 已经离开的成员列表，包含一组 Envelope，每个 Envelope 包含有关已离开成员的信息。
	Dead []*Envelope `protobuf:"bytes,2,rep,name=dead,proto3" json:"dead,omitempty"`
	// contains filtered or unexported fields
}

MembershipResponse 结构体用于响应成员请求。

func (*MembershipResponse) Descriptor deprecated 

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

Deprecated: Use MembershipResponse.ProtoReflect.Descriptor instead.

func (*MembershipResponse) GetAlive 

func (x *MembershipResponse) GetAlive() []*Envelope

func (*MembershipResponse) GetDead 

func (x *MembershipResponse) GetDead() []*Envelope

func (*MembershipResponse) ProtoMessage 

func (*MembershipResponse) ProtoMessage()

func (*MembershipResponse) ProtoReflect 

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

func (*MembershipResponse) Reset 

func (x *MembershipResponse) Reset()

func (*MembershipResponse) String 

func (x *MembershipResponse) String() string

type Payload 

type Payload struct {

	// SeqNum 表示序列号。
	SeqNum uint64 `protobuf:"varint,1,opt,name=seq_num,json=seqNum,proto3" json:"seq_num,omitempty"`
	// Data 用于存储区块数据。
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// PrivateData 该字段是一个字节数组列表，用于存储多个私有数据。
	PrivateData [][]byte `protobuf:"bytes,3,rep,name=private_data,json=privateData,proto3" json:"private_data,omitempty"`
	// contains filtered or unexported fields
}

Payload 内包含了一个区块的信息。

func (*Payload) Descriptor deprecated 

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

Deprecated: Use Payload.ProtoReflect.Descriptor instead.

func (*Payload) GetData 

func (x *Payload) GetData() []byte

func (*Payload) GetPrivateData 

func (x *Payload) GetPrivateData() [][]byte

func (*Payload) GetSeqNum 

func (x *Payload) GetSeqNum() uint64

func (*Payload) ProtoMessage 

func (*Payload) ProtoMessage()

func (*Payload) ProtoReflect 

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

func (*Payload) Reset 

func (x *Payload) Reset()

func (*Payload) String 

func (x *Payload) String() string

type PeerIdentity 

type PeerIdentity struct {

	// PkiId 字段是一个字节数组，用于表示公钥基础设施的标识。
	PkiId []byte `protobuf:"bytes,1,opt,name=pki_id,json=pkiId,proto3" json:"pki_id,omitempty"`
	// Cert 用于存储证书信息。
	Cert []byte `protobuf:"bytes,2,opt,name=cert,proto3" json:"cert,omitempty"`
	// Metadata 用于存储关于对等体的元数据信息。
	Metadata []byte `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

PeerIdentity 包含了对等体的身份信息。

func (*PeerIdentity) Descriptor deprecated 

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

Deprecated: Use PeerIdentity.ProtoReflect.Descriptor instead.

func (*PeerIdentity) GetCert 

func (x *PeerIdentity) GetCert() []byte

func (*PeerIdentity) GetMetadata 

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

func (*PeerIdentity) GetPkiId 

func (x *PeerIdentity) GetPkiId() []byte

func (*PeerIdentity) ProtoMessage 

func (*PeerIdentity) ProtoMessage()

func (*PeerIdentity) ProtoReflect 

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

func (*PeerIdentity) Reset 

func (x *PeerIdentity) Reset()

func (*PeerIdentity) String 

func (x *PeerIdentity) String() string

type PeerTime 

type PeerTime struct {

	// IncNum 用于表示对等体的逻辑时间的增量数。
	IncNum uint64 `protobuf:"varint,1,opt,name=inc_num,json=incNum,proto3" json:"inc_num,omitempty"`
	// SeqNum 用于表示对等体的逻辑时间的序列号。
	SeqNum uint64 `protobuf:"varint,2,opt,name=seq_num,json=seqNum,proto3" json:"seq_num,omitempty"`
	// contains filtered or unexported fields
}

PeerTime 该结构体用于表示对等体的时间戳。

func (*PeerTime) Descriptor deprecated 

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

Deprecated: Use PeerTime.ProtoReflect.Descriptor instead.

func (*PeerTime) GetIncNum 

func (x *PeerTime) GetIncNum() uint64

func (*PeerTime) GetSeqNum 

func (x *PeerTime) GetSeqNum() uint64

func (*PeerTime) ProtoMessage 

func (*PeerTime) ProtoMessage()

func (*PeerTime) ProtoReflect 

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

func (*PeerTime) Reset 

func (x *PeerTime) Reset()

func (*PeerTime) String 

func (x *PeerTime) String() string

type PrivateDataMessage 

type PrivateDataMessage struct {
	Payload *PrivatePayload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

PrivateDataMessage 用于封装私有数据。

func (*PrivateDataMessage) Descriptor deprecated 

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

Deprecated: Use PrivateDataMessage.ProtoReflect.Descriptor instead.

func (*PrivateDataMessage) GetPayload 

func (x *PrivateDataMessage) GetPayload() *PrivatePayload

func (*PrivateDataMessage) ProtoMessage 

func (*PrivateDataMessage) ProtoMessage()

func (*PrivateDataMessage) ProtoReflect 

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

func (*PrivateDataMessage) Reset 

func (x *PrivateDataMessage) Reset()

func (*PrivateDataMessage) String 

func (x *PrivateDataMessage) String() string

type PrivatePayload 

type PrivatePayload struct {

	// CollectionName 用于在路由时基于集合分区进行定位。
	CollectionName string `protobuf:"bytes,1,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	// Namespace 用于标识私有数据所属的命名空间。
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// TxId 表示交易的 ID。
	TxId string `protobuf:"bytes,3,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"`
	// PrivateRwset 用于存储私有读写集。
	PrivateRwset []byte `protobuf:"bytes,4,opt,name=private_rwset,json=privateRwset,proto3" json:"private_rwset,omitempty"`
	// PrivateSimHeight 表示私有数据提交高度。
	PrivateSimHeight uint64 `protobuf:"varint,5,opt,name=private_sim_height,json=privateSimHeight,proto3" json:"private_sim_height,omitempty"`
	// CollectionConfigs 此字段类型为 ppeer.CollectionConfigPackage，用于存储集合的配置信息。
	CollectionConfigs *ppeer.CollectionConfigPackage `protobuf:"bytes,6,opt,name=collection_configs,json=collectionConfigs,proto3" json:"collection_configs,omitempty"`
	// contains filtered or unexported fields
}

PrivatePayload 结构体用于封装私有数据。

func (*PrivatePayload) Descriptor deprecated 

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

Deprecated: Use PrivatePayload.ProtoReflect.Descriptor instead.

func (*PrivatePayload) GetCollectionConfigs 

func (x *PrivatePayload) GetCollectionConfigs() *ppeer.CollectionConfigPackage

func (*PrivatePayload) GetCollectionName 

func (x *PrivatePayload) GetCollectionName() string

func (*PrivatePayload) GetNamespace 

func (x *PrivatePayload) GetNamespace() string

func (*PrivatePayload) GetPrivateRwset 

func (x *PrivatePayload) GetPrivateRwset() []byte

func (*PrivatePayload) GetPrivateSimHeight 

func (x *PrivatePayload) GetPrivateSimHeight() uint64

func (*PrivatePayload) GetTxId 

func (x *PrivatePayload) GetTxId() string

func (*PrivatePayload) ProtoMessage 

func (*PrivatePayload) ProtoMessage()

func (*PrivatePayload) ProtoReflect 

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

func (*PrivatePayload) Reset 

func (x *PrivatePayload) Reset()

func (*PrivatePayload) String 

func (x *PrivatePayload) String() string

type Properties 

type Properties struct {

	// LedgerHeight 账本高度。
	LedgerHeight uint64 `protobuf:"varint,1,opt,name=ledger_height,json=ledgerHeight,proto3" json:"ledger_height,omitempty"`
	// LeftChannel 是否离开通道的标志。
	LeftChannel bool `protobuf:"varint,2,opt,name=left_channel,json=leftChannel,proto3" json:"left_channel,omitempty"`
	// Chaincodes 链码列表。
	Chaincodes []*Chaincode `protobuf:"bytes,3,rep,name=chaincodes,proto3" json:"chaincodes,omitempty"`
	// contains filtered or unexported fields
}

Properties 包含了对等体的一些属性信息。

func (*Properties) Descriptor deprecated 

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

Deprecated: Use Properties.ProtoReflect.Descriptor instead.

func (*Properties) GetChaincodes 

func (x *Properties) GetChaincodes() []*Chaincode

func (*Properties) GetLedgerHeight 

func (x *Properties) GetLedgerHeight() uint64

func (*Properties) GetLeftChannel 

func (x *Properties) GetLeftChannel() bool

func (*Properties) ProtoMessage 

func (*Properties) ProtoMessage()

func (*Properties) ProtoReflect 

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

func (*Properties) Reset 

func (x *Properties) Reset()

func (*Properties) String 

func (x *Properties) String() string

type PullMsgType 

type PullMsgType int32

PullMsgType 指定了 Gossip 消息的类型。 

const (
	// UNDEFINED 表示未定义的消息类型。
	PullMsgType_UNDEFINED PullMsgType = 0
	// BLOCK_MSG 表示包含一个区块的消息。
	PullMsgType_BLOCK_MSG PullMsgType = 1
	// IDENTITY_MSG 表示包含身份信息的消息类型。
	PullMsgType_IDENTITY_MSG PullMsgType = 2
)

func (PullMsgType) Descriptor 

func (PullMsgType) Descriptor() protoreflect.EnumDescriptor

func (PullMsgType) Enum 

func (x PullMsgType) Enum() *PullMsgType

func (PullMsgType) EnumDescriptor deprecated 

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

Deprecated: Use PullMsgType.Descriptor instead.

func (PullMsgType) Number 

func (x PullMsgType) Number() protoreflect.EnumNumber

func (PullMsgType) String 

func (x PullMsgType) String() string

func (PullMsgType) Type 

func (PullMsgType) Type() protoreflect.EnumType

type PvtDataDigest 

type PvtDataDigest struct {

	// TxId 是一个字符串，表示交易的 ID。
	TxId string `protobuf:"bytes,1,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"`
	// Namespace 表示私有数据所属的命名空间。
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Collection 表示私有数据所属的集合。
	Collection string `protobuf:"bytes,3,opt,name=collection,proto3" json:"collection,omitempty"`
	// BlockSeq 表示所属的区块的序列号。
	BlockSeq uint64 `protobuf:"varint,4,opt,name=block_seq,json=blockSeq,proto3" json:"block_seq,omitempty"`
	// SeqInBlock 表示私有数据在区块中的位置。
	SeqInBlock uint64 `protobuf:"varint,5,opt,name=seq_in_block,json=seqInBlock,proto3" json:"seq_in_block,omitempty"`
	// contains filtered or unexported fields
}

PvtDataDigest 定义了私有数据的摘要信息。

func (*PvtDataDigest) Descriptor deprecated 

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

Deprecated: Use PvtDataDigest.ProtoReflect.Descriptor instead.

func (*PvtDataDigest) GetBlockSeq 

func (x *PvtDataDigest) GetBlockSeq() uint64

func (*PvtDataDigest) GetCollection 

func (x *PvtDataDigest) GetCollection() string

func (*PvtDataDigest) GetNamespace 

func (x *PvtDataDigest) GetNamespace() string

func (*PvtDataDigest) GetSeqInBlock 

func (x *PvtDataDigest) GetSeqInBlock() uint64

func (*PvtDataDigest) GetTxId 

func (x *PvtDataDigest) GetTxId() string

func (*PvtDataDigest) ProtoMessage 

func (*PvtDataDigest) ProtoMessage()

func (*PvtDataDigest) ProtoReflect 

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

func (*PvtDataDigest) Reset 

func (x *PvtDataDigest) Reset()

func (*PvtDataDigest) String 

func (x *PvtDataDigest) String() string

type PvtDataElement 

type PvtDataElement struct {

	// Digest 是一个 PvtDataDigest 类型的字段，包含私有数据的摘要信息。
	Digest *PvtDataDigest `protobuf:"bytes,1,opt,name=digest,proto3" json:"digest,omitempty"`
	// Payload 该字段是一个字节数组列表，用于存储序列化后的键值读写集数据 (kvrwset.KVRWSet)。
	Payload [][]byte `protobuf:"bytes,2,rep,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

PvtDataElement 包含了私有数据的元素信息。

func (*PvtDataElement) Descriptor deprecated 

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

Deprecated: Use PvtDataElement.ProtoReflect.Descriptor instead.

func (*PvtDataElement) GetDigest 

func (x *PvtDataElement) GetDigest() *PvtDataDigest

func (*PvtDataElement) GetPayload 

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

func (*PvtDataElement) ProtoMessage 

func (*PvtDataElement) ProtoMessage()

func (*PvtDataElement) ProtoReflect 

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

func (*PvtDataElement) Reset 

func (x *PvtDataElement) Reset()

func (*PvtDataElement) String 

func (x *PvtDataElement) String() string

type PvtDataPayload 

type PvtDataPayload struct {
	TxSeqInBlock uint64 `protobuf:"varint,1,opt,name=tx_seq_in_block,json=txSeqInBlock,proto3" json:"tx_seq_in_block,omitempty"`
	Payload      []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*PvtDataPayload) Descriptor deprecated 

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

Deprecated: Use PvtDataPayload.ProtoReflect.Descriptor instead.

func (*PvtDataPayload) GetPayload 

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

func (*PvtDataPayload) GetTxSeqInBlock 

func (x *PvtDataPayload) GetTxSeqInBlock() uint64

func (*PvtDataPayload) ProtoMessage 

func (*PvtDataPayload) ProtoMessage()

func (*PvtDataPayload) ProtoReflect 

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

func (*PvtDataPayload) Reset 

func (x *PvtDataPayload) Reset()

func (*PvtDataPayload) String 

func (x *PvtDataPayload) String() string

type RemotePvtDataRequest 

type RemotePvtDataRequest struct {

	// Digests 是一个元素类型为 PvtDataDigest 的数组，包含若干个私有数据的摘要。
	Digests []*PvtDataDigest `protobuf:"bytes,1,rep,name=digests,proto3" json:"digests,omitempty"`
	// contains filtered or unexported fields
}

RemotePvtDataRequest 结构体用于请求缺失的私有读写集。

func (*RemotePvtDataRequest) Descriptor deprecated 

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

Deprecated: Use RemotePvtDataRequest.ProtoReflect.Descriptor instead.

func (*RemotePvtDataRequest) GetDigests 

func (x *RemotePvtDataRequest) GetDigests() []*PvtDataDigest

func (*RemotePvtDataRequest) ProtoMessage 

func (*RemotePvtDataRequest) ProtoMessage()

func (*RemotePvtDataRequest) ProtoReflect 

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

func (*RemotePvtDataRequest) Reset 

func (x *RemotePvtDataRequest) Reset()

func (*RemotePvtDataRequest) String 

func (x *RemotePvtDataRequest) String() string

type RemotePvtDataResponse 

type RemotePvtDataResponse struct {

	// Elements 是一个元素类型为 PvtDataElement 的数组，包含若干个私有数据。
	Elements []*PvtDataElement `protobuf:"bytes,1,rep,name=elements,proto3" json:"elements,omitempty"`
	// contains filtered or unexported fields
}

RemotePvtDataResponse 结构体用于响应对私有数据的请求。

func (*RemotePvtDataResponse) Descriptor deprecated 

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

Deprecated: Use RemotePvtDataResponse.ProtoReflect.Descriptor instead.

func (*RemotePvtDataResponse) GetElements 

func (x *RemotePvtDataResponse) GetElements() []*PvtDataElement

func (*RemotePvtDataResponse) ProtoMessage 

func (*RemotePvtDataResponse) ProtoMessage()

func (*RemotePvtDataResponse) ProtoReflect 

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

func (*RemotePvtDataResponse) Reset 

func (x *RemotePvtDataResponse) Reset()

func (*RemotePvtDataResponse) String 

func (x *RemotePvtDataResponse) String() string

type RemoteStateRequest 

type RemoteStateRequest struct {

	// StartSeqNum 请求的区块的其实序列号。
	StartSeqNum uint64 `protobuf:"varint,1,opt,name=start_seq_num,json=startSeqNum,proto3" json:"start_seq_num,omitempty"`
	// EndSeqNum 请求的区块的结束序列号。
	EndSeqNum uint64 `protobuf:"varint,2,opt,name=end_seq_num,json=endSeqNum,proto3" json:"end_seq_num,omitempty"`
	// contains filtered or unexported fields
}

RemoteStateRequest 此结构体用于在分布式系统中从远程对等体请求特定范围的区块数据。

func (*RemoteStateRequest) Descriptor deprecated 

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

Deprecated: Use RemoteStateRequest.ProtoReflect.Descriptor instead.

func (*RemoteStateRequest) GetEndSeqNum 

func (x *RemoteStateRequest) GetEndSeqNum() uint64

func (*RemoteStateRequest) GetStartSeqNum 

func (x *RemoteStateRequest) GetStartSeqNum() uint64

func (*RemoteStateRequest) ProtoMessage 

func (*RemoteStateRequest) ProtoMessage()

func (*RemoteStateRequest) ProtoReflect 

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

func (*RemoteStateRequest) Reset 

func (x *RemoteStateRequest) Reset()

func (*RemoteStateRequest) String 

func (x *RemoteStateRequest) String() string

type RemoteStateResponse 

type RemoteStateResponse struct {

	// Payloads 包含若干个完整的区块数据。
	Payloads []*Payload `protobuf:"bytes,1,rep,name=payloads,proto3" json:"payloads,omitempty"`
	// contains filtered or unexported fields
}

RemoteStateResponse 此结构体用于向远程对等体发送一组区块数据。

func (*RemoteStateResponse) Descriptor deprecated 

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

Deprecated: Use RemoteStateResponse.ProtoReflect.Descriptor instead.

func (*RemoteStateResponse) GetPayloads 

func (x *RemoteStateResponse) GetPayloads() []*Payload

func (*RemoteStateResponse) ProtoMessage 

func (*RemoteStateResponse) ProtoMessage()

func (*RemoteStateResponse) ProtoReflect 

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

func (*RemoteStateResponse) Reset 

func (x *RemoteStateResponse) Reset()

func (*RemoteStateResponse) String 

func (x *RemoteStateResponse) String() string

type Secret 

type Secret struct {

	// Types that are assignable to Content:
	//
	//	*Secret_InternalEndpoint
	Content isSecret_Content `protobuf_oneof:"content"`
	// contains filtered or unexported fields
}

func (*Secret) Descriptor deprecated 

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

Deprecated: Use Secret.ProtoReflect.Descriptor instead.

func (*Secret) GetContent 

func (m *Secret) GetContent() isSecret_Content

func (*Secret) GetInternalEndpoint 

func (x *Secret) GetInternalEndpoint() string

func (*Secret) ProtoMessage 

func (*Secret) ProtoMessage()

func (*Secret) ProtoReflect 

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

func (*Secret) Reset 

func (x *Secret) Reset()

func (*Secret) String 

func (x *Secret) String() string

type SecretEnvelope 

type SecretEnvelope struct {

	// Payload 字段用于存储加密数据。
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// Signature 用于存储对 Payload 进行签名的结果。
	Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

SecretEnvelope 结构体主要用途是在敏感数据传输中提供保密性。通过对 Payload 进行加密和签名， 可以确保数据在传输过程中不会被泄露或篡改。

func (*SecretEnvelope) Descriptor deprecated 

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

Deprecated: Use SecretEnvelope.ProtoReflect.Descriptor instead.

func (*SecretEnvelope) GetPayload 

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

func (*SecretEnvelope) GetSignature 

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

func (*SecretEnvelope) ProtoMessage 

func (*SecretEnvelope) ProtoMessage()

func (*SecretEnvelope) ProtoReflect 

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

func (*SecretEnvelope) Reset 

func (x *SecretEnvelope) Reset()

func (*SecretEnvelope) String 

func (x *SecretEnvelope) String() string

type Secret_InternalEndpoint 

type Secret_InternalEndpoint struct {
	InternalEndpoint string `protobuf:"bytes,1,opt,name=internalEndpoint,proto3,oneof"`
}

type StateInfo 

type StateInfo struct {

	// Timestamp 对等体的时间戳信息。
	Timestamp *PeerTime `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// PkiId 用于标识对等体。
	PkiId []byte `protobuf:"bytes,2,opt,name=pki_id,json=pkiId,proto3" json:"pki_id,omitempty"`
	// ChannelMAC 通道消息的认证码，用于证明发送消息的对等体知道通道的名称。
	Channel_MAC []byte `protobuf:"bytes,3,opt,name=channel_MAC,json=channelMAC,proto3" json:"channel_MAC,omitempty"`
	// Properties 属性信息。
	Properties *Properties `protobuf:"bytes,4,opt,name=properties,proto3" json:"properties,omitempty"`
	// contains filtered or unexported fields
}

StateInfo 结构体用于对等体向其他对等体中继其状态信息。

func (*StateInfo) Descriptor deprecated 

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

Deprecated: Use StateInfo.ProtoReflect.Descriptor instead.

func (*StateInfo) GetChannel_MAC 

func (x *StateInfo) GetChannel_MAC() []byte

func (*StateInfo) GetPkiId 

func (x *StateInfo) GetPkiId() []byte

func (*StateInfo) GetProperties 

func (x *StateInfo) GetProperties() *Properties

func (*StateInfo) GetTimestamp 

func (x *StateInfo) GetTimestamp() *PeerTime

func (*StateInfo) ProtoMessage 

func (*StateInfo) ProtoMessage()

func (*StateInfo) ProtoReflect 

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

func (*StateInfo) Reset 

func (x *StateInfo) Reset()

func (*StateInfo) String 

func (x *StateInfo) String() string

type StateInfoPullRequest 

type StateInfoPullRequest struct {

	// ChannelMAC 是一个认证码，用于证明发送该消息的对等体知道通道的名称。
	Channel_MAC []byte `protobuf:"bytes,1,opt,name=channel_MAC,json=channelMAC,proto3" json:"channel_MAC,omitempty"`
	// contains filtered or unexported fields
}

StateInfoPullRequest 该结构体用于发起对远程对等体的请求，以获取状态信息的快照。

func (*StateInfoPullRequest) Descriptor deprecated 

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

Deprecated: Use StateInfoPullRequest.ProtoReflect.Descriptor instead.

func (*StateInfoPullRequest) GetChannel_MAC 

func (x *StateInfoPullRequest) GetChannel_MAC() []byte

func (*StateInfoPullRequest) ProtoMessage 

func (*StateInfoPullRequest) ProtoMessage()

func (*StateInfoPullRequest) ProtoReflect 

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

func (*StateInfoPullRequest) Reset 

func (x *StateInfoPullRequest) Reset()

func (*StateInfoPullRequest) String 

func (x *StateInfoPullRequest) String() string

type StateInfoSnapshot 

type StateInfoSnapshot struct {

	// Elements 可在一些情况下传输大量状态信息。
	Elements []*Envelope `protobuf:"bytes,1,rep,name=elements,proto3" json:"elements,omitempty"`
	// contains filtered or unexported fields
}

StateInfoSnapshot 是对 StateInfo 消息的聚合，其中包含了多个 Envelope 元素。

func (*StateInfoSnapshot) Descriptor deprecated 

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

Deprecated: Use StateInfoSnapshot.ProtoReflect.Descriptor instead.

func (*StateInfoSnapshot) GetElements 

func (x *StateInfoSnapshot) GetElements() []*Envelope

func (*StateInfoSnapshot) ProtoMessage 

func (*StateInfoSnapshot) ProtoMessage()

func (*StateInfoSnapshot) ProtoReflect 

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

func (*StateInfoSnapshot) Reset 

func (x *StateInfoSnapshot) Reset()

func (*StateInfoSnapshot) String 

func (x *StateInfoSnapshot) String() string

type UnimplementedGossipServer 

type UnimplementedGossipServer struct {
}

UnimplementedGossipServer can be embedded to have forward compatible implementations.

func (*UnimplementedGossipServer) GossipStream 

func (*UnimplementedGossipServer) GossipStream(Gossip_GossipStreamServer) error

func (*UnimplementedGossipServer) Ping 

func (*UnimplementedGossipServer) Ping(context.Context, *Empty) (*Empty, error)

Source Files

View all Source files

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.