remotenodes

type ArtifactSource interface {
	Open(context.Context, string, string) (*runnerartifacts.Artifact, error)
}

type Authentication struct {
	Kind          AuthenticationKind `json:"kind"`
	PasswordRef   string             `json:"password_ref"`
	PrivateKeyRef string             `json:"private_key_ref"`
	PassphraseRef string             `json:"passphrase_ref"`
}

type AuthenticationKind string

type BindCommand struct {
	ID               string
	ExpectedRevision uint64
	Identity         runnerinstall.Identity
	Token            *credentials.Lease
}

type Binding struct {
	Identity runnerinstall.Identity `json:"identity"`
	TokenRef string                 `json:"token_ref"`
}

type Configuration struct {
	Format         int       `json:"format"`
	Revision       uint64    `json:"revision"`
	Default        Selection `json:"default"`
	Nodes          []Node    `json:"nodes"`
	CredentialRefs []string  `json:"credential_refs"`
}

type Connection struct {
	Node           Node
	Authentication remotessh.Authentication
	// contains filtered or unexported fields
}

type Connector func(context.Context, remotessh.Endpoint, remotessh.Authentication) (RemoteSession, error)

type Dependencies struct {
	Store       *FileStore
	Credentials credentials.Store
	Now         func() time.Time
	// Must consult accepted, uncertain and undownloaded local job ownership.
	// Absence fails closed; removing a node never uninstalls its server runner.
	CanRemove func(context.Context, Node) error
}

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

type HostKey struct {
	Type        string `json:"type"`
	Fingerprint string `json:"fingerprint"`
}

type HostKeyConfirmation struct {
	ID               string
	ExpectedRevision uint64
	Key              HostKey
}

type Installation struct {
	Request            runnerinstall.Request `json:"request"`
	Release            string                `json:"release"`
	Arch               string                `json:"arch"`
	Stage              string                `json:"stage"`
	ErrorCode          string                `json:"error_code"`
	TemporaryDirectory string                `json:"temporary_directory"`
	CleanupPending     bool                  `json:"cleanup_pending"`
}

type InstallationCommand struct {
	ID                  string
	ExpectedRevision    uint64
	ExpectedOperationID string
	Installation        Installation
}

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

type ManagerDependencies struct {
	Configuration *Service
	Artifacts     ArtifactSource
	Release       string
	Connect       Connector
}

type Node struct {
	domain.EntityMeta
	Name           string         `json:"name"`
	Region         string         `json:"region"`
	Host           string         `json:"host"`
	Port           uint16         `json:"port"`
	User           string         `json:"user"`
	Enabled        bool           `json:"enabled"`
	Authentication Authentication `json:"authentication"`
	HostKey        *HostKey       `json:"host_key"`
	Binding        *Binding       `json:"binding"`
	Installation   *Installation  `json:"installation"`
	Observation    *Observation   `json:"observation"`
}

type NodeView struct {
	ID                 string             `json:"id"`
	Revision           uint64             `json:"revision"`
	Name               string             `json:"name"`
	Region             string             `json:"region"`
	Host               string             `json:"host"`
	Port               uint16             `json:"port"`
	User               string             `json:"user"`
	Enabled            bool               `json:"enabled"`
	AuthenticationKind AuthenticationKind `json:"authentication_kind"`
	HasAuthentication  bool               `json:"has_authentication"`
	HasPassphrase      bool               `json:"has_passphrase"`
	HostKey            *HostKey           `json:"host_key"`
	RunnerNodeID       string             `json:"runner_node_id"`
	InstallationID     string             `json:"installation_id"`
	Installation       *Installation      `json:"installation"`
	Upgrade            *Upgrade           `json:"upgrade"`
	Observation        *Observation       `json:"observation"`
	Status             string             `json:"status"`
	Eligible           bool               `json:"eligible"`
	Checking           bool               `json:"checking"`
}

type Observation struct {
	CheckedAt       time.Time               `json:"checked_at"`
	Status          string                  `json:"status"`
	ProposedHostKey *HostKey                `json:"proposed_host_key"`
	System          *remotessh.SystemInfo   `json:"system"`
	Runner          *jobcontract.RunnerInfo `json:"runner"`
}

type Pairing struct {
	Identity runnerinstall.Identity
	Runner   jobcontract.RunnerInfo
	Token    *credentials.Lease
}

type RemoteSession interface {
	Probe(context.Context) (remotessh.SystemInfo, error)
	Shared(context.Context) (Pairing, error)
	Bound(context.Context, Binding, *credentials.Lease) (jobcontract.RunnerInfo, error)
	Provision(
		context.Context,
		runnerinstall.Request,
		remotessh.Artifact,
		func(runnerinstall.Progress),
	) (runnerinstall.Result, error)
	Operation(context.Context, string) (runnerinstall.Operation, error)
	UpgradeOperation(context.Context, string) (runnerinstall.UpgradeOperation, error)
	Upgrade(
		context.Context,
		runnerinstall.UpgradeRequest,
		remotessh.Artifact,
		func(runnerinstall.UpgradeProgress),
	) (runnerinstall.UpgradeOperation, error)
	RetryUpgrade(
		context.Context,
		runnerinstall.UpgradeRequest,
		remotessh.Artifact,
		func(runnerinstall.UpgradeProgress),
	) (runnerinstall.UpgradeOperation, error)
	RecoverUpgrade(
		context.Context,
		runnerinstall.UpgradeRequest,
		remotessh.Artifact,
		func(runnerinstall.UpgradeProgress),
	) (runnerinstall.UpgradeOperation, error)
	CleanupBootstrap(context.Context, string) error
	Close() error
}

type SaveCommand struct {
	ID               string
	ExpectedRevision uint64
	Name             string
	Region           string
	Host             string
	Port             uint16
	User             string
	Enabled          bool
	Authentication   AuthenticationKind
	HostKey          *HostKey
	Secrets          SecretUpdate
}

type SecretUpdate struct {
	Password         *credentials.Lease
	PrivateKey       *credentials.Lease
	Passphrase       *credentials.Lease
	RemovePassphrase bool
}

type Selection struct {
	Revision uint64                 `json:"revision"`
	Kind     jobcontract.TargetKind `json:"kind"`
	NodeID   string                 `json:"node_id"`
}

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

type Snapshot struct {
	Revision                 uint64     `json:"revision"`
	Default                  Selection  `json:"default"`
	Nodes                    []NodeView `json:"nodes"`
	PendingCredentialCleanup int        `json:"pending_credential_cleanup"`
}

type TaskConcurrencyCommand struct {
	ID                    string
	ExpectedRevision      uint64
	ExpectedMaxActiveJobs uint32
	MaxActiveJobs         uint32
}

type Upgrade struct {
	Request            runnerinstall.UpgradeRequest    `json:"request"`
	Release            string                          `json:"release"`
	Arch               string                          `json:"arch"`
	TemporaryDirectory string                          `json:"temporary_directory"`
	Stage              string                          `json:"stage"`
	ErrorCode          string                          `json:"error_code"`
	Operation          *runnerinstall.UpgradeOperation `json:"operation"`
	ChangedAt          time.Time                       `json:"changed_at"`
}

type UpgradeAction struct {
	ID               string
	ExpectedRevision uint64
	OperationID      string
}

type UpgradeCommand struct {
	ID               string
	ExpectedRevision uint64
	OperationID      string
	ExpectedBuildID  string
}