chpvdr

Documentation

Index

• type ChannelProvider
  • func New(config fab.EndpointConfig) (*ChannelProvider, error)
  • func (cp *ChannelProvider) ChannelService(ctx fab.ClientContext, channelID string) (fab.ChannelService, error)
  • func (cp *ChannelProvider) Close()
  • func (cp *ChannelProvider) Initialize(providers context.Providers) error
• type ChannelService
  • func (cs *ChannelService) ChannelConfig() (fab.ChannelCfg, error)
  • func (cs *ChannelService) Config() (fab.ChannelConfig, error)
  • func (cs *ChannelService) Discovery() (fab.DiscoveryService, error)
  • func (cs *ChannelService) EventService(opts ...options.Opt) (fab.EventService, error)
  • func (cs *ChannelService) Membership() (fab.ChannelMembership, error)
  • func (cs *ChannelService) Selection() (fab.SelectionService, error)
  • func (cs *ChannelService) Transactor(reqCtx reqContext.Context) (fab.Transactor, error)
• type EventClientRef
  • func NewEventClientRef(idleTimeout time.Duration, evtClientProvider eventClientProvider) *EventClientRef
  • func (ref *EventClientRef) Close()
  • func (ref *EventClientRef) Closed() bool
  • func (ref *EventClientRef) RegisterBlockEvent(filter ...fab.BlockFilter) (fab.Registration, <-chan *fab.BlockEvent, error)
  • func (ref *EventClientRef) RegisterChaincodeEvent(ccID, eventFilter string) (fab.Registration, <-chan *fab.CCEvent, error)
  • func (ref *EventClientRef) RegisterFilteredBlockEvent() (fab.Registration, <-chan *fab.FilteredBlockEvent, error)
  • func (ref *EventClientRef) RegisterTxStatusEvent(txID string) (fab.Registration, <-chan *fab.TxStatusEvent, error)
  • func (ref *EventClientRef) Unregister(reg fab.Registration)

Types

type ChannelProvider

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

ChannelProvider keeps context across ChannelService instances.

TODO: add listener for channel config changes. Upon channel config change, underlying channel services need to recreate their channel clients.

func New

func New(config fab.EndpointConfig) (*ChannelProvider, error)

New creates a ChannelProvider based on a context

func (*ChannelProvider) ChannelService

func (cp *ChannelProvider) ChannelService(ctx fab.ClientContext, channelID string) (fab.ChannelService, error)

ChannelService creates a ChannelService for an identity

func (*ChannelProvider) Close

func (cp *ChannelProvider) Close()

Close frees resources and caches.

func (*ChannelProvider) Initialize

func (cp *ChannelProvider) Initialize(providers context.Providers) error

Initialize sets the provider context

type ChannelService

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

ChannelService provides Channel clients and maintains contexts for them. the identity context is used

func (*ChannelService) ChannelConfig

func (cs *ChannelService) ChannelConfig() (fab.ChannelCfg, error)

ChannelConfig returns the channel config for this channel

func (*ChannelService) Config

func (cs *ChannelService) Config() (fab.ChannelConfig, error)

Config returns the Config for the named channel

func (*ChannelService) Discovery

func (cs *ChannelService) Discovery() (fab.DiscoveryService, error)

Discovery returns a DiscoveryService for the given channel

func (*ChannelService) EventService

func (cs *ChannelService) EventService(opts ...options.Opt) (fab.EventService, error)

EventService returns the EventService.

func (*ChannelService) Membership

func (cs *ChannelService) Membership() (fab.ChannelMembership, error)

Membership returns and caches a channel member identifier A membership reference is returned that refreshes with the configured interval

func (*ChannelService) Selection

func (cs *ChannelService) Selection() (fab.SelectionService, error)

Selection returns a SelectionService for the given channel

func (*ChannelService) Transactor

func (cs *ChannelService) Transactor(reqCtx reqContext.Context) (fab.Transactor, error)

Transactor returns the transactor

type EventClientRef

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

EventClientRef holds a reference to the event client and manages its lifecycle. When the idle timeout has been reached then the event client is closed. The next time the event client ref is accessed, a new event client is created. The EventClientRef implements all of the functions of fab.EventService, so the EventClientRef may be used wherever an EventService is required.

func NewEventClientRef

func NewEventClientRef(idleTimeout time.Duration, evtClientProvider eventClientProvider) *EventClientRef

NewEventClientRef returns a new EventClientRef

func (*EventClientRef) Close

func (ref *EventClientRef) Close()

Close immediately closes the connection.

func (*EventClientRef) Closed

func (ref *EventClientRef) Closed() bool

Closed returns true if the event client is closed

func (*EventClientRef) RegisterBlockEvent

func (ref *EventClientRef) RegisterBlockEvent(filter ...fab.BlockFilter) (fab.Registration, <-chan *fab.BlockEvent, error)

RegisterBlockEvent registers for block events.

func (*EventClientRef) RegisterChaincodeEvent

func (ref *EventClientRef) RegisterChaincodeEvent(ccID, eventFilter string) (fab.Registration, <-chan *fab.CCEvent, error)

RegisterChaincodeEvent registers for chaincode events.

func (*EventClientRef) RegisterFilteredBlockEvent

func (ref *EventClientRef) RegisterFilteredBlockEvent() (fab.Registration, <-chan *fab.FilteredBlockEvent, error)

RegisterFilteredBlockEvent registers for filtered block events.

func (*EventClientRef) RegisterTxStatusEvent

func (ref *EventClientRef) RegisterTxStatusEvent(txID string) (fab.Registration, <-chan *fab.TxStatusEvent, error)

RegisterTxStatusEvent registers for transaction status events.

func (*EventClientRef) Unregister

func (ref *EventClientRef) Unregister(reg fab.Registration)

Unregister removes the given registration and closes the event channel.