fabric: github.com/hyperledger/fabric/protos/gossip Index | Files

package gossip

import "github.com/hyperledger/fabric/protos/gossip"

Index

Package Files

extensions.go message.pb.go

Variables

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",
}
var GossipMessage_Tag_value = map[string]int32{
    "UNDEFINED":    0,
    "EMPTY":        1,
    "ORG_ONLY":     2,
    "CHAN_ONLY":    3,
    "CHAN_AND_ORG": 4,
    "CHAN_OR_ORG":  5,
}
var PullMsgType_name = map[int32]string{
    0:  "UNDEFINED",
    1:  "BLOCK_MSG",
    2:  "IDENTITY_MSG",
}
var PullMsgType_value = map[string]int32{
    "UNDEFINED":    0,
    "BLOCK_MSG":    1,
    "IDENTITY_MSG": 2,
}

func NewGossipMessageComparator Uses

func NewGossipMessageComparator(dataBlockStorageSize int) common.MessageReplacingPolicy

NewGossipMessageComparator creates a MessageReplacingPolicy given a maximum number of blocks to hold

func RegisterGossipServer Uses

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

type Acknowledgement Uses

type Acknowledgement struct {
    Error                string   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*Acknowledgement) Descriptor Uses

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

func (*Acknowledgement) GetError Uses

func (m *Acknowledgement) GetError() string

func (*Acknowledgement) ProtoMessage Uses

func (*Acknowledgement) ProtoMessage()

func (*Acknowledgement) Reset Uses

func (m *Acknowledgement) Reset()

func (*Acknowledgement) String Uses

func (m *Acknowledgement) String() string

func (*Acknowledgement) XXX_DiscardUnknown Uses

func (m *Acknowledgement) XXX_DiscardUnknown()

func (*Acknowledgement) XXX_Marshal Uses

func (m *Acknowledgement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Acknowledgement) XXX_Merge Uses

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

func (*Acknowledgement) XXX_Size Uses

func (m *Acknowledgement) XXX_Size() int

func (*Acknowledgement) XXX_Unmarshal Uses

func (m *Acknowledgement) XXX_Unmarshal(b []byte) error

type AliveMessage Uses

type AliveMessage struct {
    Membership           *Member   `protobuf:"bytes,1,opt,name=membership,proto3" json:"membership,omitempty"`
    Timestamp            *PeerTime `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
    Identity             []byte    `protobuf:"bytes,4,opt,name=identity,proto3" json:"identity,omitempty"`
    XXX_NoUnkeyedLiteral struct{}  `json:"-"`
    XXX_unrecognized     []byte    `json:"-"`
    XXX_sizecache        int32     `json:"-"`
}

AliveMessage is sent to inform remote peers of a peer's existence and activity

func (*AliveMessage) Descriptor Uses

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

func (*AliveMessage) GetIdentity Uses

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

func (*AliveMessage) GetMembership Uses

func (m *AliveMessage) GetMembership() *Member

func (*AliveMessage) GetTimestamp Uses

func (m *AliveMessage) GetTimestamp() *PeerTime

func (*AliveMessage) ProtoMessage Uses

func (*AliveMessage) ProtoMessage()

func (*AliveMessage) Reset Uses

func (m *AliveMessage) Reset()

func (*AliveMessage) String Uses

func (m *AliveMessage) String() string

func (*AliveMessage) XXX_DiscardUnknown Uses

func (m *AliveMessage) XXX_DiscardUnknown()

func (*AliveMessage) XXX_Marshal Uses

func (m *AliveMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AliveMessage) XXX_Merge Uses

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

func (*AliveMessage) XXX_Size Uses

func (m *AliveMessage) XXX_Size() int

func (*AliveMessage) XXX_Unmarshal Uses

func (m *AliveMessage) XXX_Unmarshal(b []byte) error

type AuthInfo Uses

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

AuthInfo represents the authentication data that was provided by the remote peer at the connection time

type Chaincode Uses

type Chaincode struct {
    Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    Version              string   `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
    Metadata             []byte   `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Chaincode represents a Chaincode that is installed on a peer

func (*Chaincode) Descriptor Uses

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

func (*Chaincode) GetMetadata Uses

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

func (*Chaincode) GetName Uses

func (m *Chaincode) GetName() string

func (*Chaincode) GetVersion Uses

func (m *Chaincode) GetVersion() string

func (*Chaincode) ProtoMessage Uses

func (*Chaincode) ProtoMessage()

func (*Chaincode) Reset Uses

func (m *Chaincode) Reset()

func (*Chaincode) String Uses

func (m *Chaincode) String() string

func (*Chaincode) XXX_DiscardUnknown Uses

func (m *Chaincode) XXX_DiscardUnknown()

func (*Chaincode) XXX_Marshal Uses

func (m *Chaincode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Chaincode) XXX_Merge Uses

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

func (*Chaincode) XXX_Size Uses

func (m *Chaincode) XXX_Size() int

func (*Chaincode) XXX_Unmarshal Uses

func (m *Chaincode) XXX_Unmarshal(b []byte) error

type ConnEstablish Uses

type ConnEstablish struct {
    PkiId                []byte   `protobuf:"bytes,1,opt,name=pki_id,json=pkiId,proto3" json:"pki_id,omitempty"`
    Identity             []byte   `protobuf:"bytes,2,opt,name=identity,proto3" json:"identity,omitempty"`
    TlsCertHash          []byte   `protobuf:"bytes,3,opt,name=tls_cert_hash,json=tlsCertHash,proto3" json:"tls_cert_hash,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

ConnEstablish is the message used for the gossip handshake Whenever a peer connects to another peer, it handshakes with it by sending this message that proves its identity

func (*ConnEstablish) Descriptor Uses

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

func (*ConnEstablish) GetIdentity Uses

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

func (*ConnEstablish) GetPkiId Uses

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

func (*ConnEstablish) GetTlsCertHash Uses

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

func (*ConnEstablish) ProtoMessage Uses

func (*ConnEstablish) ProtoMessage()

func (*ConnEstablish) Reset Uses

func (m *ConnEstablish) Reset()

func (*ConnEstablish) String Uses

func (m *ConnEstablish) String() string

func (*ConnEstablish) XXX_DiscardUnknown Uses

func (m *ConnEstablish) XXX_DiscardUnknown()

func (*ConnEstablish) XXX_Marshal Uses

func (m *ConnEstablish) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConnEstablish) XXX_Merge Uses

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

func (*ConnEstablish) XXX_Size Uses

func (m *ConnEstablish) XXX_Size() int

func (*ConnEstablish) XXX_Unmarshal Uses

func (m *ConnEstablish) XXX_Unmarshal(b []byte) error

type ConnectionInfo Uses

type ConnectionInfo struct {
    ID       common.PKIidType
    Auth     *AuthInfo
    Identity api.PeerIdentityType
    Endpoint string
}

ConnectionInfo represents information about the remote peer that sent a certain ReceivedMessage

func (*ConnectionInfo) String Uses

func (c *ConnectionInfo) String() string

String returns a string representation of this ConnectionInfo

type DataDigest Uses

type DataDigest struct {
    Nonce                uint64      `protobuf:"varint,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
    Digests              [][]byte    `protobuf:"bytes,2,rep,name=digests,proto3" json:"digests,omitempty"`
    MsgType              PullMsgType `protobuf:"varint,3,opt,name=msg_type,json=msgType,proto3,enum=gossip.PullMsgType" json:"msg_type,omitempty"`
    XXX_NoUnkeyedLiteral struct{}    `json:"-"`
    XXX_unrecognized     []byte      `json:"-"`
    XXX_sizecache        int32       `json:"-"`
}

DataDigest is the message sent from the receiver peer to the initator peer and contains the data items it has

func (*DataDigest) Descriptor Uses

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

func (*DataDigest) FormattedDigests Uses

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

func (*DataDigest) GetDigests Uses

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

func (*DataDigest) GetMsgType Uses

func (m *DataDigest) GetMsgType() PullMsgType

func (*DataDigest) GetNonce Uses

func (m *DataDigest) GetNonce() uint64

func (*DataDigest) ProtoMessage Uses

func (*DataDigest) ProtoMessage()

func (*DataDigest) Reset Uses

func (m *DataDigest) Reset()

func (*DataDigest) String Uses

func (m *DataDigest) String() string

func (*DataDigest) XXX_DiscardUnknown Uses

func (m *DataDigest) XXX_DiscardUnknown()

func (*DataDigest) XXX_Marshal Uses

func (m *DataDigest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataDigest) XXX_Merge Uses

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

func (*DataDigest) XXX_Size Uses

func (m *DataDigest) XXX_Size() int

func (*DataDigest) XXX_Unmarshal Uses

func (m *DataDigest) XXX_Unmarshal(b []byte) error

type DataMessage Uses

type DataMessage struct {
    Payload              *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

DataMessage is the message that contains a block

func (*DataMessage) Descriptor Uses

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

func (*DataMessage) GetPayload Uses

func (m *DataMessage) GetPayload() *Payload

func (*DataMessage) ProtoMessage Uses

func (*DataMessage) ProtoMessage()

func (*DataMessage) Reset Uses

func (m *DataMessage) Reset()

func (*DataMessage) String Uses

func (m *DataMessage) String() string

func (*DataMessage) XXX_DiscardUnknown Uses

func (m *DataMessage) XXX_DiscardUnknown()

func (*DataMessage) XXX_Marshal Uses

func (m *DataMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataMessage) XXX_Merge Uses

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

func (*DataMessage) XXX_Size Uses

func (m *DataMessage) XXX_Size() int

func (*DataMessage) XXX_Unmarshal Uses

func (m *DataMessage) XXX_Unmarshal(b []byte) error

type DataRequest Uses

type DataRequest struct {
    Nonce                uint64      `protobuf:"varint,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
    Digests              [][]byte    `protobuf:"bytes,2,rep,name=digests,proto3" json:"digests,omitempty"`
    MsgType              PullMsgType `protobuf:"varint,3,opt,name=msg_type,json=msgType,proto3,enum=gossip.PullMsgType" json:"msg_type,omitempty"`
    XXX_NoUnkeyedLiteral struct{}    `json:"-"`
    XXX_unrecognized     []byte      `json:"-"`
    XXX_sizecache        int32       `json:"-"`
}

