gossip

package
v0.3.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 21, 2023 License: Apache-2.0 Imports: 9 Imported by: 1

Documentation

Index

Constants

View Source
const (
	Gossip_GossipStream_FullMethodName = "/gossip.Gossip/GossipStream"
	Gossip_Ping_FullMethodName         = "/gossip.Gossip/Ping"
)

Variables

View Source
var (
	PullMsgType_name = map[int32]string{
		0: "UNDEFINED",
		1: "BLOCK_MSG",
		2: "IDENTITY_MSG",
	}
	PullMsgType_value = map[string]int32{
		"UNDEFINED":    0,
		"BLOCK_MSG":    1,
		"IDENTITY_MSG": 2,
	}
)

Enum value maps for PullMsgType.

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

Enum value maps for GossipMessage_Tag.

View Source
var File_gossip_message_proto protoreflect.FileDescriptor
View Source
var Gossip_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gossip.Gossip",
	HandlerType: (*GossipServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Ping",
			Handler:    _Gossip_Ping_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GossipStream",
			Handler:       _Gossip_GossipStream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "gossip/message.proto",
}

Gossip_ServiceDesc is the grpc.ServiceDesc for Gossip service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterGossipServer

func RegisterGossipServer(s grpc.ServiceRegistrar, srv GossipServer)

Types

type Acknowledgement

type Acknowledgement struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*Acknowledgement) Descriptor deprecated

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

Deprecated: Use Acknowledgement.ProtoReflect.Descriptor instead.

func (*Acknowledgement) GetError

func (x *Acknowledgement) GetError() string

func (*Acknowledgement) ProtoMessage

func (*Acknowledgement) ProtoMessage()

func (*Acknowledgement) ProtoReflect

func (x *Acknowledgement) ProtoReflect() protoreflect.Message

func (*Acknowledgement) Reset

func (x *Acknowledgement) Reset()

func (*Acknowledgement) String

func (x *Acknowledgement) String() string

type AliveMessage

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"`
	// contains filtered or unexported fields
}

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

func (*AliveMessage) Descriptor deprecated

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

Deprecated: Use AliveMessage.ProtoReflect.Descriptor instead.

func (*AliveMessage) GetIdentity

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

func (*AliveMessage) GetMembership

func (x *AliveMessage) GetMembership() *Member

func (*AliveMessage) GetTimestamp

func (x *AliveMessage) GetTimestamp() *PeerTime

func (*AliveMessage) ProtoMessage

func (*AliveMessage) ProtoMessage()

func (*AliveMessage) ProtoReflect

func (x *AliveMessage) ProtoReflect() protoreflect.Message

func (*AliveMessage) Reset

func (x *AliveMessage) Reset()

func (*AliveMessage) String

func (x *AliveMessage) String() string

type Chaincode

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"`
	// contains filtered or unexported fields
}

Chaincode represents a Chaincode that is installed on a peer

func (*Chaincode) Descriptor deprecated

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

Deprecated: Use Chaincode.ProtoReflect.Descriptor instead.

func (*Chaincode) GetMetadata

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

func (*Chaincode) GetName

func (x *Chaincode) GetName() string

func (*Chaincode) GetVersion

func (x *Chaincode) GetVersion() string

func (*Chaincode) ProtoMessage

func (*Chaincode) ProtoMessage()

func (*Chaincode) ProtoReflect

func (x *Chaincode) ProtoReflect() protoreflect.Message

func (*Chaincode) Reset

func (x *Chaincode) Reset()

func (*Chaincode) String

func (x *Chaincode) String() string

type ConnEstablish

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"`
	Probe       bool   `protobuf:"varint,4,opt,name=probe,proto3" json:"probe,omitempty"`
	// contains filtered or unexported fields
}

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 deprecated

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

Deprecated: Use ConnEstablish.ProtoReflect.Descriptor instead.

func (*ConnEstablish) GetIdentity

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

func (*ConnEstablish) GetPkiId

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

func (*ConnEstablish) GetProbe

func (x *ConnEstablish) GetProbe() bool

func (*ConnEstablish) GetTlsCertHash

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

func (*ConnEstablish) ProtoMessage

func (*ConnEstablish) ProtoMessage()

func (*ConnEstablish) ProtoReflect

func (x *ConnEstablish) ProtoReflect() protoreflect.Message

func (*ConnEstablish) Reset

func (x *ConnEstablish) Reset()

func (*ConnEstablish) String

func (x *ConnEstablish) String() string

