agentapi

type ActionResponse struct {
	Success  bool             `json:"success"`
	Message  string           `json:"message,omitempty"`
	PBMFence *PBMRestartFence `json:"pbmFence,omitempty"`
}

type AgentBuild struct {
	Version string `json:"version"`
	Commit  string `json:"commit"`
	Build   string `json:"build"`
}

type BootstrapMember struct {
	ID       int      `json:"id"`
	Host     string   `json:"host"`
	Priority *float64 `json:"priority,omitempty"`
	Votes    *int     `json:"votes,omitempty"`
}

type BootstrapRequest struct {
	ReplSetName  string            `json:"replSetName"`
	Members      []BootstrapMember `json:"members"`
	UserAdmin    Credentials       `json:"userAdmin"`
	ConfigServer bool              `json:"configServer"`
}

type BootstrapResponse struct {
	Initialized bool `json:"initialized"`
	UserCreated bool `json:"userCreated"`
	// Primary redirects localhost-exception creation to the elected member.
	// Empty means credentials were created or verified on this invocation.
	Primary string `json:"primary,omitempty"`
}

type Certificate struct {
	CertPEM string `json:"certPEM"`
	KeyPEM  string `json:"keyPEM"`
}

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

type ClientOptions struct {
	BaseURL       string
	Token         string
	CAPEM         []byte
	Timeout       time.Duration
	EngineTimeout time.Duration
	DialContext   func(context.Context, string, string) (net.Conn, error)
	// DialInstanceContext authorizes and pins a runtime within the logical
	// member's namespace. Arguments are network, logical host:port and instance host.
	DialInstanceContext func(context.Context, string, string, string) (net.Conn, error)
}

type ContainerResources struct {
	// CPUCores are usable cores: the effective cgroup cpuset size, capped by
	// a cpu.max quota when one is set.
	CPUCores float64 `json:"cpuCores"`
	// MemoryBytes is the cgroup memory limit, or MemTotal without one.
	MemoryBytes uint64 `json:"memoryBytes"`
	// RootDiskBytes is the size of the filesystem mounted at /.
	RootDiskBytes uint64 `json:"rootDiskBytes"`
}

type Credentials struct {
	Username string `json:"username"`
	Password string `json:"password"`
	Database string `json:"database"`
}

type DiskUsage struct {
	TotalBytes uint64 `json:"totalBytes"`
	UsedBytes  uint64 `json:"usedBytes"`
	FreeBytes  uint64 `json:"freeBytes"`
}

type ErrorResponse struct {
	Error string `json:"error"`
}

type HTTPError struct {
	StatusCode              int
	Method, Action, Message string
}

type LogLine struct {
	Timestamp time.Time `json:"timestamp"`
	Process   string    `json:"process"`
	Stream    string    `json:"stream"`
	Message   string    `json:"message"`
	// Launch identity scopes retained process output to one supervised child.
	SupervisorSession string `json:"supervisorSession,omitempty"`
	Launch            uint64 `json:"launch,omitempty"`
	// ExitCode is populated in retained logs only after this launch is reaped.
	ExitCode *int `json:"exitCode,omitempty"`
}

type LogsResponse struct {
	Lines []LogLine `json:"lines"`
}

type Maintenance struct {
	Enabled bool `json:"enabled"`
}

type MemberConfig struct {
	Cluster               string                 `json:"cluster"`
	Member                string                 `json:"member"`
	Volume                *VolumeIdentity        `json:"volume,omitempty"`
	Engine                string                 `json:"engine,omitempty"`
	EngineSpec            json.RawMessage        `json:"engineSpec,omitempty"`
	Role                  string                 `json:"role"`
	ReplSetName           string                 `json:"replSetName"`
	Port                  int                    `json:"port"`
	ConfigDB              string                 `json:"configDB,omitempty"`
	ShardServer           bool                   `json:"shardServer,omitempty"`
	WiredTigerCacheSizeGB float64                `json:"wiredTigerCacheSizeGB,omitempty"`
	SlowOpThresholdMS     int64                  `json:"slowOpThresholdMS,omitempty"`
	EngineVersion         string                 `json:"engineVersion"`
	EngineConfig          string                 `json:"engineConfig"`
	Keyfile               string                 `json:"keyfile"`
	TLS                   TLSConfig              `json:"tls"`
	AgentTLS              Certificate            `json:"agentTLS"`
	SystemUsers           map[string]Credentials `json:"systemUsers"`
	PBMEnabled            bool                   `json:"pbmEnabled"`
	// PBMGoMemoryLimitBytes is the CP-derived Go runtime soft limit for the
	// next PBM child launch. Zero means an old/unknown budget, not unlimited RAM.
	PBMGoMemoryLimitBytes uint64   `json:"pbmGoMemoryLimitBytes,omitempty"`
	DesiredProcesses      []string `json:"desiredProcesses"`
	Maintenance           bool     `json:"maintenance"`
	ConfigVersion         int64    `json:"configVersion"`
	// CertificateReloadOnly requests identity publication without engine rollout.
	// The CP must first observe the matching agent capability.
	CertificateReloadOnly bool `json:"certificateReloadOnly,omitempty"`
}