DataRequest is a message used for a peer to request certain data blocks from a remote peer

func (*DataRequest) Descriptor Uses

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

func (*DataRequest) FormattedDigests Uses

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

func (*DataRequest) GetDigests Uses

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

func (*DataRequest) GetMsgType Uses

func (m *DataRequest) GetMsgType() PullMsgType

func (*DataRequest) GetNonce Uses

func (m *DataRequest) GetNonce() uint64

func (*DataRequest) ProtoMessage Uses

func (*DataRequest) ProtoMessage()

func (*DataRequest) Reset Uses

func (m *DataRequest) Reset()

func (*DataRequest) String Uses

func (m *DataRequest) String() string

func (*DataRequest) XXX_DiscardUnknown Uses

func (m *DataRequest) XXX_DiscardUnknown()

func (*DataRequest) XXX_Marshal Uses

func (m *DataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataRequest) XXX_Merge Uses

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

func (*DataRequest) XXX_Size Uses

func (m *DataRequest) XXX_Size() int

func (*DataRequest) XXX_Unmarshal Uses

func (m *DataRequest) XXX_Unmarshal(b []byte) error

type DataUpdate Uses

type DataUpdate struct {
    Nonce                uint64      `protobuf:"varint,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
    Data                 []*Envelope `protobuf:"bytes,2,rep,name=data,proto3" json:"data,omitempty"`
    MsgType              PullMsgType `protobuf:"varint,3,opt,name=msg_type,json=msgType,proto3,enum=gossip.PullMsgType" json:"msg_type,omitempty"`
    XXX_NoUnkeyedLiteral struct{}    `json:"-"`
    XXX_unrecognized     []byte      `json:"-"`
    XXX_sizecache        int32       `json:"-"`
}

DataUpdate is the final message in the pull phase sent from the receiver to the initiator

func (*DataUpdate) Descriptor Uses

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

func (*DataUpdate) GetData Uses

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

func (*DataUpdate) GetMsgType Uses

func (m *DataUpdate) GetMsgType() PullMsgType

func (*DataUpdate) GetNonce Uses

func (m *DataUpdate) GetNonce() uint64

func (*DataUpdate) ProtoMessage Uses

func (*DataUpdate) ProtoMessage()

func (*DataUpdate) Reset Uses

func (m *DataUpdate) Reset()

func (*DataUpdate) String Uses

func (m *DataUpdate) String() string

func (*DataUpdate) XXX_DiscardUnknown Uses

func (m *DataUpdate) XXX_DiscardUnknown()

func (*DataUpdate) XXX_Marshal Uses

func (m *DataUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataUpdate) XXX_Merge Uses

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

func (*DataUpdate) XXX_Size Uses

func (m *DataUpdate) XXX_Size() int

func (*DataUpdate) XXX_Unmarshal Uses

func (m *DataUpdate) XXX_Unmarshal(b []byte) error

type Empty Uses

type Empty struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Empty is used for pinging and in tests

func (*Empty) Descriptor Uses

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

func (*Empty) ProtoMessage Uses

func (*Empty) ProtoMessage()

func (*Empty) Reset Uses

func (m *Empty) Reset()

func (*Empty) String Uses

func (m *Empty) String() string

func (*Empty) XXX_DiscardUnknown Uses

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal Uses

func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Empty) XXX_Merge Uses

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

func (*Empty) XXX_Size Uses

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal Uses

func (m *Empty) XXX_Unmarshal(b []byte) error

type Envelope Uses

type Envelope struct {
    Payload              []byte          `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
    Signature            []byte          `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
    SecretEnvelope       *SecretEnvelope `protobuf:"bytes,3,opt,name=secret_envelope,json=secretEnvelope,proto3" json:"secret_envelope,omitempty"`
    XXX_NoUnkeyedLiteral struct{}        `json:"-"`
    XXX_unrecognized     []byte          `json:"-"`
    XXX_sizecache        int32           `json:"-"`
}

Envelope contains a marshalled GossipMessage and a signature over it. It may also contain a SecretEnvelope which is a marshalled Secret

func (*Envelope) Descriptor Uses

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

func (*Envelope) GetPayload Uses

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

func (*Envelope) GetSecretEnvelope Uses

func (m *Envelope) GetSecretEnvelope() *SecretEnvelope

func (*Envelope) GetSignature Uses

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

func (*Envelope) ProtoMessage Uses

func (*Envelope) ProtoMessage()

func (*Envelope) Reset Uses

func (m *Envelope) Reset()

func (*Envelope) SignSecret Uses

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

SignSecret signs the secret payload and creates a secret envelope out of it.

func (*Envelope) String Uses

func (m *Envelope) String() string

func (*Envelope) ToGossipMessage Uses

func (e *Envelope) ToGossipMessage() (*SignedGossipMessage, error)

ToGossipMessage un-marshals a given envelope and creates a SignedGossipMessage out of it. Returns an error if un-marshaling fails.

func (*Envelope) XXX_DiscardUnknown Uses

func (m *Envelope) XXX_DiscardUnknown()

func (*Envelope) XXX_Marshal Uses

func (m *Envelope) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Envelope) XXX_Merge Uses

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

func (*Envelope) XXX_Size Uses

func (m *Envelope) XXX_Size() int

func (*Envelope) XXX_Unmarshal Uses

func (m *Envelope) XXX_Unmarshal(b []byte) error

type GossipClient Uses

type GossipClient interface {
    // GossipStream is the gRPC stream used for sending and receiving messages
    GossipStream(ctx context.Context, opts ...grpc.CallOption) (Gossip_GossipStreamClient, error)
    // Ping is used to probe a remote peer's aliveness
    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 Uses

func NewGossipClient(cc *grpc.ClientConn) GossipClient

type GossipHello Uses

type GossipHello struct {
    Nonce                uint64      `protobuf:"varint,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
    Metadata             []byte      `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
    MsgType              PullMsgType `protobuf:"varint,3,opt,name=msg_type,json=msgType,proto3,enum=gossip.PullMsgType" json:"msg_type,omitempty"`
    XXX_NoUnkeyedLiteral struct{}    `json:"-"`
    XXX_unrecognized     []byte      `json:"-"`
    XXX_sizecache        int32       `json:"-"`
}

GossipHello is the message that is used for the peer to initiate a pull round with another peer

func (*GossipHello) Descriptor Uses

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

func (*GossipHello) GetMetadata Uses

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

func (*GossipHello) GetMsgType Uses

func (m *GossipHello) GetMsgType() PullMsgType

func (*GossipHello) GetNonce Uses

func (m *GossipHello) GetNonce() uint64

func (*GossipHello) ProtoMessage Uses

func (*GossipHello) ProtoMessage()

func (*GossipHello) Reset Uses

func (m *GossipHello) Reset()

func (*GossipHello) String Uses

func (m *GossipHello) String() string

func (*GossipHello) XXX_DiscardUnknown Uses

func (m *GossipHello) XXX_DiscardUnknown()

func (*GossipHello) XXX_Marshal Uses

func (m *GossipHello) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GossipHello) XXX_Merge Uses

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

func (*GossipHello) XXX_Size Uses

func (m *GossipHello) XXX_Size() int

func (*GossipHello) XXX_Unmarshal Uses

func (m *GossipHello) XXX_Unmarshal(b []byte) error

type GossipMessage Uses

type GossipMessage struct {
    // used mainly for testing, but will might be used in the future
    // for ensuring message delivery by acking
    Nonce uint64 `protobuf:"varint,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
    // The channel of the message.
    // Some GossipMessages may set this to nil, because
    // they are cross-channels but some may not
    Channel []byte `protobuf:"bytes,2,opt,name=channel,proto3" json:"channel,omitempty"`
    // determines to which peers it is allowed
    // to forward the message
    Tag GossipMessage_Tag `protobuf:"varint,3,opt,name=tag,proto3,enum=gossip.GossipMessage_Tag" json:"tag,omitempty"`
    // Types that are valid to be assigned to Content:
    //	*GossipMessage_AliveMsg
    //	*GossipMessage_MemReq
    //	*GossipMessage_MemRes
    //	*GossipMessage_DataMsg
    //	*GossipMessage_Hello
    //	*GossipMessage_DataDig
    //	*GossipMessage_DataReq
    //	*GossipMessage_DataUpdate
    //	*GossipMessage_Empty
    //	*GossipMessage_Conn
    //	*GossipMessage_StateInfo
    //	*GossipMessage_StateSnapshot
    //	*GossipMessage_StateInfoPullReq
    //	*GossipMessage_StateRequest
    //	*GossipMessage_StateResponse
    //	*GossipMessage_LeadershipMsg
    //	*GossipMessage_PeerIdentity
    //	*GossipMessage_Ack
    //	*GossipMessage_PrivateReq
    //	*GossipMessage_PrivateRes
    //	*GossipMessage_PrivateData
    Content              isGossipMessage_Content `protobuf_oneof:"content"`
    XXX_NoUnkeyedLiteral struct{}                `json:"-"`
    XXX_unrecognized     []byte                  `json:"-"`
    XXX_sizecache        int32                   `json:"-"`
}

