manager

Documentation

Index

• Constants
• Variables
• func CheckXDSSvrConfig(cfg *XDSServerConfig) error
• func NewXDSResourceManager(bootstrapConfig *BootstrapConfig, opts ...Option) (*xdsResourceManager, error)
• type ADSClient
• type ADSStream
• type BootstrapConfig
• type Option
• type Options
  • func DefaultOptions() *Options
  • func NewOptions(opts []Option) *Options
  • func (o *Options) Apply(opts []Option)
• type XDSServerConfig
  • func (xsc XDSServerConfig) GetFetchXDSTimeout() time.Duration

Constants

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

var (
	IstiodAddr      = "istiod.istio-system.svc:15010"
	IstiodSvrName   = "istiod.istio-system.svc"
	IstioAuthEnable = false
)

Functions

func CheckXDSSvrConfig

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 ADSStream

type ADSStream = aggregateddiscoveryservice.AggregatedDiscoveryService_StreamAggregatedResourcesClient

type BootstrapConfig

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

type Option

type Option struct {
	F func(o *Options)
}

type Options

type Options struct {
	XDSSvrConfig *XDSServerConfig
	DumpPath     string
}

func DefaultOptions

func DefaultOptions() *Options

func NewOptions

func NewOptions(opts []Option) *Options

func (*Options) Apply

func (o *Options) Apply(opts []Option)

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
	LDSNotRequired  bool          // required by default for Istio
	FetchXDSTimeout time.Duration // timeout for fecth xds, default to 1s
}

func (XDSServerConfig) GetFetchXDSTimeout

func (xsc XDSServerConfig) GetFetchXDSTimeout() time.Duration

GetFetchXDSTimeout get timeout.