coordinator

Jan 24, 2017

Changes in this version

+ type IteratorCreator interface

+ type LocalShardMapper struct

+ MetaClient interface{ ... }

+ TSDBStore interface{ ... }

+ func (e *LocalShardMapper) MapShards(sources influxql.Sources, opt *influxql.SelectOptions) (IteratorCreator, error)

+ type LocalShardMapping struct

+ ShardMap map[Source]tsdb.ShardGroup

+ func (a *LocalShardMapping) Close() error

+ func (a *LocalShardMapping) CreateIterator(m *influxql.Measurement, opt influxql.IteratorOptions) (influxql.Iterator, error)

+ func (a *LocalShardMapping) FieldDimensions(m *influxql.Measurement) (fields map[string]influxql.DataType, dimensions map[string]struct{}, err error)

+ func (a *LocalShardMapping) MapType(m *influxql.Measurement, field string) influxql.DataType

type MetaClient

+ ShardGroupsByTimeRange func(database, policy string, min, max time.Time) (a []meta.ShardGroupInfo, err error)

type PointsWriter

+ func (w *PointsWriter) WithLogger(log zap.Logger)

+ type ShardMapper interface

+ MapShards func(sources influxql.Sources, opt *influxql.SelectOptions) (IteratorCreator, error)

+ type Source struct

+ Database string

+ RetentionPolicy string

type StatementExecutor

+ ShardMapper ShardMapper

Sep 7, 2016

Changes in this version

+ const DefaultMaxConcurrentQueries

+ const DefaultMaxSelectPointN

+ const DefaultMaxSelectSeriesN

+ const DefaultWriteTimeout

+ var ErrDatabaseNameRequired = errors.New("database name required")

+ var ErrPartialWrite = errors.New("partial write")

+ var ErrTimeout = errors.New("timeout")

+ var ErrWriteFailed = errors.New("write failed")

+ type BufferedPointsWriter struct

+ func NewBufferedPointsWriter(w pointsWriter, database, retentionPolicy string, capacity int) *BufferedPointsWriter

+ func (w *BufferedPointsWriter) Cap() int

+ func (w *BufferedPointsWriter) Flush() error

+ func (w *BufferedPointsWriter) Len() int

+ func (w *BufferedPointsWriter) WritePointsInto(req *IntoWriteRequest) error

+ type Config struct

+ LogQueriesAfter toml.Duration

+ MaxConcurrentQueries int

+ MaxSelectBucketsN int

+ MaxSelectPointN int

+ MaxSelectSeriesN int

+ QueryTimeout toml.Duration

+ WriteTimeout toml.Duration

+ func NewConfig() Config

+ type IntoWriteRequest struct

+ Database string

+ Points []models.Point

+ RetentionPolicy string

+ type LocalTSDBStore struct

+ func (s LocalTSDBStore) IteratorCreator(shards []meta.ShardInfo, opt *influxql.SelectOptions) (influxql.IteratorCreator, error)

+ type MetaClient interface

+ CreateContinuousQuery func(database, name, query string) error

+ CreateDatabase func(name string) (*meta.DatabaseInfo, error)

+ CreateDatabaseWithRetentionPolicy func(name string, spec *meta.RetentionPolicySpec) (*meta.DatabaseInfo, error)

+ CreateRetentionPolicy func(database string, spec *meta.RetentionPolicySpec) (*meta.RetentionPolicyInfo, error)

+ CreateSubscription func(database, rp, name, mode string, destinations []string) error

+ CreateUser func(name, password string, admin bool) (*meta.UserInfo, error)

+ Database func(name string) *meta.DatabaseInfo

+ Databases func() []meta.DatabaseInfo

+ DropContinuousQuery func(database, name string) error

+ DropDatabase func(name string) error

+ DropRetentionPolicy func(database, name string) error

+ DropShard func(id uint64) error

+ DropSubscription func(database, rp, name string) error

+ DropUser func(name string) error

+ RetentionPolicy func(database, name string) (rpi *meta.RetentionPolicyInfo, err error)

+ SetAdminPrivilege func(username string, admin bool) error

+ SetDefaultRetentionPolicy func(database, name string) error

