Versions in this module Expand all Collapse all v1 v1.19.1 Oct 25, 2022 Changes in this version + type BcsScheduler struct + Next plugin.Handler + func NewScheduler(config *ConfigItem) *BcsScheduler + func (bcs *BcsScheduler) Debug() string + func (bcs *BcsScheduler) InitSchedulerCache() error + func (bcs *BcsScheduler) IsNameError(err error) bool + func (bcs *BcsScheduler) Lookup(state request.Request, name string, typ uint16) (*dns.Msg, error) + func (bcs *BcsScheduler) MinTTL(state request.Request) uint32 + func (bcs *BcsScheduler) Name() string + func (bcs *BcsScheduler) PrimaryZone() string + func (bcs *BcsScheduler) Records(state request.Request, exact bool) ([]msg.Service, error) + func (bcs *BcsScheduler) Reverse(state request.Request, exact bool, opt plugin.Options) (svcList []msg.Service, err error) + func (bcs *BcsScheduler) Serial(state request.Request) uint32 + func (bcs *BcsScheduler) ServeDNS(ctx context.Context, w dns.ResponseWriter, r *dns.Msg) (int, error) + func (bcs *BcsScheduler) Services(state request.Request, exact bool, opt plugin.Options) (svcs []msg.Service, err error) + func (bcs *BcsScheduler) Start() error + func (bcs *BcsScheduler) Stop() error + func (bcs *BcsScheduler) Transfer(ctx context.Context, state request.Request) (int, error) + type ConfigItem struct + Cluster string + EndpointCA string + EndpointCert string + EndpointKey string + EndpointPath string + Endpoints []string + Fallthrough bool + KubeConfig string + MetricPort uint + Proxy proxy.Proxy + Register []string + ResyncPeriod int + Storage []string + StorageCA string + StorageCert string + StorageKey string + StoragePath string + UpStream []string + Zones []string + type ForwardClusterIpDomainError struct + ClusterIP string + func (fc ForwardClusterIpDomainError) Error() string