doppler_endpoint

package
v73.0.1+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 4, 2017 License: Apache-2.0, BSD-3-Clause, MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source
const HttpRequestTimeout = 5 * time.Second

Variables

View Source
var WebsocketKeepAliveDuration = 30 * time.Second

Functions

func ContainerMetricHandlerProvider

func ContainerMetricHandlerProvider(messages <-chan []byte) http.Handler

func DeDupe

func DeDupe(input <-chan []byte) <-chan []byte

func HttpHandlerProvider

func HttpHandlerProvider(messages <-chan []byte) http.Handler

func WebsocketHandlerProvider

func WebsocketHandlerProvider(messages <-chan []byte) http.Handler

Types

type DopplerEndpoint

type DopplerEndpoint struct {
	Endpoint  string
	StreamId  string
	Reconnect bool
	Timeout   time.Duration
	HProvider HandlerProvider
}

func NewDopplerEndpoint

func NewDopplerEndpoint(endpoint string,
	streamId string,
	reconnect bool) DopplerEndpoint

func (*DopplerEndpoint) GetPath

func (endpoint *DopplerEndpoint) GetPath() string

type HandlerProvider

type HandlerProvider func(<-chan []byte) http.Handler

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL