fluxdb

Documentation

Index

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

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 {
	StoreDSN           string // Storage connection string
	EnableLivePipeline bool   // connecs to a live source, can be turn off when doing re-processing
	BlockStreamAddr    string // gRPC endpoint to get real-time blocks
	ThreadsNum         int    // Number of threads of parallel processing
	EnableServerMode   bool   // Enables flux server mode, launch a server
	EnableInjectMode   bool   // Enables flux inject mode, writes into kvd
	HTTPListenAddr     string // Address to server FluxDB queries on
	EnableDevMode      bool   // Set to true to have a fluxdb not syncing with an actual live block source (**never** use this in prod)
	BlockStoreURL      string // dbin blocks store
}