type DataDigest

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"` // Maybe change this to bitmap later on
	MsgType PullMsgType `protobuf:"varint,3,opt,name=msg_type,json=msgType,proto3,enum=gossip.PullMsgType" json:"msg_type,omitempty"`
	// contains filtered or unexported fields
}

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

func (*DataDigest) Descriptor deprecated

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

Deprecated: Use DataDigest.ProtoReflect.Descriptor instead.

func (*DataDigest) GetDigests

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

func (*DataDigest) GetMsgType

func (x *DataDigest) GetMsgType() PullMsgType

func (*DataDigest) GetNonce

func (x *DataDigest) GetNonce() uint64

func (*DataDigest) ProtoMessage

func (*DataDigest) ProtoMessage()

func (*DataDigest) ProtoReflect

func (x *DataDigest) ProtoReflect() protoreflect.Message

func (*DataDigest) Reset

func (x *DataDigest) Reset()

func (*DataDigest) String

func (x *DataDigest) String() string

type DataMessage

type DataMessage struct {
	Payload *Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

DataMessage is the message that contains a block

func (*DataMessage) Descriptor deprecated

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

Deprecated: Use DataMessage.ProtoReflect.Descriptor instead.

func (*DataMessage) GetPayload

func (x *DataMessage) GetPayload() *Payload

func (*DataMessage) ProtoMessage

func (*DataMessage) ProtoMessage()

func (*DataMessage) ProtoReflect

func (x *DataMessage) ProtoReflect() protoreflect.Message

func (*DataMessage) Reset

func (x *DataMessage) Reset()

func (*DataMessage) String

func (x *DataMessage) String() string

type DataRequest

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"`
	// contains filtered or unexported fields
}

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

func (*DataRequest) Descriptor deprecated

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

Deprecated: Use DataRequest.ProtoReflect.Descriptor instead.

func (*DataRequest) GetDigests

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

func (*DataRequest) GetMsgType

func (x *DataRequest) GetMsgType() PullMsgType

func (*DataRequest) GetNonce

func (x *DataRequest) GetNonce() uint64

func (*DataRequest) ProtoMessage

func (*DataRequest) ProtoMessage()

func (*DataRequest) ProtoReflect

func (x *DataRequest) ProtoReflect() protoreflect.Message

func (*DataRequest) Reset

func (x *DataRequest) Reset()

func (*DataRequest) String

func (x *DataRequest) String() string

type DataUpdate

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"`
	// contains filtered or unexported fields
}

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

func (*DataUpdate) Descriptor deprecated

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

Deprecated: Use DataUpdate.ProtoReflect.Descriptor instead.

func (*DataUpdate) GetData

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

func (*DataUpdate) GetMsgType

func (x *DataUpdate) GetMsgType() PullMsgType

func (*DataUpdate) GetNonce

func (x *DataUpdate) GetNonce() uint64

func (*DataUpdate) ProtoMessage

func (*DataUpdate) ProtoMessage()

func (*DataUpdate) ProtoReflect

func (x *DataUpdate) ProtoReflect() protoreflect.Message

func (*DataUpdate) Reset

func (x *DataUpdate) Reset()

func (*DataUpdate) String

func (x *DataUpdate) String() string

type Empty

type Empty struct {
	// contains filtered or unexported fields
}

Empty is used for pinging and in tests

func (*Empty) Descriptor deprecated

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect

func (x *Empty) ProtoReflect() protoreflect.Message

func (*Empty) Reset

func (x *Empty) Reset()

func (*Empty) String

func (x *Empty) String() string

type Envelope

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"`
	// contains filtered or unexported fields
}

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

func (*Envelope) Descriptor deprecated

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

Deprecated: Use Envelope.ProtoReflect.Descriptor instead.

func (*Envelope) GetPayload

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

func (*Envelope) GetSecretEnvelope

func (x *Envelope) GetSecretEnvelope() *SecretEnvelope

func (*Envelope) GetSignature

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

func (*Envelope) ProtoMessage

func (*Envelope) ProtoMessage()

func (*Envelope) ProtoReflect

func (x *Envelope) ProtoReflect() protoreflect.Message

func (*Envelope) Reset

func (x *Envelope) Reset()

func (*Envelope) String

func (x *Envelope) String() string

type GossipClient

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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewGossipClient

func NewGossipClient(cc grpc.ClientConnInterface) GossipClient

type GossipHello

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"`
	// contains filtered or unexported fields
}

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

func (*GossipHello) Descriptor deprecated

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

Deprecated: Use GossipHello.ProtoReflect.Descriptor instead.

func (*GossipHello) GetMetadata

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

