docker

Documentation

Index

• Variables
• func NewDockerSource(opt shared.OptionMap, cce chan *shared.ChangeEvent, wg *sync.WaitGroup, ...) (sources.Source, error)
• type ContainerData
  • func NewContainerData(e shared.Endpoint, h []shared.Host) *ContainerData
• type ContainerMap
• type DockerSource
  • func (ds DockerSource) Initialise() error
  • func (ds *DockerSource) Start()
  • func (ds DockerSource) Stop()

Variables

var InvalidPortError = errors.New("Invalid port")

var (
	MissingDockerUrlError = errors.New("docker url not specified")
)

Functions

func NewDockerSource

func NewDockerSource(
	opt shared.OptionMap,
	cce chan *shared.ChangeEvent,
	wg *sync.WaitGroup,
	sc chan bool,
) (
	sources.Source,
	error,
)

Types

type ContainerData

type ContainerData struct {
	Endpoint  shared.Endpoint
	Hostnames []shared.Host
}

func NewContainerData

func NewContainerData(e shared.Endpoint, h []shared.Host) *ContainerData

type ContainerMap

type ContainerMap map[shared.ContainerID]*ContainerData

type DockerSource

type DockerSource struct {
	Containers ContainerMap
	// contains filtered or unexported fields
}

func (DockerSource) Initialise

func (ds DockerSource) Initialise() error

func (*DockerSource) Start

func (ds *DockerSource) Start()

func (DockerSource) Stop

func (ds DockerSource) Stop()