conv

Documentation

Index

• Constants
• func ConvertClustersConfig(xdsClusters []*xdsapi.Cluster) []*v2.Cluster
• func ConvertDuration(p *duration.Duration) time.Duration
• func ConvertEndpointsConfig(xdsEndpoint *xdsendpoint.LocalityLbEndpoints) []v2.Host
• func ConvertListenerConfig(xdsListener *xdsapi.Listener, rh routeHandler) *v2.Listener
• func ConvertRouterConf(routeConfigName string, xdsRouteConfig *xdsapi.RouteConfiguration) (*v2.RouterConfiguration, bool)
• func GetAccessLog(log *accesslog.AccessLog) (*xdsaccesslog.FileAccessLog, error)
• func GetHTTPConnectionManager(filter *xdslistener.Filter) *xdshttp.HttpConnectionManager
• func GetTcpProxy(filter *xdslistener.Filter) *xdstcp.TcpProxy
• func NewConverter() *xdsConverter
• type Converter
• type XdsStats
  • func NewXdsStats() XdsStats

Constants

const (
	IstioFault       = "envoy.fault"
	IstioRouter      = "envoy.router"
	IstioCors        = "envoy.cors"
	MosnPayloadLimit = "mosn.payload_limit"
)

istio stream filter names, which is quite different from mosn

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

metrics key in listener/proxy

const XdsType = "xds"

DownstreamType represents downstream metrics type

Functions

func ConvertClustersConfig

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

func ConvertDuration

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

func ConvertEndpointsConfig

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

func ConvertListenerConfig

func ConvertListenerConfig(xdsListener *xdsapi.Listener, rh routeHandler) *v2.Listener

todo add streamfilters parse

func ConvertRouterConf

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

func GetAccessLog

func GetAccessLog(log *accesslog.AccessLog) (*xdsaccesslog.FileAccessLog, error)

func GetHTTPConnectionManager

func GetHTTPConnectionManager(filter *xdslistener.Filter) *xdshttp.HttpConnectionManager

func GetTcpProxy

func GetTcpProxy(filter *xdslistener.Filter) *xdstcp.TcpProxy

func NewConverter

func NewConverter() *xdsConverter

Types

type Converter

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

Converter as an interface for mock test

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