func (*GossipHello) GetMsgType

func (x *GossipHello) GetMsgType() PullMsgType

func (*GossipHello) GetNonce

func (x *GossipHello) GetNonce() uint64

func (*GossipHello) ProtoMessage

func (*GossipHello) ProtoMessage()

func (*GossipHello) ProtoReflect

func (x *GossipHello) ProtoReflect() protoreflect.Message

func (*GossipHello) Reset

func (x *GossipHello) Reset()

func (*GossipHello) String

func (x *GossipHello) String() string

type GossipMessage

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 assignable 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"`
	// contains filtered or unexported fields
}

GossipMessage defines the message sent in a gossip network

func (*GossipMessage) Descriptor deprecated

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

Deprecated: Use GossipMessage.ProtoReflect.Descriptor instead.

func (*GossipMessage) GetAck

func (x *GossipMessage) GetAck() *Acknowledgement

func (*GossipMessage) GetAliveMsg

func (x *GossipMessage) GetAliveMsg() *AliveMessage

func (*GossipMessage) GetChannel

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

func (*GossipMessage) GetConn

func (x *GossipMessage) GetConn() *ConnEstablish

func (*GossipMessage) GetContent

func (m *GossipMessage) GetContent() isGossipMessage_Content

func (*GossipMessage) GetDataDig

func (x *GossipMessage) GetDataDig() *DataDigest

func (*GossipMessage) GetDataMsg

func (x *GossipMessage) GetDataMsg() *DataMessage

func (*GossipMessage) GetDataReq

func (x *GossipMessage) GetDataReq() *DataRequest

func (*GossipMessage) GetDataUpdate

func (x *GossipMessage) GetDataUpdate() *DataUpdate

func (*GossipMessage) GetEmpty

func (x *GossipMessage) GetEmpty() *Empty

func (*GossipMessage) GetHello

func (x *GossipMessage) GetHello() *GossipHello

func (*GossipMessage) GetLeadershipMsg

func (x *GossipMessage) GetLeadershipMsg() *LeadershipMessage

func (*GossipMessage) GetMemReq

func (x *GossipMessage) GetMemReq() *MembershipRequest

func (*GossipMessage) GetMemRes

func (x *GossipMessage) GetMemRes() *MembershipResponse

func (*GossipMessage) GetNonce

func (x *GossipMessage) GetNonce() uint64

func (*GossipMessage) GetPeerIdentity

func (x *GossipMessage) GetPeerIdentity() *PeerIdentity

func (*GossipMessage) GetPrivateData

func (x *GossipMessage) GetPrivateData() *PrivateDataMessage

func (*GossipMessage) GetPrivateReq

func (x *GossipMessage) GetPrivateReq() *RemotePvtDataRequest

func (*GossipMessage) GetPrivateRes

func (x *GossipMessage) GetPrivateRes() *RemotePvtDataResponse

func (*GossipMessage) GetStateInfo

func (x *GossipMessage) GetStateInfo() *StateInfo

func (*GossipMessage) GetStateInfoPullReq

func (x *GossipMessage) GetStateInfoPullReq() *StateInfoPullRequest

func (*GossipMessage) GetStateRequest

func (x *GossipMessage) GetStateRequest() *RemoteStateRequest

func (*GossipMessage) GetStateResponse

func (x *GossipMessage) GetStateResponse() *RemoteStateResponse

func (*GossipMessage) GetStateSnapshot

func (x *GossipMessage) GetStateSnapshot() *StateInfoSnapshot

func (*GossipMessage) GetTag

func (x *GossipMessage) GetTag() GossipMessage_Tag

func (*GossipMessage) ProtoMessage

func (*GossipMessage) ProtoMessage()

func (*GossipMessage) ProtoReflect

func (x *GossipMessage) ProtoReflect() protoreflect.Message

func (*GossipMessage) Reset

func (x *GossipMessage) Reset()

func (*GossipMessage) String

func (x *GossipMessage) String() string

type GossipMessage_Ack

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

type GossipMessage_AliveMsg

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

type GossipMessage_Conn

type GossipMessage_Conn struct {
	// ConnEstablish, used for establishing a connection
	Conn *ConnEstablish `protobuf:"bytes,14,opt,name=conn,proto3,oneof"`
}

type GossipMessage_DataDig

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

type GossipMessage_DataMsg

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

type GossipMessage_DataReq

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

type GossipMessage_DataUpdate

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

type GossipMessage_Empty

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

type GossipMessage_Hello

