syncer

Documentation

Index

• Constants
• func NewDiscoverySyncer(fd *fds.FunctionDiscovery, fdsMode v1.Settings_DiscoveryOptions_FdsMode) v1.DiscoverySyncer
• func RunFDS(opts bootstrap.Opts) error
• type FakeKubeNamespaceWatcher
  • func (f *FakeKubeNamespaceWatcher) BaseClient() clients.ResourceClient
  • func (f *FakeKubeNamespaceWatcher) Delete(namespace, name string, opts clients.DeleteOpts) error
  • func (f *FakeKubeNamespaceWatcher) List(namespace string, opts clients.ListOpts) (skkube.KubeNamespaceList, error)
  • func (f *FakeKubeNamespaceWatcher) Read(namespace, name string, opts clients.ReadOpts) (*skkube.KubeNamespace, error)
  • func (f *FakeKubeNamespaceWatcher) Register() error
  • func (f *FakeKubeNamespaceWatcher) Watch(namespace string, opts clients.WatchOpts) (<-chan skkube.KubeNamespaceList, <-chan error, error)
  • func (f *FakeKubeNamespaceWatcher) Write(resource *skkube.KubeNamespace, opts clients.WriteOpts) (*skkube.KubeNamespace, error)

Constants

const (
	FdsLabelKey = "discovery.solo.io/function_discovery"
)

Functions

func NewDiscoverySyncer

func NewDiscoverySyncer(fd *fds.FunctionDiscovery, fdsMode v1.Settings_DiscoveryOptions_FdsMode) v1.DiscoverySyncer

func RunFDS

func RunFDS(opts bootstrap.Opts) error

Types

type FakeKubeNamespaceWatcher

type FakeKubeNamespaceWatcher struct{}

TODO: consider using regular solo-kit namespace client instead of KubeNamespace client to eliminate the need for this fake client for non kube environments

func (*FakeKubeNamespaceWatcher) BaseClient

func (f *FakeKubeNamespaceWatcher) BaseClient() clients.ResourceClient

func (*FakeKubeNamespaceWatcher) Delete

func (f *FakeKubeNamespaceWatcher) Delete(namespace, name string, opts clients.DeleteOpts) error

func (*FakeKubeNamespaceWatcher) List

func (f *FakeKubeNamespaceWatcher) List(namespace string, opts clients.ListOpts) (skkube.KubeNamespaceList, error)

func (*FakeKubeNamespaceWatcher) Read

func (f *FakeKubeNamespaceWatcher) Read(namespace, name string, opts clients.ReadOpts) (*skkube.KubeNamespace, error)

func (*FakeKubeNamespaceWatcher) Register

func (f *FakeKubeNamespaceWatcher) Register() error

func (*FakeKubeNamespaceWatcher) Watch

func (f *FakeKubeNamespaceWatcher) Watch(namespace string, opts clients.WatchOpts) (<-chan skkube.KubeNamespaceList, <-chan error, error)

func (*FakeKubeNamespaceWatcher) Write

func (f *FakeKubeNamespaceWatcher) Write(resource *skkube.KubeNamespace, opts clients.WriteOpts) (*skkube.KubeNamespace, error)