client

Sep 5, 2014

Changes in this version

type Client

+ func (self *Client) UpdateShardSpace(database, name string, space *ShardSpace) error

Aug 22, 2014

Changes in this version

+ const UDPMaxMessageSize

+ type Client struct

+ func New(config *ClientConfig) (*Client, error)

+ func NewClient(config *ClientConfig) (*Client, error)

+ func (self *Client) AlterDatabasePrivilege(database, name string, isAdmin bool, permissions ...string) error

+ func (self *Client) AuthenticateClusterAdmin(username, password string) error

+ func (self *Client) AuthenticateDatabaseUser(database, username, password string) error

+ func (self *Client) ChangeClusterAdminPassword(name, newPassword string) error

+ func (self *Client) ChangeDatabaseUser(database, name, newPassword string, isAdmin bool, newPermissions ...string) error

+ func (self *Client) CreateClusterAdmin(name, password string) error

+ func (self *Client) CreateDatabase(name string) error

+ func (self *Client) CreateDatabaseUser(database, name, password string, permissions ...string) error

+ func (self *Client) CreateShardSpace(database string, space *ShardSpace) error

+ func (self *Client) DeleteClusterAdmin(name string) error

+ func (self *Client) DeleteContinuousQueries(id int) error

+ func (self *Client) DeleteDatabase(name string) error

+ func (self *Client) DeleteDatabaseUser(database, name string) error

+ func (self *Client) DisableCompression()

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

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

+ func (self *Client) GetClusterAdminList() ([]map[string]interface{}, error)

+ func (self *Client) GetContinuousQueries() ([]map[string]interface{}, error)

+ func (self *Client) GetDatabaseList() ([]map[string]interface{}, error)

+ func (self *Client) GetDatabaseUserList(database string) ([]map[string]interface{}, error)

+ func (self *Client) GetShardSpaces() ([]*ShardSpace, error)

+ func (self *Client) GetShards() (*LongTermShortTermShards, error)

+ func (self *Client) Ping() error

+ func (self *Client) Query(query string, precision ...TimePrecision) ([]*Series, error)

+ func (self *Client) QueryWithNumbers(query string, precision ...TimePrecision) ([]*Series, error)

+ func (self *Client) RemoveServer(id int) error

+ func (self *Client) Servers() ([]map[string]interface{}, error)

+ func (self *Client) UpdateClusterAdmin(name, password string) error

+ func (self *Client) UpdateDatabaseUser(database, name, password string) error

+ func (self *Client) UpdateDatabaseUserPermissions(database, name, readPermission, writePermissions string) error

+ func (self *Client) WriteSeries(series []*Series) error

+ func (self *Client) WriteSeriesOverUDP(series []*Series) error

+ func (self *Client) WriteSeriesWithTimePrecision(series []*Series, timePrecision TimePrecision) error

+ type ClientConfig struct

+ Database string

+ Host string

+ HttpClient *http.Client

+ IsSecure bool

+ IsUDP bool

+ Password string

+ Username string

+ type LongTermShortTermShards struct

+ All []*Shard

+ LongTerm []*Shard

+ ShortTerm []*Shard

+ type Series struct

+ Columns []string

+ Name string

+ Points [][]interface{}

+ func (self *Series) GetColumns() []string

+ func (self *Series) GetName() string

+ func (self *Series) GetPoints() [][]interface{}

+ type Shard struct

+ Database string

+ EndTime int64

+ Id uint32

+ ServerIds []uint32

+ SpaceName string

+ StartTime int64

+ type ShardSpace struct

+ Database string

+ Name string

+ Regex string

+ ReplicationFactor uint32

+ RetentionPolicy string

+ ShardDuration string

+ Split uint32

+ type ShardSpaceCollection struct

+ ShardSpaces []ShardSpace

+ type TimePrecision string

+ const Microsecond

+ const Millisecond

+ const Second