subscriber_manager

Documentation

Index

• type Options
  • func NewOptions() *Options
• type Subscriber
• type SubscriberManager
  • func NewSubscriberManager(options *Options) *SubscriberManager
  • func NewSubscriberManagerWithClient(client *core.Client, options *Options) *SubscriberManager
  • func (sm *SubscriberManager) Connect(host string, options *core.Options) error
  • func (sm *SubscriberManager) Disconnect()
  • func (sm *SubscriberManager) GetSubscribers() ([]*Subscriber, error)
  • func (sm *SubscriberManager) SubscribeToCollections(subscriberID string, collections []string) error

Types

type Options

type Options struct {
	Verbose bool
}

func NewOptions

func NewOptions() *Options

type Subscriber

type Subscriber struct {
	ID        string
	Name      string
	Component string
	Type      subscriber_manager_pb.SubscriberType
	LastCheck time.Time
}

type SubscriberManager

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

func NewSubscriberManager

func NewSubscriberManager(options *Options) *SubscriberManager

func NewSubscriberManagerWithClient

func NewSubscriberManagerWithClient(client *core.Client, options *Options) *SubscriberManager

func (*SubscriberManager) Connect

func (sm *SubscriberManager) Connect(host string, options *core.Options) error

func (*SubscriberManager) Disconnect

func (sm *SubscriberManager) Disconnect()

func (*SubscriberManager) GetSubscribers

func (sm *SubscriberManager) GetSubscribers() ([]*Subscriber, error)

func (*SubscriberManager) SubscribeToCollections

func (sm *SubscriberManager) SubscribeToCollections(subscriberID string, collections []string) error