transport

package

v1.3.0 Latest Latest Go to latest Published: Mar 24, 2024 License: Apache-2.0 Imports: 22 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/bacalhau-project/bacalhau

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type Libp2pTransport
- func NewLibp2pTransport(ctx context.Context, config Libp2pTransportConfig, ...) (*Libp2pTransport, error)
type Libp2pTransportConfig
- func (c *Libp2pTransportConfig) Validate() error

Constants ¶

View Source

const NodeInfoTopic = "bacalhau-node-info"

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Libp2pTransport ¶

type Libp2pTransport struct {
	Host host.Host
	// contains filtered or unexported fields
}

func NewLibp2pTransport ¶

func NewLibp2pTransport(ctx context.Context,
	config Libp2pTransportConfig,
	nodeInfoStore routing.NodeInfoStore) (*Libp2pTransport, error)

func (*Libp2pTransport) CallbackProxy ¶

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

CallbackProxy returns the callback proxy.

func (*Libp2pTransport) Close ¶

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

Close closes the transport layer.

func (*Libp2pTransport) ComputeProxy ¶

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

ComputeProxy returns the compute proxy.

func (*Libp2pTransport) DebugInfoProviders ¶

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

DebugInfoProviders returns the debug info.

func (*Libp2pTransport) ManagementProxy ¶ added in v1.2.3

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

RegistrationProxy is not supported for the Libp2p transport and returns nil.

func (*Libp2pTransport) NodeInfoDecorator ¶

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

NodeInfoDecorator returns the node info decorator.

func (*Libp2pTransport) NodeInfoPubSub ¶

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

NodeInfoPubSub returns the node info pubsub.

func (*Libp2pTransport) RegisterComputeCallback ¶

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

RegisterComputeCallback registers a compute callback with the transport layer.

func (*Libp2pTransport) RegisterComputeEndpoint ¶

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

RegisterComputeEndpoint registers a compute endpoint with the transport layer.

func (*Libp2pTransport) RegisterManagementEndpoint ¶ added in v1.2.3

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

RegisterManagementEndpoint is not implemented for libp2p transport. Compute nodes using this transport can call this with no effect.

func (*Libp2pTransport) RegisterNodeInfoConsumer ¶ added in v1.2.2

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

type Libp2pTransportConfig ¶

type Libp2pTransportConfig struct {
	Host           host.Host
	Peers          []string
	ReconnectDelay time.Duration
	CleanupManager *system.CleanupManager
}

func (*Libp2pTransportConfig) Validate ¶

func (c *Libp2pTransportConfig) Validate() error

Source Files ¶

View all Source files

libp2p.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL