internal

package
v0.0.0-...-2df1f68 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 30, 2015 License: MIT Imports: 2 Imported by: 0

Documentation

Overview

Package internal is a generated protocol buffer package.

It is generated from these files: 

internal/meta.proto

It has these top-level messages: 

Data
NodeInfo
DatabaseInfo
RetentionPolicyInfo
ShardGroupInfo
ShardInfo
ContinuousQueryInfo
UserInfo
UserPrivilege
Command
CreateNodeCommand
DeleteNodeCommand
CreateDatabaseCommand
DropDatabaseCommand
CreateRetentionPolicyCommand
DropRetentionPolicyCommand
SetDefaultRetentionPolicyCommand
UpdateRetentionPolicyCommand
CreateShardGroupCommand
DeleteShardGroupCommand
CreateContinuousQueryCommand
DropContinuousQueryCommand
CreateUserCommand
DropUserCommand
UpdateUserCommand
SetPrivilegeCommand
SetDataCommand
SetAdminPrivilegeCommand
UpdateNodeCommand
Response
ResponseHeader
ErrorResponse
FetchDataRequest
FetchDataResponse
JoinRequest
JoinResponse

Index

Constants

View Source 
const Default_FetchDataRequest_Blocking bool = false

Variables

View Source 
var Command_Type_name = map[int32]string{
	1:  "CreateNodeCommand",
	2:  "DeleteNodeCommand",
	3:  "CreateDatabaseCommand",
	4:  "DropDatabaseCommand",
	5:  "CreateRetentionPolicyCommand",
	6:  "DropRetentionPolicyCommand",
	7:  "SetDefaultRetentionPolicyCommand",
	8:  "UpdateRetentionPolicyCommand",
	9:  "CreateShardGroupCommand",
	10: "DeleteShardGroupCommand",
	11: "CreateContinuousQueryCommand",
	12: "DropContinuousQueryCommand",
	13: "CreateUserCommand",
	14: "DropUserCommand",
	15: "UpdateUserCommand",
	16: "SetPrivilegeCommand",
	17: "SetDataCommand",
	18: "SetAdminPrivilegeCommand",
	19: "UpdateNodeCommand",
}
View Source 
var Command_Type_value = map[string]int32{
	"CreateNodeCommand":                1,
	"DeleteNodeCommand":                2,
	"CreateDatabaseCommand":            3,
	"DropDatabaseCommand":              4,
	"CreateRetentionPolicyCommand":     5,
	"DropRetentionPolicyCommand":       6,
	"SetDefaultRetentionPolicyCommand": 7,
	"UpdateRetentionPolicyCommand":     8,
	"CreateShardGroupCommand":          9,
	"DeleteShardGroupCommand":          10,
	"CreateContinuousQueryCommand":     11,
	"DropContinuousQueryCommand":       12,
	"CreateUserCommand":                13,
	"DropUserCommand":                  14,
	"UpdateUserCommand":                15,
	"SetPrivilegeCommand":              16,
	"SetDataCommand":                   17,
	"SetAdminPrivilegeCommand":         18,
	"UpdateNodeCommand":                19,
}
View Source 
var E_CreateContinuousQueryCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*CreateContinuousQueryCommand)(nil),
	Field:         111,
	Name:          "internal.CreateContinuousQueryCommand.command",
	Tag:           "bytes,111,opt,name=command",
}
View Source 
var E_CreateDatabaseCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*CreateDatabaseCommand)(nil),
	Field:         103,
	Name:          "internal.CreateDatabaseCommand.command",
	Tag:           "bytes,103,opt,name=command",
}
View Source 
var E_CreateNodeCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*CreateNodeCommand)(nil),
	Field:         101,
	Name:          "internal.CreateNodeCommand.command",
	Tag:           "bytes,101,opt,name=command",
}
View Source 
var E_CreateRetentionPolicyCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*CreateRetentionPolicyCommand)(nil),
	Field:         105,
	Name:          "internal.CreateRetentionPolicyCommand.command",
	Tag:           "bytes,105,opt,name=command",
}
View Source 
var E_CreateShardGroupCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*CreateShardGroupCommand)(nil),
	Field:         109,
	Name:          "internal.CreateShardGroupCommand.command",
	Tag:           "bytes,109,opt,name=command",
}
View Source 
var E_CreateUserCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*CreateUserCommand)(nil),
	Field:         113,
	Name:          "internal.CreateUserCommand.command",
	Tag:           "bytes,113,opt,name=command",
}
View Source 
var E_DeleteNodeCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*DeleteNodeCommand)(nil),
	Field:         102,
	Name:          "internal.DeleteNodeCommand.command",
	Tag:           "bytes,102,opt,name=command",
}
View Source 
var E_DeleteShardGroupCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*DeleteShardGroupCommand)(nil),
	Field:         110,
	Name:          "internal.DeleteShardGroupCommand.command",
	Tag:           "bytes,110,opt,name=command",
}
View Source 
var E_DropContinuousQueryCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*DropContinuousQueryCommand)(nil),
	Field:         112,
	Name:          "internal.DropContinuousQueryCommand.command",
	Tag:           "bytes,112,opt,name=command",
}
View Source 
var E_DropDatabaseCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*DropDatabaseCommand)(nil),
	Field:         104,
	Name:          "internal.DropDatabaseCommand.command",
	Tag:           "bytes,104,opt,name=command",
}
View Source 
var E_DropRetentionPolicyCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*DropRetentionPolicyCommand)(nil),
	Field:         106,
	Name:          "internal.DropRetentionPolicyCommand.command",
	Tag:           "bytes,106,opt,name=command",
}
View Source 
var E_DropUserCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*DropUserCommand)(nil),
	Field:         114,
	Name:          "internal.DropUserCommand.command",
	Tag:           "bytes,114,opt,name=command",
}
View Source 
var E_SetAdminPrivilegeCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*SetAdminPrivilegeCommand)(nil),
	Field:         118,
	Name:          "internal.SetAdminPrivilegeCommand.command",
	Tag:           "bytes,118,opt,name=command",
}
View Source 
var E_SetDataCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*SetDataCommand)(nil),
	Field:         117,
	Name:          "internal.SetDataCommand.command",
	Tag:           "bytes,117,opt,name=command",
}
View Source 
var E_SetDefaultRetentionPolicyCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*SetDefaultRetentionPolicyCommand)(nil),
	Field:         107,
	Name:          "internal.SetDefaultRetentionPolicyCommand.command",
	Tag:           "bytes,107,opt,name=command",
}
View Source 
var E_SetPrivilegeCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*SetPrivilegeCommand)(nil),
	Field:         116,
	Name:          "internal.SetPrivilegeCommand.command",
	Tag:           "bytes,116,opt,name=command",
}
View Source 
var E_UpdateNodeCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*UpdateNodeCommand)(nil),
	Field:         119,
	Name:          "internal.UpdateNodeCommand.command",
	Tag:           "bytes,119,opt,name=command",
}
View Source 
var E_UpdateRetentionPolicyCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*UpdateRetentionPolicyCommand)(nil),
	Field:         108,
	Name:          "internal.UpdateRetentionPolicyCommand.command",
	Tag:           "bytes,108,opt,name=command",
}
View Source 
var E_UpdateUserCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*UpdateUserCommand)(nil),
	Field:         115,
	Name:          "internal.UpdateUserCommand.command",
	Tag:           "bytes,115,opt,name=command",
}
View Source 
var RPCType_name = map[int32]string{
	1: "Error",
	2: "FetchData",
	3: "Join",
}
View Source 
var RPCType_value = map[string]int32{
	"Error":     1,
	"FetchData": 2,
	"Join":      3,
}

