protoext

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
  • func (c *ConnectionInfo) String() string
• type ReceivedMessage
• type SignedGossipMessage
  • func EnvelopeToGossipMessage(e *gossip.Envelope) (*SignedGossipMessage, error)
  • func NoopSign(m *gossip.GossipMessage) (*SignedGossipMessage, error)
  • func (m *SignedGossipMessage) IsSigned() bool
  • func (m *SignedGossipMessage) Sign(signer Signer) (*gossip.Envelope, error)
  • func (m *SignedGossipMessage) String() string
  • func (m *SignedGossipMessage) Verify(peerIdentity []byte, verify Verifier) error
• type Signer
• type Verifier

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 MemberToString(m *gossip.Member) string

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 PayloadToString(p *gossip.Payload) string

func RemovePvtDataResponseToString

func RemovePvtDataResponseToString(res *gossip.RemotePvtDataResponse) string

func SignSecret

func SignSecret(e *gossip.Envelope, signer Signer, secret *gossip.Secret) error

func StateInfoPullRequestToString

func StateInfoPullRequestToString(sipr *gossip.StateInfoPullRequest) string

func StateInfoSnapshotToString

func StateInfoSnapshotToString(sis *gossip.StateInfoSnapshot) string

func StateInfoToString

func StateInfoToString(si *gossip.StateInfo) string

Types

type AuthInfo

type AuthInfo struct {
	SignedData []byte
	Signature  []byte
}

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

func (*SignedGossipMessage) Verify

func (m *SignedGossipMessage) Verify(peerIdentity []byte, verify Verifier) error

type Signer

type Signer func(msg []byte) ([]byte, error)

type Verifier

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