Documentation
¶
Overview ¶
+k8s:deepcopy-gen=package
Index ¶
Constants ¶
This section is empty.
Variables ¶
var ( Name = plugin.Name Using = plugin.Using )
var ( // ErrRegistry dsync errors. ErrRegistry = errors.New("registry") // ErrNotFound Not found error when IRegistry.GetService or IRegistry.GetServiceNode is called ErrNotFound = fmt.Errorf("%w: service not found", ErrRegistry) // ErrStoppedWatching Stopped watching error when watcher is stopped ErrStoppedWatching = fmt.Errorf("%w: stopped watching", ErrRegistry) )
Functions ¶
func Deregister ¶
Deregister 取消注册服务
Types ¶
type Event ¶
Event is returned by a call to Next on the watcher. Type can be create, update, delete +k8s:deepcopy-gen=true
func (*Event) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Event.
func (*Event) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EventType ¶
type EventType int
EventType defines registry event type
func (*EventType) MarshalText ¶
MarshalText marshals the EventType to text.
func (*EventType) Set ¶
Set converts a EventType string into a EventType value. returns error if the input string does not match known values.
func (*EventType) UnmarshalText ¶
UnmarshalText unmarshals text to a EventType.
type IRegistry ¶
type IRegistry interface {
// Register 注册服务
Register(ctx context.Context, service *Service, ttl time.Duration) error
// Deregister 取消注册服务
Deregister(ctx context.Context, service *Service) error
// GetServiceNode 查询服务节点
GetServiceNode(ctx context.Context, serviceName, nodeId string) (*Service, error)
// GetService 查询服务
GetService(ctx context.Context, serviceName string) ([]Service, error)
// ListServices 查询所有服务
ListServices(ctx context.Context) ([]Service, error)
// Watch 获取服务监听器
Watch(ctx context.Context, pattern string) (IWatcher, error)
}
The IRegistry provides an interface for service discovery and an abstraction over varying implementations {consul, etcd, zookeeper, ...}
type IWatcher ¶
type IWatcher interface {
// Pattern watching pattern
Pattern() string
// Next is a blocking call
Next() (*Event, error)
// Stop stop watching
Stop() <-chan struct{}
}
IWatcher is an interface that returns updates about services within the registry.
type Node ¶
type Node struct {
Id string `json:"id"` // 节点ID
Address string `json:"address"` // 节点的地址
Meta map[string]string `json:"meta"` // 节点元数据，以键值对的形式保存附加信息
}
Node 服务节点 +k8s:deepcopy-gen=true
func (*Node) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Node.
func (*Node) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Service ¶
type Service struct {
Name string `json:"name"` // 服务名称
Version string `json:"version"` // 服务版本号
Meta map[string]string `json:"meta"` // 服务元数据，以键值对的形式保存附加信息
Nodes []Node `json:"nodes"` // 服务节点列表
}
Service 服务配置 +k8s:deepcopy-gen=true
func GetService ¶
func GetService(servCtx service.Context, ctx context.Context, serviceName string) ([]Service, error)
GetService 查询服务
func ListServices ¶
ListServices 查询所有服务
func (*Service) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Service.
func (*Service) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
Source Files
Directories