meta

package

Go to main page

Versions in this module

v0

v0.9.6

Dec 8, 2015

Changes in this version

+ const DefaultLoggingEnabled

type Config

+ LoggingEnabled bool

type Store

+ func (s *Store) CreateDatabaseWithRetentionPolicy(name string, rpi *RetentionPolicyInfo) (*DatabaseInfo, error)

v0.9.5

Nov 17, 2015

Changes in this version

+ const DefaultRaftPromotionEnabled

+ var ErrNodeIDRequired = newError("node id must be greater than 0")

+ var ErrNodeUnableToDropFinalNode = newError("unable to drop the final node in a cluster")

+ var ErrShardNotReplicated = newError("shard not replicated")

+ var ErrSubscriptionExists = newError("subscription already exists")

+ var ErrSubscriptionNotFound = newError("subscription not found")

type Config

+ RaftPromotionEnabled bool

type Data

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

+ func (data *Data) DropSubscription(database, rp, name string) error

+ type NodeInfos []NodeInfo

+ func (n NodeInfos) Len() int

+ func (n NodeInfos) Less(i, j int) bool

+ func (n NodeInfos) Swap(i, j int)

type RetentionPolicyInfo

+ Subscriptions []SubscriptionInfo

type Store

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

+ func (s *Store) DropSubscription(database, rp, name string) error

+ func (s *Store) IsLocal() bool

+ type SubscriptionInfo struct

+ Destinations []string

+ Mode string

+ Name string

v0.9.5-rc3

Nov 16, 2015

v0.9.5-rc1

Nov 12, 2015

v0.9.4

Sep 14, 2015

Changes in this version

+ var ErrRetentionPolicyDefault = errors.New("retention policy is default")

type DatabaseInfo

+ func (di DatabaseInfo) ShardInfos() []ShardInfo

type ShardInfo

+ Owners []ShardOwner

+ func (si *ShardInfo) UnmarshalBinary(buf []byte) error

+ type ShardOwner struct

+ NodeID uint64

v0.9.3

Aug 26, 2015

Changes in this version

+ const DefaultSyncNodeDelay

+ const MaxAutoCreatedRetentionPolicyReplicaN

+ const MaxMessageSize

+ const MaxRaftNodes

+ const MuxRPCHeader

+ var ErrReplicationFactorTooLow = errors.New("replication factor must be greater than 0")

type Config

+ ClusterTracing bool

+ type JoinResult struct

+ NodeID uint64

+ RaftEnabled bool

+ RaftNodes []string

+ type Reply interface

+ GetHeader func() *internal.ResponseHeader

type Store

+ RPCListener net.Listener

+ RemoteAddr net.Addr

+ func (s *Store) AddPeer(addr string) error

+ func (s *Store) Peers() ([]string, error)

+ func (s *Store) UpdateNode(id uint64, host string) (*NodeInfo, error)

+ func (s *Store) WaitForDataChanged() error

v0.9.3-rc3

Aug 25, 2015

v0.9.3-rc2

Aug 21, 2015

v0.9.3-rc1

Aug 19, 2015

v0.9.2

Jul 24, 2015

Changes in this version

type Data

+ func (data *Data) SetAdminPrivilege(name string, admin bool) error

+ func (data *Data) ShardGroupsByTimeRange(database, policy string, tmin, tmax time.Time) ([]ShardGroupInfo, error)

+ func (data *Data) UserPrivilege(name, database string) (*influxql.Privilege, error)

+ type ShardGroupInfos []ShardGroupInfo

+ func (a ShardGroupInfos) Len() int

+ func (a ShardGroupInfos) Less(i, j int) bool

+ func (a ShardGroupInfos) Swap(i, j int)

type ShardInfo

+ func (si ShardInfo) OwnedBy(nodeID uint64) bool

type Store

+ func (s *Store) SetAdminPrivilege(username string, admin bool) error

+ func (s *Store) ShardGroupsByTimeRange(database, policy string, tmin, tmax time.Time) (a []ShardGroupInfo, err error)

+ func (s *Store) UserPrivilege(username, database string) (p *influxql.Privilege, err error)

v0.9.1

