v1

Documentation

Index

• Variables
• func NewKubeconfigsEventLoop(emitter KubeconfigsSnapshotEmitter, syncer KubeconfigsSyncer) eventloop.EventLoop
• func NewKubeconfigsSimpleEventLoop(emitter KubeconfigsSimpleEmitter, syncers ...KubeconfigsSyncer) eventloop.SimpleEventLoop
• type CloneableKubeConfig
• type KubeConfig
  • func NewKubeConfig(namespace, name string) *KubeConfig
  • func (r *KubeConfig) Clone() resources.Resource
  • func (r *KubeConfig) GroupVersionKind() schema.GroupVersionKind
  • func (r *KubeConfig) Hash(hasher hash.Hash64) (uint64, error)
  • func (r *KubeConfig) MustHash() uint64
• type KubeConfigClient
  • func NewKubeConfigClient(rcFactory factory.ResourceClientFactory) (KubeConfigClient, error)
  • func NewKubeConfigClientWithBase(rc clients.ResourceClient) KubeConfigClient
  • func NewKubeConfigClientWithToken(rcFactory factory.ResourceClientFactory, token string) (KubeConfigClient, error)
• type KubeConfigList
  • func (list KubeConfigList) AsInterfaces() []interface{}
  • func (list KubeConfigList) AsResources() resources.ResourceList
  • func (list KubeConfigList) Clone() KubeConfigList
  • func (list KubeConfigList) Each(f func(element *KubeConfig))
  • func (list KubeConfigList) EachResource(f func(element resources.Resource))
  • func (list KubeConfigList) Find(namespace, name string) (*KubeConfig, error)
  • func (list KubeConfigList) Names() []string
  • func (list KubeConfigList) NamespacesDotNames() []string
  • func (list KubeConfigList) Sort() KubeConfigList
• type KubeConfigReconciler
  • func NewKubeConfigReconciler(client KubeConfigClient) KubeConfigReconciler
• type KubeConfigWatcher
• type KubeconfigsEmitter
  • func NewKubeconfigsEmitter(kubeConfigClient KubeConfigClient) KubeconfigsEmitter
  • func NewKubeconfigsEmitterWithEmit(kubeConfigClient KubeConfigClient, emit <-chan struct{}) KubeconfigsEmitter
• type KubeconfigsSimpleEmitter
  • func NewKubeconfigsSimpleEmitter(aggregatedWatch clients.ResourceWatch) KubeconfigsSimpleEmitter
  • func NewKubeconfigsSimpleEmitterWithEmit(aggregatedWatch clients.ResourceWatch, emit <-chan struct{}) KubeconfigsSimpleEmitter
• type KubeconfigsSnapshot
  • func (s KubeconfigsSnapshot) Clone() KubeconfigsSnapshot
  • func (s KubeconfigsSnapshot) Hash(hasher hash.Hash64) (uint64, error)
  • func (s KubeconfigsSnapshot) HashFields() []zap.Field
  • func (s KubeconfigsSnapshot) Stringer() KubeconfigsSnapshotStringer
• type KubeconfigsSnapshotEmitter
• type KubeconfigsSnapshotStringer
  • func (ss KubeconfigsSnapshotStringer) String() string
• type KubeconfigsSyncDecider
• type KubeconfigsSyncDeciderWithContext
• type KubeconfigsSyncer
• type KubeconfigsSyncers
  • func (s KubeconfigsSyncers) Sync(ctx context.Context, snapshot *KubeconfigsSnapshot) error
• type TransitionKubeConfigFunc

Variables

var (
	KubeConfigGVK = schema.GroupVersionKind{
		Version: "v1",
		Group:   "multicluster.solo.io",
		Kind:    "KubeConfig",
	}
)

Functions

func NewKubeconfigsEventLoop

func NewKubeconfigsEventLoop(emitter KubeconfigsSnapshotEmitter, syncer KubeconfigsSyncer) eventloop.EventLoop

func NewKubeconfigsSimpleEventLoop

func NewKubeconfigsSimpleEventLoop(emitter KubeconfigsSimpleEmitter, syncers ...KubeconfigsSyncer) eventloop.SimpleEventLoop

Types

type CloneableKubeConfig

type CloneableKubeConfig interface {
	resources.Resource
	Clone() *github_com_solo_io_solo_kit_api_multicluster_v1.KubeConfig
}

type KubeConfig

type KubeConfig struct {
	github_com_solo_io_solo_kit_api_multicluster_v1.KubeConfig
}

func NewKubeConfig

func NewKubeConfig(namespace, name string) *KubeConfig

func (*KubeConfig) Clone

func (r *KubeConfig) Clone() resources.Resource

func (*KubeConfig) GroupVersionKind

func (r *KubeConfig) GroupVersionKind() schema.GroupVersionKind

func (*KubeConfig) Hash

func (r *KubeConfig) Hash(hasher hash.Hash64) (uint64, error)

func (*KubeConfig) MustHash

func (r *KubeConfig) MustHash() uint64

type KubeConfigClient

type KubeConfigClient interface {
	BaseClient() clients.ResourceClient
	Register() error
	Read(namespace, name string, opts clients.ReadOpts) (*KubeConfig, error)
	Write(resource *KubeConfig, opts clients.WriteOpts) (*KubeConfig, error)
	Delete(namespace, name string, opts clients.DeleteOpts) error
	List(namespace string, opts clients.ListOpts) (KubeConfigList, error)
	KubeConfigWatcher
}

