coordinator

package

Go to main page

Versions in this module

v0

v0.8.7

Nov 16, 2014

v0.8.6

Nov 16, 2014

Changes in this version

type ContinuousQueryWriter

+ func (self *ContinuousQueryWriter) Next() engine.Processor

v0.8.5

Oct 27, 2014

v0.8.4

Oct 24, 2014

Changes in this version

type ContinuousQueryWriter

+ func (self *ContinuousQueryWriter) Name() string

+ func (self *ContinuousQueryWriter) Yield(series *protocol.Series) (bool, error)

type Coordinator

+ func NewCoordinator(config *configuration.Configuration, raftServer *RaftServer, ...) *Coordinator

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

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

+ func (self *Coordinator) ChangeClusterAdminPassword(requester common.User, username, password string) error

+ func (self *Coordinator) ChangeDbUserPassword(requester common.User, db, username, password string) error

+ func (self *Coordinator) ChangeDbUserPermissions(requester common.User, db, username, readPermissions, writePermissions string) error

+ func (self *Coordinator) CommitSeriesData(db string, serieses []*protocol.Series, sync bool) error

+ func (self *Coordinator) ConnectToProtobufServers(localRaftName string) error

+ func (self *Coordinator) CreateClusterAdminUser(requester common.User, username, password string) error

+ func (self *Coordinator) CreateDbUser(requester common.User, db, username, password string, permissions ...string) error

+ func (self *Coordinator) DeleteClusterAdminUser(requester common.User, username string) error

+ func (self *Coordinator) DeleteDbUser(requester common.User, db, username string) error

+ func (self *Coordinator) GetDbUser(requester common.User, db string, username string) (common.User, error)

+ func (self *Coordinator) InterpolateValuesAndCommit(query string, db string, series *protocol.Series, targetName string, ...) error

+ func (self *Coordinator) ListClusterAdmins(requester common.User) ([]string, error)

+ func (self *Coordinator) ListDbUsers(requester common.User, db string) ([]common.User, error)

+ func (self *Coordinator) ProcessContinuousQueries(db string, series *protocol.Series)

+ func (self *Coordinator) SetDbAdmin(requester common.User, db, username string, isAdmin bool) error

+ type Handler interface

+ HandleRequest func(*protocol.Request, net.Conn) error

+ type MergeChannelProcessor struct

+ func NewMergeChannelProcessor(next engine.Processor, concurrency int) *MergeChannelProcessor

+ func (p *MergeChannelProcessor) Close() (err error)

+ func (p *MergeChannelProcessor) NextChannel(bs int) (chan<- *protocol.Response, error)

+ func (p *MergeChannelProcessor) ProcessChannels()

+ func (p *MergeChannelProcessor) String() string

type Permissions

+ func (self *Permissions) AuthorizeSelectQuery(user common.User, db string, querySpec *parser.QuerySpec) (ok bool, err common.AuthorizationError)

+ func (self *Permissions) CheckQueryPermissions(user common.User, db string, querySpec *parser.QuerySpec) (ok bool, err common.AuthorizationError)

type ProtobufClient

+ func (self *ProtobufClient) CancelRequest(request *protocol.Request)

v0.8.4-rc.1

Oct 21, 2014

v0.8.3

Sep 24, 2014

Changes in this version

type CoordinatorImpl

+ func (self *CoordinatorImpl) RunContinuousQuery(user common.User, db string, query string) error

v0.8.2

Sep 5, 2014

Changes in this version

type RaftServer

+ func (self *RaftServer) UpdateShardSpace(shardSpace *cluster.ShardSpace) error

+ type UpdateShardSpaceCommand struct

+ ShardSpace *cluster.ShardSpace

+ func NewUpdateShardSpaceCommand(space *cluster.ShardSpace) *UpdateShardSpaceCommand

+ func (c *UpdateShardSpaceCommand) Apply(server raft.Server) (interface{}, error)

+ func (c *UpdateShardSpaceCommand) CommandName() string

v0.8.0

Aug 22, 2014

Changes in this version

+ const DEFAULT_ROOT_PWD

+ const DEFAULT_ROOT_PWD_ENVKEY

+ const HOST_ID_OFFSET

+ const KILOBYTE

+ const MAX_REQUEST_SIZE

+ const MAX_REQUEST_TIME

+ const MAX_RESPONSE_SIZE

+ const MAX_SIZE

+ const MEGABYTE

+ const POINT_SEQUENCE_NUMBER_KEY

+ const RAFT_NAME_SIZE

+ const RECONNECT_RETRY_WAIT

