Versions in this module Expand all Collapse all v1 v1.4.6 Feb 25, 2020 Changes in this version + var GossipMessage_Tag_name = map[int32]string + var GossipMessage_Tag_value = map[string]int32 + var PullMsgType_name = map[int32]string + var PullMsgType_value = map[string]int32 + func NewGossipMessageComparator(dataBlockStorageSize int) common.MessageReplacingPolicy + func RegisterGossipServer(s *grpc.Server, srv GossipServer) + type Acknowledgement struct + Error string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Acknowledgement) Descriptor() ([]byte, []int) + func (*Acknowledgement) ProtoMessage() + func (dst *Acknowledgement) XXX_Merge(src proto.Message) + func (m *Acknowledgement) GetError() string + func (m *Acknowledgement) Reset() + func (m *Acknowledgement) String() string + func (m *Acknowledgement) XXX_DiscardUnknown() + func (m *Acknowledgement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Acknowledgement) XXX_Size() int + func (m *Acknowledgement) XXX_Unmarshal(b []byte) error + type AliveMessage struct + Identity []byte + Membership *Member + Timestamp *PeerTime + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*AliveMessage) Descriptor() ([]byte, []int) + func (*AliveMessage) ProtoMessage() + func (dst *AliveMessage) XXX_Merge(src proto.Message) + func (m *AliveMessage) GetIdentity() []byte + func (m *AliveMessage) GetMembership() *Member + func (m *AliveMessage) GetTimestamp() *PeerTime + func (m *AliveMessage) Reset() + func (m *AliveMessage) String() string + func (m *AliveMessage) XXX_DiscardUnknown() + func (m *AliveMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AliveMessage) XXX_Size() int + func (m *AliveMessage) XXX_Unmarshal(b []byte) error + type AuthInfo struct + Signature []byte + SignedData []byte + type Chaincode struct + Metadata []byte + Name string + Version string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Chaincode) Descriptor() ([]byte, []int) + func (*Chaincode) ProtoMessage() + func (dst *Chaincode) XXX_Merge(src proto.Message) + func (m *Chaincode) GetMetadata() []byte + func (m *Chaincode) GetName() string + func (m *Chaincode) GetVersion() string + func (m *Chaincode) Reset() + func (m *Chaincode) String() string + func (m *Chaincode) XXX_DiscardUnknown() + func (m *Chaincode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Chaincode) XXX_Size() int + func (m *Chaincode) XXX_Unmarshal(b []byte) error + type ConnEstablish struct + Identity []byte + PkiId []byte + TlsCertHash []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ConnEstablish) Descriptor() ([]byte, []int) + func (*ConnEstablish) ProtoMessage() + func (dst *ConnEstablish) XXX_Merge(src proto.Message) + func (m *ConnEstablish) GetIdentity() []byte + func (m *ConnEstablish) GetPkiId() []byte + func (m *ConnEstablish) GetTlsCertHash() []byte + func (m *ConnEstablish) Reset() + func (m *ConnEstablish) String() string + func (m *ConnEstablish) XXX_DiscardUnknown() + func (m *ConnEstablish) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ConnEstablish) XXX_Size() int + func (m *ConnEstablish) XXX_Unmarshal(b []byte) error + type ConnectionInfo struct + Auth *AuthInfo + Endpoint string + ID common.PKIidType + Identity api.PeerIdentityType + func (c *ConnectionInfo) String() string + type DataDigest struct + Digests [][]byte + MsgType PullMsgType + Nonce uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DataDigest) Descriptor() ([]byte, []int) + func (*DataDigest) ProtoMessage() + func (dd *DataDigest) FormattedDigests() []string + func (dst *DataDigest) XXX_Merge(src proto.Message) + func (m *DataDigest) GetDigests() [][]byte + func (m *DataDigest) GetMsgType() PullMsgType + func (m *DataDigest) GetNonce() uint64 + func (m *DataDigest) Reset() + func (m *DataDigest) String() string + func (m *DataDigest) XXX_DiscardUnknown() + func (m *DataDigest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DataDigest) XXX_Size() int + func (m *DataDigest) XXX_Unmarshal(b []byte) error + type DataMessage struct + Payload *Payload + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DataMessage) Descriptor() ([]byte, []int) + func (*DataMessage) ProtoMessage() + func (dst *DataMessage) XXX_Merge(src proto.Message) + func (m *DataMessage) GetPayload() *Payload + func (m *DataMessage) Reset() + func (m *DataMessage) String() string + func (m *DataMessage) XXX_DiscardUnknown() + func (m *DataMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DataMessage) XXX_Size() int + func (m *DataMessage) XXX_Unmarshal(b []byte) error + type DataRequest struct + Digests [][]byte + MsgType PullMsgType + Nonce uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DataRequest) Descriptor() ([]byte, []int) + func (*DataRequest) ProtoMessage() + func (dd *DataRequest) FormattedDigests() []string + func (dst *DataRequest) XXX_Merge(src proto.Message) + func (m *DataRequest) GetDigests() [][]byte + func (m *DataRequest) GetMsgType() PullMsgType + func (m *DataRequest) GetNonce() uint64 + func (m *DataRequest) Reset() + func (m *DataRequest) String() string + func (m *DataRequest) XXX_DiscardUnknown() + func (m *DataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DataRequest) XXX_Size() int + func (m *DataRequest) XXX_Unmarshal(b []byte) error + type DataUpdate struct + Data []*Envelope + MsgType PullMsgType + Nonce uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DataUpdate) Descriptor() ([]byte, []int) + func (*DataUpdate) ProtoMessage() + func (dst *DataUpdate) XXX_Merge(src proto.Message) + func (m *DataUpdate) GetData() []*Envelope + func (m *DataUpdate) GetMsgType() PullMsgType + func (m *DataUpdate) GetNonce() uint64 + func (m *DataUpdate) Reset() + func (m *DataUpdate) String() string + func (m *DataUpdate) XXX_DiscardUnknown() + func (m *DataUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DataUpdate) XXX_Size() int + func (m *DataUpdate) XXX_Unmarshal(b []byte) error + type Empty struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Empty) Descriptor() ([]byte, []int) + func (*Empty) ProtoMessage() + func (dst *Empty) XXX_Merge(src proto.Message) + func (m *Empty) Reset() + func (m *Empty) String() string + func (m *Empty) XXX_DiscardUnknown() + func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Empty) XXX_Size() int + func (m *Empty) XXX_Unmarshal(b []byte) error + type Envelope struct + Payload []byte + SecretEnvelope *SecretEnvelope + Signature []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Envelope) Descriptor() ([]byte, []int) + func (*Envelope) ProtoMessage() + func (dst *Envelope) XXX_Merge(src proto.Message) + func (e *Envelope) SignSecret(signer Signer, secret *Secret) error + func (e *Envelope) ToGossipMessage() (*SignedGossipMessage, error) + func (m *Envelope) GetPayload() []byte + func (m *Envelope) GetSecretEnvelope() *SecretEnvelope + func (m *Envelope) GetSignature() []byte + func (m *Envelope) Reset() + func (m *Envelope) String() string + func (m *Envelope) XXX_DiscardUnknown() + func (m *Envelope) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Envelope) XXX_Size() int + func (m *Envelope) XXX_Unmarshal(b []byte) error + type GossipClient interface + GossipStream func(ctx context.Context, opts ...grpc.CallOption) (Gossip_GossipStreamClient, error) + Ping func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) + func NewGossipClient(cc *grpc.ClientConn) GossipClient + type GossipHello struct + Metadata []byte + MsgType PullMsgType + Nonce uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GossipHello) Descriptor() ([]byte, []int) + func (*GossipHello) ProtoMessage() + func (dst *GossipHello) XXX_Merge(src proto.Message) + func (m *GossipHello) GetMetadata() []byte + func (m *GossipHello) GetMsgType() PullMsgType + func (m *GossipHello) GetNonce() uint64 + func (m *GossipHello) Reset() + func (m *GossipHello) String() string + func (m *GossipHello) XXX_DiscardUnknown() + func (m *GossipHello) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GossipHello) XXX_Size() int + func (m *GossipHello) XXX_Unmarshal(b []byte) error + type GossipMessage struct + Channel []byte + Content isGossipMessage_Content + Nonce uint64 + Tag GossipMessage_Tag + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GossipMessage) Descriptor() ([]byte, []int) + func (*GossipMessage) ProtoMessage() + func (*GossipMessage) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (dst *GossipMessage) XXX_Merge(src proto.Message) + func (m *GossipMessage) GetAck() *Acknowledgement + func (m *GossipMessage) GetAliveMsg() *AliveMessage + func (m *GossipMessage) GetChannel() []byte + func (m *GossipMessage) GetConn() *ConnEstablish + func (m *GossipMessage) GetContent() isGossipMessage_Content + func (m *GossipMessage) GetDataDig() *DataDigest + func (m *GossipMessage) GetDataMsg() *DataMessage + func (m *GossipMessage) GetDataReq() *DataRequest + func (m *GossipMessage) GetDataUpdate() *DataUpdate + func (m *GossipMessage) GetEmpty() *Empty + func (m *GossipMessage) GetHello() *GossipHello + func (m *GossipMessage) GetLeadershipMsg() *LeadershipMessage + func (m *GossipMessage) GetMemReq() *MembershipRequest + func (m *GossipMessage) GetMemRes() *MembershipResponse + func (m *GossipMessage) GetNonce() uint64 + func (m *GossipMessage) GetPeerIdentity() *PeerIdentity + func (m *GossipMessage) GetPrivateData() *PrivateDataMessage + func (m *GossipMessage) GetPrivateReq() *RemotePvtDataRequest + func (m *GossipMessage) GetPrivateRes() *RemotePvtDataResponse + func (m *GossipMessage) GetPullMsgType() PullMsgType + func (m *GossipMessage) GetStateInfo() *StateInfo + func (m *GossipMessage) GetStateInfoPullReq() *StateInfoPullRequest + func (m *GossipMessage) GetStateRequest() *RemoteStateRequest + func (m *GossipMessage) GetStateResponse() *RemoteStateResponse + func (m *GossipMessage) GetStateSnapshot() *StateInfoSnapshot + func (m *GossipMessage) GetTag() GossipMessage_Tag + func (m *GossipMessage) IsAck() bool + func (m *GossipMessage) IsAliveMsg() bool + func (m *GossipMessage) IsChannelRestricted() bool + func (m *GossipMessage) IsDataMsg() bool + func (m *GossipMessage) IsDataReq() bool + func (m *GossipMessage) IsDataUpdate() bool + func (m *GossipMessage) IsDigestMsg() bool + func (m *GossipMessage) IsHelloMsg() bool + func (m *GossipMessage) IsIdentityMsg() bool + func (m *GossipMessage) IsLeadershipMsg() bool + func (m *GossipMessage) IsOrgRestricted() bool + func (m *GossipMessage) IsPrivateDataMsg() bool + func (m *GossipMessage) IsPullMsg() bool + func (m *GossipMessage) IsRemoteStateMessage() bool + func (m *GossipMessage) IsStateInfoMsg() bool + func (m *GossipMessage) IsStateInfoPullRequestMsg() bool + func (m *GossipMessage) IsStateInfoSnapshot() bool + func (m *GossipMessage) IsTagLegal() error + func (m *GossipMessage) NoopSign() (*SignedGossipMessage, error) + func (m *GossipMessage) Reset() + func (m *GossipMessage) String() string + func (m *GossipMessage) XXX_DiscardUnknown() + func (m *GossipMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GossipMessage) XXX_Size() int + func (m *GossipMessage) XXX_Unmarshal(b []byte) error + type GossipMessage_Ack struct + Ack *Acknowledgement + type GossipMessage_AliveMsg struct + AliveMsg *AliveMessage + type GossipMessage_Conn struct + Conn *ConnEstablish + type GossipMessage_DataDig struct + DataDig *DataDigest + type GossipMessage_DataMsg struct + DataMsg *DataMessage + type GossipMessage_DataReq struct + DataReq *DataRequest + type GossipMessage_DataUpdate struct + DataUpdate *DataUpdate + type GossipMessage_Empty struct + Empty *Empty + type GossipMessage_Hello struct + Hello *GossipHello + type GossipMessage_LeadershipMsg struct + LeadershipMsg *LeadershipMessage + type GossipMessage_MemReq struct + MemReq *MembershipRequest + type GossipMessage_MemRes struct + MemRes *MembershipResponse + type GossipMessage_PeerIdentity struct + PeerIdentity *PeerIdentity + type GossipMessage_PrivateData struct + PrivateData *PrivateDataMessage + type GossipMessage_PrivateReq struct + PrivateReq *RemotePvtDataRequest + type GossipMessage_PrivateRes struct + PrivateRes *RemotePvtDataResponse + type GossipMessage_StateInfo struct + StateInfo *StateInfo + type GossipMessage_StateInfoPullReq struct + StateInfoPullReq *StateInfoPullRequest + type GossipMessage_StateRequest struct + StateRequest *RemoteStateRequest + type GossipMessage_StateResponse struct + StateResponse *RemoteStateResponse + type GossipMessage_StateSnapshot struct + StateSnapshot *StateInfoSnapshot + type GossipMessage_Tag int32 + const GossipMessage_CHAN_AND_ORG + const GossipMessage_CHAN_ONLY + const GossipMessage_CHAN_OR_ORG + const GossipMessage_EMPTY + const GossipMessage_ORG_ONLY + const GossipMessage_UNDEFINED + func (GossipMessage_Tag) EnumDescriptor() ([]byte, []int) + func (x GossipMessage_Tag) String() string + type GossipServer interface + GossipStream func(Gossip_GossipStreamServer) error + Ping func(context.Context, *Empty) (*Empty, error) + type Gossip_GossipStreamClient interface + Recv func() (*Envelope, error) + Send func(*Envelope) error + type Gossip_GossipStreamServer interface + Recv func() (*Envelope, error) + Send func(*Envelope) error + type IdentifierExtractor func(*SignedGossipMessage) string + type LeadershipMessage struct + IsDeclaration bool + PkiId []byte + Timestamp *PeerTime + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*LeadershipMessage) Descriptor() ([]byte, []int) + func (*LeadershipMessage) ProtoMessage() + func (dst *LeadershipMessage) XXX_Merge(src proto.Message) + func (m *LeadershipMessage) GetIsDeclaration() bool + func (m *LeadershipMessage) GetPkiId() []byte + func (m *LeadershipMessage) GetTimestamp() *PeerTime + func (m *LeadershipMessage) Reset() + func (m *LeadershipMessage) String() string + func (m *LeadershipMessage) XXX_DiscardUnknown() + func (m *LeadershipMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LeadershipMessage) XXX_Size() int + func (m *LeadershipMessage) XXX_Unmarshal(b []byte) error + type Member struct + Endpoint string + Metadata []byte + PkiId []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Member) Descriptor() ([]byte, []int) + func (*Member) ProtoMessage() + func (dst *Member) XXX_Merge(src proto.Message) + func (m *Member) GetEndpoint() string + func (m *Member) GetMetadata() []byte + func (m *Member) GetPkiId() []byte + func (m *Member) Reset() + func (m *Member) String() string + func (m *Member) XXX_DiscardUnknown() + func (m *Member) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Member) XXX_Size() int + func (m *Member) XXX_Unmarshal(b []byte) error + type MembershipRequest struct + Known [][]byte + SelfInformation *Envelope + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*MembershipRequest) Descriptor() ([]byte, []int) + func (*MembershipRequest) ProtoMessage() + func (dst *MembershipRequest) XXX_Merge(src proto.Message) + func (m *MembershipRequest) GetKnown() [][]byte + func (m *MembershipRequest) GetSelfInformation() *Envelope + func (m *MembershipRequest) Reset() + func (m *MembershipRequest) String() string + func (m *MembershipRequest) XXX_DiscardUnknown() + func (m *MembershipRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MembershipRequest) XXX_Size() int + func (m *MembershipRequest) XXX_Unmarshal(b []byte) error + type MembershipResponse struct + Alive []*Envelope + Dead []*Envelope + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*MembershipResponse) Descriptor() ([]byte, []int) + func (*MembershipResponse) ProtoMessage() + func (dst *MembershipResponse) XXX_Merge(src proto.Message) + func (m *MembershipResponse) GetAlive() []*Envelope + func (m *MembershipResponse) GetDead() []*Envelope + func (m *MembershipResponse) Reset() + func (m *MembershipResponse) String() string + func (m *MembershipResponse) XXX_DiscardUnknown() + func (m *MembershipResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MembershipResponse) XXX_Size() int + func (m *MembershipResponse) XXX_Unmarshal(b []byte) error + type MsgConsumer func(message *SignedGossipMessage) + type Payload struct + Data []byte + PrivateData [][]byte + SeqNum uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Payload) Descriptor() ([]byte, []int) + func (*Payload) ProtoMessage() + func (dst *Payload) XXX_Merge(src proto.Message) + func (m *Payload) GetData() []byte + func (m *Payload) GetPrivateData() [][]byte + func (m *Payload) GetSeqNum() uint64 + func (m *Payload) Reset() + func (m *Payload) String() string + func (m *Payload) XXX_DiscardUnknown() + func (m *Payload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Payload) XXX_Size() int + func (m *Payload) XXX_Unmarshal(b []byte) error + type PeerIdentity struct + Cert []byte + Metadata []byte + PkiId []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PeerIdentity) Descriptor() ([]byte, []int) + func (*PeerIdentity) ProtoMessage() + func (dst *PeerIdentity) XXX_Merge(src proto.Message) + func (m *PeerIdentity) GetCert() []byte + func (m *PeerIdentity) GetMetadata() []byte + func (m *PeerIdentity) GetPkiId() []byte + func (m *PeerIdentity) Reset() + func (m *PeerIdentity) String() string + func (m *PeerIdentity) XXX_DiscardUnknown() + func (m *PeerIdentity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PeerIdentity) XXX_Size() int + func (m *PeerIdentity) XXX_Unmarshal(b []byte) error + type PeerTime struct + IncNum uint64 + SeqNum uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PeerTime) Descriptor() ([]byte, []int) + func (*PeerTime) ProtoMessage() + func (dst *PeerTime) XXX_Merge(src proto.Message) + func (m *PeerTime) GetIncNum() uint64 + func (m *PeerTime) GetSeqNum() uint64 + func (m *PeerTime) Reset() + func (m *PeerTime) String() string + func (m *PeerTime) XXX_DiscardUnknown() + func (m *PeerTime) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PeerTime) XXX_Size() int + func (m *PeerTime) XXX_Unmarshal(b []byte) error + type PrivateDataMessage struct + Payload *PrivatePayload + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PrivateDataMessage) Descriptor() ([]byte, []int) + func (*PrivateDataMessage) ProtoMessage() + func (dst *PrivateDataMessage) XXX_Merge(src proto.Message) + func (m *PrivateDataMessage) GetPayload() *PrivatePayload + func (m *PrivateDataMessage) Reset() + func (m *PrivateDataMessage) String() string + func (m *PrivateDataMessage) XXX_DiscardUnknown() + func (m *PrivateDataMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PrivateDataMessage) XXX_Size() int + func (m *PrivateDataMessage) XXX_Unmarshal(b []byte) error + type PrivatePayload struct + CollectionConfigs *common.CollectionConfigPackage + CollectionName string + Namespace string + PrivateRwset []byte + PrivateSimHeight uint64 + TxId string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PrivatePayload) Descriptor() ([]byte, []int) + func (*PrivatePayload) ProtoMessage() + func (dst *PrivatePayload) XXX_Merge(src proto.Message) + func (m *PrivatePayload) GetCollectionConfigs() *common.CollectionConfigPackage + func (m *PrivatePayload) GetCollectionName() string + func (m *PrivatePayload) GetNamespace() string + func (m *PrivatePayload) GetPrivateRwset() []byte + func (m *PrivatePayload) GetPrivateSimHeight() uint64 + func (m *PrivatePayload) GetTxId() string + func (m *PrivatePayload) Reset() + func (m *PrivatePayload) String() string + func (m *PrivatePayload) XXX_DiscardUnknown() + func (m *PrivatePayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PrivatePayload) XXX_Size() int + func (m *PrivatePayload) XXX_Unmarshal(b []byte) error + type Properties struct + Chaincodes []*Chaincode + LedgerHeight uint64 + LeftChannel bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Properties) Descriptor() ([]byte, []int) + func (*Properties) ProtoMessage() + func (dst *Properties) XXX_Merge(src proto.Message) + func (m *Properties) GetChaincodes() []*Chaincode + func (m *Properties) GetLedgerHeight() uint64 + func (m *Properties) GetLeftChannel() bool + func (m *Properties) Reset() + func (m *Properties) String() string + func (m *Properties) XXX_DiscardUnknown() + func (m *Properties) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Properties) XXX_Size() int + func (m *Properties) XXX_Unmarshal(b []byte) error + type PullMsgType int32 + const PullMsgType_BLOCK_MSG + const PullMsgType_IDENTITY_MSG + const PullMsgType_UNDEFINED + func (PullMsgType) EnumDescriptor() ([]byte, []int) + func (x PullMsgType) String() string + type PvtDataDigest struct + BlockSeq uint64 + Collection string + Namespace string + SeqInBlock uint64 + TxId string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PvtDataDigest) Descriptor() ([]byte, []int) + func (*PvtDataDigest) ProtoMessage() + func (dig *PvtDataDigest) Hash() (string, error) + func (dst *PvtDataDigest) XXX_Merge(src proto.Message) + func (m *PvtDataDigest) GetBlockSeq() uint64 + func (m *PvtDataDigest) GetCollection() string + func (m *PvtDataDigest) GetNamespace() string + func (m *PvtDataDigest) GetSeqInBlock() uint64 + func (m *PvtDataDigest) GetTxId() string + func (m *PvtDataDigest) Reset() + func (m *PvtDataDigest) String() string + func (m *PvtDataDigest) XXX_DiscardUnknown() + func (m *PvtDataDigest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PvtDataDigest) XXX_Size() int + func (m *PvtDataDigest) XXX_Unmarshal(b []byte) error + type PvtDataElement struct + Digest *PvtDataDigest + Payload [][]byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PvtDataElement) Descriptor() ([]byte, []int) + func (*PvtDataElement) ProtoMessage() + func (dst *PvtDataElement) XXX_Merge(src proto.Message) + func (m *PvtDataElement) GetDigest() *PvtDataDigest + func (m *PvtDataElement) GetPayload() [][]byte + func (m *PvtDataElement) Reset() + func (m *PvtDataElement) String() string + func (m *PvtDataElement) XXX_DiscardUnknown() + func (m *PvtDataElement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PvtDataElement) XXX_Size() int + func (m *PvtDataElement) XXX_Unmarshal(b []byte) error + type PvtDataPayload struct + Payload []byte + TxSeqInBlock uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PvtDataPayload) Descriptor() ([]byte, []int) + func (*PvtDataPayload) ProtoMessage() + func (dst *PvtDataPayload) XXX_Merge(src proto.Message) + func (m *PvtDataPayload) GetPayload() []byte + func (m *PvtDataPayload) GetTxSeqInBlock() uint64 + func (m *PvtDataPayload) Reset() + func (m *PvtDataPayload) String() string + func (m *PvtDataPayload) XXX_DiscardUnknown() + func (m *PvtDataPayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PvtDataPayload) XXX_Size() int + func (m *PvtDataPayload) XXX_Unmarshal(b []byte) error + type ReceivedMessage interface + Ack func(err error) + GetConnectionInfo func() *ConnectionInfo + GetGossipMessage func() *SignedGossipMessage + GetSourceEnvelope func() *Envelope + Respond func(msg *GossipMessage) + type RemotePvtDataRequest struct + Digests []*PvtDataDigest + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RemotePvtDataRequest) Descriptor() ([]byte, []int) + func (*RemotePvtDataRequest) ProtoMessage() + func (dst *RemotePvtDataRequest) XXX_Merge(src proto.Message) + func (m *RemotePvtDataRequest) GetDigests() []*PvtDataDigest + func (m *RemotePvtDataRequest) Reset() + func (m *RemotePvtDataRequest) String() string + func (m *RemotePvtDataRequest) XXX_DiscardUnknown() + func (m *RemotePvtDataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RemotePvtDataRequest) XXX_Size() int + func (m *RemotePvtDataRequest) XXX_Unmarshal(b []byte) error + type RemotePvtDataResponse struct + Elements []*PvtDataElement + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RemotePvtDataResponse) Descriptor() ([]byte, []int) + func (*RemotePvtDataResponse) ProtoMessage() + func (dst *RemotePvtDataResponse) XXX_Merge(src proto.Message) + func (m *RemotePvtDataResponse) GetElements() []*PvtDataElement + func (m *RemotePvtDataResponse) Reset() + func (m *RemotePvtDataResponse) String() string + func (m *RemotePvtDataResponse) XXX_DiscardUnknown() + func (m *RemotePvtDataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RemotePvtDataResponse) XXX_Size() int + func (m *RemotePvtDataResponse) XXX_Unmarshal(b []byte) error + func (res *RemotePvtDataResponse) ToString() string + type RemoteStateRequest struct + EndSeqNum uint64 + StartSeqNum uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RemoteStateRequest) Descriptor() ([]byte, []int) + func (*RemoteStateRequest) ProtoMessage() + func (dst *RemoteStateRequest) XXX_Merge(src proto.Message) + func (m *RemoteStateRequest) GetEndSeqNum() uint64 + func (m *RemoteStateRequest) GetStartSeqNum() uint64 + func (m *RemoteStateRequest) Reset() + func (m *RemoteStateRequest) String() string + func (m *RemoteStateRequest) XXX_DiscardUnknown() + func (m *RemoteStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RemoteStateRequest) XXX_Size() int + func (m *RemoteStateRequest) XXX_Unmarshal(b []byte) error + type RemoteStateResponse struct + Payloads []*Payload + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RemoteStateResponse) Descriptor() ([]byte, []int) + func (*RemoteStateResponse) ProtoMessage() + func (dst *RemoteStateResponse) XXX_Merge(src proto.Message) + func (m *RemoteStateResponse) GetPayloads() []*Payload + func (m *RemoteStateResponse) Reset() + func (m *RemoteStateResponse) String() string + func (m *RemoteStateResponse) XXX_DiscardUnknown() + func (m *RemoteStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RemoteStateResponse) XXX_Size() int + func (m *RemoteStateResponse) XXX_Unmarshal(b []byte) error + type Secret struct + Content isSecret_Content + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Secret) Descriptor() ([]byte, []int) + func (*Secret) ProtoMessage() + func (*Secret) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (dst *Secret) XXX_Merge(src proto.Message) + func (m *Secret) GetContent() isSecret_Content + func (m *Secret) GetInternalEndpoint() string + func (m *Secret) Reset() + func (m *Secret) String() string + func (m *Secret) XXX_DiscardUnknown() + func (m *Secret) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Secret) XXX_Size() int + func (m *Secret) XXX_Unmarshal(b []byte) error + type SecretEnvelope struct + Payload []byte + Signature []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SecretEnvelope) Descriptor() ([]byte, []int) + func (*SecretEnvelope) ProtoMessage() + func (dst *SecretEnvelope) XXX_Merge(src proto.Message) + func (m *SecretEnvelope) GetPayload() []byte + func (m *SecretEnvelope) GetSignature() []byte + func (m *SecretEnvelope) Reset() + func (m *SecretEnvelope) String() string + func (m *SecretEnvelope) XXX_DiscardUnknown() + func (m *SecretEnvelope) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SecretEnvelope) XXX_Size() int + func (m *SecretEnvelope) XXX_Unmarshal(b []byte) error + func (s *SecretEnvelope) InternalEndpoint() string + type Secret_InternalEndpoint struct + InternalEndpoint string + type SignedGossipMessage struct + func (m *SignedGossipMessage) IsSigned() bool + func (m *SignedGossipMessage) Sign(signer Signer) (*Envelope, error) + func (m *SignedGossipMessage) String() string + func (m *SignedGossipMessage) Verify(peerIdentity []byte, verify Verifier) error + type Signer func(msg []byte) ([]byte, error) + type StateInfo struct + Channel_MAC []byte + PkiId []byte + Properties *Properties + Timestamp *PeerTime + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StateInfo) Descriptor() ([]byte, []int) + func (*StateInfo) ProtoMessage() + func (dst *StateInfo) XXX_Merge(src proto.Message) + func (m *StateInfo) GetChannel_MAC() []byte + func (m *StateInfo) GetPkiId() []byte + func (m *StateInfo) GetProperties() *Properties + func (m *StateInfo) GetTimestamp() *PeerTime + func (m *StateInfo) Reset() + func (m *StateInfo) String() string + func (m *StateInfo) XXX_DiscardUnknown() + func (m *StateInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StateInfo) XXX_Size() int + func (m *StateInfo) XXX_Unmarshal(b []byte) error + func (msg *StateInfo) LedgerHeight() (uint64, error) + type StateInfoPullRequest struct + Channel_MAC []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StateInfoPullRequest) Descriptor() ([]byte, []int) + func (*StateInfoPullRequest) ProtoMessage() + func (dst *StateInfoPullRequest) XXX_Merge(src proto.Message) + func (m *StateInfoPullRequest) GetChannel_MAC() []byte + func (m *StateInfoPullRequest) Reset() + func (m *StateInfoPullRequest) String() string + func (m *StateInfoPullRequest) XXX_DiscardUnknown() + func (m *StateInfoPullRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StateInfoPullRequest) XXX_Size() int + func (m *StateInfoPullRequest) XXX_Unmarshal(b []byte) error + type StateInfoSnapshot struct + Elements []*Envelope + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StateInfoSnapshot) Descriptor() ([]byte, []int) + func (*StateInfoSnapshot) ProtoMessage() + func (dst *StateInfoSnapshot) XXX_Merge(src proto.Message) + func (m *StateInfoSnapshot) GetElements() []*Envelope + func (m *StateInfoSnapshot) Reset() + func (m *StateInfoSnapshot) String() string + func (m *StateInfoSnapshot) XXX_DiscardUnknown() + func (m *StateInfoSnapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StateInfoSnapshot) XXX_Size() int + func (m *StateInfoSnapshot) XXX_Unmarshal(b []byte) error + type Verifier func(peerIdentity []byte, signature, message []byte) error