stream

Documentation

Index

• type AnalyticsStream
  • func (s *AnalyticsStream) Click(click *api.Click)
  • func (s *AnalyticsStream) Close() error
  • func (s *AnalyticsStream) Deleted(linkID string)
  • func (s *AnalyticsStream) Run(events <-chan Event)
  • func (s *AnalyticsStream) Shortened(in *api.ShortURL)
  • func (s *AnalyticsStream) Subscribe() (*ensign.Subscription, error)
• type Event
• type Stream
  • func New(conf config.EnsignConfig) (_ Stream, err error)

Types

type AnalyticsStream

type AnalyticsStream struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*AnalyticsStream) Click

func (s *AnalyticsStream) Click(click *api.Click)

func (*AnalyticsStream) Close

func (s *AnalyticsStream) Close() error

func (*AnalyticsStream) Deleted

func (s *AnalyticsStream) Deleted(linkID string)

func (*AnalyticsStream) Run

func (s *AnalyticsStream) Run(events <-chan Event)

func (*AnalyticsStream) Shortened

func (s *AnalyticsStream) Shortened(in *api.ShortURL)

func (*AnalyticsStream) Subscribe

func (s *AnalyticsStream) Subscribe() (*ensign.Subscription, error)

type Event

type Event interface {
	Event() *ensign.Event
}

type Stream

type Stream interface {
	io.Closer
	Click(*api.Click)
	Shortened(*api.ShortURL)
	Deleted(linkID string)
	Subscribe() (*ensign.Subscription, error)
}

func New

func New(conf config.EnsignConfig) (_ Stream, err error)