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(name string, opts clients.DeleteOpts) error
- func (f *FakeKubeNamespaceWatcher) List(opts clients.ListOpts) (skkube.KubeNamespaceList, error)
- func (f *FakeKubeNamespaceWatcher) Read(name string, opts clients.ReadOpts) (*skkube.KubeNamespace, error)
- func (f *FakeKubeNamespaceWatcher) Register() error
- func (f *FakeKubeNamespaceWatcher) Watch(opts clients.WatchOpts) (<-chan skkube.KubeNamespaceList, <-chan error, error)
- func (f *FakeKubeNamespaceWatcher) Write(resource *skkube.KubeNamespace, opts clients.WriteOpts) (*skkube.KubeNamespace, error)
Constants ¶
View Source
const (
FdsLabelKey = "discovery.solo.io/function_discovery"
)
Variables ¶
This section is empty.
Functions ¶
func NewDiscoverySyncer ¶
func NewDiscoverySyncer(fd *fds.FunctionDiscovery, fdsMode v1.Settings_DiscoveryOptions_FdsMode) v1.DiscoverySyncer
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(name string, opts clients.DeleteOpts) error
func (*FakeKubeNamespaceWatcher) List ¶
func (f *FakeKubeNamespaceWatcher) List(opts clients.ListOpts) (skkube.KubeNamespaceList, error)
func (*FakeKubeNamespaceWatcher) Read ¶
func (f *FakeKubeNamespaceWatcher) Read(name string, opts clients.ReadOpts) (*skkube.KubeNamespace, error)
func (*FakeKubeNamespaceWatcher) Register ¶
func (f *FakeKubeNamespaceWatcher) Register() error
func (*FakeKubeNamespaceWatcher) Watch ¶
func (f *FakeKubeNamespaceWatcher) Watch(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)
Click to show internal directories.
Click to hide internal directories.