pusher

Documentation

Index

• func Worker(p *Pusher, input *WorkRequest, responseCh chan *WorkResponse)
• type Pusher
  • func New(confCtx *config.Context, target ptypes.Transport) *Pusher
  • func (p *Pusher) Close()
  • func (p *Pusher) Run()
• type StreamStatus
• type WorkRequest
• type WorkResponse

Functions

func Worker

func Worker(p *Pusher, input *WorkRequest, responseCh chan *WorkResponse)

this is thread safe as long as it doesn't mutate anything from input structs

Types

type Pusher

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

func New

func New(confCtx *config.Context, target ptypes.Transport) *Pusher

func (*Pusher) Close

func (p *Pusher) Close()

func (*Pusher) Run

func (p *Pusher) Run()

type StreamStatus

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

type WorkRequest

type WorkRequest struct {
	SubscriptionId string
	Status         *StreamStatus
}

type WorkResponse

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
}