common

Documentation

Index

• Constants
• func CurrentTime() int64
• func GetFileSize(path string) (int64, error)
• func RingLocation(database *string, timeSeries *string, time *int64) int
• func StringToSeriesArray(seriesString string, args ...interface{}) ([]*protocol.Series, error)
• func TimeToMicroseconds(t time.Time) int64
• 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 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
)

Functions

func CurrentTime

func CurrentTime() int64

func GetFileSize

func GetFileSize(path string) (int64, error)

func RingLocation

func RingLocation(database *string, timeSeries *string, time *int64) int

func StringToSeriesArray

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

func TimeToMicroseconds

func TimeToMicroseconds(t time.Time) int64

Types

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