meta

package

Go to main page

Versions in this module

v1

v1.0.0-beta2

Jun 20, 2016

v1.0.0-beta1

Jun 6, 2016

v0

v0.13.0-rc2

May 9, 2016

v0.13.0-rc1

May 5, 2016

v0.12.2

Apr 20, 2016

v0.12.1

Apr 7, 2016

Changes in this version

type Client

+ func (c *Client) Data() Data

v0.12.0

Apr 4, 2016

Changes in this version

+ func NewShardOwner(s ShardInfo, ownerFreqs map[int]int) (uint64, error)

type Client

+ func (c *Client) DropShard(id uint64) error

+ func (c *Client) Load() error

type Data

+ func (data *Data) CloneUsers() []UserInfo

+ func (data *Data) DropShard(id uint64)

type RetentionPolicyInfo

+ func (rpi *RetentionPolicyInfo) MarshalBinary() ([]byte, error)

+ func (rpi *RetentionPolicyInfo) UnmarshalBinary(data []byte) error

type RetentionPolicyUpdate

+ ShardGroupDuration *time.Duration

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

v0.11.1

Mar 31, 2016

v0.11.0

Mar 22, 2016

Changes in this version

+ func DefaultHost(hostname, addr string) (string, error)

type Client

+ func (c *Client) DataNodeByTCPHost(tcpAddr string) (*NodeInfo, error)

+ func (c *Client) MetaServers() []string

+ func (c *Client) SetMetaServers(a []string)

+ func (c *Client) SetTLS(v bool)

+ func (c *Client) ShardIDs() []uint64

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

type Config

+ RemoteHostname string

+ type ErrAuthorize struct

+ Database string

+ Message string

+ Query *influxql.Query

+ User string

+ func (e ErrAuthorize) Error() string

+ type Peers []string

+ func (peers Peers) Append(p ...string) Peers

+ func (peers Peers) Contains(peer string) bool

+ func (peers Peers) Unique() Peers

+ type QueryAuthorizer struct

+ Client *Client

+ func NewQueryAuthorizer(c *Client) *QueryAuthorizer

+ func (a *QueryAuthorizer) AuthorizeQuery(u *UserInfo, query *influxql.Query, database string) error

type Service

+ Node *influxdb.Node

+ Version string

v0.11.0-rc1

Mar 15, 2016

v0.10.3

Mar 9, 2016

v0.10.2

Mar 3, 2016

v0.10.1

Feb 18, 2016

Changes in this version

+ var ErrRetentionPolicyConflict = errors.New("retention policy conflicts with an existing policy")

v0.10.0

Feb 4, 2016

Changes in this version

+ const DefaultCommitTimeout

+ const DefaultElectionTimeout

+ const DefaultEnabled

+ const DefaultHTTPBindAddress

+ const DefaultHeartbeatTimeout

+ const DefaultHostname

+ const DefaultLeaderLeaseTimeout

+ const DefaultLeaseDuration

+ const DefaultLoggingEnabled

+ const DefaultRaftBindAddress

+ const DefaultRaftPromotionEnabled

+ const DefaultRetentionPolicyDuration

+ const DefaultRetentionPolicyReplicaN

+ const MinRetentionPolicyDuration

+ const MuxHeader

+ 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 ErrDatabaseNotExists = errors.New("database does not exist")

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

+ var ErrNodeIDRequired = errors.New("node id must be greater than 0")

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

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

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

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

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

+ 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 ErrService = errors.New("meta service error")

+ var ErrServiceUnavailable = errors.New("meta service unavailable")

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

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

+ var ErrShardNotReplicated = errors.New("shard not replicated")

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

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

+ var ErrSubscriptionExists = errors.New("subscription already exists")

+ var ErrSubscriptionNotFound = errors.New("subscription not found")

+ 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 Client struct

+ func NewClient(metaServers []string, tls bool) *Client

+ func (c *Client) AcquireLease(name string) (l *Lease, err error)

+ func (c *Client) AdminUserExists() bool

+ func (c *Client) Authenticate(username, password string) (*UserInfo, error)

+ func (c *Client) Close() error

+ func (c *Client) ClusterID() uint64

+ func (c *Client) CreateContinuousQuery(database, name, query string) error

+ func (c *Client) CreateDataNode(httpAddr, tcpAddr string) (*NodeInfo, error)

+ func (c *Client) CreateDatabase(name string) (*DatabaseInfo, error)

+ func (c *Client) CreateDatabaseWithRetentionPolicy(name string, rpi *RetentionPolicyInfo) (*DatabaseInfo, error)

+ func (c *Client) CreateMetaNode(httpAddr, tcpAddr string) (*NodeInfo, error)

+ func (c *Client) CreateRetentionPolicy(database string, rpi *RetentionPolicyInfo) (*RetentionPolicyInfo, error)

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

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

+ func (c *Client) CreateUser(name, password string, admin bool) (*UserInfo, error)

+ func (c *Client) DataNode(id uint64) (*NodeInfo, error)

+ func (c *Client) DataNodeByHTTPHost(httpAddr string) (*NodeInfo, error)

+ func (c *Client) DataNodes() ([]NodeInfo, error)

+ func (c *Client) Database(name string) (*DatabaseInfo, error)

+ func (c *Client) Databases() ([]DatabaseInfo, error)

+ func (c *Client) DeleteDataNode(id uint64) error

+ func (c *Client) DeleteMetaNode(id uint64) error

+ func (c *Client) DeleteShardGroup(database, policy string, id uint64) error

+ func (c *Client) DropContinuousQuery(database, name string) error

+ func (c *Client) DropDatabase(name string) error

+ func (c *Client) DropRetentionPolicy(database, name string) error

+ func (c *Client) DropSubscription(database, rp, name string) error

+ func (c *Client) DropUser(name string) error

+ func (c *Client) ExecuteStatement(stmt influxql.Statement) *influxql.Result

+ func (c *Client) GetHashPasswordFn() HashPasswordFn

+ func (c *Client) IsLeader() bool

+ func (c *Client) JoinMetaServer(httpAddr, tcpAddr string) error

+ func (c *Client) MarshalBinary() ([]byte, error)

+ func (c *Client) MetaNodeByAddr(addr string) *NodeInfo

+ func (c *Client) MetaNodes() ([]NodeInfo, error)

+ func (c *Client) NodeID() uint64

+ func (c *Client) Open() error

+ func (c *Client) Ping(checkAllMetaServers bool) error

+ func (c *Client) PrecreateShardGroups(from, to time.Time) error

+ func (c *Client) RetentionPolicy(database, name string) (rpi *RetentionPolicyInfo, err error)

+ func (c *Client) SetAdminPrivilege(username string, admin bool) error

+ func (c *Client) SetData(data *Data) error

+ func (c *Client) SetDefaultRetentionPolicy(database, name string) error

+ func (c *Client) SetHashPasswordFn(fn HashPasswordFn)

+ func (c *Client) SetLogger(l *log.Logger)

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

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

+ func (c *Client) ShardOwner(shardID uint64) (database, policy string, sgi *ShardGroupInfo)

+ func (c *Client) UpdateRetentionPolicy(database, name string, rpu *RetentionPolicyUpdate) error

+ func (c *Client) UpdateUser(name, password string) error

+ func (c *Client) User(name string) (*UserInfo, error)

+ func (c *Client) UserCount() int

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

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

+ func (c *Client) Users() []UserInfo

+ func (c *Client) WaitForDataChanged() chan struct{}

+ type Config struct

+ BindAddress string

+ ClusterTracing bool

+ CommitTimeout toml.Duration

+ Dir string

+ ElectionTimeout toml.Duration

+ Enabled bool

+ HTTPBindAddress string

+ HTTPSCertificate string

+ HTTPSEnabled bool

+ HeartbeatTimeout toml.Duration

+ JoinPeers []string

+ LeaderLeaseTimeout toml.Duration

+ LeaseDuration toml.Duration

+ LoggingEnabled bool

+ PprofEnabled bool

+ RaftPromotionEnabled bool

+ RetentionAutoCreate bool

+ func NewConfig() *Config

+ func (c *Config) DefaultedBindAddress() string

+ func (c *Config) DefaultedHTTPBindAddress() string

+ func (c *Config) Validate() error

+ type ContinuousQueryInfo struct

+ Name string

+ Query string

+ type Data struct

+ ClusterID uint64

+ DataNodes []NodeInfo

+ Databases []DatabaseInfo

+ Index uint64

+ MaxNodeID uint64

+ MaxShardGroupID uint64

+ MaxShardID uint64

+ MetaNodes []NodeInfo

+ Term uint64

+ Users []UserInfo

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

+ func (data *Data) CloneDatabases() []DatabaseInfo

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

+ func (data *Data) CreateDataNode(host, tcpHost string) error

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

+ func (data *Data) CreateMetaNode(httpAddr, tcpAddr 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) CreateSubscription(database, rp, name, mode string, destinations []string) error

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

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

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

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

+ func (data *Data) DeleteMetaNode(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) DropSubscription(database, rp, name string) error

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

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

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

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

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

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

+ func (data *Data) SetMetaNode(httpAddr, tcpAddr 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) ShardGroupsByTimeRange(database, policy string, tmin, tmax time.Time) ([]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) UserPrivilege(name, database string) (*influxql.Privilege, error)

+ 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

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

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

+ type Lease struct

+ Expiration time.Time

+ Name string

+ Owner uint64

+ type Leases struct

+ func NewLeases(d time.Duration) *Leases

+ func (leases *Leases) Acquire(name string, nodeID uint64) (*Lease, error)

+ type NodeInfo struct

+ Host string

+ ID uint64

+ TCPHost string

+ 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 struct

+ Duration time.Duration

+ Name string

+ ReplicaN int

+ ShardGroupDuration time.Duration

+ ShardGroups []ShardGroupInfo

+ Subscriptions []SubscriptionInfo

+ 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 Service struct

+ Logger *log.Logger

+ RaftListener net.Listener

+ func NewService(c *Config) *Service

+ func (s *Service) Close() error

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

+ func (s *Service) HTTPAddr() string

+ func (s *Service) Open() error

+ func (s *Service) RaftAddr() string

+ func (s *Service) SetLogger(l *log.Logger)

+ type ShardGroupInfo struct

+ DeletedAt time.Time

+ EndTime time.Time

+ ID uint64

+ Shards []ShardInfo

+ StartTime time.Time

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

+ func (sgi *ShardGroupInfo) Deleted() bool

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

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

+ 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 struct

+ ID uint64

+ Owners []ShardOwner

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

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

+ type ShardOwner struct

+ NodeID uint64

+ type StatementExecutor struct

+ Store interface{ ... }

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

+ type SubscriptionInfo struct

+ Destinations []string

+ Mode string

+ Name string

+ 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.10.0-rc2

Feb 2, 2016

v0.10.0-rc1

Jan 28, 2016

v0.10.0-beta2

Jan 23, 2016

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