http

package
v0.5.0-rc.4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 7, 2014 License: MIT Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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 added in v0.5.0

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 added in v0.5.0

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 added in v0.4.1

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 added in v0.4.0

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 added in v0.5.0

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

func NewSeriesWriter added in v0.5.0

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

func (*SeriesWriter) Close added in v0.5.0

func (self *SeriesWriter) Close()

func (*SeriesWriter) Write added in v0.5.0

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

type UpdateClusterAdminUser added in v0.4.0

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

type UserDetail added in v0.5.0

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

type Writer

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL