provider

Documentation

Index

• Constants
• Variables
• func DefaultLabels() map[string]string
• func MainHarnessLabel() map[string]string
• type ContainerRequest
• type ContainerResourcesRequest
• type DockerClient
  • func NewDockerClient() (*DockerClient, error)
• type DockerNetworkRequest
• type DockerProvider
  • func NewDocker(name string, cli *DockerClient, req DockerRequest) *DockerProvider
  • func (p *DockerProvider) CreateNetwork(ctx context.Context, name string) (string, error)
  • func (p *DockerProvider) Exec(ctx context.Context, config ExecConfig) (io.Reader, error)
  • func (p *DockerProvider) GetNetwork(ctx context.Context, name string) (string, error)
  • func (p *DockerProvider) Start(ctx context.Context) error
  • func (p *DockerProvider) Teardown(ctx context.Context) error
• type DockerRequest
• type Env
  • func (e Env) ToSlice() []string
• type ExecConfig
• type File
• type Provider

Constants

const (
	DockerProviderName       = "docker"
	DockerDefaultNetworkName = "imagetest"
)

Variables

var ErrNetworkNotFound = errors.New("network not found")

Functions

func DefaultLabels

func DefaultLabels() map[string]string

func MainHarnessLabel

func MainHarnessLabel() map[string]string

Types

type ContainerRequest

type ContainerRequest struct {
	Ref        name.Reference
	Entrypoint []string
	User       string // uid:gid
	Env        Env
	Cmd        []string
	Networks   []string
	Privileged bool
	Files      []File
	// An abstraction over common memory/cpu/disk resources requests and limits
	Resources ContainerResourcesRequest
	Labels    map[string]string
	Ports     nat.PortMap
}

type ContainerResourcesRequest

type ContainerResourcesRequest struct {
	CpuRequest resource.Quantity
	CpuLimit   resource.Quantity

	MemoryRequest resource.Quantity
	MemoryLimit   resource.Quantity
}

type DockerClient

type DockerClient struct {
	*client.Client
	// contains filtered or unexported fields
}

DockerClient is a wrapper around the Docker client that provides a mutex to ensure the unsafe operations can be done safely.

func NewDockerClient

func NewDockerClient() (*DockerClient, error)

type DockerNetworkRequest

type DockerNetworkRequest struct {
	network.CreateOptions
	Name string
}

type DockerProvider

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

func NewDocker

func NewDocker(name string, cli *DockerClient, req DockerRequest) *DockerProvider

NewDocker creates a new DockerProvider with the given client.

func (*DockerProvider) CreateNetwork

func (p *DockerProvider) CreateNetwork(ctx context.Context, name string) (string, error)

CreateNetwork creates a user defined bridge network with the given name only if it doesn't exist.

func (*DockerProvider) Exec

func (p *DockerProvider) Exec(ctx context.Context, config ExecConfig) (io.Reader, error)

Exec implements Provider.

func (*DockerProvider) GetNetwork

func (p *DockerProvider) GetNetwork(ctx context.Context, name string) (string, error)

func (*DockerProvider) Start

func (p *DockerProvider) Start(ctx context.Context) error

Start implements Provider.

func (*DockerProvider) Teardown

func (p *DockerProvider) Teardown(ctx context.Context) error

Teardown implements Provider.

type DockerRequest

type DockerRequest struct {
	ContainerRequest
	Mounts []mount.Mount
	// ManagedVolumes is the list of volumes that should be torn down when the
	// provider finishes execution
	ManagedVolumes []mount.Mount
}

type Env

type Env map[string]string

func (Env) ToSlice

func (e Env) ToSlice() []string

type ExecConfig

type ExecConfig struct {
	// The command to be executed in the provider
	Command string

	// The working directory to be used to execute the command
	WorkingDir string
}

type File

type File struct {
	Contents io.Reader
	Target   string
	Mode     int64
}

type Provider

type Provider interface {
	Start(ctx context.Context) error
	Teardown(ctx context.Context) error
	Exec(ctx context.Context, config ExecConfig) (io.Reader, error)
}