pullrift

Documentation

Index

• Variables
• type PullRift
  • func NewPullRift(rcvURL string, confs []c.PullConf) (rift PullRift, err error)
  • func (r *PullRift) Close()
  • func (r *PullRift) RiftSize() (size int)
  • func (r *PullRift) Run()
• type PushSocket
  • func NewPushSocket(url string, sampleRate int) (push PushSocket, err error)

Variables

var InvalidSampleRateError = errors.New("Invalid sample rate, it must be between 1 and 100")

var NoValidPushers = errors.New("No valid pushers created")

Types

type PullRift

type PullRift struct {
	URL string
	// contains filtered or unexported fields
}

func NewPullRift

func NewPullRift(rcvURL string, confs []c.PullConf) (rift PullRift, err error)

Create new pull rift that sends to any number of push sockets

func (*PullRift) Close

func (r *PullRift) Close()

Close our sockets.

func (*PullRift) RiftSize

func (r *PullRift) RiftSize() (size int)

Returns the number of queues we are sending to

func (*PullRift) Run

func (r *PullRift) Run()

Main loop for pullRift.

type PushSocket

type PushSocket struct {
	URL        string
	SampleRate int
	// contains filtered or unexported fields
}

func NewPushSocket

func NewPushSocket(url string, sampleRate int) (push PushSocket, err error)