Versions in this module Expand all Collapse all v0 v0.1.0 Sep 28, 2021 Changes in this version + func GetService(s string) *server.ServiceInfo + func GetServiceKey(prefix string, s *server.ServiceInfo) string + func GetServiceValue(s *server.ServiceInfo) string + func RegisterBuilder(kind string, build Builder) + func Service(srv server.Server) server.Server + type BuildFunc func(string) (Registry, error) + type Builder func(string) Registry + type Config map[string]struct + type Configuration struct + Labels map[string]string + Routes []Route + type ConsumerConfig struct + Host string + ID string + Scheme string + type Endpoints struct + ConsumerConfigs map[string]ConsumerConfig + Nodes map[string]server.ServiceInfo + ProviderConfigs map[string]ProviderConfig + RouteConfigs map[string]RouteConfig + func (in *Endpoints) DeepCopy() *Endpoints + func (in *Endpoints) DeepCopyInfo(out *Endpoints) + type Event uint8 + const EventDelete + const EventUnknown + const EventUpdate + type EventMessage struct + Address string + Message interface{} + Name string + Scheme string + type Kind uint8 + const KindConfigurator + const KindConsumer + const KindProvider + const KindUnknown + func ToKind(kindStr string) Kind + func (kind Kind) String() string + type Local struct + func (n Local) Close() error + func (n Local) Kind() string + func (n Local) ListServices(ctx context.Context, s string, s2 string) ([]*server.ServiceInfo, error) + func (n Local) RegisterService(ctx context.Context, si *server.ServiceInfo) error + func (n Local) UnregisterService(ctx context.Context, si *server.ServiceInfo) error + func (n Local) WatchServices(ctx context.Context, s string, s2 string) (chan Endpoints, error) + type ProviderConfig struct + Deployment string + Enable bool + Host string + ID string + Metadata map[string]string + Region string + Scheme string + Zone string + type Registry interface + Kind func() string + ListServices func(context.Context, string, string) ([]*server.ServiceInfo, error) + RegisterService func(context.Context, *server.ServiceInfo) error + UnregisterService func(context.Context, *server.ServiceInfo) error + WatchServices func(context.Context, string, string) (chan Endpoints, error) + var DefaultRegisterer Registry = &Local{} + type Route struct + Deployment string + Method string + WeightGroups []WeightGroup + type RouteConfig struct + Deployment string + Host string + ID string + Scheme string + URI string + Upstream Upstream + func (config RouteConfig) String() string + type ServerInstance struct + IP string + Labels map[string]string + Port int + Scheme string + type Upstream struct + Groups map[string]int + Nodes map[string]int + type WeightGroup struct + Group string + Weight int
Go to main page