forkresolver

Documentation

Index

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

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)
	GRPCListenAddr  string        // Address to listen for incoming gRPC requests
	HttpListenAddr  string        // Address to listen for incoming http requests
	PublishInterval time.Duration // longest duration a dmesh peer will not publish
	IndicesPath     string        // Location for inflight indices
	BlocksStoreURL  string        // Path to read blocks archives
}

type Modules

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