Documentation ¶
Index ¶
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.
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.