image

Documentation

Index

• type BaseImage
• type BuildOpts
• type Builder
  • func NewBuilder(config types.AppConfig, registry *common.ImageRegistry, ...) (*Builder, error)
  • func (b *Builder) Build(ctx context.Context, opts *BuildOpts, outputChan chan common.OutputMsg) error
  • func (b *Builder) Exists(ctx context.Context, imageId string) bool
  • func (b *Builder) GetImageId(opts *BuildOpts) (string, error)
• type ImageIdHash
• type ImageService
  • func NewRuncImageService(ctx context.Context, opts ImageServiceOpts) (ImageService, error)
• type ImageServiceOpts
• type RuncImageService
  • func (is *RuncImageService) BuildImage(in *pb.BuildImageRequest, stream pb.ImageService_BuildImageServer) error
  • func (is *RuncImageService) VerifyImageBuild(ctx context.Context, in *pb.VerifyImageBuildRequest) (*pb.VerifyImageBuildResponse, error)

Types

type BaseImage

type BaseImage struct {
	SourceRegistry string
	ImageName      string
	ImageTag       string
}

type BuildOpts

type BuildOpts struct {
	BaseImageRegistry  string
	BaseImageName      string
	BaseImageTag       string
	PythonVersion      string
	PythonPackages     []string
	Commands           []string
	ExistingImageUri   string
	ExistingImageCreds *string
	ForceRebuild       bool
}

type Builder

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

func NewBuilder

func NewBuilder(config types.AppConfig, registry *common.ImageRegistry, scheduler *scheduler.Scheduler, tailscale *network.Tailscale, containerRepo repository.ContainerRepository) (*Builder, error)

func (*Builder) Build

func (b *Builder) Build(ctx context.Context, opts *BuildOpts, outputChan chan common.OutputMsg) error

Build user image

func (*Builder) Exists

func (b *Builder) Exists(ctx context.Context, imageId string) bool

Check if an image already exists in the registry

func (*Builder) GetImageId

func (b *Builder) GetImageId(opts *BuildOpts) (string, error)

type ImageIdHash

type ImageIdHash struct {
	BaseImageName   string
	BaseImageTag    string
	UserImageTag    string
	PythonVersion   string
	PythonPackages  []string
	ExitingImageUri string
	CommandListHash string
}

type ImageService

type ImageService interface {
	pb.ImageServiceServer
	VerifyImageBuild(ctx context.Context, in *pb.VerifyImageBuildRequest) (*pb.VerifyImageBuildResponse, error)
	BuildImage(in *pb.BuildImageRequest, stream pb.ImageService_BuildImageServer) error
}

func NewRuncImageService

func NewRuncImageService(
	ctx context.Context,
	opts ImageServiceOpts,
) (ImageService, error)

type ImageServiceOpts

type ImageServiceOpts struct {
	Config        types.AppConfig
	ContainerRepo repository.ContainerRepository
	Scheduler     *scheduler.Scheduler
	Tailscale     *network.Tailscale
}

type RuncImageService

type RuncImageService struct {
	pb.UnimplementedImageServiceServer
	// contains filtered or unexported fields
}

func (*RuncImageService) BuildImage

func (is *RuncImageService) BuildImage(in *pb.BuildImageRequest, stream pb.ImageService_BuildImageServer) error

func (*RuncImageService) VerifyImageBuild

func (is *RuncImageService) VerifyImageBuild(ctx context.Context, in *pb.VerifyImageBuildRequest) (*pb.VerifyImageBuildResponse, error)