cluster

Jun 13, 2014

Changes in this version

type SavedConfiguration

+ LastShardIdUsed uint32

May 29, 2014

Changes in this version

+ func HashDbAndSeriesToInt(database, series string) int

type ClusterConfiguration

+ func (self *ClusterConfiguration) DatabasesExists(db string) bool

+ func (self *ClusterConfiguration) RemoveServer(server *ClusterServer) error

May 13, 2014

Changes in this version

type ServerConnection

+ ClearRequests func()

May 8, 2014

Changes in this version

type ClusterConfiguration

+ func (self *ClusterConfiguration) DatabaseExists(name string) bool

May 6, 2014

Changes in this version

type QuerySpec

+ AllShardsQuery func() bool

Apr 29, 2014

Changes in this version

type ClusterConfiguration

+ LocalServer *ClusterServer

+ func (self *ClusterConfiguration) ChangeProtobufConnectionString(server *ClusterServer)

+ func (self *ClusterConfiguration) GetLocalConfiguration() *configuration.Configuration

type ServerConnection

+ Close func()

Apr 25, 2014

Changes in this version

type ClusterConfiguration

+ func (self *ClusterConfiguration) ChangeDbUserPermissions(db, username, readPermissions, writePermissions string) error

type DbUser

+ func (self *DbUser) ChangePermissions(readPermissions, writePermissions string)

type Shard

+ SyncWrite func(*p.Request) error

type ShardData

+ func (self *ShardData) SyncWrite(request *p.Request) error

Apr 15, 2014

Changes in this version

type ClusterConfiguration

+ func (self *ClusterConfiguration) HasUncommitedWrites() bool

type ClusterServer

+ MaxBackoff time.Duration

+ MinBackoff time.Duration

type WriteBuffer

+ func (self *WriteBuffer) HasUncommitedWrites() bool

+ func (self *WriteBuffer) ShardsRequestNumber() map[uint32]uint32

Apr 2, 2014

Changes in this version

type ShardData

+ func (self *ShardData) QueryResponseBufferSize(querySpec *parser.QuerySpec, batchPointSize int) int

Mar 28, 2014

Changes in this version

type ClusterConfiguration

+ func (self *ClusterConfiguration) CreateCheckpoint() error

type SavedConfiguration

+ ContinuousQueries map[string][]*ContinuousQuery

type WAL

+ CreateCheckpoint func() error

Mar 24, 2014

Changes in this version

+ const DEFAULT_BACKOFF

+ const FIRST_LOWER_CASE_CHARACTER

+ const HEARTBEAT_TIMEOUT

+ const LOCAL_WRITE_BUFFER_SIZE

+ const MAX_BACKOFF

+ const PER_SERVER_BUFFER_SIZE

+ var HEARTBEAT_TYPE = protocol.Request_HEARTBEAT

+ func HashPassword(password string) ([]byte, error)

+ func SortShardsByTimeAscending(shards []*ShardData)

+ func SortShardsByTimeDescending(shards []*ShardData)

+ type ByShardTimeAsc struct

+ func (s ByShardTimeAsc) Less(i, j int) bool

+ type ByShardTimeDesc struct

+ func (s ByShardTimeDesc) Less(i, j int) bool

+ type ClusterAdmin struct

+ func (self *ClusterAdmin) HasReadAccess(_ string) bool

+ func (self *ClusterAdmin) HasWriteAccess(_ string) bool

+ func (self *ClusterAdmin) IsClusterAdmin() bool

+ type ClusterConfiguration struct

+ DatabaseReplicationFactors map[string]uint8

+ LocalRaftName string

+ LocalServerId uint32

+ ParsedContinuousQueries map[string]map[uint32]*parser.SelectQuery

+ func NewClusterConfiguration(config *configuration.Configuration, wal WAL, shardStore LocalShardStore, ...) *ClusterConfiguration

+ func (self *ClusterConfiguration) AddPotentialServer(server *ClusterServer)

+ func (self *ClusterConfiguration) AddShards(shards []*NewShardData) ([]*ShardData, error)

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

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

+ func (self *ClusterConfiguration) ChangeDbUserPassword(db, username, hash string) error

+ func (self *ClusterConfiguration) CreateContinuousQuery(db string, query string) error

+ func (self *ClusterConfiguration) CreateDatabase(name string, replicationFactor uint8) error

+ func (self *ClusterConfiguration) CreateFutureShardsAutomaticallyBeforeTimeComes()

+ func (self *ClusterConfiguration) DeleteContinuousQuery(db string, id uint32) error

+ func (self *ClusterConfiguration) DropDatabase(name string) error

+ func (self *ClusterConfiguration) DropShard(shardId uint32, serverIds []uint32) error

+ func (self *ClusterConfiguration) GetAllShards() []*ShardData

