agent

package

v1.9.0-crc0 Latest Latest Go to latest Published: Apr 9, 2025 License: Apache-2.0 Imports: 35 Imported by: 0

Details

This section is empty.

This section is empty.

func IPsFromInterface(ifaceName string) ([]netip.Addr, error)

Default function for getting the list of IPs configured for a specific network interface

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

Flows reporting agent

func FlowsAgent(cfg *config.Agent) (*Flows, error)

FlowsAgent instantiates a new agent, given a configuration.

func (f *Flows) Run(ctx context.Context) error

Run a Flows agent. The function will keep running in the same thread until the passed context is canceled

func (f *Flows) Status() Status

type InterfaceFilter interface {
	Allowed(iface string) (bool, error)
}

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

Packets reporting agent

func PacketsAgent(cfg *config.Agent) (*Packets, error)

PacketsAgent instantiates a new agent, given a configuration.

func (p *Packets) Run(ctx context.Context) error

Run a Packets agent. The function will keep running in the same thread until the passed context is canceled

func (p *Packets) Status() Status

type Status int

Status of the agent service. Helps on the health report as well as making some asynchronous tests waiting for the agent to accept flows.

const (
	StatusNotStarted Status = iota
	StatusStarting
	StatusStarted
	StatusStopping
	StatusStopped
)

func (s Status) String() string