broker

Documentation

Index

• type BaseSubscription
  • func (baseSubscription BaseSubscription) GetTopicEventChan() chan TopicEvent
  • func (baseSubscription BaseSubscription) GetTopics() []string
• type ISubscription
• type TopicEvent

Types

type BaseSubscription

type BaseSubscription struct {
	TopicEventChan chan TopicEvent
	Topics         []string
}

BaseSubscription ...

func (BaseSubscription) GetTopicEventChan

func (baseSubscription BaseSubscription) GetTopicEventChan() chan TopicEvent

GetTopicEventChan returns topic with event channel

func (BaseSubscription) GetTopics

func (baseSubscription BaseSubscription) GetTopics() []string

GetTopics returns topics for pubsub or streams

type ISubscription

type ISubscription interface {
	GetTopicEventChan() chan TopicEvent
	GetTopics() []string
}

ISubscription is an interface for pubsub and stream subscriptions

type TopicEvent

type TopicEvent struct {
	Event []byte
	Topic string
}

TopicEvent ...