containers

package

v1.2.1 Latest Latest Go to latest Published: Nov 23, 2022 License: Apache-2.0 Imports: 30 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/coroot/coroot-node-agent

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func ConntrackGetActualDestination(src, dst netaddr.IPPort) netaddr.IPPort
func ConntrackInit() error
func ContainerdInit() error
func DockerdInit() error
func JournaldInit() error
func JournaldSubscribe(cg *cgroup.Cgroup, ch chan<- logparser.LogEntry) error
func JournaldUnsubscribe(cg *cgroup.Cgroup)
func TaskstatsInit() error
func TaskstatsPID(pid uint32) (*taskstats.Stats, error)
func TaskstatsTGID(pid uint32) (*taskstats.Stats, error)
type ActiveConnection
type AddrPair
type Container
- func NewContainer(cg *cgroup.Cgroup, md *ContainerMetadata) *Container
- func (c *Container) Close()
- func (c *Container) Collect(ch chan<- prometheus.Metric)
- func (c *Container) Dead(now time.Time) bool
- func (c *Container) Describe(ch chan<- *prometheus.Desc)
type ContainerID
type ContainerMetadata
- func ContainerdInspect(containerID string) (*ContainerMetadata, error)
- func DockerdInspect(containerID string) (*ContainerMetadata, error)
type Delays
type L7Stats
type LogParser
- func (p *LogParser) Stop()
type Registry
- func NewRegistry(reg prometheus.Registerer, kernelVersion string) (*Registry, error)
- func (r *Registry) Close()

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	L7Requests = map[ebpftracer.L7Protocol]prometheus.CounterOpts{
		ebpftracer.L7ProtocolHTTP:      {Name: "container_http_requests_total", Help: "Total number of outbound HTTP requests"},
		ebpftracer.L7ProtocolPostgres:  {Name: "container_postgres_queries_total", Help: "Total number of outbound Postgres queries"},
		ebpftracer.L7ProtocolRedis:     {Name: "container_redis_queries_total", Help: "Total number of outbound Redis queries"},
		ebpftracer.L7ProtocolMemcached: {Name: "container_memcached_queries_total", Help: "Total number of outbound Memcached queries"},
		ebpftracer.L7ProtocolMysql:     {Name: "container_mysql_queries_total", Help: "Total number of outbound Mysql queries"},
		ebpftracer.L7ProtocolMongo:     {Name: "container_mongo_queries_total", Help: "Total number of outbound Mongo queries"},
	}
	L7Latency = map[ebpftracer.L7Protocol]prometheus.HistogramOpts{
		ebpftracer.L7ProtocolHTTP:      {Name: "container_http_request_duration_seconds_total", Help: "Histogram of the response time for each outbound HTTP request"},
		ebpftracer.L7ProtocolPostgres:  {Name: "container_postgres_queries_duration_seconds_total", Help: "Histogram of the execution time for each outbound Postgres query"},
		ebpftracer.L7ProtocolRedis:     {Name: "container_redis_queries_duration_seconds_total", Help: "Histogram of the execution time for each outbound Redis query"},
		ebpftracer.L7ProtocolMemcached: {Name: "container_memcached_queries_duration_seconds_total", Help: "Histogram of the execution time for each outbound Memcached query"},
		ebpftracer.L7ProtocolMysql:     {Name: "container_mysql_queries_duration_seconds_total", Help: "Histogram of the execution time for each outbound Mysql query"},
		ebpftracer.L7ProtocolMongo:     {Name: "container_mongo_queries_duration_seconds_total", Help: "Histogram of the execution time for each outbound Mongo query"},
	}
)

Functions ¶

func ConntrackGetActualDestination ¶

func ConntrackGetActualDestination(src, dst netaddr.IPPort) netaddr.IPPort

func ConntrackInit ¶

func ConntrackInit() error

func ContainerdInit ¶

func ContainerdInit() error

func DockerdInit ¶

func DockerdInit() error

func JournaldInit ¶

func JournaldInit() error

func JournaldSubscribe ¶

func JournaldSubscribe(cg *cgroup.Cgroup, ch chan<- logparser.LogEntry) error

func JournaldUnsubscribe ¶

func JournaldUnsubscribe(cg *cgroup.Cgroup)

func TaskstatsInit ¶

func TaskstatsInit() error

func TaskstatsPID ¶

func TaskstatsPID(pid uint32) (*taskstats.Stats, error)

func TaskstatsTGID ¶

func TaskstatsTGID(pid uint32) (*taskstats.Stats, error)

Types ¶

type ActiveConnection ¶ added in v1.2.0

type ActiveConnection struct {
	ActualDest netaddr.IPPort
	Pid        uint32
	Fd         uint64
	Timestamp  uint64
	Closed     time.Time
}

type AddrPair ¶

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

type Container ¶

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

func NewContainer ¶

func NewContainer(cg *cgroup.Cgroup, md *ContainerMetadata) *Container

func (*Container) Close ¶

func (c *Container) Close()

func (*Container) Collect ¶

func (c *Container) Collect(ch chan<- prometheus.Metric)

func (*Container) Dead ¶

func (c *Container) Dead(now time.Time) bool

func (*Container) Describe ¶

func (c *Container) Describe(ch chan<- *prometheus.Desc)

type ContainerID ¶

type ContainerID string

type ContainerMetadata ¶

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

func ContainerdInspect ¶

func ContainerdInspect(containerID string) (*ContainerMetadata, error)

func DockerdInspect ¶

func DockerdInspect(containerID string) (*ContainerMetadata, error)

type Delays ¶

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

type L7Stats ¶ added in v1.2.0

type L7Stats struct {
	Requests *prometheus.CounterVec
	Latency  prometheus.Histogram
}

type LogParser ¶

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

func (*LogParser) Stop ¶

func (p *LogParser) Stop()

type Registry ¶

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

func NewRegistry ¶

func NewRegistry(reg prometheus.Registerer, kernelVersion string) (*Registry, error)

func (*Registry) Close ¶

func (r *Registry) Close()

Source Files ¶

View all Source files

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