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) GetEndpoint() (*core.Endpoint, error)
  • func (sm *SubscriberManager) GetSubscribers() ([]*Subscriber, error)
  • func (sm *SubscriberManager) SubscribeToCollections(subscriberID string, collections []string) error
  • func (sm *SubscriberManager) UpdateSubscriberPipelines(subscriberID string, pipelines []uint64) error

Types

type Options

type Options struct {
	Endpoint string
	Domain   string
	Key      *keyring.KeyInfo
	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
	AppID       string
	AccessKey   string
	Permissions []string
	Collections []string
	Pipelines   []uint64
}

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) GetEndpoint

func (sm *SubscriberManager) GetEndpoint() (*core.Endpoint, error)

func (*SubscriberManager) GetSubscribers

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

func (*SubscriberManager) SubscribeToCollections

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

func (*SubscriberManager) UpdateSubscriberPipelines

func (sm *SubscriberManager) UpdateSubscriberPipelines(subscriberID string, pipelines []uint64) error