GossipMessage defines the message sent in a gossip network

func (*GossipMessage) Descriptor Uses

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

func (*GossipMessage) GetAck Uses

func (m *GossipMessage) GetAck() *Acknowledgement

func (*GossipMessage) GetAliveMsg Uses

func (m *GossipMessage) GetAliveMsg() *AliveMessage

func (*GossipMessage) GetChannel Uses

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

func (*GossipMessage) GetConn Uses

func (m *GossipMessage) GetConn() *ConnEstablish

func (*GossipMessage) GetContent Uses

func (m *GossipMessage) GetContent() isGossipMessage_Content

func (*GossipMessage) GetDataDig Uses

func (m *GossipMessage) GetDataDig() *DataDigest

func (*GossipMessage) GetDataMsg Uses

func (m *GossipMessage) GetDataMsg() *DataMessage

func (*GossipMessage) GetDataReq Uses

func (m *GossipMessage) GetDataReq() *DataRequest

func (*GossipMessage) GetDataUpdate Uses

func (m *GossipMessage) GetDataUpdate() *DataUpdate

func (*GossipMessage) GetEmpty Uses

func (m *GossipMessage) GetEmpty() *Empty

func (*GossipMessage) GetHello Uses

func (m *GossipMessage) GetHello() *GossipHello

func (*GossipMessage) GetLeadershipMsg Uses

func (m *GossipMessage) GetLeadershipMsg() *LeadershipMessage

func (*GossipMessage) GetMemReq Uses

func (m *GossipMessage) GetMemReq() *MembershipRequest

func (*GossipMessage) GetMemRes Uses

func (m *GossipMessage) GetMemRes() *MembershipResponse

func (*GossipMessage) GetNonce Uses

func (m *GossipMessage) GetNonce() uint64

func (*GossipMessage) GetPeerIdentity Uses

func (m *GossipMessage) GetPeerIdentity() *PeerIdentity

func (*GossipMessage) GetPrivateData Uses

func (m *GossipMessage) GetPrivateData() *PrivateDataMessage

func (*GossipMessage) GetPrivateReq Uses

func (m *GossipMessage) GetPrivateReq() *RemotePvtDataRequest

func (*GossipMessage) GetPrivateRes Uses

func (m *GossipMessage) GetPrivateRes() *RemotePvtDataResponse

func (*GossipMessage) GetPullMsgType Uses

func (m *GossipMessage) GetPullMsgType() PullMsgType

GetPullMsgType returns the phase of the pull mechanism this GossipMessage belongs to for example: Hello, Digest, etc. If this isn't a pull message, PullMsgType_UNDEFINED is returned.

func (*GossipMessage) GetStateInfo Uses

func (m *GossipMessage) GetStateInfo() *StateInfo

func (*GossipMessage) GetStateInfoPullReq Uses

func (m *GossipMessage) GetStateInfoPullReq() *StateInfoPullRequest

func (*GossipMessage) GetStateRequest Uses

func (m *GossipMessage) GetStateRequest() *RemoteStateRequest

func (*GossipMessage) GetStateResponse Uses

func (m *GossipMessage) GetStateResponse() *RemoteStateResponse

func (*GossipMessage) GetStateSnapshot Uses

func (m *GossipMessage) GetStateSnapshot() *StateInfoSnapshot

func (*GossipMessage) GetTag Uses

func (m *GossipMessage) GetTag() GossipMessage_Tag

func (*GossipMessage) IsAck Uses

func (m *GossipMessage) IsAck() bool

IsAck returns whether this GossipMessage is an acknowledgement

func (*GossipMessage) IsAliveMsg Uses

func (m *GossipMessage) IsAliveMsg() bool

IsAliveMsg returns whether this GossipMessage is an AliveMessage

func (*GossipMessage) IsChannelRestricted Uses

func (m *GossipMessage) IsChannelRestricted() bool

IsChannelRestricted returns whether this GossipMessage should be routed only in its channel

func (*GossipMessage) IsDataMsg Uses

func (m *GossipMessage) IsDataMsg() bool

IsDataMsg returns whether this GossipMessage is a data message

func (*GossipMessage) IsDataReq Uses

func (m *GossipMessage) IsDataReq() bool

IsDataReq returns whether this GossipMessage is a data request message

func (*GossipMessage) IsDataUpdate Uses

func (m *GossipMessage) IsDataUpdate() bool

IsDataUpdate returns whether this GossipMessage is a data update message

func (*GossipMessage) IsDigestMsg Uses

func (m *GossipMessage) IsDigestMsg() bool

IsDigestMsg returns whether this GossipMessage is a digest message

func (*GossipMessage) IsHelloMsg Uses

func (m *GossipMessage) IsHelloMsg() bool

IsHelloMsg returns whether this GossipMessage is a hello message

func (*GossipMessage) IsIdentityMsg Uses

func (m *GossipMessage) IsIdentityMsg() bool

IsIdentityMsg returns whether this GossipMessage is an identity message

func (*GossipMessage) IsLeadershipMsg Uses

func (m *GossipMessage) IsLeadershipMsg() bool

IsLeadershipMsg returns whether this GossipMessage is a leadership (leader election) message

func (*GossipMessage) IsOrgRestricted Uses

func (m *GossipMessage) IsOrgRestricted() bool

IsOrgRestricted returns whether this GossipMessage should be routed only inside the organization

func (*GossipMessage) IsPrivateDataMsg Uses

func (m *GossipMessage) IsPrivateDataMsg() bool

IsPrivateDataMsg returns whether this message is related to private data

func (*GossipMessage) IsPullMsg Uses

func (m *GossipMessage) IsPullMsg() bool

IsPullMsg returns whether this GossipMessage is a message that belongs to the pull mechanism

func (*GossipMessage) IsRemoteStateMessage Uses

func (m *GossipMessage) IsRemoteStateMessage() bool

IsRemoteStateMessage returns whether this GossipMessage is related to state synchronization

func (*GossipMessage) IsStateInfoMsg Uses

func (m *GossipMessage) IsStateInfoMsg() bool

IsStateInfoMsg returns whether this GossipMessage is a stateInfo message

func (*GossipMessage) IsStateInfoPullRequestMsg Uses

func (m *GossipMessage) IsStateInfoPullRequestMsg() bool

IsStateInfoPullRequestMsg returns whether this GossipMessage is a stateInfoPullRequest

func (*GossipMessage) IsStateInfoSnapshot Uses

func (m *GossipMessage) IsStateInfoSnapshot() bool

IsStateInfoSnapshot returns whether this GossipMessage is a stateInfo snapshot

func (*GossipMessage) IsTagLegal Uses

func (m *GossipMessage) IsTagLegal() error

IsTagLegal checks the GossipMessage tags and inner type and returns an error if the tag doesn't match the type.

func (*GossipMessage) NoopSign Uses

func (m *GossipMessage) NoopSign() (*SignedGossipMessage, error)

NoopSign creates a SignedGossipMessage with a nil signature

func (*GossipMessage) ProtoMessage Uses

func (*GossipMessage) ProtoMessage()

