Proof-of-concept draft for teleport-update binary implementation

api/client/webclient/webclient.go

@@ -68,6 +68,9 @@ type Config struct {
 	Timeout time.Duration
 	// TraceProvider is used to retrieve a Tracer for creating spans
 	TraceProvider oteltrace.TracerProvider
+	// Group is an optional agent group identifier that modulates
+	// the returned desired agent version update information.
+	Group string
 }
 
 // CheckAndSetDefaults checks and sets defaults
@@ -171,6 +174,10 @@ func Find(cfg *Config) (*PingResponse, error) {
 
 	endpoint := fmt.Sprintf("https://%s/webapi/find", cfg.ProxyAddr)
 
+	if cfg.Group != "" {
+		endpoint = fmt.Sprintf("%s?group=%s", endpoint, cfg.Group)
+	}
+
 	req, err := http.NewRequestWithContext(ctx, http.MethodGet, endpoint, nil)
 	if err != nil {
 		return nil, trace.Wrap(err)
@@ -295,6 +302,8 @@ type PingResponse struct {
 	Proxy ProxySettings `json:"proxy"`
 	// ServerVersion is the version of Teleport that is running.
 	ServerVersion string `json:"server_version"`
+	// ServerVersion is the version of Teleport that is running.
+	ServerEdition string `json:"server_edition"`
 	// MinClientVersion is the minimum client version required by the server.
 	MinClientVersion string `json:"min_client_version"`
 	// ClusterName contains the name of the Teleport cluster.
@@ -303,6 +312,13 @@ type PingResponse struct {
 	// reserved: license_warnings ([]string)
 	// AutomaticUpgrades describes whether agents should automatically upgrade.
 	AutomaticUpgrades bool `json:"automatic_upgrades"`
+
+	// AgentAutoupdate specifies whether an agent should update now (not implemented).
+	AgentAutoupdate bool `json:"agent_autoupdate"`
+	// AgentVersion contains the target agent version (not implemented).
+	AgentVersion string `json:"agent_version"`
+	// AgentUpdateJitterSeconds specifies the amount of jitter to wait before updating (not implemented).
+	AgentUpdateJitterSeconds int `json:"agent_update_jitter_seconds"`
 }
 
 // PingErrorResponse contains the error from /webapi/ping.

constants.go

@@ -280,6 +280,9 @@ const (
 	// ComponentProxySecureGRPC represents a secure gRPC server running on Proxy (used for Kube).
 	ComponentProxySecureGRPC = "proxy:secure-grpc"
 
+	// ComponentUpdater represents the agent updater.
+	ComponentUpdater = "updater"
+
 	// VerboseLogsEnvVar forces all logs to be verbose (down to DEBUG level)
 	VerboseLogsEnvVar = "TELEPORT_DEBUG"