dockerimpl

Documentation

Index

• func NewClientFromEnv() (*client.Client, error)
• type Backend
  • func NewDockerBackend(c *client.Client, config Config, image builder.ImageConfig) (*Backend, error)
  • func (b *Backend) AttachContainer(ctx context.Context, appID string, stdin io.Reader, stdout, stderr io.Writer) error
  • func (b *Backend) AvailableDomains() domain.AvailableDomainSlice
  • func (b *Backend) AvailablePorts() domain.AvailablePortSlice
  • func (b *Backend) Dispose(_ context.Context) error
  • func (b *Backend) ExecContainer(ctx context.Context, appID string, cmd []string, stdin io.Reader, ...) error
  • func (b *Backend) GetContainer(ctx context.Context, appID string) (*domain.Container, error)
  • func (b *Backend) ListContainers(ctx context.Context) ([]*domain.Container, error)
  • func (b *Backend) ListenContainerEvents() (sub <-chan *domain.ContainerEvent, unsub func())
  • func (b *Backend) Start(ctx context.Context) error
  • func (b *Backend) Synchronize(ctx context.Context, s *domain.DesiredState) error
• type Config
  • func (c *Config) Validate() error

Functions

func NewClientFromEnv

func NewClientFromEnv() (*client.Client, error)

Types

type Backend

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

func NewDockerBackend

func NewDockerBackend(
	c *client.Client,
	config Config,
	image builder.ImageConfig,
) (*Backend, error)

func (*Backend) AttachContainer

func (b *Backend) AttachContainer(ctx context.Context, appID string, stdin io.Reader, stdout, stderr io.Writer) error

func (*Backend) AvailableDomains

func (b *Backend) AvailableDomains() domain.AvailableDomainSlice

func (*Backend) AvailablePorts

func (b *Backend) AvailablePorts() domain.AvailablePortSlice

func (*Backend) Dispose

func (b *Backend) Dispose(_ context.Context) error

func (*Backend) ExecContainer

func (b *Backend) ExecContainer(ctx context.Context, appID string, cmd []string, stdin io.Reader, stdout, stderr io.Writer) error

func (*Backend) GetContainer

func (b *Backend) GetContainer(ctx context.Context, appID string) (*domain.Container, error)

func (*Backend) ListContainers

func (b *Backend) ListContainers(ctx context.Context) ([]*domain.Container, error)

func (*Backend) ListenContainerEvents

func (b *Backend) ListenContainerEvents() (sub <-chan *domain.ContainerEvent, unsub func())

func (*Backend) Start

func (b *Backend) Start(ctx context.Context) error

func (*Backend) Synchronize

func (b *Backend) Synchronize(ctx context.Context, s *domain.DesiredState) error

type Config

type Config struct {
	ConfDir string        `mapstructure:"confDir" yaml:"confDir"`
	Domains []*domainConf `mapstructure:"domains" yaml:"domains"`
	Ports   []*portConf   `mapstructure:"ports" yaml:"ports"`
	SS      struct {
		URL string `mapstructure:"url" yaml:"url"`
	} `mapstructure:"ss" yaml:"ss"`
	Network string       `mapstructure:"network" yaml:"network"`
	Labels  []*labelConf `mapstructure:"labels" yaml:"labels"`
	TLS     struct {
		CertResolver string `mapstructure:"certResolver" yaml:"certResolver"`
		Wildcard     struct {
			Domains domain.WildcardDomains `mapstructure:"domains" yaml:"domains"`
		} `mapstructure:"wildcard" yaml:"wildcard"`
	} `mapstructure:"tls" yaml:"tls"`
	Resources struct {
		CPUs              float64 `mapstructure:"cpus" yaml:"cpus"`
		Memory            int64   `mapstructure:"memory" yaml:"memory"`
		MemorySwap        int64   `mapstructure:"memorySwap" yaml:"memorySwap"`
		MemoryReservation int64   `mapstructure:"memoryReservation" yaml:"memoryReservation"`
	} `mapstructure:"resources" yaml:"resources"`
}

func (*Config) Validate

func (c *Config) Validate() error