+ func (self *ClusterConfiguration) GetClusterAdmin(username string) *ClusterAdmin

+ func (self *ClusterConfiguration) GetClusterAdmins() (names []string)

+ func (self *ClusterConfiguration) GetContinuousQueries(db string) []*ContinuousQuery

+ func (self *ClusterConfiguration) GetDatabases() []*Database

+ func (self *ClusterConfiguration) GetDbUser(db, username string) *DbUser

+ func (self *ClusterConfiguration) GetDbUsers(db string) []common.User

+ func (self *ClusterConfiguration) GetLocalShardById(id uint32) *ShardData

+ func (self *ClusterConfiguration) GetLongTermShards() []*ShardData

+ func (self *ClusterConfiguration) GetMapForJsonSerialization() map[string]interface{}

+ func (self *ClusterConfiguration) GetServerById(id *uint32) *ClusterServer

+ func (self *ClusterConfiguration) GetServerByProtobufConnectionString(connectionString string) *ClusterServer

+ func (self *ClusterConfiguration) GetServerByRaftName(name string) *ClusterServer

+ func (self *ClusterConfiguration) GetShardToWriteToBySeriesAndTime(db, series string, microsecondsEpoch int64) (*ShardData, error)

+ func (self *ClusterConfiguration) GetShards(querySpec *parser.QuerySpec) []*ShardData

+ func (self *ClusterConfiguration) GetShortTermShards() []*ShardData

+ func (self *ClusterConfiguration) HasContinuousQueries() bool

+ func (self *ClusterConfiguration) HashDbAndSeriesToInt(database, series string) int

+ func (self *ClusterConfiguration) IsSingleServer() bool

+ func (self *ClusterConfiguration) LastContinuousQueryRunTime() time.Time

+ func (self *ClusterConfiguration) MarshalNewShardArrayToShards(newShards []*NewShardData) ([]*ShardData, error)

+ func (self *ClusterConfiguration) RecoverFromWAL() error

+ func (self *ClusterConfiguration) Recovery(b []byte) error

+ func (self *ClusterConfiguration) Save() ([]byte, error)

+ func (self *ClusterConfiguration) SaveClusterAdmin(u *ClusterAdmin)

+ func (self *ClusterConfiguration) SaveDbUser(u *DbUser)

+ func (self *ClusterConfiguration) ServerId() uint32

+ func (self *ClusterConfiguration) Servers() []*ClusterServer

+ func (self *ClusterConfiguration) SetContinuousQueryTimestamp(timestamp time.Time) error

+ func (self *ClusterConfiguration) SetLastContinuousQueryRunTime(t time.Time)

+ func (self *ClusterConfiguration) SetShardCreator(shardCreator ShardCreator)

+ func (self *ClusterConfiguration) WaitForLocalServerLoaded()

+ type ClusterServer struct

+ Backoff time.Duration

+ HeartbeatInterval time.Duration

+ Id uint32

+ ProtobufConnectionString string

+ RaftConnectionString string

+ RaftName string

+ State ServerState

+ func NewClusterServer(raftName, raftConnectionString, protobufConnectionString string, ...) *ClusterServer

+ func (self *ClusterServer) BufferWrite(request *protocol.Request)

+ func (self *ClusterServer) Connect()

+ func (self *ClusterServer) GetId() uint32

+ func (self *ClusterServer) IsUp() bool

+ func (self *ClusterServer) MakeRequest(request *protocol.Request, responseStream chan *protocol.Response)

+ func (self *ClusterServer) SetWriteBuffer(writeBuffer *WriteBuffer)

+ func (self *ClusterServer) StartHeartbeat()

+ func (self *ClusterServer) Write(request *protocol.Request) error

+ type CommonUser struct

+ CacheKey string

+ Hash string

+ IsUserDeleted bool

+ Name string

+ func (self *CommonUser) ChangePassword(hash string) error

+ func (self *CommonUser) GetDb() string

+ func (self *CommonUser) GetName() string

+ func (self *CommonUser) HasReadAccess(name string) bool

+ func (self *CommonUser) HasWriteAccess(name string) bool

+ func (self *CommonUser) IsClusterAdmin() bool

+ func (self *CommonUser) IsDbAdmin(db string) bool

+ func (self *CommonUser) IsDeleted() bool

+ type ContinuousQuery struct

+ Id uint32

+ Query string

+ type Database struct

+ Name string

+ ReplicationFactor uint8

+ type DbUser struct

+ Db string

+ IsAdmin bool

+ ReadFrom []*Matcher

+ WriteTo []*Matcher

+ func (self *DbUser) GetDb() string

+ func (self *DbUser) HasReadAccess(name string) bool

+ func (self *DbUser) HasWriteAccess(name string) bool

+ func (self *DbUser) IsDbAdmin(db string) bool

+ type LocalShardDb interface

+ DropDatabase func(database string) error

