gossip

package

Go to main page

Versions in this module

v1

v1.4.0-rc1

Dec 10, 2018

v1.3.0

Oct 10, 2018

Changes in this version

type Acknowledgement

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *Acknowledgement) XXX_Merge(src proto.Message)

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *AliveMessage) XXX_Merge(src proto.Message)

+ 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 Chaincode

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *Chaincode) XXX_Merge(src proto.Message)

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *ConnEstablish) XXX_Merge(src proto.Message)

+ 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 DataDigest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *DataDigest) XXX_Merge(src proto.Message)

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *DataMessage) XXX_Merge(src proto.Message)

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *DataRequest) XXX_Merge(src proto.Message)

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *DataUpdate) XXX_Merge(src proto.Message)

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *Empty) XXX_Merge(src proto.Message)

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *Envelope) XXX_Merge(src proto.Message)

+ 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 GossipHello

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *GossipHello) XXX_Merge(src proto.Message)

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *GossipMessage) XXX_Merge(src proto.Message)

+ 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 LeadershipMessage

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *LeadershipMessage) XXX_Merge(src proto.Message)

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *Member) XXX_Merge(src proto.Message)

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *MembershipRequest) XXX_Merge(src proto.Message)

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *MembershipResponse) XXX_Merge(src proto.Message)

+ 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 Payload

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *Payload) XXX_Merge(src proto.Message)

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *PeerIdentity) XXX_Merge(src proto.Message)

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *PeerTime) XXX_Merge(src proto.Message)

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *PrivateDataMessage) XXX_Merge(src proto.Message)

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *PrivatePayload) XXX_Merge(src proto.Message)

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *Properties) XXX_Merge(src proto.Message)

+ 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 PvtDataDigest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *PvtDataDigest) XXX_Merge(src proto.Message)

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *PvtDataElement) XXX_Merge(src proto.Message)

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *PvtDataPayload) XXX_Merge(src proto.Message)

+ 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 RemotePvtDataRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *RemotePvtDataRequest) XXX_Merge(src proto.Message)

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *RemotePvtDataResponse) XXX_Merge(src proto.Message)

+ 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

type RemoteStateRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *RemoteStateRequest) XXX_Merge(src proto.Message)

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *RemoteStateResponse) XXX_Merge(src proto.Message)

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *Secret) XXX_Merge(src proto.Message)

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *SecretEnvelope) XXX_Merge(src proto.Message)

+ 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

type StateInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *StateInfo) XXX_Merge(src proto.Message)

+ 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

type StateInfoPullRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *StateInfoPullRequest) XXX_Merge(src proto.Message)

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *StateInfoSnapshot) XXX_Merge(src proto.Message)

+ 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

v1.3.0-rc1

Sep 25, 2018

v1.2.1

Sep 27, 2018

v1.2.0

Jul 3, 2018

Changes in this version

+ type Chaincode struct

+ Metadata []byte

+ Name string

+ Version string

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

+ func (*Chaincode) ProtoMessage()

+ func (m *Chaincode) GetMetadata() []byte

+ func (m *Chaincode) GetName() string

+ func (m *Chaincode) GetVersion() string

+ func (m *Chaincode) Reset()

+ func (m *Chaincode) String() string

type PrivatePayload

+ CollectionConfigs *common2.CollectionConfigPackage

+ PrivateSimHeight uint64

+ func (m *PrivatePayload) GetCollectionConfigs() *common2.CollectionConfigPackage

+ func (m *PrivatePayload) GetPrivateSimHeight() uint64

type Properties

+ Chaincodes []*Chaincode

+ func (m *Properties) GetChaincodes() []*Chaincode

v1.2.0-rc1

Jun 22, 2018

v1.1.1

Jul 8, 2018

v1.1.0

Mar 15, 2018

Changes in this version

+ type Acknowledgement struct

+ Error string

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

+ func (*Acknowledgement) ProtoMessage()

+ func (m *Acknowledgement) GetError() string

+ func (m *Acknowledgement) Reset()

+ func (m *Acknowledgement) String() string

type DataDigest

+ func (dd *DataDigest) FormattedDigests() []string

type DataRequest

+ func (dd *DataRequest) FormattedDigests() []string

type GossipMessage

+ func (m *GossipMessage) GetAck() *Acknowledgement

+ func (m *GossipMessage) GetPrivateData() *PrivateDataMessage

+ func (m *GossipMessage) GetPrivateReq() *RemotePvtDataRequest

+ func (m *GossipMessage) GetPrivateRes() *RemotePvtDataResponse

