watchers

Documentation

Index

• type PublicPathsWatcher
  • func NewPublicPathsWatcher(client *etcd.Client) *PublicPathsWatcher
  • func (p PublicPathsWatcher) GetPublicPaths() []string
  • func (p *PublicPathsWatcher) Init() error
  • func (p *PublicPathsWatcher) Watch()

Types

type PublicPathsWatcher

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

TODO This implementation does not following micro-services design pattern. Might be better to use event-driven paradigm: TODO i.e. pion-manager publishes event upon adding/removing paths, pion-proxy subscribes event to update changes PublicPaths object is used to get latest list of public paths in the Etcd by monitoring changes of the given Etcd key.

func NewPublicPathsWatcher

func NewPublicPathsWatcher(client *etcd.Client) *PublicPathsWatcher

func (PublicPathsWatcher) GetPublicPaths

func (p PublicPathsWatcher) GetPublicPaths() []string

func (*PublicPathsWatcher) Init

func (p *PublicPathsWatcher) Init() error

func (*PublicPathsWatcher) Watch

func (p *PublicPathsWatcher) Watch()

Watch monitors latest changes in the list of public paths