submanager

Documentation

Index

• Variables
• type Subscription
  • func (s *Subscription) Read() (nut17.WsNotification, error)
  • func (s *Subscription) SubId() string
• type SubscriptionManager
  • func NewSubscriptionManager(mint string) (*SubscriptionManager, error)
  • func (sm *SubscriptionManager) Close() error
  • func (sm *SubscriptionManager) CloseSubscripton(subId string) error
  • func (sm *SubscriptionManager) IsSubscriptionKindSupported(kind nut17.SubscriptionKind) bool
  • func (sm *SubscriptionManager) Run(errChan chan<- error)
  • func (sm *SubscriptionManager) Subscribe(kind nut17.SubscriptionKind, filters []string) (*Subscription, error)

Variables

var (
	ErrNUT17NotSupported = errors.New("NUT-17 Not supported")
)

Types

type Subscription

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

func (*Subscription) Read

func (s *Subscription) Read() (nut17.WsNotification, error)

func (*Subscription) SubId

func (s *Subscription) SubId() string

type SubscriptionManager

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

func NewSubscriptionManager

func NewSubscriptionManager(mint string) (*SubscriptionManager, error)

func (*SubscriptionManager) Close

func (sm *SubscriptionManager) Close() error

func (*SubscriptionManager) CloseSubscripton

func (sm *SubscriptionManager) CloseSubscripton(subId string) error

func (*SubscriptionManager) IsSubscriptionKindSupported

func (sm *SubscriptionManager) IsSubscriptionKindSupported(kind nut17.SubscriptionKind) bool

func (*SubscriptionManager) Run

func (sm *SubscriptionManager) Run(errChan chan<- error)

Run should be called in a separate goroutine to run in the background. It will be stopped when Close is called on the SubscriptionManager

func (*SubscriptionManager) Subscribe

func (sm *SubscriptionManager) Subscribe(kind nut17.SubscriptionKind, filters []string) (*Subscription, error)