Documentation
¶
Index ¶
- Variables
- type Config
- 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, req *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)
Constants ¶
This section is empty.
Variables ¶
View Source
var ( DefaultAgentPort = defaultAgentPort DefaultAgentImage = defaultAgentImage DefaultBuildkitImage = defaultBuildkitImage )
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct { AgentImage string `usage:"Image to run the agent w/ missing tag inferred from version"` 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 (*Config) GetBuildkitImage ¶
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, req *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
Source Files
¶
Click to show internal directories.
Click to hide internal directories.