+ const REQUEST_RETRY_ATTEMPTS

+ const SHARDS_TO_QUERY_FOR_LIST_SERIES

+ var BARRIER_TIME_MAX int64 = math.MaxInt64

+ var BARRIER_TIME_MIN int64 = math.MinInt64

+ func SendCommandToServer(url string, command raft.Command) (interface{}, error)

+ type ChangeDbUserPassword struct

+ Database string

+ Hash string

+ Username string

+ func NewChangeDbUserPasswordCommand(db, username, hash string) *ChangeDbUserPassword

+ func (c *ChangeDbUserPassword) Apply(server raft.Server) (interface{}, error)

+ func (c *ChangeDbUserPassword) CommandName() string

+ type ChangeDbUserPermissions struct

+ Database string

+ ReadPermissions string

+ Username string

+ WritePermissions string

+ func NewChangeDbUserPermissionsCommand(db, username, readPermissions, writePermissions string) *ChangeDbUserPermissions

+ func (c *ChangeDbUserPermissions) Apply(server raft.Server) (interface{}, error)

+ func (c *ChangeDbUserPermissions) CommandName() string

+ type ClusterConsensus interface

+ AssignCoordinator func(coordinator *CoordinatorImpl) error

+ ChangeDbUserPassword func(db, username string, hash []byte) error

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

+ CreateContinuousQuery func(db string, query string) error

+ CreateDatabase func(name string) error

+ CreateRootUser func() error

+ DeleteContinuousQuery func(db string, id uint32) error

+ DropDatabase func(name string) error

+ DropSeries func(database, series string) error

+ ForceLogCompaction func() error

+ SaveClusterAdminUser func(u *cluster.ClusterAdmin) error

+ SaveDbUser func(user *cluster.DbUser) error

+ type ContinuousQueryWriter struct

+ func NewContinuousQueryWriter(yield func(*protocol.Series) error) *ContinuousQueryWriter

+ func (self *ContinuousQueryWriter) Close()

+ func (self *ContinuousQueryWriter) Write(series *protocol.Series) error

+ type Coordinator interface

+ CreateContinuousQuery func(user common.User, db string, query string) error

+ CreateDatabase func(user common.User, db string) error

+ DeleteContinuousQuery func(user common.User, db string, id uint32) error

+ DropDatabase func(user common.User, db string) error

+ ForceCompaction func(user common.User) error

+ ListContinuousQueries func(user common.User, db string) ([]*protocol.Series, error)

+ ListDatabases func(user common.User) ([]*cluster.Database, error)

+ RunQuery func(user common.User, db, query string, seriesWriter SeriesWriter) error

+ WriteSeriesData func(user common.User, db string, series []*protocol.Series) error

+ type CoordinatorImpl struct

+ func NewCoordinatorImpl(config *configuration.Configuration, raftServer ClusterConsensus, ...) *CoordinatorImpl

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

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

+ func (self *CoordinatorImpl) ChangeClusterAdminPassword(requester common.User, username, password string) error

+ func (self *CoordinatorImpl) ChangeDbUserPassword(requester common.User, db, username, password string) error

+ func (self *CoordinatorImpl) ChangeDbUserPermissions(requester common.User, db, username, readPermissions, writePermissions string) error

+ func (self *CoordinatorImpl) CommitSeriesData(db string, serieses []*protocol.Series, sync bool) error

+ func (self *CoordinatorImpl) ConnectToProtobufServers(localRaftName string) error

+ func (self *CoordinatorImpl) CreateClusterAdminUser(requester common.User, username, password string) error

+ func (self *CoordinatorImpl) CreateContinuousQuery(user common.User, db string, query string) error

+ func (self *CoordinatorImpl) CreateDatabase(user common.User, db string) error

+ func (self *CoordinatorImpl) CreateDbUser(requester common.User, db, username, password string, permissions ...string) error

+ func (self *CoordinatorImpl) DeleteClusterAdminUser(requester common.User, username string) error

+ func (self *CoordinatorImpl) DeleteContinuousQuery(user common.User, db string, id uint32) error

+ func (self *CoordinatorImpl) DeleteDbUser(requester common.User, db, username string) error

+ func (self *CoordinatorImpl) DropDatabase(user common.User, db string) error

+ func (self *CoordinatorImpl) ForceCompaction(user common.User) error

+ func (self *CoordinatorImpl) GetDbUser(requester common.User, db string, username string) (common.User, error)

+ func (self *CoordinatorImpl) InterpolateValuesAndCommit(query string, db string, series *protocol.Series, targetName string, ...) error

