Versions in this module Expand all Collapse all v1 v1.0.2 Sep 27, 2023 v1.0.1 May 23, 2023 Changes in this version + var ErrNotFound = errors.New("not found") + func DecodeMetadata(tags []string) map[string]string + func DecodeVersion(tags []string) (string, bool) + func EncodeEndpoints(en []*Endpoint) []string + func EncodeMetadata(md map[string]string) []string + func EncodeVersion(v string) []string + type Endpoint struct + Metadata map[string]string + Name string + Request *Value + Response *Value + func DecodeEndpoints(tags []string) []*Endpoint + type KVResult struct + Key string + Value interface{} + type Node struct + Address string + Id string + Metadata map[string]string + Port int + type Option func(*Options) + type Options struct + Address []string + Context context.Context + Secure bool + TLSConfig *tls.Config + Timeout time.Duration + type RegisterOption func(*RegisterOptions) + func RegisterTTL(t time.Duration) RegisterOption + type RegisterOptions struct + Context context.Context + TTL time.Duration + type Registry interface + BlockingQuery func(targetPointer interface{}, prefix interface{}, call func(value interface{})) + Delete func(key string) (err error) + Deregister func(*Service) error + Get func(key string) (rsp *KVResult, err error) + GetService func(string) ([]*Service, error) + Init func(...Option) error + ListServices func() ([]*Service, error) + Options func() Options + Put func(key string, value interface{}) (err error) + Register func(*Service, ...RegisterOption) error + String func() string + Watch func(...WatchOption) (Watcher, error) + type Result struct + Action string + Service *Service + type Service struct + Endpoints []*Endpoint + Metadata map[string]string + Name string + Nodes []*Node + Version string + type Value struct + Name string + Type string + Values []*Value + type WatchOption func(*WatchOptions) + func WatchService(name string) WatchOption + type WatchOptions struct + Context context.Context + Service string + type Watcher interface + Next func() (*Result, error) + Stop func()