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 ParseGogoConfig(c gogoConfigObject, config proto.Message) error
• func UpstreamToClusterName(upstream core.ResourceRef) string
• func ValidateRouteDestinations(snap *v1.ApiSnapshot, action *v1.RouteAction) error
• func ValidateVirtualHostDomains(virtualHosts []*v1.VirtualHost, ...)
• 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 (
	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.")
)

var (
	ClusterConnectionTimeout = time.Second * 5
)

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 ParseGogoConfig

func ParseGogoConfig(c gogoConfigObject, 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

func ValidateVirtualHostDomains

func ValidateVirtualHostDomains(virtualHosts []*v1.VirtualHost, httpListenerReport *validationapi.HttpListenerReport)

returns an error if any of the virtualhost domains overlap Visible for testing

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