service

type ConfigChangedHandler func(ctx context.Context, changed func(string) bool) error

type Configurable interface {
	DefineConfig(name string, options ...cfg.Option) error
	Config(name string) (value string)
	SetConfig(name string, value any) error
	ResetConfig(name string) error

	SetOnConfigChanged(handler ConfigChangedHandler) error
}

type Executor interface {
	Go(ctx context.Context, f func(ctx context.Context) (err error)) error
	Parallel(jobs ...func() (err error)) error
}

type Identifier interface {
	ID() string
	Hostname() string
	Description() string
	Version() int
	Deployment() string
	Plane() string
	Locality() string
}

type Logger interface {
	LogDebug(ctx context.Context, msg string, args ...any)
	LogInfo(ctx context.Context, msg string, args ...any)
	LogWarn(ctx context.Context, msg string, args ...any)
	LogError(ctx context.Context, msg string, args ...any)
}

type Meter interface {
	IncrementCounter(ctx context.Context, name string, val float64, attributes ...any) (err error)
	RecordGauge(ctx context.Context, name string, val float64, attributes ...any) (err error)
	RecordHistogram(ctx context.Context, name string, val float64, attributes ...any) (err error)
}

type MeterDescriber interface {
	DescribeCounter(name string, desc string) (err error)
	DescribeGauge(name string, desc string) (err error)
	DescribeHistogram(name string, desc string, buckets []float64) (err error)

	SetOnObserveMetrics(handler ObserveMetricsHandler) error
}

type ObserveMetricsHandler func(ctx context.Context) error

type Publisher interface {
	Request(ctx context.Context, options ...pub.Option) (*http.Response, error)
	Publish(ctx context.Context, options ...pub.Option) <-chan *pub.Response
}

type PublisherSubscriber interface {
	Publisher
	Subscriber
}

type Resourcer interface {
	SetResFS(resFS fs.FS) error
	ResFS() fs.FS
}

type Service interface {
	Publisher
	Subscriber
	Logger
	MeterDescriber
	Meter
	Tracer
	StarterStopper
	Identifier
	Configurable
	Resourcer
	Ticker
	Timer
	Executor
}

type ShutdownHandler func(ctx context.Context) error

type StarterStopper interface {
	Startup(ctx context.Context) (err error)
	Shutdown(ctx context.Context) error
	IsStarted() bool
	Lifetime() context.Context

	SetHostname(hostname string) error
	SetDeployment(deployment string) error
	SetPlane(plane string) error

	SetOnStartup(handler StartupHandler) error
	SetOnShutdown(handler ShutdownHandler) error
}

type StartupHandler func(ctx context.Context) error

type Subscriber interface {
	Subscribe(method string, path string, handler sub.HTTPHandler, options ...sub.Option) (unsub func() (err error), err error)
}

type Ticker interface {
	StartTicker(name string, interval time.Duration, handler TickerHandler) error
}

type TickerHandler func(ctx context.Context) error

type Timer interface {
	Now(ctx context.Context) time.Time
	Sleep(ctx context.Context, duration time.Duration) bool
}

type Tracer interface {
	StartSpan(ctx context.Context, spanName string, opts ...trc.Option) (context.Context, trc.Span)
	Span(ctx context.Context) trc.Span
	ForceTrace(ctx context.Context)
}