collector

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 21, 2019 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Collector

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

Collector ...

func NewCollector

func NewCollector(cfg *config.Config, publisher Publisher) (*Collector, error)

NewCollector ...

type MessageBusLocalPublisher

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

MessageBusLocalPublisher ...

func NewMessageBusLocalPublisher

func NewMessageBusLocalPublisher(msgbus *msgbus.MessageBus) *MessageBusLocalPublisher

NewMessageBusLocalPublisher ...

func (*MessageBusLocalPublisher) Publish

func (p *MessageBusLocalPublisher) Publish(topic string, payload []byte) error

Publish ...

type MessageBusRemotePublisher

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

MessageBusRemotePublisher ...

func NewMessageBusRemotePublisher

func NewMessageBusRemotePublisher(url string) *MessageBusRemotePublisher

NewMessageBusRemotePublisher ...

func (*MessageBusRemotePublisher) Publish

func (p *MessageBusRemotePublisher) Publish(topic string, payload []byte) error

Publish ...

type Node

type Node struct {
	ID             string   `json:"id,omitempty"`
	Name           string   `json:"name,omitempty"`
	Addr           string   `json:"addr,omitempty"`
	Containers     string   `json:"containers,omitempty"`
	ReservedCPUs   string   `json:"reserved_cpus,omitempty"`
	ReservedMemory string   `json:"reserved_memory,omitempty"`
	Labels         []string `json:"labels,omitempty"`
}

type Publisher

type Publisher interface {
	Publish(topic string, payload []byte) error
}

Publisher ...

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL