syncer

Documentation

Index

• Constants
• func GetFunctionDiscoveriesWithExtensions(opts bootstrap.Opts, extensions Extensions) []fds.FunctionDiscoveryFactory
• func GetFunctionDiscoveriesWithExtensionsAndRegistry(opts bootstrap.Opts, ...) []fds.FunctionDiscoveryFactory
• func NewDiscoverySyncer(fd *fds.FunctionDiscovery, fdsMode v1.Settings_DiscoveryOptions_FdsMode) v1.DiscoverySyncer
• func NewSetupFunc() setuputils.SetupFunc
• func NewSetupFuncWithExtensions(extensions Extensions) setuputils.SetupFunc
• func RunFDS(opts bootstrap.Opts) error
• func RunFDSWithExtensions(opts bootstrap.Opts, extensions Extensions) error
• type Extensions
• 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

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

Functions

func GetFunctionDiscoveriesWithExtensions

func GetFunctionDiscoveriesWithExtensions(opts bootstrap.Opts, extensions Extensions) []fds.FunctionDiscoveryFactory

func GetFunctionDiscoveriesWithExtensionsAndRegistry

func GetFunctionDiscoveriesWithExtensionsAndRegistry(opts bootstrap.Opts, registryDiscFacts func(opts bootstrap.Opts) []fds.FunctionDiscoveryFactory, extensions Extensions) []fds.FunctionDiscoveryFactory

func NewDiscoverySyncer

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

func NewSetupFunc

func NewSetupFunc() setuputils.SetupFunc

func NewSetupFuncWithExtensions

func NewSetupFuncWithExtensions(extensions Extensions) setuputils.SetupFunc

NewSetupFuncWithExtensions used as extension point for external repo

func RunFDS

func RunFDS(opts bootstrap.Opts) error

func RunFDSWithExtensions

func RunFDSWithExtensions(opts bootstrap.Opts, extensions Extensions) error

Types

type Extensions

type Extensions struct {
	DiscoveryFactoryFuncs []func(opts bootstrap.Opts) fds.FunctionDiscoveryFactory
}

type FakeKubeNamespaceWatcher

type FakeKubeNamespaceWatcher struct{}

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

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)