type PBMRequest struct {
	Command   string          `json:"command"`
	RequestID string          `json:"requestID,omitempty"`
	Args      []string        `json:"args,omitempty"`
	Config    json.RawMessage `json:"config,omitempty"`
}

type PBMResponse struct {
	Output   json.RawMessage `json:"output,omitempty"`
	Stderr   string          `json:"stderr,omitempty"`
	ExitCode int             `json:"exitCode"`
}

type PBMRestartFence struct {
	OldExited    bool      `json:"oldExited"`
	PID          int       `json:"pid"`
	StartedAfter time.Time `json:"startedAfter"`
	MemberTime   time.Time `json:"memberTime"`
}

type ProcessAction struct {
	Process string `json:"process"`
	Action  string `json:"action"`
	// RequestID is stable across retries of one logical restart.
	RequestID string `json:"requestID,omitempty"`
	// RestoreCommandTS requests a PBM-only active fence with a member clock guard.
	RestoreCommandTS int64 `json:"restoreCommandTS,omitempty"`
}

type ProcessStatus struct {
	State     string     `json:"state"`
	PID       int        `json:"pid"`
	Restarts  int        `json:"restarts"`
	StartedAt *time.Time `json:"startedAt,omitempty"`
	ExitCode  *int       `json:"exitCode,omitempty"`
	Error     string     `json:"error,omitempty"`
	// SupervisorSession and Launch identify actual successful child launches.
	// A higher Launch in the same session proves the previous child was reaped;
	// unlike StartedAt, these identities do not compare wall clocks.
	SupervisorSession string `json:"supervisorSession,omitempty"`
	Launch            uint64 `json:"launch,omitempty"`
	// GoMemoryLimitBytes reports the limit configured at this child's launch;
	// changing desired configuration alone does not change a running process.
	GoMemoryLimitBytes uint64 `json:"goMemoryLimitBytes,omitempty"`
}

type Status struct {
	Agent           AgentBuild               `json:"agent"`
	Processes       map[string]ProcessStatus `json:"processes"`
	Volume          *VolumeStatus            `json:"volume,omitempty"`
	EngineVersion   string                   `json:"engineVersion"`
	ConfigVersion   int64                    `json:"configVersion"`
	Disk            DiskUsage                `json:"disk"`
	HostFingerprint string                   `json:"hostFingerprint"`
	Maintenance     bool                     `json:"maintenance"`
	UptimeSeconds   int64                    `json:"uptimeSeconds"`
	// PBMRestoreFence advertises supervised stop/wait/start confirmation.
	PBMRestoreFence bool `json:"pbmRestoreFence,omitempty"`
	// PBMRestoreIdentity advertises restore-scoped PBM authentication support.
	PBMRestoreIdentity bool `json:"pbmRestoreIdentity,omitempty"`
	// CertificateReloadOnly advertises reload-only native certificate application.
	CertificateReloadOnly bool `json:"certificateReloadOnly,omitempty"`
	// Error explains a blocked local recovery without making status unreachable.
	Error string `json:"error,omitempty"`
	// MongoReady observes authenticated router access to config-server metadata.
	// Nil means this agent did not observe router application readiness.
	MongoReady *bool  `json:"mongoReady,omitempty"`
	MongoError string `json:"mongoError,omitempty"`
	// Resources is what the container can currently use, read at request
	// time. Nil from agents that predate the field or could read nothing.
	Resources *ContainerResources `json:"resources,omitempty"`
}

type TLSConfig struct {
	Mode    string `json:"mode"`
	CAPEM   string `json:"caPEM"`
	CertPEM string `json:"certPEM"`
	KeyPEM  string `json:"keyPEM"`
}

type VolumeIdentity struct {
	ClusterUID  string `json:"clusterUid"`
	Member      string `json:"member"`
	Volume      string `json:"volume"`
	VolumeID    string `json:"volumeId"`
	Initialized bool   `json:"initialized"`
}

type VolumeStatus struct {
	Identity VolumeIdentity `json:"identity"`
	Verified bool           `json:"verified"`
	Lost     bool           `json:"lost"`
	Message  string         `json:"message,omitempty"`
}