conv

Documentation

Index

• Constants
• func ConvertClustersConfig(xdsClusters []*envoy_config_cluster_v3.Cluster) []*v2.Cluster
• func ConvertDuration(p *duration.Duration) time.Duration
• func ConvertEndpointsConfig(xdsEndpoint *envoy_config_endpoint_v3.LocalityLbEndpoints) []v2.Host
• func ConvertListenerConfig(xdsListener *envoy_config_listener_v3.Listener, rh routeHandler) []*v2.Listener
• func ConvertRouterConf(routeConfigName string, ...) (*v2.RouterConfiguration, bool)
• func EnvoyConfigDeleteClusterByName(name string)
• func EnvoyConfigDeleteListeners(listeners []*envoy_config_listener_v3.Listener)
• func EnvoyConfigDump() []byte
• func EnvoyConfigUpdateClusters(clusters []*envoy_config_cluster_v3.Cluster)
• func EnvoyConfigUpdateListeners(listeners []*envoy_config_listener_v3.Listener)
• func EnvoyConfigUpdateRoutes(routes []*envoy_config_route_v3.RouteConfiguration)
• func GetAccessLog(log *envoy_config_accesslog_v3.AccessLog) (*envoy_extensions_access_loggers_file_v3.FileAccessLog, error)
• func GetHTTPConnectionManager(filter *envoy_config_listener_v3.Filter) ...
• func GetTcpProxy(filter *envoy_config_listener_v3.Filter) *envoy_extensions_filters_network_tcp_proxy_v3.TcpProxy
• func NewConverter() *xdsConverter
• type Converter
• type DefaultPassthroughCluster
• type XdsStats
  • func NewXdsStats() XdsStats

Constants

const (
	CdsUpdateSuccessTotal = "cds_update_success"
	CdsUpdateRejectTotal  = "cds_update_reject"
	LdsUpdateSuccessTotal = "ls_update_success"
	LdsUpdateRejectTotal  = "lds_update_reject"
)

metrics key in listener/proxy

const (
	MosnPayloadLimit = "mosn.payload_limit"
)

istio stream filter names, which is quite different from mosn

const XdsType = "xds"

DownstreamType represents downstream metrics type

Functions

func ConvertClustersConfig

func ConvertClustersConfig(xdsClusters []*envoy_config_cluster_v3.Cluster) []*v2.Cluster

func ConvertDuration

func ConvertDuration(p *duration.Duration) time.Duration

func ConvertEndpointsConfig

func ConvertEndpointsConfig(xdsEndpoint *envoy_config_endpoint_v3.LocalityLbEndpoints) []v2.Host

func ConvertListenerConfig

func ConvertListenerConfig(xdsListener *envoy_config_listener_v3.Listener, rh routeHandler) []*v2.Listener

func ConvertRouterConf

func ConvertRouterConf(routeConfigName string, xdsRouteConfig *envoy_config_route_v3.RouteConfiguration) (*v2.RouterConfiguration, bool)

func EnvoyConfigDeleteClusterByName

func EnvoyConfigDeleteClusterByName(name string)

func EnvoyConfigDeleteListeners

func EnvoyConfigDeleteListeners(listeners []*envoy_config_listener_v3.Listener)

func EnvoyConfigDump

func EnvoyConfigDump() []byte

EnvoyConfigDump dump all envoy config

func EnvoyConfigUpdateClusters

func EnvoyConfigUpdateClusters(clusters []*envoy_config_cluster_v3.Cluster)

EnvoyConfigUpdateClusters update envoy cluster config

func EnvoyConfigUpdateListeners

func EnvoyConfigUpdateListeners(listeners []*envoy_config_listener_v3.Listener)

EnvoyConfigUpdateListeners update envoy listener config

func EnvoyConfigUpdateRoutes

func EnvoyConfigUpdateRoutes(routes []*envoy_config_route_v3.RouteConfiguration)

EnvoyConfigUpdateRoutes update envoy route config

func GetAccessLog

func GetAccessLog(log *envoy_config_accesslog_v3.AccessLog) (*envoy_extensions_access_loggers_file_v3.FileAccessLog, error)

func GetHTTPConnectionManager

func GetHTTPConnectionManager(filter *envoy_config_listener_v3.Filter) *envoy_extensions_filters_network_http_connection_manager_v3.HttpConnectionManager

func GetTcpProxy

func GetTcpProxy(filter *envoy_config_listener_v3.Filter) *envoy_extensions_filters_network_tcp_proxy_v3.TcpProxy

func NewConverter

func NewConverter() *xdsConverter

Types

type Converter

type Converter interface {
	Stats() *XdsStats
	AppendRouterName(name string)
	GetRouterNames() []string
	ConvertAddOrUpdateRouters(routers []*envoy_config_route_v3.RouteConfiguration)
	ConvertAddOrUpdateListeners(listeners []*envoy_config_listener_v3.Listener)
	ConvertDeleteListeners(listeners []*envoy_config_listener_v3.Listener)
	ConvertUpdateClusters(clusters []*envoy_config_cluster_v3.Cluster)
	ConvertDeleteClusters(clusters []*envoy_config_cluster_v3.Cluster)
	ConvertUpdateEndpoints(loadAssignments []*envoy_config_endpoint_v3.ClusterLoadAssignment) error
}

Converter as an interface for mock test

type DefaultPassthroughCluster

type DefaultPassthroughCluster string

DefaultPassthroughCluster: EGRESS_CLUSTER or INGRESS_CLUSTER, counterpart of v2.ListenerType

const EGRESS_CLUSTER DefaultPassthroughCluster = "PassthroughCluster"

const INGRESS_CLUSTER DefaultPassthroughCluster = "InboundPassthroughClusterIpv4"

type XdsStats

type XdsStats struct {
	CdsUpdateSuccess gometrics.Counter
	CdsUpdateReject  gometrics.Counter
	LdsUpdateSuccess gometrics.Counter
	LdsUpdateReject  gometrics.Counter
}

func NewXdsStats

func NewXdsStats() XdsStats

NewXdsStats returns a stats with namespace prefix proxy