Documentation
¶
Index ¶
Constants ¶
View Source
const ( ChannelPrefix = "rumors.event." ChannelArticles = ChannelPrefix + "articles" ChannelTg = ChannelPrefix + "telegram" OpMarshal = "pubsub: marshal" OpPublish = "pubsub: publish" OpClose = "pubsub: close" )
Variables ¶
This section is empty.
Functions ¶
func PublisherActivator ¶
func SubscriberActivator ¶
Types ¶
type Article ¶
type Article struct {
ID uuid.UUID `json:"id,omitempty"`
SiteID uuid.UUID `json:"site_id,omitempty"`
Lang string `json:"lang,omitempty"`
Title string `json:"title,omitempty"`
ShortDesc string `json:"short_desc,omitempty"`
Link string `json:"link,omitempty"`
Image string `json:"image,omitempty"`
PubDate time.Time `json:"pub_date,omitempty"`
PubDiff string `json:"pub_diff,omitempty"`
Categories []string `json:"categories,omitempty"`
}
func FromEntity ¶
type Publisher ¶
type Publisher struct {
// contains filtered or unexported fields
}
func NewPublisher ¶
func NewPublisher(rdbMaker *rdb.UniversalClientMaker) *Publisher
type Subscriber ¶
type Subscriber struct {
// contains filtered or unexported fields
}
func NewSubscriber ¶
func NewSubscriber(rdbMaker *rdb.UniversalClientMaker) *Subscriber
func (*Subscriber) Close ¶
func (s *Subscriber) Close() (err error)
Click to show internal directories.
Click to hide internal directories.