config

Documentation

Overview

MIT License

Copyright (c) 2022 Kubeshop

Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the "Software"), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions:

The above copyright notice and this permission notice shall be included in all copies or substantial portions of the Software.

THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.

MIT License

Copyright (c) 2022 Kubeshop

Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the "Software"), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions:

The above copyright notice and this permission notice shall be included in all copies or substantial portions of the Software.

THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.

MIT License

Copyright (c) 2022 Kubeshop

Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the "Software"), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions:

The above copyright notice and this permission notice shall be included in all copies or substantial portions of the Software.

THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.

Index

• Constants
• func ConfigSource(cluster string) *envoy_core_v3.ConfigSource
• func IsRouterFilter(filter *hcm.HttpFilter) bool
• func NewListenerBuilder() *listenerBuilder
• type AccessLogBuilder
  • func NewJSONAccessLog(template map[string]string) (*AccessLogBuilder, error)
  • func NewTextAccessLog(template string) (*AccessLogBuilder, error)
  • func (a *AccessLogBuilder) GetAccessLog() *accesslog.AccessLog
  • func (a *AccessLogBuilder) ValidateAll() error
• type Certificate
• type EnvoyConfiguration
  • func New() *EnvoyConfiguration
  • func (e *EnvoyConfiguration) AddCluster(clusterName, upstreamServiceHost string, upstreamServicePort uint32)
  • func (e *EnvoyConfiguration) AddClusterWithTLS(clusterName, upstreamServiceHost string, upstreamServicePort uint32) error
  • func (e *EnvoyConfiguration) AddListener(l *listener.Listener)
  • func (e *EnvoyConfiguration) AddRouteToVHost(vhost string, rt *route.Route) error
  • func (e *EnvoyConfiguration) AddVirtualHost(vh *types.VirtualHost)
  • func (e *EnvoyConfiguration) ClusterExist(name string) bool
  • func (e *EnvoyConfiguration) GenerateSnapshot() (*cache.Snapshot, error)
  • func (e *EnvoyConfiguration) GetVirtualHost(name string) *types.VirtualHost
  • func (e *EnvoyConfiguration) GetVirtualHosts() map[string]*types.VirtualHost
• type HCMBuilder
  • func NewHCMBuilder() (*HCMBuilder, error)
  • func (h *HCMBuilder) AddAccessLog(al *accesslog.AccessLog) *HCMBuilder
  • func (h *HCMBuilder) AddFilter(newFilter *hcm.HttpFilter) error
  • func (h *HCMBuilder) GetHTTPConnectionManager() *hcm.HttpConnectionManager
  • func (h *HCMBuilder) ValidateAll() error
• type TLS

Constants

const (
	AccessLogFormatJson string = "json"
	AccessLogFormatText string = "text"
)

const (
	RouteName = "local_route"
)

Functions

func ConfigSource

func ConfigSource(cluster string) *envoy_core_v3.ConfigSource

ConfigSource returns a *envoy_core_v3.ConfigSource for cluster.

func IsRouterFilter

func IsRouterFilter(filter *hcm.HttpFilter) bool

func NewListenerBuilder

func NewListenerBuilder() *listenerBuilder

Types

type AccessLogBuilder

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

func NewJSONAccessLog

func NewJSONAccessLog(template map[string]string) (*AccessLogBuilder, error)

func NewTextAccessLog

func NewTextAccessLog(template string) (*AccessLogBuilder, error)

func (*AccessLogBuilder) GetAccessLog

func (a *AccessLogBuilder) GetAccessLog() *accesslog.AccessLog

func (*AccessLogBuilder) ValidateAll

func (a *AccessLogBuilder) ValidateAll() error

type Certificate

type Certificate struct {
	Cert string
	Key  string
}

type EnvoyConfiguration

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

func New

func New() *EnvoyConfiguration

func (*EnvoyConfiguration) AddCluster

func (e *EnvoyConfiguration) AddCluster(clusterName, upstreamServiceHost string, upstreamServicePort uint32)

AddCluster creates Envoy cluster which is the representation of backend service For the simplicity right now we don't support endpoints assignments separately, i.e. one cluster - one endpoint, not multiple load balanced Cluster with the same name will be overwritten

func (*EnvoyConfiguration) AddClusterWithTLS

func (e *EnvoyConfiguration) AddClusterWithTLS(clusterName, upstreamServiceHost string, upstreamServicePort uint32) error

AddClusterWithTLS - AddCluster with SNI or rather `AutoSni` enabled`. Example SNI : "kubeshop-kusk-gateway-oauth2.eu.auth0.com" -> "eu.auth0.com"

func (*EnvoyConfiguration) AddListener

func (e *EnvoyConfiguration) AddListener(l *listener.Listener)

func (*EnvoyConfiguration) AddRouteToVHost

func (e *EnvoyConfiguration) AddRouteToVHost(vhost string, rt *route.Route) error

AddRouteToVHost appends new route with proxying to the upstream to the list of routes by path and method

func (*EnvoyConfiguration) AddVirtualHost

func (e *EnvoyConfiguration) AddVirtualHost(vh *types.VirtualHost)

func (*EnvoyConfiguration) ClusterExist

func (e *EnvoyConfiguration) ClusterExist(name string) bool

func (*EnvoyConfiguration) GenerateSnapshot

func (e *EnvoyConfiguration) GenerateSnapshot() (*cache.Snapshot, error)

func (*EnvoyConfiguration) GetVirtualHost

func (e *EnvoyConfiguration) GetVirtualHost(name string) *types.VirtualHost

func (*EnvoyConfiguration) GetVirtualHosts

func (e *EnvoyConfiguration) GetVirtualHosts() map[string]*types.VirtualHost

type HCMBuilder

type HCMBuilder struct {
	HTTPConnectionManager *hcm.HttpConnectionManager
}

func NewHCMBuilder

func NewHCMBuilder() (*HCMBuilder, error)

func (*HCMBuilder) AddAccessLog

func (h *HCMBuilder) AddAccessLog(al *accesslog.AccessLog) *HCMBuilder

func (*HCMBuilder) AddFilter

func (h *HCMBuilder) AddFilter(newFilter *hcm.HttpFilter) error

AddFilter appends f to the list of filters for this HTTPConnectionManager. f may be nil, in which case it is ignored and an error will be returned. Note that Router filters (filters with TypeUrl `type.googleapis.com/envoy.extensions.filters.http.router.v3.Router`) are specially treated. There may only be one of these filters, and it must be the last. AddFilter will ensure that the router filter, if present, is last, and will panic if a second Router is added when one is already present.

func (*HCMBuilder) GetHTTPConnectionManager

func (h *HCMBuilder) GetHTTPConnectionManager() *hcm.HttpConnectionManager

func (*HCMBuilder) ValidateAll

func (h *HCMBuilder) ValidateAll() error

type TLS

type TLS struct {
	CipherSuites              []string
	TlsMinimumProtocolVersion string
	TlsMaximumProtocolVersion string
	Certificates              []Certificate
}