type GossipMessage_Hello struct {
	// Used for push&pull
	Hello *GossipHello `protobuf:"bytes,9,opt,name=hello,proto3,oneof"`
}

type GossipMessage_LeadershipMsg

type GossipMessage_LeadershipMsg struct {
	// Used to indicate intent of peer to become leader
	LeadershipMsg *LeadershipMessage `protobuf:"bytes,20,opt,name=leadership_msg,json=leadershipMsg,proto3,oneof"`
}

type GossipMessage_MemReq

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

type GossipMessage_MemRes

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

type GossipMessage_PeerIdentity

type GossipMessage_PeerIdentity struct {
	// Used to learn of a peer's certificate
	PeerIdentity *PeerIdentity `protobuf:"bytes,21,opt,name=peer_identity,json=peerIdentity,proto3,oneof"`
}

type GossipMessage_PrivateData

type GossipMessage_PrivateData struct {
	// Encapsulates private data used to distribute
	// private rwset after the endorsement
	PrivateData *PrivateDataMessage `protobuf:"bytes,25,opt,name=private_data,json=privateData,proto3,oneof"`
}

type GossipMessage_PrivateReq

type GossipMessage_PrivateReq struct {
	// Used to request private data
	PrivateReq *RemotePvtDataRequest `protobuf:"bytes,23,opt,name=privateReq,proto3,oneof"`
}

type GossipMessage_PrivateRes

type GossipMessage_PrivateRes struct {
	// Used to respond to private data requests
	PrivateRes *RemotePvtDataResponse `protobuf:"bytes,24,opt,name=privateRes,proto3,oneof"`
}

type GossipMessage_StateInfo

type GossipMessage_StateInfo struct {
	// Used for relaying information
	// about state
	StateInfo *StateInfo `protobuf:"bytes,15,opt,name=state_info,json=stateInfo,proto3,oneof"`
}

type GossipMessage_StateInfoPullReq

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

type GossipMessage_StateRequest

type GossipMessage_StateRequest struct {
	// Used to ask from a remote peer a set of blocks
	StateRequest *RemoteStateRequest `protobuf:"bytes,18,opt,name=state_request,json=stateRequest,proto3,oneof"`
}

type GossipMessage_StateResponse

type GossipMessage_StateResponse struct {
	// Used to send a set of blocks to a remote peer
	StateResponse *RemoteStateResponse `protobuf:"bytes,19,opt,name=state_response,json=stateResponse,proto3,oneof"`
}

type GossipMessage_StateSnapshot

type GossipMessage_StateSnapshot struct {
	// Used for sending sets of StateInfo messages
	StateSnapshot *StateInfoSnapshot `protobuf:"bytes,16,opt,name=state_snapshot,json=stateSnapshot,proto3,oneof"`
}

type GossipMessage_Tag

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

func (GossipMessage_Tag) Enum

func (GossipMessage_Tag) EnumDescriptor deprecated

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

Deprecated: Use GossipMessage_Tag.Descriptor instead.

func (GossipMessage_Tag) Number

func (GossipMessage_Tag) String

func (x GossipMessage_Tag) String() string

func (GossipMessage_Tag) Type

type GossipServer

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. All implementations should embed UnimplementedGossipServer for forward compatibility

type Gossip_GossipStreamClient

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

type Gossip_GossipStreamServer

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

type LeadershipMessage

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"`
	// contains filtered or unexported fields
}

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

func (*LeadershipMessage) Descriptor deprecated

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

Deprecated: Use LeadershipMessage.ProtoReflect.Descriptor instead.

func (*LeadershipMessage) GetIsDeclaration

func (x *LeadershipMessage) GetIsDeclaration() bool

func (*LeadershipMessage) GetPkiId

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

func (*LeadershipMessage) GetTimestamp

func (x *LeadershipMessage) GetTimestamp() *PeerTime

func (*LeadershipMessage) ProtoMessage

func (*LeadershipMessage) ProtoMessage()

func (*LeadershipMessage) ProtoReflect

func (x *LeadershipMessage) ProtoReflect() protoreflect.Message

func (*LeadershipMessage) Reset

func (x *LeadershipMessage) Reset()

func (*LeadershipMessage) String

func (x *LeadershipMessage) String() string

type Member

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"`
	// contains filtered or unexported fields
}

Member holds membership-related information about a peer

func (*Member) Descriptor deprecated

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

Deprecated: Use Member.ProtoReflect.Descriptor instead.

func (*Member) GetEndpoint

func (x *Member) GetEndpoint() string

func (*Member) GetMetadata

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

func (*Member) GetPkiId

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

