Versions in this module Expand all Collapse all v1 v1.5.2 Jun 10, 2025 Changes in this version + func ConsoleLogger(logger logging.Logger) func(*Manager) + func EnablePrintStatements(yes bool) func(*Manager) + func GetCompilerOnContext(context *storage.Context) *ast.Compiler + func GracefulShutdownPeriod(gracefulShutdownPeriod int) func(*Manager) + func Info(term *ast.Term) func(*Manager) + func InitBundles(b map[string]*bundle.Bundle) func(*Manager) + func InitFiles(f loader.Result) func(*Manager) + func Logger(logger logging.Logger) func(*Manager) + func MaxErrors(n int) func(*Manager) + func PrintHook(h print.Hook) func(*Manager) + func SetCompilerOnContext(context *storage.Context, compiler *ast.Compiler) + func SetWasmResolversOnContext(context *storage.Context, rs []*wasm.Resolver) + func WithDistributedTracingOpts(tr tracing.Options) func(*Manager) + func WithEnableTelemetry(enableTelemetry bool) func(*Manager) + func WithHooks(hs hooks.Hooks) func(*Manager) + func WithParserOptions(opts ast.ParserOptions) func(*Manager) + func WithPrometheusRegister(prometheusRegister prometheus.Registerer) func(*Manager) + func WithRouter(r *http.ServeMux) func(*Manager) + func WithTelemetryGatherers(gs map[string]report.Gatherer) func(*Manager) + func WithTracerProvider(tracerProvider *trace.TracerProvider) func(*Manager) + type Factory interface + New func(manager *Manager, config any) Plugin + Validate func(manager *Manager, config []byte) (any, error) + type Manager struct + Config *config.Config + ID string + Info *ast.Term + Store storage.Store + func New(raw []byte, id string, store storage.Store, opts ...func(*Manager)) (*Manager, error) + func (m *Manager) AuthPlugin(name string) rest.HTTPAuthPlugin + func (m *Manager) Client(name string) rest.Client + func (m *Manager) ConsoleLogger() logging.Logger + func (m *Manager) DefaultServiceOpts(config *config.Config) cfg.ServiceOptions + func (m *Manager) EnablePrintStatements() bool + func (m *Manager) GetCompiler() *ast.Compiler + func (m *Manager) GetRouter() *http.ServeMux + func (m *Manager) GetWasmResolvers() []*wasm.Resolver + func (m *Manager) Init(ctx context.Context) error + func (m *Manager) InterQueryBuiltinCacheConfig() *cache.Config + func (m *Manager) Labels() map[string]string + func (m *Manager) Logger() logging.Logger + func (m *Manager) ParserOptions() ast.ParserOptions + func (m *Manager) Plugin(name string) Plugin + func (m *Manager) PluginStatus() map[string]*Status + func (m *Manager) Plugins() []string + func (m *Manager) PrintHook() print.Hook + func (m *Manager) PrometheusRegister() prometheus.Registerer + func (m *Manager) PublicKeys() map[string]*keys.Config + func (m *Manager) Reconfigure(config *config.Config) error + func (m *Manager) Register(name string, plugin Plugin) + func (m *Manager) RegisterCacheTrigger(trigger func(*cache.Config)) + func (m *Manager) RegisterCompilerTrigger(f func(storage.Transaction)) + func (m *Manager) RegisterNDCacheTrigger(trigger func(bool)) + func (m *Manager) RegisterPluginStatusListener(name string, listener StatusListener) + func (m *Manager) ServerInitialized() + func (m *Manager) ServerInitializedChannel() <-chan struct{} + func (m *Manager) Services() []string + func (m *Manager) Start(ctx context.Context) error + func (m *Manager) Stop(ctx context.Context) + func (m *Manager) TracerProvider() *trace.TracerProvider + func (m *Manager) UnregisterPluginStatusListener(name string) + func (m *Manager) UpdatePluginStatus(pluginName string, status *Status) + type Plugin interface + Reconfigure func(ctx context.Context, config any) + Start func(ctx context.Context) error + Stop func(ctx context.Context) + type State string + const StateErr + const StateNotReady + const StateOK + const StateWarn + type Status struct + Message string + State State + func (s *Status) Equal(other *Status) bool + func (s *Status) String() string + type StatusListener func(status map[string]*Status) + type TriggerMode string + const DefaultTriggerMode + const TriggerManual + const TriggerPeriodic + func ValidateAndInjectDefaultsForTriggerMode(a, b *TriggerMode) (*TriggerMode, error) + type Triggerable interface + Trigger func(context.Context) error
Go to main page