Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

servregistry

package

Go to main page

Versions in this module

v0

v0.7.0

Dec 1, 2021

v0.6.0

Sep 29, 2021

v0.5.1

Sep 2, 2021

v0.5.0

Aug 10, 2021

v0.4.0

Jun 28, 2021

Changes in this version

+ type MetadataPair struct

+ Key string

+ Value string

v0.3.0

Mar 24, 2021

v0.2.1

Jan 25, 2021

Changes in this version

+ var ErrAlreadyExists error = errors.New("resource already exists")

+ var ErrEndpNameNotProvided error = errors.New("endpoint name not provided")

+ var ErrEndpNotOwnedByOp error = errors.New("endpoint is not owned by the cnwan operator")

+ var ErrEndpNotProvided error = errors.New("endpoint is empty")

+ var ErrNoEndpoints error = errors.New("service has no endpoints")

+ var ErrNotFound error = errors.New("resource not found")

+ var ErrNsNameNotProvided error = errors.New("namespace name is empty")

+ var ErrNsNotEmpty error = errors.New("namespace is not empty")

+ var ErrNsNotOwnedByOp error = errors.New("namespace is not owned by the cnwan operator")

+ var ErrNsNotOwnedServs error = errors.New("namespace contains services not owned by the operator")

+ var ErrNsNotProvided error = errors.New("namespace is empty")

+ var ErrServNameNotProvided error = errors.New("service name is empty")

+ var ErrServNoMetadata error = errors.New("service has no metadata")

+ var ErrServNotEmpty error = errors.New("service is not empty")

+ var ErrServNotOwnedByOp error = errors.New("service is not owned by the cnwan operator")

+ var ErrServNotOwnedEndps error = errors.New("service contains endpoints not owned by the operator")

+ var ErrServNotProvided error = errors.New("service is empty")

+ var ErrServRegNotProvided error = errors.New("no service registry is provided")

+ var ErrTimeOutExpired error = errors.New("timeout expired while waiting for service registry to reply")

+ type Broker struct

+ Reg ServiceRegistry

+ func NewBroker(reg ServiceRegistry, opKey, opVal string) (*Broker, error)

+ func (b *Broker) ManageNs(nsData *Namespace) (regNs *Namespace, err error)

+ func (b *Broker) ManageServ(servData *Service) (regServ *Service, err error)

+ func (b *Broker) ManageServEndps(nsName, servName string, endpsData []*Endpoint) (endpErrs map[string]error, err error)

+ func (b *Broker) RemoveNs(nsName string, forceNotEmpty bool) (err error)

+ func (b *Broker) RemoveServ(nsName, servName string, forceNotEmpty bool) (err error)

+ type Endpoint struct

+ Address string

+ Metadata map[string]string

+ Name string

+ NsName string

+ Port int32

+ ServName string

+ type Namespace struct

+ Metadata map[string]string

+ Name string

+ type Service struct

+ Metadata map[string]string

+ Name string

+ NsName string

+ type ServiceRegistry interface

+ CreateEndp func(endp *Endpoint) (*Endpoint, error)

+ CreateNs func(ns *Namespace) (*Namespace, error)

+ CreateServ func(serv *Service) (*Service, error)

+ DeleteEndp func(nsName, servName, endpName string) error

+ DeleteNs func(name string) error

+ DeleteServ func(nsName, servName string) error

+ ExtractData func(ns *corev1.Namespace, serv *corev1.Service) (*Namespace, *Service, []*Endpoint, error)

+ GetEndp func(nsName, servName, endpName string) (*Endpoint, error)

+ GetNs func(name string) (*Namespace, error)

+ GetServ func(nsName, servName string) (*Service, error)

+ ListEndp func(nsName, servName string) ([]*Endpoint, error)

+ ListNs func() ([]*Namespace, error)

+ ListServ func(nsName string) ([]*Service, error)

+ UpdateEndp func(endp *Endpoint) (*Endpoint, error)

+ UpdateNs func(ns *Namespace) (*Namespace, error)

+ UpdateServ func(serv *Service) (*Service, error)