func (*Member) ProtoMessage

func (*Member) ProtoMessage()

func (*Member) ProtoReflect

func (x *Member) ProtoReflect() protoreflect.Message

func (*Member) Reset

func (x *Member) Reset()

func (*Member) String

func (x *Member) String() string

type MembershipRequest

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"`
	// contains filtered or unexported fields
}

MembershipRequest is used to ask membership information from a remote peer

func (*MembershipRequest) Descriptor deprecated

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

Deprecated: Use MembershipRequest.ProtoReflect.Descriptor instead.

func (*MembershipRequest) GetKnown

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

func (*MembershipRequest) GetSelfInformation

func (x *MembershipRequest) GetSelfInformation() *Envelope

func (*MembershipRequest) ProtoMessage

func (*MembershipRequest) ProtoMessage()

func (*MembershipRequest) ProtoReflect

func (x *MembershipRequest) ProtoReflect() protoreflect.Message

func (*MembershipRequest) Reset

func (x *MembershipRequest) Reset()

func (*MembershipRequest) String

func (x *MembershipRequest) String() string

type MembershipResponse

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"`
	// contains filtered or unexported fields
}

MembershipResponse is used for replying to MembershipRequests

func (*MembershipResponse) Descriptor deprecated

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

Deprecated: Use MembershipResponse.ProtoReflect.Descriptor instead.

func (*MembershipResponse) GetAlive

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

func (*MembershipResponse) GetDead

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

func (*MembershipResponse) ProtoMessage

func (*MembershipResponse) ProtoMessage()

func (*MembershipResponse) ProtoReflect

func (x *MembershipResponse) ProtoReflect() protoreflect.Message

func (*MembershipResponse) Reset

func (x *MembershipResponse) Reset()

func (*MembershipResponse) String

func (x *MembershipResponse) String() string

type Payload

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"`
	// contains filtered or unexported fields
}

Payload contains a block

func (*Payload) Descriptor deprecated

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

Deprecated: Use Payload.ProtoReflect.Descriptor instead.

func (*Payload) GetData

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

func (*Payload) GetPrivateData

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

func (*Payload) GetSeqNum

func (x *Payload) GetSeqNum() uint64

func (*Payload) ProtoMessage

func (*Payload) ProtoMessage()

func (*Payload) ProtoReflect

func (x *Payload) ProtoReflect() protoreflect.Message

func (*Payload) Reset

func (x *Payload) Reset()

func (*Payload) String

func (x *Payload) String() string

type PeerIdentity

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"`
	// contains filtered or unexported fields
}

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

func (*PeerIdentity) Descriptor deprecated

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

Deprecated: Use PeerIdentity.ProtoReflect.Descriptor instead.

func (*PeerIdentity) GetCert

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

func (*PeerIdentity) GetMetadata

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

func (*PeerIdentity) GetPkiId

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

func (*PeerIdentity) ProtoMessage

func (*PeerIdentity) ProtoMessage()

func (*PeerIdentity) ProtoReflect

func (x *PeerIdentity) ProtoReflect() protoreflect.Message

func (*PeerIdentity) Reset

func (x *PeerIdentity) Reset()

func (*PeerIdentity) String

func (x *PeerIdentity) String() string

type PeerTime

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"`
	// contains filtered or unexported fields
}

PeerTime defines the logical time of a peer's life

func (*PeerTime) Descriptor deprecated

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

Deprecated: Use PeerTime.ProtoReflect.Descriptor instead.

func (*PeerTime) GetIncNum

func (x *PeerTime) GetIncNum() uint64

func (*PeerTime) GetSeqNum

func (x *PeerTime) GetSeqNum() uint64

func (*PeerTime) ProtoMessage

func (*PeerTime) ProtoMessage()

func (*PeerTime) ProtoReflect

func (x *PeerTime) ProtoReflect() protoreflect.Message

func (*PeerTime) Reset

func (x *PeerTime) Reset()

func (*PeerTime) String

func (x *PeerTime) String() string

type PrivateDataMessage

type PrivateDataMessage struct {
	Payload *PrivatePayload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

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

func (*PrivateDataMessage) Descriptor deprecated

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

Deprecated: Use PrivateDataMessage.ProtoReflect.Descriptor instead.

func (*PrivateDataMessage) GetPayload

func (x *PrivateDataMessage) GetPayload() *PrivatePayload

func (*PrivateDataMessage) ProtoMessage

func (*PrivateDataMessage) ProtoMessage()

func (*PrivateDataMessage) ProtoReflect

func (x *PrivateDataMessage) ProtoReflect() protoreflect.Message

func (*PrivateDataMessage) Reset

func (x *PrivateDataMessage) Reset()

func (*PrivateDataMessage) String

func (x *PrivateDataMessage) String() string

type PrivatePayload

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"`
	// contains filtered or unexported fields
}

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