func NewKubeConfigClient

func NewKubeConfigClient(rcFactory factory.ResourceClientFactory) (KubeConfigClient, error)

func NewKubeConfigClientWithBase

func NewKubeConfigClientWithBase(rc clients.ResourceClient) KubeConfigClient

func NewKubeConfigClientWithToken

func NewKubeConfigClientWithToken(rcFactory factory.ResourceClientFactory, token string) (KubeConfigClient, error)

type KubeConfigList

type KubeConfigList []*KubeConfig

func (KubeConfigList) AsInterfaces

func (list KubeConfigList) AsInterfaces() []interface{}

func (KubeConfigList) AsResources

func (list KubeConfigList) AsResources() resources.ResourceList

func (KubeConfigList) Clone

func (list KubeConfigList) Clone() KubeConfigList

func (KubeConfigList) Each

func (list KubeConfigList) Each(f func(element *KubeConfig))

func (KubeConfigList) EachResource

func (list KubeConfigList) EachResource(f func(element resources.Resource))

func (KubeConfigList) Find

func (list KubeConfigList) Find(namespace, name string) (*KubeConfig, error)

func (KubeConfigList) Names

func (list KubeConfigList) Names() []string

func (KubeConfigList) NamespacesDotNames

func (list KubeConfigList) NamespacesDotNames() []string

func (KubeConfigList) Sort

func (list KubeConfigList) Sort() KubeConfigList

type KubeConfigReconciler

type KubeConfigReconciler interface {
	Reconcile(namespace string, desiredResources KubeConfigList, transition TransitionKubeConfigFunc, opts clients.ListOpts) error
}

func NewKubeConfigReconciler

func NewKubeConfigReconciler(client KubeConfigClient) KubeConfigReconciler

type KubeConfigWatcher

type KubeConfigWatcher interface {
	// watch namespace-scoped kubeconfigs
	Watch(namespace string, opts clients.WatchOpts) (<-chan KubeConfigList, <-chan error, error)
}

type KubeconfigsEmitter

type KubeconfigsEmitter interface {
	KubeconfigsSnapshotEmitter
	Register() error
	KubeConfig() KubeConfigClient
}

func NewKubeconfigsEmitter

func NewKubeconfigsEmitter(kubeConfigClient KubeConfigClient) KubeconfigsEmitter

func NewKubeconfigsEmitterWithEmit

func NewKubeconfigsEmitterWithEmit(kubeConfigClient KubeConfigClient, emit <-chan struct{}) KubeconfigsEmitter

type KubeconfigsSimpleEmitter

type KubeconfigsSimpleEmitter interface {
	Snapshots(ctx context.Context) (<-chan *KubeconfigsSnapshot, <-chan error, error)
}

func NewKubeconfigsSimpleEmitter

func NewKubeconfigsSimpleEmitter(aggregatedWatch clients.ResourceWatch) KubeconfigsSimpleEmitter

func NewKubeconfigsSimpleEmitterWithEmit

func NewKubeconfigsSimpleEmitterWithEmit(aggregatedWatch clients.ResourceWatch, emit <-chan struct{}) KubeconfigsSimpleEmitter

type KubeconfigsSnapshot

type KubeconfigsSnapshot struct {
	Kubeconfigs KubeConfigList
}

func (KubeconfigsSnapshot) Clone

func (s KubeconfigsSnapshot) Clone() KubeconfigsSnapshot

func (KubeconfigsSnapshot) Hash

func (s KubeconfigsSnapshot) Hash(hasher hash.Hash64) (uint64, error)

func (KubeconfigsSnapshot) HashFields

func (s KubeconfigsSnapshot) HashFields() []zap.Field

func (KubeconfigsSnapshot) Stringer

func (s KubeconfigsSnapshot) Stringer() KubeconfigsSnapshotStringer

type KubeconfigsSnapshotEmitter

type KubeconfigsSnapshotEmitter interface {
	Snapshots(watchNamespaces []string, opts clients.WatchOpts) (<-chan *KubeconfigsSnapshot, <-chan error, error)
}

type KubeconfigsSnapshotStringer

type KubeconfigsSnapshotStringer struct {
	Version     uint64
	Kubeconfigs []string
}

func (KubeconfigsSnapshotStringer) String

func (ss KubeconfigsSnapshotStringer) String() string

type KubeconfigsSyncDecider

type KubeconfigsSyncDecider interface {
	KubeconfigsSyncer
	ShouldSync(old, new *KubeconfigsSnapshot) bool
}

Deprecated: use KubeconfigsSyncDeciderWithContext

type KubeconfigsSyncDeciderWithContext

type KubeconfigsSyncDeciderWithContext interface {
	KubeconfigsSyncer
	ShouldSync(ctx context.Context, old, new *KubeconfigsSnapshot) bool
}

type KubeconfigsSyncer

type KubeconfigsSyncer interface {
	Sync(context.Context, *KubeconfigsSnapshot) error
}

type KubeconfigsSyncers

type KubeconfigsSyncers []KubeconfigsSyncer

func (KubeconfigsSyncers) Sync

func (s KubeconfigsSyncers) Sync(ctx context.Context, snapshot *KubeconfigsSnapshot) error

type TransitionKubeConfigFunc

type TransitionKubeConfigFunc func(original, desired *KubeConfig) (bool, error)

Option to copy anything from the original to the desired before writing. Return value of false means don't update