relay

Documentation

Index

• type RelayNetwork
  • func NewRelayNetwork(originNetwork network.Network, destinationNetwork network.Network, ...) *RelayNetwork
  • func (r *RelayNetwork) Done() <-chan struct{}
  • func (r *RelayNetwork) Ready() <-chan struct{}
  • func (r *RelayNetwork) Register(channel channels.Channel, messageProcessor network.MessageProcessor) (network.Conduit, error)
  • func (r *RelayNetwork) RegisterBlobService(channel channels.Channel, store datastore.Batching, ...) (network.BlobService, error)
  • func (r *RelayNetwork) RegisterPingService(pid protocol.ID, provider network.PingInfoProvider) (network.PingService, error)
  • func (r *RelayNetwork) Start(ctx irrecoverable.SignalerContext)
• 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

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