visitor

Documentation

Index

• Constants
• Variables
• func PingDocker(_client *client.Client) error
• type Watcher
  • func New(client *client.Client) *Watcher
  • func (w *Watcher) Container(id string) *types.ContainerJSON
  • func (w *Watcher) Find(visitor func(*types.ContainerJSON) (bool, error)) ([]*types.ContainerJSON, error)
  • func (w *Watcher) Ready()
  • func (w *Watcher) Start(ctx context.Context) error
  • func (w *Watcher) VisitCurrentCointainer(visitor func(container *types.ContainerJSON) error)
  • func (w *Watcher) WatchFor(visitor func(action string, container *types.ContainerJSON), labels ...string)

Constants

const (
	START     = "start" // Container action
	STOP      = "stop"  // Container action
	DIE       = "die"   // Container action
	DESTROY   = "destroy"
	CONTAINER = "container"
	EVENT     = "event"
)

Variables

var (
	// DockerTries is the number of retries
	DockerTries = 12
)

Functions

func PingDocker

func PingDocker(_client *client.Client) error

PingDocker ping Docker, try 12 times, wait 5s

Types

type Watcher

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

func New

func New(client *client.Client) *Watcher

New Watcher, from a Docker client

func (*Watcher) Container

func (w *Watcher) Container(id string) *types.ContainerJSON

func (*Watcher) Find

func (w *Watcher) Find(visitor func(*types.ContainerJSON) (bool, error)) ([]*types.ContainerJSON, error)

func (*Watcher) Ready

func (w *Watcher) Ready()

Ready when already here containers are known

func (*Watcher) Start

func (w *Watcher) Start(ctx context.Context) error

Start watching Docker events

func (*Watcher) VisitCurrentCointainer

func (w *Watcher) VisitCurrentCointainer(visitor func(container *types.ContainerJSON) error)

VisitCurrentCointainer visit already present containers

func (*Watcher) WatchFor

func (w *Watcher) WatchFor(visitor func(action string, container *types.ContainerJSON), labels ...string)

WatchFor visitor function and label names