Jul 2, 2015

Changes in this version

+ const AutoCreateRetentionPolicyName

+ const AutoCreateRetentionPolicyPeriod

+ const DefaultBindAddress

+ const DefaultCommitTimeout

+ const DefaultElectionTimeout

+ const DefaultHeartbeatTimeout

+ const DefaultHostname

+ const DefaultLeaderLeaseTimeout

+ const DefaultRetentionPolicyDuration

+ const DefaultRetentionPolicyReplicaN

+ const ExecMagic

+ const MinRetentionPolicyDuration

+ const MuxExecHeader

+ const MuxRaftHeader

+ const RetentionPolicyMinDuration

+ const SaltBytes

+ var BcryptCost = 10

+ var ErrAuthenticate = errors.New("authentication failed")

+ var ErrContinuousQueryExists = errors.New("continuous query already exists")

+ var ErrContinuousQueryNotFound = errors.New("continuous query not found")

+ var ErrDatabaseExists = errors.New("database already exists")

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

+ var ErrDatabaseNotFound = errors.New("database not found")

+ var ErrNodeExists = errors.New("node already exists")

+ var ErrNodeNotFound = errors.New("node not found")

+ var ErrNodesRequired = errors.New("at least one node required")

+ var ErrReplicationFactorMismatch = errors.New(...)

+ var ErrRetentionPolicyDurationTooLow = errors.New(...)

+ var ErrRetentionPolicyExists = errors.New("retention policy already exists")

+ var ErrRetentionPolicyNameExists = errors.New("retention policy name already exists")

+ var ErrRetentionPolicyNameRequired = errors.New("retention policy name required")

+ var ErrRetentionPolicyNotFound = errors.New("retention policy not found")

+ var ErrShardGroupExists = errors.New("shard group already exists")

+ var ErrShardGroupNotFound = errors.New("shard group not found")

+ var ErrStoreClosed = errors.New("raft store already closed")

+ var ErrStoreOpen = errors.New("store already open")

+ var ErrTooManyPeers = errors.New("too many peers; influxdb v0.9.0 is limited to 3 nodes in a cluster")

+ var ErrUserExists = errors.New("user already exists")

+ var ErrUserNotFound = errors.New("user not found")

+ var ErrUsernameRequired = errors.New("username required")

+ func MarshalTime(t time.Time) int64

+ func UnmarshalTime(v int64) time.Time

+ type AuthError struct

+ func NewAuthError(text string) AuthError

+ func (e AuthError) Error() string

+ type Config struct

+ BindAddress string

+ CommitTimeout toml.Duration

+ Dir string

+ ElectionTimeout toml.Duration

+ HeartbeatTimeout toml.Duration

+ Hostname string

+ LeaderLeaseTimeout toml.Duration

+ Peers []string

+ RetentionAutoCreate bool

+ func NewConfig() Config

+ type ContinuousQueryInfo struct

+ Name string

+ Query string

+ type Data struct

+ ClusterID uint64

+ Databases []DatabaseInfo

+ Index uint64

+ MaxNodeID uint64

+ MaxShardGroupID uint64

+ MaxShardID uint64

+ Nodes []NodeInfo

+ Term uint64

+ Users []UserInfo

+ func (data *Data) Clone() *Data

+ func (data *Data) CreateContinuousQuery(database, name, query string) error

+ func (data *Data) CreateDatabase(name string) error

+ func (data *Data) CreateNode(host string) error

+ func (data *Data) CreateRetentionPolicy(database string, rpi *RetentionPolicyInfo) error

+ func (data *Data) CreateShardGroup(database, policy string, timestamp time.Time) error

+ func (data *Data) CreateUser(name, hash string, admin bool) error

+ func (data *Data) Database(name string) *DatabaseInfo

+ func (data *Data) DeleteNode(id uint64) error

+ func (data *Data) DeleteShardGroup(database, policy string, id uint64) error

+ func (data *Data) DropContinuousQuery(database, name string) error

+ func (data *Data) DropDatabase(name string) error

+ func (data *Data) DropRetentionPolicy(database, name string) error

+ func (data *Data) DropUser(name string) error