+ IsClosed func() bool

+ Query func(*parser.QuerySpec, QueryProcessor) error

+ Write func(database string, series *p.Series) error

+ type LocalShardStore interface

+ BufferWrite func(request *p.Request)

+ DeleteShard func(shardId uint32) error

+ GetOrCreateShard func(id uint32) (LocalShardDb, error)

+ ReturnShard func(id uint32)

+ SetWriteBuffer func(writeBuffer *WriteBuffer)

+ Write func(request *p.Request) error

+ type Matcher struct

+ IsRegex bool

+ Name string

+ func (self *Matcher) Matches(name string) bool

+ type NewShardData struct

+ DurationSplit bool

+ EndTime time.Time

+ Id uint32

+ ServerIds []uint32

+ StartTime time.Time

+ Type ShardType

+ type QueryProcessor interface

+ Close func()

+ GetName func() string

+ SetShardInfo func(shardId int, shardLocal bool)

+ YieldPoint func(seriesName *string, columnNames []string, point *p.Point) bool

+ YieldSeries func(seriesIncoming *p.Series) bool

+ type QuerySpec interface

+ Database func() string

+ GetEndTime func() time.Time

+ GetGroupByInterval func() *time.Duration

+ GetStartTime func() time.Time

+ IsRegex func() bool

+ ShouldQueryShortTermAndLongTerm func() (shouldQueryShortTerm bool, shouldQueryLongTerm bool)

+ TableNames func() []string

+ type SavedConfiguration struct

+ Admins map[string]*ClusterAdmin

+ Databases map[string]uint8

+ DbUsers map[string]map[string]*DbUser

+ LongTermShards []*NewShardData

+ Servers []*ClusterServer

+ ShortTermShards []*NewShardData

+ type ServerConnection interface

+ Connect func()

+ MakeRequest func(request *protocol.Request, responseStream chan *protocol.Response) error

+ type ServerState int

+ const DeletingOldData

+ const LoadingRingData

+ const Potential

+ const Running

+ const SendingRingData

+ type Shard interface

+ EndTime func() time.Time

+ Id func() uint32

+ IsMicrosecondInRange func(t int64) bool

+ Query func(querySpec *parser.QuerySpec, response chan *p.Response)

+ StartTime func() time.Time

+ Write func(*p.Request) error

+ type ShardCollection []*ShardData

+ func (s ShardCollection) Len() int

+ func (s ShardCollection) Swap(i, j int)

+ type ShardCreator interface

+ CreateShards func(shards []*NewShardData) ([]*ShardData, error)

+ type ShardData struct

+ IsLocal bool

+ func NewShard(id uint32, startTime, endTime time.Time, shardType ShardType, ...) *ShardData

+ func (self *ShardData) DropDatabase(database string, sendToServers bool)

+ func (self *ShardData) EndMicro() int64

+ func (self *ShardData) EndTime() time.Time

+ func (self *ShardData) HandleDestructiveQuery(querySpec *parser.QuerySpec, request *p.Request, response chan *p.Response, ...)

+ func (self *ShardData) Id() uint32

+ func (self *ShardData) IsMicrosecondInRange(t int64) bool

+ func (self *ShardData) LogAndHandleDestructiveQuery(querySpec *parser.QuerySpec, request *p.Request, response chan *p.Response, ...)

+ func (self *ShardData) Query(querySpec *parser.QuerySpec, response chan *p.Response)

+ func (self *ShardData) ServerIds() []uint32

+ func (self *ShardData) SetLocalStore(store LocalShardStore, localServerId uint32) error

+ func (self *ShardData) SetServers(servers []*ClusterServer)

+ func (self *ShardData) ShouldAggregateLocally(querySpec *parser.QuerySpec) bool

+ func (self *ShardData) StartMicro() int64

+ func (self *ShardData) StartTime() time.Time

+ func (self *ShardData) String() string

+ func (self *ShardData) ToNewShardData() *NewShardData

+ func (self *ShardData) Write(request *p.Request) error

+ func (self *ShardData) WriteLocalOnly(request *p.Request) error

+ type ShardType int

+ const LONG_TERM

+ const SHORT_TERM

+ type WAL interface

+ AssignSequenceNumbersAndLog func(request *protocol.Request, shard wal.Shard) (uint32, error)

+ Commit func(requestNumber uint32, serverId uint32) error

+ RecoverServerFromLastCommit func(serverId uint32, shardIds []uint32, ...) error

+ RecoverServerFromRequestNumber func(requestNumber uint32, shardIds []uint32, ...) error

+ type WriteBuffer struct

+ func NewWriteBuffer(writerInfo string, writer Writer, wal WAL, serverId uint32, bufferSize int) *WriteBuffer

+ func (self *WriteBuffer) Write(request *protocol.Request)

+ type Writer interface

+ Write func(request *protocol.Request) error