Versions in this module Expand all Collapse all v0 v0.0.2 Jan 22, 2021 v0.0.1 Jan 22, 2021 Changes in this version + func WithBlockEvents() options.Opt + func WithConnectionEvent(value chan *dispatcher.ConnectionEvent) options.Opt + func WithMaxConnectAttempts(value uint) options.Opt + func WithMaxReconnectAttempts(value uint) options.Opt + func WithReconnect(value bool) options.Opt + func WithReconnectInitialDelay(value time.Duration) options.Opt + func WithResponseTimeout(value time.Duration) options.Opt + func WithTimeBetweenConnectAttempts(value time.Duration) options.Opt + type Client struct + func New(dispatcher eventservice.Dispatcher, opts ...options.Opt) *Client + func (c *Client) Close() + func (c *Client) CloseIfIdle() bool + func (c *Client) Connect() error + func (c *Client) ConnectionState() ConnectionState + func (c *Client) RegisterBlockEvent(filter ...fab.BlockFilter) (fab.Registration, <-chan *fab.BlockEvent, error) + func (c *Client) SetAfterConnectHandler(h handler) + func (c *Client) SetBeforeReconnectHandler(h handler) + func (c *Client) Stopped() bool + func (c *Client) TransferRegistrations(close bool) (fab.EventSnapshot, error) + func (p *Client) PermitBlockEvents() + func (p *Client) SetConnectEventCh(value chan *dispatcher.ConnectionEvent) + func (p *Client) SetEventConsumerBufferSize(value uint) + func (p *Client) SetMaxConnectAttempts(value uint) + func (p *Client) SetMaxReconnectAttempts(value uint) + func (p *Client) SetReconnect(value bool) + func (p *Client) SetReconnectInitialDelay(value time.Duration) + func (p *Client) SetResponseTimeout(value time.Duration) + func (p *Client) SetTimeBetweenConnectAttempts(value time.Duration) + type ConnectionState int32 + const Connected + const Connecting + const Disconnected + func (s ConnectionState) String() string