sysdig

Documentation

Overview

Package sysdig provides a source implementation to integrate with Sysdig Secure. It queries the SysQL API to fetch vulnerability data for container images and pushes results through IBDM's standard pipeline.

Index

• Variables
• type Source
  • func NewSource() (*Source, error)
  • func (s *Source) StartSyncProcess(ctx context.Context, typesToSync map[string]source.Extra, ...) error

Variables

var (
	// ErrMissingEnvVariable reports missing mandatory environment variables.
	ErrMissingEnvVariable = errors.New("missing environment variable")
	// ErrInvalidEnvVariable reports malformed environment variable values.
	ErrInvalidEnvVariable = errors.New("invalid environment value")
)

var (
	// ErrSysdigSource wraps all errors originating from the Sysdig source.
	ErrSysdigSource = errors.New("sysdig source")
)

Types

type Source

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

Source implements source.SyncableSource for Sysdig Secure. It queries the SysQL API to fetch vulnerability data and pushes results through the IBDM pipeline.

func NewSource

func NewSource() (*Source, error)

NewSource constructs a Source by reading its configuration from environment variables and initialising the underlying HTTP client. It returns ErrSysdigSource if the configuration is invalid.

func (*Source) StartSyncProcess

func (s *Source) StartSyncProcess(ctx context.Context, typesToSync map[string]source.Extra, results chan<- source.Data) error

StartSyncProcess performs a full synchronisation of the requested resource types by querying the Sysdig SysQL API and sending results to results. Only known data types are processed; unknown types are skipped with a debug log message.