+ func (m *GossipMessage) IsAck() bool

+ func (m *GossipMessage) IsPrivateDataMsg() bool

+ type GossipMessage_Ack struct

+ Ack *Acknowledgement

+ type GossipMessage_PrivateData struct

+ PrivateData *PrivateDataMessage

+ type GossipMessage_PrivateReq struct

+ PrivateReq *RemotePvtDataRequest

+ type GossipMessage_PrivateRes struct

+ PrivateRes *RemotePvtDataResponse

type Payload

+ PrivateData [][]byte

+ func (m *Payload) GetPrivateData() [][]byte

+ type PrivateDataMessage struct

+ Payload *PrivatePayload

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

+ func (*PrivateDataMessage) ProtoMessage()

+ func (m *PrivateDataMessage) GetPayload() *PrivatePayload

+ func (m *PrivateDataMessage) Reset()

+ func (m *PrivateDataMessage) String() string

+ type PrivatePayload struct

+ CollectionName string

+ Namespace string

+ PrivateRwset []byte

+ TxId string

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

+ func (*PrivatePayload) ProtoMessage()

+ func (m *PrivatePayload) GetCollectionName() string

+ func (m *PrivatePayload) GetNamespace() string

+ func (m *PrivatePayload) GetPrivateRwset() []byte

+ func (m *PrivatePayload) GetTxId() string

+ func (m *PrivatePayload) Reset()

+ func (m *PrivatePayload) String() string

+ type Properties struct

+ LedgerHeight uint64

+ LeftChannel bool

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

+ func (*Properties) ProtoMessage()

+ func (m *Properties) GetLedgerHeight() uint64

+ func (m *Properties) GetLeftChannel() bool

+ func (m *Properties) Reset()

+ func (m *Properties) String() string

+ type PvtDataDigest struct

+ BlockSeq uint64

+ Collection string

+ Namespace string

+ SeqInBlock uint64

+ TxId string

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

+ func (*PvtDataDigest) ProtoMessage()

+ func (dig *PvtDataDigest) Hash() (string, error)

+ 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

+ type PvtDataElement struct

+ Digest *PvtDataDigest

+ Payload [][]byte

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

+ func (*PvtDataElement) ProtoMessage()

+ func (m *PvtDataElement) GetDigest() *PvtDataDigest

+ func (m *PvtDataElement) GetPayload() [][]byte

+ func (m *PvtDataElement) Reset()

+ func (m *PvtDataElement) String() string

+ type PvtDataPayload struct

+ Payload []byte

+ TxSeqInBlock uint64

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

+ func (*PvtDataPayload) ProtoMessage()

+ func (m *PvtDataPayload) GetPayload() []byte

+ func (m *PvtDataPayload) GetTxSeqInBlock() uint64

+ func (m *PvtDataPayload) Reset()

+ func (m *PvtDataPayload) String() string

type ReceivedMessage

+ Ack func(err error)

+ type RemotePvtDataRequest struct

+ Digests []*PvtDataDigest

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

+ func (*RemotePvtDataRequest) ProtoMessage()

+ func (m *RemotePvtDataRequest) GetDigests() []*PvtDataDigest

+ func (m *RemotePvtDataRequest) Reset()

+ func (m *RemotePvtDataRequest) String() string

+ type RemotePvtDataResponse struct

+ Elements []*PvtDataElement

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

+ func (*RemotePvtDataResponse) ProtoMessage()

+ func (m *RemotePvtDataResponse) GetElements() []*PvtDataElement

+ func (m *RemotePvtDataResponse) Reset()

+ func (m *RemotePvtDataResponse) String() string

+ func (res *RemotePvtDataResponse) ToString() string

type StateInfo

+ Properties *Properties

+ func (m *StateInfo) GetProperties() *Properties

+ func (msg *StateInfo) LedgerHeight() (uint64, error)

v1.1.0-rc1

Mar 1, 2018

v1.1.0-preview

Nov 1, 2017

v1.1.0-alpha

Jan 26, 2018

v1.0.6

Feb 18, 2018

v1.0.5

Dec 6, 2017

v1.0.4

Oct 31, 2017

v1.0.3

Oct 3, 2017

v1.0.2

Aug 31, 2017

v1.0.1

Aug 7, 2017

v1.0.0

Jul 11, 2017

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 AliveMessage struct

+ Identity []byte

+ Membership *Member

+ Timestamp *PeerTime

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

+ func (*AliveMessage) ProtoMessage()

+ func (m *AliveMessage) GetIdentity() []byte

+ func (m *AliveMessage) GetMembership() *Member

