Documentation ¶
Index ¶
- func AliveMessageToString(am *gossip.AliveMessage) string
- func DataDigestToString(dig *gossip.DataDigest) string
- func DataRequestToString(dataReq *gossip.DataRequest) string
- func DataUpdateToString(du *gossip.DataUpdate) string
- func GetPullMsgType(m *gossip.GossipMessage) gossip.PullMsgType
- func InternalEndpoint(s *gossip.SecretEnvelope) string
- func IsAck(m *gossip.GossipMessage) bool
- func IsAliveMsg(m *gossip.GossipMessage) bool
- func IsChannelRestricted(m *gossip.GossipMessage) bool
- func IsDataMsg(m *gossip.GossipMessage) bool
- func IsDataReq(m *gossip.GossipMessage) bool
- func IsDataUpdate(m *gossip.GossipMessage) bool
- func IsDigestMsg(m *gossip.GossipMessage) bool
- func IsHelloMsg(m *gossip.GossipMessage) bool
- func IsIdentityMsg(m *gossip.GossipMessage) bool
- func IsLeadershipMsg(m *gossip.GossipMessage) bool
- func IsOrgRestricted(m *gossip.GossipMessage) bool
- func IsPrivateDataMsg(m *gossip.GossipMessage) bool
- func IsPullMsg(m *gossip.GossipMessage) bool
- func IsRemoteStateMessage(m *gossip.GossipMessage) bool
- func IsStateInfoMsg(m *gossip.GossipMessage) bool
- func IsStateInfoPullRequestMsg(m *gossip.GossipMessage) bool
- func IsStateInfoSnapshot(m *gossip.GossipMessage) bool
- func IsTagLegal(m *gossip.GossipMessage) error
- func LeadershipMessageToString(lm *gossip.LeadershipMessage) string
- func MemberToString(m *gossip.Member) string
- func MembershipRequestToString(mr *gossip.MembershipRequest) string
- func MembershipResponseToString(mr *gossip.MembershipResponse) string
- func NewGossipMessageComparator(dataBlockStorageSize int) common.MessageReplacingPolicy
- func PayloadToString(p *gossip.Payload) string
- func RemovePvtDataResponseToString(res *gossip.RemotePvtDataResponse) string
- func SignSecret(e *gossip.Envelope, signer Signer, secret *gossip.Secret) error
- func StateInfoPullRequestToString(sipr *gossip.StateInfoPullRequest) string
- func StateInfoSnapshotToString(sis *gossip.StateInfoSnapshot) string
- func StateInfoToString(si *gossip.StateInfo) string
- type AuthInfo
- type ConnectionInfo
- type ReceivedMessage
- type SignedGossipMessage
- type Signer
- type Verifier
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AliveMessageToString ¶
func AliveMessageToString(am *gossip.AliveMessage) string
func DataDigestToString ¶
func DataDigestToString(dig *gossip.DataDigest) string
func DataRequestToString ¶
func DataRequestToString(dataReq *gossip.DataRequest) string
func DataUpdateToString ¶
func DataUpdateToString(du *gossip.DataUpdate) string
func GetPullMsgType ¶
func GetPullMsgType(m *gossip.GossipMessage) gossip.PullMsgType
func InternalEndpoint ¶
func InternalEndpoint(s *gossip.SecretEnvelope) string
func IsAck ¶
func IsAck(m *gossip.GossipMessage) bool
func IsAliveMsg ¶
func IsAliveMsg(m *gossip.GossipMessage) bool
func IsChannelRestricted ¶
func IsChannelRestricted(m *gossip.GossipMessage) bool
func IsDataMsg ¶
func IsDataMsg(m *gossip.GossipMessage) bool
func IsDataReq ¶
func IsDataReq(m *gossip.GossipMessage) bool
func IsDataUpdate ¶
func IsDataUpdate(m *gossip.GossipMessage) bool
func IsDigestMsg ¶
func IsDigestMsg(m *gossip.GossipMessage) bool
func IsHelloMsg ¶
func IsHelloMsg(m *gossip.GossipMessage) bool
func IsIdentityMsg ¶
func IsIdentityMsg(m *gossip.GossipMessage) bool
func IsLeadershipMsg ¶
func IsLeadershipMsg(m *gossip.GossipMessage) bool
func IsOrgRestricted ¶
func IsOrgRestricted(m *gossip.GossipMessage) bool
func IsPrivateDataMsg ¶
func IsPrivateDataMsg(m *gossip.GossipMessage) bool
func IsPullMsg ¶
func IsPullMsg(m *gossip.GossipMessage) bool
func IsRemoteStateMessage ¶
func IsRemoteStateMessage(m *gossip.GossipMessage) bool
func IsStateInfoMsg ¶
func IsStateInfoMsg(m *gossip.GossipMessage) bool
func IsStateInfoPullRequestMsg ¶
func IsStateInfoPullRequestMsg(m *gossip.GossipMessage) bool
func IsStateInfoSnapshot ¶
func IsStateInfoSnapshot(m *gossip.GossipMessage) bool
func IsTagLegal ¶
func IsTagLegal(m *gossip.GossipMessage) error
func LeadershipMessageToString ¶
func LeadershipMessageToString(lm *gossip.LeadershipMessage) string
func MemberToString ¶
func MembershipRequestToString ¶
func MembershipRequestToString(mr *gossip.MembershipRequest) string
func MembershipResponseToString ¶
func MembershipResponseToString(mr *gossip.MembershipResponse) string
func NewGossipMessageComparator ¶
func NewGossipMessageComparator(dataBlockStorageSize int) common.MessageReplacingPolicy
func PayloadToString ¶
func RemovePvtDataResponseToString ¶
func RemovePvtDataResponseToString(res *gossip.RemotePvtDataResponse) string
func StateInfoPullRequestToString ¶
func StateInfoPullRequestToString(sipr *gossip.StateInfoPullRequest) string
func StateInfoSnapshotToString ¶
func StateInfoSnapshotToString(sis *gossip.StateInfoSnapshot) string
func StateInfoToString ¶
Types ¶
type ConnectionInfo ¶
type ConnectionInfo struct { ID common.PKIidType Auth *AuthInfo Identity api.PeerIdentityType Endpoint string }
func (*ConnectionInfo) String ¶
func (c *ConnectionInfo) String() string
type ReceivedMessage ¶
type ReceivedMessage interface { Respond(msg *gossip.GossipMessage) GetGossipMessage() *SignedGossipMessage GetSourceEnvelope() *gossip.Envelope GetConnectionInfo() *ConnectionInfo Ack(err error) }
type SignedGossipMessage ¶
type SignedGossipMessage struct { *gossip.Envelope *gossip.GossipMessage }
func EnvelopeToGossipMessage ¶
func EnvelopeToGossipMessage(e *gossip.Envelope) (*SignedGossipMessage, error)
func NoopSign ¶
func NoopSign(m *gossip.GossipMessage) (*SignedGossipMessage, error)
func (*SignedGossipMessage) IsSigned ¶
func (m *SignedGossipMessage) IsSigned() bool
func (*SignedGossipMessage) Sign ¶
func (m *SignedGossipMessage) Sign(signer Signer) (*gossip.Envelope, error)
func (*SignedGossipMessage) String ¶
func (m *SignedGossipMessage) String() string
Click to show internal directories.
Click to hide internal directories.