utils

Documentation

Index

• Constants
• Variables
• func AnyToMessage(a *pany.Any) (proto.Message, error)
• func EnsureRouteAction(out *envoyroute.Route) error
• func EnvoyPathAsString(matcher *route.RouteMatch) string
• func FilterLogLevel(r io.ReadCloser, level LogLevel) strings.Builder
• func GogoMessageToAnyGoProto(msg proto.Message) (*pany.Any, error)
• func MessageToAny(msg proto.Message) (*pany.Any, error)
• func MustAnyToMessage(a *pany.Any) proto.Message
• func MustGogoMessageToAnyGoProto(msg proto.Message) *pany.Any
• func MustMessageToAny(msg proto.Message) *pany.Any
• func NewSslConfigTranslator() *sslConfigTranslator
• func PathAsString(matcher *matchers.Matcher) string
• func SanitizeForEnvoy(ctx context.Context, resourceName, resourceTypeName string) string
• func SortGatewayRoutesByPath(routes []*gatewayv1.Route)
• func SortRoutesByPath(routes []*v1.Route)
• type CertSource
• type LogLevel
  • func (l LogLevel) String() string
• type SslConfigTranslator

Constants

const (
	MetadataPluginName = "envoy.grpc_credentials.file_based_metadata"
)

Variables

var (
	TlsVersionNotFoundError = func(v v1.SslParameters_ProtocolVersion) error {
		return eris.Errorf("tls version %v not found", v)
	}

	SslSecretNotFoundError = func(err error) error {
		return eris.Wrapf(err, "SSL secret not found")
	}

	NotTlsSecretError = func(ref core.ResourceRef) error {
		return eris.Errorf("%v is not a TLS secret", ref)
	}

	NoCertificateFoundError = eris.New("no certificate information found")
)

var (
	InvalidRouteActionError = errors.New("cannot use this plugin on non-Route_Route route actions")
)

Functions

func AnyToMessage

func AnyToMessage(a *pany.Any) (proto.Message, error)

func EnsureRouteAction

func EnsureRouteAction(out *envoyroute.Route) error

func EnvoyPathAsString

func EnvoyPathAsString(matcher *route.RouteMatch) string

func FilterLogLevel

func FilterLogLevel(r io.ReadCloser, level LogLevel) strings.Builder

Filter JSON logs with level

func GogoMessageToAnyGoProto

func GogoMessageToAnyGoProto(msg proto.Message) (*pany.Any, error)

gogoprotos converted directly to goproto any can't be marshalled unless you wrap the contents of the gogoproto in a typed struct

func MessageToAny

func MessageToAny(msg proto.Message) (*pany.Any, error)

func MustAnyToMessage

func MustAnyToMessage(a *pany.Any) proto.Message

func MustGogoMessageToAnyGoProto

func MustGogoMessageToAnyGoProto(msg proto.Message) *pany.Any

gogoprotos converted directly to goproto any can't be marshalled unless you wrap the contents of the gogoproto in a typed struct

func MustMessageToAny

func MustMessageToAny(msg proto.Message) *pany.Any

func NewSslConfigTranslator

func NewSslConfigTranslator() *sslConfigTranslator

func PathAsString

func PathAsString(matcher *matchers.Matcher) string

func SanitizeForEnvoy

func SanitizeForEnvoy(ctx context.Context, resourceName, resourceTypeName string) string

func SortGatewayRoutesByPath

func SortGatewayRoutesByPath(routes []*gatewayv1.Route)

func SortRoutesByPath

func SortRoutesByPath(routes []*v1.Route)

Matchers sort according to the following rules: 1. exact path < regex path < prefix path 2. lexicographically greater path string < lexicographically greater path string

Types

type CertSource

type CertSource interface {
	GetSecretRef() *core.ResourceRef
	GetSslFiles() *v1.SSLFiles
	GetSds() *v1.SDSConfig
	GetVerifySubjectAltName() []string
	GetParameters() *v1.SslParameters
	GetAlpnProtocols() []string
}

type LogLevel

type LogLevel int8

A Level is a logging priority. Higher levels are more important.

const (
	LogLevelInfo LogLevel = iota - 1
	LogLevelWarn
	LogLevelError
	LogLevelAll
)

func (LogLevel) String

func (l LogLevel) String() string

String returns a lower-case ASCII representation of the log level.

type SslConfigTranslator

type SslConfigTranslator interface {
	ResolveUpstreamSslConfig(secrets v1.SecretList, uc *v1.UpstreamSslConfig) (*envoyauth.UpstreamTlsContext, error)
	ResolveDownstreamSslConfig(secrets v1.SecretList, dc *v1.SslConfig) (*envoyauth.DownstreamTlsContext, error)
	ResolveCommonSslConfig(cs CertSource, secrets v1.SecretList, mustHaveCert bool) (*envoyauth.CommonTlsContext, error)
}