Documentation
¶
Index ¶
- type DockerOrchestrator
- func (d *DockerOrchestrator) CreateNetwork(ctx context.Context, name string) (string, error)
- func (d *DockerOrchestrator) GetContainerIP(ctx context.Context, id string, networkName string) (string, error)
- func (d *DockerOrchestrator) GetContainerInspect(ctx context.Context, id string) (types.ContainerJSON, error)
- func (d *DockerOrchestrator) GetNetworkGateway(ctx context.Context, id string) (string, error)
- func (d *DockerOrchestrator) PullImage(ctx context.Context, imageName string) error
- func (d *DockerOrchestrator) RemoveNetwork(ctx context.Context, id string) error
- func (d *DockerOrchestrator) StartContainer(ctx context.Context, config *container.Config, ...) (string, error)
- func (d *DockerOrchestrator) StopAndRemoveContainer(ctx context.Context, id string) error
- func (d *DockerOrchestrator) StreamLogs(ctx context.Context, id string, stdout io.Writer, stderr io.Writer) error
- func (d *DockerOrchestrator) WaitForContainer(ctx context.Context, id string) (<-chan container.WaitResponse, <-chan error)
- func (d *DockerOrchestrator) WaitHTTP(ctx context.Context, url string, timeout time.Duration) error
- func (d *DockerOrchestrator) WaitTCP(ctx context.Context, address string, timeout time.Duration) error
- func (d *DockerOrchestrator) WaitTCPInternal(ctx context.Context, networkName, address string, timeout time.Duration) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DockerOrchestrator ¶
type DockerOrchestrator struct {
// contains filtered or unexported fields
}
func NewDockerOrchestrator ¶
func NewDockerOrchestrator() (*DockerOrchestrator, error)
func (*DockerOrchestrator) CreateNetwork ¶
func (*DockerOrchestrator) GetContainerIP ¶
func (*DockerOrchestrator) GetContainerInspect ¶
func (d *DockerOrchestrator) GetContainerInspect(ctx context.Context, id string) (types.ContainerJSON, error)
func (*DockerOrchestrator) GetNetworkGateway ¶
func (*DockerOrchestrator) PullImage ¶
func (d *DockerOrchestrator) PullImage(ctx context.Context, imageName string) error
func (*DockerOrchestrator) RemoveNetwork ¶
func (d *DockerOrchestrator) RemoveNetwork(ctx context.Context, id string) error
func (*DockerOrchestrator) StartContainer ¶
func (d *DockerOrchestrator) StartContainer(ctx context.Context, config *container.Config, hostConfig *container.HostConfig, networkingConfig *network.NetworkingConfig, containerName string) (string, error)
func (*DockerOrchestrator) StopAndRemoveContainer ¶
func (d *DockerOrchestrator) StopAndRemoveContainer(ctx context.Context, id string) error
func (*DockerOrchestrator) StreamLogs ¶
func (*DockerOrchestrator) WaitForContainer ¶
func (d *DockerOrchestrator) WaitForContainer(ctx context.Context, id string) (<-chan container.WaitResponse, <-chan error)
func (*DockerOrchestrator) WaitTCPInternal ¶
func (d *DockerOrchestrator) WaitTCPInternal(ctx context.Context, networkName, address string, timeout time.Duration) error
WaitTCPInternal waits for a TCP service to be available. Uses direct TCP dial from host instead of spawning Alpine containers. The address parameter should be in "host:port" format (e.g., "localhost:3306").
Click to show internal directories.
Click to hide internal directories.