source

package

v0.0.0-...-89e5b94 Latest Latest Go to latest Published: Apr 26, 2024 License: Apache-2.0 Imports: 40 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/secretflow/kuscia

Links

Open Source Insights

Documentation ¶

Rendered for

Index ¶

type InitConfig
type Manager
- func NewManager(cfg *InitConfig) *Manager
- func (m *Manager) AllReady() bool
- func (m *Manager) Run(stopCh <-chan struct{}) error
type Merger
type PodConfigNotificationMode

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type InitConfig ¶

type InitConfig struct {
	Namespace  string
	NodeName   types.NodeName
	SourceCfg  *config.SourceCfg
	KubeClient kubernetes.Interface
	Updates    chan<- kubetypes.PodUpdate
	Recorder   record.EventRecorder
}

type Manager ¶

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

func NewManager ¶

func NewManager(cfg *InitConfig) *Manager

func (*Manager) AllReady ¶

func (m *Manager) AllReady() bool

func (*Manager) Run ¶

func (m *Manager) Run(stopCh <-chan struct{}) error

Run starts all sources

type Merger ¶

type Merger interface {
	// Merge invoked when a change from a source is received.  May also function as an incremental
	// merger if you wish to consume changes incrementally.  Must be reentrant when more than
	// one source is defined.
	Merge(source string, update interface{}) error
}

type PodConfigNotificationMode ¶

type PodConfigNotificationMode int

PodConfigNotificationMode describes how changes are sent to the update channel.

const (
	// PodConfigNotificationUnknown is the default value for
	// PodConfigNotificationMode when uninitialized.
	PodConfigNotificationUnknown PodConfigNotificationMode = iota
	// PodConfigNotificationSnapshot delivers the full configuration as a SET whenever
	// any change occurs.
	PodConfigNotificationSnapshot
	// PodConfigNotificationSnapshotAndUpdates delivers an UPDATE and DELETE message whenever pods are
	// changed, and a SET message if there are any additions or removals.
	PodConfigNotificationSnapshotAndUpdates
	// PodConfigNotificationIncremental delivers ADD, UPDATE, DELETE, REMOVE, RECONCILE to the update channel.
	PodConfigNotificationIncremental
)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL