aws

Documentation

Index

• type AWSLambdaFunctionDiscovery
  • func (f *AWSLambdaFunctionDiscovery) DetectFunctions(ctx context.Context, url *url.URL, dependencies func() fds.Dependencies, ...) error
  • func (f *AWSLambdaFunctionDiscovery) DetectFunctionsOnce(ctx context.Context, secrets v1.SecretList) ([]*glooaws.LambdaFunctionSpec, error)
  • func (f *AWSLambdaFunctionDiscovery) DetectType(ctx context.Context, url *url.URL) (*plugins.ServiceSpec, error)
  • func (f *AWSLambdaFunctionDiscovery) IsFunctional() bool
• type AWSLambdaFunctionDiscoveryFactory
  • func (f *AWSLambdaFunctionDiscoveryFactory) NewFunctionDiscovery(u *v1.Upstream) fds.UpstreamFunctionDiscovery

Types

type AWSLambdaFunctionDiscovery

type AWSLambdaFunctionDiscovery struct {
	// contains filtered or unexported fields
}

func (*AWSLambdaFunctionDiscovery) DetectFunctions

func (f *AWSLambdaFunctionDiscovery) DetectFunctions(ctx context.Context, url *url.URL, dependencies func() fds.Dependencies, updatecb func(fds.UpstreamMutator) error) error

TODO: how to handle changes in secret or upstream (like the upstream ref)? perhaps the in param for the upstream should be a function? in func() *v1.Upstream

func (*AWSLambdaFunctionDiscovery) DetectFunctionsOnce

func (f *AWSLambdaFunctionDiscovery) DetectFunctionsOnce(ctx context.Context, secrets v1.SecretList) ([]*glooaws.LambdaFunctionSpec, error)

func (*AWSLambdaFunctionDiscovery) DetectType

func (f *AWSLambdaFunctionDiscovery) DetectType(ctx context.Context, url *url.URL) (*plugins.ServiceSpec, error)

func (*AWSLambdaFunctionDiscovery) IsFunctional

func (f *AWSLambdaFunctionDiscovery) IsFunctional() bool

type AWSLambdaFunctionDiscoveryFactory

type AWSLambdaFunctionDiscoveryFactory struct {
	PollingTime time.Duration
}

func (*AWSLambdaFunctionDiscoveryFactory) NewFunctionDiscovery

func (f *AWSLambdaFunctionDiscoveryFactory) NewFunctionDiscovery(u *v1.Upstream) fds.UpstreamFunctionDiscovery