metrics

Documentation

Index

• Constants
• Variables
• func FilteredHostMetricsHandler() http.Handler
• func GetFilteredHostMetrics(ctx context.Context) (*bytes.Buffer, error)
• func HostMetricsHandler(ncConfig *NodeCollectorConfig) (*http.Handler, error)
• func NewNodeCollector(config *NodeCollectorConfig) (*collector.NodeCollector, error)
• type MetricsPusher
  • func NewMetricsPusher(client *client.Client, serviceMetricsFetcher *ServiceMetricsFetcher) *MetricsPusher
  • func (m *MetricsPusher) PushDeviceMetrics(ctx *dpcontext.Context)
  • func (m *MetricsPusher) PushServiceMetrics(ctx *dpcontext.Context)
  • func (m *MetricsPusher) SetBundle(bundle models.Bundle)
• type NodeCollectorConfig
• type ServiceMetricsFetcher
  • func NewServiceMetricsFetcher(supervisorLookup supervisor.Lookup, netnsManager *netns.Manager) *ServiceMetricsFetcher
  • func (s *ServiceMetricsFetcher) ContainerServiceMetrics(ctx context.Context, applicationID, service string, port int, path string) (*http.Response, error)

Constants

const MaxRequestsInFlight = 3

This should be more than enough concurrent requests. We're only polling this once per device (non-concurrently), so other requests come from customer API calls. If we exceed this count, we're probably doing something wrong.

Variables

var (
	ErrInvalidCollector = errors.New("invalid collector")

	DefaultNodeCollectorConfig = NodeCollectorConfig{
		ProcFSPath: "/proc",
		SysFSPath:  "/sys",
		RootFSPath: "/",
		Collectors: []string{
			"cpu",
			"diskstats",
			"filesystem",
			"loadavg",
			"meminfo",
			"textfile",
			"time",
			"netdev",
		},
	}
)

Functions

func FilteredHostMetricsHandler

func FilteredHostMetricsHandler() http.Handler

func GetFilteredHostMetrics

func GetFilteredHostMetrics(ctx context.Context) (*bytes.Buffer, error)

func HostMetricsHandler

func HostMetricsHandler(ncConfig *NodeCollectorConfig) (*http.Handler, error)

func NewNodeCollector

func NewNodeCollector(config *NodeCollectorConfig) (*collector.NodeCollector, error)

Types

type MetricsPusher

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

func NewMetricsPusher

func NewMetricsPusher(
	client *client.Client,
	serviceMetricsFetcher *ServiceMetricsFetcher,
) *MetricsPusher

func (*MetricsPusher) PushDeviceMetrics

func (m *MetricsPusher) PushDeviceMetrics(ctx *dpcontext.Context)

func (*MetricsPusher) PushServiceMetrics

func (m *MetricsPusher) PushServiceMetrics(ctx *dpcontext.Context)

func (*MetricsPusher) SetBundle

func (m *MetricsPusher) SetBundle(bundle models.Bundle)

type NodeCollectorConfig

type NodeCollectorConfig struct {
	ProcFSPath string
	SysFSPath  string
	RootFSPath string
	Collectors []string
}

type ServiceMetricsFetcher

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

func NewServiceMetricsFetcher

func NewServiceMetricsFetcher(
	supervisorLookup supervisor.Lookup,
	netnsManager *netns.Manager,
) *ServiceMetricsFetcher

func (*ServiceMetricsFetcher) ContainerServiceMetrics

func (s *ServiceMetricsFetcher) ContainerServiceMetrics(ctx context.Context, applicationID, service string, port int, path string) (*http.Response, error)