adapter

package
v0.16.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 2, 2023 License: MIT Imports: 32 Imported by: 0

Documentation

Index

Constants

View Source 
const ContainerEnvPath = ".env"
View Source 
const (
	ContainerServicePath = ".vertex/service.yml"
)
View Source 
const ContainerSettingsPath = ".vertex/settings.yml"

Variables

View Source 
var (
	ErrContainerNotFound = errors.New("container not found")
)
View Source 
var (
	ErrLoggerNotFound = errors.New("container logger not found")
)

Functions

func NewContainerEnvFSAdapter 

func NewContainerEnvFSAdapter(params *ContainerEnvFSAdapterParams) port.ContainerEnvAdapter

func NewContainerFSAdapter 

func NewContainerFSAdapter(params *ContainerFSAdapterParams) port.ContainerAdapter

func NewContainerLogsFSAdapter 

func NewContainerLogsFSAdapter(params *ContainerLogsFSAdapterParams) port.ContainerLogsAdapter

func NewContainerServiceFSAdapter 

func NewContainerServiceFSAdapter(params *ContainerServiceFSAdapterParams) port.ContainerServiceAdapter

func NewContainerSettingsFSAdapter 

func NewContainerSettingsFSAdapter(params *ContainerSettingsFSAdapterParams) port.ContainerSettingsAdapter

func NewDockerCliAdapter added in v0.13.0 

func NewDockerCliAdapter() port.DockerAdapter

func NewServiceFSAdapter 

func NewServiceFSAdapter(params *ServiceFSAdapterParams) port.ServiceAdapter

Types

type ContainerEnvFSAdapter 

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

func (*ContainerEnvFSAdapter) Load 

func (a *ContainerEnvFSAdapter) Load(uuid uuid.UUID) (containerstypes.ContainerEnvVariables, error)

func (*ContainerEnvFSAdapter) Save 

func (a *ContainerEnvFSAdapter) Save(uuid uuid.UUID, env containerstypes.ContainerEnvVariables) error

type ContainerEnvFSAdapterParams 

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

type ContainerFSAdapter 

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

func (*ContainerFSAdapter) Create 

func (a *ContainerFSAdapter) Create(uuid uuid.UUID) error

func (*ContainerFSAdapter) Delete 

func (a *ContainerFSAdapter) Delete(uuid uuid.UUID) error

func (*ContainerFSAdapter) GetAll 

func (a *ContainerFSAdapter) GetAll() ([]uuid.UUID, error)

func (*ContainerFSAdapter) GetPath 

func (a *ContainerFSAdapter) GetPath(uuid uuid.UUID) string

type ContainerFSAdapterParams 

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

type ContainerFilePath 

type ContainerFilePath string

type ContainerLogger 

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

func (*ContainerLogger) Close 

func (l *ContainerLogger) Close() error

func (*ContainerLogger) Open 

func (l *ContainerLogger) Open() error

type ContainerLogsFSAdapter 

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

func (*ContainerLogsFSAdapter) LoadBuffer 

func (a *ContainerLogsFSAdapter) LoadBuffer(uuid uuid.UUID) ([]containerstypes.LogLine, error)

func (*ContainerLogsFSAdapter) Pop 

func (a *ContainerLogsFSAdapter) Pop(uuid uuid.UUID) (containerstypes.LogLine, error)

func (*ContainerLogsFSAdapter) Push 

func (a *ContainerLogsFSAdapter) Push(uuid uuid.UUID, line containerstypes.LogLine)

func (*ContainerLogsFSAdapter) Register 

func (a *ContainerLogsFSAdapter) Register(uuid uuid.UUID) error

func (*ContainerLogsFSAdapter) Unregister 

func (a *ContainerLogsFSAdapter) Unregister(uuid uuid.UUID) error

func (*ContainerLogsFSAdapter) UnregisterAll 

func (a *ContainerLogsFSAdapter) UnregisterAll() error

type ContainerLogsFSAdapterParams 

type ContainerLogsFSAdapterParams struct {
	ContainersPath string
}

type ContainerRunnerDockerAdapter 

type ContainerRunnerDockerAdapter struct{}

func NewContainerRunnerFSAdapter 

func NewContainerRunnerFSAdapter() ContainerRunnerDockerAdapter

func (ContainerRunnerDockerAdapter) CheckForUpdates 

func (a ContainerRunnerDockerAdapter) CheckForUpdates(inst *types.Container) error

func (ContainerRunnerDockerAdapter) DeleteContainer added in v0.16.0 

func (a ContainerRunnerDockerAdapter) DeleteContainer(inst *types.Container) error

func (ContainerRunnerDockerAdapter) DeleteMounts added in v0.16.0 

func (a ContainerRunnerDockerAdapter) DeleteMounts(inst *types.Container) error

func (ContainerRunnerDockerAdapter) GetAllVersions 

func (a ContainerRunnerDockerAdapter) GetAllVersions(inst types.Container) ([]string, error)

func (ContainerRunnerDockerAdapter) HasUpdateAvailable 

func (a ContainerRunnerDockerAdapter) HasUpdateAvailable(inst types.Container) (bool, error)

func (ContainerRunnerDockerAdapter) Info 

func (a ContainerRunnerDockerAdapter) Info(inst types.Container) (map[string]any, error)

func (ContainerRunnerDockerAdapter) Start 

func (a ContainerRunnerDockerAdapter) Start(inst *types.Container, setStatus func(status string)) (io.ReadCloser, io.ReadCloser, error)

func (ContainerRunnerDockerAdapter) Stop 

func (a ContainerRunnerDockerAdapter) Stop(inst *types.Container) error

func (ContainerRunnerDockerAdapter) WaitCondition 

func (a ContainerRunnerDockerAdapter) WaitCondition(inst *types.Container, cond types.WaitContainerCondition) error

type ContainerServiceFSAdapter 

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

func (*ContainerServiceFSAdapter) Load 

func (a *ContainerServiceFSAdapter) Load(uuid uuid.UUID) (types.Service, error)

func (*ContainerServiceFSAdapter) LoadRaw 

func (a *ContainerServiceFSAdapter) LoadRaw(uuid uuid.UUID) (interface{}, error)

func (*ContainerServiceFSAdapter) Save 

func (a *ContainerServiceFSAdapter) Save(uuid uuid.UUID, service types.Service) error

type ContainerServiceFSAdapterParams 

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

type ContainerSettingsFSAdapter 

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

func (*ContainerSettingsFSAdapter) Load 

func (a *ContainerSettingsFSAdapter) Load(uuid uuid.UUID) (types.ContainerSettings, error)

func (*ContainerSettingsFSAdapter) Save 

func (a *ContainerSettingsFSAdapter) Save(uuid uuid.UUID, settings types.ContainerSettings) error

type ContainerSettingsFSAdapterParams 

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

type DockerCliAdapter added in v0.13.0 

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

func (DockerCliAdapter) BuildImage added in v0.13.0 

func (a DockerCliAdapter) BuildImage(options types.BuildImageOptions) (dockertypes.ImageBuildResponse, error)

func (DockerCliAdapter) CreateContainer added in v0.13.0 

func (a DockerCliAdapter) CreateContainer(options types.CreateContainerOptions) (types.CreateContainerResponse, error)

func (DockerCliAdapter) DeleteContainer added in v0.13.0 

func (a DockerCliAdapter) DeleteContainer(id string) error

func (DockerCliAdapter) InfoContainer added in v0.13.0 

func (a DockerCliAdapter) InfoContainer(id string) (types.InfoContainerResponse, error)

func (DockerCliAdapter) InfoImage added in v0.13.0 

func (a DockerCliAdapter) InfoImage(id string) (types.InfoImageResponse, error)

func (DockerCliAdapter) ListContainers added in v0.13.0 

func (a DockerCliAdapter) ListContainers() ([]types.DockerContainer, error)

func (DockerCliAdapter) LogsStderrContainer added in v0.13.0 

func (a DockerCliAdapter) LogsStderrContainer(id string) (io.ReadCloser, error)

func (DockerCliAdapter) LogsStdoutContainer added in v0.13.0 

func (a DockerCliAdapter) LogsStdoutContainer(id string) (io.ReadCloser, error)

func (DockerCliAdapter) PullImage added in v0.13.0 

func (a DockerCliAdapter) PullImage(options types.PullImageOptions) (io.ReadCloser, error)

func (DockerCliAdapter) StartContainer added in v0.13.0 

func (a DockerCliAdapter) StartContainer(id string) error

func (DockerCliAdapter) StopContainer added in v0.13.0 

func (a DockerCliAdapter) StopContainer(id string) error

func (DockerCliAdapter) WaitContainer added in v0.13.0 

func (a DockerCliAdapter) WaitContainer(id string, cond types.WaitContainerCondition) error

type ServiceFSAdapter 

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

func (*ServiceFSAdapter) Get 

func (a *ServiceFSAdapter) Get(id string) (containerstypes.Service, error)

func (*ServiceFSAdapter) GetAll 

func (a *ServiceFSAdapter) GetAll() []containerstypes.Service

func (*ServiceFSAdapter) GetRaw 

func (a *ServiceFSAdapter) GetRaw(id string) (interface{}, error)

func (*ServiceFSAdapter) GetScript 

func (a *ServiceFSAdapter) GetScript(id string) ([]byte, error)

func (*ServiceFSAdapter) Reload 

func (a *ServiceFSAdapter) Reload() error

type ServiceFSAdapterParams 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.