func (*GossipMessage) Reset Uses

func (m *GossipMessage) Reset()

func (*GossipMessage) String Uses

func (m *GossipMessage) String() string

func (*GossipMessage) XXX_DiscardUnknown Uses

func (m *GossipMessage) XXX_DiscardUnknown()

func (*GossipMessage) XXX_Marshal Uses

func (m *GossipMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GossipMessage) XXX_Merge Uses

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

func (*GossipMessage) XXX_OneofFuncs Uses

func (*GossipMessage) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*GossipMessage) XXX_Size Uses

func (m *GossipMessage) XXX_Size() int

func (*GossipMessage) XXX_Unmarshal Uses

func (m *GossipMessage) XXX_Unmarshal(b []byte) error

type GossipMessage_Ack Uses

type GossipMessage_Ack struct {
    Ack *Acknowledgement `protobuf:"bytes,22,opt,name=ack,proto3,oneof"`
}

type GossipMessage_AliveMsg Uses

type GossipMessage_AliveMsg struct {
    AliveMsg *AliveMessage `protobuf:"bytes,5,opt,name=alive_msg,json=aliveMsg,proto3,oneof"`
}

type GossipMessage_Conn Uses

type GossipMessage_Conn struct {
    Conn *ConnEstablish `protobuf:"bytes,14,opt,name=conn,proto3,oneof"`
}

type GossipMessage_DataDig Uses

type GossipMessage_DataDig struct {
    DataDig *DataDigest `protobuf:"bytes,10,opt,name=data_dig,json=dataDig,proto3,oneof"`
}

type GossipMessage_DataMsg Uses

type GossipMessage_DataMsg struct {
    DataMsg *DataMessage `protobuf:"bytes,8,opt,name=data_msg,json=dataMsg,proto3,oneof"`
}

type GossipMessage_DataReq Uses

type GossipMessage_DataReq struct {
    DataReq *DataRequest `protobuf:"bytes,11,opt,name=data_req,json=dataReq,proto3,oneof"`
}

type GossipMessage_DataUpdate Uses

type GossipMessage_DataUpdate struct {
    DataUpdate *DataUpdate `protobuf:"bytes,12,opt,name=data_update,json=dataUpdate,proto3,oneof"`
}

type GossipMessage_Empty Uses

type GossipMessage_Empty struct {
    Empty *Empty `protobuf:"bytes,13,opt,name=empty,proto3,oneof"`
}

type GossipMessage_Hello Uses

type GossipMessage_Hello struct {
    Hello *GossipHello `protobuf:"bytes,9,opt,name=hello,proto3,oneof"`
}

type GossipMessage_LeadershipMsg Uses

type GossipMessage_LeadershipMsg struct {
    LeadershipMsg *LeadershipMessage `protobuf:"bytes,20,opt,name=leadership_msg,json=leadershipMsg,proto3,oneof"`
}

type GossipMessage_MemReq Uses

type GossipMessage_MemReq struct {
    MemReq *MembershipRequest `protobuf:"bytes,6,opt,name=mem_req,json=memReq,proto3,oneof"`
}

type GossipMessage_MemRes Uses

type GossipMessage_MemRes struct {
    MemRes *MembershipResponse `protobuf:"bytes,7,opt,name=mem_res,json=memRes,proto3,oneof"`
}

type GossipMessage_PeerIdentity Uses

type GossipMessage_PeerIdentity struct {
    PeerIdentity *PeerIdentity `protobuf:"bytes,21,opt,name=peer_identity,json=peerIdentity,proto3,oneof"`
}

type GossipMessage_PrivateData Uses

type GossipMessage_PrivateData struct {
    PrivateData *PrivateDataMessage `protobuf:"bytes,25,opt,name=private_data,json=privateData,proto3,oneof"`
}

type GossipMessage_PrivateReq Uses

type GossipMessage_PrivateReq struct {
    PrivateReq *RemotePvtDataRequest `protobuf:"bytes,23,opt,name=privateReq,proto3,oneof"`
}

type GossipMessage_PrivateRes Uses

type GossipMessage_PrivateRes struct {
    PrivateRes *RemotePvtDataResponse `protobuf:"bytes,24,opt,name=privateRes,proto3,oneof"`
}

type GossipMessage_StateInfo Uses

type GossipMessage_StateInfo struct {
    StateInfo *StateInfo `protobuf:"bytes,15,opt,name=state_info,json=stateInfo,proto3,oneof"`
}

type GossipMessage_StateInfoPullReq Uses

type GossipMessage_StateInfoPullReq struct {
    StateInfoPullReq *StateInfoPullRequest `protobuf:"bytes,17,opt,name=state_info_pull_req,json=stateInfoPullReq,proto3,oneof"`
}

type GossipMessage_StateRequest Uses

type GossipMessage_StateRequest struct {
    StateRequest *RemoteStateRequest `protobuf:"bytes,18,opt,name=state_request,json=stateRequest,proto3,oneof"`
}

type GossipMessage_StateResponse Uses

type GossipMessage_StateResponse struct {
    StateResponse *RemoteStateResponse `protobuf:"bytes,19,opt,name=state_response,json=stateResponse,proto3,oneof"`
}

type GossipMessage_StateSnapshot Uses

type GossipMessage_StateSnapshot struct {
    StateSnapshot *StateInfoSnapshot `protobuf:"bytes,16,opt,name=state_snapshot,json=stateSnapshot,proto3,oneof"`
}

type GossipMessage_Tag Uses

type GossipMessage_Tag int32
const (
    GossipMessage_UNDEFINED    GossipMessage_Tag = 0
    GossipMessage_EMPTY        GossipMessage_Tag = 1
    GossipMessage_ORG_ONLY     GossipMessage_Tag = 2
    GossipMessage_CHAN_ONLY    GossipMessage_Tag = 3
    GossipMessage_CHAN_AND_ORG GossipMessage_Tag = 4
    GossipMessage_CHAN_OR_ORG  GossipMessage_Tag = 5
)

func (GossipMessage_Tag) EnumDescriptor Uses

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

func (GossipMessage_Tag) String Uses

func (x GossipMessage_Tag) String() string

type GossipServer Uses

type GossipServer interface {
    // GossipStream is the gRPC stream used for sending and receiving messages
    GossipStream(Gossip_GossipStreamServer) error
    // Ping is used to probe a remote peer's aliveness
    Ping(context.Context, *Empty) (*Empty, error)
}

GossipServer is the server API for Gossip service.

type Gossip_GossipStreamClient Uses

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

type Gossip_GossipStreamServer Uses

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

type IdentifierExtractor Uses

type IdentifierExtractor func(*SignedGossipMessage) string

IdentifierExtractor extracts from a SignedGossipMessage an identifier

type LeadershipMessage Uses

type LeadershipMessage struct {
    PkiId                []byte    `protobuf:"bytes,1,opt,name=pki_id,json=pkiId,proto3" json:"pki_id,omitempty"`
    Timestamp            *PeerTime `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
    IsDeclaration        bool      `protobuf:"varint,3,opt,name=is_declaration,json=isDeclaration,proto3" json:"is_declaration,omitempty"`
    XXX_NoUnkeyedLiteral struct{}  `json:"-"`
    XXX_unrecognized     []byte    `json:"-"`
    XXX_sizecache        int32     `json:"-"`
}

Leadership Message is sent during leader election to inform remote peers about intent of peer to proclaim itself as leader

func (*LeadershipMessage) Descriptor Uses

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

func (*LeadershipMessage) GetIsDeclaration Uses

func (m *LeadershipMessage) GetIsDeclaration() bool

func (*LeadershipMessage) GetPkiId Uses

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

func (*LeadershipMessage) GetTimestamp Uses

func (m *LeadershipMessage) GetTimestamp() *PeerTime

func (*LeadershipMessage) ProtoMessage Uses

func (*LeadershipMessage) ProtoMessage()

func (*LeadershipMessage) Reset Uses

func (m *LeadershipMessage) Reset()

func (*LeadershipMessage) String Uses

func (m *LeadershipMessage) String() string

func (*LeadershipMessage) XXX_DiscardUnknown Uses

func (m *LeadershipMessage) XXX_DiscardUnknown()

func (*LeadershipMessage) XXX_Marshal Uses

func (m *LeadershipMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LeadershipMessage) XXX_Merge Uses

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

func (*LeadershipMessage) XXX_Size Uses

func (m *LeadershipMessage) XXX_Size() int

func (*LeadershipMessage) XXX_Unmarshal Uses

func (m *LeadershipMessage) XXX_Unmarshal(b []byte) error

type Member Uses

type Member struct {
    Endpoint             string   `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
    Metadata             []byte   `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
    PkiId                []byte   `protobuf:"bytes,3,opt,name=pki_id,json=pkiId,proto3" json:"pki_id,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Member holds membership-related information about a peer

func (*Member) Descriptor Uses

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

func (*Member) GetEndpoint Uses

func (m *Member) GetEndpoint() string

func (*Member) GetMetadata Uses

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

func (*Member) GetPkiId Uses

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

func (*Member) ProtoMessage Uses

func (*Member) ProtoMessage()

func (*Member) Reset Uses

func (m *Member) Reset()

func (*Member) String Uses

func (m *Member) String() string

func (*Member) XXX_DiscardUnknown Uses

func (m *Member) XXX_DiscardUnknown()

func (*Member) XXX_Marshal Uses

func (m *Member) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Member) XXX_Merge Uses

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

