Documentation ¶
Index ¶
- Constants
- type PublisherService
- func (pubService *PublisherService) Get(name string) (chan interface{}, error)
- func (pubService *PublisherService) PublishData(data []byte, topics []string) error
- func (pubService *PublisherService) RegisterToPublish(topics []string) error
- func (pubService *PublisherService) Run(stream inet.Stream)
- func (pubService *PublisherService) Set(name string, value interface{}) error
- func (pubService *PublisherService) Start(ctx context.Context) error
- func (pubService *PublisherService) Stop() error
- func (pubService *PublisherService) UnregisterToPublish(topics []string) error
- type TopicName
Constants ¶
View Source
const ( NAME = "publisher" VERSION = 1 )
Name and Version of this service.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PublisherService ¶
type PublisherService struct { service.ApplicationContainer // contains filtered or unexported fields }
func NewPublisherService ¶
func NewPublisherService(r ra.RemoteAccess) *PublisherService
func (*PublisherService) Get ¶
func (pubService *PublisherService) Get(name string) (chan interface{}, error)
func (*PublisherService) PublishData ¶
func (pubService *PublisherService) PublishData(data []byte, topics []string) error
PublishData takes some data and publishes it to all given topics.
func (*PublisherService) RegisterToPublish ¶
func (pubService *PublisherService) RegisterToPublish(topics []string) error
RegisterToPublish helps register to multiple topics at once.
func (*PublisherService) Run ¶
func (pubService *PublisherService) Run(stream inet.Stream)
func (*PublisherService) Set ¶
func (pubService *PublisherService) Set(name string, value interface{}) error
func (*PublisherService) Start ¶
func (pubService *PublisherService) Start(ctx context.Context) error
func (*PublisherService) Stop ¶
func (pubService *PublisherService) Stop() error
func (*PublisherService) UnregisterToPublish ¶ added in v0.1.0
func (pubService *PublisherService) UnregisterToPublish(topics []string) error
Click to show internal directories.
Click to hide internal directories.