Documentation
¶
Index ¶
- Variables
- func WaitForEvent(ns string, eventName string) error
- type Event
- type VirtualNotify
- func (p *VirtualNotify) Cleanup()
- func (p *VirtualNotify) Close()
- func (p *VirtualNotify) EventsChan() <-chan Event
- func (p *VirtualNotify) Next() (Event, error)
- func (p *VirtualNotify) Publish(eventName string) error
- func (p *VirtualNotify) PublishTimeout(eventName string, timeout time.Duration) error
- func (p *VirtualNotify) Run(interval time.Duration)
- func (p *VirtualNotify) Subscribe(eventName string) error
- func (p *VirtualNotify) Unsubscribe(eventName string)
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrClosed = os.ErrClosed
View Source
var ErrTimeout = fmt.Errorf("timeout")
View Source
var TempDir = os.TempDir()
Functions ¶
func WaitForEvent ¶
Types ¶
type VirtualNotify ¶
type VirtualNotify struct {
// contains filtered or unexported fields
}
func New ¶
func New(ns string) *VirtualNotify
func (*VirtualNotify) Cleanup ¶
func (p *VirtualNotify) Cleanup()
func (*VirtualNotify) Close ¶
func (p *VirtualNotify) Close()
func (*VirtualNotify) EventsChan ¶
func (p *VirtualNotify) EventsChan() <-chan Event
func (*VirtualNotify) Next ¶
func (p *VirtualNotify) Next() (Event, error)
func (*VirtualNotify) Publish ¶
func (p *VirtualNotify) Publish(eventName string) error
func (*VirtualNotify) PublishTimeout ¶
func (p *VirtualNotify) PublishTimeout(eventName string, timeout time.Duration) error
func (*VirtualNotify) Run ¶
func (p *VirtualNotify) Run(interval time.Duration)
func (*VirtualNotify) Subscribe ¶
func (p *VirtualNotify) Subscribe(eventName string) error
func (*VirtualNotify) Unsubscribe ¶
func (p *VirtualNotify) Unsubscribe(eventName string)
Click to show internal directories.
Click to hide internal directories.