http

Documentation

Index

• func CompressionHandler(enableCompression bool, handler libhttp.HandlerFunc) libhttp.HandlerFunc
• func CorsAndCompressionHeaderHandler(handler libhttp.HandlerFunc) libhttp.HandlerFunc
• func CorsHeaderHandler(handler libhttp.HandlerFunc) libhttp.HandlerFunc
• type AllPointsWriter
• type ChunkWriter
• type CompressedResponseWriter
  • func NewCompressionResponseWriter(useCompression bool, rw libhttp.ResponseWriter, req *libhttp.Request) *CompressedResponseWriter
  • func (self *CompressedResponseWriter) Header() libhttp.Header
  • func (self *CompressedResponseWriter) Write(bs []byte) (int, error)
  • func (self *CompressedResponseWriter) WriteHeader(responseCode int)
• type HttpServer
  • func NewHttpServer(httpAddr string, theEngine engine.EngineI, ...) *HttpServer
  • func (self *HttpServer) Close()
  • func (self *HttpServer) ListenAndServe()
  • func (self *HttpServer) Serve(listener net.Listener)
• type NewUser
• type Point
• type SerializedSeries
• type TimePrecision
  • func TimePrecisionFromString(s string) (TimePrecision, error)
• type UpdateUser
• type Writer

Functions

func CompressionHandler

func CompressionHandler(enableCompression bool, handler libhttp.HandlerFunc) libhttp.HandlerFunc

func CorsAndCompressionHeaderHandler

func CorsAndCompressionHeaderHandler(handler libhttp.HandlerFunc) libhttp.HandlerFunc

func CorsHeaderHandler

func CorsHeaderHandler(handler libhttp.HandlerFunc) libhttp.HandlerFunc

Types

type AllPointsWriter

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

type ChunkWriter

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

type CompressedResponseWriter

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

func NewCompressionResponseWriter

func NewCompressionResponseWriter(useCompression bool, rw libhttp.ResponseWriter, req *libhttp.Request) *CompressedResponseWriter

func (*CompressedResponseWriter) Header

func (self *CompressedResponseWriter) Header() libhttp.Header

func (*CompressedResponseWriter) Write

func (self *CompressedResponseWriter) Write(bs []byte) (int, error)

func (*CompressedResponseWriter) WriteHeader

func (self *CompressedResponseWriter) WriteHeader(responseCode int)

type HttpServer

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

func NewHttpServer

func NewHttpServer(httpAddr string, theEngine engine.EngineI, theCoordinator coordinator.Coordinator, userManager coordinator.UserManager) *HttpServer

func (*HttpServer) Close

func (self *HttpServer) Close()

func (*HttpServer) ListenAndServe

func (self *HttpServer) ListenAndServe()

func (*HttpServer) Serve

func (self *HttpServer) Serve(listener net.Listener)

type NewUser

type NewUser struct {
	Name     string `json:"username"`
	Password string `json:"password"`
}

type Point

type Point struct {
	Timestamp      int64         `json:"timestamp"`
	SequenceNumber uint32        `json:"sequenceNumber"`
	Values         []interface{} `json:"values"`
}

type SerializedSeries

type SerializedSeries struct {
	Name           string          `json:"name"`
	Columns        []string        `json:"columns"`
	IntegerColumns []int           `json:"integer_columns,omitempty"`
	Points         [][]interface{} `json:"points"`
}

type TimePrecision

type TimePrecision int

const (
	MicrosecondPrecision TimePrecision = iota
	MillisecondPrecision
	SecondPrecision
)

func TimePrecisionFromString

func TimePrecisionFromString(s string) (TimePrecision, error)

type UpdateUser

type UpdateUser struct {
	Password string `json:"password"`
}

type Writer

type Writer interface {
	// contains filtered or unexported methods
}