translator

Documentation

Overview

Package translator is a generated protocol buffer package.

It is generated from these files:

functional_base.proto

It has these top-level messages:

FunctionalFilterRouteConfig

Index

• Constants
• Variables
• func DataSourceFromString(str string) *envoycore.DataSource
• func GlooMatcherToEnvoyMatcher(matcher *matchers.Matcher) envoyroute.RouteMatch
• func MakeRdsResources(routeConfigs []*envoyapi.RouteConfiguration) envoycache.Resources
• func NewAccessLogWithConfig(name string, config proto.Message) (envoyal.AccessLog, error)
• func NewFilterWithConfig(name string, config proto.Message) (envoylistener.Filter, error)
• func NewHttpConnectionManager(listener *v1.HttpListener, httpFilters []*envoyhttp.HttpFilter, rdsName string) *envoyhttp.HttpConnectionManager
• func ParseConfig(c configObject, config proto.Message) error
• func UpstreamToClusterName(upstream core.ResourceRef) string
• func ValidateRouteDestinations(snap *v1.ApiSnapshot, action *v1.RouteAction) error
• type FunctionalFilterRouteConfig
  • func (*FunctionalFilterRouteConfig) Descriptor() ([]byte, []int)
  • func (m *FunctionalFilterRouteConfig) GetFunctionName() string
  • func (*FunctionalFilterRouteConfig) ProtoMessage()
  • func (m *FunctionalFilterRouteConfig) Reset()
  • func (m *FunctionalFilterRouteConfig) String() string
• type Translator
  • func NewTranslator(sslConfigTranslator utils.SslConfigTranslator, settings *v1.Settings, ...) Translator

Constants

const (
	ClusterConnectionTimeout = time.Second * 5

	SslCertificateChainKey = "tls.crt"
	SslPrivateKeyKey       = "tls.key"
	SslRootCaKey           = "tls.root"
)

const (
	DefaultHttpStatPrefix = "http"
)

const EnvoyLb = "envoy.lb"

const SoloAnnotations = "io.solo.annotations"

Variables

var (
	DefaultHealthCheckTimeout  = time.Second * 5
	DefaultHealthCheckInterval = time.Millisecond * 100
	DefaultThreshold           = &types.UInt32Value{
		Value: 5,
	}

	NilFieldError = func(fieldName string) error {
		return errors.Errorf("The field %s cannot be nil", fieldName)
	}
)

var (
	NoDestinationSpecifiedError = errors.New("must specify at least one weighted destination for multi destination routes")

	SubsetsMisconfiguredErr = errors.New("route has a subset config, but the upstream does not.")
)

Functions

func DataSourceFromString

func DataSourceFromString(str string) *envoycore.DataSource

func GlooMatcherToEnvoyMatcher

func GlooMatcherToEnvoyMatcher(matcher *matchers.Matcher) envoyroute.RouteMatch

utility function to transform gloo matcher to envoy route matcher

func MakeRdsResources

func MakeRdsResources(routeConfigs []*envoyapi.RouteConfiguration) envoycache.Resources

func NewAccessLogWithConfig

func NewAccessLogWithConfig(name string, config proto.Message) (envoyal.AccessLog, error)

func NewFilterWithConfig

func NewFilterWithConfig(name string, config proto.Message) (envoylistener.Filter, error)

func NewHttpConnectionManager

func NewHttpConnectionManager(listener *v1.HttpListener, httpFilters []*envoyhttp.HttpFilter, rdsName string) *envoyhttp.HttpConnectionManager

func ParseConfig

func ParseConfig(c configObject, config proto.Message) error

func UpstreamToClusterName

func UpstreamToClusterName(upstream core.ResourceRef) string

returns the name of the cluster created for a given upstream

func ValidateRouteDestinations

func ValidateRouteDestinations(snap *v1.ApiSnapshot, action *v1.RouteAction) error

Types

type FunctionalFilterRouteConfig

type FunctionalFilterRouteConfig struct {
	FunctionName string `protobuf:"bytes,1,opt,name=function_name,json=functionName,proto3" json:"function_name,omitempty"`
}

func (*FunctionalFilterRouteConfig) Descriptor

func (*FunctionalFilterRouteConfig) Descriptor() ([]byte, []int)

func (*FunctionalFilterRouteConfig) GetFunctionName

func (m *FunctionalFilterRouteConfig) GetFunctionName() string

func (*FunctionalFilterRouteConfig) ProtoMessage

func (*FunctionalFilterRouteConfig) ProtoMessage()

func (*FunctionalFilterRouteConfig) Reset

func (m *FunctionalFilterRouteConfig) Reset()

func (*FunctionalFilterRouteConfig) String

func (m *FunctionalFilterRouteConfig) String() string

type Translator

type Translator interface {
	Translate(params plugins.Params, proxy *v1.Proxy) (envoycache.Snapshot, reporter.ResourceReports, *validationapi.ProxyReport, error)
}

func NewTranslator

func NewTranslator(sslConfigTranslator utils.SslConfigTranslator, settings *v1.Settings, getPlugins func() []plugins.Plugin) Translator