server

Documentation

Index

• func NewRouter(producer *kafka.DefaultProducer, auth string, allowedIPs *zbxnet.AllowedPeers) http.Handler
• func Run(server *http.Server, cert, key string, tls bool, errors chan<- error)
• func ServerInit(port string, router http.Handler, timeout int) *http.Server
• type BufferedResponseWriter
  • func (b *BufferedResponseWriter) Header() http.Header
  • func (b *BufferedResponseWriter) Write(data []byte) (int, error)
  • func (b *BufferedResponseWriter) WriteHeader(code int)
  • func (b *BufferedResponseWriter) WriteResponse()

Functions

func NewRouter

func NewRouter(producer *kafka.DefaultProducer, auth string, allowedIPs *zbxnet.AllowedPeers) http.Handler

NewRouter creates a mux http handler with all the routing handled.

func Run

func Run(server *http.Server, cert, key string, tls bool, errors chan<- error)

Run starts the server.

func ServerInit

func ServerInit(port string, router http.Handler, timeout int) *http.Server

ServerInit initializes a http server with provided parameters.

Types

type BufferedResponseWriter

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

BufferedResponseWriter response writer for http handler.

func (*BufferedResponseWriter) Header

func (b *BufferedResponseWriter) Header() http.Header

Header returns set headers.

func (*BufferedResponseWriter) Write

func (b *BufferedResponseWriter) Write(data []byte) (int, error)

Write writes data into buffer.

func (*BufferedResponseWriter) WriteHeader

func (b *BufferedResponseWriter) WriteHeader(code int)

WriteHeader sets code for response.

func (*BufferedResponseWriter) WriteResponse

func (b *BufferedResponseWriter) WriteResponse()

WriteResponse writes response as a json encoded text.