func (*PrivatePayload) Descriptor deprecated

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

Deprecated: Use PrivatePayload.ProtoReflect.Descriptor instead.

func (*PrivatePayload) GetCollectionConfigs

func (x *PrivatePayload) GetCollectionConfigs() *peer.CollectionConfigPackage

func (*PrivatePayload) GetCollectionName

func (x *PrivatePayload) GetCollectionName() string

func (*PrivatePayload) GetNamespace

func (x *PrivatePayload) GetNamespace() string

func (*PrivatePayload) GetPrivateRwset

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

func (*PrivatePayload) GetPrivateSimHeight

func (x *PrivatePayload) GetPrivateSimHeight() uint64

func (*PrivatePayload) GetTxId

func (x *PrivatePayload) GetTxId() string

func (*PrivatePayload) ProtoMessage

func (*PrivatePayload) ProtoMessage()

func (*PrivatePayload) ProtoReflect

func (x *PrivatePayload) ProtoReflect() protoreflect.Message

func (*PrivatePayload) Reset

func (x *PrivatePayload) Reset()

func (*PrivatePayload) String

func (x *PrivatePayload) String() string

type Properties

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"`
	// contains filtered or unexported fields
}

func (*Properties) Descriptor deprecated

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

Deprecated: Use Properties.ProtoReflect.Descriptor instead.

func (*Properties) GetChaincodes

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

func (*Properties) GetLedgerHeight

func (x *Properties) GetLedgerHeight() uint64

func (*Properties) GetLeftChannel

func (x *Properties) GetLeftChannel() bool

func (*Properties) ProtoMessage

func (*Properties) ProtoMessage()

func (*Properties) ProtoReflect

func (x *Properties) ProtoReflect() protoreflect.Message

func (*Properties) Reset

func (x *Properties) Reset()

func (*Properties) String

func (x *Properties) String() string

type PullMsgType

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

func (PullMsgType) Descriptor

func (PullMsgType) Enum

func (x PullMsgType) Enum() *PullMsgType

func (PullMsgType) EnumDescriptor deprecated

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

Deprecated: Use PullMsgType.Descriptor instead.

func (PullMsgType) Number

func (x PullMsgType) Number() protoreflect.EnumNumber

func (PullMsgType) String

func (x PullMsgType) String() string

func (PullMsgType) Type

type PvtDataDigest

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"`
	// contains filtered or unexported fields
}

PvtDataDigest defines a digest of private data

func (*PvtDataDigest) Descriptor deprecated

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

Deprecated: Use PvtDataDigest.ProtoReflect.Descriptor instead.

func (*PvtDataDigest) GetBlockSeq

func (x *PvtDataDigest) GetBlockSeq() uint64

func (*PvtDataDigest) GetCollection

func (x *PvtDataDigest) GetCollection() string

func (*PvtDataDigest) GetNamespace

func (x *PvtDataDigest) GetNamespace() string

func (*PvtDataDigest) GetSeqInBlock

func (x *PvtDataDigest) GetSeqInBlock() uint64

func (*PvtDataDigest) GetTxId

func (x *PvtDataDigest) GetTxId() string

func (*PvtDataDigest) ProtoMessage

func (*PvtDataDigest) ProtoMessage()

func (*PvtDataDigest) ProtoReflect

func (x *PvtDataDigest) ProtoReflect() protoreflect.Message

func (*PvtDataDigest) Reset

func (x *PvtDataDigest) Reset()

func (*PvtDataDigest) String

func (x *PvtDataDigest) String() string

type PvtDataElement

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"`
	// contains filtered or unexported fields
}

func (*PvtDataElement) Descriptor deprecated

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

Deprecated: Use PvtDataElement.ProtoReflect.Descriptor instead.

func (*PvtDataElement) GetDigest

func (x *PvtDataElement) GetDigest() *PvtDataDigest

func (*PvtDataElement) GetPayload

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

func (*PvtDataElement) ProtoMessage

func (*PvtDataElement) ProtoMessage()

func (*PvtDataElement) ProtoReflect

func (x *PvtDataElement) ProtoReflect() protoreflect.Message

func (*PvtDataElement) Reset

func (x *PvtDataElement) Reset()

func (*PvtDataElement) String

func (x *PvtDataElement) String() string

