agentserver

type CertificateHandler interface {
	HandleAgentEvent(ctx context.Context, agentID string, ev *agentpb.CertificateInfo) error
}

type ContainerHandler interface {
	HandleAgentEvent(ctx context.Context, agentID string, ev *agentpb.ContainerEvent) error
}

type Deps struct {
	AgentStore  *sqlite.AgentStore
	Broadcaster EventBroadcaster
	Sessions    *Sessions
	Limiter     *Limiter
	Dispatcher  *Dispatcher
	Logger      *slog.Logger
}

type DispatchDeps struct {
	Container   ContainerHandler
	Endpoint    EndpointHandler
	Heartbeat   HeartbeatHandler
	Resource    ResourceHandler
	Certificate CertificateHandler
	Swarm       SwarmTopologyHandler
	Kubernetes  KubernetesTopologyHandler
	// LabelSync, if set, provisions endpoint/cert monitors from a container's
	// labels after each container event. Optional (nil = no label discovery).
	LabelSync LabelSyncFunc
}

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

type EndpointHandler interface {
	HandleAgentEvent(ctx context.Context, agentID string, ev *agentpb.EndpointEvent) error
}

type EventBroadcaster interface {
	BroadcastEvent(eventType string, data any)
}

type HeartbeatHandler interface {
	HandleAgentEvent(ctx context.Context, agentID string, ev *agentpb.HeartbeatEvent) error
}

type KubernetesTopologyHandler interface {
	HandleAgentEvent(ctx context.Context, agentID string, ev *agentpb.KubernetesTopology) error
}

type LabelSyncFunc func(ctx context.Context, agentID, containerName, externalID string, labels map[string]string)

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

type PublicURLConfig struct {
	// Explicit override from MAINTENANT_GRPC_URL env or --grpc-url flag.
	// If non-empty, it is used as-is (after ensuring the grpcs:// scheme).
	Explicit string

	// ListenAddr is the address the gRPC server is bound to (e.g. "127.0.0.1:8443").
	// Used as fallback when neither Explicit nor request headers are available.
	ListenAddr string
}

type ResourceHandler interface {
	HandleAgentEvent(ctx context.Context, agentID string, ev *agentpb.ResourceSample) error
}

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

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

type StaleAgentsFn func(ctx context.Context, threshold time.Duration) ([]string, error)

type SwarmTopologyHandler interface {
	HandleAgentEvent(ctx context.Context, agentID string, ev *agentpb.SwarmTopology) error
}