Documentation ¶
Index ¶
- type ChannelProvider
- 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 (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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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, opts ...options.Opt) (*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) CloseContext ¶
func (cp *ChannelProvider) CloseContext(ctx fab.ClientContext)
CloseContext frees resources and caches for the given context.
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.