Documentation
¶
Index ¶
- func ShutdownTaskHandler()
- type Handler
- func (s *Handler) RenewTaskLease(ctx context.Context, in *pb.TaskLeaseRequest) (*pb.TaskLeaseResponse, error)
- func (s *Handler) ReportInstalledMods(ctx context.Context, in *pb.InstalledModsReport) (*pbModels.SSMEmpty, error)
- func (s *Handler) ReportTaskStatus(ctx context.Context, in *pb.TaskStatusReport) (*pbModels.SSMEmpty, error)
- func (s *Handler) SubscribeTasks(in *pb.SubscribeTasksRequest, stream pb.AgentTaskService_SubscribeTasksServer) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ShutdownTaskHandler ¶ added in v1.0.79
func ShutdownTaskHandler()
ShutdownTaskHandler closes every subscription so GracefulStop can complete. The agents reconnect to another replica; their leases are untouched.
Types ¶
type Handler ¶
type Handler struct {
pb.UnimplementedAgentTaskServiceServer
}
func (*Handler) RenewTaskLease ¶ added in v1.0.79
func (s *Handler) RenewTaskLease(ctx context.Context, in *pb.TaskLeaseRequest) (*pb.TaskLeaseResponse, error)
func (*Handler) ReportInstalledMods ¶ added in v1.0.79
func (s *Handler) ReportInstalledMods(ctx context.Context, in *pb.InstalledModsReport) (*pbModels.SSMEmpty, error)
ReportInstalledMods records what is actually in the agent's Mods directory. The agent is the only authority on that, so its own API key is the authz: it can only ever report for itself.
func (*Handler) ReportTaskStatus ¶ added in v1.0.79
func (*Handler) SubscribeTasks ¶ added in v1.0.79
func (s *Handler) SubscribeTasks(in *pb.SubscribeTasksRequest, stream pb.AgentTaskService_SubscribeTasksServer) error
SubscribeTasks holds the stream open for the agent's lifetime, forwarding assignments the dispatcher claims for it.
Status.Online is deliberately not touched here: it is owned by the state RPC pipeline, which fires integration events on transitions. This method only records which replica can reach the agent.
Source Files
Click to show internal directories.
Click to hide internal directories.