http

Mar 24, 2014

Changes in this version

+ type ApiUser struct

+ Name string

+ type ContinuousQuery struct

+ Id int64

+ Query string

+ type SeriesWriter struct

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

+ func (self *SeriesWriter) Close()

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

+ type UserDetail struct

+ IsAdmin bool

+ Name string

+ type UserManager interface

+ AuthenticateClusterAdmin func(username, password string) (common.User, error)

+ AuthenticateDbUser func(db, username, password string) (common.User, error)

+ ChangeClusterAdminPassword func(requester common.User, username, password string) error

+ ChangeDbUserPassword func(requester common.User, db, username, password string) error

+ CreateClusterAdminUser func(request common.User, username, password string) error

+ CreateDbUser func(request common.User, db, username, password string) error

+ DeleteClusterAdminUser func(requester common.User, username string) error

+ DeleteDbUser func(requester common.User, db, username string) error

+ GetDbUser func(requester common.User, db, username string) (common.User, error)

+ ListClusterAdmins func(requester common.User) ([]string, error)

+ ListDbUsers func(requester common.User, db string) ([]common.User, error)

+ SetDbAdmin func(requester common.User, db, username string, isAdmin bool) error

Jan 31, 2014

Changes in this version

+ var TRUE = true

Jan 30, 2014

Changes in this version

type HttpServer

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

Jan 17, 2014

Changes in this version

+ type NewContinuousQuery struct

+ Query string

type NewUser

+ IsAdmin bool

+ type UpdateClusterAdminUser struct

+ Password string

Dec 2, 2013

Changes in this version

+ var VALID_TABLE_NAMES *regexp.Regexp

Nov 14, 2013

Changes in this version

type NewUser

+ Username string

Oct 28, 2013

Changes in this version

+ type Database struct

+ Name string

+ type User struct

+ Name string

Oct 24, 2013

Changes in this version

+ 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 struct

+ type ChunkWriter struct

+ type CompressedResponseWriter struct

+ 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 struct

+ 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 struct

+ Name string

+ Password string

+ type Point struct

+ SequenceNumber uint32

+ Timestamp int64

+ Values []interface{}

+ type SerializedSeries struct

+ Columns []string

+ IntegerColumns []int

+ Name string

+ Points [][]interface{}

+ type TimePrecision int

+ const MicrosecondPrecision

+ const MillisecondPrecision

+ const SecondPrecision

+ func TimePrecisionFromString(s string) (TimePrecision, error)

+ type UpdateUser struct

+ Password string

+ type Writer interface