bridge

Documentation

Overview

generated by go-extpoints -- DO NOT EDIT

Index

• Variables
• func Register(component interface{}, name string) []string
• func Unregister(name string) []string
• type AdapterFactory
• type Bridge
  • func New(docker *dockerapi.Client, adapterUri string, config Config) (*Bridge, error)
  • func (b *Bridge) Add(containerId string)
  • func (b *Bridge) Ping() error
  • func (b *Bridge) Refresh()
  • func (b *Bridge) Remove(containerId string)
  • func (b *Bridge) RemoveOnExit(containerId string)
  • func (b *Bridge) SetupSigtermBehavior(behavior string, msg *dockerapi.APIEvents, ttl int, checkStatus string)
  • func (b *Bridge) Sync(quiet bool)
• type Config
• type ContainersFilters
  • func (f *ContainersFilters) Set(value string) error
  • func (f *ContainersFilters) String() string
  • func (f *ContainersFilters) WithContainerId(containerId string) ContainersFilters
• type DeadContainer
• type RegistryAdapter
• type Service
• type ServicePort
• type TtlHealthCheck

Variables

var AdapterFactories = &adapterFactoryExt{
	newExtensionPoint(new(AdapterFactory)),
}

var Hostname string

Functions

func Register

func Register(component interface{}, name string) []string

func Unregister

func Unregister(name string) []string

Types

type AdapterFactory

type AdapterFactory interface {
	New(uri *url.URL) RegistryAdapter
}

type Bridge

type Bridge struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func New

func New(docker *dockerapi.Client, adapterUri string, config Config) (*Bridge, error)

func (*Bridge) Add

func (b *Bridge) Add(containerId string)

func (*Bridge) Ping

func (b *Bridge) Ping() error

func (*Bridge) Refresh

func (b *Bridge) Refresh()

func (*Bridge) Remove

func (b *Bridge) Remove(containerId string)

func (*Bridge) RemoveOnExit

func (b *Bridge) RemoveOnExit(containerId string)

func (*Bridge) SetupSigtermBehavior

func (b *Bridge) SetupSigtermBehavior(behavior string, msg *dockerapi.APIEvents, ttl int, checkStatus string)

func (*Bridge) Sync

func (b *Bridge) Sync(quiet bool)

type Config

type Config struct {
	HostIp            string
	Internal          bool
	UseIpFromLabel    string
	ForceTags         string
	RefreshTtl        int
	RefreshInterval   int
	DeregisterCheck   string
	Cleanup           bool
	ContainersFilters ContainersFilters
}

type ContainersFilters

type ContainersFilters map[string][]string

func (*ContainersFilters) Set

func (f *ContainersFilters) Set(value string) error

func (*ContainersFilters) String

func (f *ContainersFilters) String() string

func (*ContainersFilters) WithContainerId

func (f *ContainersFilters) WithContainerId(containerId string) ContainersFilters

type DeadContainer

type DeadContainer struct {
	TTL      int
	Services []*Service
}

type RegistryAdapter

type RegistryAdapter interface {
	Ping() error
	Register(service *Service) error
	Deregister(service *Service) error
	SetupHealthCheck(service *Service, healthCheck *TtlHealthCheck) error
	Refresh(service *Service) error
	Services() ([]*Service, error)
}

type Service

type Service struct {
	ID    string
	Name  string
	Port  int
	IP    string
	Tags  []string
	Attrs map[string]string
	TTL   int

	Origin ServicePort
}

type ServicePort

type ServicePort struct {
	HostPort          string
	HostIP            string
	ExposedPort       string
	ExposedIP         string
	PortType          string
	ContainerHostname string
	ContainerID       string
	ContainerName     string
	// contains filtered or unexported fields
}

type TtlHealthCheck

type TtlHealthCheck struct {
	TTL         int
	CheckStatus string
}