exporter

Documentation

Index

• Constants
• func NewCAdvisorManager(urls []string) *cAdvisorManager
• func NewClientTLS_gRPC(address string)
• func NewClient_gRPC(address string) *client_gRPC
• type ActionType
• type CollectorClientRPC
• type ExporterManager
  • func (em *ExporterManager) Dispatch(ch <-chan bool)
• type Job
• type MeterDispatcher

Constants

const (
	Key = `` /* 1674-byte string literal not displayed */

	Cert = `` /* 1455-byte string literal not displayed */

)

Functions

func NewCAdvisorManager

func NewCAdvisorManager(urls []string) *cAdvisorManager

func NewClientTLS_gRPC

func NewClientTLS_gRPC(address string)

func NewClient_gRPC

func NewClient_gRPC(address string) *client_gRPC

Types

type ActionType

type ActionType int

const (
	ACTION_START ActionType = iota
	ACTION_PAUSE
	ACTION_CONTINUE
	ACTION_STOP
)

type CollectorClientRPC

type CollectorClientRPC interface {
	Transit(*pb.MeteringReqResp) (*pb.MeteringReqResp, error)
}

type ExporterManager

type ExporterManager struct {
	MeteringNameURLs    map[string][]string
	MetricsCollectorRPC string
	Dispatchers         map[string]MeterDispatcher

	RootPath string
	// contains filtered or unexported fields
}

func (*ExporterManager) Dispatch

func (em *ExporterManager) Dispatch(ch <-chan bool)

type Job

type Job struct {
	Id *ActionType

	Err         error
	LastUpdated time.Time
	// contains filtered or unexported fields
}

type MeterDispatcher

type MeterDispatcher interface {
	RPC(CollectorClientRPC) MeterDispatcher
	StartMetering() map[string]Job
	ReapMetrics(url string) (*pb.MeteringReqResp, error)
	StopMetering()
}