Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

complianceeventsapi

package

Go to main page

Versions in this module

v0

v0.15.0

Oct 3, 2024

v0.14.0

Jun 6, 2024

Changes in this version

type Policy

+ SpecID int32

+ type Spec struct

+ KeyID int32

+ Spec JSONMap

+ func (s *Spec) GetOrCreate(ctx context.Context, db *sql.DB) error

+ func (s *Spec) InsertQuery() (string, []any)

+ func (s *Spec) SelectQuery(returnedColumns ...string) (string, []any)

v0.13.0

Feb 29, 2024

Changes in this version

+ var ErrDBConnectionFailed = errors.New("the compliance events database could not be connected to")

+ var ErrForbidden = errors.New("the request is not allowed")

+ var ErrInvalidConnectionURL = errors.New("the database connection URL is invalid")

+ var ErrInvalidQueryArg error

+ var ErrInvalidQueryArgValue = errors.New("invalid query argument")

+ var ErrInvalidSortOption error

+ var ErrNoAccess = errors.New("the user has no access")

+ var ErrRetryable = errors.New("")

+ var ErrUnauthorized = errors.New("not authorized")

+ func GetClusterForeignKey(ctx context.Context, db *sql.DB, cluster Cluster) (int32, error)

+ func MonitorDatabaseConnection(ctx context.Context, complianceServerCtx *ComplianceServerCtx, ...)

+ func ParseDBSecret(dbSecret *corev1.Secret, tempDirPath string) (string, error)

+ func RecordLocalClusterComplianceEvent(ctx context.Context, complianceServerCtx *ComplianceServerCtx, ...) error

+ type Cluster struct

+ ClusterID string

+ KeyID int32

+ Name string

+ func (c *Cluster) GetOrCreate(ctx context.Context, db *sql.DB) error

+ func (c *Cluster) InsertQuery() (string, []any)

+ func (c *Cluster) SelectQuery(returnedColumns ...string) (string, []any)

+ func (c Cluster) Validate() error

+ type ComplianceAPIServer struct

+ func NewComplianceAPIServer(listenAddress string, cfg *rest.Config, cert *tls.Certificate) *ComplianceAPIServer

+ func (s *ComplianceAPIServer) Start(ctx context.Context, serverContext *ComplianceServerCtx) error

+ type ComplianceDBSecretReconciler struct

+ Client *kubernetes.Clientset

+ ComplianceServerCtx *ComplianceServerCtx

+ ConnectionURL string

+ DynamicWatcher k8sdepwatches.DynamicWatcher

+ TempDir string

+ func (r *ComplianceDBSecretReconciler) Reconcile(ctx context.Context, watcher k8sdepwatches.ObjectIdentifier) (ctrl.Result, error)

+ type ComplianceEvent struct

+ Cluster Cluster

+ Event EventDetails

+ EventID int32

+ ParentPolicy *ParentPolicy

+ Policy Policy

+ func (ce *ComplianceEvent) Create(ctx context.Context, db *sql.DB) error

+ func (ce ComplianceEvent) Validate(ctx context.Context, serverContext *ComplianceServerCtx) error

+ type ComplianceServerCtx struct

+ ClusterID string

+ DB *sql.DB

+ Lock sync.RWMutex

+ ParentPolicyToID sync.Map

+ PolicyToID sync.Map

+ Queue workqueue.Interface

+ func NewComplianceServerCtx(dbConnectionURL string, clusterID string) (*ComplianceServerCtx, error)

+ func (c *ComplianceServerCtx) MigrateDB(ctx context.Context, client *kubernetes.Clientset, controllerNamespace string) error

+ type EventDetails struct

+ ClusterID int32

+ Compliance string

+ KeyID int32

+ Message string

+ Metadata JSONMap

+ ParentPolicyID *int32

+ PolicyID int32

+ ReportedBy *string

+ Timestamp time.Time

+ func (e *EventDetails) InsertQuery() (string, []any)

+ func (e EventDetails) Validate() error

+ type EventDetailsQueued struct

+ ClusterID int32

+ Compliance string

+ Message string

+ ParentPolicyID int32

+ PolicyID int32

+ ReportedBy string

+ Timestamp time.Time

+ func (e *EventDetailsQueued) EventDetails() *EventDetails

+ func (e *EventDetailsQueued) InsertQuery() (string, []any)

+ type JSONMap map[string]interface

+ func (j *JSONMap) Scan(src interface{}) error

+ func (j JSONMap) Value() (driver.Value, error)

+ type ListResponse struct

+ Data []ComplianceEvent

+ Metadata metadata

+ type ParentPolicy struct

+ Categories pq.StringArray

+ Controls pq.StringArray

+ KeyID int32

+ Name string

+ Namespace string

+ Standards pq.StringArray

+ func ParentPolicyFromPolicyObj(plc *policiesv1.Policy) ParentPolicy

+ func (p *ParentPolicy) GetOrCreate(ctx context.Context, db *sql.DB) error

+ func (p *ParentPolicy) InsertQuery() (string, []any)

+ func (p *ParentPolicy) SelectQuery(returnedColumns ...string) (string, []any)

+ func (p ParentPolicy) Key() string

+ func (p ParentPolicy) Validate() error

+ type Policy struct

+ APIGroup string

+ KeyID int32

+ Kind string

+ Name string

+ Namespace *string

+ Severity *string

+ Spec JSONMap

+ func PolicyFromUnstructured(obj unstructured.Unstructured) *Policy

+ func (p *Policy) GetOrCreate(ctx context.Context, db *sql.DB) error

+ func (p *Policy) InsertQuery() (string, []any)

+ func (p *Policy) Key() string

+ func (p *Policy) SelectQuery(returnedColumns ...string) (string, []any)

+ func (p *Policy) Validate() error

+ type Scannable interface

+ Scan func(dest ...any) error

v0.12.0

Oct 6, 2023

Changes in this version

+ const ControllerName

+ const DBSecretName

+ const WatchNamespaceEnvVar

+ var ErrCouldNotStart = errors.New("the compliance events API manager could not be started")

+ var ErrInvalidDBSecret = errors.New("the governance-policy-database secret is invalid")

+ func StartManager(ctx context.Context, k8sConfig *rest.Config, enableLeaderElection bool) error

+ type ComplianceEventsAPIReconciler struct

+ Scheme *k8sruntime.Scheme

+ TempDir string

+ func (r *ComplianceEventsAPIReconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)

+ func (r *ComplianceEventsAPIReconciler) SetupWithManager(mgr ctrl.Manager) error