provider

package
v1.5.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 14, 2026 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	WildcardNamespace = "*"
	DefaultNamespace  = "default"
)
View Source 
const (
	NebulaAdaptor = CodecAdaptor(`nebula`)
	DubboAdaptor  = CodecAdaptor(`dubbo`)
	K8sAdaptor    = CodecAdaptor(`k8s`)
)

Variables

This section is empty.

Functions

This section is empty.

Types

type CodecAdaptor added in v1.5.0 

type CodecAdaptor string

type ConsulDiscoveryClient 

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

func GetConsulDiscoveryClient 

func GetConsulDiscoveryClient(connectController connector.ConnectController) (*ConsulDiscoveryClient, error)

func (*ConsulDiscoveryClient) CatalogInstances added in v1.2.1 

func (dc *ConsulDiscoveryClient) CatalogInstances(service string, q *connector.QueryOptions) ([]*connector.AgentService, error)

func (*ConsulDiscoveryClient) CatalogServices 

func (dc *ConsulDiscoveryClient) CatalogServices(q *connector.QueryOptions) ([]ctv1.NamespacedService, error)

func (*ConsulDiscoveryClient) Close added in v1.3.8 

func (dc *ConsulDiscoveryClient) Close()

func (*ConsulDiscoveryClient) Deregister 

func (dc *ConsulDiscoveryClient) Deregister(dereg *connector.CatalogDeregistration) error

func (*ConsulDiscoveryClient) EnableNamespaces added in v1.2.1 

func (dc *ConsulDiscoveryClient) EnableNamespaces() bool

func (*ConsulDiscoveryClient) EnsureNamespaceExists 

func (dc *ConsulDiscoveryClient) EnsureNamespaceExists(ns string) (bool, error)

EnsureNamespaceExists ensures a namespace with name ns exists. If it doesn't, it will create it and set crossNSACLPolicy as a policy default. Boolean return value indicates if the namespace was created by this call.

func (*ConsulDiscoveryClient) GetClusterTag added in v1.2.1 

func (dc *ConsulDiscoveryClient) GetClusterTag() string

func (*ConsulDiscoveryClient) GetConnectorUidTag added in v1.2.1 

func (dc *ConsulDiscoveryClient) GetConnectorUidTag() string

func (*ConsulDiscoveryClient) IsInternalServices 

func (dc *ConsulDiscoveryClient) IsInternalServices() bool

func (*ConsulDiscoveryClient) MicroServiceProvider 

func (dc *ConsulDiscoveryClient) MicroServiceProvider() ctv1.DiscoveryServiceProvider

func (*ConsulDiscoveryClient) Register 

func (dc *ConsulDiscoveryClient) Register(reg *connector.CatalogRegistration) error

func (*ConsulDiscoveryClient) RegisteredInstances added in v1.2.1 

func (dc *ConsulDiscoveryClient) RegisteredInstances(service string, q *connector.QueryOptions) ([]*connector.CatalogService, error)

RegisteredInstances is used to query catalog entries for a given service

func (*ConsulDiscoveryClient) RegisteredNamespace added in v1.2.1 

func (dc *ConsulDiscoveryClient) RegisteredNamespace(kubeNS string) string

RegisteredNamespace returns the cloud namespace that a service should be registered in based on the namespace options. It returns an empty string if namespaces aren't enabled.

func (*ConsulDiscoveryClient) RegisteredServices added in v1.2.1 

func (dc *ConsulDiscoveryClient) RegisteredServices(q *connector.QueryOptions) ([]ctv1.NamespacedService, error)

type EurekaDiscoveryClient 

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

func GetEurekaDiscoveryClient 

func GetEurekaDiscoveryClient(connectController connector.ConnectController) (*EurekaDiscoveryClient, error)

func (*EurekaDiscoveryClient) CatalogInstances added in v1.2.1 

func (dc *EurekaDiscoveryClient) CatalogInstances(service string, _ *connector.QueryOptions) ([]*connector.AgentService, error)

func (*EurekaDiscoveryClient) CatalogServices 

func (dc *EurekaDiscoveryClient) CatalogServices(*connector.QueryOptions) ([]ctv1.NamespacedService, error)

func (*EurekaDiscoveryClient) Close added in v1.3.8 

func (dc *EurekaDiscoveryClient) Close()

func (*EurekaDiscoveryClient) Deregister 

func (dc *EurekaDiscoveryClient) Deregister(dereg *connector.CatalogDeregistration) error

func (*EurekaDiscoveryClient) EnableNamespaces added in v1.2.1 

func (dc *EurekaDiscoveryClient) EnableNamespaces() bool

func (*EurekaDiscoveryClient) EnsureNamespaceExists 

func (dc *EurekaDiscoveryClient) EnsureNamespaceExists(string) (bool, error)

EnsureNamespaceExists ensures a namespace with name ns exists.

func (*EurekaDiscoveryClient) IsInternalServices 

