server

Documentation

Index

• Variables
• type Config
  • func (c *Config) GetAgentImage() string
  • func (c *Config) GetBuildkitImage() string
  • func (c *Config) Interface(ctx context.Context, config *client.Config) (*Interface, error)
• type Interface
  • func (i *Interface) Close()
  • func (i *Interface) List(ctx context.Context, req *imagesv1.ImageListRequest) (*imagesv1.ImageListResponse, error)
  • func (i *Interface) Pull(ctx context.Context, request *imagesv1.ImagePullRequest) (*imagesv1.ImagePullResponse, error)
  • func (i *Interface) PullProgress(req *imagesv1.ImageProgressRequest, srv imagesv1.Images_PullProgressServer) error
  • func (i *Interface) Push(ctx context.Context, request *imagesv1.ImagePushRequest) (*imagesv1.ImagePushResponse, error)
  • func (i *Interface) PushProgress(req *imagesv1.ImageProgressRequest, srv imagesv1.Images_PushProgressServer) error
  • func (i *Interface) Remove(ctx context.Context, req *imagesv1.ImageRemoveRequest) (*imagesv1.ImageRemoveResponse, error)
  • func (i *Interface) Status(ctx context.Context, req *imagesv1.ImageStatusRequest) (*imagesv1.ImageStatusResponse, error)
  • func (i *Interface) Tag(ctx context.Context, req *imagesv1.ImageTagRequest) (*imagesv1.ImageTagResponse, error)

Variables

var (
	DefaultAgentPort     = defaultAgentPort
	DefaultAgentImage    = defaultAgentImage
	DefaultBuildkitImage = defaultBuildkitImage
)

Types

type Config

type Config struct {
	AgentImage        string `usage:"Image to run the agent w/ missing tag inferred from version" default:"docker.io/rancher/k3c"`
	AgentPort         int    `usage:"Port that the agent will listen on" default:"1233"`
	BuildkitImage     string `usage:"BuildKit image for running buildkitd" default:"docker.io/moby/buildkit:v0.8.1"`
	BuildkitNamespace string `usage:"BuildKit namespace in containerd (not 'k8s.io')" default:"buildkit"`
	BuildkitPort      int    `usage:"BuildKit service port" default:"1234"`
	BuildkitSocket    string `usage:"BuildKit socket address" default:"unix:///run/buildkit/buildkitd.sock"`
	ContainerdSocket  string `usage:"Containerd socket address" default:"/run/k3s/containerd/containerd.sock"`
}

func (*Config) GetAgentImage

func (c *Config) GetAgentImage() string

func (*Config) GetBuildkitImage

func (c *Config) GetBuildkitImage() string

func (*Config) Interface

func (c *Config) Interface(ctx context.Context, config *client.Config) (*Interface, error)

type Interface

type Interface struct {
	Kubernetes     *client.Interface
	Buildkit       *buildkit.Client
	Containerd     *containerd.Client
	RuntimeService criv1.RuntimeServiceClient
	ImageService   criv1.ImageServiceClient
	// contains filtered or unexported fields
}

func (*Interface) Close

func (i *Interface) Close()

Close the Interface connections to various backends.

func (*Interface) List

func (i *Interface) List(ctx context.Context, req *imagesv1.ImageListRequest) (*imagesv1.ImageListResponse, error)

List images server-side impl

func (*Interface) Pull

func (i *Interface) Pull(ctx context.Context, request *imagesv1.ImagePullRequest) (*imagesv1.ImagePullResponse, error)

Pull server-side impl

func (*Interface) PullProgress

func (i *Interface) PullProgress(req *imagesv1.ImageProgressRequest, srv imagesv1.Images_PullProgressServer) error

PullProgress server-side impl

func (*Interface) Push

func (i *Interface) Push(ctx context.Context, request *imagesv1.ImagePushRequest) (*imagesv1.ImagePushResponse, error)

Push server-side impl

func (*Interface) PushProgress

func (i *Interface) PushProgress(req *imagesv1.ImageProgressRequest, srv imagesv1.Images_PushProgressServer) error

PushProgress server-side impl

func (*Interface) Remove

func (i *Interface) Remove(ctx context.Context, req *imagesv1.ImageRemoveRequest) (*imagesv1.ImageRemoveResponse, error)

Remove image server-side impl

func (*Interface) Status

func (i *Interface) Status(ctx context.Context, req *imagesv1.ImageStatusRequest) (*imagesv1.ImageStatusResponse, error)

Status of an image server-side impl (unused)

func (*Interface) Tag

func (i *Interface) Tag(ctx context.Context, req *imagesv1.ImageTagRequest) (*imagesv1.ImageTagResponse, error)

Tag image server-side impl, adapted from containerd's `ctr tag` implementation