registry

type Backend ¶

type Backend struct {
	Alive bool

	ReverseProxy *httputil.ReverseProxy
	// contains filtered or unexported fields
}

type Balancer ¶

type Balancer struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type Context ¶

type Context interface {
	Context(context.Context)
}

type Dao ¶ added in v4.0.1

type Dao interface {
	Item

	Driver() string
	Dsn() string
}

Dao stores a DAO in the registry

type Edge ¶ added in v4.0.1

type Edge interface {
	Item

	Vertices() []string
}

Edge links two vertices together

type Generic ¶ added in v4.0.1

type Generic interface {
	Item

	Type() registry.ItemType
}

Generic is the simplest Item implementation

type Item ¶

type Item interface {
	Name() string
	ID() string
	Metadata() map[string]string
	As(interface{}) bool
}

Item is the main interface for registry items

type MetaSetter ¶ added in v4.0.6

type MetaSetter interface {
	SetMetadata(map[string]string)
}

type MetaWrapper ¶ added in v4.0.6

type MetaWrapper struct {
	Registry
	// contains filtered or unexported fields
}

func (m *MetaWrapper) Register(item Item, opts ...RegisterOption) error

type Node ¶

type Node interface {
	Item
	Hostname() string
	IPs() []string
	AdvertiseIP() string
}

type Option ¶

type Option func(*Options)

func WithAction(a pb.ActionType) Option

func WithContext(ctx context.Context) Option

func WithFailFast() Option

func WithFilter(f func(Item) bool) Option

func WithID(id string) Option

func WithMeta(name, value string) Option

func WithName(n string) Option

func WithType(t pb.ItemType) Option

type Options ¶

type Options struct {
	Context  context.Context
	FailFast bool
	Actions  []pb.ActionType
	IDs      []string
	Names    []string
	Types    []pb.ItemType
	Filters  []func(item Item) bool
}

func (o *Options) ActionsMatch(eventAction pb.ActionType) bool

func (o *Options) Matches(name, itemName string) bool

type RawRegistry ¶ added in v4.0.1

type RawRegistry interface {
	Start(Item) error
	Stop(Item) error
	Register(Item, ...RegisterOption) error
	Deregister(Item, ...RegisterOption) error
	Get(string, ...Option) (Item, error)
	List(...Option) ([]Item, error)
	Watch(...Option) (Watcher, error)
	NewLocker(name string) sync.Locker

	Close() error
	Done() <-chan struct{}

	As(interface{}) bool
}

type RegisterOption ¶ added in v4.0.1

type RegisterOption func(options *RegisterOptions)

func WithDeregisterFull() RegisterOption

func WithEdgeTo(id, label string, meta map[string]string) RegisterOption

func WithRegisterFailFast() RegisterOption

func WithWatch(wi StatusReporter) RegisterOption

type RegisterOptions ¶ added in v4.0.1

type RegisterOptions struct {
	Edges          []registerEdge
	Watch          interface{}
	FailFast       bool
	DeregisterFull bool
}

type Registry ¶

type Registry interface {
	RawRegistry
	RegisterEdge(item1, item2, edgeLabel string, metadata map[string]string, oo ...RegisterOption) (Edge, error)
	ListAdjacentItems(sourceItem Item, targetOptions ...Option) (items []Item)
}

func GraphRegistry(r RawRegistry) Registry

func NewMetaWrapper(reg Registry, f func(map[string]string), opts ...Option) Registry

func NewTransientWrapper(reg Registry, opts ...Option) Registry

func OpenRegistry(ctx context.Context, urlstr string) (Registry, error)

type Result ¶

type Result interface {
	Action() pb.ActionType
	Items() []Item
}

func NewResult(action pb.ActionType, items []Item) Result

type Server ¶ added in v4.0.1

type Server interface {
	Item
	Server()
}

Server represents a running server

type Service ¶

type Service interface {
	Item

	Version() string
	Tags() []string

	Start(oo ...RegisterOption) error
	Stop(oo ...RegisterOption) error

	ServerScheme() string
}

Service represents an instantiated service in the registry

type Status ¶ added in v4.0.1

type Status string

type StatusReporter ¶ added in v4.0.1

type StatusReporter interface {
	WatchStatus() (StatusWatcher, error)
}

type StatusWatcher ¶ added in v4.0.1

type StatusWatcher interface {
	Next() (Item, error)
	Stop()
}

type TransientWrapper ¶ added in v4.0.6

type TransientWrapper struct {
	Registry
	// contains filtered or unexported fields
}

func (m *TransientWrapper) Register(item Item, opts ...RegisterOption) error

type URLMux ¶

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

URLMux is a URL opener multiplexer. It matches the scheme of the URLs against a set of registered schemes and calls the opener that matches the URL's scheme. See https://gocloud.dev/concepts/urls/ for more information.

The zero value is a multiplexer with no registered schemes.

func DefaultURLMux() *URLMux

func (mux *URLMux) OpenRegistry(ctx context.Context, urlstr string) (Registry, error)

func (mux *URLMux) Register(scheme string, opener URLOpener)

func (mux *URLMux) Schemes() []string

func (mux *URLMux) ValidScheme(scheme string) bool

type URLOpener ¶

type URLOpener interface {
	OpenURL(ctx context.Context, u *url.URL) (Registry, error)
}

URLOpener represents types than can open Registries based on a URL. The opener must not modify the URL argument. OpenURL must be safe to call from multiple goroutines.

This interface is generally implemented by types in driver packages.

type Watcher ¶

type Watcher interface {
	Next() (Result, error)
	Stop()
}

func NewWatcher(id string, opts Options, res chan Result) Watcher