events

Dec 5, 2020

Changes in this version

+ type Eventing struct

+ Listener chan StateVar

+ func NewEventing(wanted []string, bootID *types.BootID) (evt *Eventing, err error)

+ func (me *Eventing) AddSub(dur time.Duration, urls []*url.URL, svs []StateVar) (sid uuid.UUID)

+ func (me *Eventing) Listen(ctx context.Context)

+ func (me *Eventing) RemoveAllSubs()

+ func (me *Eventing) RemoveSub(sid uuid.UUID) (err error)

+ func (me *Eventing) RenewSub(sid uuid.UUID, dur time.Duration) (err error)

+ func (me *Eventing) Run()

+ func (me *Eventing) Stop()

type StateVar

+ ToBeEvented func() bool

+ ToBeMulticasted func() bool

Nov 12, 2020

Changes in this version

+ func ParseTimeout(t string) (dur time.Duration, err error)

+ func ParseURLs(callback string) (urls []*url.URL, err error)

+ type Multicast struct

+ Listener chan StateVar

+ func NewMulticast(wanted []string, bootID *types.BootID) (mul *Multicast, err error)

+ func (me *Multicast) Listen(ctx context.Context)

+ func (me *Multicast) Run()

+ func (me *Multicast) Stop()

+ type StateVar interface

+ DeviceUDN func() string

+ Name func() string

+ ServiceID func() string

+ ServiceType func() string

+ ServiceVersion func() string

+ String func() string

+ type Subscription struct

+ func (me Subscription) Run()

+ func (me Subscription) Stop()

+ type Subscriptions map[uuid.UUID]*Subscription

+ func NewSubscriptionMap() Subscriptions

+ func (me Subscriptions) Add(dur time.Duration, urls []*url.URL, svs []StateVar) (sid uuid.UUID)

+ func (me Subscriptions) Remove(sid uuid.UUID) (err error)

+ func (me Subscriptions) RemoveAll()

+ func (me Subscriptions) Renew(sid uuid.UUID, dur time.Duration) (err error)