observability

type BoundPort struct {
	Addr netip.Addr
	Port int
}

type DebugLogWriter struct {
	Log *slog.Logger
}

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

type LogEntry struct {
	Timestamp  time.Time
	Stream     LogStream
	TraceID    string
	Attributes map[string]string
	Body       string
}

type LogReader struct {
	Address string        `asm:"victorialogs-address"`
	Timeout time.Duration `asm:"victorialogs-timeout"`
	// contains filtered or unexported fields
}

type LogReaderOption func(*logReadOpts)

type LogStream string

type LogTarget struct {
	EntityID  string
	SandboxID string
}

type LogWriter interface {
	WriteEntry(entity string, le LogEntry) error
}

type LogsMaintainer struct {
}

type PersistentLogReader struct {
	Address string        `asm:"victorialogs-address"`
	Timeout time.Duration `asm:"victorialogs-timeout"`
	// contains filtered or unexported fields
}

type PersistentLogWriter struct {
	Address string        `asm:"victorialogs-address"`
	Timeout time.Duration `asm:"victorialogs-timeout"`
	// contains filtered or unexported fields
}

type PortStatus string

type PortTracker interface {
	SetPortStatus(containerID string, bp BoundPort, status PortStatus)
}

type ResourcesMonitor struct {
	Writer *metrics.VictoriaMetricsWriter `asm:"victoriametrics-writer"`
	Reader *metrics.VictoriaMetricsReader `asm:"victoriametrics-reader"`
	Log    *slog.Logger
}

type StatusMonitor struct {
	Log *slog.Logger
	// contains filtered or unexported fields
}