Documentation
¶
Index ¶
- func AvailabilityAgentupgradesPath(name string) string
- func CancelAgentupgradesPath(name string, attemptID string) string
- func DecodeAvailabilityRequest(mux goahttp.Muxer, decoder func(*http.Request) goahttp.Decoder) func(*http.Request) (*agentupgrades.AvailabilityPayload, error)
- func DecodeCancelRequest(mux goahttp.Muxer, decoder func(*http.Request) goahttp.Decoder) func(*http.Request) (*agentupgrades.CancelPayload, error)
- func DecodeRollbackRequest(mux goahttp.Muxer, decoder func(*http.Request) goahttp.Decoder) func(*http.Request) (*agentupgrades.RollbackPayload, error)
- func DecodeStartRequest(mux goahttp.Muxer, decoder func(*http.Request) goahttp.Decoder) func(*http.Request) (*agentupgrades.AgentUpgradeStartPayload, error)
- func DecodeStatusRequest(mux goahttp.Muxer, decoder func(*http.Request) goahttp.Decoder) func(*http.Request) (*agentupgrades.StatusPayload, error)
- func EncodeAvailabilityError(encoder func(context.Context, http.ResponseWriter) goahttp.Encoder, ...) func(context.Context, http.ResponseWriter, error) error
- func EncodeAvailabilityResponse(encoder func(context.Context, http.ResponseWriter) goahttp.Encoder) func(context.Context, http.ResponseWriter, any) error
- func EncodeCancelError(encoder func(context.Context, http.ResponseWriter) goahttp.Encoder, ...) func(context.Context, http.ResponseWriter, error) error
- func EncodeCancelResponse(encoder func(context.Context, http.ResponseWriter) goahttp.Encoder) func(context.Context, http.ResponseWriter, any) error
- func EncodeRollbackError(encoder func(context.Context, http.ResponseWriter) goahttp.Encoder, ...) func(context.Context, http.ResponseWriter, error) error
- func EncodeRollbackResponse(encoder func(context.Context, http.ResponseWriter) goahttp.Encoder) func(context.Context, http.ResponseWriter, any) error
- func EncodeStartError(encoder func(context.Context, http.ResponseWriter) goahttp.Encoder, ...) func(context.Context, http.ResponseWriter, error) error
- func EncodeStartResponse(encoder func(context.Context, http.ResponseWriter) goahttp.Encoder) func(context.Context, http.ResponseWriter, any) error
- func EncodeStatusError(encoder func(context.Context, http.ResponseWriter) goahttp.Encoder, ...) func(context.Context, http.ResponseWriter, error) error
- func EncodeStatusResponse(encoder func(context.Context, http.ResponseWriter) goahttp.Encoder) func(context.Context, http.ResponseWriter, any) error
- func Mount(mux goahttp.Muxer, h *Server)
- func MountAvailabilityHandler(mux goahttp.Muxer, h http.Handler)
- func MountCancelHandler(mux goahttp.Muxer, h http.Handler)
- func MountRollbackHandler(mux goahttp.Muxer, h http.Handler)
- func MountStartHandler(mux goahttp.Muxer, h http.Handler)
- func MountStatusHandler(mux goahttp.Muxer, h http.Handler)
- func NewAvailabilityHandler(endpoint goa.Endpoint, mux goahttp.Muxer, ...) http.Handler
- func NewAvailabilityPayload(name string, namespace string) *agentupgrades.AvailabilityPayload
- func NewCancelHandler(endpoint goa.Endpoint, mux goahttp.Muxer, ...) http.Handler
- func NewCancelPayload(name string, attemptID string, namespace string) *agentupgrades.CancelPayload
- func NewRollbackHandler(endpoint goa.Endpoint, mux goahttp.Muxer, ...) http.Handler
- func NewRollbackPayload(name string, attemptID string, namespace string) *agentupgrades.RollbackPayload
- func NewStartAgentUpgradeStartPayload(body *StartRequestBody, name string, namespace string) *agentupgrades.AgentUpgradeStartPayload
- func NewStartHandler(endpoint goa.Endpoint, mux goahttp.Muxer, ...) http.Handler
- func NewStatusHandler(endpoint goa.Endpoint, mux goahttp.Muxer, ...) http.Handler
- func NewStatusPayload(name string, attemptID string, namespace string) *agentupgrades.StatusPayload
- func RollbackAgentupgradesPath(name string, attemptID string) string
- func StartAgentupgradesPath(name string) string
- func StatusAgentupgradesPath(name string, attemptID string) string
- func ValidateStartRequestBody(body *StartRequestBody) (err error)
- type AvailabilityResponseBody
- type CancelResponseBody
- type MountPoint
- type RollbackResponseBody
- type Server
- type StartRequestBody
- type StartResponseBody
- type StatusResponseBody
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AvailabilityAgentupgradesPath ¶
AvailabilityAgentupgradesPath returns the URL path to the agentupgrades service availability HTTP endpoint.
func CancelAgentupgradesPath ¶
CancelAgentupgradesPath returns the URL path to the agentupgrades service cancel HTTP endpoint.
func DecodeAvailabilityRequest ¶
func DecodeAvailabilityRequest(mux goahttp.Muxer, decoder func(*http.Request) goahttp.Decoder) func(*http.Request) (*agentupgrades.AvailabilityPayload, error)
DecodeAvailabilityRequest returns a decoder for requests sent to the agentupgrades availability endpoint.
func DecodeCancelRequest ¶
func DecodeCancelRequest(mux goahttp.Muxer, decoder func(*http.Request) goahttp.Decoder) func(*http.Request) (*agentupgrades.CancelPayload, error)
DecodeCancelRequest returns a decoder for requests sent to the agentupgrades cancel endpoint.
func DecodeRollbackRequest ¶
func DecodeRollbackRequest(mux goahttp.Muxer, decoder func(*http.Request) goahttp.Decoder) func(*http.Request) (*agentupgrades.RollbackPayload, error)
DecodeRollbackRequest returns a decoder for requests sent to the agentupgrades rollback endpoint.
func DecodeStartRequest ¶
func DecodeStartRequest(mux goahttp.Muxer, decoder func(*http.Request) goahttp.Decoder) func(*http.Request) (*agentupgrades.AgentUpgradeStartPayload, error)
DecodeStartRequest returns a decoder for requests sent to the agentupgrades start endpoint.
func DecodeStatusRequest ¶
func DecodeStatusRequest(mux goahttp.Muxer, decoder func(*http.Request) goahttp.Decoder) func(*http.Request) (*agentupgrades.StatusPayload, error)
DecodeStatusRequest returns a decoder for requests sent to the agentupgrades status endpoint.
func EncodeAvailabilityError ¶
func EncodeAvailabilityError(encoder func(context.Context, http.ResponseWriter) goahttp.Encoder, formatter func(ctx context.Context, err error) goahttp.Statuser) func(context.Context, http.ResponseWriter, error) error
EncodeAvailabilityError returns an encoder for errors returned by the availability agentupgrades endpoint.
func EncodeAvailabilityResponse ¶
func EncodeAvailabilityResponse(encoder func(context.Context, http.ResponseWriter) goahttp.Encoder) func(context.Context, http.ResponseWriter, any) error
EncodeAvailabilityResponse returns an encoder for responses returned by the agentupgrades availability endpoint.
func EncodeCancelError ¶
func EncodeCancelError(encoder func(context.Context, http.ResponseWriter) goahttp.Encoder, formatter func(ctx context.Context, err error) goahttp.Statuser) func(context.Context, http.ResponseWriter, error) error
EncodeCancelError returns an encoder for errors returned by the cancel agentupgrades endpoint.
func EncodeCancelResponse ¶
func EncodeCancelResponse(encoder func(context.Context, http.ResponseWriter) goahttp.Encoder) func(context.Context, http.ResponseWriter, any) error
EncodeCancelResponse returns an encoder for responses returned by the agentupgrades cancel endpoint.
func EncodeRollbackError ¶
func EncodeRollbackError(encoder func(context.Context, http.ResponseWriter) goahttp.Encoder, formatter func(ctx context.Context, err error) goahttp.Statuser) func(context.Context, http.ResponseWriter, error) error
EncodeRollbackError returns an encoder for errors returned by the rollback agentupgrades endpoint.
func EncodeRollbackResponse ¶
func EncodeRollbackResponse(encoder func(context.Context, http.ResponseWriter) goahttp.Encoder) func(context.Context, http.ResponseWriter, any) error
EncodeRollbackResponse returns an encoder for responses returned by the agentupgrades rollback endpoint.
func EncodeStartError ¶
func EncodeStartError(encoder func(context.Context, http.ResponseWriter) goahttp.Encoder, formatter func(ctx context.Context, err error) goahttp.Statuser) func(context.Context, http.ResponseWriter, error) error
EncodeStartError returns an encoder for errors returned by the start agentupgrades endpoint.
func EncodeStartResponse ¶
func EncodeStartResponse(encoder func(context.Context, http.ResponseWriter) goahttp.Encoder) func(context.Context, http.ResponseWriter, any) error
EncodeStartResponse returns an encoder for responses returned by the agentupgrades start endpoint.
func EncodeStatusError ¶
func EncodeStatusError(encoder func(context.Context, http.ResponseWriter) goahttp.Encoder, formatter func(ctx context.Context, err error) goahttp.Statuser) func(context.Context, http.ResponseWriter, error) error
EncodeStatusError returns an encoder for errors returned by the status agentupgrades endpoint.
func EncodeStatusResponse ¶
func EncodeStatusResponse(encoder func(context.Context, http.ResponseWriter) goahttp.Encoder) func(context.Context, http.ResponseWriter, any) error
EncodeStatusResponse returns an encoder for responses returned by the agentupgrades status endpoint.
func MountAvailabilityHandler ¶
MountAvailabilityHandler configures the mux to serve the "agentupgrades" service "availability" endpoint.
func MountCancelHandler ¶
MountCancelHandler configures the mux to serve the "agentupgrades" service "cancel" endpoint.
func MountRollbackHandler ¶
MountRollbackHandler configures the mux to serve the "agentupgrades" service "rollback" endpoint.
func MountStartHandler ¶
MountStartHandler configures the mux to serve the "agentupgrades" service "start" endpoint.
func MountStatusHandler ¶
MountStatusHandler configures the mux to serve the "agentupgrades" service "status" endpoint.
func NewAvailabilityHandler ¶
func NewAvailabilityHandler( endpoint goa.Endpoint, mux goahttp.Muxer, decoder func(*http.Request) goahttp.Decoder, encoder func(context.Context, http.ResponseWriter) goahttp.Encoder, errhandler func(context.Context, http.ResponseWriter, error), formatter func(ctx context.Context, err error) goahttp.Statuser, ) http.Handler
NewAvailabilityHandler creates a HTTP handler which loads the HTTP request and calls the "agentupgrades" service "availability" endpoint.
func NewAvailabilityPayload ¶
func NewAvailabilityPayload(name string, namespace string) *agentupgrades.AvailabilityPayload
NewAvailabilityPayload builds a agentupgrades service availability endpoint payload.
func NewCancelHandler ¶
func NewCancelHandler( endpoint goa.Endpoint, mux goahttp.Muxer, decoder func(*http.Request) goahttp.Decoder, encoder func(context.Context, http.ResponseWriter) goahttp.Encoder, errhandler func(context.Context, http.ResponseWriter, error), formatter func(ctx context.Context, err error) goahttp.Statuser, ) http.Handler
NewCancelHandler creates a HTTP handler which loads the HTTP request and calls the "agentupgrades" service "cancel" endpoint.
func NewCancelPayload ¶
func NewCancelPayload(name string, attemptID string, namespace string) *agentupgrades.CancelPayload
NewCancelPayload builds a agentupgrades service cancel endpoint payload.
func NewRollbackHandler ¶
func NewRollbackHandler( endpoint goa.Endpoint, mux goahttp.Muxer, decoder func(*http.Request) goahttp.Decoder, encoder func(context.Context, http.ResponseWriter) goahttp.Encoder, errhandler func(context.Context, http.ResponseWriter, error), formatter func(ctx context.Context, err error) goahttp.Statuser, ) http.Handler
NewRollbackHandler creates a HTTP handler which loads the HTTP request and calls the "agentupgrades" service "rollback" endpoint.
func NewRollbackPayload ¶
func NewRollbackPayload(name string, attemptID string, namespace string) *agentupgrades.RollbackPayload
NewRollbackPayload builds a agentupgrades service rollback endpoint payload.
func NewStartAgentUpgradeStartPayload ¶
func NewStartAgentUpgradeStartPayload(body *StartRequestBody, name string, namespace string) *agentupgrades.AgentUpgradeStartPayload
NewStartAgentUpgradeStartPayload builds a agentupgrades service start endpoint payload.
func NewStartHandler ¶
func NewStartHandler( endpoint goa.Endpoint, mux goahttp.Muxer, decoder func(*http.Request) goahttp.Decoder, encoder func(context.Context, http.ResponseWriter) goahttp.Encoder, errhandler func(context.Context, http.ResponseWriter, error), formatter func(ctx context.Context, err error) goahttp.Statuser, ) http.Handler
NewStartHandler creates a HTTP handler which loads the HTTP request and calls the "agentupgrades" service "start" endpoint.
func NewStatusHandler ¶
func NewStatusHandler( endpoint goa.Endpoint, mux goahttp.Muxer, decoder func(*http.Request) goahttp.Decoder, encoder func(context.Context, http.ResponseWriter) goahttp.Encoder, errhandler func(context.Context, http.ResponseWriter, error), formatter func(ctx context.Context, err error) goahttp.Statuser, ) http.Handler
NewStatusHandler creates a HTTP handler which loads the HTTP request and calls the "agentupgrades" service "status" endpoint.
func NewStatusPayload ¶
func NewStatusPayload(name string, attemptID string, namespace string) *agentupgrades.StatusPayload
NewStatusPayload builds a agentupgrades service status endpoint payload.
func RollbackAgentupgradesPath ¶
RollbackAgentupgradesPath returns the URL path to the agentupgrades service rollback HTTP endpoint.
func StartAgentupgradesPath ¶
StartAgentupgradesPath returns the URL path to the agentupgrades service start HTTP endpoint.
func StatusAgentupgradesPath ¶
StatusAgentupgradesPath returns the URL path to the agentupgrades service status HTTP endpoint.
func ValidateStartRequestBody ¶
func ValidateStartRequestBody(body *StartRequestBody) (err error)
ValidateStartRequestBody runs the validations defined on StartRequestBody
Types ¶
type AvailabilityResponseBody ¶
type AvailabilityResponseBody struct {
// Platform policy admits agent upgrades
PolicyEnabled bool `form:"policy_enabled" json:"policy_enabled" xml:"policy_enabled"`
// Durable attempt/recording storage is ready
StorageAvailable bool `form:"storage_available" json:"storage_available" xml:"storage_available"`
// Workspace resolves as an eligible running Windows VM
WorkspaceEligible bool `form:"workspace_eligible" json:"workspace_eligible" xml:"workspace_eligible"`
// Fresh authenticated guest inventory is available (guest integration)
InventoryAvailable bool `form:"inventory_available" json:"inventory_available" xml:"inventory_available"`
// A start request would be admitted right now
Admissible bool `form:"admissible" json:"admissible" xml:"admissible"`
// Why start would be denied; empty when admissible
DenyReason string `form:"deny_reason" json:"deny_reason" xml:"deny_reason"`
// Reservation-holding attempt for this VM, when present
ActiveAttemptID *string `form:"active_attempt_id,omitempty" json:"active_attempt_id,omitempty" xml:"active_attempt_id,omitempty"`
// Resolved controller-owned VM UID, when eligible
VMUID *string `form:"vm_uid,omitempty" json:"vm_uid,omitempty" xml:"vm_uid,omitempty"`
}
AvailabilityResponseBody is the type of the "agentupgrades" service "availability" endpoint HTTP response body.
func NewAvailabilityResponseBody ¶
func NewAvailabilityResponseBody(res *agentupgradesviews.AgentUpgradeAvailabilityView) *AvailabilityResponseBody
NewAvailabilityResponseBody builds the HTTP response body from the result of the "availability" endpoint of the "agentupgrades" service.
type CancelResponseBody ¶
type CancelResponseBody struct {
// Server-minted attempt identifier
AttemptID string `form:"attempt_id" json:"attempt_id" xml:"attempt_id"`
Namespace string `form:"namespace" json:"namespace" xml:"namespace"`
WorkspaceName string `form:"workspace_name" json:"workspace_name" xml:"workspace_name"`
WorkspaceUID string `form:"workspace_uid" json:"workspace_uid" xml:"workspace_uid"`
// Controller-owned VM UID the reservation is bound to
VMUID string `form:"vm_uid" json:"vm_uid" xml:"vm_uid"`
// UID of the administrator that admitted the attempt
ActorID string `form:"actor_id" json:"actor_id" xml:"actor_id"`
// Attempt lifecycle state
State string `form:"state" json:"state" xml:"state"`
TargetID string `form:"target_id" json:"target_id" xml:"target_id"`
TargetManifestSha256 string `form:"target_manifest_sha256" json:"target_manifest_sha256" xml:"target_manifest_sha256"`
ExpectedInstalledInventorySha256 string `` /* 127-byte string literal not displayed */
// Whether the admitted attempt may run the bounded reboot sequence
AllowReboot bool `form:"allow_reboot" json:"allow_reboot" xml:"allow_reboot"`
// An administrator requested safe-boundary cancellation
CancelRequested bool `form:"cancel_requested" json:"cancel_requested" xml:"cancel_requested"`
// Linked execution admission record (recording authorization)
ExecutionID string `form:"execution_id" json:"execution_id" xml:"execution_id"`
// Protected attempt recording
RecordingID string `form:"recording_id" json:"recording_id" xml:"recording_id"`
// Independently authorized recording link
RecordingURL string `form:"recording_url" json:"recording_url" xml:"recording_url"`
// Canonical status URL for this attempt
StatusURL string `form:"status_url" json:"status_url" xml:"status_url"`
// Last reconciled guest journal sequence
JournalSequence uint64 `form:"journal_sequence" json:"journal_sequence" xml:"journal_sequence"`
// Pinned rollback predecessor target
PredecessorTargetID *string `form:"predecessor_target_id,omitempty" json:"predecessor_target_id,omitempty" xml:"predecessor_target_id,omitempty"`
// Pinned rollback predecessor manifest digest
PredecessorManifestSha256 *string `` /* 133-byte string literal not displayed */
// Bounded machine-readable failure code
ErrorCode *string `form:"error_code,omitempty" json:"error_code,omitempty" xml:"error_code,omitempty"`
// RFC3339 admission timestamp
AdmittedAt string `form:"admitted_at" json:"admitted_at" xml:"admitted_at"`
StagingAt *string `form:"staging_at,omitempty" json:"staging_at,omitempty" xml:"staging_at,omitempty"`
PreparedAt *string `form:"prepared_at,omitempty" json:"prepared_at,omitempty" xml:"prepared_at,omitempty"`
InstallingAt *string `form:"installing_at,omitempty" json:"installing_at,omitempty" xml:"installing_at,omitempty"`
AwaitingRebootAt *string `form:"awaiting_reboot_at,omitempty" json:"awaiting_reboot_at,omitempty" xml:"awaiting_reboot_at,omitempty"`
VerifyingAt *string `form:"verifying_at,omitempty" json:"verifying_at,omitempty" xml:"verifying_at,omitempty"`
RollbackRequestedAt *string `form:"rollback_requested_at,omitempty" json:"rollback_requested_at,omitempty" xml:"rollback_requested_at,omitempty"`
RollingBackAt *string `form:"rolling_back_at,omitempty" json:"rolling_back_at,omitempty" xml:"rolling_back_at,omitempty"`
TerminalAt *string `form:"terminal_at,omitempty" json:"terminal_at,omitempty" xml:"terminal_at,omitempty"`
UpdatedAt string `form:"updated_at" json:"updated_at" xml:"updated_at"`
}
CancelResponseBody is the type of the "agentupgrades" service "cancel" endpoint HTTP response body.
func NewCancelResponseBody ¶
func NewCancelResponseBody(res *agentupgradesviews.AgentUpgradeAttemptView) *CancelResponseBody
NewCancelResponseBody builds the HTTP response body from the result of the "cancel" endpoint of the "agentupgrades" service.
type MountPoint ¶
type MountPoint struct {
// Method is the name of the service method served by the mounted HTTP handler.
Method string
// Verb is the HTTP method used to match requests to the mounted handler.
Verb string
// Pattern is the HTTP request path pattern used to match requests to the
// mounted handler.
Pattern string
}
MountPoint holds information about the mounted endpoints.
type RollbackResponseBody ¶
type RollbackResponseBody struct {
// Server-minted attempt identifier
AttemptID string `form:"attempt_id" json:"attempt_id" xml:"attempt_id"`
Namespace string `form:"namespace" json:"namespace" xml:"namespace"`
WorkspaceName string `form:"workspace_name" json:"workspace_name" xml:"workspace_name"`
WorkspaceUID string `form:"workspace_uid" json:"workspace_uid" xml:"workspace_uid"`
// Controller-owned VM UID the reservation is bound to
VMUID string `form:"vm_uid" json:"vm_uid" xml:"vm_uid"`
// UID of the administrator that admitted the attempt
ActorID string `form:"actor_id" json:"actor_id" xml:"actor_id"`
// Attempt lifecycle state
State string `form:"state" json:"state" xml:"state"`
TargetID string `form:"target_id" json:"target_id" xml:"target_id"`
TargetManifestSha256 string `form:"target_manifest_sha256" json:"target_manifest_sha256" xml:"target_manifest_sha256"`
ExpectedInstalledInventorySha256 string `` /* 127-byte string literal not displayed */
// Whether the admitted attempt may run the bounded reboot sequence
AllowReboot bool `form:"allow_reboot" json:"allow_reboot" xml:"allow_reboot"`
// An administrator requested safe-boundary cancellation
CancelRequested bool `form:"cancel_requested" json:"cancel_requested" xml:"cancel_requested"`
// Linked execution admission record (recording authorization)
ExecutionID string `form:"execution_id" json:"execution_id" xml:"execution_id"`
// Protected attempt recording
RecordingID string `form:"recording_id" json:"recording_id" xml:"recording_id"`
// Independently authorized recording link
RecordingURL string `form:"recording_url" json:"recording_url" xml:"recording_url"`
// Canonical status URL for this attempt
StatusURL string `form:"status_url" json:"status_url" xml:"status_url"`
// Last reconciled guest journal sequence
JournalSequence uint64 `form:"journal_sequence" json:"journal_sequence" xml:"journal_sequence"`
// Pinned rollback predecessor target
PredecessorTargetID *string `form:"predecessor_target_id,omitempty" json:"predecessor_target_id,omitempty" xml:"predecessor_target_id,omitempty"`
// Pinned rollback predecessor manifest digest
PredecessorManifestSha256 *string `` /* 133-byte string literal not displayed */
// Bounded machine-readable failure code
ErrorCode *string `form:"error_code,omitempty" json:"error_code,omitempty" xml:"error_code,omitempty"`
// RFC3339 admission timestamp
AdmittedAt string `form:"admitted_at" json:"admitted_at" xml:"admitted_at"`
StagingAt *string `form:"staging_at,omitempty" json:"staging_at,omitempty" xml:"staging_at,omitempty"`
PreparedAt *string `form:"prepared_at,omitempty" json:"prepared_at,omitempty" xml:"prepared_at,omitempty"`
InstallingAt *string `form:"installing_at,omitempty" json:"installing_at,omitempty" xml:"installing_at,omitempty"`
AwaitingRebootAt *string `form:"awaiting_reboot_at,omitempty" json:"awaiting_reboot_at,omitempty" xml:"awaiting_reboot_at,omitempty"`
VerifyingAt *string `form:"verifying_at,omitempty" json:"verifying_at,omitempty" xml:"verifying_at,omitempty"`
RollbackRequestedAt *string `form:"rollback_requested_at,omitempty" json:"rollback_requested_at,omitempty" xml:"rollback_requested_at,omitempty"`
RollingBackAt *string `form:"rolling_back_at,omitempty" json:"rolling_back_at,omitempty" xml:"rolling_back_at,omitempty"`
TerminalAt *string `form:"terminal_at,omitempty" json:"terminal_at,omitempty" xml:"terminal_at,omitempty"`
UpdatedAt string `form:"updated_at" json:"updated_at" xml:"updated_at"`
}
RollbackResponseBody is the type of the "agentupgrades" service "rollback" endpoint HTTP response body.
func NewRollbackResponseBody ¶
func NewRollbackResponseBody(res *agentupgradesviews.AgentUpgradeAttemptView) *RollbackResponseBody
NewRollbackResponseBody builds the HTTP response body from the result of the "rollback" endpoint of the "agentupgrades" service.
type Server ¶
type Server struct {
Mounts []*MountPoint
Availability http.Handler
Start http.Handler
Status http.Handler
Cancel http.Handler
Rollback http.Handler
}
Server lists the agentupgrades service endpoint HTTP handlers.
func New ¶
func New( e *agentupgrades.Endpoints, mux goahttp.Muxer, decoder func(*http.Request) goahttp.Decoder, encoder func(context.Context, http.ResponseWriter) goahttp.Encoder, errhandler func(context.Context, http.ResponseWriter, error), formatter func(ctx context.Context, err error) goahttp.Statuser, ) *Server
New instantiates HTTP handlers for all the agentupgrades service endpoints using the provided encoder and decoder. The handlers are mounted on the given mux using the HTTP verb and path defined in the design. errhandler is called whenever a response fails to be encoded. formatter is used to format errors returned by the service methods prior to encoding. Both errhandler and formatter are optional and can be nil.
func (*Server) MethodNames ¶
MethodNames returns the methods served.
type StartRequestBody ¶
type StartRequestBody struct {
// Operator-approved immutable target
TargetID *string `form:"target_id,omitempty" json:"target_id,omitempty" xml:"target_id,omitempty"`
// Expected signed manifest digest for the target
TargetManifestSha256 *string `form:"target_manifest_sha256,omitempty" json:"target_manifest_sha256,omitempty" xml:"target_manifest_sha256,omitempty"`
// Client-observed VM UID; must match the current controller-owned UID
ExpectedVMUID *string `form:"expected_vm_uid,omitempty" json:"expected_vm_uid,omitempty" xml:"expected_vm_uid,omitempty"`
// Client-observed execution revocation epoch
ExpectedRevocationEpoch *uint64 `` /* 127-byte string literal not displayed */
// Client-observed installed inventory digest (re-verified before install)
ExpectedInstalledInventorySha256 *string `` /* 157-byte string literal not displayed */
// Client-chosen key; an identical replay returns the original attempt
IdempotencyKey *string `form:"idempotency_key,omitempty" json:"idempotency_key,omitempty" xml:"idempotency_key,omitempty"`
// Permit the recorded bounded reboot sequence
AllowReboot *bool `form:"allow_reboot,omitempty" json:"allow_reboot,omitempty" xml:"allow_reboot,omitempty"`
}
StartRequestBody is the type of the "agentupgrades" service "start" endpoint HTTP request body.
type StartResponseBody ¶
type StartResponseBody struct {
// Server-minted attempt identifier
AttemptID string `form:"attempt_id" json:"attempt_id" xml:"attempt_id"`
Namespace string `form:"namespace" json:"namespace" xml:"namespace"`
WorkspaceName string `form:"workspace_name" json:"workspace_name" xml:"workspace_name"`
WorkspaceUID string `form:"workspace_uid" json:"workspace_uid" xml:"workspace_uid"`
// Controller-owned VM UID the reservation is bound to
VMUID string `form:"vm_uid" json:"vm_uid" xml:"vm_uid"`
// UID of the administrator that admitted the attempt
ActorID string `form:"actor_id" json:"actor_id" xml:"actor_id"`
// Attempt lifecycle state
State string `form:"state" json:"state" xml:"state"`
TargetID string `form:"target_id" json:"target_id" xml:"target_id"`
TargetManifestSha256 string `form:"target_manifest_sha256" json:"target_manifest_sha256" xml:"target_manifest_sha256"`
ExpectedInstalledInventorySha256 string `` /* 127-byte string literal not displayed */
// Whether the admitted attempt may run the bounded reboot sequence
AllowReboot bool `form:"allow_reboot" json:"allow_reboot" xml:"allow_reboot"`
// An administrator requested safe-boundary cancellation
CancelRequested bool `form:"cancel_requested" json:"cancel_requested" xml:"cancel_requested"`
// Linked execution admission record (recording authorization)
ExecutionID string `form:"execution_id" json:"execution_id" xml:"execution_id"`
// Protected attempt recording
RecordingID string `form:"recording_id" json:"recording_id" xml:"recording_id"`
// Independently authorized recording link
RecordingURL string `form:"recording_url" json:"recording_url" xml:"recording_url"`
// Canonical status URL for this attempt
StatusURL string `form:"status_url" json:"status_url" xml:"status_url"`
// Last reconciled guest journal sequence
JournalSequence uint64 `form:"journal_sequence" json:"journal_sequence" xml:"journal_sequence"`
// Pinned rollback predecessor target
PredecessorTargetID *string `form:"predecessor_target_id,omitempty" json:"predecessor_target_id,omitempty" xml:"predecessor_target_id,omitempty"`
// Pinned rollback predecessor manifest digest
PredecessorManifestSha256 *string `` /* 133-byte string literal not displayed */
// Bounded machine-readable failure code
ErrorCode *string `form:"error_code,omitempty" json:"error_code,omitempty" xml:"error_code,omitempty"`
// RFC3339 admission timestamp
AdmittedAt string `form:"admitted_at" json:"admitted_at" xml:"admitted_at"`
StagingAt *string `form:"staging_at,omitempty" json:"staging_at,omitempty" xml:"staging_at,omitempty"`
PreparedAt *string `form:"prepared_at,omitempty" json:"prepared_at,omitempty" xml:"prepared_at,omitempty"`
InstallingAt *string `form:"installing_at,omitempty" json:"installing_at,omitempty" xml:"installing_at,omitempty"`
AwaitingRebootAt *string `form:"awaiting_reboot_at,omitempty" json:"awaiting_reboot_at,omitempty" xml:"awaiting_reboot_at,omitempty"`
VerifyingAt *string `form:"verifying_at,omitempty" json:"verifying_at,omitempty" xml:"verifying_at,omitempty"`
RollbackRequestedAt *string `form:"rollback_requested_at,omitempty" json:"rollback_requested_at,omitempty" xml:"rollback_requested_at,omitempty"`
RollingBackAt *string `form:"rolling_back_at,omitempty" json:"rolling_back_at,omitempty" xml:"rolling_back_at,omitempty"`
TerminalAt *string `form:"terminal_at,omitempty" json:"terminal_at,omitempty" xml:"terminal_at,omitempty"`
UpdatedAt string `form:"updated_at" json:"updated_at" xml:"updated_at"`
}
StartResponseBody is the type of the "agentupgrades" service "start" endpoint HTTP response body.
func NewStartResponseBody ¶
func NewStartResponseBody(res *agentupgradesviews.AgentUpgradeAttemptView) *StartResponseBody
NewStartResponseBody builds the HTTP response body from the result of the "start" endpoint of the "agentupgrades" service.
type StatusResponseBody ¶
type StatusResponseBody struct {
// Server-minted attempt identifier
AttemptID string `form:"attempt_id" json:"attempt_id" xml:"attempt_id"`
Namespace string `form:"namespace" json:"namespace" xml:"namespace"`
WorkspaceName string `form:"workspace_name" json:"workspace_name" xml:"workspace_name"`
WorkspaceUID string `form:"workspace_uid" json:"workspace_uid" xml:"workspace_uid"`
// Controller-owned VM UID the reservation is bound to
VMUID string `form:"vm_uid" json:"vm_uid" xml:"vm_uid"`
// UID of the administrator that admitted the attempt
ActorID string `form:"actor_id" json:"actor_id" xml:"actor_id"`
// Attempt lifecycle state
State string `form:"state" json:"state" xml:"state"`
TargetID string `form:"target_id" json:"target_id" xml:"target_id"`
TargetManifestSha256 string `form:"target_manifest_sha256" json:"target_manifest_sha256" xml:"target_manifest_sha256"`
ExpectedInstalledInventorySha256 string `` /* 127-byte string literal not displayed */
// Whether the admitted attempt may run the bounded reboot sequence
AllowReboot bool `form:"allow_reboot" json:"allow_reboot" xml:"allow_reboot"`
// An administrator requested safe-boundary cancellation
CancelRequested bool `form:"cancel_requested" json:"cancel_requested" xml:"cancel_requested"`
// Linked execution admission record (recording authorization)
ExecutionID string `form:"execution_id" json:"execution_id" xml:"execution_id"`
// Protected attempt recording
RecordingID string `form:"recording_id" json:"recording_id" xml:"recording_id"`
// Independently authorized recording link
RecordingURL string `form:"recording_url" json:"recording_url" xml:"recording_url"`
// Canonical status URL for this attempt
StatusURL string `form:"status_url" json:"status_url" xml:"status_url"`
// Last reconciled guest journal sequence
JournalSequence uint64 `form:"journal_sequence" json:"journal_sequence" xml:"journal_sequence"`
// Pinned rollback predecessor target
PredecessorTargetID *string `form:"predecessor_target_id,omitempty" json:"predecessor_target_id,omitempty" xml:"predecessor_target_id,omitempty"`
// Pinned rollback predecessor manifest digest
PredecessorManifestSha256 *string `` /* 133-byte string literal not displayed */
// Bounded machine-readable failure code
ErrorCode *string `form:"error_code,omitempty" json:"error_code,omitempty" xml:"error_code,omitempty"`
// RFC3339 admission timestamp
AdmittedAt string `form:"admitted_at" json:"admitted_at" xml:"admitted_at"`
StagingAt *string `form:"staging_at,omitempty" json:"staging_at,omitempty" xml:"staging_at,omitempty"`
PreparedAt *string `form:"prepared_at,omitempty" json:"prepared_at,omitempty" xml:"prepared_at,omitempty"`
InstallingAt *string `form:"installing_at,omitempty" json:"installing_at,omitempty" xml:"installing_at,omitempty"`
AwaitingRebootAt *string `form:"awaiting_reboot_at,omitempty" json:"awaiting_reboot_at,omitempty" xml:"awaiting_reboot_at,omitempty"`
VerifyingAt *string `form:"verifying_at,omitempty" json:"verifying_at,omitempty" xml:"verifying_at,omitempty"`
RollbackRequestedAt *string `form:"rollback_requested_at,omitempty" json:"rollback_requested_at,omitempty" xml:"rollback_requested_at,omitempty"`
RollingBackAt *string `form:"rolling_back_at,omitempty" json:"rolling_back_at,omitempty" xml:"rolling_back_at,omitempty"`
TerminalAt *string `form:"terminal_at,omitempty" json:"terminal_at,omitempty" xml:"terminal_at,omitempty"`
UpdatedAt string `form:"updated_at" json:"updated_at" xml:"updated_at"`
}
StatusResponseBody is the type of the "agentupgrades" service "status" endpoint HTTP response body.
func NewStatusResponseBody ¶
func NewStatusResponseBody(res *agentupgradesviews.AgentUpgradeAttemptView) *StatusResponseBody
NewStatusResponseBody builds the HTTP response body from the result of the "status" endpoint of the "agentupgrades" service.