func (*Member) XXX_Size Uses

func (m *Member) XXX_Size() int

func (*Member) XXX_Unmarshal Uses

func (m *Member) XXX_Unmarshal(b []byte) error

type MembershipRequest Uses

type MembershipRequest struct {
    SelfInformation      *Envelope `protobuf:"bytes,1,opt,name=self_information,json=selfInformation,proto3" json:"self_information,omitempty"`
    Known                [][]byte  `protobuf:"bytes,2,rep,name=known,proto3" json:"known,omitempty"`
    XXX_NoUnkeyedLiteral struct{}  `json:"-"`
    XXX_unrecognized     []byte    `json:"-"`
    XXX_sizecache        int32     `json:"-"`
}

MembershipRequest is used to ask membership information from a remote peer

func (*MembershipRequest) Descriptor Uses

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

func (*MembershipRequest) GetKnown Uses

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

func (*MembershipRequest) GetSelfInformation Uses

func (m *MembershipRequest) GetSelfInformation() *Envelope

func (*MembershipRequest) ProtoMessage Uses

func (*MembershipRequest) ProtoMessage()

func (*MembershipRequest) Reset Uses

func (m *MembershipRequest) Reset()

func (*MembershipRequest) String Uses

func (m *MembershipRequest) String() string

func (*MembershipRequest) XXX_DiscardUnknown Uses

func (m *MembershipRequest) XXX_DiscardUnknown()

func (*MembershipRequest) XXX_Marshal Uses

func (m *MembershipRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MembershipRequest) XXX_Merge Uses

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

func (*MembershipRequest) XXX_Size Uses

func (m *MembershipRequest) XXX_Size() int

func (*MembershipRequest) XXX_Unmarshal Uses

func (m *MembershipRequest) XXX_Unmarshal(b []byte) error

type MembershipResponse Uses

type MembershipResponse struct {
    Alive                []*Envelope `protobuf:"bytes,1,rep,name=alive,proto3" json:"alive,omitempty"`
    Dead                 []*Envelope `protobuf:"bytes,2,rep,name=dead,proto3" json:"dead,omitempty"`
    XXX_NoUnkeyedLiteral struct{}    `json:"-"`
    XXX_unrecognized     []byte      `json:"-"`
    XXX_sizecache        int32       `json:"-"`
}

MembershipResponse is used for replying to MembershipRequests

func (*MembershipResponse) Descriptor Uses

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

func (*MembershipResponse) GetAlive Uses

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

func (*MembershipResponse) GetDead Uses

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

func (*MembershipResponse) ProtoMessage Uses

func (*MembershipResponse) ProtoMessage()

func (*MembershipResponse) Reset Uses

func (m *MembershipResponse) Reset()

func (*MembershipResponse) String Uses

func (m *MembershipResponse) String() string

func (*MembershipResponse) XXX_DiscardUnknown Uses

func (m *MembershipResponse) XXX_DiscardUnknown()

func (*MembershipResponse) XXX_Marshal Uses

func (m *MembershipResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MembershipResponse) XXX_Merge Uses

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

func (*MembershipResponse) XXX_Size Uses

func (m *MembershipResponse) XXX_Size() int

func (*MembershipResponse) XXX_Unmarshal Uses

func (m *MembershipResponse) XXX_Unmarshal(b []byte) error

type MsgConsumer Uses

type MsgConsumer func(message *SignedGossipMessage)

MsgConsumer invokes code given a SignedGossipMessage

type Payload Uses

type Payload struct {
    SeqNum               uint64   `protobuf:"varint,1,opt,name=seq_num,json=seqNum,proto3" json:"seq_num,omitempty"`
    Data                 []byte   `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
    PrivateData          [][]byte `protobuf:"bytes,3,rep,name=private_data,json=privateData,proto3" json:"private_data,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Payload contains a block

func (*Payload) Descriptor Uses

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

func (*Payload) GetData Uses

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

func (*Payload) GetPrivateData Uses

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

func (*Payload) GetSeqNum Uses

func (m *Payload) GetSeqNum() uint64

func (*Payload) ProtoMessage Uses

func (*Payload) ProtoMessage()

func (*Payload) Reset Uses

func (m *Payload) Reset()

func (*Payload) String Uses

func (m *Payload) String() string

func (*Payload) XXX_DiscardUnknown Uses

func (m *Payload) XXX_DiscardUnknown()

func (*Payload) XXX_Marshal Uses

func (m *Payload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Payload) XXX_Merge Uses

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

func (*Payload) XXX_Size Uses

func (m *Payload) XXX_Size() int

func (*Payload) XXX_Unmarshal Uses

func (m *Payload) XXX_Unmarshal(b []byte) error

type PeerIdentity Uses

type PeerIdentity struct {
    PkiId                []byte   `protobuf:"bytes,1,opt,name=pki_id,json=pkiId,proto3" json:"pki_id,omitempty"`
    Cert                 []byte   `protobuf:"bytes,2,opt,name=cert,proto3" json:"cert,omitempty"`
    Metadata             []byte   `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

PeerIdentity defines the identity of the peer Used to make other peers learn of the identity of a certain peer

func (*PeerIdentity) Descriptor Uses

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

func (*PeerIdentity) GetCert Uses

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

func (*PeerIdentity) GetMetadata Uses

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

func (*PeerIdentity) GetPkiId Uses

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

func (*PeerIdentity) ProtoMessage Uses

func (*PeerIdentity) ProtoMessage()

func (*PeerIdentity) Reset Uses

func (m *PeerIdentity) Reset()

func (*PeerIdentity) String Uses

func (m *PeerIdentity) String() string

func (*PeerIdentity) XXX_DiscardUnknown Uses

func (m *PeerIdentity) XXX_DiscardUnknown()

func (*PeerIdentity) XXX_Marshal Uses

func (m *PeerIdentity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PeerIdentity) XXX_Merge Uses

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

func (*PeerIdentity) XXX_Size Uses

func (m *PeerIdentity) XXX_Size() int

func (*PeerIdentity) XXX_Unmarshal Uses

func (m *PeerIdentity) XXX_Unmarshal(b []byte) error

type PeerTime Uses

type PeerTime struct {
    IncNum               uint64   `protobuf:"varint,1,opt,name=inc_num,json=incNum,proto3" json:"inc_num,omitempty"`
    SeqNum               uint64   `protobuf:"varint,2,opt,name=seq_num,json=seqNum,proto3" json:"seq_num,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

PeerTime defines the logical time of a peer's life

func (*PeerTime) Descriptor Uses

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

func (*PeerTime) GetIncNum Uses

func (m *PeerTime) GetIncNum() uint64

func (*PeerTime) GetSeqNum Uses

func (m *PeerTime) GetSeqNum() uint64

func (*PeerTime) ProtoMessage Uses

func (*PeerTime) ProtoMessage()

func (*PeerTime) Reset Uses

func (m *PeerTime) Reset()

func (*PeerTime) String Uses

func (m *PeerTime) String() string

func (*PeerTime) XXX_DiscardUnknown Uses

func (m *PeerTime) XXX_DiscardUnknown()

func (*PeerTime) XXX_Marshal Uses

func (m *PeerTime) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PeerTime) XXX_Merge Uses

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

func (*PeerTime) XXX_Size Uses

func (m *PeerTime) XXX_Size() int

func (*PeerTime) XXX_Unmarshal Uses

func (m *PeerTime) XXX_Unmarshal(b []byte) error

type PrivateDataMessage Uses

type PrivateDataMessage struct {
    Payload              *PrivatePayload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
    XXX_NoUnkeyedLiteral struct{}        `json:"-"`
    XXX_unrecognized     []byte          `json:"-"`
    XXX_sizecache        int32           `json:"-"`
}

PrivateDataMessage message which includes private data information to distributed once transaction has been endorsed

func (*PrivateDataMessage) Descriptor Uses

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

func (*PrivateDataMessage) GetPayload Uses

func (m *PrivateDataMessage) GetPayload() *PrivatePayload

func (*PrivateDataMessage) ProtoMessage Uses

func (*PrivateDataMessage) ProtoMessage()

func (*PrivateDataMessage) Reset Uses

func (m *PrivateDataMessage) Reset()

func (*PrivateDataMessage) String Uses

func (m *PrivateDataMessage) String() string

func (*PrivateDataMessage) XXX_DiscardUnknown Uses

func (m *PrivateDataMessage) XXX_DiscardUnknown()

func (*PrivateDataMessage) XXX_Marshal Uses

func (m *PrivateDataMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrivateDataMessage) XXX_Merge Uses

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

func (*PrivateDataMessage) XXX_Size Uses

func (m *PrivateDataMessage) XXX_Size() int

func (*PrivateDataMessage) XXX_Unmarshal Uses

func (m *PrivateDataMessage) XXX_Unmarshal(b []byte) error

type PrivatePayload Uses

type PrivatePayload struct {
    CollectionName       string                          `protobuf:"bytes,1,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
    Namespace            string                          `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
    TxId                 string                          `protobuf:"bytes,3,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"`
    PrivateRwset         []byte                          `protobuf:"bytes,4,opt,name=private_rwset,json=privateRwset,proto3" json:"private_rwset,omitempty"`
    PrivateSimHeight     uint64                          `protobuf:"varint,5,opt,name=private_sim_height,json=privateSimHeight,proto3" json:"private_sim_height,omitempty"`
    CollectionConfigs    *common.CollectionConfigPackage `protobuf:"bytes,6,opt,name=collection_configs,json=collectionConfigs,proto3" json:"collection_configs,omitempty"`
    XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
    XXX_unrecognized     []byte                          `json:"-"`
    XXX_sizecache        int32                           `json:"-"`
}

PrivatePayload payload to encapsulate private data with collection name to enable routing based on collection partitioning

func (*PrivatePayload) Descriptor Uses

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

func (*PrivatePayload) GetCollectionConfigs Uses

func (m *PrivatePayload) GetCollectionConfigs() *common.CollectionConfigPackage

func (*PrivatePayload) GetCollectionName Uses

func (m *PrivatePayload) GetCollectionName() string

func (*PrivatePayload) GetNamespace Uses

func (m *PrivatePayload) GetNamespace() string

func (*PrivatePayload) GetPrivateRwset Uses

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

func (*PrivatePayload) GetPrivateSimHeight Uses

func (m *PrivatePayload) GetPrivateSimHeight() uint64

func (*PrivatePayload) GetTxId Uses

func (m *PrivatePayload) GetTxId() string

func (*PrivatePayload) ProtoMessage Uses

func (*PrivatePayload) ProtoMessage()

func (*PrivatePayload) Reset Uses

func (m *PrivatePayload) Reset()

func (*PrivatePayload) String Uses

func (m *PrivatePayload) String() string

func (*PrivatePayload) XXX_DiscardUnknown Uses

func (m *PrivatePayload) XXX_DiscardUnknown()

func (*PrivatePayload) XXX_Marshal Uses

func (m *PrivatePayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrivatePayload) XXX_Merge Uses

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

func (*PrivatePayload) XXX_Size Uses

func (m *PrivatePayload) XXX_Size() int

func (*PrivatePayload) XXX_Unmarshal Uses

func (m *PrivatePayload) XXX_Unmarshal(b []byte) error

type Properties Uses

type Properties struct {
    LedgerHeight         uint64       `protobuf:"varint,1,opt,name=ledger_height,json=ledgerHeight,proto3" json:"ledger_height,omitempty"`
    LeftChannel          bool         `protobuf:"varint,2,opt,name=left_channel,json=leftChannel,proto3" json:"left_channel,omitempty"`
    Chaincodes           []*Chaincode `protobuf:"bytes,3,rep,name=chaincodes,proto3" json:"chaincodes,omitempty"`
    XXX_NoUnkeyedLiteral struct{}     `json:"-"`
    XXX_unrecognized     []byte       `json:"-"`
    XXX_sizecache        int32        `json:"-"`
}

func (*Properties) Descriptor Uses

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

func (*Properties) GetChaincodes Uses

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

func (*Properties) GetLedgerHeight Uses

func (m *Properties) GetLedgerHeight() uint64

func (*Properties) GetLeftChannel Uses

func (m *Properties) GetLeftChannel() bool

func (*Properties) ProtoMessage Uses

func (*Properties) ProtoMessage()

func (*Properties) Reset Uses

func (m *Properties) Reset()

func (*Properties) String Uses

func (m *Properties) String() string

func (*Properties) XXX_DiscardUnknown Uses

func (m *Properties) XXX_DiscardUnknown()

func (*Properties) XXX_Marshal Uses

func (m *Properties) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Properties) XXX_Merge Uses

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

