discovery

package
v0.3.3 Latest Latest
Warning

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

 Go to latest Published: Jan 21, 2024 License: Apache-2.0 Imports: 10 Imported by: 851

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterDiscoveryServer 

func RegisterDiscoveryServer(s *grpc.Server, srv DiscoveryServer)

Types

type AuthInfo 

type AuthInfo struct {
	// This is the identity of the client that is used to verify the signature
	// on the SignedRequest's payload.
	// It is a msp.SerializedIdentity in bytes form
	ClientIdentity []byte `protobuf:"bytes,1,opt,name=client_identity,json=clientIdentity,proto3" json:"client_identity,omitempty"`
	// This is the hash of the client's TLS cert.
	// When the network is running with TLS, clients that don't include a certificate
	// will be denied access to the service.
	// Since the Request is encapsulated with a SignedRequest (which is signed),
	// this binds the TLS session to the enrollement identity of the client and
	// therefore both authenticates the client to the server,
	// and also prevents the server from relaying the request message to another server.
	ClientTlsCertHash    []byte   `protobuf:"bytes,2,opt,name=client_tls_cert_hash,json=clientTlsCertHash,proto3" json:"client_tls_cert_hash,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

AuthInfo aggregates authentication information that the server uses to authenticate the client

func (*AuthInfo) Descriptor 

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

func (*AuthInfo) GetClientIdentity 

func (m *AuthInfo) GetClientIdentity() []byte

func (*AuthInfo) GetClientTlsCertHash 

func (m *AuthInfo) GetClientTlsCertHash() []byte

func (*AuthInfo) ProtoMessage 

func (*AuthInfo) ProtoMessage()

func (*AuthInfo) Reset 

func (m *AuthInfo) Reset()

func (*AuthInfo) String 

func (m *AuthInfo) String() string

func (*AuthInfo) XXX_DiscardUnknown 

func (m *AuthInfo) XXX_DiscardUnknown()

func (*AuthInfo) XXX_Marshal 

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

func (*AuthInfo) XXX_Merge 

func (m *AuthInfo) XXX_Merge(src proto.Message)

func (*AuthInfo) XXX_Size 

func (m *AuthInfo) XXX_Size() int

func (*AuthInfo) XXX_Unmarshal 

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

type ChaincodeQuery 

type ChaincodeQuery struct {
	Interests            []*peer.ChaincodeInterest `protobuf:"bytes,1,rep,name=interests,proto3" json:"interests,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

ChaincodeQuery requests ChaincodeQueryResults for a given list of chaincode invocations. Each invocation is a separate one, and the endorsement policy is evaluated independantly for each given interest.

func (*ChaincodeQuery) Descriptor 

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

func (*ChaincodeQuery) GetInterests 

func (m *ChaincodeQuery) GetInterests() []*peer.ChaincodeInterest

func (*ChaincodeQuery) ProtoMessage 

func (*ChaincodeQuery) ProtoMessage()

func (*ChaincodeQuery) Reset 

func (m *ChaincodeQuery) Reset()

func (*ChaincodeQuery) String 

func (m *ChaincodeQuery) String() string

func (*ChaincodeQuery) XXX_DiscardUnknown 

func (m *ChaincodeQuery) XXX_DiscardUnknown()

func (*ChaincodeQuery) XXX_Marshal 

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

func (*ChaincodeQuery) XXX_Merge 

func (m *ChaincodeQuery) XXX_Merge(src proto.Message)

func (*ChaincodeQuery) XXX_Size 

func (m *ChaincodeQuery) XXX_Size() int

func (*ChaincodeQuery) XXX_Unmarshal 

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

type ChaincodeQueryResult 

type ChaincodeQueryResult struct {
	Content              []*EndorsementDescriptor `protobuf:"bytes,1,rep,name=content,proto3" json:"content,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

ChaincodeQueryResult contains EndorsementDescriptors for chaincodes

func (*ChaincodeQueryResult) Descriptor 

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

func (*ChaincodeQueryResult) GetContent 

func (m *ChaincodeQueryResult) GetContent() []*EndorsementDescriptor

func (*ChaincodeQueryResult) ProtoMessage 

func (*ChaincodeQueryResult) ProtoMessage()

func (*ChaincodeQueryResult) Reset 

func (m *ChaincodeQueryResult) Reset()

func (*ChaincodeQueryResult) String 

func (m *ChaincodeQueryResult) String() string

func (*ChaincodeQueryResult) XXX_DiscardUnknown 

func (m *ChaincodeQueryResult) XXX_DiscardUnknown()

func (*ChaincodeQueryResult) XXX_Marshal 

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

func (*ChaincodeQueryResult) XXX_Merge 

func (m *ChaincodeQueryResult) XXX_Merge(src proto.Message)

func (*ChaincodeQueryResult) XXX_Size 

func (m *ChaincodeQueryResult) XXX_Size() int

func (*ChaincodeQueryResult) XXX_Unmarshal 

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

type ConfigQuery 

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

ConfigQuery requests a ConfigResult

func (*ConfigQuery) Descriptor 

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

func (*ConfigQuery) ProtoMessage 

func (*ConfigQuery) ProtoMessage()

func (*ConfigQuery) Reset 

func (m *ConfigQuery) Reset()

func (*ConfigQuery) String 

func (m *ConfigQuery) String() string

func (*ConfigQuery) XXX_DiscardUnknown 

func (m *ConfigQuery) XXX_DiscardUnknown()

func (*ConfigQuery) XXX_Marshal 

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

func (*ConfigQuery) XXX_Merge 

func (m *ConfigQuery) XXX_Merge(src proto.Message)

func (*ConfigQuery) XXX_Size 

func (m *ConfigQuery) XXX_Size() int

func (*ConfigQuery) XXX_Unmarshal 

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

type ConfigResult 

type ConfigResult struct {
	// msps is a map from MSP_ID to FabricMSPConfig
	Msps map[string]*msp.FabricMSPConfig `` /* 149-byte string literal not displayed */
	// orderers is a map from MSP_ID to endpoint lists of orderers
	Orderers             map[string]*Endpoints `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ConfigResult) Descriptor 

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

func (*ConfigResult) GetMsps 

func (m *ConfigResult) GetMsps() map[string]*msp.FabricMSPConfig

func (*ConfigResult) GetOrderers 

func (m *ConfigResult) GetOrderers() map[string]*Endpoints

func (*ConfigResult) ProtoMessage 

func (*ConfigResult) ProtoMessage()

func (*ConfigResult) Reset 

func (m *ConfigResult) Reset()

func (*ConfigResult) String 

func (m *ConfigResult) String() string

func (*ConfigResult) XXX_DiscardUnknown 

func (m *ConfigResult) XXX_DiscardUnknown()

func (*ConfigResult) XXX_Marshal 

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

func (*ConfigResult) XXX_Merge 

func (m *ConfigResult) XXX_Merge(src proto.Message)

func (*ConfigResult) XXX_Size 

func (m *ConfigResult) XXX_Size() int

func (*ConfigResult) XXX_Unmarshal 

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

type DiscoveryClient 

type DiscoveryClient interface {
	// Discover receives a signed request, and returns a response.
	Discover(ctx context.Context, in *SignedRequest, opts ...grpc.CallOption) (*Response, error)
}

DiscoveryClient is the client API for Discovery service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDiscoveryClient 

func NewDiscoveryClient(cc *grpc.ClientConn) DiscoveryClient

type DiscoveryServer 

type DiscoveryServer interface {
	// Discover receives a signed request, and returns a response.
	Discover(context.Context, *SignedRequest) (*Response, error)
}

DiscoveryServer is the server API for Discovery service.

type EndorsementDescriptor 

type EndorsementDescriptor struct {
	Chaincode string `protobuf:"bytes,1,opt,name=chaincode,proto3" json:"chaincode,omitempty"`
	// Specifies the endorsers, separated to groups.
	EndorsersByGroups map[string]*Peers `` /* 202-byte string literal not displayed */
	// Specifies options of fulfulling the endorsement policy.
	// Each option lists the group names, and the amount of signatures needed
	// from each group.
	Layouts              []*Layout `protobuf:"bytes,3,rep,name=layouts,proto3" json:"layouts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

EndorsementDescriptor contains information about which peers can be used to request endorsement from, such that the endorsement policy would be fulfilled. Here is how to compute a set of peers to ask an endorsement from, given an EndorsementDescriptor: Let e: G --> P be the endorsers_by_groups field that maps a group to a set of peers. Note that applying e on a group g yields a set of peers.

  1. Select a layout l: G --> N out of the layouts given. l is the quantities_by_group field of a Layout, and it maps a group to an integer.
  2. R = {} (an empty set of peers)
  3. For each group g in the layout l, compute n = l(g) 3.1) Denote P_g as a set of n random peers {p0, p1, ... p_n} selected from e(g) 3.2) R = R U P_g (add P_g to R)
  4. The set of peers R is the peers the client needs to request endorsements from

func (*EndorsementDescriptor) Descriptor 

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

func (*EndorsementDescriptor) GetChaincode 

func (m *EndorsementDescriptor) GetChaincode() string

func (*EndorsementDescriptor) GetEndorsersByGroups 

func (m *EndorsementDescriptor) GetEndorsersByGroups() map[string]*Peers

func (*EndorsementDescriptor) GetLayouts 

func (m *EndorsementDescriptor) GetLayouts() []*Layout

func (*EndorsementDescriptor) ProtoMessage 

func (*EndorsementDescriptor) ProtoMessage()

func (*EndorsementDescriptor) Reset 

func (m *EndorsementDescriptor) Reset()

func (*EndorsementDescriptor) String 

func (m *EndorsementDescriptor) String() string

func (*EndorsementDescriptor) XXX_DiscardUnknown 

func (m *EndorsementDescriptor) XXX_DiscardUnknown()

func (*EndorsementDescriptor) XXX_Marshal 

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

func (*EndorsementDescriptor) XXX_Merge 

func (m *EndorsementDescriptor) XXX_Merge(src proto.Message)

func (*EndorsementDescriptor) XXX_Size 

func (m *EndorsementDescriptor) XXX_Size() int

func (*EndorsementDescriptor) XXX_Unmarshal 

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

type Endpoint 

type Endpoint struct {
	Host                 string   `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Port                 uint32   `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Endpoint is a combination of a host and a port

func (*Endpoint) Descriptor 

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

func (*Endpoint) GetHost 

func (m *Endpoint) GetHost() string

func (*Endpoint) GetPort 

func (m *Endpoint) GetPort() uint32

func (*Endpoint) ProtoMessage 

func (*Endpoint) ProtoMessage()

func (*Endpoint) Reset 

func (m *Endpoint) Reset()

func (*Endpoint) String 

func (m *Endpoint) String() string

func (*Endpoint) XXX_DiscardUnknown 

func (m *Endpoint) XXX_DiscardUnknown()

func (*Endpoint) XXX_Marshal 

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

func (*Endpoint) XXX_Merge 

func (m *Endpoint) XXX_Merge(src proto.Message)

func (*Endpoint) XXX_Size 

func (m *Endpoint) XXX_Size() int

func (*Endpoint) XXX_Unmarshal 

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

type Endpoints 

type Endpoints struct {
	Endpoint             []*Endpoint `protobuf:"bytes,1,rep,name=endpoint,proto3" json:"endpoint,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

Endpoints is a list of Endpoint(s)

func (*Endpoints) Descriptor 

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

func (*Endpoints) GetEndpoint 

func (m *Endpoints) GetEndpoint() []*Endpoint

func (*Endpoints) ProtoMessage 

func (*Endpoints) ProtoMessage()

func (*Endpoints) Reset 

func (m *Endpoints) Reset()

func (*Endpoints) String 

func (m *Endpoints) String() string

func (*Endpoints) XXX_DiscardUnknown 

func (m *Endpoints) XXX_DiscardUnknown()

func (*Endpoints) XXX_Marshal 

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

func (*Endpoints) XXX_Merge 

func (m *Endpoints) XXX_Merge(src proto.Message)

func (*Endpoints) XXX_Size 

func (m *Endpoints) XXX_Size() int

func (*Endpoints) XXX_Unmarshal 

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

type Error 

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

Error denotes that something went wrong and contains the error message

func (*Error) Descriptor 

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

func (*Error) GetContent 

func (m *Error) GetContent() string

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) String 

func (m *Error) String() string

func (*Error) XXX_DiscardUnknown 

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal 

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

func (*Error) XXX_Merge 

func (m *Error) XXX_Merge(src proto.Message)

func (*Error) XXX_Size 

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal 

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

type Layout 

type Layout struct {
	// Specifies how many non repeated signatures of each group
	// are needed for endorsement
	QuantitiesByGroup    map[string]uint32 `` /* 203-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Layout contains a mapping from a group name to number of peers that are needed for fulfilling an endorsement policy

func (*Layout) Descriptor 

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

func (*Layout) GetQuantitiesByGroup 

func (m *Layout) GetQuantitiesByGroup() map[string]uint32

func (*Layout) ProtoMessage 

func (*Layout) ProtoMessage()

func (*Layout) Reset 

func (m *Layout) Reset()

func (*Layout) String 

func (m *Layout) String() string

func (*Layout) XXX_DiscardUnknown 

func (m *Layout) XXX_DiscardUnknown()

func (*Layout) XXX_Marshal 

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

func (*Layout) XXX_Merge 

func (m *Layout) XXX_Merge(src proto.Message)

func (*Layout) XXX_Size 

func (m *Layout) XXX_Size() int

func (*Layout) XXX_Unmarshal 

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

type LocalPeerQuery 

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

LocalPeerQuery queries for peers in a non channel context

func (*LocalPeerQuery) Descriptor 

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

func (*LocalPeerQuery) ProtoMessage 

func (*LocalPeerQuery) ProtoMessage()

func (*LocalPeerQuery) Reset 

func (m *LocalPeerQuery) Reset()

func (*LocalPeerQuery) String 

func (m *LocalPeerQuery) String() string

func (*LocalPeerQuery) XXX_DiscardUnknown 

func (m *LocalPeerQuery) XXX_DiscardUnknown()

func (*LocalPeerQuery) XXX_Marshal 

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

func (*LocalPeerQuery) XXX_Merge 

func (m *LocalPeerQuery) XXX_Merge(src proto.Message)

func (*LocalPeerQuery) XXX_Size 

func (m *LocalPeerQuery) XXX_Size() int

func (*LocalPeerQuery) XXX_Unmarshal 

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

type Peer 

type Peer struct {
	// This is an Envelope of a GossipMessage with a gossip.StateInfo message
	StateInfo *gossip.Envelope `protobuf:"bytes,1,opt,name=state_info,json=stateInfo,proto3" json:"state_info,omitempty"`
	// This is an Envelope of a GossipMessage with a gossip.AliveMessage message
	MembershipInfo *gossip.Envelope `protobuf:"bytes,2,opt,name=membership_info,json=membershipInfo,proto3" json:"membership_info,omitempty"`
	// This is the msp.SerializedIdentity of the peer, represented in bytes.
	Identity             []byte   `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Peer contains information about the peer such as its channel specific state, and membership information.

func (*Peer) Descriptor 

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

func (*Peer) GetIdentity 

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

func (*Peer) GetMembershipInfo 

func (m *Peer) GetMembershipInfo() *gossip.Envelope

func (*Peer) GetStateInfo 

func (m *Peer) GetStateInfo() *gossip.Envelope

func (*Peer) ProtoMessage 

func (*Peer) ProtoMessage()

func (*Peer) Reset 

func (m *Peer) Reset()

func (*Peer) String 

func (m *Peer) String() string

func (*Peer) XXX_DiscardUnknown 

func (m *Peer) XXX_DiscardUnknown()

func (*Peer) XXX_Marshal 

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

func (*Peer) XXX_Merge 

func (m *Peer) XXX_Merge(src proto.Message)

func (*Peer) XXX_Size 

func (m *Peer) XXX_Size() int

func (*Peer) XXX_Unmarshal 

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

type PeerMembershipQuery 

type PeerMembershipQuery struct {
	Filter               *peer.ChaincodeInterest `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

PeerMembershipQuery requests PeerMembershipResult. The filter field may be optionally populated in order for the peer membership to be filtered according to chaincodes that are installed on peers and collection access control policies.

func (*PeerMembershipQuery) Descriptor 

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

func (*PeerMembershipQuery) GetFilter 

func (m *PeerMembershipQuery) GetFilter() *peer.ChaincodeInterest

func (*PeerMembershipQuery) ProtoMessage 

func (*PeerMembershipQuery) ProtoMessage()

func (*PeerMembershipQuery) Reset 

func (m *PeerMembershipQuery) Reset()

func (*PeerMembershipQuery) String 

func (m *PeerMembershipQuery) String() string

func (*PeerMembershipQuery) XXX_DiscardUnknown 

func (m *PeerMembershipQuery) XXX_DiscardUnknown()

func (*PeerMembershipQuery) XXX_Marshal 

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

func (*PeerMembershipQuery) XXX_Merge 

func (m *PeerMembershipQuery) XXX_Merge(src proto.Message)

func (*PeerMembershipQuery) XXX_Size 

func (m *PeerMembershipQuery) XXX_Size() int

func (*PeerMembershipQuery) XXX_Unmarshal 

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

type PeerMembershipResult 

type PeerMembershipResult struct {
	PeersByOrg           map[string]*Peers `` /* 181-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

PeerMembershipResult contains peers mapped by their organizations (MSP_ID)

func (*PeerMembershipResult) Descriptor 

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

func (*PeerMembershipResult) GetPeersByOrg 

func (m *PeerMembershipResult) GetPeersByOrg() map[string]*Peers

func (*PeerMembershipResult) ProtoMessage 

func (*PeerMembershipResult) ProtoMessage()

func (*PeerMembershipResult) Reset 

func (m *PeerMembershipResult) Reset()

func (*PeerMembershipResult) String 

func (m *PeerMembershipResult) String() string

func (*PeerMembershipResult) XXX_DiscardUnknown 

func (m *PeerMembershipResult) XXX_DiscardUnknown()

func (*PeerMembershipResult) XXX_Marshal 

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

func (*PeerMembershipResult) XXX_Merge 

func (m *PeerMembershipResult) XXX_Merge(src proto.Message)

func (*PeerMembershipResult) XXX_Size 

func (m *PeerMembershipResult) XXX_Size() int

func (*PeerMembershipResult) XXX_Unmarshal 

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

type Peers 

type Peers struct {
	Peers                []*Peer  `protobuf:"bytes,1,rep,name=peers,proto3" json:"peers,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Peers contains a list of Peer(s)

func (*Peers) Descriptor 

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

func (*Peers) GetPeers 

func (m *Peers) GetPeers() []*Peer

func (*Peers) ProtoMessage 

func (*Peers) ProtoMessage()

func (*Peers) Reset 

func (m *Peers) Reset()

func (*Peers) String 

func (m *Peers) String() string

func (*Peers) XXX_DiscardUnknown 

func (m *Peers) XXX_DiscardUnknown()

func (*Peers) XXX_Marshal 

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

func (*Peers) XXX_Merge 

func (m *Peers) XXX_Merge(src proto.Message)

func (*Peers) XXX_Size 

func (m *Peers) XXX_Size() int

func (*Peers) XXX_Unmarshal 

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

type Query 

type Query struct {
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	// Types that are valid to be assigned to Query:
	//
	//	*Query_ConfigQuery
	//	*Query_PeerQuery
	//	*Query_CcQuery
	//	*Query_LocalPeers
	Query                isQuery_Query `protobuf_oneof:"query"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

Query asks for information in the context of a specific channel

func (*Query) Descriptor 

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

func (*Query) GetCcQuery 

func (m *Query) GetCcQuery() *ChaincodeQuery

func (*Query) GetChannel 

func (m *Query) GetChannel() string

func (*Query) GetConfigQuery 

func (m *Query) GetConfigQuery() *ConfigQuery

func (*Query) GetLocalPeers 

func (m *Query) GetLocalPeers() *LocalPeerQuery

func (*Query) GetPeerQuery 

func (m *Query) GetPeerQuery() *PeerMembershipQuery

func (*Query) GetQuery 

func (m *Query) GetQuery() isQuery_Query

func (*Query) ProtoMessage 

func (*Query) ProtoMessage()

func (*Query) Reset 

func (m *Query) Reset()

func (*Query) String 

func (m *Query) String() string

func (*Query) XXX_DiscardUnknown 

func (m *Query) XXX_DiscardUnknown()

func (*Query) XXX_Marshal 

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

func (*Query) XXX_Merge 

func (m *Query) XXX_Merge(src proto.Message)

func (*Query) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Query) XXX_Size 

func (m *Query) XXX_Size() int

func (*Query) XXX_Unmarshal 

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

type QueryResult 

type QueryResult struct {
	// Types that are valid to be assigned to Result:
	//
	//	*QueryResult_Error
	//	*QueryResult_ConfigResult
	//	*QueryResult_CcQueryRes
	//	*QueryResult_Members
	Result               isQueryResult_Result `protobuf_oneof:"result"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

QueryResult contains a result for a given Query. The corresponding Query can be inferred by the index of the QueryResult from its enclosing Response message. QueryResults are ordered in the same order as the Queries are ordered in their enclosing Request.

func (*QueryResult) Descriptor 

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

func (*QueryResult) GetCcQueryRes 

func (m *QueryResult) GetCcQueryRes() *ChaincodeQueryResult

func (*QueryResult) GetConfigResult 

func (m *QueryResult) GetConfigResult() *ConfigResult

func (*QueryResult) GetError 

func (m *QueryResult) GetError() *Error

func (*QueryResult) GetMembers 

func (m *QueryResult) GetMembers() *PeerMembershipResult

func (*QueryResult) GetResult 

func (m *QueryResult) GetResult() isQueryResult_Result

func (*QueryResult) ProtoMessage 

func (*QueryResult) ProtoMessage()

func (*QueryResult) Reset 

func (m *QueryResult) Reset()

func (*QueryResult) String 

func (m *QueryResult) String() string

func (*QueryResult) XXX_DiscardUnknown 

func (m *QueryResult) XXX_DiscardUnknown()

func (*QueryResult) XXX_Marshal 

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

func (*QueryResult) XXX_Merge 

func (m *QueryResult) XXX_Merge(src proto.Message)

func (*QueryResult) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*QueryResult) XXX_Size 

func (m *QueryResult) XXX_Size() int

func (*QueryResult) XXX_Unmarshal 

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

type QueryResult_CcQueryRes 

type QueryResult_CcQueryRes struct {
	CcQueryRes *ChaincodeQueryResult `protobuf:"bytes,3,opt,name=cc_query_res,json=ccQueryRes,proto3,oneof"`
}

type QueryResult_ConfigResult 

type QueryResult_ConfigResult struct {
	ConfigResult *ConfigResult `protobuf:"bytes,2,opt,name=config_result,json=configResult,proto3,oneof"`
}

type QueryResult_Error 

type QueryResult_Error struct {
	Error *Error `protobuf:"bytes,1,opt,name=error,proto3,oneof"`
}

type QueryResult_Members 

type QueryResult_Members struct {
	Members *PeerMembershipResult `protobuf:"bytes,4,opt,name=members,proto3,oneof"`
}

type Query_CcQuery 

type Query_CcQuery struct {
	CcQuery *ChaincodeQuery `protobuf:"bytes,4,opt,name=cc_query,json=ccQuery,proto3,oneof"`
}

type Query_ConfigQuery 

type Query_ConfigQuery struct {
	ConfigQuery *ConfigQuery `protobuf:"bytes,2,opt,name=config_query,json=configQuery,proto3,oneof"`
}

type Query_LocalPeers 

type Query_LocalPeers struct {
	LocalPeers *LocalPeerQuery `protobuf:"bytes,5,opt,name=local_peers,json=localPeers,proto3,oneof"`
}

type Query_PeerQuery 

type Query_PeerQuery struct {
	PeerQuery *PeerMembershipQuery `protobuf:"bytes,3,opt,name=peer_query,json=peerQuery,proto3,oneof"`
}

type Request 

type Request struct {
	// authentication contains information that the service uses to check
	// the client's eligibility for the queries.
	Authentication *AuthInfo `protobuf:"bytes,1,opt,name=authentication,proto3" json:"authentication,omitempty"`
	// queries
	Queries              []*Query `protobuf:"bytes,2,rep,name=queries,proto3" json:"queries,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request contains authentication info about the client that sent the request and the queries it wishes to query the service

func (*Request) Descriptor 

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

func (*Request) GetAuthentication 

func (m *Request) GetAuthentication() *AuthInfo

func (*Request) GetQueries 

func (m *Request) GetQueries() []*Query

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) Reset 

func (m *Request) Reset()

func (*Request) String 

func (m *Request) String() string

func (*Request) XXX_DiscardUnknown 

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal 

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

func (*Request) XXX_Merge 

func (m *Request) XXX_Merge(src proto.Message)

func (*Request) XXX_Size 

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal 

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

type Response 

type Response struct {
	// The results are returned in the same order of the queries
	Results              []*QueryResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*Response) Descriptor 

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

func (*Response) GetResults 

func (m *Response) GetResults() []*QueryResult

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) String 

func (m *Response) String() string

func (*Response) XXX_DiscardUnknown 

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal 

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

func (*Response) XXX_Merge 

func (m *Response) XXX_Merge(src proto.Message)

func (*Response) XXX_Size 

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal 

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

type SignedRequest 

type SignedRequest 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:"-"`
}

SignedRequest contains a serialized Request in the payload field and a signature. The identity that is used to verify the signature can be extracted from the authentication field of type AuthInfo in the Request itself after deserializing it.

func (*SignedRequest) Descriptor 

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

func (*SignedRequest) GetPayload 

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

func (*SignedRequest) GetSignature 

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

func (*SignedRequest) ProtoMessage 

func (*SignedRequest) ProtoMessage()

func (*SignedRequest) Reset 

func (m *SignedRequest) Reset()

func (*SignedRequest) String 

func (m *SignedRequest) String() string

func (*SignedRequest) XXX_DiscardUnknown 

func (m *SignedRequest) XXX_DiscardUnknown()

func (*SignedRequest) XXX_Marshal 

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

func (*SignedRequest) XXX_Merge 

func (m *SignedRequest) XXX_Merge(src proto.Message)

func (*SignedRequest) XXX_Size 

func (m *SignedRequest) XXX_Size() int

func (*SignedRequest) XXX_Unmarshal 

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

type UnimplementedDiscoveryServer 

type UnimplementedDiscoveryServer struct {
}

UnimplementedDiscoveryServer can be embedded to have forward compatible implementations.

func (*UnimplementedDiscoveryServer) Discover 

func (*UnimplementedDiscoveryServer) Discover(ctx context.Context, req *SignedRequest) (*Response, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.