Versions in this module Expand all Collapse all v0 v0.2.0 Mar 31, 2017 v0.1.0 Mar 29, 2017 Changes in this version + const ChildStreamCreatedId + const CreatedId + const RotatedId + const SubscribedId + const SubscriptionActivityId + const UnsubscribedId + func EncodeRegularLine(input string) string + func Parse(line string) (metaType string, lineContent string, metaEvent interface{}) + type ChildStreamCreated struct + ChildStream string + Timestamp string + func NewChildStreamCreated(childStream string) *ChildStreamCreated + func (c *ChildStreamCreated) Serialize() string + type Created struct + SubscriptionIds []string + Timestamp string + func NewCreated(subscriptionIds []string) *Created + func (c *Created) Serialize() string + type Rotated struct + Next string + Timestamp string + func NewRotated(next string) *Rotated + func (r *Rotated) Serialize() string + type Subscribed struct + SubscriptionId string + Timestamp string + func NewSubscribed(subscriptionId string) *Subscribed + func (s *Subscribed) Serialize() string + type SubscriptionActivity struct + Activity []string + Timestamp string + func NewSubscriptionActivity() *SubscriptionActivity + func (c *SubscriptionActivity) Serialize() string + type Unsubscribed struct + SubscriptionId string + Timestamp string + func NewUnsubscribed(subscriptionId string) *Unsubscribed + func (u *Unsubscribed) Serialize() string
Go to main page