+ func (m *AliveMessage) GetTimestamp() *PeerTime

+ func (m *AliveMessage) Reset()

+ func (m *AliveMessage) String() string

+ type AuthInfo struct

+ Signature []byte

+ SignedData []byte

+ type ConnEstablish struct

+ Identity []byte

+ PkiId []byte

+ TlsCertHash []byte

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

+ func (*ConnEstablish) ProtoMessage()

+ func (m *ConnEstablish) GetIdentity() []byte

+ func (m *ConnEstablish) GetPkiId() []byte

+ func (m *ConnEstablish) GetTlsCertHash() []byte

+ func (m *ConnEstablish) Reset()

+ func (m *ConnEstablish) String() string

+ type ConnectionInfo struct

+ Auth *AuthInfo

+ Endpoint string

+ ID common.PKIidType

+ Identity api.PeerIdentityType

+ func (c *ConnectionInfo) IsAuthenticated() bool

+ func (c *ConnectionInfo) String() string

+ type DataDigest struct

+ Digests []string

+ MsgType PullMsgType

+ Nonce uint64

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

+ func (*DataDigest) ProtoMessage()

+ func (m *DataDigest) GetDigests() []string

+ func (m *DataDigest) GetMsgType() PullMsgType

+ func (m *DataDigest) GetNonce() uint64

+ func (m *DataDigest) Reset()

+ func (m *DataDigest) String() string

+ type DataMessage struct

+ Payload *Payload

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

+ func (*DataMessage) ProtoMessage()

+ func (m *DataMessage) GetPayload() *Payload

+ func (m *DataMessage) Reset()

+ func (m *DataMessage) String() string

+ type DataRequest struct

+ Digests []string

+ MsgType PullMsgType

+ Nonce uint64

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

+ func (*DataRequest) ProtoMessage()

+ func (m *DataRequest) GetDigests() []string

+ func (m *DataRequest) GetMsgType() PullMsgType

+ func (m *DataRequest) GetNonce() uint64

+ func (m *DataRequest) Reset()

+ func (m *DataRequest) String() string

+ type DataUpdate struct

+ Data []*Envelope

+ MsgType PullMsgType

+ Nonce uint64

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

+ func (*DataUpdate) ProtoMessage()

+ func (m *DataUpdate) GetData() []*Envelope

+ func (m *DataUpdate) GetMsgType() PullMsgType

+ func (m *DataUpdate) GetNonce() uint64

+ func (m *DataUpdate) Reset()

+ func (m *DataUpdate) String() string

+ type Empty struct

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

+ func (*Empty) ProtoMessage()

+ func (m *Empty) Reset()

+ func (m *Empty) String() string

+ type Envelope struct

+ Payload []byte

+ SecretEnvelope *SecretEnvelope

+ Signature []byte

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

+ func (*Envelope) ProtoMessage()

+ 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

+ 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

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

+ func (*GossipHello) ProtoMessage()

+ func (m *GossipHello) GetMetadata() []byte

+ func (m *GossipHello) GetMsgType() PullMsgType

+ func (m *GossipHello) GetNonce() uint64

+ func (m *GossipHello) Reset()

+ func (m *GossipHello) String() string

+ type GossipMessage struct

+ Channel []byte

+ Content isGossipMessage_Content

+ Nonce uint64

+ Tag GossipMessage_Tag

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

+ func (*GossipMessage) ProtoMessage()

+ func (*GossipMessage) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

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

+ 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_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

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

+ func (*LeadershipMessage) ProtoMessage()

+ func (m *LeadershipMessage) GetIsDeclaration() bool

+ func (m *LeadershipMessage) GetPkiId() []byte

+ func (m *LeadershipMessage) GetTimestamp() *PeerTime

+ func (m *LeadershipMessage) Reset()

+ func (m *LeadershipMessage) String() string

+ type Member struct

+ Endpoint string

+ Metadata []byte

+ PkiId []byte

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

+ func (*Member) ProtoMessage()

+ func (m *Member) GetEndpoint() string

+ func (m *Member) GetMetadata() []byte

+ func (m *Member) GetPkiId() []byte

+ func (m *Member) Reset()

+ func (m *Member) String() string

+ type MembershipRequest struct

+ Known [][]byte

+ SelfInformation *Envelope

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

+ func (*MembershipRequest) ProtoMessage()

+ func (m *MembershipRequest) GetKnown() [][]byte

+ func (m *MembershipRequest) GetSelfInformation() *Envelope

+ func (m *MembershipRequest) Reset()

+ func (m *MembershipRequest) String() string

+ type MembershipResponse struct