Functions

This section is empty.

Types

type Command 

type Command struct {
	Type             *Command_Type             `protobuf:"varint,1,req,name=type,enum=internal.Command_Type" json:"type,omitempty"`
	XXX_extensions   map[int32]proto.Extension `json:"-"`
	XXX_unrecognized []byte                    `json:"-"`
}

func (*Command) ExtensionMap 

func (m *Command) ExtensionMap() map[int32]proto.Extension

func (*Command) ExtensionRangeArray 

func (*Command) ExtensionRangeArray() []proto.ExtensionRange

func (*Command) GetType 

func (m *Command) GetType() Command_Type

func (*Command) ProtoMessage 

func (*Command) ProtoMessage()

func (*Command) Reset 

func (m *Command) Reset()

func (*Command) String 

func (m *Command) String() string

type Command_Type 

type Command_Type int32
const (
	Command_CreateNodeCommand                Command_Type = 1
	Command_DeleteNodeCommand                Command_Type = 2
	Command_CreateDatabaseCommand            Command_Type = 3
	Command_DropDatabaseCommand              Command_Type = 4
	Command_CreateRetentionPolicyCommand     Command_Type = 5
	Command_DropRetentionPolicyCommand       Command_Type = 6
	Command_SetDefaultRetentionPolicyCommand Command_Type = 7
	Command_UpdateRetentionPolicyCommand     Command_Type = 8
	Command_CreateShardGroupCommand          Command_Type = 9
	Command_DeleteShardGroupCommand          Command_Type = 10
	Command_CreateContinuousQueryCommand     Command_Type = 11
	Command_DropContinuousQueryCommand       Command_Type = 12
	Command_CreateUserCommand                Command_Type = 13
	Command_DropUserCommand                  Command_Type = 14
	Command_UpdateUserCommand                Command_Type = 15
	Command_SetPrivilegeCommand              Command_Type = 16
	Command_SetDataCommand                   Command_Type = 17
	Command_SetAdminPrivilegeCommand         Command_Type = 18
	Command_UpdateNodeCommand                Command_Type = 19
)

func (Command_Type) Enum 

func (x Command_Type) Enum() *Command_Type

func (Command_Type) String 

func (x Command_Type) String() string

func (*Command_Type) UnmarshalJSON 

func (x *Command_Type) UnmarshalJSON(data []byte) error

type ContinuousQueryInfo 