+ func (data *Data) MarshalBinary() ([]byte, error)

+ func (data *Data) Node(id uint64) *NodeInfo

+ func (data *Data) NodeByHost(host string) *NodeInfo

+ func (data *Data) RetentionPolicy(database, name string) (*RetentionPolicyInfo, error)

+ func (data *Data) SetDefaultRetentionPolicy(database, name string) error

+ func (data *Data) SetPrivilege(name, database string, p influxql.Privilege) error

+ func (data *Data) ShardGroupByTimestamp(database, policy string, timestamp time.Time) (*ShardGroupInfo, error)

+ func (data *Data) ShardGroups(database, policy string) ([]ShardGroupInfo, error)

+ func (data *Data) UnmarshalBinary(buf []byte) error

+ func (data *Data) UpdateRetentionPolicy(database, name string, rpu *RetentionPolicyUpdate) error

+ func (data *Data) UpdateUser(name, hash string) error

+ func (data *Data) User(username string) *UserInfo

+ func (data *Data) UserPrivileges(name string) (map[string]influxql.Privilege, error)

+ type DatabaseInfo struct

+ ContinuousQueries []ContinuousQueryInfo

+ DefaultRetentionPolicy string

+ Name string

+ RetentionPolicies []RetentionPolicyInfo

+ func (di DatabaseInfo) RetentionPolicy(name string) *RetentionPolicyInfo

+ type HashPasswordFn func(password string) ([]byte, error)

+ type NodeInfo struct

+ Host string

+ ID uint64

+ type RetentionPolicyInfo struct

+ Duration time.Duration

+ Name string

+ ReplicaN int

+ ShardGroupDuration time.Duration

+ ShardGroups []ShardGroupInfo

+ func NewRetentionPolicyInfo(name string) *RetentionPolicyInfo

+ func (rpi *RetentionPolicyInfo) DeletedShardGroups() []*ShardGroupInfo

+ func (rpi *RetentionPolicyInfo) ExpiredShardGroups(t time.Time) []*ShardGroupInfo

+ func (rpi *RetentionPolicyInfo) ShardGroupByTimestamp(timestamp time.Time) *ShardGroupInfo

+ type RetentionPolicyUpdate struct

+ Duration *time.Duration

+ Name *string

+ ReplicaN *int

+ func (rpu *RetentionPolicyUpdate) SetDuration(v time.Duration)

+ func (rpu *RetentionPolicyUpdate) SetName(v string)

+ func (rpu *RetentionPolicyUpdate) SetReplicaN(v int)

+ type ShardGroupInfo struct

+ DeletedAt time.Time

+ EndTime time.Time

+ ID uint64

+ Shards []ShardInfo

+ StartTime time.Time

+ func (s *ShardGroupInfo) ShardFor(hash uint64) ShardInfo

+ func (sgi *ShardGroupInfo) Contains(timestamp time.Time) bool

+ func (sgi *ShardGroupInfo) Deleted() bool

+ func (sgi *ShardGroupInfo) Overlaps(min, max time.Time) bool

+ type ShardInfo struct

+ ID uint64

+ OwnerIDs []uint64

+ type StatementExecutor struct

+ Store interface{ ... }

+ func (e *StatementExecutor) ExecuteStatement(stmt influxql.Statement) *influxql.Result

+ type Store struct

+ Addr net.Addr

+ CommitTimeout time.Duration

+ ElectionTimeout time.Duration

+ ExecListener net.Listener

+ HeartbeatTimeout time.Duration

+ LeaderLeaseTimeout time.Duration

+ Logger *log.Logger

+ RaftListener net.Listener

+ func NewStore(c Config) *Store

+ func (s *Store) AdminUserExists() (exists bool, err error)

+ func (s *Store) Authenticate(username, password string) (ui *UserInfo, err error)

+ func (s *Store) Close() error

+ func (s *Store) ClusterID() (id uint64, err error)

+ func (s *Store) CreateContinuousQuery(database, name, query string) error

+ func (s *Store) CreateDatabase(name string) (*DatabaseInfo, error)

+ func (s *Store) CreateDatabaseIfNotExists(name string) (*DatabaseInfo, error)

+ func (s *Store) CreateNode(host string) (*NodeInfo, error)

+ func (s *Store) CreateRetentionPolicy(database string, rpi *RetentionPolicyInfo) (*RetentionPolicyInfo, error)

+ func (s *Store) CreateRetentionPolicyIfNotExists(database string, rpi *RetentionPolicyInfo) (*RetentionPolicyInfo, error)

+ func (s *Store) CreateShardGroup(database, policy string, timestamp time.Time) (*ShardGroupInfo, error)

+ func (s *Store) CreateShardGroupIfNotExists(database, policy string, timestamp time.Time) (*ShardGroupInfo, error)

+ func (s *Store) CreateUser(name, password string, admin bool) (*UserInfo, error)

+ func (s *Store) Database(name string) (di *DatabaseInfo, err error)

+ func (s *Store) Databases() (dis []DatabaseInfo, err error)

+ func (s *Store) DefaultRetentionPolicy(database string) (rpi *RetentionPolicyInfo, err error)

+ func (s *Store) DeleteNode(id uint64) error

+ func (s *Store) DeleteShardGroup(database, policy string, id uint64) error

+ func (s *Store) DropContinuousQuery(database, name string) error

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

+ func (s *Store) DropRetentionPolicy(database, name string) error

+ func (s *Store) DropUser(name string) error

+ func (s *Store) Err() <-chan error

+ func (s *Store) GetHashPasswordFn() HashPasswordFn

+ func (s *Store) IDPath() string

+ func (s *Store) IsLeader() bool

+ func (s *Store) Leader() string

+ func (s *Store) LeaderCh() <-chan bool

+ func (s *Store) MarshalBinary() ([]byte, error)

+ func (s *Store) Node(id uint64) (ni *NodeInfo, err error)

+ func (s *Store) NodeByHost(host string) (ni *NodeInfo, err error)

+ func (s *Store) NodeID() uint64

+ func (s *Store) Nodes() (a []NodeInfo, err error)

+ func (s *Store) Open() error

+ func (s *Store) Path() string

+ func (s *Store) PrecreateShardGroups(cutoff time.Time) error

+ func (s *Store) Ready() <-chan struct{}

+ func (s *Store) RetentionPolicies(database string) (a []RetentionPolicyInfo, err error)

+ func (s *Store) RetentionPolicy(database, name string) (rpi *RetentionPolicyInfo, err error)

+ func (s *Store) SetData(data *Data) error

+ func (s *Store) SetDefaultRetentionPolicy(database, name string) error

+ func (s *Store) SetHashPasswordFn(fn HashPasswordFn)

+ func (s *Store) SetPeers(addrs []string) error

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

+ func (s *Store) ShardGroupByTimestamp(database, policy string, timestamp time.Time) (sgi *ShardGroupInfo, err error)

+ func (s *Store) ShardGroups(database, policy string) (a []ShardGroupInfo, err error)

+ func (s *Store) ShardOwner(shardID uint64) (database, policy string, sgi *ShardGroupInfo)

+ func (s *Store) Snapshot() error

+ func (s *Store) UpdateRetentionPolicy(database, name string, rpu *RetentionPolicyUpdate) error

+ func (s *Store) UpdateUser(name, password string) error

+ func (s *Store) User(name string) (ui *UserInfo, err error)

+ func (s *Store) UserCount() (count int, err error)

+ func (s *Store) UserPrivileges(username string) (p map[string]influxql.Privilege, err error)

+ func (s *Store) Users() (a []UserInfo, err error)

+ func (s *Store) VisitRetentionPolicies(f func(d DatabaseInfo, r RetentionPolicyInfo))

+ func (s *Store) WaitForLeader(timeout time.Duration) error

+ type UserInfo struct

+ Admin bool

+ Hash string

+ Name string

+ Privileges map[string]influxql.Privilege

+ func (ui *UserInfo) Authorize(privilege influxql.Privilege, database string) bool

v0.9.1-rc2

Jul 1, 2015

v0.9.0-rc33

Jun 10, 2015

v0.9.0-rc32

Jun 7, 2015

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