func (*Properties) XXX_Size Uses

func (m *Properties) XXX_Size() int

func (*Properties) XXX_Unmarshal Uses

func (m *Properties) XXX_Unmarshal(b []byte) error

type PullMsgType Uses

type PullMsgType int32
const (
    PullMsgType_UNDEFINED    PullMsgType = 0
    PullMsgType_BLOCK_MSG    PullMsgType = 1
    PullMsgType_IDENTITY_MSG PullMsgType = 2
)

func (PullMsgType) EnumDescriptor Uses

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

func (PullMsgType) String Uses

func (x PullMsgType) String() string

type PvtDataDigest Uses

type PvtDataDigest struct {
    TxId                 string   `protobuf:"bytes,1,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"`
    Namespace            string   `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
    Collection           string   `protobuf:"bytes,3,opt,name=collection,proto3" json:"collection,omitempty"`
    BlockSeq             uint64   `protobuf:"varint,4,opt,name=block_seq,json=blockSeq,proto3" json:"block_seq,omitempty"`
    SeqInBlock           uint64   `protobuf:"varint,5,opt,name=seq_in_block,json=seqInBlock,proto3" json:"seq_in_block,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

PvtDataDigest defines a digest of private data

func (*PvtDataDigest) Descriptor Uses

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

func (*PvtDataDigest) GetBlockSeq Uses

func (m *PvtDataDigest) GetBlockSeq() uint64

func (*PvtDataDigest) GetCollection Uses

func (m *PvtDataDigest) GetCollection() string

func (*PvtDataDigest) GetNamespace Uses

func (m *PvtDataDigest) GetNamespace() string

func (*PvtDataDigest) GetSeqInBlock Uses

func (m *PvtDataDigest) GetSeqInBlock() uint64

func (*PvtDataDigest) GetTxId Uses

func (m *PvtDataDigest) GetTxId() string

func (*PvtDataDigest) Hash Uses

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

Hash returns the SHA256 representation of the PvtDataDigest's bytes

func (*PvtDataDigest) ProtoMessage Uses

func (*PvtDataDigest) ProtoMessage()

func (*PvtDataDigest) Reset Uses

func (m *PvtDataDigest) Reset()

func (*PvtDataDigest) String Uses

func (m *PvtDataDigest) String() string

func (*PvtDataDigest) XXX_DiscardUnknown Uses

func (m *PvtDataDigest) XXX_DiscardUnknown()

func (*PvtDataDigest) XXX_Marshal Uses

func (m *PvtDataDigest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PvtDataDigest) XXX_Merge Uses

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

func (*PvtDataDigest) XXX_Size Uses

func (m *PvtDataDigest) XXX_Size() int

func (*PvtDataDigest) XXX_Unmarshal Uses

func (m *PvtDataDigest) XXX_Unmarshal(b []byte) error

type PvtDataElement Uses

type PvtDataElement struct {
    Digest *PvtDataDigest `protobuf:"bytes,1,opt,name=digest,proto3" json:"digest,omitempty"`
    // the payload is a marshaled kvrwset.KVRWSet
    Payload              [][]byte `protobuf:"bytes,2,rep,name=payload,proto3" json:"payload,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*PvtDataElement) Descriptor Uses

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

func (*PvtDataElement) GetDigest Uses

func (m *PvtDataElement) GetDigest() *PvtDataDigest

func (*PvtDataElement) GetPayload Uses

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

func (*PvtDataElement) ProtoMessage Uses

func (*PvtDataElement) ProtoMessage()

func (*PvtDataElement) Reset Uses

func (m *PvtDataElement) Reset()

func (*PvtDataElement) String Uses

func (m *PvtDataElement) String() string

func (*PvtDataElement) XXX_DiscardUnknown Uses

func (m *PvtDataElement) XXX_DiscardUnknown()

func (*PvtDataElement) XXX_Marshal Uses

func (m *PvtDataElement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PvtDataElement) XXX_Merge Uses

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

func (*PvtDataElement) XXX_Size Uses

func (m *PvtDataElement) XXX_Size() int

func (*PvtDataElement) XXX_Unmarshal Uses

func (m *PvtDataElement) XXX_Unmarshal(b []byte) error

type PvtDataPayload Uses

type PvtDataPayload struct {
    TxSeqInBlock uint64 `protobuf:"varint,1,opt,name=tx_seq_in_block,json=txSeqInBlock,proto3" json:"tx_seq_in_block,omitempty"`
    // Encodes marhslaed bytes of rwset.TxPvtReadWriteSet
    // defined in rwset.proto
    Payload              []byte   `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

PvtPayload augments private rwset data and tx index inside the block

func (*PvtDataPayload) Descriptor Uses

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

func (*PvtDataPayload) GetPayload Uses

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

func (*PvtDataPayload) GetTxSeqInBlock Uses

func (m *PvtDataPayload) GetTxSeqInBlock() uint64

func (*PvtDataPayload) ProtoMessage Uses

func (*PvtDataPayload) ProtoMessage()

func (*PvtDataPayload) Reset Uses

func (m *PvtDataPayload) Reset()

func (*PvtDataPayload) String Uses

func (m *PvtDataPayload) String() string

func (*PvtDataPayload) XXX_DiscardUnknown Uses

func (m *PvtDataPayload) XXX_DiscardUnknown()

func (*PvtDataPayload) XXX_Marshal Uses

func (m *PvtDataPayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PvtDataPayload) XXX_Merge Uses

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

func (*PvtDataPayload) XXX_Size Uses

func (m *PvtDataPayload) XXX_Size() int

func (*PvtDataPayload) XXX_Unmarshal Uses

func (m *PvtDataPayload) XXX_Unmarshal(b []byte) error

type ReceivedMessage Uses

type ReceivedMessage interface {

    // Respond sends a GossipMessage to the origin from which this ReceivedMessage was sent from
    Respond(msg *GossipMessage)

    // GetGossipMessage returns the underlying GossipMessage
    GetGossipMessage() *SignedGossipMessage

    // GetSourceMessage Returns the Envelope the ReceivedMessage was
    // constructed with
    GetSourceEnvelope() *Envelope

    // GetConnectionInfo returns information about the remote peer
    // that sent the message
    GetConnectionInfo() *ConnectionInfo

    // Ack returns to the sender an acknowledgement for the message
    // An ack can receive an error that indicates that the operation related
    // to the message has failed
    Ack(err error)
}

ReceivedMessage is a GossipMessage wrapper that enables the user to send a message to the origin from which the ReceivedMessage was sent from. It also allows to know the identity of the sender, to obtain the raw bytes the GossipMessage was un-marshaled from, and the signature over these raw bytes.

type RemotePvtDataRequest Uses

type RemotePvtDataRequest struct {
    Digests              []*PvtDataDigest `protobuf:"bytes,1,rep,name=digests,proto3" json:"digests,omitempty"`
    XXX_NoUnkeyedLiteral struct{}         `json:"-"`
    XXX_unrecognized     []byte           `json:"-"`
    XXX_sizecache        int32            `json:"-"`
}

RemotePrivateDataRequest message used to request missing private rwset

func (*RemotePvtDataRequest) Descriptor Uses

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

func (*RemotePvtDataRequest) GetDigests Uses

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

func (*RemotePvtDataRequest) ProtoMessage Uses

func (*RemotePvtDataRequest) ProtoMessage()

func (*RemotePvtDataRequest) Reset Uses

func (m *RemotePvtDataRequest) Reset()

func (*RemotePvtDataRequest) String Uses

func (m *RemotePvtDataRequest) String() string

func (*RemotePvtDataRequest) XXX_DiscardUnknown Uses

func (m *RemotePvtDataRequest) XXX_DiscardUnknown()

func (*RemotePvtDataRequest) XXX_Marshal Uses

func (m *RemotePvtDataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemotePvtDataRequest) XXX_Merge Uses

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

func (*RemotePvtDataRequest) XXX_Size Uses

func (m *RemotePvtDataRequest) XXX_Size() int

func (*RemotePvtDataRequest) XXX_Unmarshal Uses

func (m *RemotePvtDataRequest) XXX_Unmarshal(b []byte) error

type RemotePvtDataResponse Uses

type RemotePvtDataResponse struct {
    Elements             []*PvtDataElement `protobuf:"bytes,1,rep,name=elements,proto3" json:"elements,omitempty"`
    XXX_NoUnkeyedLiteral struct{}          `json:"-"`
    XXX_unrecognized     []byte            `json:"-"`
    XXX_sizecache        int32             `json:"-"`
}

RemotePrivateData message to response on private data replication request

func (*RemotePvtDataResponse) Descriptor Uses

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

func (*RemotePvtDataResponse) GetElements Uses

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

func (*RemotePvtDataResponse) ProtoMessage Uses

func (*RemotePvtDataResponse) ProtoMessage()

func (*RemotePvtDataResponse) Reset Uses

func (m *RemotePvtDataResponse) Reset()

func (*RemotePvtDataResponse) String Uses

func (m *RemotePvtDataResponse) String() string

func (*RemotePvtDataResponse) ToString Uses

func (res *RemotePvtDataResponse) ToString() string

ToString returns a string representation of this RemotePvtDataResponse

func (*RemotePvtDataResponse) XXX_DiscardUnknown Uses

func (m *RemotePvtDataResponse) XXX_DiscardUnknown()

func (*RemotePvtDataResponse) XXX_Marshal Uses

func (m *RemotePvtDataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemotePvtDataResponse) XXX_Merge Uses

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

func (*RemotePvtDataResponse) XXX_Size Uses

func (m *RemotePvtDataResponse) XXX_Size() int

func (*RemotePvtDataResponse) XXX_Unmarshal Uses

func (m *RemotePvtDataResponse) XXX_Unmarshal(b []byte) error

type RemoteStateRequest Uses

type RemoteStateRequest struct {
    StartSeqNum          uint64   `protobuf:"varint,1,opt,name=start_seq_num,json=startSeqNum,proto3" json:"start_seq_num,omitempty"`
    EndSeqNum            uint64   `protobuf:"varint,2,opt,name=end_seq_num,json=endSeqNum,proto3" json:"end_seq_num,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

RemoteStateRequest is used to ask a set of blocks from a remote peer

func (*RemoteStateRequest) Descriptor Uses

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

func (*RemoteStateRequest) GetEndSeqNum Uses

func (m *RemoteStateRequest) GetEndSeqNum() uint64

func (*RemoteStateRequest) GetStartSeqNum Uses

func (m *RemoteStateRequest) GetStartSeqNum() uint64

func (*RemoteStateRequest) ProtoMessage Uses

func (*RemoteStateRequest) ProtoMessage()

func (*RemoteStateRequest) Reset Uses

func (m *RemoteStateRequest) Reset()

func (*RemoteStateRequest) String Uses

func (m *RemoteStateRequest) String() string

func (*RemoteStateRequest) XXX_DiscardUnknown Uses

func (m *RemoteStateRequest) XXX_DiscardUnknown()

func (*RemoteStateRequest) XXX_Marshal Uses

func (m *RemoteStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoteStateRequest) XXX_Merge Uses

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

func (*RemoteStateRequest) XXX_Size Uses

func (m *RemoteStateRequest) XXX_Size() int

func (*RemoteStateRequest) XXX_Unmarshal Uses

func (m *RemoteStateRequest) XXX_Unmarshal(b []byte) error

type RemoteStateResponse Uses

type RemoteStateResponse struct {
    Payloads             []*Payload `protobuf:"bytes,1,rep,name=payloads,proto3" json:"payloads,omitempty"`
    XXX_NoUnkeyedLiteral struct{}   `json:"-"`
    XXX_unrecognized     []byte     `json:"-"`
    XXX_sizecache        int32      `json:"-"`
}

RemoteStateResponse is used to send a set of blocks to a remote peer

func (*RemoteStateResponse) Descriptor Uses

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

func (*RemoteStateResponse) GetPayloads Uses

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

func (*RemoteStateResponse) ProtoMessage Uses

func (*RemoteStateResponse) ProtoMessage()

func (*RemoteStateResponse) Reset Uses

func (m *RemoteStateResponse) Reset()

func (*RemoteStateResponse) String Uses

func (m *RemoteStateResponse) String() string

func (*RemoteStateResponse) XXX_DiscardUnknown Uses

func (m *RemoteStateResponse) XXX_DiscardUnknown()

func (*RemoteStateResponse) XXX_Marshal Uses

func (m *RemoteStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoteStateResponse) XXX_Merge Uses

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

func (*RemoteStateResponse) XXX_Size Uses

func (m *RemoteStateResponse) XXX_Size() int

func (*RemoteStateResponse) XXX_Unmarshal Uses

func (m *RemoteStateResponse) XXX_Unmarshal(b []byte) error

type Secret Uses

type Secret struct {
    // Types that are valid to be assigned to Content:
    //	*Secret_InternalEndpoint
    Content              isSecret_Content `protobuf_oneof:"content"`
    XXX_NoUnkeyedLiteral struct{}         `json:"-"`
    XXX_unrecognized     []byte           `json:"-"`
    XXX_sizecache        int32            `json:"-"`
}

Secret is an entity that might be omitted from an Envelope when the remote peer that is receiving the Envelope shouldn't know the secret's content.

func (*Secret) Descriptor Uses

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

func (*Secret) GetContent Uses

func (m *Secret) GetContent() isSecret_Content

func (*Secret) GetInternalEndpoint Uses

func (m *Secret) GetInternalEndpoint() string

func (*Secret) ProtoMessage Uses

func (*Secret) ProtoMessage()

func (*Secret) Reset Uses

func (m *Secret) Reset()

func (*Secret) String Uses

func (m *Secret) String() string

func (*Secret) XXX_DiscardUnknown Uses

func (m *Secret) XXX_DiscardUnknown()

func (*Secret) XXX_Marshal Uses

func (m *Secret) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Secret) XXX_Merge Uses

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

func (*Secret) XXX_OneofFuncs Uses

func (*Secret) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*Secret) XXX_Size Uses

func (m *Secret) XXX_Size() int

func (*Secret) XXX_Unmarshal Uses

func (m *Secret) XXX_Unmarshal(b []byte) error

type SecretEnvelope Uses

type SecretEnvelope struct {
    Payload              []byte   `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
    Signature            []byte   `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

SecretEnvelope is a marshalled Secret and a signature over it. The signature should be validated by the peer that signed the Envelope the SecretEnvelope came with

func (*SecretEnvelope) Descriptor Uses

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

func (*SecretEnvelope) GetPayload Uses

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

func (*SecretEnvelope) GetSignature Uses

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

func (*SecretEnvelope) InternalEndpoint Uses

func (s *SecretEnvelope) InternalEndpoint() string

InternalEndpoint returns the internal endpoint in the secret envelope, or an empty string if a failure occurs.

func (*SecretEnvelope) ProtoMessage Uses

func (*SecretEnvelope) ProtoMessage()

func (*SecretEnvelope) Reset Uses

func (m *SecretEnvelope) Reset()

func (*SecretEnvelope) String Uses

func (m *SecretEnvelope) String() string

func (*SecretEnvelope) XXX_DiscardUnknown Uses

func (m *SecretEnvelope) XXX_DiscardUnknown()

func (*SecretEnvelope) XXX_Marshal Uses

func (m *SecretEnvelope) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SecretEnvelope) XXX_Merge Uses

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

func (*SecretEnvelope) XXX_Size Uses

func (m *SecretEnvelope) XXX_Size() int

func (*SecretEnvelope) XXX_Unmarshal Uses

func (m *SecretEnvelope) XXX_Unmarshal(b []byte) error

type Secret_InternalEndpoint Uses

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

type SignedGossipMessage Uses

type SignedGossipMessage struct {
    *Envelope
    *GossipMessage
}

SignedGossipMessage contains a GossipMessage and the Envelope from which it came from

func (*SignedGossipMessage) IsSigned Uses

func (m *SignedGossipMessage) IsSigned() bool

IsSigned returns whether the message has a signature in the envelope.

func (*SignedGossipMessage) Sign Uses

func (m *SignedGossipMessage) Sign(signer Signer) (*Envelope, error)

Sign signs a GossipMessage with given Signer. Returns an Envelope on success, panics on failure.

func (*SignedGossipMessage) String Uses

func (m *SignedGossipMessage) String() string

String returns a string representation of a SignedGossipMessage

func (*SignedGossipMessage) Verify Uses

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

Verify verifies a signed GossipMessage with a given Verifier. Returns nil on success, error on failure.

type Signer Uses

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

Signer signs a message, and returns (signature, nil) on success, and nil and an error on failure.

type StateInfo Uses

type StateInfo struct {
    Timestamp *PeerTime `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
    PkiId     []byte    `protobuf:"bytes,3,opt,name=pki_id,json=pkiId,proto3" json:"pki_id,omitempty"`
    // channel_MAC is an authentication code that proves
    // that the peer that sent this message knows
    // the name of the channel.
    Channel_MAC          []byte      `protobuf:"bytes,4,opt,name=channel_MAC,json=channelMAC,proto3" json:"channel_MAC,omitempty"`
    Properties           *Properties `protobuf:"bytes,5,opt,name=properties,proto3" json:"properties,omitempty"`
    XXX_NoUnkeyedLiteral struct{}    `json:"-"`
    XXX_unrecognized     []byte      `json:"-"`
    XXX_sizecache        int32       `json:"-"`
}

StateInfo is used for a peer to relay its state information to other peers

func (*StateInfo) Descriptor Uses

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

func (*StateInfo) GetChannel_MAC Uses

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

func (*StateInfo) GetPkiId Uses

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

func (*StateInfo) GetProperties Uses

func (m *StateInfo) GetProperties() *Properties

func (*StateInfo) GetTimestamp Uses

func (m *StateInfo) GetTimestamp() *PeerTime

func (*StateInfo) LedgerHeight Uses

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

LedgerHeight returns the ledger height that is specified in the StateInfo message

func (*StateInfo) ProtoMessage Uses

func (*StateInfo) ProtoMessage()

func (*StateInfo) Reset Uses

func (m *StateInfo) Reset()

func (*StateInfo) String Uses

func (m *StateInfo) String() string

func (*StateInfo) XXX_DiscardUnknown Uses

func (m *StateInfo) XXX_DiscardUnknown()

func (*StateInfo) XXX_Marshal Uses

func (m *StateInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StateInfo) XXX_Merge Uses

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

func (*StateInfo) XXX_Size Uses

func (m *StateInfo) XXX_Size() int

func (*StateInfo) XXX_Unmarshal Uses

func (m *StateInfo) XXX_Unmarshal(b []byte) error

type StateInfoPullRequest Uses

type StateInfoPullRequest struct {
    // channel_MAC is an authentication code that proves
    // that the peer that sent this message knows
    // the name of the channel.
    Channel_MAC          []byte   `protobuf:"bytes,1,opt,name=channel_MAC,json=channelMAC,proto3" json:"channel_MAC,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

StateInfoPullRequest is used to fetch a StateInfoSnapshot from a remote peer

func (*StateInfoPullRequest) Descriptor Uses

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

func (*StateInfoPullRequest) GetChannel_MAC Uses

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

func (*StateInfoPullRequest) ProtoMessage Uses

func (*StateInfoPullRequest) ProtoMessage()

func (*StateInfoPullRequest) Reset Uses

func (m *StateInfoPullRequest) Reset()

func (*StateInfoPullRequest) String Uses

func (m *StateInfoPullRequest) String() string

func (*StateInfoPullRequest) XXX_DiscardUnknown Uses

func (m *StateInfoPullRequest) XXX_DiscardUnknown()

func (*StateInfoPullRequest) XXX_Marshal Uses

func (m *StateInfoPullRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StateInfoPullRequest) XXX_Merge Uses

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

func (*StateInfoPullRequest) XXX_Size Uses

func (m *StateInfoPullRequest) XXX_Size() int

func (*StateInfoPullRequest) XXX_Unmarshal Uses

func (m *StateInfoPullRequest) XXX_Unmarshal(b []byte) error

type StateInfoSnapshot Uses

type StateInfoSnapshot struct {
    Elements             []*Envelope `protobuf:"bytes,1,rep,name=elements,proto3" json:"elements,omitempty"`
    XXX_NoUnkeyedLiteral struct{}    `json:"-"`
    XXX_unrecognized     []byte      `json:"-"`
    XXX_sizecache        int32       `json:"-"`
}

StateInfoSnapshot is an aggregation of StateInfo messages

func (*StateInfoSnapshot) Descriptor Uses

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

func (*StateInfoSnapshot) GetElements Uses

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

func (*StateInfoSnapshot) ProtoMessage Uses

func (*StateInfoSnapshot) ProtoMessage()

func (*StateInfoSnapshot) Reset Uses

func (m *StateInfoSnapshot) Reset()

func (*StateInfoSnapshot) String Uses

func (m *StateInfoSnapshot) String() string

func (*StateInfoSnapshot) XXX_DiscardUnknown Uses

func (m *StateInfoSnapshot) XXX_DiscardUnknown()

func (*StateInfoSnapshot) XXX_Marshal Uses

func (m *StateInfoSnapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StateInfoSnapshot) XXX_Merge Uses

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

func (*StateInfoSnapshot) XXX_Size Uses

func (m *StateInfoSnapshot) XXX_Size() int

func (*StateInfoSnapshot) XXX_Unmarshal Uses

func (m *StateInfoSnapshot) XXX_Unmarshal(b []byte) error

type Verifier Uses

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

Verifier receives a peer identity, a signature and a message and returns nil if the signature on the message could be verified using the given identity.

Package gossip imports 12 packages (graph) and is imported by 30 packages. Updated 2019-08-13. Refresh now. Tools for package owners.