Documentation
¶
Index ¶
Constants ¶
View Source
const ( PodNamespace = "POD_NAMESPACE" PodName = "POD_NAME" MetaNamespace = "NAMESPACE" InstanceIP = "INSTANCE_IP" KitexXdsDomain = "KITEX_XDS_DOMAIN" // use json to marshal it. KitexXdsMetas = "KITEX_XDS_METAS" IstioAddrEnvKey = "KITEX_XDS_ISTIO_ADDR" IstioServiceNameEnvKey = "KITEX_XDS_ISTIO_SERVICE_NAME" IstioAuthEnvKey = "KITEX_XDS_ISTIO_AUTH" IstioVersion = "ISTIO_VERSION" IstioMetaInstanceIPs = "INSTANCE_IPS" )
Variables ¶
View Source
var ( IstiodAddr = "istiod.istio-system.svc:15010" IstiodSvrName = "istiod.istio-system.svc" IstioAuthEnable = false )
Functions ¶
func CheckXDSSvrConfig ¶ added in v0.1.1
func CheckXDSSvrConfig(cfg *XDSServerConfig) error
func NewXDSResourceManager ¶
func NewXDSResourceManager(bootstrapConfig *BootstrapConfig, opts ...Option) (*xdsResourceManager, error)
NewXDSResourceManager creates a new xds resource manager
Types ¶
type ADSClient ¶
type ADSClient = aggregateddiscoveryservice.Client
type BootstrapConfig ¶
type BootstrapConfig struct {
// contains filtered or unexported fields
}
type Options ¶
type Options struct {
XDSSvrConfig *XDSServerConfig
DumpPath string
}
func DefaultOptions ¶ added in v0.1.1
func DefaultOptions() *Options
func NewOptions ¶
type XDSServerConfig ¶
type XDSServerConfig struct {
SvrName string // The name of the xDS server
SvrAddr string // The address of the xDS server
XDSAuth bool // If this xDS enable the authentication of xDS stream
NDSNotRequired bool // required by default for Istio
FetchXDSTimeout time.Duration // timeout for fecth xds, default to 1s
}
func (XDSServerConfig) GetFetchXDSTimeout ¶ added in v0.3.0
func (xsc XDSServerConfig) GetFetchXDSTimeout() time.Duration
GetFetchXDSTimeout get timeout.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.