+ Alive []*Envelope

+ Dead []*Envelope

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

+ func (*MembershipResponse) ProtoMessage()

+ func (m *MembershipResponse) GetAlive() []*Envelope

+ func (m *MembershipResponse) GetDead() []*Envelope

+ func (m *MembershipResponse) Reset()

+ func (m *MembershipResponse) String() string

+ type MsgConsumer func(message *SignedGossipMessage)

+ type Payload struct

+ Data []byte

+ SeqNum uint64

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

+ func (*Payload) ProtoMessage()

+ func (m *Payload) GetData() []byte

+ func (m *Payload) GetSeqNum() uint64

+ func (m *Payload) Reset()

+ func (m *Payload) String() string

+ type PeerIdentity struct

+ Cert []byte

+ Metadata []byte

+ PkiId []byte

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

+ func (*PeerIdentity) ProtoMessage()

+ func (m *PeerIdentity) GetCert() []byte

+ func (m *PeerIdentity) GetMetadata() []byte

+ func (m *PeerIdentity) GetPkiId() []byte

+ func (m *PeerIdentity) Reset()

+ func (m *PeerIdentity) String() string

+ type PeerTime struct

+ IncNum uint64

+ SeqNum uint64

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

+ func (*PeerTime) ProtoMessage()

+ func (m *PeerTime) GetIncNum() uint64

+ func (m *PeerTime) GetSeqNum() uint64

+ func (m *PeerTime) Reset()

+ func (m *PeerTime) String() string

+ 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 ReceivedMessage interface

+ GetConnectionInfo func() *ConnectionInfo

+ GetGossipMessage func() *SignedGossipMessage

+ GetSourceEnvelope func() *Envelope

+ Respond func(msg *GossipMessage)

+ type RemoteStateRequest struct

+ EndSeqNum uint64

+ StartSeqNum uint64

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

+ func (*RemoteStateRequest) ProtoMessage()

+ func (m *RemoteStateRequest) GetEndSeqNum() uint64

+ func (m *RemoteStateRequest) GetStartSeqNum() uint64

+ func (m *RemoteStateRequest) Reset()

+ func (m *RemoteStateRequest) String() string

+ type RemoteStateResponse struct

+ Payloads []*Payload

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

+ func (*RemoteStateResponse) ProtoMessage()

+ func (m *RemoteStateResponse) GetPayloads() []*Payload

+ func (m *RemoteStateResponse) Reset()

+ func (m *RemoteStateResponse) String() string

+ type Secret struct

+ Content isSecret_Content

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

+ func (*Secret) ProtoMessage()

+ func (*Secret) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *Secret) GetContent() isSecret_Content

+ func (m *Secret) GetInternalEndpoint() string

+ func (m *Secret) Reset()

+ func (m *Secret) String() string

+ type SecretEnvelope struct

+ Payload []byte

+ Signature []byte

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

+ func (*SecretEnvelope) ProtoMessage()

+ func (m *SecretEnvelope) GetPayload() []byte

+ func (m *SecretEnvelope) GetSignature() []byte

+ func (m *SecretEnvelope) Reset()

+ func (m *SecretEnvelope) String() string

+ 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

+ Metadata []byte

+ PkiId []byte

+ Timestamp *PeerTime

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

+ func (*StateInfo) ProtoMessage()

+ func (m *StateInfo) GetChannel_MAC() []byte

+ func (m *StateInfo) GetMetadata() []byte

+ func (m *StateInfo) GetPkiId() []byte

+ func (m *StateInfo) GetTimestamp() *PeerTime

+ func (m *StateInfo) Reset()

+ func (m *StateInfo) String() string

+ type StateInfoPullRequest struct

+ Channel_MAC []byte

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

+ func (*StateInfoPullRequest) ProtoMessage()

+ func (m *StateInfoPullRequest) GetChannel_MAC() []byte

+ func (m *StateInfoPullRequest) Reset()

+ func (m *StateInfoPullRequest) String() string

+ type StateInfoSnapshot struct

+ Elements []*Envelope

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

+ func (*StateInfoSnapshot) ProtoMessage()

+ func (m *StateInfoSnapshot) GetElements() []*Envelope

+ func (m *StateInfoSnapshot) Reset()

+ func (m *StateInfoSnapshot) String() string

+ type Verifier func(peerIdentity []byte, signature, message []byte) error

v1.0.0-rc1

Jun 23, 2017

v1.0.0-beta

Jun 8, 2017

v1.0.0-alpha2

May 12, 2017

v1.0.0-alpha

Mar 15, 2017

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