net

Documentation

Overview

Package net provides local access to system probe

Index

• Variables
• func CheckPath(path string) error
• type Conn
• type RemoteSysProbeUtil
  • func (r *RemoteSysProbeUtil) GetConnections(clientID string) (*model.Connections, error)
  • func (r *RemoteSysProbeUtil) GetNetworkID() (string, error)
  • func (r *RemoteSysProbeUtil) GetPing(clientID string, host string, count int, interval time.Duration, ...) ([]byte, error)
  • func (r *RemoteSysProbeUtil) GetProcStats(pids []int32) (*model.ProcStatsWithPermByPID, error)
  • func (r *RemoteSysProbeUtil) GetTraceroute(clientID string, host string, port uint16, protocol nppayload.Protocol, ...) ([]byte, error)
  • func (r *RemoteSysProbeUtil) Register(clientID string) error
• type SysProbeUtil
  • func GetRemoteSystemProbeUtil(path string) (SysProbeUtil, error)
• type SysProbeUtilGetter

Variables

var (
	// ErrNotImplemented is an error used when system-probe is attempted to be accessed on an unsupported OS
	ErrNotImplemented = errors.New("system-probe unsupported")
)

Functions

func CheckPath

func CheckPath(path string) error

CheckPath is used in conjunction with calling the stats endpoint, since we are calling this From the main agent and want to ensure the socket exists

Types

type Conn

type Conn interface {
	// GetListener returns the underlying net.Listener
	GetListener() net.Listener

	// Stop and clean up resources for the underlying connection
	Stop()
}

Conn is a wrapper over some net.Listener

type RemoteSysProbeUtil

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

RemoteSysProbeUtil wraps interactions with a remote system probe service

func (*RemoteSysProbeUtil) GetConnections

func (r *RemoteSysProbeUtil) GetConnections(clientID string) (*model.Connections, error)

GetConnections returns a set of active network connections, retrieved from the system probe service

func (*RemoteSysProbeUtil) GetNetworkID

func (r *RemoteSysProbeUtil) GetNetworkID() (string, error)

GetNetworkID fetches the network_id (vpc_id) from system-probe

func (*RemoteSysProbeUtil) GetPing

func (r *RemoteSysProbeUtil) GetPing(clientID string, host string, count int, interval time.Duration, timeout time.Duration) ([]byte, error)

GetPing returns the results of a ping to a host

func (*RemoteSysProbeUtil) GetProcStats

func (r *RemoteSysProbeUtil) GetProcStats(pids []int32) (*model.ProcStatsWithPermByPID, error)

GetProcStats returns a set of process stats by querying system-probe

func (*RemoteSysProbeUtil) GetTraceroute

func (r *RemoteSysProbeUtil) GetTraceroute(clientID string, host string, port uint16, protocol nppayload.Protocol, maxTTL uint8, timeout time.Duration) ([]byte, error)

GetTraceroute returns the results of a traceroute to a host

func (*RemoteSysProbeUtil) Register

func (r *RemoteSysProbeUtil) Register(clientID string) error

Register registers the client to system probe

type SysProbeUtil

type SysProbeUtil interface {
	GetConnections(clientID string) (*model.Connections, error)
	GetProcStats(pids []int32) (*model.ProcStatsWithPermByPID, error)
	Register(clientID string) error
	GetNetworkID() (string, error)
	GetPing(clientID string, host string, count int, interval time.Duration, timeout time.Duration) ([]byte, error)
	GetTraceroute(clientID string, host string, port uint16, protocol nppayload.Protocol, maxTTL uint8, timeout time.Duration) ([]byte, error)
}

SysProbeUtil fetches info from the SysProbe running remotely

func GetRemoteSystemProbeUtil

func GetRemoteSystemProbeUtil(path string) (SysProbeUtil, error)

GetRemoteSystemProbeUtil returns a ready to use RemoteSysProbeUtil. It is backed by a shared singleton.

type SysProbeUtilGetter

type SysProbeUtilGetter func(string) (SysProbeUtil, error)

SysProbeUtilGetter is a function that returns a SysProbeUtil for the given path The standard implementation is GetRemoteSysProbeUtil