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 ¶ added in v0.17.0
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 ¶ added in v0.17.0
func (f *FakeKubeNamespaceWatcher) BaseClient() clients.ResourceClient
func (*FakeKubeNamespaceWatcher) Delete ¶ added in v0.17.0
func (f *FakeKubeNamespaceWatcher) Delete(name string, opts clients.DeleteOpts) error
func (*FakeKubeNamespaceWatcher) List ¶ added in v0.17.0
func (f *FakeKubeNamespaceWatcher) List(opts clients.ListOpts) (skkube.KubeNamespaceList, error)
func (*FakeKubeNamespaceWatcher) Read ¶ added in v0.17.0
func (f *FakeKubeNamespaceWatcher) Read(name string, opts clients.ReadOpts) (*skkube.KubeNamespace, error)
func (*FakeKubeNamespaceWatcher) Register ¶ added in v0.17.0
func (f *FakeKubeNamespaceWatcher) Register() error
func (*FakeKubeNamespaceWatcher) Watch ¶ added in v0.17.0
func (f *FakeKubeNamespaceWatcher) Watch(opts clients.WatchOpts) (<-chan skkube.KubeNamespaceList, <-chan error, error)
func (*FakeKubeNamespaceWatcher) Write ¶ added in v0.17.0
func (f *FakeKubeNamespaceWatcher) Write(resource *skkube.KubeNamespace, opts clients.WriteOpts) (*skkube.KubeNamespace, error)
Source Files
Click to show internal directories.
Click to hide internal directories.