Documentation
¶
Index ¶
- type NetworkNameChangeListener
- type Observer
- type Option
- func WithBootstrapAddrs(addrs ...peer.AddrInfo) Option
- func WithBootstrapAddrsFromString(addrs ...string) Option
- func WithConnectivityCheckInterval(interval time.Duration) Option
- func WithConnectivityMinPeers(count int) Option
- func WithDataSourceName(dataSourceName string) Option
- func WithDynamicNetworkNameFromManifestProvider(id peer.ID) Option
- func WithHost(h host.Host) Option
- func WithMessageBufferSize(messageBufferSize int) Option
- func WithNetworkNameChangeListener(listener NetworkNameChangeListener) Option
- func WithQueryServerListenAddress(addr string) Option
- func WithQueryServerReadTimeout(d time.Duration) Option
- func WithRetention(retention time.Duration) Option
- func WithRotateInterval(d time.Duration) Option
- func WithRotatePath(path string) Option
- func WithStaticNetworkName(name gpbft.NetworkName) Option
- type QueryRequest
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type NetworkNameChangeListener ¶
type NetworkNameChangeListener func(context.Context, *pubsub.PubSub) (<-chan gpbft.NetworkName, error)
NetworkNameChangeListener returns a channel that is notified whenever the network name changes. The channel should never be closed.
type Option ¶
type Option func(*options) error
func WithBootstrapAddrs ¶
func WithDataSourceName ¶
func WithMessageBufferSize ¶
func WithNetworkNameChangeListener ¶
func WithNetworkNameChangeListener(listener NetworkNameChangeListener) Option
func WithRetention ¶
func WithRotateInterval ¶
func WithRotatePath ¶
func WithStaticNetworkName ¶
func WithStaticNetworkName(name gpbft.NetworkName) Option
type QueryRequest ¶
type QueryRequest struct {
Query string `json:"Query"`
}
Click to show internal directories.
Click to hide internal directories.