sync

package
v0.0.0-...-d1b9435 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 15, 2023 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Controller 

type Controller struct {
	// contains filtered or unexported fields
}

func NewController 

func NewController(
	ctx context.Context,
	configMapInformer coreinformers.ConfigMapInformer,
	client clientset.Interface,
	namespace string,
	logger log.Logger,
	registry *prometheus.Registry,
	opts Options,
) (*Controller, error)

func (*Controller) Run 

func (c *Controller) Run(ctx context.Context, workers int) error

Run will set up the event handlers for types we are interested in, as well as syncing informer caches and starting workers. It will block until stopCh is closed, at which point it will shutdown the queue and wait for workers to finish processing their current work items.

func (*Controller) WaitForFileToSync 

func (c *Controller) WaitForFileToSync(ctx context.Context) error

WaitForFileToSync waits for the file to be synced to disk.

type Options 

type Options struct {
	// ConfigMapKey is the key for hashring config on the generated ConfigMap
	ConfigMapKey string
	// ConfigMapName is the name of the generated ConfigMap
	ConfigMapName string
	// FilePath is the path to which the data gets written
	FilePath string
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.