provider

package
v1.2.4 Latest Latest
Warning

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

 Go to latest Published: Apr 18, 2024 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	WildcardNamespace = "*"
	DefaultNamespace  = "default"
)

Variables

This section is empty.

Functions

This section is empty.

Types

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) ([]connector.MicroService, error)

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) ([]connector.MicroService, 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) ([]connector.MicroService, error)

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) ([]connector.MicroService, 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) ([]connector.MicroService, error)

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) ([]connector.MicroService, 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) ([]connector.MicroService, error)

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) ([]connector.MicroService, 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.