Versions in this module Expand all Collapse all v0 v0.9.4-rc1 Sep 10, 2015 v0.9.3 Aug 26, 2015 Changes in this version + const Default_FetchDataRequest_Blocking + var E_UpdateNodeCommand_Command = &proto.ExtensionDesc + var RPCType_name = map[int32]string + var RPCType_value = map[string]int32 type Command_Type + const Command_UpdateNodeCommand + type ErrorResponse struct + Header *ResponseHeader + XXX_unrecognized []byte + func (*ErrorResponse) ProtoMessage() + func (m *ErrorResponse) GetHeader() *ResponseHeader + func (m *ErrorResponse) Reset() + func (m *ErrorResponse) String() string + type FetchDataRequest struct + Blocking *bool + Index *uint64 + Term *uint64 + XXX_unrecognized []byte + func (*FetchDataRequest) ProtoMessage() + func (m *FetchDataRequest) GetBlocking() bool + func (m *FetchDataRequest) GetIndex() uint64 + func (m *FetchDataRequest) GetTerm() uint64 + func (m *FetchDataRequest) Reset() + func (m *FetchDataRequest) String() string + type FetchDataResponse struct + Data []byte + Header *ResponseHeader + Index *uint64 + Term *uint64 + XXX_unrecognized []byte + func (*FetchDataResponse) ProtoMessage() + func (m *FetchDataResponse) GetData() []byte + func (m *FetchDataResponse) GetHeader() *ResponseHeader + func (m *FetchDataResponse) GetIndex() uint64 + func (m *FetchDataResponse) GetTerm() uint64 + func (m *FetchDataResponse) Reset() + func (m *FetchDataResponse) String() string + type JoinRequest struct + Addr *string + XXX_unrecognized []byte + func (*JoinRequest) ProtoMessage() + func (m *JoinRequest) GetAddr() string + func (m *JoinRequest) Reset() + func (m *JoinRequest) String() string + type JoinResponse struct + EnableRaft *bool + Header *ResponseHeader + NodeID *uint64 + RaftNodes []string + XXX_unrecognized []byte + func (*JoinResponse) ProtoMessage() + func (m *JoinResponse) GetEnableRaft() bool + func (m *JoinResponse) GetHeader() *ResponseHeader + func (m *JoinResponse) GetNodeID() uint64 + func (m *JoinResponse) GetRaftNodes() []string + func (m *JoinResponse) Reset() + func (m *JoinResponse) String() string + type RPCType int32 + const RPCType_Error + const RPCType_FetchData + const RPCType_Join + func (x *RPCType) UnmarshalJSON(data []byte) error + func (x RPCType) Enum() *RPCType + func (x RPCType) String() string + type ResponseHeader struct + Error *string + OK *bool + XXX_unrecognized []byte + func (*ResponseHeader) ProtoMessage() + func (m *ResponseHeader) GetError() string + func (m *ResponseHeader) GetOK() bool + func (m *ResponseHeader) Reset() + func (m *ResponseHeader) String() string + type UpdateNodeCommand struct + Host *string + ID *uint64 + XXX_unrecognized []byte + func (*UpdateNodeCommand) ProtoMessage() + func (m *UpdateNodeCommand) GetHost() string + func (m *UpdateNodeCommand) GetID() uint64 + func (m *UpdateNodeCommand) Reset() + func (m *UpdateNodeCommand) String() string 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 + var E_SetAdminPrivilegeCommand_Command = &proto.ExtensionDesc type Command_Type + const Command_SetAdminPrivilegeCommand + type SetAdminPrivilegeCommand struct + Admin *bool + Username *string + XXX_unrecognized []byte + func (*SetAdminPrivilegeCommand) ProtoMessage() + func (m *SetAdminPrivilegeCommand) GetAdmin() bool + func (m *SetAdminPrivilegeCommand) GetUsername() string + func (m *SetAdminPrivilegeCommand) Reset() + func (m *SetAdminPrivilegeCommand) String() string v0.9.2-rc1 Jul 17, 2015 v0.9.1 Jul 2, 2015 v0.9.1-rc2 Jul 1, 2015 v0.9.1-rc1 Jun 26, 2015 v0.9.0 Jun 11, 2015 Changes in this version + var Command_Type_name = map[int32]string + var Command_Type_value = map[string]int32 + var E_CreateContinuousQueryCommand_Command = &proto.ExtensionDesc + var E_CreateDatabaseCommand_Command = &proto.ExtensionDesc + var E_CreateNodeCommand_Command = &proto.ExtensionDesc + var E_CreateRetentionPolicyCommand_Command = &proto.ExtensionDesc + var E_CreateShardGroupCommand_Command = &proto.ExtensionDesc + var E_CreateUserCommand_Command = &proto.ExtensionDesc + var E_DeleteNodeCommand_Command = &proto.ExtensionDesc + var E_DeleteShardGroupCommand_Command = &proto.ExtensionDesc + var E_DropContinuousQueryCommand_Command = &proto.ExtensionDesc + var E_DropDatabaseCommand_Command = &proto.ExtensionDesc + var E_DropRetentionPolicyCommand_Command = &proto.ExtensionDesc + var E_DropUserCommand_Command = &proto.ExtensionDesc + var E_SetDataCommand_Command = &proto.ExtensionDesc + var E_SetDefaultRetentionPolicyCommand_Command = &proto.ExtensionDesc + var E_SetPrivilegeCommand_Command = &proto.ExtensionDesc + var E_UpdateRetentionPolicyCommand_Command = &proto.ExtensionDesc + var E_UpdateUserCommand_Command = &proto.ExtensionDesc + type Command struct + Type *Command_Type + XXX_extensions map[int32]proto.Extension + XXX_unrecognized []byte + func (*Command) ExtensionRangeArray() []proto.ExtensionRange + func (*Command) ProtoMessage() + func (m *Command) ExtensionMap() map[int32]proto.Extension + func (m *Command) GetType() Command_Type + func (m *Command) Reset() + func (m *Command) String() string + type Command_Type int32 + const Command_CreateContinuousQueryCommand + const Command_CreateDatabaseCommand + const Command_CreateNodeCommand + const Command_CreateRetentionPolicyCommand + const Command_CreateShardGroupCommand + const Command_CreateUserCommand + const Command_DeleteNodeCommand + const Command_DeleteShardGroupCommand + const Command_DropContinuousQueryCommand + const Command_DropDatabaseCommand + const Command_DropRetentionPolicyCommand + const Command_DropUserCommand + const Command_SetDataCommand + const Command_SetDefaultRetentionPolicyCommand + const Command_SetPrivilegeCommand + const Command_UpdateRetentionPolicyCommand + const Command_UpdateUserCommand + func (x *Command_Type) UnmarshalJSON(data []byte) error + func (x Command_Type) Enum() *Command_Type + func (x Command_Type) String() string + type ContinuousQueryInfo struct + Name *string + Query *string + XXX_unrecognized []byte + func (*ContinuousQueryInfo) ProtoMessage() + func (m *ContinuousQueryInfo) GetName() string + func (m *ContinuousQueryInfo) GetQuery() string + func (m *ContinuousQueryInfo) Reset() + func (m *ContinuousQueryInfo) String() string + type CreateContinuousQueryCommand struct + Database *string + Name *string + Query *string + XXX_unrecognized []byte + func (*CreateContinuousQueryCommand) ProtoMessage() + func (m *CreateContinuousQueryCommand) GetDatabase() string + func (m *CreateContinuousQueryCommand) GetName() string + func (m *CreateContinuousQueryCommand) GetQuery() string + func (m *CreateContinuousQueryCommand) Reset() + func (m *CreateContinuousQueryCommand) String() string + type CreateDatabaseCommand struct + Name *string + XXX_unrecognized []byte + func (*CreateDatabaseCommand) ProtoMessage() + func (m *CreateDatabaseCommand) GetName() string + func (m *CreateDatabaseCommand) Reset() + func (m *CreateDatabaseCommand) String() string + type CreateNodeCommand struct + Host *string + Rand *uint64 + XXX_unrecognized []byte + func (*CreateNodeCommand) ProtoMessage() + func (m *CreateNodeCommand) GetHost() string + func (m *CreateNodeCommand) GetRand() uint64 + func (m *CreateNodeCommand) Reset() + func (m *CreateNodeCommand) String() string + type CreateRetentionPolicyCommand struct + Database *string + RetentionPolicy *RetentionPolicyInfo + XXX_unrecognized []byte + func (*CreateRetentionPolicyCommand) ProtoMessage() + func (m *CreateRetentionPolicyCommand) GetDatabase() string + func (m *CreateRetentionPolicyCommand) GetRetentionPolicy() *RetentionPolicyInfo + func (m *CreateRetentionPolicyCommand) Reset() + func (m *CreateRetentionPolicyCommand) String() string + type CreateShardGroupCommand struct + Database *string + Policy *string + Timestamp *int64 + XXX_unrecognized []byte + func (*CreateShardGroupCommand) ProtoMessage() + func (m *CreateShardGroupCommand) GetDatabase() string + func (m *CreateShardGroupCommand) GetPolicy() string + func (m *CreateShardGroupCommand) GetTimestamp() int64 + func (m *CreateShardGroupCommand) Reset() + func (m *CreateShardGroupCommand) String() string + type CreateUserCommand struct + Admin *bool + Hash *string + Name *string + XXX_unrecognized []byte + func (*CreateUserCommand) ProtoMessage() + func (m *CreateUserCommand) GetAdmin() bool + func (m *CreateUserCommand) GetHash() string + func (m *CreateUserCommand) GetName() string + func (m *CreateUserCommand) Reset() + func (m *CreateUserCommand) String() string + type Data struct + ClusterID *uint64 + Databases []*DatabaseInfo + Index *uint64 + MaxNodeID *uint64 + MaxShardGroupID *uint64 + MaxShardID *uint64 + Nodes []*NodeInfo + Term *uint64 + Users []*UserInfo + XXX_unrecognized []byte + func (*Data) ProtoMessage() + func (m *Data) GetClusterID() uint64 + func (m *Data) GetDatabases() []*DatabaseInfo + func (m *Data) GetIndex() uint64 + func (m *Data) GetMaxNodeID() uint64 + func (m *Data) GetMaxShardGroupID() uint64 + func (m *Data) GetMaxShardID() uint64 + func (m *Data) GetNodes() []*NodeInfo + func (m *Data) GetTerm() uint64 + func (m *Data) GetUsers() []*UserInfo + func (m *Data) Reset() + func (m *Data) String() string + type DatabaseInfo struct + ContinuousQueries []*ContinuousQueryInfo + DefaultRetentionPolicy *string + Name *string + RetentionPolicies []*RetentionPolicyInfo + XXX_unrecognized []byte + func (*DatabaseInfo) ProtoMessage() + func (m *DatabaseInfo) GetContinuousQueries() []*ContinuousQueryInfo + func (m *DatabaseInfo) GetDefaultRetentionPolicy() string + func (m *DatabaseInfo) GetName() string + func (m *DatabaseInfo) GetRetentionPolicies() []*RetentionPolicyInfo + func (m *DatabaseInfo) Reset() + func (m *DatabaseInfo) String() string + type DeleteNodeCommand struct + ID *uint64 + XXX_unrecognized []byte + func (*DeleteNodeCommand) ProtoMessage() + func (m *DeleteNodeCommand) GetID() uint64 + func (m *DeleteNodeCommand) Reset() + func (m *DeleteNodeCommand) String() string + type DeleteShardGroupCommand struct + Database *string + Policy *string + ShardGroupID *uint64 + XXX_unrecognized []byte + func (*DeleteShardGroupCommand) ProtoMessage() + func (m *DeleteShardGroupCommand) GetDatabase() string + func (m *DeleteShardGroupCommand) GetPolicy() string + func (m *DeleteShardGroupCommand) GetShardGroupID() uint64 + func (m *DeleteShardGroupCommand) Reset() + func (m *DeleteShardGroupCommand) String() string + type DropContinuousQueryCommand struct + Database *string + Name *string + XXX_unrecognized []byte + func (*DropContinuousQueryCommand) ProtoMessage() + func (m *DropContinuousQueryCommand) GetDatabase() string + func (m *DropContinuousQueryCommand) GetName() string + func (m *DropContinuousQueryCommand) Reset() + func (m *DropContinuousQueryCommand) String() string + type DropDatabaseCommand struct + Name *string + XXX_unrecognized []byte + func (*DropDatabaseCommand) ProtoMessage() + func (m *DropDatabaseCommand) GetName() string + func (m *DropDatabaseCommand) Reset() + func (m *DropDatabaseCommand) String() string + type DropRetentionPolicyCommand struct + Database *string + Name *string + XXX_unrecognized []byte + func (*DropRetentionPolicyCommand) ProtoMessage() + func (m *DropRetentionPolicyCommand) GetDatabase() string + func (m *DropRetentionPolicyCommand) GetName() string + func (m *DropRetentionPolicyCommand) Reset() + func (m *DropRetentionPolicyCommand) String() string + type DropUserCommand struct + Name *string + XXX_unrecognized []byte + func (*DropUserCommand) ProtoMessage() + func (m *DropUserCommand) GetName() string + func (m *DropUserCommand) Reset() + func (m *DropUserCommand) String() string + type NodeInfo struct + Host *string + ID *uint64 + XXX_unrecognized []byte + func (*NodeInfo) ProtoMessage() + func (m *NodeInfo) GetHost() string + func (m *NodeInfo) GetID() uint64 + func (m *NodeInfo) Reset() + func (m *NodeInfo) String() string + type Response struct + Error *string + Index *uint64 + OK *bool + XXX_unrecognized []byte + func (*Response) ProtoMessage() + func (m *Response) GetError() string + func (m *Response) GetIndex() uint64 + func (m *Response) GetOK() bool + func (m *Response) Reset() + func (m *Response) String() string + type RetentionPolicyInfo struct + Duration *int64 + Name *string + ReplicaN *uint32 + ShardGroupDuration *int64 + ShardGroups []*ShardGroupInfo + XXX_unrecognized []byte + func (*RetentionPolicyInfo) ProtoMessage() + func (m *RetentionPolicyInfo) GetDuration() int64 + func (m *RetentionPolicyInfo) GetName() string + func (m *RetentionPolicyInfo) GetReplicaN() uint32 + func (m *RetentionPolicyInfo) GetShardGroupDuration() int64 + func (m *RetentionPolicyInfo) GetShardGroups() []*ShardGroupInfo + func (m *RetentionPolicyInfo) Reset() + func (m *RetentionPolicyInfo) String() string + type SetDataCommand struct + Data *Data + XXX_unrecognized []byte + func (*SetDataCommand) ProtoMessage() + func (m *SetDataCommand) GetData() *Data + func (m *SetDataCommand) Reset() + func (m *SetDataCommand) String() string + type SetDefaultRetentionPolicyCommand struct + Database *string + Name *string + XXX_unrecognized []byte + func (*SetDefaultRetentionPolicyCommand) ProtoMessage() + func (m *SetDefaultRetentionPolicyCommand) GetDatabase() string + func (m *SetDefaultRetentionPolicyCommand) GetName() string + func (m *SetDefaultRetentionPolicyCommand) Reset() + func (m *SetDefaultRetentionPolicyCommand) String() string + type SetPrivilegeCommand struct + Database *string + Privilege *int32 + Username *string + XXX_unrecognized []byte + func (*SetPrivilegeCommand) ProtoMessage() + func (m *SetPrivilegeCommand) GetDatabase() string + func (m *SetPrivilegeCommand) GetPrivilege() int32 + func (m *SetPrivilegeCommand) GetUsername() string + func (m *SetPrivilegeCommand) Reset() + func (m *SetPrivilegeCommand) String() string + type ShardGroupInfo struct + DeletedAt *int64 + EndTime *int64 + ID *uint64 + Shards []*ShardInfo + StartTime *int64 + XXX_unrecognized []byte + func (*ShardGroupInfo) ProtoMessage() + func (m *ShardGroupInfo) GetDeletedAt() int64 + func (m *ShardGroupInfo) GetEndTime() int64 + func (m *ShardGroupInfo) GetID() uint64 + func (m *ShardGroupInfo) GetShards() []*ShardInfo + func (m *ShardGroupInfo) GetStartTime() int64 + func (m *ShardGroupInfo) Reset() + func (m *ShardGroupInfo) String() string + type ShardInfo struct + ID *uint64 + OwnerIDs []uint64 + XXX_unrecognized []byte + func (*ShardInfo) ProtoMessage() + func (m *ShardInfo) GetID() uint64 + func (m *ShardInfo) GetOwnerIDs() []uint64 + func (m *ShardInfo) Reset() + func (m *ShardInfo) String() string + type UpdateRetentionPolicyCommand struct + Database *string + Duration *int64 + Name *string + NewName *string + ReplicaN *uint32 + XXX_unrecognized []byte + func (*UpdateRetentionPolicyCommand) ProtoMessage() + func (m *UpdateRetentionPolicyCommand) GetDatabase() string + func (m *UpdateRetentionPolicyCommand) GetDuration() int64 + func (m *UpdateRetentionPolicyCommand) GetName() string + func (m *UpdateRetentionPolicyCommand) GetNewName() string + func (m *UpdateRetentionPolicyCommand) GetReplicaN() uint32 + func (m *UpdateRetentionPolicyCommand) Reset() + func (m *UpdateRetentionPolicyCommand) String() string + type UpdateUserCommand struct + Hash *string + Name *string + XXX_unrecognized []byte + func (*UpdateUserCommand) ProtoMessage() + func (m *UpdateUserCommand) GetHash() string + func (m *UpdateUserCommand) GetName() string + func (m *UpdateUserCommand) Reset() + func (m *UpdateUserCommand) String() string + type UserInfo struct + Admin *bool + Hash *string + Name *string + Privileges []*UserPrivilege + XXX_unrecognized []byte + func (*UserInfo) ProtoMessage() + func (m *UserInfo) GetAdmin() bool + func (m *UserInfo) GetHash() string + func (m *UserInfo) GetName() string + func (m *UserInfo) GetPrivileges() []*UserPrivilege + func (m *UserInfo) Reset() + func (m *UserInfo) String() string + type UserPrivilege struct + Database *string + Privilege *int32 + XXX_unrecognized []byte + func (*UserPrivilege) ProtoMessage() + func (m *UserPrivilege) GetDatabase() string + func (m *UserPrivilege) GetPrivilege() int32 + func (m *UserPrivilege) Reset() + func (m *UserPrivilege) String() string v0.9.0-rc33 Jun 10, 2015 v0.9.0-rc32 Jun 7, 2015
Go to main page