Documentation ¶
Index ¶
- type ControlInfoDBSyncer
- type DBSyncer
- func NewControlInfoDBSyncer(log logr.Logger) DBSyncer
- func NewLocalSpecDBSyncer(log logr.Logger, config *configv1.Config) DBSyncer
- func NewManagedClustersDBSyncer(log logr.Logger) DBSyncer
- func NewPlacementDecisionsDBSyncer(log logr.Logger) DBSyncer
- func NewPlacementRulesDBSyncer(log logr.Logger) DBSyncer
- func NewPlacementsDBSyncer(log logr.Logger) DBSyncer
- func NewPoliciesDBSyncer(log logr.Logger, config *configv1.Config) DBSyncer
- func NewSubscriptionReportsDBSyncer(log logr.Logger) DBSyncer
- func NewSubscriptionStatusesDBSyncer(log logr.Logger) DBSyncer
- type LocalSpecDBSyncer
- type ManagedClustersDBSyncer
- type PoliciesDBSyncer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ControlInfoDBSyncer ¶
type ControlInfoDBSyncer struct {
// contains filtered or unexported fields
}
ControlInfoDBSyncer implements control info transport to db sync.
func (*ControlInfoDBSyncer) RegisterBundleHandlerFunctions ¶
func (syncer *ControlInfoDBSyncer) RegisterBundleHandlerFunctions( conflationManager *conflator.ConflationManager, )
RegisterBundleHandlerFunctions registers bundle handler functions within the conflation manager.
func (*ControlInfoDBSyncer) RegisterCreateBundleFunctions ¶
func (syncer *ControlInfoDBSyncer) RegisterCreateBundleFunctions(transportInstance transport.Transport)
RegisterCreateBundleFunctions registers create bundle functions within the transport instance.
type DBSyncer ¶
type DBSyncer interface { // RegisterCreateBundleFunctions registers create bundle functions within the transport instance. RegisterCreateBundleFunctions(transportInstance transport.Transport) // RegisterBundleHandlerFunctions registers bundle handler functions within the conflation manager. RegisterBundleHandlerFunctions(conflationManager *conflator.ConflationManager) }
DBSyncer interface for registering business logic needed for handling bundles.
func NewControlInfoDBSyncer ¶
NewControlInfoDBSyncer creates a new instance of ControlInfoDBSyncer.
func NewLocalSpecDBSyncer ¶
NewLocalSpecDBSyncer creates a new instance of LocalSpecDBSyncer.
func NewManagedClustersDBSyncer ¶
NewManagedClustersDBSyncer creates a new instance of ManagedClustersDBSyncer.
func NewPlacementDecisionsDBSyncer ¶
NewPlacementDecisionsDBSyncer creates a new instance of genericDBSyncer to sync placement-decisions.
func NewPlacementRulesDBSyncer ¶
NewPlacementRulesDBSyncer creates a new instance of genericDBSyncer to sync placement-rules.
func NewPlacementsDBSyncer ¶
NewPlacementsDBSyncer creates a new instance of genericDBSyncer to sync placements.
func NewPoliciesDBSyncer ¶
NewPoliciesDBSyncer creates a new instance of PoliciesDBSyncer.
func NewSubscriptionReportsDBSyncer ¶
NewSubscriptionReportsDBSyncer creates a new instance of genericDBSyncer to sync subscription-reports.
func NewSubscriptionStatusesDBSyncer ¶
NewSubscriptionStatusesDBSyncer creates a new instance of genericDBSyncer to sync subscription-statuses.
type LocalSpecDBSyncer ¶
type LocalSpecDBSyncer struct {
// contains filtered or unexported fields
}
LocalSpecDBSyncer implements local objects spec db sync business logic.
func (*LocalSpecDBSyncer) RegisterBundleHandlerFunctions ¶
func (syncer *LocalSpecDBSyncer) RegisterBundleHandlerFunctions(conflationManager *conflator.ConflationManager)
RegisterBundleHandlerFunctions registers bundle handler functions within the conflation manager. handler functions need to do "diff" between objects received in the bundle and the objects in db. leaf hub sends only the current existing objects, and status transport bridge should understand implicitly which objects were deleted. therefore, whatever is in the db and cannot be found in the bundle has to be deleted from the db. for the objects that appear in both, need to check if something has changed using resourceVersion field comparison and if the object was changed, update the db with the current object.
func (*LocalSpecDBSyncer) RegisterCreateBundleFunctions ¶
func (syncer *LocalSpecDBSyncer) RegisterCreateBundleFunctions(transportInstance transport.Transport)
RegisterCreateBundleFunctions registers create bundle functions within the transport instance.
type ManagedClustersDBSyncer ¶
type ManagedClustersDBSyncer struct {
// contains filtered or unexported fields
}
ManagedClustersDBSyncer implements managed clusters db sync business logic.
func (*ManagedClustersDBSyncer) RegisterBundleHandlerFunctions ¶
func (syncer *ManagedClustersDBSyncer) RegisterBundleHandlerFunctions(conflationManager *conflator.ConflationManager)
RegisterBundleHandlerFunctions registers bundle handler functions within the conflation manager. handler function need to do "diff" between objects received in the bundle and the objects in db. leaf hub sends only the current existing objects, and status transport bridge should understand implicitly which objects were deleted. therefore, whatever is in the db and cannot be found in the bundle has to be deleted from the db. for the objects that appear in both, need to check if something has changed using resourceVersion field comparison and if the object was changed, update the db with the current object.
func (*ManagedClustersDBSyncer) RegisterCreateBundleFunctions ¶
func (syncer *ManagedClustersDBSyncer) RegisterCreateBundleFunctions(transportInstance transport.Transport)
RegisterCreateBundleFunctions registers create bundle functions within the transport instance.
type PoliciesDBSyncer ¶
type PoliciesDBSyncer struct {
// contains filtered or unexported fields
}
PoliciesDBSyncer implements policies db sync business logic.
func (*PoliciesDBSyncer) RegisterBundleHandlerFunctions ¶
func (syncer *PoliciesDBSyncer) RegisterBundleHandlerFunctions(conflationManager *conflator.ConflationManager)
RegisterBundleHandlerFunctions registers bundle handler functions within the conflation manager. handler functions need to do "diff" between objects received in the bundle and the objects in db. leaf hub sends only the current existing objects, and status transport bridge should understand implicitly which objects were deleted. therefore, whatever is in the db and cannot be found in the bundle has to be deleted from the db. for the objects that appear in both, need to check if something has changed using resourceVersion field comparison and if the object was changed, update the db with the current object.
func (*PoliciesDBSyncer) RegisterCreateBundleFunctions ¶
func (syncer *PoliciesDBSyncer) RegisterCreateBundleFunctions(transportInstance transport.Transport)
RegisterCreateBundleFunctions registers create bundle functions within the transport instance.
Source Files ¶
- control_info_db_syncer.go
- db_syncer.go
- generic_db_syncer.go
- local_spec_db_syncer.go
- log_helpers.go
- managed_clusters_db_syncer.go
- placement_decisions_db_syncer.go
- placement_rules_db_syncer.go
- placements_db_syncer.go
- policies_db_syncer.go
- subscription_reports_db_syncer.go
- subscription_statuses_db_syncer.go