net

package
v0.0.0-...-2feb83d Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 30, 2024 License: Apache-2.0 Imports: 27 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source
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 GetRemoteSystemProbeUtil

func GetRemoteSystemProbeUtil(path string) (*RemoteSysProbeUtil, error)

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

func (*RemoteSysProbeUtil) DetectLanguage

func (r *RemoteSysProbeUtil) DetectLanguage(pids []int32) ([]languagemodels.Language, error)

func (*RemoteSysProbeUtil) GetCheck

func (r *RemoteSysProbeUtil) GetCheck(module sysconfigtypes.ModuleName) (interface{}, error)

GetCheck returns the check output of the specified module

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) 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) GetPprof

func (r *RemoteSysProbeUtil) GetPprof(path string) ([]byte, error)

GetPprof queries the pprof endpoint for system-probe

func (*RemoteSysProbeUtil) GetProcStats added in v0.9.0

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

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

func (*RemoteSysProbeUtil) GetStats

func (r *RemoteSysProbeUtil) GetStats() (map[string]interface{}, error)

GetStats returns the expvar stats of the system probe

func (*RemoteSysProbeUtil) GetTraceroute

func (r *RemoteSysProbeUtil) GetTraceroute(clientID string, host string, port uint16, maxTTL uint8, timeout uint) ([]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)
	GetStats() (map[string]interface{}, error)
	GetProcStats(pids []int32) (*model.ProcStatsWithPermByPID, error)
	Register(clientID string) error
}

SysProbeUtil fetches info from the SysProbe running remotely

type UDSListener

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

UDSListener (Unix Domain Socket Listener)

func NewListener

func NewListener(socketAddr string) (*UDSListener, error)

NewListener returns an idle UDSListener

func (*UDSListener) GetListener

func (l *UDSListener) GetListener() net.Listener

GetListener will return the underlying Conn's net.Listener

func (*UDSListener) Stop

func (l *UDSListener) Stop()

Stop closes the UDSListener connection and stops listening

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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