Documentation ¶
Index ¶
- Variables
- type ContainerRestarter
- type Docker
- func (d *Docker) GetLabeled(ctx context.Context, labels []string) (containerNames []string, err error)
- func (d *Docker) GetUnhealthy(ctx context.Context) (unhealthies []UnhealthyContainer, err error)
- func (d *Docker) NegotiateVersion(ctx context.Context)
- func (d *Docker) RestartContainer(ctx context.Context, name string) (err error)
- func (d *Docker) StreamUnhealthy(ctx context.Context, unhealthies chan<- UnhealthyContainer, ...)
- type Dockerer
- type LabeledGetter
- type UnhealthyContainer
- type UnhealthyGetter
- type UnhealthyStreamer
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrCreateDockerClient = errors.New("cannot create Docker client")
)
Functions ¶
This section is empty.
Types ¶
type ContainerRestarter ¶
type Docker ¶
type Docker struct {
// contains filtered or unexported fields
}
func (*Docker) GetLabeled ¶ added in v0.2.0
func (*Docker) GetUnhealthy ¶
func (d *Docker) GetUnhealthy(ctx context.Context) (unhealthies []UnhealthyContainer, err error)
func (*Docker) NegotiateVersion ¶ added in v0.3.0
func (*Docker) RestartContainer ¶
func (*Docker) StreamUnhealthy ¶
func (d *Docker) StreamUnhealthy(ctx context.Context, unhealthies chan<- UnhealthyContainer, crashed chan<- error)
type Dockerer ¶
type Dockerer interface { UnhealthyGetter UnhealthyStreamer ContainerRestarter LabeledGetter }
type LabeledGetter ¶ added in v0.2.0
type UnhealthyContainer ¶
type UnhealthyGetter ¶
type UnhealthyGetter interface {
GetUnhealthy(ctx context.Context) (unhealthies []UnhealthyContainer, err error)
}
type UnhealthyStreamer ¶
type UnhealthyStreamer interface {
StreamUnhealthy(ctx context.Context, unhealthies chan<- UnhealthyContainer, crashed chan<- error)
}
Click to show internal directories.
Click to hide internal directories.