template_manager

package
v0.0.0-...-b66211f Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 11, 2026 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DeleteBuild

type DeleteBuild struct {
	BuildID    uuid.UUID
	TemplateID string

	ClusterID uuid.UUID
	NodeID    string
}

type FromTemplateError

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

func (*FromTemplateError) Error

func (e *FromTemplateError) Error() string

func (*FromTemplateError) Unwrap

func (e *FromTemplateError) Unwrap() error

type PollBuildStatus

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

type TemplateManager

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

func New

func New(
	sqlcDB *sqlcdb.Client,
	clusters *clusters.Pool,
	buildCache *templatecache.TemplatesBuildCache,
	templateCache *templatecache.TemplateCache,
	featureFlags *featureflags.Client,
) (*TemplateManager, error)

func (*TemplateManager) BuildStatusSync

func (tm *TemplateManager) BuildStatusSync(ctx context.Context, buildID uuid.UUID, templateID string, clusterID uuid.UUID, nodeID *string) error

func (*TemplateManager) BuildsStatusPeriodicalSync

func (tm *TemplateManager) BuildsStatusPeriodicalSync(ctx context.Context)

func (*TemplateManager) CreateTemplate

func (tm *TemplateManager) CreateTemplate(
	ctx context.Context,
	teamID uuid.UUID,
	teamSlug string,
	templateID string,
	buildID uuid.UUID,
	kernelVersion,
	firecrackerVersion string,
	startCommand *string,
	vCpuCount,
	diskSizeMB,
	freeDiskSizeMB,
	memoryMB int64,
	readyCommand *string,
	fromImage *string,
	fromTemplate *string,
	fromImageRegistry *api.FromImageRegistry,
	force *bool,
	steps *[]api.TemplateStep,
	clusterID uuid.UUID,
	nodeID string,
	version string,
) (e error)

func (*TemplateManager) DeleteBuild

func (tm *TemplateManager) DeleteBuild(ctx context.Context, buildID uuid.UUID, templateID string, clusterID uuid.UUID, nodeID string) error

func (*TemplateManager) DeleteBuilds

func (tm *TemplateManager) DeleteBuilds(ctx context.Context, builds []DeleteBuild) error

func (*TemplateManager) GetAvailableBuildClient

func (tm *TemplateManager) GetAvailableBuildClient(ctx context.Context, clusterID uuid.UUID) (*clusters.Instance, error)

func (*TemplateManager) GetClusterBuildClient

func (tm *TemplateManager) GetClusterBuildClient(clusterID uuid.UUID, nodeID string) (*clusters.GRPCClient, error)

func (*TemplateManager) GetClusterResources

func (tm *TemplateManager) GetClusterResources(clusterID uuid.UUID) (clusters.ClusterResource, error)

func (*TemplateManager) GetStatus

func (tm *TemplateManager) GetStatus(ctx context.Context, buildID uuid.UUID, templateID string, clusterID uuid.UUID, nodeID string) (*templatemanagergrpc.TemplateBuildStatusResponse, error)

func (*TemplateManager) InitLayerFileUpload

func (tm *TemplateManager) InitLayerFileUpload(ctx context.Context, clusterID uuid.UUID, nodeID string, teamID uuid.UUID, templateID string, hash string) (*templatemanager.InitLayerFileUploadResponse, error)

func (*TemplateManager) SetFinished

func (tm *TemplateManager) SetFinished(ctx context.Context, buildID uuid.UUID, rootfsSize int64, envdVersion, kernelVersion, firecrackerVersion string) error

func (*TemplateManager) SetStatus

func (*TemplateManager) SetTerminalStatus

func (tm *TemplateManager) SetTerminalStatus(ctx context.Context, buildID uuid.UUID, statusGroup types.BuildStatusGroup, reason *templatemanagergrpc.TemplateBuildStatusReason) (bool, error)

SetTerminalStatus records a build's final outcome and reports whether this write is the one that ended it: several pollers watch the same build, and the build keeps the first outcome recorded.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL