Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ChannelSynchronizer ¶
type ChannelSynchronizer struct {
EnableForClusterNamespace bool
EnableForChannel bool
ObjectStore utils.ObjectStore
Signal <-chan struct{}
SyncInterval int
//this is created during manager start up time and shared with reconcile.
// ChannelDescriptor, holds a map of channels unit
ChannelDescriptor *utils.ChannelDescriptor
// contains filtered or unexported fields
}
ChannelSynchronizer syncs objectbucket channels with ObjectStore
func CreateObjectStoreSynchronizer ¶
func CreateObjectStoreSynchronizer(config *rest.Config, chdesc *utils.ChannelDescriptor, syncInterval int) (*ChannelSynchronizer, error)
CreateSynchronizer - creates an instance of ChannelSynchronizer
func (*ChannelSynchronizer) Start ¶
func (sync *ChannelSynchronizer) Start(s <-chan struct{}) error
Start - starts the sync process
Click to show internal directories.
Click to hide internal directories.