endpoint

Documentation

Index

• type DiscoveryWrapper
  • func NewEndpointDiscoveryWrapper(ctx context.Client, channelID string, target fab.DiscoveryService, opts ...Opt) (*DiscoveryWrapper, error)
  • func (s *DiscoveryWrapper) GetPeers() ([]fab.Peer, error)
• type EventEndpoint
  • func FromPeerConfig(config fab.EndpointConfig, peer fab.Peer, peerCfg *fab.PeerConfig) *EventEndpoint
  • func (e *EventEndpoint) EventURL() string
  • func (e *EventEndpoint) Opts() []options.Opt
• type Opt
  • func WithTargetFilter(filter fab.TargetFilter) Opt

Types

type DiscoveryWrapper

type DiscoveryWrapper struct {
	fab.DiscoveryService
	// contains filtered or unexported fields
}

DiscoveryWrapper wraps a target discovery service and and adds endpoint data to each of the discovered peers.

func NewEndpointDiscoveryWrapper

func NewEndpointDiscoveryWrapper(ctx context.Client, channelID string, target fab.DiscoveryService, opts ...Opt) (*DiscoveryWrapper, error)

NewEndpointDiscoveryWrapper returns a new event endpoint discovery service that wraps a given target discovery service and adds endpoint data to each of the discovered peers.

func (*DiscoveryWrapper) GetPeers

func (s *DiscoveryWrapper) GetPeers() ([]fab.Peer, error)

GetPeers returns the discovered peers

type EventEndpoint

type EventEndpoint struct {
	Certificate *x509.Certificate
	fab.Peer
	EvtURL string
	// contains filtered or unexported fields
}

EventEndpoint extends a Peer endpoint and provides the event URL, which, in the case of Eventhub, is different from the peer endpoint

func FromPeerConfig

func FromPeerConfig(config fab.EndpointConfig, peer fab.Peer, peerCfg *fab.PeerConfig) *EventEndpoint

FromPeerConfig creates a new EventEndpoint from the given config

func (*EventEndpoint) EventURL

func (e *EventEndpoint) EventURL() string

EventURL returns the event URL

func (*EventEndpoint) Opts

func (e *EventEndpoint) Opts() []options.Opt

Opts returns additional options for the event connection

type Opt

type Opt func(p *DiscoveryWrapper)

Opt is a discoveryProvider option

func WithTargetFilter

func WithTargetFilter(filter fab.TargetFilter) Opt

WithTargetFilter applies the target filter to the discovery provider