http

Documentation

Index

• Variables
• 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(httpPort string, adminAssetsDir string, theEngine engine.EngineI, ...) *HttpServer
  • func (self *HttpServer) Close()
  • func (self *HttpServer) EnableSsl(addr, certPath string)
  • func (self *HttpServer) ListenAndServe()
  • func (self *HttpServer) Serve(listener net.Listener)
• type NewContinuousQuery
• type NewUser
• type Point
• type SerializedSeries
• type TimePrecision
  • func TimePrecisionFromString(s string) (TimePrecision, error)
• type UpdateClusterAdminUser
• type User
• type Writer

Variables

var VALID_TABLE_NAMES *regexp.Regexp

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(httpPort string, adminAssetsDir string, theEngine engine.EngineI, theCoordinator coordinator.Coordinator, userManager coordinator.UserManager) *HttpServer

func (*HttpServer) Close

func (self *HttpServer) Close()

func (*HttpServer) EnableSsl

func (self *HttpServer) EnableSsl(addr, certPath string)

func (*HttpServer) ListenAndServe

func (self *HttpServer) ListenAndServe()

func (*HttpServer) Serve

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

type NewContinuousQuery

type NewContinuousQuery struct {
	Query string `json:"query"`
}

type NewUser

type NewUser struct {
	Name     string `json:"name"`
	Password string `json:"password"`
	IsAdmin  bool   `json:"isAdmin"`
}

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"`
	Points  [][]interface{} `json:"points"`
}

type TimePrecision

type TimePrecision int

const (
	MicrosecondPrecision TimePrecision = iota
	MillisecondPrecision
	SecondPrecision
)

func TimePrecisionFromString

func TimePrecisionFromString(s string) (TimePrecision, error)

type UpdateClusterAdminUser

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

type User

type User struct {
	Name string `json:"username"`
}

type Writer

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