registry

Documentation

Index

• func New(client *client.Http, user *authentication.User) platforms.Registry
• type Registry
  • func (registry *Registry) AddOrUpdate(group string, name string, containerAddr platforms.IContainer)
  • func (registry *Registry) BackOff(group string, name string) error
  • func (registry *Registry) BackOffReset(group string, name string)
  • func (registry *Registry) Find(prefix string, group string, name string) platforms.IContainer
  • func (registry *Registry) FindGroup(prefix string, group string) []platforms.IContainer
  • func (registry *Registry) FindLocal(group string, name string) platforms.IContainer
  • func (registry *Registry) GetIndexes(prefix string, group string, name string) ([]uint64, error)
  • func (registry *Registry) GetIndexesLocal(prefix string, group string, name string) ([]uint64, error)
  • func (registry *Registry) Name(client *client.Http, prefix string, group string, name string) (string, []uint64, error)
  • func (registry *Registry) NameReplica(group string, name string, index uint64) string
  • func (registry *Registry) Remove(prefix string, group string, name string) error
  • func (registry *Registry) Sync(group string, name string) error

Functions

func New

func New(client *client.Http, user *authentication.User) platforms.Registry

Types

type Registry

type Registry struct {
	Containers     map[string]platforms.IContainer
	ContainersLock sync.RWMutex
	BackOffTracker map[string]map[string]uint64
	Client         *client.Http
	User           *authentication.User
}

func (*Registry) AddOrUpdate

func (registry *Registry) AddOrUpdate(group string, name string, containerAddr platforms.IContainer)

func (*Registry) BackOff

func (registry *Registry) BackOff(group string, name string) error

func (*Registry) BackOffReset

func (registry *Registry) BackOffReset(group string, name string)

func (*Registry) Find

func (registry *Registry) Find(prefix string, group string, name string) platforms.IContainer

func (*Registry) FindGroup

func (registry *Registry) FindGroup(prefix string, group string) []platforms.IContainer

func (*Registry) FindLocal

func (registry *Registry) FindLocal(group string, name string) platforms.IContainer

func (*Registry) GetIndexes

func (registry *Registry) GetIndexes(prefix string, group string, name string) ([]uint64, error)

func (*Registry) GetIndexesLocal

func (registry *Registry) GetIndexesLocal(prefix string, group string, name string) ([]uint64, error)

func (*Registry) Name

func (registry *Registry) Name(client *client.Http, prefix string, group string, name string) (string, []uint64, error)

func (*Registry) NameReplica

func (registry *Registry) NameReplica(group string, name string, index uint64) string

func (*Registry) Remove

func (registry *Registry) Remove(prefix string, group string, name string) error

func (*Registry) Sync

func (registry *Registry) Sync(group string, name string) error