Documentation
¶
Index ¶
- func NewFunctionDiscoveryFactory() fds.FunctionDiscoveryFactory
- type FunctionDiscoveryFactory
- type UpstreamFunctionDiscovery
- func (f *UpstreamFunctionDiscovery) DetectFunctions(ctx context.Context, url *url.URL, _ func() fds.Dependencies, ...) error
- func (f *UpstreamFunctionDiscovery) DetectFunctionsOnce(ctx context.Context, url *url.URL, updatecb func(fds.UpstreamMutator) error) error
- func (f *UpstreamFunctionDiscovery) DetectType(ctx context.Context, url *url.URL) (*plugins.ServiceSpec, error)
- func (f *UpstreamFunctionDiscovery) IsFunctional() bool
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewFunctionDiscoveryFactory ¶ added in v1.9.25
func NewFunctionDiscoveryFactory() fds.FunctionDiscoveryFactory
Types ¶
type FunctionDiscoveryFactory ¶
type FunctionDiscoveryFactory struct {
// TODO: yuval-k: integrate backoff stuff here
DetectionTimeout time.Duration
DetectionRetryBase time.Duration
FunctionPollTime time.Duration
// TODO: move over to ArtifactClient
Artifacts v1.ArtifactClient
}
FunctionDiscoveryFactory returns a FunctionDiscovery that can be used to discover functions ilackarms: this is the root object
func (*FunctionDiscoveryFactory) NewFunctionDiscovery ¶
func (f *FunctionDiscoveryFactory) NewFunctionDiscovery(u *v1.Upstream, _ fds.AdditionalClients) fds.UpstreamFunctionDiscovery
NewFunctionDiscovery returns a FunctionDiscovery that can be used to discover functions
type UpstreamFunctionDiscovery ¶
type UpstreamFunctionDiscovery struct {
// contains filtered or unexported fields
}
UpstreamFunctionDiscovery represents a function discovery for upstream
func (*UpstreamFunctionDiscovery) DetectFunctions ¶
func (f *UpstreamFunctionDiscovery) DetectFunctions(ctx context.Context, url *url.URL, _ func() fds.Dependencies, updatecb func(fds.UpstreamMutator) error) error
func (*UpstreamFunctionDiscovery) DetectFunctionsOnce ¶
func (f *UpstreamFunctionDiscovery) DetectFunctionsOnce(ctx context.Context, url *url.URL, updatecb func(fds.UpstreamMutator) error) error
func (*UpstreamFunctionDiscovery) DetectType ¶
func (f *UpstreamFunctionDiscovery) DetectType(ctx context.Context, url *url.URL) (*plugins.ServiceSpec, error)
func (*UpstreamFunctionDiscovery) IsFunctional ¶
func (f *UpstreamFunctionDiscovery) IsFunctional() bool
IsFunctional returns true if the upstream is functional
Source Files
Click to show internal directories.
Click to hide internal directories.