host

Jul 24, 2024

Changes in this version

+ func WithBootNodesReachabilityInterval(d time.Duration) func(cfg *Config)

+ func WithDisabledResourceLimits(b bool) func(cfg *Config)

+ func WithMustReachBootNodes(b bool) func(*Config)

type Config

+ BootNodesReachabilityCheckInterval time.Duration

+ DisableResourceLimits bool

+ MustReachBootNodes bool

type Host

+ func (h *Host) ConnectToBootNodes(ctx context.Context) error

+ func (h *Host) ConnectToDialbackPeers(ctx context.Context) error

+ func (h *Host) ConnectToKnownPeers(ctx context.Context) error

Feb 8, 2024

Changes in this version

type Host

+ func (h *Host) InitPubSub(ctx context.Context) error

+ func (h *Host) JoinTopic(topic string) (*pubsub.Topic, error)

Sep 6, 2023

Changes in this version

type Host

+ func (h *Host) PrivateKey() crypto.PrivKey

+ func (h *Host) PublicKey() crypto.PubKey

+ func (h *Host) SendMessageOnProtocol(ctx context.Context, to peer.ID, payload []byte, protocol protocol.ID) error

Sep 4, 2023

Changes in this version

+ func WithBootNodes(nodes []multiaddr.Multiaddr) func(*Config)

+ func WithConnectionThreshold(n uint) func(*Config)

+ func WithDialBackAddress(a string) func(*Config)

+ func WithDialBackPeers(peers []blockless.Peer) func(*Config)

+ func WithDialBackPeersLimit(n uint) func(*Config)

+ func WithDialBackPort(n uint) func(*Config)

+ func WithDialBackWebsocketPort(n uint) func(*Config)

+ func WithDiscoveryInterval(d time.Duration) func(*Config)

+ func WithPrivateKey(filepath string) func(*Config)

+ func WithWebsocket(b bool) func(*Config)

+ func WithWebsocketPort(port uint) func(*Config)

+ type Config struct

+ BootNodes []multiaddr.Multiaddr

+ ConnectionThreshold uint

+ DialBackAddress string

+ DialBackPeers []blockless.Peer

+ DialBackPeersLimit uint

+ DialBackPort uint

+ DialBackWebsocketPort uint

+ DiscoveryInterval time.Duration

+ PrivateKey string

+ Websocket bool

+ WebsocketPort uint

+ type Host struct

+ func New(log zerolog.Logger, address string, port uint, options ...func(*Config)) (*Host, error)

+ func (h *Host) Addresses() []string

+ func (h *Host) DiscoverPeers(ctx context.Context, topic string) error

+ func (h *Host) Publish(ctx context.Context, topic *pubsub.Topic, payload []byte) error

+ func (h *Host) SendMessage(ctx context.Context, to peer.ID, payload []byte) error

+ func (h *Host) Subscribe(ctx context.Context, topic string) (*pubsub.Topic, *pubsub.Subscription, error)