runtime

Documentation

Index

• type OperationOptions
• type Options
• type Service
  • func NewService(options Options) *Service
  • func (service *Service) BuildEffectiveEnvironments(runtime *actions.RuntimeNode, environmentName string) (map[string]domain.EnvironmentDefinition, error)
  • func (service *Service) CollectRuntimeNodes(runtime *actions.RuntimeNode) []*actions.RuntimeNode
  • func (service *Service) CollectTiltfiles(options OperationOptions) (tiltfilePaths []string, rootDir string, err error)
  • func (service *Service) Doctor(options OperationOptions) error
  • func (service *Service) Down(options OperationOptions) error
  • func (service *Service) EnsureInitialized() error
  • func (service *Service) Info(message string, arguments ...any)
  • func (service *Service) Initialize() error
  • func (service *Service) ListNodeManeuvers(node domain.OrchestrationNode) []domain.ManeuverDefinition
  • func (service *Service) Maneuver(options OperationOptions, maneuverName string) error
  • func (service *Service) ModulesInit() error
  • func (service *Service) ModulesStatus() error
  • func (service *Service) ModulesSync() error
  • func (service *Service) ModulesUpdate() error
  • func (service *Service) NodesByID() map[string]*actions.RuntimeNode
  • func (service *Service) NormalizeOptions(options actions.OperationOptions) actions.OperationOptions
  • func (service *Service) ResolveExecutionOrder(runtime *actions.RuntimeNode, nodesByID map[string]*actions.RuntimeNode) ([]*actions.RuntimeNode, error)
  • func (service *Service) Root() *actions.RuntimeNode
  • func (service *Service) RootManeuvers() []domain.ManeuverDefinition
  • func (service *Service) RootNodeID() string
  • func (service *Service) RunProcess(request ports.ProcessRunRequest) error
  • func (service *Service) RuntimeWorkingDirectory() string
  • func (service *Service) SelectReactor(node domain.OrchestrationNode) ports.Reactor
  • func (service *Service) SetConfigurationPath(configurationPath string)
  • func (service *Service) ShouldOperateOnNode(node domain.OrchestrationNode, tags []string) bool
  • func (service *Service) Signal(options OperationOptions, arguments []string) error
  • func (service *Service) Status(options OperationOptions) error
  • func (service *Service) Success(message string, arguments ...any)
  • func (service *Service) Tree() error
  • func (service *Service) Up(options OperationOptions) error
  • func (service *Service) VerifyNodeHealth(runtime *actions.RuntimeNode, _ string) error
  • func (service *Service) Warn(message string, arguments ...any)

Types

type OperationOptions

type OperationOptions = actions.OperationOptions

OperationOptions controls one orchestration capability call.

type Options

type Options struct {
	ConfigurationPath string
	WorkingDirectory  string
	Logger            logging.Logger

	NodeConfigLoader ports.NodeConfigLoader
	TiltReactor      ports.Reactor
	NativeReactor    ports.Reactor
	ProcessRunner    ports.ProcessRunner
}

Options configures runtime service construction.

type Service

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

Service is the API-first runtime service layer.

func NewService

func NewService(options Options) *Service

NewService creates a runtime service.

func (*Service) BuildEffectiveEnvironments

func (service *Service) BuildEffectiveEnvironments(runtime *actions.RuntimeNode, environmentName string) (map[string]domain.EnvironmentDefinition, error)

func (*Service) CollectRuntimeNodes

func (service *Service) CollectRuntimeNodes(runtime *actions.RuntimeNode) []*actions.RuntimeNode

func (*Service) CollectTiltfiles

func (service *Service) CollectTiltfiles(options OperationOptions) (tiltfilePaths []string, rootDir string, err error)

CollectTiltfiles returns ordered tiltfile paths for all Tilt-backed nodes that should participate in the current fleet operation, along with the project root directory. Parent Tiltfiles are preserved so module-level deployment definitions can be combined with unit-level image builds in a single generated Tiltfile. Used by the cobracli adapter to build a combined fleet Tiltfile.

func (*Service) Doctor

func (service *Service) Doctor(options OperationOptions) error

func (*Service) Down

func (service *Service) Down(options OperationOptions) error

func (*Service) EnsureInitialized

func (service *Service) EnsureInitialized() error

func (*Service) Info

func (service *Service) Info(message string, arguments ...any)

func (*Service) Initialize

func (service *Service) Initialize() error

Initialize discovers configuration and builds runtime topology.

func (*Service) ListNodeManeuvers

func (service *Service) ListNodeManeuvers(node domain.OrchestrationNode) []domain.ManeuverDefinition

func (*Service) Maneuver

func (service *Service) Maneuver(options OperationOptions, maneuverName string) error

func (*Service) ModulesInit

func (service *Service) ModulesInit() error

func (*Service) ModulesStatus

func (service *Service) ModulesStatus() error

func (*Service) ModulesSync

func (service *Service) ModulesSync() error

func (*Service) ModulesUpdate

func (service *Service) ModulesUpdate() error

func (*Service) NodesByID

func (service *Service) NodesByID() map[string]*actions.RuntimeNode

func (*Service) NormalizeOptions

func (service *Service) NormalizeOptions(options actions.OperationOptions) actions.OperationOptions

func (*Service) ResolveExecutionOrder

func (service *Service) ResolveExecutionOrder(runtime *actions.RuntimeNode, nodesByID map[string]*actions.RuntimeNode) ([]*actions.RuntimeNode, error)

func (*Service) Root

func (service *Service) Root() *actions.RuntimeNode

func (*Service) RootManeuvers

func (service *Service) RootManeuvers() []domain.ManeuverDefinition

RootManeuvers returns root node maneuvers for command surface generation.

func (*Service) RootNodeID

func (service *Service) RootNodeID() string

RootNodeID returns runtime root node identifier.

func (*Service) RunProcess

func (service *Service) RunProcess(request ports.ProcessRunRequest) error

func (*Service) RuntimeWorkingDirectory

func (service *Service) RuntimeWorkingDirectory() string

RuntimeWorkingDirectory returns the discovered root path.

func (*Service) SelectReactor

func (service *Service) SelectReactor(node domain.OrchestrationNode) ports.Reactor

func (*Service) SetConfigurationPath

func (service *Service) SetConfigurationPath(configurationPath string)

SetConfigurationPath updates explicit configuration path before initialization.

func (*Service) ShouldOperateOnNode

func (service *Service) ShouldOperateOnNode(node domain.OrchestrationNode, tags []string) bool

func (*Service) Signal

func (service *Service) Signal(options OperationOptions, arguments []string) error

func (*Service) Status

func (service *Service) Status(options OperationOptions) error

func (*Service) Success

func (service *Service) Success(message string, arguments ...any)

func (*Service) Tree

func (service *Service) Tree() error

func (*Service) Up

func (service *Service) Up(options OperationOptions) error

func (*Service) VerifyNodeHealth

func (service *Service) VerifyNodeHealth(runtime *actions.RuntimeNode, _ string) error

func (*Service) Warn

func (service *Service) Warn(message string, arguments ...any)