Versions in this module Expand all Collapse all v1 v1.7.9 Oct 27, 2019 Changes in this version + var LosAngeles = mustParseLocation("America/Los_Angeles") + func MustReadAll(r io.Reader) []byte + func NewRetentionPolicySpec(name string, rf int, duration time.Duration) *meta.RetentionPolicySpec + func RemoteEnabled() bool + type Config struct + func NewConfig() *Config + type LocalServer struct + Config *Config + func (s *LocalServer) Close() + func (s *LocalServer) Closed() bool + func (s *LocalServer) CreateDatabase(db string) (*meta.DatabaseInfo, error) + func (s *LocalServer) CreateDatabaseAndRetentionPolicy(db string, rp *meta.RetentionPolicySpec, makeDefault bool) error + func (s *LocalServer) CreateSubscription(database, rp, name, mode string, destinations []string) error + func (s *LocalServer) DropDatabase(db string) error + func (s *LocalServer) Open() error + func (s *LocalServer) Reset() error + func (s *LocalServer) URL() string + func (s *LocalServer) WritePoints(database, retentionPolicy string, consistencyLevel models.ConsistencyLevel, ...) error + func (s LocalServer) HTTPGet(url string) (results string, err error) + func (s LocalServer) HTTPPost(url string, content []byte) (results string, err error) + func (s LocalServer) MustQuery(query string) string + func (s LocalServer) MustQueryWithParams(query string, values url.Values) string + func (s LocalServer) MustWrite(db, rp, body string, params url.Values) string + func (s LocalServer) Query(query string) (results string, err error) + func (s LocalServer) QueryWithParams(query string, values url.Values) (results string, err error) + func (s LocalServer) Write(db, rp, body string, params url.Values) (results string, err error) + type Query struct + func (q *Query) Error(err error) string + func (q *Query) Execute(s Server) (err error) + type RemoteServer struct + func (s *RemoteServer) Close() + func (s *RemoteServer) Closed() bool + func (s *RemoteServer) CreateDatabase(db string) (*meta.DatabaseInfo, error) + func (s *RemoteServer) CreateDatabaseAndRetentionPolicy(db string, rp *meta.RetentionPolicySpec, makeDefault bool) error + func (s *RemoteServer) CreateSubscription(database, rp, name, mode string, destinations []string) error + func (s *RemoteServer) DropDatabase(db string) error + func (s *RemoteServer) Open() error + func (s *RemoteServer) Reset() error + func (s *RemoteServer) SetLogOutput(w io.Writer) + func (s *RemoteServer) URL() string + func (s *RemoteServer) WritePoints(database, retentionPolicy string, consistencyLevel models.ConsistencyLevel, ...) error + func (s RemoteServer) HTTPGet(url string) (results string, err error) + func (s RemoteServer) HTTPPost(url string, content []byte) (results string, err error) + func (s RemoteServer) MustQuery(query string) string + func (s RemoteServer) MustQueryWithParams(query string, values url.Values) string + func (s RemoteServer) MustWrite(db, rp, body string, params url.Values) string + func (s RemoteServer) Query(query string) (results string, err error) + func (s RemoteServer) QueryWithParams(query string, values url.Values) (results string, err error) + func (s RemoteServer) Write(db, rp, body string, params url.Values) (results string, err error) + type Server interface + Close func() + Closed func() bool + CreateDatabase func(db string) (*meta.DatabaseInfo, error) + CreateDatabaseAndRetentionPolicy func(db string, rp *meta.RetentionPolicySpec, makeDefault bool) error + CreateSubscription func(database, rp, name, mode string, destinations []string) error + DropDatabase func(db string) error + MustWrite func(db, rp, body string, params url.Values) string + Open func() error + Query func(query string) (results string, err error) + QueryWithParams func(query string, values url.Values) (results string, err error) + Reset func() error + SetLogOutput func(w io.Writer) + URL func() string + Write func(db, rp, body string, params url.Values) (results string, err error) + WritePoints func(database, retentionPolicy string, consistencyLevel models.ConsistencyLevel, ...) error + func NewServer(c *Config) Server + func OpenDefaultServer(c *Config) Server + func OpenServer(c *Config) Server + func OpenServerWithVersion(c *Config, version string) Server + type Test struct + func NewTest(db, rp string) Test + type Tests map[string]Test + type Write struct + type WriteError struct + func (wr WriteError) Body() string + func (wr WriteError) Error() string + func (wr WriteError) StatusCode() int + type Writes []*Write