websocketserver

Documentation

Index

• type Batcher
• type WebsocketServer
  • func New(apiEndpoint string, sinkManager *sinkmanager.SinkManager, ...) (*WebsocketServer, error)
  • func (w *WebsocketServer) ServeHTTP(writer http.ResponseWriter, request *http.Request)
  • func (w *WebsocketServer) Start()
  • func (w *WebsocketServer) Stop()

Types

type Batcher

type Batcher interface {
	BatchIncrementCounter(name string)
	BatchCounter(name string) metricbatcher.BatchCounterChainer
}

type WebsocketServer

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

func New

func New(apiEndpoint string, sinkManager *sinkmanager.SinkManager, writeTimeout time.Duration, keepAliveInterval time.Duration, messageDrainBufferSize uint, dropsondeOrigin string, batcher Batcher) (*WebsocketServer, error)

func (*WebsocketServer) ServeHTTP

func (w *WebsocketServer) ServeHTTP(writer http.ResponseWriter, request *http.Request)

func (*WebsocketServer) Start

func (w *WebsocketServer) Start()

func (*WebsocketServer) Stop

func (w *WebsocketServer) Stop()