live

Documentation

Index

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

Variables

var LiveAppStartAborted = fmt.Errorf("getting start block aborted by live application")

Types

type App

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

func New

func New(config *Config, modules *Modules) *App

func (*App) IsReady

func (a *App) IsReady() bool

func (*App) Run

func (a *App) Run() error

type Config

type Config struct {
	ServiceVersion           string        // dmesh service version (v1)
	TierLevel                uint32        // level of the search tier
	GRPCListenAddr           string        // Address to listen for incoming gRPC requests
	PublishInterval          time.Duration // longest duration a dmesh peer will not publish
	BlockmetaAddr            string        // grpc address to blockmeta to decide if the chain is up-to-date
	BlocksStoreURL           string        // Path to read blocks archives
	BlockstreamAddr          string        // gRPC URL to reach a stream of blocks
	HeadDelayTolerance       uint64        // Number of blocks above a backend's head we allow a request query to be served (Live & Router)
	StartBlockDriftTolerance uint64        // Number of blocks behind LIB that the start block is allowed to be
	ShutdownDelay            time.Duration // On shutdown, time to wait before actually leaving, to try and drain connections
	LiveIndexesPath          string        // /tmp/live/indexes", "Location for live indexes (ideally a ramdisk)
	TruncationThreshold      int           //number of available dmesh peers that should serve irreversible blocks before we truncate them from this backend's memory
	RealtimeTolerance        time.Duration // longest delay to consider this service as real-time(ready) on initialization

}

type Modules

type Modules struct {
	BlockMapper search.BlockMapper
	Dmesh       dmeshClient.SearchClient
}