Documentation
¶
Index ¶
- func Main()
- type ContainerEventRepeater
- type MetricsCounters
- type ProcessInfoCache
- type Sensor
- func (s *Sensor) NewEvent() *api.Event
- func (s *Sensor) NewEventFromContainer(containerId string) *api.Event
- func (s *Sensor) NewEventFromSample(sample *perf.SampleRecord, data perf.TraceEventSampleData) *api.Event
- func (s *Sensor) NewSubscription(sub *api.Subscription) (*stream.Stream, error)
- func (s *Sensor) Start() error
- func (s *Sensor) Stop()
- type TelemetryService
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type ContainerEventRepeater ¶
type ContainerEventRepeater struct {
// contains filtered or unexported fields
}
func NewContainerEventRepeater ¶
func NewContainerEventRepeater(sensor *Sensor) (*ContainerEventRepeater, error)
func (*ContainerEventRepeater) NewEventStream ¶
func (cer *ContainerEventRepeater) NewEventStream(sub *api.Subscription) (*stream.Stream, error)
type MetricsCounters ¶
type MetricsCounters struct {
// Number of events created during the sample period
Events uint64
// Number of subscriptions
Subscriptions int32
}
Counters used for metrics
type ProcessInfoCache ¶
type ProcessInfoCache struct {
// contains filtered or unexported fields
}
func NewProcessInfoCache ¶
func NewProcessInfoCache(sensor *Sensor) ProcessInfoCache
func (*ProcessInfoCache) ProcessContainerId ¶
func (pc *ProcessInfoCache) ProcessContainerId(pid int) (string, bool)
processContainerId returns the container ID that the process indicated by the given host PID.
type Sensor ¶
type Sensor struct {
// Unique Id for this sensor. Sensor Ids are ephemeral.
Id string
// Metrics counters for this sensor
Metrics MetricsCounters
// contains filtered or unexported fields
}
Sensor represents the state of the singleton Sensor instance
func (*Sensor) NewEventFromContainer ¶
func (*Sensor) NewEventFromSample ¶
func (s *Sensor) NewEventFromSample(sample *perf.SampleRecord, data perf.TraceEventSampleData) *api.Event
func (*Sensor) NewSubscription ¶
NewSubscription creates a new telemetry subscription from the given api.Subscription descriptor. NewSubscription returns a stream.Stream of api.Events matching the specified filters. Closing the Stream cancels the subscription.
type TelemetryService ¶
type TelemetryService struct {
// contains filtered or unexported fields
}
func NewTelemetryService ¶
func NewTelemetryService(sensor *Sensor, address string) *TelemetryService
func (*TelemetryService) Name ¶
func (ts *TelemetryService) Name() string
func (*TelemetryService) Serve ¶
func (ts *TelemetryService) Serve() error
func (*TelemetryService) Stop ¶
func (ts *TelemetryService) Stop()
Source Files
Click to show internal directories.
Click to hide internal directories.