common

Documentation

Index

• Constants
• Variables
• func ConvertToDataStoreSeries(s *SerializedSeries, precision TimePrecision) (*protocol.Series, error)
• func CurrentTime() int64
• func GetFileSize(path string) (int64, error)
• func ParseTimeDuration(value string) (int64, error)
• func StringToSeriesArray(seriesString string, args ...interface{}) ([]*protocol.Series, error)
• func TimeToMicroseconds(t time.Time) int64
• 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 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
• 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

var VALID_TABLE_NAMES *regexp.Regexp

Functions

func ConvertToDataStoreSeries

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

func CurrentTime

func CurrentTime() int64

func GetFileSize

func GetFileSize(path string) (int64, error)

func ParseTimeDuration

func ParseTimeDuration(value string) (int64, error)

func StringToSeriesArray

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

func TimeToMicroseconds

func TimeToMicroseconds(t time.Time) int64

Types

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

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
}