archive

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 {
	// dmesh configuration
	ServiceVersion          string        // dmesh service version (v1)
	TierLevel               uint32        // level of the search tier
	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
	EnableMovingTail        bool          // Enable moving t`ail, requires a relative --start-block (negative number)
	IndexesStoreURL         string        // location of indexes to download/open/serve
	IndexesPath             string        // location where to store the downloaded index files
	ReadOnlyIndexesPaths    []string      // list of paths where to load indexes on start
	ShardSize               uint64        // indexes shard size
	StartBlock              int64         // Start at given block num, the initial sync and polling
	StopBlock               uint64        // Stop before given block num, the initial sync and polling
	SyncFromStore           bool          // Download missing indexes from --indexes-store before starting
	SyncMaxIndexes          int           // Maximum number of indexes to sync. On production, use a very large number.
	IndicesDLThreads        int           // Number of indices files to download from the GS input store and decompress in parallel. In prod, use large value like 20.
	NumQueryThreads         int           // Number of end-user query parallel threads to query blocks indexes
	IndexPolling            bool          // Populate local indexes using indexes store polling.
	WarmupFilepath          string        // Optional filename containing queries to warm-up the search
	ShutdownDelay           time.Duration //On shutdown, time to wait before actually leaving, to try and drain connections
	EnableEmptyResultsCache bool          // Enable roaring-bitmap-based empty results caching
	MemcacheAddr            string        // Empty results cache's memcache server address
}

type Modules

type Modules struct {
	Dmesh dmeshClient.SearchClient
}