relay

Documentation

Index

• Variables
• func StartRelay(ctx context.Context, cfg *config.Config, metrics *metrics.PrometheusMetrics)

Variables

var (
	// RegisteredClients stores function that returns instace which satisfies chain.IClient interface
	// This function panics if any error occurs while initialization
	RegisteredClients = map[string]chain.ClientFunc{}
	// RegisteredRetryChannels stores channels for each chain to receive and handle packets that needs to be
	// retried.
	RegisteredRetryChannels = map[string]chan *chain.Packet{}
	// RegisteredCompleteChannels stores channel for each chain to receive and handle packets that has successfully
	// been stored in db-service.
	RegisteredCompleteChannels = map[string]chan<- *chain.Packet{}
)

Each chain registers required instance into these maps in its init() function. Gateway to chain specific logic.

Functions

func StartRelay

func StartRelay(ctx context.Context, cfg *config.Config, metrics *metrics.PrometheusMetrics)

StartRelay setups all the necessary environment for running the relay and starts it.