activities

type AgentActivities struct {
	// Tunnel is the agent's gRPC connection to the FallBCK server (carrying its bearer
	// token); PBS backup sessions are opened through it.
	Tunnel grpc.ClientConnInterface
	// Workers bounds concurrent chunk uploads (0 = default)
	Workers int
	// Credentials fetches PBS connection details for jobs in direct mode
	// (GET /api/v1/agents/pbs-credentials with the run's ticket)
	Credentials func(ctx context.Context, ticket string) (*backup.DirectOptions, error)
	// LogTail returns the agent's recent log output, attached to failures
	LogTail func() string
}

type DBAgentActivities struct {
	// Tunnel is the agent's gRPC connection to the FallBCK server (PBS sessions)
	Tunnel grpc.ClientConnInterface
	// Workers bounds concurrent chunk uploads (0 = default)
	Workers int
	// Credentials fetches PBS connection details for jobs in direct mode
	Credentials func(ctx context.Context, ticket string) (*backup.DirectOptions, error)
	// DBPassword fetches the server-stored database password for a run
	DBPassword func(ctx context.Context, ticket string) (string, error)
	// Config is the agent's db_backup configuration (defaults applied)
	Config   dbbackup.Config
	Hostname string
	Version  string
	// LogTail returns the agent's recent log output, attached to failures
	LogTail func() string
}

type K8sAgentActivities struct {
	// Tunnel is the agent's gRPC connection to the FallBCK server (resources upload)
	Tunnel grpc.ClientConnInterface
	// Clients are the in-cluster API clients
	Clients *k8sagent.Clients
	// Config supplies the server URL / TLS settings handed to worker pods
	Config      *config.AgentConfig
	ClusterName string
	// AgentNamespace is the namespace the agent pod runs in
	AgentNamespace string
	Version        string
	// Worker pod parameters (from the Helm chart)
	WorkerImage               string
	WorkerImagePullPolicy     string
	WorkerResourcesJSON       string
	WorkerSecurityContextJSON string
	// Credentials fetches PBS connection details for jobs in direct mode
	Credentials func(ctx context.Context, ticket string) (*backup.DirectOptions, error)
	// VolumeTicket mints a per-volume backup ticket from the session ticket
	VolumeTicket func(ctx context.Context, sessionTicket, volumeBackupID string) (string, error)
	// WorkerToken mints a short-lived agent bearer for worker pods
	WorkerToken func(ctx context.Context, sessionTicket string) (string, time.Time, error)
	// SpoolDir stages the resource dump (default <data dir>/spool)
	SpoolDir string
	// LogTail returns the agent's recent log output, attached to failures
	LogTail func() string

	// Runs tracks in-flight run ids for the orphan sweep. It lives in a named field:
	// worker.RegisterActivity(struct) validates every exported *method* of the struct,
	// so helpers must not be methods on K8sAgentActivities.
	Runs *RunTracker
	// contains filtered or unexported fields
}

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

type ServerActivities struct {
	DB           *db.DB
	Config       *config.ServerConfig
	TokenManager *auth.TokenManager
}