transport

Mar 14, 2024

Changes in this version

type Libp2pTransport

+ func (t *Libp2pTransport) ManagementProxy() compute.ManagementEndpoint

+ func (t *Libp2pTransport) RegisterManagementEndpoint(endpoint compute.ManagementEndpoint) error

Mar 4, 2024

Changes in this version

type Libp2pTransport

+ func (t *Libp2pTransport) GetConnectionInfo(ctx context.Context) interface{}

+ func (t *Libp2pTransport) RegisterNodeInfoConsumer(ctx context.Context, nodeInfoStore routing.NodeInfoStore) error

Jan 30, 2024

Changes in this version

+ const NodeInfoTopic

+ type Libp2pTransport struct

+ Host host.Host

+ func NewLibp2pTransport(ctx context.Context, config Libp2pTransportConfig, ...) (*Libp2pTransport, error)

+ func (t *Libp2pTransport) CallbackProxy() compute.Callback

+ func (t *Libp2pTransport) Close(ctx context.Context) error

+ func (t *Libp2pTransport) ComputeProxy() compute.Endpoint

+ func (t *Libp2pTransport) DebugInfoProviders() []model.DebugInfoProvider

+ func (t *Libp2pTransport) NodeInfoDecorator() models.NodeInfoDecorator

+ func (t *Libp2pTransport) NodeInfoPubSub() pubsub.PubSub[models.NodeInfo]

+ func (t *Libp2pTransport) RegisterComputeCallback(callback compute.Callback) error

+ func (t *Libp2pTransport) RegisterComputeEndpoint(endpoint compute.Endpoint) error

+ type Libp2pTransportConfig struct

+ CleanupManager *system.CleanupManager

+ Host host.Host

+ Peers []string

+ ReconnectDelay time.Duration

+ func (c *Libp2pTransportConfig) Validate() error