+ func (self *CoordinatorImpl) ListClusterAdmins(requester common.User) ([]string, error)

+ func (self *CoordinatorImpl) ListContinuousQueries(user common.User, db string) ([]*protocol.Series, error)

+ func (self *CoordinatorImpl) ListDatabases(user common.User) ([]*cluster.Database, error)

+ func (self *CoordinatorImpl) ListDbUsers(requester common.User, db string) ([]common.User, error)

+ func (self *CoordinatorImpl) ProcessContinuousQueries(db string, series *protocol.Series)

+ func (self *CoordinatorImpl) RunQuery(user common.User, database string, queryString string, ...) (err error)

+ func (self *CoordinatorImpl) SetDbAdmin(requester common.User, db, username string, isAdmin bool) error

+ func (self *CoordinatorImpl) WriteSeriesData(user common.User, db string, series []*protocol.Series) error

+ type CreateContinuousQueryCommand struct

+ Database string

+ Query string

+ func NewCreateContinuousQueryCommand(database string, query string) *CreateContinuousQueryCommand

+ func (c *CreateContinuousQueryCommand) Apply(server raft.Server) (interface{}, error)

+ func (c *CreateContinuousQueryCommand) CommandName() string

+ type CreateDatabaseCommand struct

+ Name string

+ func NewCreateDatabaseCommand(name string) *CreateDatabaseCommand

+ func (c *CreateDatabaseCommand) Apply(server raft.Server) (interface{}, error)

+ func (c *CreateDatabaseCommand) CommandName() string

+ type CreateSeriesFieldIdsCommand struct

+ Database string

+ Series []*protocol.Series

+ func NewCreateSeriesFieldIdsCommand(database string, series []*protocol.Series) *CreateSeriesFieldIdsCommand

+ func (c *CreateSeriesFieldIdsCommand) Apply(server raft.Server) (interface{}, error)

+ func (c *CreateSeriesFieldIdsCommand) CommandName() string

+ func (c *CreateSeriesFieldIdsCommand) Decode(r io.Reader) error

+ func (c *CreateSeriesFieldIdsCommand) Encode(w io.Writer) error

+ type CreateShardSpaceCommand struct

+ ShardSpace *cluster.ShardSpace

+ func NewCreateShardSpaceCommand(space *cluster.ShardSpace) *CreateShardSpaceCommand

+ func (c *CreateShardSpaceCommand) Apply(server raft.Server) (interface{}, error)

+ func (c *CreateShardSpaceCommand) CommandName() string

+ type CreateShardsCommand struct

+ Shards []*cluster.NewShardData

+ SpaceName string

+ func NewCreateShardsCommand(shards []*cluster.NewShardData) *CreateShardsCommand

+ func (c *CreateShardsCommand) Apply(server raft.Server) (interface{}, error)

+ func (c *CreateShardsCommand) CommandName() string

+ func (c *CreateShardsCommand) Decode(r io.Reader) error

+ func (c *CreateShardsCommand) Encode(w io.Writer) error

+ type DeleteContinuousQueryCommand struct

+ Database string

+ Id uint32

+ func NewDeleteContinuousQueryCommand(database string, id uint32) *DeleteContinuousQueryCommand

+ func (c *DeleteContinuousQueryCommand) Apply(server raft.Server) (interface{}, error)

+ func (c *DeleteContinuousQueryCommand) CommandName() string

+ type DropDatabaseCommand struct

+ Name string

+ func NewDropDatabaseCommand(name string) *DropDatabaseCommand

+ func (c *DropDatabaseCommand) Apply(server raft.Server) (interface{}, error)

+ func (c *DropDatabaseCommand) CommandName() string

+ type DropSeriesCommand struct

+ Database string

+ Series string

+ func NewDropSeriesCommand(database, series string) *DropSeriesCommand

+ func (c *DropSeriesCommand) Apply(server raft.Server) (interface{}, error)

+ func (c *DropSeriesCommand) CommandName() string

+ type DropShardCommand struct

+ ServerIds []uint32

+ ShardId uint32

+ func NewDropShardCommand(id uint32, serverIds []uint32) *DropShardCommand

+ func (c *DropShardCommand) Apply(server raft.Server) (interface{}, error)

+ func (c *DropShardCommand) CommandName() string

+ type DropShardSpaceCommand struct

+ Database string

+ Name string

+ func NewDropShardSpaceCommand(database, name string) *DropShardSpaceCommand

+ func (c *DropShardSpaceCommand) Apply(server raft.Server) (interface{}, error)

+ func (c *DropShardSpaceCommand) CommandName() string

