subscriber

Documentation

Index

• Constants
• type SubscriberService
  • func NewSubscriberService(r bc.RemoteAccess) *SubscriberService
  • func (subService *SubscriberService) Get(name string) (chan interface{}, error)
  • func (subService *SubscriberService) Run(stream inet.Stream)
  • func (subService *SubscriberService) Set(name string, value interface{}) error
  • func (subService *SubscriberService) Start(ctx context.Context) error
  • func (subService *SubscriberService) Stop() error
  • func (subService *SubscriberService) SubscribeToTopics(topics []string) (chan *pubsub.Message, error)
  • func (subService *SubscriberService) UnsubscribeToTopics(topics []string) error
• type TopicWrapper

Constants

const (
	NAME    = "subscriber"
	VERSION = 1
)

Name and Version of this service.

Types

type SubscriberService

type SubscriberService struct {
	service.ApplicationContainer
	// contains filtered or unexported fields
}

func NewSubscriberService

func NewSubscriberService(r bc.RemoteAccess) *SubscriberService

func (*SubscriberService) Get

func (subService *SubscriberService) Get(name string) (chan interface{}, error)

func (*SubscriberService) Run

func (subService *SubscriberService) Run(stream inet.Stream)

func (*SubscriberService) Set

func (subService *SubscriberService) Set(name string, value interface{}) error

func (*SubscriberService) Start

func (subService *SubscriberService) Start(ctx context.Context) error

func (*SubscriberService) Stop

func (subService *SubscriberService) Stop() error

func (*SubscriberService) SubscribeToTopics

func (subService *SubscriberService) SubscribeToTopics(topics []string) (chan *pubsub.Message, error)

SubscribeToTopics subscribes to multiple topics and outputs all into a single chan.

func (*SubscriberService) UnsubscribeToTopics

func (subService *SubscriberService) UnsubscribeToTopics(topics []string) error

UnsubscribeToTopics will unregister from the remote access and close the subscription channel

type TopicWrapper

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