session

type Body struct {
	Data  []byte `json:"data,omitempty"`
	ReqID string `json:"req_id,omitempty"`
}

type BootstrapRequest struct {
	// TimeoutInSeconds is the timeout for the bootstrap script.
	// If not set, the default timeout is 10 seconds.
	TimeoutInSeconds int `json:"timeout_in_seconds,omitempty"`

	// ScriptBase64 is the base64 encoded script to run.
	ScriptBase64 string `json:"script_base64,omitempty"`
}

type BootstrapResponse struct {
	Output   string `json:"output,omitempty"`
	ExitCode int32  `json:"exit_code,omitempty"`
}

type DiagnosticAcceptedResponse struct {
	Accepted bool   `json:"accepted"`
	Reason   string `json:"reason,omitempty"`
}

type DiagnosticRequest struct {
	ReportID       string `json:"report_id"`
	Type           string `json:"type"`
	TimeoutSeconds int64  `json:"timeout_seconds,omitempty"`
}

type KAPMTLSCredentialsRequest struct {
	CertificatePEM       []byte `json:"certificate_pem"`
	PrivateKeyPEM        []byte `json:"private_key_pem"`
	GatewayCAPEM         []byte `json:"gateway_ca_pem"`
	GatewayEndpoint      string `json:"gateway_endpoint"`
	ServerName           string `json:"server_name"`
	ClientCAFingerprint  string `json:"client_ca_fingerprint"`
	GatewayCAFingerprint string `json:"gateway_ca_fingerprint"`
}

type KAPMTLSStatus struct {
	CredentialsInstalled bool      `json:"credentials_installed"`
	CertificateSerial    string    `json:"certificate_serial,omitempty"`
	CertificateNotAfter  time.Time `json:"certificate_not_after,omitempty"`
	AgentInstalled       bool      `json:"agent_installed"`
	AgentActive          bool      `json:"agent_active"`
	AgentReady           bool      `json:"agent_ready"`
	AgentVersion         string    `json:"agent_version,omitempty"`
	GatewayEndpoint      string    `json:"gateway_endpoint,omitempty"`
	ServerName           string    `json:"server_name,omitempty"`
	ClientCAFingerprint  string    `json:"client_ca_fingerprint,omitempty"`
	GatewayCAFingerprint string    `json:"gateway_ca_fingerprint,omitempty"`
}

type KubeletCredentials struct {
	// Config is the kubelet configuration, which carries the providerID.
	Config *NodeCredentialFile `json:"config,omitempty"`
	// ClientCertificate is the client certificate and its private key, in the
	// single file kubelet reads them from.
	ClientCertificate *NodeCredentialFile `json:"client_certificate,omitempty"`
}

type NodeCredentialFile struct {
	// Path is absolute and must fall under an allowed prefix.
	Path string `json:"path"`
	// Contents is the file body. Empty contents are rejected: a credential
	// truncated to nothing looks like a successful write to the caller and
	// fails much later, wherever the file is actually read.
	Contents []byte `json:"contents"`
	// Mode defaults to 0600 when zero.
	Mode uint32 `json:"mode,omitempty"`
}

type NodeCredentialsRequest struct {
	// Kubelet is the material a kubelet needs to register.
	Kubelet *KubeletCredentials `json:"kubelet,omitempty"`
}

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

type OpOption func(*Op)

type Protocol string

type Request struct {
	Method        string            `json:"method,omitempty"`
	Components    []string          `json:"components,omitempty"`
	StartTime     time.Time         `json:"start_time"`
	EndTime       time.Time         `json:"end_time"`
	Since         time.Duration     `json:"since"`
	UpdateVersion string            `json:"update_version,omitempty"`
	UpdateConfig  map[string]string `json:"update_config,omitempty"`

	Bootstrap          *BootstrapRequest         `json:"bootstrap,omitempty"`
	InjectFaultRequest *pkgfaultinjector.Request `json:"inject_fault_request,omitempty"`
	Diagnostic         *DiagnosticRequest        `json:"diagnostic,omitempty"`

	// ComponentName is the name of the component to query or deregister.
	ComponentName string `json:"component_name,omitempty"`

	// TagName is the tag of the component to trigger check.
	// Optional. If set, it triggers all the component checks
	// that match this tag value.
	TagName string `json:"tag_name,omitempty"`

	// CustomPluginSpecs is the specs for the custom plugins to register or overwrite.
	CustomPluginSpecs pkgcustomplugins.Specs `json:"custom_plugin_specs,omitempty"`

	// Token is the new token to update on the agent side.
	Token string `json:"token,omitempty"`

	// KAPMTLSCredentials carries short-lived client credentials for the
	// node-local KAP mTLS agent. The private key must never be logged.
	KAPMTLSCredentials *KAPMTLSCredentialsRequest `json:"kap_mtls_credentials,omitempty"`

	// NodeCredentials carries credential material the control plane places on
	// the node, with the destination of each file in the request. Private keys
	// travel here, so it must never be logged.
	NodeCredentials *NodeCredentialsRequest `json:"node_credentials,omitempty"`
}

type Response struct {
	// Error is the error message from session processor.
	// don't use "error" type as it doesn't marshal/unmarshal well
	Error string `json:"error,omitempty"`
	// ErrorCode is the error code from session processor.
	// It uses the same semantics as the HTTP status code.
	// See: https://www.iana.org/assignments/http-status-codes/http-status-codes.xhtml
	ErrorCode int32 `json:"error_code,omitempty"`

	GossipRequest *apiv1.GossipRequest `json:"gossip_request,omitempty"`

	States  apiv1.GPUdComponentHealthStates `json:"states,omitempty"`
	Events  apiv1.GPUdComponentEvents       `json:"events,omitempty"`
	Metrics apiv1.GPUdComponentMetrics      `json:"metrics,omitempty"`

	Bootstrap  *BootstrapResponse          `json:"bootstrap,omitempty"`
	Diagnostic *DiagnosticAcceptedResponse `json:"diagnostic,omitempty"`

	PackageStatus []apiv1.PackageStatus `json:"package_status,omitempty"`

	// CustomPluginSpecs lists the specs for the custom plugins.
	CustomPluginSpecs pkgcustomplugins.Specs `json:"custom_plugin_specs,omitempty"`

	// Token is the current token value from the agent.
	Token string `json:"token,omitempty"`

	// KAPMTLSStatus contains only non-secret credential and process metadata.
	KAPMTLSStatus *KAPMTLSStatus `json:"kap_mtls_status,omitempty"`
}

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