func (dc *EurekaDiscoveryClient) IsInternalServices() bool

func (*EurekaDiscoveryClient) MicroServiceProvider 

func (dc *EurekaDiscoveryClient) MicroServiceProvider() ctv1.DiscoveryServiceProvider

func (*EurekaDiscoveryClient) Register 

func (dc *EurekaDiscoveryClient) Register(reg *connector.CatalogRegistration) error

func (*EurekaDiscoveryClient) RegisteredInstances added in v1.2.1 

func (dc *EurekaDiscoveryClient) RegisteredInstances(service string, _ *connector.QueryOptions) ([]*connector.CatalogService, error)

RegisteredInstances is used to query catalog entries for a given service

func (*EurekaDiscoveryClient) RegisteredNamespace added in v1.2.1 

func (dc *EurekaDiscoveryClient) RegisteredNamespace(string) string

RegisteredNamespace returns the cloud namespace that a service should be registered in based on the namespace options. It returns an empty string if namespaces aren't enabled.

func (*EurekaDiscoveryClient) RegisteredServices added in v1.2.1 

func (dc *EurekaDiscoveryClient) RegisteredServices(*connector.QueryOptions) ([]ctv1.NamespacedService, error)

type MachineDiscoveryClient 

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

func GetMachineDiscoveryClient 

func GetMachineDiscoveryClient(connectController connector.ConnectController,
	machineClient machineClientset.Interface) (*MachineDiscoveryClient, error)

func (*MachineDiscoveryClient) CatalogInstances added in v1.2.1 

func (dc *MachineDiscoveryClient) CatalogInstances(service string, _ *connector.QueryOptions) ([]*connector.AgentService, error)

func (*MachineDiscoveryClient) CatalogServices 

func (dc *MachineDiscoveryClient) CatalogServices(*connector.QueryOptions) ([]ctv1.NamespacedService, error)

func (*MachineDiscoveryClient) Close added in v1.3.8 

func (dc *MachineDiscoveryClient) Close()

func (*MachineDiscoveryClient) Deregister 

func (dc *MachineDiscoveryClient) Deregister(*connector.CatalogDeregistration) error

func (*MachineDiscoveryClient) EnableNamespaces added in v1.2.1 

func (dc *MachineDiscoveryClient) EnableNamespaces() bool

func (*MachineDiscoveryClient) EnsureNamespaceExists 

func (dc *MachineDiscoveryClient) EnsureNamespaceExists(string) (bool, error)

EnsureNamespaceExists ensures a namespace with name ns exists.

func (*MachineDiscoveryClient) IsInternalServices 

func (dc *MachineDiscoveryClient) IsInternalServices() bool

func (*MachineDiscoveryClient) MicroServiceProvider 

func (dc *MachineDiscoveryClient) MicroServiceProvider() ctv1.DiscoveryServiceProvider

func (*MachineDiscoveryClient) Register 

func (dc *MachineDiscoveryClient) Register(*connector.CatalogRegistration) error

func (*MachineDiscoveryClient) RegisteredInstances added in v1.2.1 

func (dc *MachineDiscoveryClient) RegisteredInstances(string, *connector.QueryOptions) ([]*connector.CatalogService, error)

RegisteredInstances is used to query catalog entries for a given service

func (*MachineDiscoveryClient) RegisteredNamespace added in v1.2.1 

func (dc *MachineDiscoveryClient) RegisteredNamespace(string) string

RegisteredNamespace returns the cloud namespace that a service should be registered in based on the namespace options. It returns an empty string if namespaces aren't enabled.

func (*MachineDiscoveryClient) RegisteredServices added in v1.2.1 

func (dc *MachineDiscoveryClient) RegisteredServices(*connector.QueryOptions) ([]ctv1.NamespacedService, error)

type NacosDiscoveryClient added in v1.2.1 

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

func GetNacosDiscoveryClient added in v1.2.1 

func GetNacosDiscoveryClient(connectController connector.ConnectController) (*NacosDiscoveryClient, error)

func (*NacosDiscoveryClient) CatalogInstances added in v1.2.1 

func (dc *NacosDiscoveryClient) CatalogInstances(service string, _ *connector.QueryOptions) ([]*connector.AgentService, error)

func (*NacosDiscoveryClient) CatalogServices added in v1.2.1 

func (dc *NacosDiscoveryClient) CatalogServices(*connector.QueryOptions) ([]ctv1.NamespacedService, error)

func (*NacosDiscoveryClient) Close added in v1.3.8 

func (dc *NacosDiscoveryClient) Close()

func (*NacosDiscoveryClient) Deregister added in v1.2.1 

func (dc *NacosDiscoveryClient) Deregister(dereg *connector.CatalogDeregistration) error

func (*NacosDiscoveryClient) EnableNamespaces added in v1.2.1 

func (dc *NacosDiscoveryClient) EnableNamespaces() bool

