syncers

Documentation

Index

• type DownSyncer
  • func NewDownSyncer(logger klog.Logger, upstreamClientFactory ClientFactory, ...) (*DownSyncer, error)
  • func (ds *DownSyncer) BackStatusMany(resource edgev1alpha1.EdgeSyncConfigResource, ...) error
  • func (ds *DownSyncer) BackStatusOne(resource edgev1alpha1.EdgeSyncConfigResource, ...) error
  • func (ds *DownSyncer) ReInitializeClients(syncedResources []edgev1alpha1.EdgeSyncConfigResource, ...) error
  • func (ds *DownSyncer) SyncMany(resource edgev1alpha1.EdgeSyncConfigResource, ...) error
  • func (ds *DownSyncer) SyncOne(resource edgev1alpha1.EdgeSyncConfigResource, ...) error
  • func (ds *DownSyncer) UnsyncMany(resource edgev1alpha1.EdgeSyncConfigResource, ...) error
  • func (ds *DownSyncer) UnsyncOne(resource edgev1alpha1.EdgeSyncConfigResource, ...) error
• type SyncerInterface
• type UpSyncer
  • func NewUpSyncer(logger klog.Logger, upstreamClientFactory ClientFactory, ...) (*UpSyncer, error)
  • func (us *UpSyncer) BackStatusOne(resource edgev1alpha1.EdgeSyncConfigResource, ...) error
  • func (us *UpSyncer) ReInitializeClients(syncedResources []edgev1alpha1.EdgeSyncConfigResource, ...) error
  • func (us *UpSyncer) SyncMany(resource edgev1alpha1.EdgeSyncConfigResource, ...) error
  • func (us *UpSyncer) SyncOne(resource edgev1alpha1.EdgeSyncConfigResource, ...) error
  • func (us *UpSyncer) UnsyncMany(resource edgev1alpha1.EdgeSyncConfigResource, ...) error
  • func (us *UpSyncer) UnsyncOne(resource edgev1alpha1.EdgeSyncConfigResource, ...) error

Types

type DownSyncer

type DownSyncer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewDownSyncer

func NewDownSyncer(logger klog.Logger, upstreamClientFactory ClientFactory, downstreamClientFactory ClientFactory, syncedResources []edgev1alpha1.EdgeSyncConfigResource, conversions []edgev1alpha1.EdgeSynConversion) (*DownSyncer, error)

func (*DownSyncer) BackStatusMany

func (ds *DownSyncer) BackStatusMany(resource edgev1alpha1.EdgeSyncConfigResource, conversions []edgev1alpha1.EdgeSynConversion) error

func (*DownSyncer) BackStatusOne

func (ds *DownSyncer) BackStatusOne(resource edgev1alpha1.EdgeSyncConfigResource, conversions []edgev1alpha1.EdgeSynConversion) error

func (*DownSyncer) ReInitializeClients

func (ds *DownSyncer) ReInitializeClients(syncedResources []edgev1alpha1.EdgeSyncConfigResource, conversions []edgev1alpha1.EdgeSynConversion) error

func (*DownSyncer) SyncMany

func (ds *DownSyncer) SyncMany(resource edgev1alpha1.EdgeSyncConfigResource, conversions []edgev1alpha1.EdgeSynConversion) error

func (*DownSyncer) SyncOne

func (ds *DownSyncer) SyncOne(resource edgev1alpha1.EdgeSyncConfigResource, conversions []edgev1alpha1.EdgeSynConversion) error

func (*DownSyncer) UnsyncMany

func (ds *DownSyncer) UnsyncMany(resource edgev1alpha1.EdgeSyncConfigResource, conversions []edgev1alpha1.EdgeSynConversion) error

func (*DownSyncer) UnsyncOne

func (ds *DownSyncer) UnsyncOne(resource edgev1alpha1.EdgeSyncConfigResource, conversions []edgev1alpha1.EdgeSynConversion) error

type SyncerInterface

type SyncerInterface interface {
	ReInitializeClients(resources []edgev1alpha1.EdgeSyncConfigResource, conversions []edgev1alpha1.EdgeSynConversion) error
	SyncOne(resource edgev1alpha1.EdgeSyncConfigResource, conversions []edgev1alpha1.EdgeSynConversion) error
	BackStatusOne(resource edgev1alpha1.EdgeSyncConfigResource, conversions []edgev1alpha1.EdgeSynConversion) error
	SyncMany(resource edgev1alpha1.EdgeSyncConfigResource, conversions []edgev1alpha1.EdgeSynConversion) error
}

type UpSyncer

type UpSyncer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewUpSyncer

func NewUpSyncer(logger klog.Logger, upstreamClientFactory ClientFactory, downstreamClientFactory ClientFactory, syncedResources []edgev1alpha1.EdgeSyncConfigResource, conversions []edgev1alpha1.EdgeSynConversion) (*UpSyncer, error)

func (*UpSyncer) BackStatusOne

func (us *UpSyncer) BackStatusOne(resource edgev1alpha1.EdgeSyncConfigResource, conversions []edgev1alpha1.EdgeSynConversion) error

func (*UpSyncer) ReInitializeClients

func (us *UpSyncer) ReInitializeClients(syncedResources []edgev1alpha1.EdgeSyncConfigResource, conversions []edgev1alpha1.EdgeSynConversion) error

func (*UpSyncer) SyncMany

func (us *UpSyncer) SyncMany(resource edgev1alpha1.EdgeSyncConfigResource, conversions []edgev1alpha1.EdgeSynConversion) error

func (*UpSyncer) SyncOne

func (us *UpSyncer) SyncOne(resource edgev1alpha1.EdgeSyncConfigResource, conversions []edgev1alpha1.EdgeSynConversion) error

func (*UpSyncer) UnsyncMany

func (us *UpSyncer) UnsyncMany(resource edgev1alpha1.EdgeSyncConfigResource, conversions []edgev1alpha1.EdgeSynConversion) error

func (*UpSyncer) UnsyncOne

func (us *UpSyncer) UnsyncOne(resource edgev1alpha1.EdgeSyncConfigResource, conversions []edgev1alpha1.EdgeSynConversion) error