doppler_endpoint

Documentation

Index

• Constants
• Variables
• func ContainerMetricHandlerProvider(messages <-chan []byte) http.Handler
• func DeDupe(input <-chan []byte) <-chan []byte
• func HttpHandlerProvider(messages <-chan []byte) http.Handler
• func WebsocketHandlerProvider(messages <-chan []byte) http.Handler
• type DopplerEndpoint
  • func NewDopplerEndpoint(endpoint string, streamId string, reconnect bool) DopplerEndpoint
  • func (endpoint *DopplerEndpoint) GetPath() string
• type HandlerProvider

Constants

const HttpRequestTimeout = 5 * time.Second

Variables

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