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
• func TimePrecisionFromString(s string) (TimePrecision, error)
• type AllPointsWriter
• type ApiUser
• 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 ContinuousQuery
• type HttpServer
  • func NewHttpServer(httpPort string, adminAssetsDir string, theCoordinator coordinator.Coordinator, ...) *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 SeriesWriter
  • func NewSeriesWriter(yield func(*protocol.Series) error) *SeriesWriter
  • func (self *SeriesWriter) Close()
  • func (self *SeriesWriter) Write(series *protocol.Series) error
• type UpdateClusterAdminUser
• type UserDetail
• 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

func TimePrecisionFromString

func TimePrecisionFromString(s string) (TimePrecision, error)

Types

type AllPointsWriter

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

type ApiUser

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

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 ContinuousQuery

type ContinuousQuery struct {
	Id    int64  `json:"id"`
	Query string `json:"query"`
}

type HttpServer

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

func NewHttpServer

func NewHttpServer(httpPort string, adminAssetsDir string, theCoordinator coordinator.Coordinator, userManager coordinator.UserManager, clusterConfig *cluster.ClusterConfiguration, raftServer *coordinator.RaftServer) *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 SeriesWriter

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

func NewSeriesWriter

func NewSeriesWriter(yield func(*protocol.Series) error) *SeriesWriter

func (*SeriesWriter) Close

func (self *SeriesWriter) Close()

func (*SeriesWriter) Write

func (self *SeriesWriter) Write(series *protocol.Series) error

type UpdateClusterAdminUser

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

type UserDetail

type UserDetail struct {
	Name    string `json:"name"`
	IsAdmin bool   `json:"isAdmin"`
}

type Writer

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