worker

Documentation

Index

• Variables
• type DockerClient
• type Error
  • func (e *Error) Error() string
  • func (e *Error) Unwrap() error
• type SnapshotOptions
• type Worker
  • func New(cli DockerClient, authpath string) (*Worker, error)
  • func (c *Worker) TakeSnapshot(ctx context.Context, opt *SnapshotOptions) error

Variables

var (
	ErrInvalidImage = errors.New("invlid image name")
	ErrCommit       = errors.New("container commit failed")
	ErrPush         = errors.New("image push failed")
)

Types

type DockerClient

type DockerClient interface {
	ContainerCommit(ctx context.Context, container string, options types.ContainerCommitOptions) (types.IDResponse, error)
	ImagePush(ctx context.Context, ref string, options types.ImagePushOptions) (io.ReadCloser, error)
}

DockerClient is a subset of docker CommonAPIClient, to make the worker interface simpler

type Error

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

func (*Error) Error

func (e *Error) Error() string

func (*Error) Unwrap

func (e *Error) Unwrap() error

type SnapshotOptions

type SnapshotOptions struct {
	// docker registry auth header, from imagePushSecret
	// see: https://kubernetes.io/docs/tasks/configure-pod-container/pull-image-private-registry/#inspecting-the-secret-regcred
	Container string `json:"container,omitempty"`
	Image     string `json:"image,omitempty"` // image full name: host/path/image:tag
	Author    string `json:"author,omitempty"`
	Comment   string `json:"comment,omitempty"`
}

type Worker

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

func New

func New(cli DockerClient, authpath string) (*Worker, error)

func (*Worker) TakeSnapshot

func (c *Worker) TakeSnapshot(ctx context.Context, opt *SnapshotOptions) error