agent

Documentation

Index

• func GetItems(resources client.ObjectList) []interface{}
• type Config
• type Shipper
  • func NewShipper(config *ShipperConfig) *Shipper
  • func (s *Shipper) Post(payload controlplane.AgentPayload) error
• type ShipperConfig
• type SubjectVersion
• type VersionTrackerReconciler
  • func (r *VersionTrackerReconciler) ExtractSubjectVersion(v v1alpha1.VersionTracker, items []interface{}) SubjectVersion
  • func (r *VersionTrackerReconciler) PrepareThePayload(sv SubjectVersion) controlplane.AgentPayload
  • func (r *VersionTrackerReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *VersionTrackerReconciler) SetupWithManager(mgr ctrl.Manager) error
  • func (r *VersionTrackerReconciler) ShipToControlPlane(ver SubjectVersion) error

Functions

func GetItems

func GetItems(resources client.ObjectList) []interface{}

Returns the list of items from the resources based on the resource type

Types

type Config

type Config struct {
	// The interval between individual synchronizations
	Interval time.Duration
	// Agent Identifier
	ID string
	// Url of Control Plane API
	ControlPlaneUrl string
	// Token to authenticate with Control Plane API
	ControlPlaneAuthToken string
	// Tags
	Tags map[string]string
}

type Shipper

type Shipper struct {
	Client    *http.Client
	BaseURL   string
	AuthToken string
}

func NewShipper

func NewShipper(config *ShipperConfig) *Shipper

func (*Shipper) Post

func (s *Shipper) Post(payload controlplane.AgentPayload) error

type ShipperConfig

type ShipperConfig struct {
	URL       string
	Token     string
	TLSVerify bool
	Timeout   time.Duration
}

type SubjectVersion

type SubjectVersion struct {
	ID                 string
	Namespace          string
	TotalResourceCount int
	UniqVersions       []string
	Versions           []*v1alpha1.Version
	RemoteVersion      v1alpha1.RemoteVersion
}

type VersionTrackerReconciler

type VersionTrackerReconciler struct {
	client.Client
	Log    logr.Logger
	Scheme *runtime.Scheme
	Config *Config
}

VersionTrackerReconciler reconciles a VersionTracker object

func (*VersionTrackerReconciler) ExtractSubjectVersion

func (r *VersionTrackerReconciler) ExtractSubjectVersion(v v1alpha1.VersionTracker, items []interface{}) SubjectVersion

ExtractSubjectVersion looks at the feild of each individuel resource and extracts the version based on the extraction configuration in the VersionTracker

func (*VersionTrackerReconciler) PrepareThePayload

func (r *VersionTrackerReconciler) PrepareThePayload(sv SubjectVersion) controlplane.AgentPayload

func (*VersionTrackerReconciler) Reconcile

func (r *VersionTrackerReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.8.3/pkg/reconcile

func (*VersionTrackerReconciler) SetupWithManager

func (r *VersionTrackerReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

func (*VersionTrackerReconciler) ShipToControlPlane

func (r *VersionTrackerReconciler) ShipToControlPlane(ver SubjectVersion) error