+ SetPrivilege func(username, database string, p influxql.Privilege) error

+ ShardsByTimeRange func(sources influxql.Sources, tmin, tmax time.Time) (a []meta.ShardInfo, err error)

+ UpdateRetentionPolicy func(database, name string, rpu *meta.RetentionPolicyUpdate) error

+ UpdateUser func(name, password string) error

+ UserPrivilege func(username, database string) (*influxql.Privilege, error)

+ UserPrivileges func(username string) (map[string]influxql.Privilege, error)

+ Users func() []meta.UserInfo

+ type PointsWriter struct

+ Logger *log.Logger

+ MetaClient interface{ ... }

+ Node *influxdb.Node

+ ShardWriter interface{ ... }

+ Subscriber interface{ ... }

+ TSDBStore interface{ ... }

+ WriteTimeout time.Duration

+ func NewPointsWriter() *PointsWriter

+ func (w *PointsWriter) Close() error

+ func (w *PointsWriter) MapShards(wp *WritePointsRequest) (*ShardMapping, error)

+ func (w *PointsWriter) Open() error

+ func (w *PointsWriter) SetLogOutput(lw io.Writer)

+ func (w *PointsWriter) Statistics(tags map[string]string) []models.Statistic

+ func (w *PointsWriter) WritePoints(database, retentionPolicy string, consistencyLevel models.ConsistencyLevel, ...) error

+ func (w *PointsWriter) WritePointsInto(p *IntoWriteRequest) error

+ type ShardIteratorCreator interface

+ ShardIteratorCreator func(id uint64) influxql.IteratorCreator

+ type ShardMapping struct

+ Points map[uint64][]models.Point

+ Shards map[uint64]*meta.ShardInfo

+ func NewShardMapping() *ShardMapping

+ func (s *ShardMapping) MapPoint(shardInfo *meta.ShardInfo, p models.Point)

+ type StatementExecutor struct

+ MaxSelectBucketsN int

+ MaxSelectPointN int

+ MaxSelectSeriesN int

+ MetaClient MetaClient

+ Monitor *monitor.Monitor

+ PointsWriter pointsWriter

+ TSDBStore TSDBStore

+ TaskManager influxql.StatementExecutor

+ func (e *StatementExecutor) ExecuteStatement(stmt influxql.Statement, ctx influxql.ExecutionContext) error

+ func (e *StatementExecutor) NormalizeStatement(stmt influxql.Statement, defaultDatabase string) (err error)

+ type TSDBStore interface

+ BackupShard func(id uint64, since time.Time, w io.Writer) error

+ CreateShard func(database, policy string, shardID uint64, enabled bool) error

+ DeleteDatabase func(name string) error

+ DeleteMeasurement func(database, name string) error

+ DeleteRetentionPolicy func(database, name string) error

+ DeleteSeries func(database string, sources []influxql.Source, condition influxql.Expr) error

+ DeleteShard func(id uint64) error

+ IteratorCreator func(shards []meta.ShardInfo, opt *influxql.SelectOptions) (influxql.IteratorCreator, error)

+ Measurements func(database string, cond influxql.Expr) ([]string, error)

+ RestoreShard func(id uint64, r io.Reader) error

+ TagValues func(database string, cond influxql.Expr) ([]tsdb.TagValues, error)

+ WriteToShard func(shardID uint64, points []models.Point) error

+ type WritePointsRequest struct

+ Database string

+ Points []models.Point

+ RetentionPolicy string

+ func (w *WritePointsRequest) AddPoint(name string, value interface{}, timestamp time.Time, tags map[string]string)

+ type WriteStatistics struct

+ PointWriteReq int64

+ PointWriteReqLocal int64

+ SubWriteDrop int64

+ SubWriteOK int64

+ WriteDropped int64

+ WriteErr int64

+ WriteOK int64

+ WriteReq int64

+ WriteTimeout int64

Nov 16, 2014

Changes in this version

type ContinuousQueryWriter

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

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)

Sep 24, 2014

Changes in this version

type CoordinatorImpl

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

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

Sep 3, 2014

Changes in this version

type RaftServer

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

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