type PvtDataPayload

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"`
	// contains filtered or unexported fields
}

PvtPayload augments private rwset data and tx index inside the block

func (*PvtDataPayload) Descriptor deprecated

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

Deprecated: Use PvtDataPayload.ProtoReflect.Descriptor instead.

func (*PvtDataPayload) GetPayload

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

func (*PvtDataPayload) GetTxSeqInBlock

func (x *PvtDataPayload) GetTxSeqInBlock() uint64

func (*PvtDataPayload) ProtoMessage

func (*PvtDataPayload) ProtoMessage()

func (*PvtDataPayload) ProtoReflect

func (x *PvtDataPayload) ProtoReflect() protoreflect.Message

func (*PvtDataPayload) Reset

func (x *PvtDataPayload) Reset()

func (*PvtDataPayload) String

func (x *PvtDataPayload) String() string

type RemotePvtDataRequest

type RemotePvtDataRequest struct {
	Digests []*PvtDataDigest `protobuf:"bytes,1,rep,name=digests,proto3" json:"digests,omitempty"`
	// contains filtered or unexported fields
}

RemotePrivateDataRequest message used to request missing private rwset

func (*RemotePvtDataRequest) Descriptor deprecated

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

Deprecated: Use RemotePvtDataRequest.ProtoReflect.Descriptor instead.

func (*RemotePvtDataRequest) GetDigests

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

func (*RemotePvtDataRequest) ProtoMessage

func (*RemotePvtDataRequest) ProtoMessage()

func (*RemotePvtDataRequest) ProtoReflect

func (x *RemotePvtDataRequest) ProtoReflect() protoreflect.Message

func (*RemotePvtDataRequest) Reset

func (x *RemotePvtDataRequest) Reset()

func (*RemotePvtDataRequest) String

func (x *RemotePvtDataRequest) String() string

type RemotePvtDataResponse

type RemotePvtDataResponse struct {
	Elements []*PvtDataElement `protobuf:"bytes,1,rep,name=elements,proto3" json:"elements,omitempty"`
	// contains filtered or unexported fields
}

RemotePrivateData message to response on private data replication request

func (*RemotePvtDataResponse) Descriptor deprecated

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

Deprecated: Use RemotePvtDataResponse.ProtoReflect.Descriptor instead.

func (*RemotePvtDataResponse) GetElements

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

func (*RemotePvtDataResponse) ProtoMessage

func (*RemotePvtDataResponse) ProtoMessage()

func (*RemotePvtDataResponse) ProtoReflect

func (x *RemotePvtDataResponse) ProtoReflect() protoreflect.Message

func (*RemotePvtDataResponse) Reset

func (x *RemotePvtDataResponse) Reset()

func (*RemotePvtDataResponse) String

func (x *RemotePvtDataResponse) String() string

type RemoteStateRequest

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"`
	// contains filtered or unexported fields
}

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

func (*RemoteStateRequest) Descriptor deprecated

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

Deprecated: Use RemoteStateRequest.ProtoReflect.Descriptor instead.

func (*RemoteStateRequest) GetEndSeqNum

func (x *RemoteStateRequest) GetEndSeqNum() uint64

func (*RemoteStateRequest) GetStartSeqNum

func (x *RemoteStateRequest) GetStartSeqNum() uint64

func (*RemoteStateRequest) ProtoMessage

func (*RemoteStateRequest) ProtoMessage()

func (*RemoteStateRequest) ProtoReflect

func (x *RemoteStateRequest) ProtoReflect() protoreflect.Message

func (*RemoteStateRequest) Reset

func (x *RemoteStateRequest) Reset()

func (*RemoteStateRequest) String

func (x *RemoteStateRequest) String() string

type RemoteStateResponse

type RemoteStateResponse struct {
	Payloads []*Payload `protobuf:"bytes,1,rep,name=payloads,proto3" json:"payloads,omitempty"`
	// contains filtered or unexported fields
}

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

func (*RemoteStateResponse) Descriptor deprecated

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

Deprecated: Use RemoteStateResponse.ProtoReflect.Descriptor instead.

func (*RemoteStateResponse) GetPayloads

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

func (*RemoteStateResponse) ProtoMessage

func (*RemoteStateResponse) ProtoMessage()

func (*RemoteStateResponse) ProtoReflect

func (x *RemoteStateResponse) ProtoReflect() protoreflect.Message

func (*RemoteStateResponse) Reset

func (x *RemoteStateResponse) Reset()

func (*RemoteStateResponse) String

func (x *RemoteStateResponse) String() string

type Secret

