overlay

Documentation

Index

• Constants
• Variables
• type DockerClient
• type Weave
  • func NewWeave(hostID string, client weave.Client, dockerEndpoint string) (*Weave, error)
  • func (*Weave) Name() string
  • func (w *Weave) Report() (report.Report, error)
  • func (w *Weave) Stop()
  • func (w *Weave) Tag(r report.Report) (report.Report, error)

Constants

const (
	WeavePeerName                          = "weave_peer_name"
	WeavePeerNickName                      = "weave_peer_nick_name"
	WeaveDNSHostname                       = "weave_dns_hostname"
	WeaveMACAddress                        = "weave_mac_address"
	WeaveVersion                           = "weave_version"
	WeaveEncryption                        = "weave_encryption"
	WeaveProtocol                          = "weave_protocol"
	WeavePeerDiscovery                     = "weave_peer_discovery"
	WeaveTargetCount                       = "weave_target_count"
	WeaveConnectionCount                   = "weave_connection_count"
	WeavePeerCount                         = "weave_peer_count"
	WeaveTrustedSubnets                    = "weave_trusted_subnet_count"
	WeaveIPAMTableID                       = "weave_ipam_table"
	WeaveIPAMStatus                        = "weave_ipam_status"
	WeaveIPAMRange                         = "weave_ipam_range"
	WeaveIPAMDefaultSubnet                 = "weave_ipam_default_subnet"
	WeaveDNSTableID                        = "weave_dns_table"
	WeaveDNSDomain                         = "weave_dns_domain"
	WeaveDNSUpstream                       = "weave_dns_upstream"
	WeaveDNSTTL                            = "weave_dns_ttl"
	WeaveDNSEntryCount                     = "weave_dns_entry_count"
	WeaveProxyTableID                      = "weave_proxy_table"
	WeaveProxyStatus                       = "weave_proxy_status"
	WeaveProxyAddress                      = "weave_proxy_address"
	WeavePluginTableID                     = "weave_plugin_table"
	WeavePluginStatus                      = "weave_plugin_status"
	WeavePluginDriver                      = "weave_plugin_driver"
	WeaveConnectionsConnection             = "weave_connection_connection"
	WeaveConnectionsState                  = "weave_connection_state"
	WeaveConnectionsInfo                   = "weave_connection_info"
	WeaveConnectionsTablePrefix            = "weave_connections_table_"
	WeaveConnectionsMulticolumnTablePrefix = "weave_connections_multicolumn_table_"
)

Keys for use in Node

Variables

var (
	// NewDockerClientStub is used for testing
	NewDockerClientStub = newDockerClient
)

Types

type DockerClient

type DockerClient interface {
	CreateExec(docker_client.CreateExecOptions) (*docker_client.Exec, error)
	StartExec(string, docker_client.StartExecOptions) error
	InspectContainer(id string) (*docker_client.Container, error)
}

DockerClient is used for testing

type Weave

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

Weave represents a single Weave router, presumably on the same host as the probe. It is both a Reporter and a Tagger: it produces an Overlay topology, and (in theory) can tag existing topologies with foreign keys to overlay -- though I'm not sure what that would look like in practice right now.

func NewWeave

func NewWeave(hostID string, client weave.Client, dockerEndpoint string) (*Weave, error)

NewWeave returns a new Weave tagger based on the Weave router at address. The address should be an IP or FQDN, no port.

func (*Weave) Name

func (*Weave) Name() string

Name of this reporter/tagger/ticker, for metrics gathering

func (*Weave) Report

func (w *Weave) Report() (report.Report, error)

Report implements Reporter.

func (*Weave) Stop

func (w *Weave) Stop()

Stop gathering weave ps output.

func (*Weave) Tag

func (w *Weave) Tag(r report.Report) (report.Report, error)

Tag implements Tagger.