cluster

Documentation

Index

• Variables
• type Cluster
  • func New() *Cluster
  • func (c *Cluster) All(maxAge time.Duration) (list []Member)
  • func (c *Cluster) App(app string, maxAge time.Duration) (list []Member)
  • func (c *Cluster) Matching(id, app string, maxAge time.Duration) (list []Member)
  • func (c *Cluster) Purge(maxAge time.Duration)
  • func (c *Cluster) Update(id, app string)
• type Member

Variables

var AutoPurgeAge = 12 * time.Hour

AutoPurgeAge is the maximum age allowed for members' last update when automatically purging.

var AutoPurgeInterval = 24 * time.Hour

AutoPurgeInterval is the maximum amount of time to wait before automatically purging the cluster of stale members

Types

type Cluster

type Cluster struct {
	// contains filtered or unexported fields
}

Cluster describes the set of ari proxies in a system. The list is indexed by a hash of the asterisk ID and the ARI application and indicates the time of last contact.

func New

func New() *Cluster

New returns a new Cluster

func (*Cluster) All

func (c *Cluster) All(maxAge time.Duration) (list []Member)

All returns a list of all cluster members whose LastActive time is no older thatn the given maxAge.

func (*Cluster) App

func (c *Cluster) App(app string, maxAge time.Duration) (list []Member)

App returns a list of all cluster members for the given ARI Application whose LastActive time is no older than the given maxAge.

func (*Cluster) Matching

func (c *Cluster) Matching(id, app string, maxAge time.Duration) (list []Member)

Matching returns a list of all cluster members for whom the given proxy Metadata matches

func (*Cluster) Purge

func (c *Cluster) Purge(maxAge time.Duration)

Purge removes any proxies in the cluster which are older than the given maxAge.

func (*Cluster) Update

func (c *Cluster) Update(id, app string)

Update adds (or updates) a proxy to/in the cluster

type Member

type Member struct {
	// ID is the unique identifier for the Asterisk node
	ID string

	// App indicates the ARI application of this proxy
	App string

	// LastActive is the timestamp of the last occurrence of this node
	LastActive time.Time
}

Member describes the state of a Member of an application cluster