type Secret struct {

	// Types that are assignable to Content:
	//
	//	*Secret_InternalEndpoint
	Content isSecret_Content `protobuf_oneof:"content"`
	// contains filtered or unexported fields
}

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 deprecated

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

Deprecated: Use Secret.ProtoReflect.Descriptor instead.

func (*Secret) GetContent

func (m *Secret) GetContent() isSecret_Content

func (*Secret) GetInternalEndpoint

func (x *Secret) GetInternalEndpoint() string

func (*Secret) ProtoMessage

func (*Secret) ProtoMessage()

func (*Secret) ProtoReflect

func (x *Secret) ProtoReflect() protoreflect.Message

func (*Secret) Reset

func (x *Secret) Reset()

func (*Secret) String

func (x *Secret) String() string

type SecretEnvelope

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"`
	// contains filtered or unexported fields
}

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 deprecated

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

Deprecated: Use SecretEnvelope.ProtoReflect.Descriptor instead.

func (*SecretEnvelope) GetPayload

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

func (*SecretEnvelope) GetSignature

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

func (*SecretEnvelope) ProtoMessage

func (*SecretEnvelope) ProtoMessage()

func (*SecretEnvelope) ProtoReflect

func (x *SecretEnvelope) ProtoReflect() protoreflect.Message

func (*SecretEnvelope) Reset

func (x *SecretEnvelope) Reset()

func (*SecretEnvelope) String

func (x *SecretEnvelope) String() string

type Secret_InternalEndpoint

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

type StateInfo

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"`
	// contains filtered or unexported fields
}

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

func (*StateInfo) Descriptor deprecated

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

Deprecated: Use StateInfo.ProtoReflect.Descriptor instead.

func (*StateInfo) GetChannel_MAC

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

func (*StateInfo) GetPkiId

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

func (*StateInfo) GetProperties

func (x *StateInfo) GetProperties() *Properties

func (*StateInfo) GetTimestamp

func (x *StateInfo) GetTimestamp() *PeerTime

func (*StateInfo) ProtoMessage

func (*StateInfo) ProtoMessage()

func (*StateInfo) ProtoReflect

func (x *StateInfo) ProtoReflect() protoreflect.Message

func (*StateInfo) Reset

func (x *StateInfo) Reset()

func (*StateInfo) String

func (x *StateInfo) String() string

type StateInfoPullRequest

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"`
	// contains filtered or unexported fields
}

StateInfoPullRequest is used to fetch a StateInfoSnapshot from a remote peer

func (*StateInfoPullRequest) Descriptor deprecated

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

Deprecated: Use StateInfoPullRequest.ProtoReflect.Descriptor instead.

func (*StateInfoPullRequest) GetChannel_MAC

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

func (*StateInfoPullRequest) ProtoMessage

func (*StateInfoPullRequest) ProtoMessage()

func (*StateInfoPullRequest) ProtoReflect

func (x *StateInfoPullRequest) ProtoReflect() protoreflect.Message

func (*StateInfoPullRequest) Reset

func (x *StateInfoPullRequest) Reset()

func (*StateInfoPullRequest) String

func (x *StateInfoPullRequest) String() string

type StateInfoSnapshot

type StateInfoSnapshot struct {
	Elements []*Envelope `protobuf:"bytes,1,rep,name=elements,proto3" json:"elements,omitempty"`
	// contains filtered or unexported fields
}

StateInfoSnapshot is an aggregation of StateInfo messages

func (*StateInfoSnapshot) Descriptor deprecated

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

Deprecated: Use StateInfoSnapshot.ProtoReflect.Descriptor instead.

func (*StateInfoSnapshot) GetElements

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

func (*StateInfoSnapshot) ProtoMessage

func (*StateInfoSnapshot) ProtoMessage()

func (*StateInfoSnapshot) ProtoReflect

func (x *StateInfoSnapshot) ProtoReflect() protoreflect.Message

func (*StateInfoSnapshot) Reset

func (x *StateInfoSnapshot) Reset()

func (*StateInfoSnapshot) String

func (x *StateInfoSnapshot) String() string

type UnimplementedGossipServer

type UnimplementedGossipServer struct {
}

UnimplementedGossipServer should be embedded to have forward compatible implementations.

func (UnimplementedGossipServer) GossipStream

func (UnimplementedGossipServer) Ping

type UnsafeGossipServer

type UnsafeGossipServer interface {
	// contains filtered or unexported methods
}

UnsafeGossipServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to GossipServer will result in compilation errors.

Jump to

Keyboard shortcuts

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