application

type Config ¶

type Config = config.Config

type HTTPObservation ¶

type HTTPObservation struct {
	Method    string
	Status    int
	ErrorKind string
	Duration  time.Duration
}

Readiness probes are excluded from HTTP observations and counters. HTTPObservation contains only bounded labels, never request or response data. Method is a known RPC method or "unknown" (also used for non-RPC requests). ErrorKind is empty on success; Status is the HTTP response status, so a JSON-RPC failure can have Status 200 and a nonempty ErrorKind. Duration measures handling time, excluding the observer itself.

type HookEvent ¶

type HookEvent = ports.HookEvent

type MaintenanceObservation ¶

type MaintenanceObservation struct {
	ErrorKind string
	Duration  time.Duration
}

MaintenanceObservation describes one complete Maintain call, including the startup call. ErrorKind is empty on success and never contains error text.

type Options ¶

type Options struct {
	Key                []byte
	Clock              func() time.Time
	Hook               func(HookEvent) error
	DisableMaintenance bool
	// Observers run synchronously after transactions release their locks. They must
	// be concurrency-safe and return promptly. Observer panics are isolated.
	ObserveHTTP        func(HTTPObservation)
	ObserveMaintenance func(MaintenanceObservation)
}

type Service ¶

type Service struct {
	// contains filtered or unexported fields
}

func Open(path string, cfg *Config, opts Options) (*Service, error)

func (s *Service) AuthorityID() string

func (s *Service) Close() error

func (s *Service) Handler() http.Handler

func (s *Service) ImportConfig(ctx context.Context, cfg Config) error

func (s *Service) Maintain(ctx context.Context) (err error)

func (s *Service) Stats() Stats

type Stats ¶

type Stats struct {
	TotalRequests       uint64
	Errors              uint64
	MaintenanceRuns     uint64
	MaintenanceFailures uint64
}

Stats is a process-local cumulative snapshot. Fields are individually atomic; concurrent activity may advance between field reads. Readiness is excluded.