reg

Documentation

Overview

package reg

Index

• Variables
• func Free(instanceId string)
• func InitRegistry()
• func InstanceSetSnapshot() map[string]*common.Instance
• func Put(ins *common.Instance) error
• func Remove(ins *common.Instance)

Variables

var (
	ExpirationTime = time.Second * 30 // 30s
)

Functions

func Free

func Free(instanceId string)

Free sets registered instance state to FREE so it can be detected by timer expiration job.

func InitRegistry

func InitRegistry()

InitRegistry starts a timer job for instance expiration detection in a single goroutine.

func InstanceSetSnapshot

func InstanceSetSnapshot() map[string]*common.Instance

InstanceSetSnapshot takes a snapshot for current instances.

func Put

func Put(ins *common.Instance) error

Put registers a new Instance.

It returns an error if the new Instance is conflict with the registered Instance,

func Remove

func Remove(ins *common.Instance)

Remove indicates this client deregister from Registry immediately.