docker

type Container struct {
	ID     string
	Name   string
	Image  string
	Status string
	// ManagementPort is the host port mapped to the container's
	// 15672/tcp (Management API) port, or 0 if that port isn't published
	// to the host (e.g. host networking, or a non-standard setup).
	ManagementPort int
}

type ContainerClient interface {
	// FindRabbitMQContainers lists running containers whose image name
	// contains "rabbitmq".
	FindRabbitMQContainers(ctx context.Context) ([]Container, error)
	Stats(ctx context.Context, id string) (Stats, error)
	Start(ctx context.Context, id string) error
	Stop(ctx context.Context, id string) error
	Restart(ctx context.Context, id string) error
	// Logs returns a stream of the container's logs; the caller must close it.
	Logs(ctx context.Context, id string, tailLines int) (io.ReadCloser, error)
}

type FakeClient struct {
	Containers []Container
	StatsByID  map[string]Stats
	LogsByID   map[string]string

	// Calls records every mutating call made, in order, as
	// "action:containerID" (e.g. "start:abc123"), so tests can assert on
	// what the code under test actually did.
	Calls []string

	// ErrByAction, if set for an action name ("start", "stop", "restart"),
	// makes that action return the given error instead of succeeding.
	ErrByAction map[string]error
}

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

type Stats struct {
	CPUPercent float64
	MemPercent float64
}