func (*NacosDiscoveryClient) EnsureNamespaceExists added in v1.2.1 

func (dc *NacosDiscoveryClient) EnsureNamespaceExists(ns string) (bool, error)

EnsureNamespaceExists ensures a namespace with name ns exists.

func (*NacosDiscoveryClient) IsInternalServices added in v1.2.1 

func (dc *NacosDiscoveryClient) IsInternalServices() bool

func (*NacosDiscoveryClient) MicroServiceProvider added in v1.2.1 

func (dc *NacosDiscoveryClient) MicroServiceProvider() ctv1.DiscoveryServiceProvider

func (*NacosDiscoveryClient) Register added in v1.2.1 

func (dc *NacosDiscoveryClient) Register(reg *connector.CatalogRegistration) error

func (*NacosDiscoveryClient) RegisteredInstances added in v1.2.1 

func (dc *NacosDiscoveryClient) RegisteredInstances(service string, _ *connector.QueryOptions) ([]*connector.CatalogService, error)

RegisteredInstances is used to query catalog entries for a given service

func (*NacosDiscoveryClient) RegisteredNamespace added in v1.2.1 

func (dc *NacosDiscoveryClient) RegisteredNamespace(kubeNS string) string

RegisteredNamespace returns the cloud namespace that a service should be registered in based on the namespace options. It returns an empty string if namespaces aren't enabled.

func (*NacosDiscoveryClient) RegisteredServices added in v1.2.1 

func (dc *NacosDiscoveryClient) RegisteredServices(*connector.QueryOptions) ([]ctv1.NamespacedService, error)

func (*NacosDiscoveryClient) SubscribeToService added in v1.5.2 

func (dc *NacosDiscoveryClient) SubscribeToService(
	serviceName string,
	groups []string,
	clusters []string,
	callback func(instances interface{}, err error),
) (unsubscribe func(), generation uint64, err error)

func (*NacosDiscoveryClient) SubscriptionGeneration added in v1.5.2 

func (dc *NacosDiscoveryClient) SubscriptionGeneration() uint64

type ZookeeperDiscoveryClient added in v1.5.0 

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

func GetZookeeperDiscoveryClient added in v1.5.0 

func GetZookeeperDiscoveryClient(connectController connector.ConnectController) (*ZookeeperDiscoveryClient, error)

func (*ZookeeperDiscoveryClient) CatalogInstances added in v1.5.0 

func (dc *ZookeeperDiscoveryClient) CatalogInstances(service string, _ *connector.QueryOptions) ([]*connector.AgentService, error)

func (*ZookeeperDiscoveryClient) CatalogServices added in v1.5.0 

func (dc *ZookeeperDiscoveryClient) CatalogServices(*connector.QueryOptions) ([]ctv1.NamespacedService, error)

func (*ZookeeperDiscoveryClient) Close added in v1.5.0 

func (dc *ZookeeperDiscoveryClient) Close()

func (*ZookeeperDiscoveryClient) Deregister added in v1.5.0 

func (dc *ZookeeperDiscoveryClient) Deregister(dereg *connector.CatalogDeregistration) error

func (*ZookeeperDiscoveryClient) EnableNamespaces added in v1.5.0 

func (dc *ZookeeperDiscoveryClient) EnableNamespaces() bool

func (*ZookeeperDiscoveryClient) EnsureNamespaceExists added in v1.5.0 

func (dc *ZookeeperDiscoveryClient) EnsureNamespaceExists(ns string) (bool, error)

EnsureNamespaceExists ensures a namespace with name ns exists.

func (*ZookeeperDiscoveryClient) IsInternalServices added in v1.5.0 

func (dc *ZookeeperDiscoveryClient) IsInternalServices() bool

func (*ZookeeperDiscoveryClient) MicroServiceProvider added in v1.5.0 

func (dc *ZookeeperDiscoveryClient) MicroServiceProvider() ctv1.DiscoveryServiceProvider

func (*ZookeeperDiscoveryClient) Register added in v1.5.0 

func (dc *ZookeeperDiscoveryClient) Register(reg *connector.CatalogRegistration) error

func (*ZookeeperDiscoveryClient) RegisteredInstances added in v1.5.0 

func (dc *ZookeeperDiscoveryClient) RegisteredInstances(service string, _ *connector.QueryOptions) ([]*connector.CatalogService, error)

RegisteredInstances is used to query catalog entries for a given service

func (*ZookeeperDiscoveryClient) RegisteredNamespace added in v1.5.0 

func (dc *ZookeeperDiscoveryClient) RegisteredNamespace(kubeNS string) string

RegisteredNamespace returns the cloud namespace that a service should be registered in based on the namespace options. It returns an empty string if namespaces aren't enabled.

func (*ZookeeperDiscoveryClient) RegisteredServices added in v1.5.0 

func (dc *ZookeeperDiscoveryClient) RegisteredServices(*connector.QueryOptions) ([]ctv1.NamespacedService, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.