common

Documentation

Index

• Constants
• Variables
• func ConvertToDataStoreSeries(s ApiSeries, precision TimePrecision) (*protocol.Series, error)
• func CurrentTime() int64
• func GetFileSize(path string) (int64, error)
• func MergeSeries(s1, s2 *protocol.Series) *protocol.Series
• func ParseTimeDuration(value string) (int64, error)
• func RecoverFunc(database, query string, cleanup func(err interface{}))
• func StringToSeriesArray(seriesString string, args ...interface{}) ([]*protocol.Series, error)
• func TimeToMicroseconds(t time.Time) int64
• type ApiSeries
• type AuthenticationError
  • func NewAuthenticationError(formatStr string, args ...interface{}) AuthenticationError
  • func (self AuthenticationError) Error() string
• type AuthorizationError
  • func NewAuthorizationError(formatStr string, args ...interface{}) AuthorizationError
  • func (self AuthorizationError) Error() string
• type EnhancedTime
• type ErrorWithStacktrace
  • func NewErrorWithStacktrace(cause error, msg ...interface{}) *ErrorWithStacktrace
  • func (self *ErrorWithStacktrace) Error() string
• type QueryError
  • func NewQueryError(code int, msg string, args ...interface{}) *QueryError
  • func (self *QueryError) Error() string
• type SerializedSeries
  • func SerializeSeries(memSeries map[string]*protocol.Series, precision TimePrecision) []*SerializedSeries
  • func (self *SerializedSeries) GetColumns() []string
  • func (self *SerializedSeries) GetName() string
  • func (self *SerializedSeries) GetPoints() [][]interface{}
• type TimePrecision
• type Type
  • func CoerceValues(leftValue, rightValue *protocol.FieldValue) (interface{}, interface{}, Type)
• type User

Constants

const (
	TYPE_INT = iota
	TYPE_STRING
	TYPE_BOOL
	TYPE_DOUBLE
	TYPE_UNKNOWN
)

const (
	WrongNumberOfArguments = iota
	InvalidArgument
	InternalError
)

Variables

var (
	TRUE  = true
	FALSE = false
)

var VALID_TABLE_NAMES *regexp.Regexp

Functions

func ConvertToDataStoreSeries

func ConvertToDataStoreSeries(s ApiSeries, precision TimePrecision) (*protocol.Series, error)

func CurrentTime

func CurrentTime() int64

func GetFileSize

func GetFileSize(path string) (int64, error)

func MergeSeries

func MergeSeries(s1, s2 *protocol.Series) *protocol.Series

merges two time series making sure that the resulting series has the union of the two series columns and the values set properly. will panic if the two series don't have the same name

func ParseTimeDuration

func ParseTimeDuration(value string) (int64, error)

Returns the parsed duration in nanoseconds, support 'u', 's', 'm', 'h', 'd' and 'w' suffixes.

func RecoverFunc

func RecoverFunc(database, query string, cleanup func(err interface{}))

func StringToSeriesArray

func StringToSeriesArray(seriesString string, args ...interface{}) ([]*protocol.Series, error)

func TimeToMicroseconds

func TimeToMicroseconds(t time.Time) int64

Types

type ApiSeries

type ApiSeries interface {
	GetName() string
	GetColumns() []string
	GetPoints() [][]interface{}
}

type AuthenticationError

type AuthenticationError string

func NewAuthenticationError

func NewAuthenticationError(formatStr string, args ...interface{}) AuthenticationError

func (AuthenticationError) Error

func (self AuthenticationError) Error() string

type AuthorizationError

type AuthorizationError string

func NewAuthorizationError

func NewAuthorizationError(formatStr string, args ...interface{}) AuthorizationError

func (AuthorizationError) Error

func (self AuthorizationError) Error() string

type EnhancedTime

type EnhancedTime time.Time

type ErrorWithStacktrace

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

An error that remembers where it was thrown from

func NewErrorWithStacktrace

func NewErrorWithStacktrace(cause error, msg ...interface{}) *ErrorWithStacktrace

if msg is provided, msg is treated as the error message and the error is treated as the original cause of this error. Otherwise the error is used as the error message. This is useful for chaining multiple errors to trace what was the original error that triggered the subsequent errors

func (*ErrorWithStacktrace) Error

func (self *ErrorWithStacktrace) Error() string

type QueryError

type QueryError struct {
	ErrorCode int
	ErrorMsg  string
}

func NewQueryError

func NewQueryError(code int, msg string, args ...interface{}) *QueryError

func (*QueryError) Error

func (self *QueryError) Error() string

type SerializedSeries

type SerializedSeries struct {
	Name    string          `json:"name"`
	Columns []string        `json:"columns"`
	Points  [][]interface{} `json:"points"`
}

func SerializeSeries

func SerializeSeries(memSeries map[string]*protocol.Series, precision TimePrecision) []*SerializedSeries

takes a slice of protobuf series and convert them to the format that the http api expect

func (*SerializedSeries) GetColumns

func (self *SerializedSeries) GetColumns() []string

func (*SerializedSeries) GetName

func (self *SerializedSeries) GetName() string

func (*SerializedSeries) GetPoints

func (self *SerializedSeries) GetPoints() [][]interface{}

type TimePrecision

type TimePrecision int

const (
	MicrosecondPrecision TimePrecision = iota
	MillisecondPrecision
	SecondPrecision
)

type Type

type Type int

func CoerceValues

func CoerceValues(leftValue, rightValue *protocol.FieldValue) (interface{}, interface{}, Type)

type User

type User interface {
	GetName() string
	IsDeleted() bool
	IsClusterAdmin() bool
	IsDbAdmin(db string) bool
	GetDb() string
	HasWriteAccess(name string) bool
	HasReadAccess(name string) bool
}