provisioner

Documentation

Index

• Variables
• func GenerateCACertificate(org string) ([]byte, []byte, error)
• func GenerateClientCertificate(org string, caCert, caKey []byte) ([]byte, []byte, error)
• func GenerateServerCertificate(org string, caCert, caKey []byte, hosts []string) ([]byte, []byte, error)
• func NewWindowsASG(f docker.FactoryApi, st storage.StorageApi) *windows
• func OutOfCapacity(e error) bool
• type DinD
  • func NewDinD(generator id.Generator, f docker.FactoryApi, s storage.StorageApi) *DinD
  • func (d *DinD) InstanceDelete(session *types.Session, instance *types.Instance) error
  • func (d *DinD) InstanceExec(instance *types.Instance, cmd []string) (int, error)
  • func (d *DinD) InstanceFSTree(instance *types.Instance) (io.Reader, error)
  • func (d *DinD) InstanceFile(instance *types.Instance, filePath string) (io.Reader, error)
  • func (d *DinD) InstanceGetTerminal(instance *types.Instance) (net.Conn, error)
  • func (d *DinD) InstanceNew(session *types.Session, conf types.InstanceConfig) (*types.Instance, error)
  • func (d *DinD) InstanceResizeTerminal(instance *types.Instance, rows, cols uint) error
  • func (d *DinD) InstanceUploadFromReader(instance *types.Instance, fileName, dest string, reader io.Reader) error
  • func (d *DinD) InstanceUploadFromUrl(instance *types.Instance, fileName, dest, url string) error
• type InstanceProvisionerApi
• type InstanceProvisionerFactoryApi
  • func NewInstanceProvisionerFactory(w InstanceProvisionerApi, d InstanceProvisionerApi) InstanceProvisionerFactoryApi
• type SessionProvisionerApi
  • func NewOverlaySessionProvisioner(df docker.FactoryApi) SessionProvisionerApi

Variables

var OutOfCapacityError = errors.New("OutOfCapacity")

Functions

func GenerateCACertificate

func GenerateCACertificate(org string) ([]byte, []byte, error)

func GenerateClientCertificate

func GenerateClientCertificate(org string, caCert, caKey []byte) ([]byte, []byte, error)

func GenerateServerCertificate

func GenerateServerCertificate(org string, caCert, caKey []byte, hosts []string) ([]byte, []byte, error)

func NewWindowsASG

func NewWindowsASG(f docker.FactoryApi, st storage.StorageApi) *windows

func OutOfCapacity

func OutOfCapacity(e error) bool

Types

type DinD

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

func NewDinD

func NewDinD(generator id.Generator, f docker.FactoryApi, s storage.StorageApi) *DinD

func (*DinD) InstanceDelete

func (d *DinD) InstanceDelete(session *types.Session, instance *types.Instance) error

func (*DinD) InstanceExec

func (d *DinD) InstanceExec(instance *types.Instance, cmd []string) (int, error)

func (*DinD) InstanceFSTree

func (d *DinD) InstanceFSTree(instance *types.Instance) (io.Reader, error)

func (*DinD) InstanceFile

func (d *DinD) InstanceFile(instance *types.Instance, filePath string) (io.Reader, error)

func (*DinD) InstanceGetTerminal

func (d *DinD) InstanceGetTerminal(instance *types.Instance) (net.Conn, error)

func (*DinD) InstanceNew

func (d *DinD) InstanceNew(session *types.Session, conf types.InstanceConfig) (*types.Instance, error)

func (*DinD) InstanceResizeTerminal

func (d *DinD) InstanceResizeTerminal(instance *types.Instance, rows, cols uint) error

func (*DinD) InstanceUploadFromReader

func (d *DinD) InstanceUploadFromReader(instance *types.Instance, fileName, dest string, reader io.Reader) error

func (*DinD) InstanceUploadFromUrl

func (d *DinD) InstanceUploadFromUrl(instance *types.Instance, fileName, dest, url string) error

type InstanceProvisionerApi

type InstanceProvisionerApi interface {
	InstanceNew(session *types.Session, conf types.InstanceConfig) (*types.Instance, error)
	InstanceDelete(session *types.Session, instance *types.Instance) error
	InstanceExec(instance *types.Instance, cmd []string) (int, error)
	InstanceFSTree(instance *types.Instance) (io.Reader, error)
	InstanceFile(instance *types.Instance, filePath string) (io.Reader, error)

	InstanceResizeTerminal(instance *types.Instance, cols, rows uint) error
	InstanceGetTerminal(instance *types.Instance) (net.Conn, error)

	InstanceUploadFromUrl(instance *types.Instance, fileName, dest, url string) error
	InstanceUploadFromReader(instance *types.Instance, fileName, dest string, reader io.Reader) error
}

type InstanceProvisionerFactoryApi

type InstanceProvisionerFactoryApi interface {
	GetProvisioner(instanceType string) (InstanceProvisionerApi, error)
}

func NewInstanceProvisionerFactory

func NewInstanceProvisionerFactory(w InstanceProvisionerApi, d InstanceProvisionerApi) InstanceProvisionerFactoryApi

type SessionProvisionerApi

type SessionProvisionerApi interface {
	SessionNew(ctx context.Context, session *types.Session) error
	SessionClose(session *types.Session) error
}

func NewOverlaySessionProvisioner

func NewOverlaySessionProvisioner(df docker.FactoryApi) SessionProvisionerApi