Documentation ¶
Overview ¶
© 2020 Red Hat, Inc.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
© 2020 Red Hat, Inc.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Index ¶
- Constants
- func DefaultResourcesEquivalent(obj1, obj2 *unstructured.Unstructured) bool
- func ResourcesNotEquivalent(obj1, obj2 *unstructured.Unstructured) bool
- type Interface
- type OnSuccessfulSyncFunc
- type Operation
- type ResourceEquivalenceFunc
- type ResourceSyncerConfig
- type ShouldProcessFunc
- type SyncDirection
- type TransformFunc
Constants ¶
const ( DirectionLabel = "direction" OperationLabel = "operation" SyncerNameLabel = "syncer_name" )
const OrigNamespaceLabelKey = "submariner-io/originatingNamespace"
Variables ¶
This section is empty.
Functions ¶
func DefaultResourcesEquivalent ¶ added in v0.6.0
func DefaultResourcesEquivalent(obj1, obj2 *unstructured.Unstructured) bool
func ResourcesNotEquivalent ¶ added in v0.6.2
func ResourcesNotEquivalent(obj1, obj2 *unstructured.Unstructured) bool
Types ¶
type Interface ¶
type Interface interface { Start(stopCh <-chan struct{}) error AwaitStopped() GetResource(name, namespace string) (runtime.Object, bool, error) ListResources() ([]runtime.Object, error) Reconcile(resourceLister func() []runtime.Object) }
func NewResourceSyncer ¶
func NewResourceSyncer(config *ResourceSyncerConfig) (Interface, error)
type OnSuccessfulSyncFunc ¶ added in v0.6.0
OnSuccessfulSyncFunc is invoked after a successful sync operation.
type ResourceEquivalenceFunc ¶ added in v0.6.0
type ResourceEquivalenceFunc func(obj1, obj2 *unstructured.Unstructured) bool
type ResourceSyncerConfig ¶
type ResourceSyncerConfig struct { // Name of this syncer used for logging. Name string // SourceClient the client used to obtain the resources to sync. SourceClient dynamic.Interface // SourceNamespace the namespace of the resources to sync. SourceNamespace string // SourceLabelSelector optional selector to restrict the resources to sync by their labels. SourceLabelSelector string // SourceFieldSelector optional selector to restrict the resources to sync by their fields. SourceFieldSelector string // LocalClusterID the cluster ID of the source client. This is used in conjunction with Direction to avoid // loops when syncing the same resources between the local and remote sources. LocalClusterID string // Direction specifies how resources are synced. It is assumed that resources emanating from a remote source have // the cluster ID label specified by federate.ClusterIDLabelKey set appropriately. If set to LocalToRemote, only // resources that do not have a cluster ID label are synced. This avoids re-syncing non-local resources. If set to // RemoteToLocal, resources whose cluster ID label matches LocalClusterID are not synced. This avoids syncing // local resources from the remote source. Direction SyncDirection // RestMapper used to obtain GroupVersionResources. RestMapper meta.RESTMapper // Federator used to perform the syncing. Federator federate.Federator // ResourceType the type of the resources to sync. ResourceType runtime.Object // Transform function used to transform resources prior to syncing. Transform TransformFunc // OnSuccessfulSync function invoked after a successful sync operation. OnSuccessfulSync OnSuccessfulSyncFunc // ResourcesEquivalent function to compare two resources for equivalence. This is invoked on an update notification // to compare the old and new resources. If true is returned, the update is ignored, otherwise the update is processed. // By default all updates are processed. ResourcesEquivalent ResourceEquivalenceFunc // ShouldProcess function invoked to determine if a resource should be processed. ShouldProcess ShouldProcessFunc // WaitForCacheSync if true, waits for the informer cache to sync on Start. Default is true. WaitForCacheSync *bool // Scheme used to convert resource objects. By default the global k8s Scheme is used. Scheme *runtime.Scheme // ResyncPeriod if non-zero, the period at which resources will be re-synced regardless if anything changed. Default is 0. ResyncPeriod time.Duration // SyncCounterOpts if specified, used to create a gauge to record counter metrics. // Alternatively the gauge can be created directly and passed via the SyncCounter field, // in which case SyncCounterOpts is ignored. SyncCounterOpts *prometheus.GaugeOpts // SyncCounter if specified, used to record counter metrics. SyncCounter *prometheus.GaugeVec }
type ShouldProcessFunc ¶ added in v0.9.0
type ShouldProcessFunc func(obj *unstructured.Unstructured, op Operation) bool
type SyncDirection ¶
type SyncDirection int
const ( None SyncDirection = iota // Resources are synced from a local source to a remote source. LocalToRemote // Resources are synced from a remote source to a local source. RemoteToLocal )
func (SyncDirection) String ¶ added in v0.9.0
func (d SyncDirection) String() string
type TransformFunc ¶
TransformFunc is invoked prior to syncing to transform the resource or evaluate if it should be synced. If nil is returned, the resource is not synced and, if the second return value is true, the resource is re-queued to be retried later.