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 + func Worker(p *Pusher, input *WorkRequest, responseCh chan *WorkResponse) + type Pusher struct + func New(confCtx *config.Context, target ptypes.Transport) *Pusher + func (p *Pusher) Close() + func (p *Pusher) Run() + type StreamStatus struct + Sleep time.Duration + Stream string + type WorkRequest struct + Status *StreamStatus + SubscriptionId string + type WorkResponse struct + ActivityIntelligence []*StreamStatus + Error error + Request *WorkRequest + ShouldContinueRunning bool + Sleep time.Duration + SubscriptionId string
Go to main page