docker

Oct 17, 2022

Changes in this version

+ const DefaultDialTimeout

+ const DefaultHost

+ const DefaultPort

+ const DefaultStopTimeout

+ var ErrNoDocker = errors.New("docker/podman API not available")

+ func GetPlatformImage(ref, platform string) (string, error)

+ func GetRegistry(img string) (string, error)

+ func NewClient(defaultHost string) (dockerClient client.CommonAPIClient, dockerHostInRemote string, err error)

+ func ParseDigest(output string) string

+ type Credentials struct

+ Password string

+ Username string

+ func EmptyCredentialsProvider(ctx context.Context, registry string) (Credentials, error)

+ type CredentialsProvider func(ctx context.Context, image string) (Credentials, error)

+ type Opt func(*Pusher)

+ func WithCredentialsProvider(cp CredentialsProvider) Opt

+ func WithProgressListener(pl fn.ProgressListener) Opt

+ func WithPusherDockerClientFactory(dockerClientFactory PusherDockerClientFactory) Opt

+ func WithTransport(transport http.RoundTripper) Opt

+ func WithVerbose(verbose bool) Opt

+ type Pusher struct

+ func NewPusher(opts ...Opt) *Pusher

+ func (n *Pusher) Push(ctx context.Context, f fn.Function) (digest string, err error)

+ type PusherDockerClient interface

+ Close func() error

+ ImagePush func(ctx context.Context, ref string, options types.ImagePushOptions) (io.ReadCloser, error)

+ type PusherDockerClientFactory func() (PusherDockerClient, error)

+ type Runner struct

+ func NewRunner(verbose bool, out, errOut io.Writer) *Runner

+ func (n *Runner) Run(ctx context.Context, f fn.Function) (job *fn.Job, err error)