telemetry

type AckAgentActionsRequest struct {
	Ack []*AgentActionAck `json:"ack,omitempty"`
}

type AgentAction struct {
	ID        string          `json:"id"`
	Type      AgentActionType `json:"type"`
	CreatedAt time.Time       `json:"createdAt"`
	Data      json.RawMessage `json:"data"`
}

type AgentActionAck struct {
	ID    string  `json:"id"`
	Error *string `json:"error,omitempty"`
}

type AgentActionDeleteNode struct {
	NodeName string `json:"nodeName"`
}

type AgentActionDrainNode struct {
	NodeName            string `json:"nodeName"`
	DrainTimeoutSeconds int    `json:"drainTimeoutSeconds"`
	Force               bool   `json:"force"`
}

type AgentActionPatchNode struct {
	NodeName string            `json:"nodeName"`
	Labels   map[string]string `json:"labels"`
	Taints   []NodeTaint       `json:"taints"`
}

type AgentActionType string

type Client interface {
	GetActions(ctx context.Context, clusterID string) ([]*AgentAction, error)
	AckActions(ctx context.Context, clusterID string, ack []*AgentActionAck) error
}

type GetAgentActionsResponse struct {
	Actions []*AgentAction `json:"actions"`
}

type NodeTaint struct {
	Key    string `json:"key"`
	Value  string `json:"value"`
	Effect string `json:"effect"`
}