Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Registrar ¶
type Registrar struct {
// contains filtered or unexported fields
}
func (*Registrar) LogProvider ¶
func (r *Registrar) LogProvider() *otellog.LoggerProvider
LogProvider returns the OTEL log provider for the process log stream.
func (*Registrar) LogStreamID ¶
func (*Registrar) ProcessType ¶ added in v0.19.951
func (*Registrar) TracerProvider ¶ added in v0.19.915
func (r *Registrar) TracerProvider() oteltrace.TracerProvider
TracerProvider returns the process-scoped OTEL TracerProvider, falling back to the global if none was created. Callers should prefer this over otel.GetTracerProvider() because transitive deps (e.g. the docker distribution registry) call otel.SetTracerProvider during their init and silently overwrite the global, sending our spans to the default OTLP endpoint instead of the runner traces ingest endpoint.
type Result ¶
type Result struct {
fx.Out
Registrar *Registrar
ProcessLogProvider *otellog.LoggerProvider `name:"process-log-provider" optional:"true"`
ProcessTracerProvider *sdktrace.TracerProvider `name:"process-tracer-provider" optional:"true"`
}
type ShutdownPoller ¶
type ShutdownPoller struct {
// contains filtered or unexported fields
}
func NewShutdownPoller ¶
func NewShutdownPoller(params ShutdownPollerParams) *ShutdownPoller
type ShutdownPollerParams ¶
type ShutdownPollerParams struct {
fx.In
APIClient nuonrunner.Client
Cfg *internal.Config
L *zap.Logger `name:"system"`
LC fx.Lifecycle
Registrar *Registrar
Settings *settings.Settings
Shutdowner fx.Shutdowner
V *validator.Validate
// only provided in the mng process; nil in the install/run process.
Health *health.Server `optional:"true"`
}
Click to show internal directories.
Click to hide internal directories.