type ContinuousQueryInfo struct {
	Name             *string `protobuf:"bytes,1,req" json:"Name,omitempty"`
	Query            *string `protobuf:"bytes,2,req" json:"Query,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ContinuousQueryInfo) GetName 

func (m *ContinuousQueryInfo) GetName() string

func (*ContinuousQueryInfo) GetQuery 

func (m *ContinuousQueryInfo) GetQuery() string

func (*ContinuousQueryInfo) ProtoMessage 

func (*ContinuousQueryInfo) ProtoMessage()

func (*ContinuousQueryInfo) Reset 

func (m *ContinuousQueryInfo) Reset()

func (*ContinuousQueryInfo) String 

func (m *ContinuousQueryInfo) String() string

type CreateContinuousQueryCommand 

type CreateContinuousQueryCommand struct {
	Database         *string `protobuf:"bytes,1,req" json:"Database,omitempty"`
	Name             *string `protobuf:"bytes,2,req" json:"Name,omitempty"`
	Query            *string `protobuf:"bytes,3,req" json:"Query,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*CreateContinuousQueryCommand) GetDatabase 

func (m *CreateContinuousQueryCommand) GetDatabase() string

func (*CreateContinuousQueryCommand) GetName 

func (m *CreateContinuousQueryCommand) GetName() string

func (*CreateContinuousQueryCommand) GetQuery 

func (m *CreateContinuousQueryCommand) GetQuery() string

func (*CreateContinuousQueryCommand) ProtoMessage 

func (*CreateContinuousQueryCommand) ProtoMessage()

func (*CreateContinuousQueryCommand) Reset 

func (m *CreateContinuousQueryCommand) Reset()

func (*CreateContinuousQueryCommand) String 

func (m *CreateContinuousQueryCommand) String() string

type CreateDatabaseCommand 

type CreateDatabaseCommand struct {
	Name             *string `protobuf:"bytes,1,req" json:"Name,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*CreateDatabaseCommand) GetName 

func (m *CreateDatabaseCommand) GetName() string

func (*CreateDatabaseCommand) ProtoMessage 

func (*CreateDatabaseCommand) ProtoMessage()

func (*CreateDatabaseCommand) Reset 

func (m *CreateDatabaseCommand) Reset()

func (*CreateDatabaseCommand) String 

func (m *CreateDatabaseCommand) String() string

type CreateNodeCommand 

type CreateNodeCommand struct {
	Host             *string `protobuf:"bytes,1,req" json:"Host,omitempty"`
	Rand             *uint64 `protobuf:"varint,2,req" json:"Rand,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*CreateNodeCommand) GetHost 

func (m *CreateNodeCommand) GetHost() string

func (*CreateNodeCommand) GetRand 

func (m *CreateNodeCommand) GetRand() uint64

func (*CreateNodeCommand) ProtoMessage 

func (*CreateNodeCommand) ProtoMessage()

func (*CreateNodeCommand) Reset 

func (m *CreateNodeCommand) Reset()

func (*CreateNodeCommand) String 

func (m *CreateNodeCommand) String() string

type CreateRetentionPolicyCommand 

type CreateRetentionPolicyCommand struct {
	Database         *string              `protobuf:"bytes,1,req" json:"Database,omitempty"`
	RetentionPolicy  *RetentionPolicyInfo `protobuf:"bytes,2,req" json:"RetentionPolicy,omitempty"`
	XXX_unrecognized []byte               `json:"-"`
}

func (*CreateRetentionPolicyCommand) GetDatabase 

func (m *CreateRetentionPolicyCommand) GetDatabase() string

func (*CreateRetentionPolicyCommand) GetRetentionPolicy 

func (m *CreateRetentionPolicyCommand) GetRetentionPolicy() *RetentionPolicyInfo

func (*CreateRetentionPolicyCommand) ProtoMessage 

func (*CreateRetentionPolicyCommand) ProtoMessage()

func (*CreateRetentionPolicyCommand) Reset 

func (m *CreateRetentionPolicyCommand) Reset()

func (*CreateRetentionPolicyCommand) String 

func (m *CreateRetentionPolicyCommand) String() string

type CreateShardGroupCommand 

type CreateShardGroupCommand struct {
	Database         *string `protobuf:"bytes,1,req" json:"Database,omitempty"`
	Policy           *string `protobuf:"bytes,2,req" json:"Policy,omitempty"`
	Timestamp        *int64  `protobuf:"varint,3,req" json:"Timestamp,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*CreateShardGroupCommand) GetDatabase 

func (m *CreateShardGroupCommand) GetDatabase() string

func (*CreateShardGroupCommand) GetPolicy 

func (m *CreateShardGroupCommand) GetPolicy() string

func (*CreateShardGroupCommand) GetTimestamp 

func (m *CreateShardGroupCommand) GetTimestamp() int64

func (*CreateShardGroupCommand) ProtoMessage 

func (*CreateShardGroupCommand) ProtoMessage()

func (*CreateShardGroupCommand) Reset 

func (m *CreateShardGroupCommand) Reset()

func (*CreateShardGroupCommand) String 

func (m *CreateShardGroupCommand) String() string

type CreateUserCommand 

type CreateUserCommand struct {
	Name             *string `protobuf:"bytes,1,req" json:"Name,omitempty"`
	Hash             *string `protobuf:"bytes,2,req" json:"Hash,omitempty"`
	Admin            *bool   `protobuf:"varint,3,req" json:"Admin,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*CreateUserCommand) GetAdmin 

func (m *CreateUserCommand) GetAdmin() bool

func (*CreateUserCommand) GetHash 

func (m *CreateUserCommand) GetHash() string

func (*CreateUserCommand) GetName 

func (m *CreateUserCommand) GetName() string

func (*CreateUserCommand) ProtoMessage 

func (*CreateUserCommand) ProtoMessage()

func (*CreateUserCommand) Reset 

func (m *CreateUserCommand) Reset()

func (*CreateUserCommand) String 

func (m *CreateUserCommand) String() string

type Data 

type Data struct {
	Term             *uint64         `protobuf:"varint,1,req" json:"Term,omitempty"`
	Index            *uint64         `protobuf:"varint,2,req" json:"Index,omitempty"`
	ClusterID        *uint64         `protobuf:"varint,3,req" json:"ClusterID,omitempty"`
	Nodes            []*NodeInfo     `protobuf:"bytes,4,rep" json:"Nodes,omitempty"`
	Databases        []*DatabaseInfo `protobuf:"bytes,5,rep" json:"Databases,omitempty"`
	Users            []*UserInfo     `protobuf:"bytes,6,rep" json:"Users,omitempty"`
	MaxNodeID        *uint64         `protobuf:"varint,7,req" json:"MaxNodeID,omitempty"`
	MaxShardGroupID  *uint64         `protobuf:"varint,8,req" json:"MaxShardGroupID,omitempty"`
	MaxShardID       *uint64         `protobuf:"varint,9,req" json:"MaxShardID,omitempty"`
	XXX_unrecognized []byte          `json:"-"`
}

func (*Data) GetClusterID 

func (m *Data) GetClusterID() uint64

func (*Data) GetDatabases 

func (m *Data) GetDatabases() []*DatabaseInfo

func (*Data) GetIndex 

func (m *Data) GetIndex() uint64

func (*Data) GetMaxNodeID 

func (m *Data) GetMaxNodeID() uint64

func (*Data) GetMaxShardGroupID 

func (m *Data) GetMaxShardGroupID() uint64

func (*Data) GetMaxShardID 

func (m *Data) GetMaxShardID() uint64

func (*Data) GetNodes 

func (m *Data) GetNodes() []*NodeInfo

func (*Data) GetTerm 

func (m *Data) GetTerm() uint64

func (*Data) GetUsers 

func (m *Data) GetUsers() []*UserInfo

func (*Data) ProtoMessage 

func (*Data) ProtoMessage()

func (*Data) Reset 

func (m *Data) Reset()

func (*Data) String 

func (m *Data) String() string

type DatabaseInfo 

type DatabaseInfo struct {
	Name                   *string                `protobuf:"bytes,1,req" json:"Name,omitempty"`
	DefaultRetentionPolicy *string                `protobuf:"bytes,2,req" json:"DefaultRetentionPolicy,omitempty"`
	RetentionPolicies      []*RetentionPolicyInfo `protobuf:"bytes,3,rep" json:"RetentionPolicies,omitempty"`
	ContinuousQueries      []*ContinuousQueryInfo `protobuf:"bytes,4,rep" json:"ContinuousQueries,omitempty"`
	XXX_unrecognized       []byte                 `json:"-"`
}

func (*DatabaseInfo) GetContinuousQueries 

func (m *DatabaseInfo) GetContinuousQueries() []*ContinuousQueryInfo

func (*DatabaseInfo) GetDefaultRetentionPolicy 

func (m *DatabaseInfo) GetDefaultRetentionPolicy() string

func (*DatabaseInfo) GetName 

func (m *DatabaseInfo) GetName() string

func (*DatabaseInfo) GetRetentionPolicies 

func (m *DatabaseInfo) GetRetentionPolicies() []*RetentionPolicyInfo

func (*DatabaseInfo) ProtoMessage 

func (*DatabaseInfo) ProtoMessage()

func (*DatabaseInfo) Reset 

func (m *DatabaseInfo) Reset()

func (*DatabaseInfo) String 

func (m *DatabaseInfo) String() string

type DeleteNodeCommand 

type DeleteNodeCommand struct {
	ID               *uint64 `protobuf:"varint,1,req" json:"ID,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*DeleteNodeCommand) GetID 

func (m *DeleteNodeCommand) GetID() uint64

func (*DeleteNodeCommand) ProtoMessage 

func (*DeleteNodeCommand) ProtoMessage()

func (*DeleteNodeCommand) Reset 

func (m *DeleteNodeCommand) Reset()

func (*DeleteNodeCommand) String 

func (m *DeleteNodeCommand) String() string

type DeleteShardGroupCommand 

type DeleteShardGroupCommand struct {
	Database         *string `protobuf:"bytes,1,req" json:"Database,omitempty"`
	Policy           *string `protobuf:"bytes,2,req" json:"Policy,omitempty"`
	ShardGroupID     *uint64 `protobuf:"varint,3,req" json:"ShardGroupID,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*DeleteShardGroupCommand) GetDatabase 

func (m *DeleteShardGroupCommand) GetDatabase() string

func (*DeleteShardGroupCommand) GetPolicy 

func (m *DeleteShardGroupCommand) GetPolicy() string

func (*DeleteShardGroupCommand) GetShardGroupID 

func (m *DeleteShardGroupCommand) GetShardGroupID() uint64

func (*DeleteShardGroupCommand) ProtoMessage 

func (*DeleteShardGroupCommand) ProtoMessage()

func (*DeleteShardGroupCommand) Reset 

func (m *DeleteShardGroupCommand) Reset()

func (*DeleteShardGroupCommand) String 

func (m *DeleteShardGroupCommand) String() string

type DropContinuousQueryCommand 

type DropContinuousQueryCommand struct {
	Database         *string `protobuf:"bytes,1,req" json:"Database,omitempty"`
	Name             *string `protobuf:"bytes,2,req" json:"Name,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*DropContinuousQueryCommand) GetDatabase 

func (m *DropContinuousQueryCommand) GetDatabase() string

func (*DropContinuousQueryCommand) GetName 

func (m *DropContinuousQueryCommand) GetName() string

func (*DropContinuousQueryCommand) ProtoMessage 

func (*DropContinuousQueryCommand) ProtoMessage()

func (*DropContinuousQueryCommand) Reset 

func (m *DropContinuousQueryCommand) Reset()

func (*DropContinuousQueryCommand) String 

func (m *DropContinuousQueryCommand) String() string

type DropDatabaseCommand 

type DropDatabaseCommand struct {
	Name             *string `protobuf:"bytes,1,req" json:"Name,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*DropDatabaseCommand) GetName 

func (m *DropDatabaseCommand) GetName() string

func (*DropDatabaseCommand) ProtoMessage 

func (*DropDatabaseCommand) ProtoMessage()

func (*DropDatabaseCommand) Reset 

func (m *DropDatabaseCommand) Reset()

func (*DropDatabaseCommand) String 

func (m *DropDatabaseCommand) String() string

type DropRetentionPolicyCommand 

type DropRetentionPolicyCommand struct {
	Database         *string `protobuf:"bytes,1,req" json:"Database,omitempty"`
	Name             *string `protobuf:"bytes,2,req" json:"Name,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*DropRetentionPolicyCommand) GetDatabase 

func (m *DropRetentionPolicyCommand) GetDatabase() string

func (*DropRetentionPolicyCommand) GetName 

func (m *DropRetentionPolicyCommand) GetName() string

func (*DropRetentionPolicyCommand) ProtoMessage 

func (*DropRetentionPolicyCommand) ProtoMessage()

func (*DropRetentionPolicyCommand) Reset 

func (m *DropRetentionPolicyCommand) Reset()

func (*DropRetentionPolicyCommand) String 

func (m *DropRetentionPolicyCommand) String() string

type DropUserCommand 

type DropUserCommand struct {
	Name             *string `protobuf:"bytes,1,req" json:"Name,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*DropUserCommand) GetName 

func (m *DropUserCommand) GetName() string

func (*DropUserCommand) ProtoMessage 

func (*DropUserCommand) ProtoMessage()

func (*DropUserCommand) Reset 

func (m *DropUserCommand) Reset()

func (*DropUserCommand) String 

func (m *DropUserCommand) String() string

type ErrorResponse 

type ErrorResponse struct {
	Header           *ResponseHeader `protobuf:"bytes,1,req" json:"Header,omitempty"`
	XXX_unrecognized []byte          `json:"-"`
}

func (*ErrorResponse) GetHeader 

func (m *ErrorResponse) GetHeader() *ResponseHeader

func (*ErrorResponse) ProtoMessage 

func (*ErrorResponse) ProtoMessage()

func (*ErrorResponse) Reset 

func (m *ErrorResponse) Reset()

func (*ErrorResponse) String 

func (m *ErrorResponse) String() string

type FetchDataRequest 

type FetchDataRequest struct {
	Index            *uint64 `protobuf:"varint,1,req" json:"Index,omitempty"`
	Term             *uint64 `protobuf:"varint,2,req" json:"Term,omitempty"`
	Blocking         *bool   `protobuf:"varint,3,opt,def=0" json:"Blocking,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*FetchDataRequest) GetBlocking 

func (m *FetchDataRequest) GetBlocking() bool

func (*FetchDataRequest) GetIndex 

func (m *FetchDataRequest) GetIndex() uint64

func (*FetchDataRequest) GetTerm 

func (m *FetchDataRequest) GetTerm() uint64

func (*FetchDataRequest) ProtoMessage 

func (*FetchDataRequest) ProtoMessage()

func (*FetchDataRequest) Reset 

func (m *FetchDataRequest) Reset()

func (*FetchDataRequest) String 

func (m *FetchDataRequest) String() string

type FetchDataResponse 

type FetchDataResponse struct {
	Header           *ResponseHeader `protobuf:"bytes,1,req" json:"Header,omitempty"`
	Index            *uint64         `protobuf:"varint,2,req" json:"Index,omitempty"`
	Term             *uint64         `protobuf:"varint,3,req" json:"Term,omitempty"`
	Data             []byte          `protobuf:"bytes,4,opt" json:"Data,omitempty"`
	XXX_unrecognized []byte          `json:"-"`
}

func (*FetchDataResponse) GetData 

func (m *FetchDataResponse) GetData() []byte

func (*FetchDataResponse) GetHeader 

func (m *FetchDataResponse) GetHeader() *ResponseHeader

func (*FetchDataResponse) GetIndex 

func (m *FetchDataResponse) GetIndex() uint64

func (*FetchDataResponse) GetTerm 

func (m *FetchDataResponse) GetTerm() uint64

func (*FetchDataResponse) ProtoMessage 

func (*FetchDataResponse) ProtoMessage()

func (*FetchDataResponse) Reset 

func (m *FetchDataResponse) Reset()

func (*FetchDataResponse) String 

func (m *FetchDataResponse) String() string

type JoinRequest 

type JoinRequest struct {
	Addr             *string `protobuf:"bytes,1,req" json:"Addr,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*JoinRequest) GetAddr 

func (m *JoinRequest) GetAddr() string

func (*JoinRequest) ProtoMessage 

func (*JoinRequest) ProtoMessage()

func (*JoinRequest) Reset 

func (m *JoinRequest) Reset()

func (*JoinRequest) String 

func (m *JoinRequest) String() string

type JoinResponse 

type JoinResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,req" json:"Header,omitempty"`
	// Indicates that this node should take part in the raft cluster.
	EnableRaft *bool `protobuf:"varint,2,opt" json:"EnableRaft,omitempty"`
	// The addresses of raft peers to use if joining as a raft member. If not joining
	// as a raft member, these are the nodes running raft.
	RaftNodes []string `protobuf:"bytes,3,rep" json:"RaftNodes,omitempty"`
	// The node ID assigned to the requesting node.
	NodeID           *uint64 `protobuf:"varint,4,opt" json:"NodeID,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*JoinResponse) GetEnableRaft 

func (m *JoinResponse) GetEnableRaft() bool

func (*JoinResponse) GetHeader 

func (m *JoinResponse) GetHeader() *ResponseHeader

func (*JoinResponse) GetNodeID 

func (m *JoinResponse) GetNodeID() uint64

func (*JoinResponse) GetRaftNodes 

func (m *JoinResponse) GetRaftNodes() []string

func (*JoinResponse) ProtoMessage 

func (*JoinResponse) ProtoMessage()

func (*JoinResponse) Reset 

func (m *JoinResponse) Reset()

func (*JoinResponse) String 

func (m *JoinResponse) String() string

type NodeInfo 

type NodeInfo struct {
	ID               *uint64 `protobuf:"varint,1,req" json:"ID,omitempty"`
	Host             *string `protobuf:"bytes,2,req" json:"Host,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*NodeInfo) GetHost 

func (m *NodeInfo) GetHost() string

func (*NodeInfo) GetID 

func (m *NodeInfo) GetID() uint64

func (*NodeInfo) ProtoMessage 

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) Reset 

func (m *NodeInfo) Reset()

func (*NodeInfo) String 

func (m *NodeInfo) String() string

type RPCType 

type RPCType int32
const (
	RPCType_Error     RPCType = 1
	RPCType_FetchData RPCType = 2
	RPCType_Join      RPCType = 3
)

func (RPCType) Enum 

func (x RPCType) Enum() *RPCType

func (RPCType) String 

func (x RPCType) String() string

func (*RPCType) UnmarshalJSON 

func (x *RPCType) UnmarshalJSON(data []byte) error

type Response 

type Response struct {
	OK               *bool   `protobuf:"varint,1,req" json:"OK,omitempty"`
	Error            *string `protobuf:"bytes,2,opt" json:"Error,omitempty"`
	Index            *uint64 `protobuf:"varint,3,opt" json:"Index,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*Response) GetError 

func (m *Response) GetError() string

func (*Response) GetIndex 

func (m *Response) GetIndex() uint64

func (*Response) GetOK 

func (m *Response) GetOK() bool

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) String 

func (m *Response) String() string

type ResponseHeader 

type ResponseHeader struct {
	OK               *bool   `protobuf:"varint,1,req" json:"OK,omitempty"`
	Error            *string `protobuf:"bytes,2,opt" json:"Error,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ResponseHeader) GetError 

func (m *ResponseHeader) GetError() string

func (*ResponseHeader) GetOK 

func (m *ResponseHeader) GetOK() bool

func (*ResponseHeader) ProtoMessage 

func (*ResponseHeader) ProtoMessage()

func (*ResponseHeader) Reset 

func (m *ResponseHeader) Reset()

func (*ResponseHeader) String 

func (m *ResponseHeader) String() string

type RetentionPolicyInfo 

type RetentionPolicyInfo struct {
	Name               *string           `protobuf:"bytes,1,req" json:"Name,omitempty"`
	Duration           *int64            `protobuf:"varint,2,req" json:"Duration,omitempty"`
	ShardGroupDuration *int64            `protobuf:"varint,3,req" json:"ShardGroupDuration,omitempty"`
	ReplicaN           *uint32           `protobuf:"varint,4,req" json:"ReplicaN,omitempty"`
	ShardGroups        []*ShardGroupInfo `protobuf:"bytes,5,rep" json:"ShardGroups,omitempty"`
	XXX_unrecognized   []byte            `json:"-"`
}

func (*RetentionPolicyInfo) GetDuration 

func (m *RetentionPolicyInfo) GetDuration() int64

func (*RetentionPolicyInfo) GetName 

func (m *RetentionPolicyInfo) GetName() string

func (*RetentionPolicyInfo) GetReplicaN 

func (m *RetentionPolicyInfo) GetReplicaN() uint32

func (*RetentionPolicyInfo) GetShardGroupDuration 

func (m *RetentionPolicyInfo) GetShardGroupDuration() int64

func (*RetentionPolicyInfo) GetShardGroups 

func (m *RetentionPolicyInfo) GetShardGroups() []*ShardGroupInfo

func (*RetentionPolicyInfo) ProtoMessage 

func (*RetentionPolicyInfo) ProtoMessage()

func (*RetentionPolicyInfo) Reset 

func (m *RetentionPolicyInfo) Reset()

func (*RetentionPolicyInfo) String 

func (m *RetentionPolicyInfo) String() string

type SetAdminPrivilegeCommand 

type SetAdminPrivilegeCommand struct {
	Username         *string `protobuf:"bytes,1,req" json:"Username,omitempty"`
	Admin            *bool   `protobuf:"varint,2,req" json:"Admin,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*SetAdminPrivilegeCommand) GetAdmin 

func (m *SetAdminPrivilegeCommand) GetAdmin() bool

func (*SetAdminPrivilegeCommand) GetUsername 

func (m *SetAdminPrivilegeCommand) GetUsername() string

func (*SetAdminPrivilegeCommand) ProtoMessage 

func (*SetAdminPrivilegeCommand) ProtoMessage()

func (*SetAdminPrivilegeCommand) Reset 

func (m *SetAdminPrivilegeCommand) Reset()

func (*SetAdminPrivilegeCommand) String 

func (m *SetAdminPrivilegeCommand) String() string

type SetDataCommand 

type SetDataCommand struct {
	Data             *Data  `protobuf:"bytes,1,req" json:"Data,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*SetDataCommand) GetData 

func (m *SetDataCommand) GetData() *Data

func (*SetDataCommand) ProtoMessage 

func (*SetDataCommand) ProtoMessage()

func (*SetDataCommand) Reset 

func (m *SetDataCommand) Reset()

func (*SetDataCommand) String 

func (m *SetDataCommand) String() string

type SetDefaultRetentionPolicyCommand 

type SetDefaultRetentionPolicyCommand struct {
	Database         *string `protobuf:"bytes,1,req" json:"Database,omitempty"`
	Name             *string `protobuf:"bytes,2,req" json:"Name,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*SetDefaultRetentionPolicyCommand) GetDatabase 

func (m *SetDefaultRetentionPolicyCommand) GetDatabase() string

func (*SetDefaultRetentionPolicyCommand) GetName 

func (m *SetDefaultRetentionPolicyCommand) GetName() string

func (*SetDefaultRetentionPolicyCommand) ProtoMessage 

func (*SetDefaultRetentionPolicyCommand) ProtoMessage()

func (*SetDefaultRetentionPolicyCommand) Reset 

func (m *SetDefaultRetentionPolicyCommand) Reset()

func (*SetDefaultRetentionPolicyCommand) String 

func (m *SetDefaultRetentionPolicyCommand) String() string

type SetPrivilegeCommand 

type SetPrivilegeCommand struct {
	Username         *string `protobuf:"bytes,1,req" json:"Username,omitempty"`
	Database         *string `protobuf:"bytes,2,req" json:"Database,omitempty"`
	Privilege        *int32  `protobuf:"varint,3,req" json:"Privilege,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*SetPrivilegeCommand) GetDatabase 

func (m *SetPrivilegeCommand) GetDatabase() string

func (*SetPrivilegeCommand) GetPrivilege 

func (m *SetPrivilegeCommand) GetPrivilege() int32

func (*SetPrivilegeCommand) GetUsername 

func (m *SetPrivilegeCommand) GetUsername() string

func (*SetPrivilegeCommand) ProtoMessage 

func (*SetPrivilegeCommand) ProtoMessage()

func (*SetPrivilegeCommand) Reset 

func (m *SetPrivilegeCommand) Reset()

func (*SetPrivilegeCommand) String 

func (m *SetPrivilegeCommand) String() string

type ShardGroupInfo 

type ShardGroupInfo struct {
	ID               *uint64      `protobuf:"varint,1,req" json:"ID,omitempty"`
	StartTime        *int64       `protobuf:"varint,2,req" json:"StartTime,omitempty"`
	EndTime          *int64       `protobuf:"varint,3,req" json:"EndTime,omitempty"`
	DeletedAt        *int64       `protobuf:"varint,4,req" json:"DeletedAt,omitempty"`
	Shards           []*ShardInfo `protobuf:"bytes,5,rep" json:"Shards,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*ShardGroupInfo) GetDeletedAt 

func (m *ShardGroupInfo) GetDeletedAt() int64

func (*ShardGroupInfo) GetEndTime 

func (m *ShardGroupInfo) GetEndTime() int64

func (*ShardGroupInfo) GetID 

func (m *ShardGroupInfo) GetID() uint64

func (*ShardGroupInfo) GetShards 

func (m *ShardGroupInfo) GetShards() []*ShardInfo

func (*ShardGroupInfo) GetStartTime 

func (m *ShardGroupInfo) GetStartTime() int64

func (*ShardGroupInfo) ProtoMessage 

func (*ShardGroupInfo) ProtoMessage()

func (*ShardGroupInfo) Reset 

func (m *ShardGroupInfo) Reset()

func (*ShardGroupInfo) String 

func (m *ShardGroupInfo) String() string

type ShardInfo 

type ShardInfo struct {
	ID               *uint64  `protobuf:"varint,1,req" json:"ID,omitempty"`
	OwnerIDs         []uint64 `protobuf:"varint,2,rep" json:"OwnerIDs,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*ShardInfo) GetID 

func (m *ShardInfo) GetID() uint64

func (*ShardInfo) GetOwnerIDs 

func (m *ShardInfo) GetOwnerIDs() []uint64

func (*ShardInfo) ProtoMessage 

func (*ShardInfo) ProtoMessage()

func (*ShardInfo) Reset 

func (m *ShardInfo) Reset()

func (*ShardInfo) String 

func (m *ShardInfo) String() string

type UpdateNodeCommand 

type UpdateNodeCommand struct {
	ID               *uint64 `protobuf:"varint,1,req" json:"ID,omitempty"`
	Host             *string `protobuf:"bytes,2,req" json:"Host,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*UpdateNodeCommand) GetHost 

func (m *UpdateNodeCommand) GetHost() string

func (*UpdateNodeCommand) GetID 

func (m *UpdateNodeCommand) GetID() uint64

func (*UpdateNodeCommand) ProtoMessage 

func (*UpdateNodeCommand) ProtoMessage()

func (*UpdateNodeCommand) Reset 

func (m *UpdateNodeCommand) Reset()

func (*UpdateNodeCommand) String 

func (m *UpdateNodeCommand) String() string

type UpdateRetentionPolicyCommand 

type UpdateRetentionPolicyCommand struct {
	Database         *string `protobuf:"bytes,1,req" json:"Database,omitempty"`
	Name             *string `protobuf:"bytes,2,req" json:"Name,omitempty"`
	NewName          *string `protobuf:"bytes,3,opt" json:"NewName,omitempty"`
	Duration         *int64  `protobuf:"varint,4,opt" json:"Duration,omitempty"`
	ReplicaN         *uint32 `protobuf:"varint,5,opt" json:"ReplicaN,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*UpdateRetentionPolicyCommand) GetDatabase 

func (m *UpdateRetentionPolicyCommand) GetDatabase() string

func (*UpdateRetentionPolicyCommand) GetDuration 

func (m *UpdateRetentionPolicyCommand) GetDuration() int64

func (*UpdateRetentionPolicyCommand) GetName 

func (m *UpdateRetentionPolicyCommand) GetName() string

func (*UpdateRetentionPolicyCommand) GetNewName 

func (m *UpdateRetentionPolicyCommand) GetNewName() string

func (*UpdateRetentionPolicyCommand) GetReplicaN 

func (m *UpdateRetentionPolicyCommand) GetReplicaN() uint32

func (*UpdateRetentionPolicyCommand) ProtoMessage 

func (*UpdateRetentionPolicyCommand) ProtoMessage()

func (*UpdateRetentionPolicyCommand) Reset 

func (m *UpdateRetentionPolicyCommand) Reset()

func (*UpdateRetentionPolicyCommand) String 

func (m *UpdateRetentionPolicyCommand) String() string

type UpdateUserCommand 

type UpdateUserCommand struct {
	Name             *string `protobuf:"bytes,1,req" json:"Name,omitempty"`
	Hash             *string `protobuf:"bytes,2,req" json:"Hash,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*UpdateUserCommand) GetHash 

func (m *UpdateUserCommand) GetHash() string

func (*UpdateUserCommand) GetName 

func (m *UpdateUserCommand) GetName() string

func (*UpdateUserCommand) ProtoMessage 

func (*UpdateUserCommand) ProtoMessage()

func (*UpdateUserCommand) Reset 

func (m *UpdateUserCommand) Reset()

func (*UpdateUserCommand) String 

func (m *UpdateUserCommand) String() string

type UserInfo 

type UserInfo struct {
	Name             *string          `protobuf:"bytes,1,req" json:"Name,omitempty"`
	Hash             *string          `protobuf:"bytes,2,req" json:"Hash,omitempty"`
	Admin            *bool            `protobuf:"varint,3,req" json:"Admin,omitempty"`
	Privileges       []*UserPrivilege `protobuf:"bytes,4,rep" json:"Privileges,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*UserInfo) GetAdmin 

func (m *UserInfo) GetAdmin() bool

func (*UserInfo) GetHash 

func (m *UserInfo) GetHash() string

func (*UserInfo) GetName 

func (m *UserInfo) GetName() string

func (*UserInfo) GetPrivileges 

func (m *UserInfo) GetPrivileges() []*UserPrivilege

func (*UserInfo) ProtoMessage 

func (*UserInfo) ProtoMessage()

func (*UserInfo) Reset 

func (m *UserInfo) Reset()

func (*UserInfo) String 

func (m *UserInfo) String() string

type UserPrivilege 

type UserPrivilege struct {
	Database         *string `protobuf:"bytes,1,req" json:"Database,omitempty"`
	Privilege        *int32  `protobuf:"varint,2,req" json:"Privilege,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*UserPrivilege) GetDatabase 

func (m *UserPrivilege) GetDatabase() string

func (*UserPrivilege) GetPrivilege 

func (m *UserPrivilege) GetPrivilege() int32

func (*UserPrivilege) ProtoMessage 

func (*UserPrivilege) ProtoMessage()

func (*UserPrivilege) Reset 

func (m *UserPrivilege) Reset()

func (*UserPrivilege) String 

func (m *UserPrivilege) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.