gvisor

type Collector struct {
	// StopLookup and EmitStop are required when StopObservations is enabled.
	// StopLookup must accept a container that has just exited and a Pod that
	// is being deleted; the start lookup rejects both.
	StopLookup InventoryLookup
	EmitStop   func(context.Context, StopObservation)
	// contains filtered or unexported fields
}

type Health struct {
	Receiver         Stats  `json:"receiver"`
	Running          bool   `json:"running"`
	RecheckRejected  uint64 `json:"recheck_rejected"`
	ExportSubmitted  uint64 `json:"export_submitted"`
	ListenerFailures uint64 `json:"listener_failures"`
	// StopExportSubmitted + StopRecheckRejected == Receiver.StopCallbacksCompleted.
	StopRecheckRejected uint64 `json:"stop_recheck_rejected"`
	StopExportSubmitted uint64 `json:"stop_export_submitted"`
}

type Identity struct {
	ContainerID    string
	SandboxID      string
	RuntimeHandler string
	Namespace      string
	PodName        string
	PodUID         string
	ContainerName  string
}

type IntegrationConfig struct {
	Enabled         bool   `mapstructure:"enabled"`
	SocketPath      string `mapstructure:"socketPath"`
	RuntimeEndpoint string `mapstructure:"runtimeEndpoint"`
	RuntimeHandler  string `mapstructure:"runtimeHandler"`
	// StopObservations additionally exports stops matched to a verified start
	// on the same trace connection. It requires the runsc trace session to
	// select sentry/task_exit and sentry/exit_notify_parent, plus the
	// thread_id, group_id and thread_group_start_time context fields.
	StopObservations bool `mapstructure:"stopObservations"`
}

type InventoryLookup func(context.Context, string) (Identity, error)

type Observation struct {
	Start
	Identity Identity
	Node     string
}

type Receiver struct {
	SocketPath string
	Resolve    Resolver
	OnStart    StartHandler
	// OnStop is optional. When nil, exit points are ignored as before. When
	// set, the receiver matches exits against verified starts on the same
	// connection and never infers a stop from a closed connection.
	OnStop StopHandler
	// contains filtered or unexported fields
}

type Resolver func(containerID string) bool

type Start struct {
	Source      string
	ContainerID string
	ObservedAt  time.Time
	Dropped     uint32 // Cumulative sender-reported drop count on this connection.
	// contains filtered or unexported fields
}

type StartHandler func(context.Context, Start)

type Stats struct {
	ActiveConnections   int64  `json:"active_connections"`
	Listening           bool   `json:"listening"`
	CanceledStarts      uint64 `json:"canceled_starts"`
	AcceptedConnections uint64 `json:"accepted_connections"`
	RejectedConnections uint64 `json:"rejected_connections"`
	ClosedConnections   uint64 `json:"closed_connections"`
	Handshakes          uint64 `json:"handshakes"`
	HandshakeErrors     uint64 `json:"handshake_errors"`
	ReceivedFrames      uint64 `json:"received_frames"`
	ReadErrors          uint64 `json:"read_errors"`
	InterruptedReads    uint64 `json:"interrupted_reads"`
	InvalidFrames       uint64 `json:"invalid_frames"`
	UnresolvedStarts    uint64 `json:"unresolved_starts"`
	IgnoredFrames       uint64 `json:"ignored_frames"`
	VerifiedStarts      uint64 `json:"verified_starts"`
	CallbacksCompleted  uint64 `json:"callbacks_completed"`
	SenderDropFrames    uint64 `json:"sender_drop_frames"`
	QueueDrops          uint64 `json:"queue_drops"`

	// Stop matching, populated only when OnStop is set. VerifiedStops equals
	// StopQueueDrops + CanceledStops + StopCallbacksCompleted after Run returns.
	VerifiedStops          uint64 `json:"verified_stops"`
	DuplicateTerminals     uint64 `json:"duplicate_terminals"`
	NonterminalExits       uint64 `json:"nonterminal_exits"`
	UnobservedTerminations uint64 `json:"unobserved_terminations"`
	StopKeyMissing         uint64 `json:"stop_key_missing"`
	StopTrackingOverflow   uint64 `json:"stop_tracking_overflow"`
	StopQueueDrops         uint64 `json:"stop_queue_drops"`
	CanceledStops          uint64 `json:"canceled_stops"`
	StopCallbacksCompleted uint64 `json:"stop_callbacks_completed"`
}

type Stop struct {
	Source      string
	ContainerID string
	ObservedAt  time.Time
	Dropped     uint32 // Cumulative sender-reported drop count on this connection.
	ExitCode    int    // CRI-style: the exit code, or 128+signal when signaled.
	Signal      int    // Terminating signal, or zero for a normal exit.
}

type StopHandler func(context.Context, Stop)

type StopObservation struct {
	Stop
	Identity Identity
	Node     string
}