+ type InfluxChangeConnectionStringCommand struct

+ ConnectionString string

+ Force bool

+ Name string

+ ProtobufConnectionString string

+ func (c *InfluxChangeConnectionStringCommand) Apply(server raft.Server) (interface{}, error)

+ func (c *InfluxChangeConnectionStringCommand) CommandName() string

+ func (c *InfluxChangeConnectionStringCommand) NodeName() string

+ type InfluxForceLeaveCommand struct

+ Id uint32

+ func (c *InfluxForceLeaveCommand) Apply(server raft.Server) (interface{}, error)

+ func (c *InfluxForceLeaveCommand) CommandName() string

+ type InfluxJoinCommand struct

+ ConnectionString string

+ Name string

+ ProtobufConnectionString string

+ func (c *InfluxJoinCommand) Apply(server raft.Server) (interface{}, error)

+ func (c *InfluxJoinCommand) CommandName() string

+ func (c *InfluxJoinCommand) NodeName() string

+ type Metastore interface

+ ReplaceFieldNamesWithFieldIds func(database string, series []*protocol.Series) error

+ type Permissions struct

+ func (self *Permissions) AuthorizeChangeClusterAdminPassword(user common.User) (ok bool, err common.AuthorizationError)

+ func (self *Permissions) AuthorizeChangeDbUserPassword(user common.User, db string, targetUsername string) (ok bool, err common.AuthorizationError)

+ func (self *Permissions) AuthorizeChangeDbUserPermissions(user common.User, db string) (ok bool, err common.AuthorizationError)

+ func (self *Permissions) AuthorizeCreateClusterAdmin(user common.User) (ok bool, err common.AuthorizationError)

+ func (self *Permissions) AuthorizeCreateContinuousQuery(user common.User, db string) (ok bool, err common.AuthorizationError)

+ func (self *Permissions) AuthorizeCreateDatabase(user common.User) (ok bool, err common.AuthorizationError)

+ func (self *Permissions) AuthorizeCreateDbUser(user common.User, db string) (ok bool, err common.AuthorizationError)

+ func (self *Permissions) AuthorizeDeleteClusterAdmin(user common.User) (ok bool, err common.AuthorizationError)

+ func (self *Permissions) AuthorizeDeleteContinuousQuery(user common.User, db string) (ok bool, err common.AuthorizationError)

+ func (self *Permissions) AuthorizeDeleteDbUser(user common.User, db string) (ok bool, err common.AuthorizationError)

+ func (self *Permissions) AuthorizeDeleteQuery(user common.User, db string) (ok bool, err common.AuthorizationError)

+ func (self *Permissions) AuthorizeDropDatabase(user common.User) (ok bool, err common.AuthorizationError)

+ func (self *Permissions) AuthorizeDropSeries(user common.User, db string, seriesName string) (ok bool, err common.AuthorizationError)

+ func (self *Permissions) AuthorizeGetDbUser(user common.User, db string) (ok bool, err common.AuthorizationError)

+ func (self *Permissions) AuthorizeGrantDbUserAdmin(user common.User, db string) (ok bool, err common.AuthorizationError)

+ func (self *Permissions) AuthorizeListClusterAdmins(user common.User) (ok bool, err common.AuthorizationError)

+ func (self *Permissions) AuthorizeListContinuousQueries(user common.User, db string) (ok bool, err common.AuthorizationError)

+ func (self *Permissions) AuthorizeListDatabases(user common.User) (ok bool, err common.AuthorizationError)

+ func (self *Permissions) AuthorizeListDbUsers(user common.User, db string) (ok bool, err common.AuthorizationError)

+ type ProtobufClient struct

+ func NewProtobufClient(hostAndPort string, writeTimeout time.Duration) *ProtobufClient

+ func (self *ProtobufClient) ClearRequests()

+ func (self *ProtobufClient) Close()

+ func (self *ProtobufClient) Connect()

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

+ type ProtobufRequestHandler struct

+ func NewProtobufRequestHandler(coordinator Coordinator, clusterConfig *cluster.ClusterConfiguration) *ProtobufRequestHandler

+ func (self *ProtobufRequestHandler) HandleRequest(request *protocol.Request, conn net.Conn) error

+ func (self *ProtobufRequestHandler) WriteResponse(conn net.Conn, response *protocol.Response) error

+ type ProtobufServer struct

+ func NewProtobufServer(port string, requestHandler RequestHandler) *ProtobufServer

+ func (self *ProtobufServer) Close()

+ func (self *ProtobufServer) ListenAndServe()

