registry

Documentation

Index

• type Registry
  • func (registry *Registry) AddOrUpdate(group string, name string, containerAddr platforms.IContainer)
  • func (registry *Registry) All() map[string]map[string]platforms.IContainer
  • func (registry *Registry) BackOffReset(group string, name string)
  • func (registry *Registry) BackOffTracking(group string, name string)
  • func (registry *Registry) Find(group string, name string) platforms.IContainer
  • func (registry *Registry) FindGroup(group string) map[string]platforms.IContainer
  • func (registry *Registry) FindLocal(group string, name string) platforms.IContainer
  • func (registry *Registry) GetIndexes(group string, name string) []uint64
  • func (registry *Registry) ListenChanges()
  • func (registry *Registry) Name(client *client.Http, group string, name string) (string, []uint64)
  • func (registry *Registry) NameReplicas(group string, name string, index uint64) (string, uint64)
  • func (registry *Registry) Remove(group string, name string) bool
  • func (registry *Registry) Sync(container distributed.Container)

Types

type Registry

type Registry struct {
	Containers     map[string]map[string]platforms.IContainer
	ContainersLock sync.RWMutex
	Indexes        map[string][]uint64
	BackOffTracker map[string]map[string]uint64
	Object         map[string]objects.Object
	ChangeC        chan distributed.Container
	Client         *client.Http
	User           *authentication.User
}

func (*Registry) AddOrUpdate

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

func (*Registry) All

func (registry *Registry) All() map[string]map[string]platforms.IContainer

func (*Registry) BackOffReset

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

func (*Registry) BackOffTracking

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

func (*Registry) Find

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

func (*Registry) FindGroup

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

func (*Registry) FindLocal

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

func (*Registry) GetIndexes

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

func (*Registry) ListenChanges

func (registry *Registry) ListenChanges()

func (*Registry) Name

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

func (*Registry) NameReplicas

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

func (*Registry) Remove

func (registry *Registry) Remove(group string, name string) bool

func (*Registry) Sync

func (registry *Registry) Sync(container distributed.Container)