conv

package

v1.6.0 Latest Latest Go to latest Published: Aug 17, 2023 License: Apache-2.0 Imports: 56 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/mosn/mosn

Links

Open Source Insights

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 ¶

View Source

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

metrics key in listener/proxy

View Source

const (
	MosnPayloadLimit = "mosn.payload_limit"
)

istio stream filter names, which is quite different from mosn

View Source

const XdsType = "xds"

DownstreamType represents downstream metrics type

Variables ¶

This section is empty.

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 ¶ added in v1.3.0

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL