Documentation
¶
Index ¶
- type Registry
- func (registry *Registry) AddOrUpdate(group string, name string, containerAddr platforms.IContainer)
- func (registry *Registry) BackOffReset(group string, name string)
- func (registry *Registry) BackOffTracking(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(group string, name string) []uint64
- func (registry *Registry) Name(client *client.Http, group string, name string) (string, []uint64)
- 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(container platforms.IContainer) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
Client *client.Http
User *authentication.User
}
func (*Registry) AddOrUpdate ¶
func (registry *Registry) AddOrUpdate(group string, name string, containerAddr platforms.IContainer)
func (*Registry) BackOffReset ¶
func (*Registry) BackOffTracking ¶
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) NameReplica ¶
Source Files
Click to show internal directories.
Click to hide internal directories.