relayer

Documentation

Index

• Variables
• type App
  • func New(config *Config) *App
  • func (a *App) IsReady() bool
  • func (a *App) Run() error
• type Config

Variables

var RelayerStartAborted = fmt.Errorf("getting start block aborted by relayer application terminating signal")

Types

type App

type App struct {
	*shutter.Shutter
	// contains filtered or unexported fields
}

func New

func New(config *Config) *App

func (*App) IsReady

func (a *App) IsReady() bool

func (*App) Run

func (a *App) Run() error

type Config

type Config struct {
	SourcesAddr      []string
	GRPCListenAddr   string
	MergerAddr       string
	BufferSize       int
	MaxDrift         time.Duration
	MaxSourceLatency time.Duration
	MinStartOffset   uint64
	InitTime         time.Duration
	SourceStoreURL   string
}