+ type RaftServer struct

+ func NewRaftServer(config *configuration.Configuration, ...) *RaftServer

+ func (s *RaftServer) AssignCoordinator(coordinator *CoordinatorImpl) error

+ func (s *RaftServer) ChangeConnectionString(raftName, protobufConnectionString, raftConnectionString string, forced bool) error

+ func (s *RaftServer) ChangeDbUserPassword(db, username string, hash []byte) error

+ func (s *RaftServer) ChangeDbUserPermissions(db, username, readPermissions, writePermissions string) error

+ func (s *RaftServer) CommittedAllChanges() bool

+ func (s *RaftServer) CompactLog()

+ func (s *RaftServer) CreateContinuousQuery(db string, query string) error

+ func (s *RaftServer) CreateDatabase(name string) error

+ func (s *RaftServer) CreateRootUser() error

+ func (s *RaftServer) DeleteContinuousQuery(db string, id uint32) error

+ func (s *RaftServer) DropDatabase(name string) error

+ func (s *RaftServer) ForceLogCompaction() error

+ func (s *RaftServer) GetLeaderConnectString() (string, bool)

+ func (s *RaftServer) GetLeaderRaftName() string

+ func (s *RaftServer) GetRaftName() string

+ func (s *RaftServer) HandleFunc(pattern string, handler func(http.ResponseWriter, *http.Request))

+ func (s *RaftServer) IsLeaderByRaftName(name string) bool

+ func (s *RaftServer) Join(leader string) error

+ func (s *RaftServer) ListenAndServe() error

+ func (s *RaftServer) RemoveServer(id uint32) error

+ func (s *RaftServer) SaveClusterAdminUser(u *cluster.ClusterAdmin) error

+ func (s *RaftServer) SaveDbUser(u *cluster.DbUser) error

+ func (s *RaftServer) Serve(l net.Listener) error

+ func (s *RaftServer) SetContinuousQueryTimestamp(timestamp time.Time) error

+ func (s *RaftServer) StartProcessingContinuousQueries()

+ func (self *RaftServer) Close()

+ func (self *RaftServer) CreateShardSpace(shardSpace *cluster.ShardSpace) error

+ func (self *RaftServer) CreateShards(shards []*cluster.NewShardData) ([]*cluster.ShardData, error)

+ func (self *RaftServer) DropSeries(database, series string) error

+ func (self *RaftServer) DropShard(id uint32, serverIds []uint32) error

+ func (self *RaftServer) DropShardSpace(database, name string) error

+ func (self *RaftServer) GetOrSetFieldIdsForSeries(database string, series []*protocol.Series) ([]*protocol.Series, error)

+ type RequestHandler interface

+ HandleRequest func(request *protocol.Request, conn net.Conn) error

+ type SaveClusterAdminCommand struct

+ User *cluster.ClusterAdmin

+ func NewSaveClusterAdminCommand(u *cluster.ClusterAdmin) *SaveClusterAdminCommand

+ func (c *SaveClusterAdminCommand) Apply(server raft.Server) (interface{}, error)

+ func (c *SaveClusterAdminCommand) CommandName() string

+ type SaveDbUserCommand struct

+ User *cluster.DbUser

+ func NewSaveDbUserCommand(u *cluster.DbUser) *SaveDbUserCommand

+ func (c *SaveDbUserCommand) Apply(server raft.Server) (interface{}, error)

+ func (c *SaveDbUserCommand) CommandName() string

+ type SeriesWriter interface

+ Close func()

+ Write func(*protocol.Series) error

+ type SetContinuousQueryTimestampCommand struct

+ Timestamp time.Time

+ func NewSetContinuousQueryTimestampCommand(timestamp time.Time) *SetContinuousQueryTimestampCommand

+ func (c *SetContinuousQueryTimestampCommand) Apply(server raft.Server) (interface{}, error)

+ func (c *SetContinuousQueryTimestampCommand) CommandName() string

+ type ShardAwareObject interface

+ CanCollateShards func(querySpec *parser.QuerySpec) bool

+ GetShardById func(id uint32) cluster.Shard

+ GetShardToWriteToBySeriesAndTime func(db, series string, microsecondsEpoch int64) (cluster.Shard, error)

+ GetShards func(querySpec *parser.QuerySpec) []cluster.Shard

v0.8.0-rc.5

Aug 15, 2014

v0.8.0-rc.4

Jul 28, 2014

v0.8.0-rc.3

Jul 21, 2014

v0.8.0-rc.2

Jul 16, 2014

v0.8.0-rc.1

Jul 15, 2014

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL