aws

Documentation

Index

• Constants
• func EncodeFunctionSpec(spec FunctionSpec) *types.Struct
• func EncodeUpstreamSpec(spec UpstreamSpec) *types.Struct
• func GetExecutionStyle(routeExtensions *types.Struct) (string, error)
• type FunctionSpec
  • func DecodeFunctionSpec(generic v1.FunctionSpec) (*FunctionSpec, error)
  • func (s *FunctionSpec) ValidateLambda() error
• type Plugin
  • func (p *Plugin) GetDependencies(cfg *v1.Config) *plugin.Dependencies
  • func (p *Plugin) HttpFilters(params *plugin.FilterPluginParams) []plugin.StagedFilter
  • func (p *Plugin) ParseFunctionSpec(params *plugin.FunctionPluginParams, in v1.FunctionSpec) (*types.Struct, error)
  • func (p *Plugin) ProcessRoute(_ *plugin.RoutePluginParams, in *v1.Route, out *envoyroute.Route) error
  • func (p *Plugin) ProcessUpstream(params *plugin.UpstreamPluginParams, in *v1.Upstream, out *envoyapi.Cluster) error
• type UpstreamSpec
  • func DecodeUpstreamSpec(generic v1.UpstreamSpec) (*UpstreamSpec, error)
  • func (s *UpstreamSpec) GetLambdaHostname() string

Constants

const (
	// define Upstream type name
	UpstreamTypeAws = "aws"

	// upstream-specific metadata
	AwsAccessKey = "access_key"
	AwsSecretKey = "secret_key"
)

const (
	ExecutionStyleNone  = "none"
	ExecutionStyleSync  = "sync"
	ExecutionStyleAsync = "async"
)

const (
	// TODO: execution_type should be moved to a separate package
	RoutePluginKeyExecutionStyle = "execution_style"
)

Functions

func EncodeFunctionSpec

func EncodeFunctionSpec(spec FunctionSpec) *types.Struct

func EncodeUpstreamSpec

func EncodeUpstreamSpec(spec UpstreamSpec) *types.Struct

func GetExecutionStyle

func GetExecutionStyle(routeExtensions *types.Struct) (string, error)

Types

type FunctionSpec

type FunctionSpec struct {
	FunctionName string `json:"function_name"`
	Qualifier    string `json:"qualifier"`
}

func DecodeFunctionSpec

func DecodeFunctionSpec(generic v1.FunctionSpec) (*FunctionSpec, error)

func (*FunctionSpec) ValidateLambda

func (s *FunctionSpec) ValidateLambda() error

type Plugin

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

func (*Plugin) GetDependencies

func (p *Plugin) GetDependencies(cfg *v1.Config) *plugin.Dependencies

func (*Plugin) HttpFilters

func (p *Plugin) HttpFilters(params *plugin.FilterPluginParams) []plugin.StagedFilter

func (*Plugin) ParseFunctionSpec

func (p *Plugin) ParseFunctionSpec(params *plugin.FunctionPluginParams, in v1.FunctionSpec) (*types.Struct, error)

func (*Plugin) ProcessRoute

func (p *Plugin) ProcessRoute(_ *plugin.RoutePluginParams, in *v1.Route, out *envoyroute.Route) error

func (*Plugin) ProcessUpstream

func (p *Plugin) ProcessUpstream(params *plugin.UpstreamPluginParams, in *v1.Upstream, out *envoyapi.Cluster) error

type UpstreamSpec

type UpstreamSpec struct {
	Region    string `json:"region"`
	SecretRef string `json:"secret_ref"`
}

func DecodeUpstreamSpec

func DecodeUpstreamSpec(generic v1.UpstreamSpec) (*UpstreamSpec, error)

func (*UpstreamSpec) GetLambdaHostname

func (s *UpstreamSpec) GetLambdaHostname() string