agent

Documentation

Index

• Constants
• type ErrorDetails
• type ErrorType
• type Factory
  • func (f *Factory) IsProducingLeaderModules() bool
  • func (f *Factory) Name() string
  • func (f *Factory) New(config *modagent.Config) (modagent.Module, error)
  • func (f *Factory) StartStopPhase() modshared.ModuleStartStopPhase
• type MessageType
• type RequestPayload
• type ResponsePayload
• type Settings
• type TerminationProgress
• type WorkerSettings
• type WorkspaceAgentInfo
• type WorkspaceRailsInfo
• type WorkspaceUpdateType

Constants

const (
	WorkspaceUpdateTypePartial WorkspaceUpdateType = "partial"
	WorkspaceUpdateTypeFull    WorkspaceUpdateType = "full"

	WorkspaceStateTerminated string = "Terminated"
	WorkspaceStateError      string = "Error"

	TerminationProgressTerminating TerminationProgress = "Terminating"
	TerminationProgressTerminated  TerminationProgress = "Terminated"

	ErrorTypeApplier    ErrorType = "applier"
	ErrorTypeKubernetes ErrorType = "kubernetes"
)

Types

type ErrorDetails

type ErrorDetails struct {
	ErrorType    ErrorType `json:"error_type,omitempty"`
	ErrorMessage string    `json:"error_message,omitempty"`
}

type ErrorType

type ErrorType string

type Factory

type Factory struct {
}

func (*Factory) IsProducingLeaderModules

func (f *Factory) IsProducingLeaderModules() bool

func (*Factory) Name

func (f *Factory) Name() string

func (*Factory) New

func (f *Factory) New(config *modagent.Config) (modagent.Module, error)

func (*Factory) StartStopPhase

func (f *Factory) StartStopPhase() modshared.ModuleStartStopPhase

type MessageType

type MessageType string

type RequestPayload

type RequestPayload struct {
	UpdateType          WorkspaceUpdateType  `json:"update_type"`
	WorkspaceAgentInfos []WorkspaceAgentInfo `json:"workspace_agent_infos"`
}

type ResponsePayload

type ResponsePayload struct {
	WorkspaceRailsInfos []*WorkspaceRailsInfo `json:"workspace_rails_infos"`
	Settings            *Settings             `json:"settings"`
}

type Settings

type Settings struct {
	FullReconciliationIntervalSeconds    int `json:"full_reconciliation_interval_seconds"`
	PartialReconciliationIntervalSeconds int `json:"partial_reconciliation_interval_seconds"`
}

type TerminationProgress

type TerminationProgress string

type WorkerSettings

type WorkerSettings struct {
	FullReconciliationInterval    time.Duration
	PartialReconciliationInterval time.Duration
}

type WorkspaceAgentInfo

type WorkspaceAgentInfo struct {
	Name                    string              `json:"name"`
	Namespace               string              `json:"namespace,omitempty"`
	LatestK8sDeploymentInfo map[string]any      `json:"latest_k8s_deployment_info,omitempty"`
	TerminationProgress     TerminationProgress `json:"termination_progress,omitempty"`
	ErrorDetails            *ErrorDetails       `json:"error_details,omitempty"`
}

type WorkspaceRailsInfo

type WorkspaceRailsInfo struct {
	Name                      string `json:"name"`
	Namespace                 string `json:"namespace"`
	DeploymentResourceVersion string `json:"deployment_resource_version,omitempty"`
	ActualState               string `json:"actual_state,omitempty"`
	DesiredState              string `json:"desired_state,omitempty"`
	ConfigToApply             string `json:"config_to_apply,omitempty"`
}

type WorkspaceUpdateType

type WorkspaceUpdateType string