relay

package

v0.30.8 Latest Latest Go to latest Published: May 31, 2023 License: AGPL-3.0 Imports: 10 Imported by: 2

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/onflow/flow-go

Links

Open Source Insights

Documentation ¶

Index ¶

type RelayNetwork
- func NewRelayNetwork(originNetwork network.Network, destinationNetwork network.Network, ...) *RelayNetwork
type Relayer
- func NewRelayer(destinationNetwork network.Network, channel channels.Channel, ...) (*Relayer, error)
- func (r *Relayer) Close() error
- func (r *Relayer) Process(channel channels.Channel, originID flow.Identifier, event interface{}) error

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type RelayNetwork ¶

type RelayNetwork struct {
	// contains filtered or unexported fields
}

func NewRelayNetwork ¶

func NewRelayNetwork(
	originNetwork network.Network,
	destinationNetwork network.Network,
	logger zerolog.Logger,
	channels map[channels.Channel]channels.Channel,
) *RelayNetwork

func (*RelayNetwork) Done ¶

func (r *RelayNetwork) Done() <-chan struct{}

func (*RelayNetwork) Ready ¶

func (r *RelayNetwork) Ready() <-chan struct{}

func (*RelayNetwork) Register ¶

func (r *RelayNetwork) Register(channel channels.Channel, messageProcessor network.MessageProcessor) (network.Conduit, error)

func (*RelayNetwork) RegisterBlobService ¶

func (r *RelayNetwork) RegisterBlobService(channel channels.Channel, store datastore.Batching, opts ...network.BlobServiceOption) (network.BlobService, error)

func (*RelayNetwork) RegisterPingService ¶

func (r *RelayNetwork) RegisterPingService(pid protocol.ID, provider network.PingInfoProvider) (network.PingService, error)

func (*RelayNetwork) Start ¶

func (r *RelayNetwork) Start(ctx irrecoverable.SignalerContext)

type Relayer ¶

type Relayer struct {
	// contains filtered or unexported fields
}

func NewRelayer ¶

func NewRelayer(destinationNetwork network.Network, channel channels.Channel, processor network.MessageProcessor) (*Relayer, error)

func (*Relayer) Close ¶

func (r *Relayer) Close() error

func (*Relayer) Process ¶

func (r *Relayer) Process(channel channels.Channel, originID flow.Identifier, event interface{}) error

Source Files ¶

View all Source files

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