http_polling

Documentation

Index

• Variables
• func SetInputIntervalMillis(input []byte, interval int64) []byte
• func SetRequestInput(input, requestInput []byte) []byte
• func SetSkipPublishSameResponse(input []byte, skip bool) []byte
• type HttpPollingStream
  • func New(client httpclient.Client) *HttpPollingStream
  • func (h *HttpPollingStream) Start(input []byte, next chan<- []byte, stop <-chan struct{})
  • func (h *HttpPollingStream) UniqueIdentifier() []byte

Variables

var (
	HttpPolling = []byte("http_polling_stream")
)

Functions

func SetInputIntervalMillis

func SetInputIntervalMillis(input []byte, interval int64) []byte

func SetRequestInput

func SetRequestInput(input, requestInput []byte) []byte

func SetSkipPublishSameResponse

func SetSkipPublishSameResponse(input []byte, skip bool) []byte

Types

type HttpPollingStream

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

func New

func New(client httpclient.Client) *HttpPollingStream

func (*HttpPollingStream) Start

func (h *HttpPollingStream) Start(input []byte, next chan<- []byte, stop <-chan struct{})

func (*HttpPollingStream) UniqueIdentifier

func (h *HttpPollingStream) UniqueIdentifier() []byte