pusher

type Pusher struct {
	// contains filtered or unexported fields
}

type StreamStatus struct {
	Stream string
	Sleep  time.Duration
	// contains filtered or unexported fields
}

type WorkRequest struct {
	SubscriptionId string
	Status         *StreamStatus
}

type WorkResponse struct {
	Request               *WorkRequest
	Error                 error
	Sleep                 time.Duration
	ShouldContinueRunning bool

	// if this is subscription stream, intelligence about
	// where the Target stands on subscribed streams that
	// had activity
	ActivityIntelligence []*StreamStatus

	SubscriptionId string
}