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

package gossip

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

Index

Package Files

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 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 (m *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 (m *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 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 (m *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 (m *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 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) 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 (m *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 (m *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) 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 (m *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 (m *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 (m *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) String Uses

func (m *Envelope) String() string

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 (m *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 (m *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) 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) 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 (m *GossipMessage) XXX_Merge(src proto.Message)

func (*GossipMessage) XXX_OneofWrappers Uses

func (*GossipMessage) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers 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 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 (m *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 (m *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 (m *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 (m *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 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 (m *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 (m *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 (m *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 (m *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    *peer.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() *peer.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 (m *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 (m *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) 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 (m *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 (m *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 (m *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 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 (m *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) 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 (m *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 (m *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 (m *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 (m *Secret) XXX_Merge(src proto.Message)

func (*Secret) XXX_OneofWrappers Uses

func (*Secret) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers 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) 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 (m *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 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) 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 (m *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 (m *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 (m *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 UnimplementedGossipServer Uses

type UnimplementedGossipServer struct {
}

UnimplementedGossipServer can be embedded to have forward compatible implementations.

func (*UnimplementedGossipServer) GossipStream Uses

func (*UnimplementedGossipServer) GossipStream(srv Gossip_GossipStreamServer) error

func (*UnimplementedGossipServer) Ping Uses

func (*UnimplementedGossipServer) Ping(ctx context.Context, req *Empty) (*Empty, error)

Package gossip imports 8 packages (graph) and is imported by 20 packages. Updated 2019-11-25. Refresh now. Tools for package owners.