1 Star 0 Fork 0

zhuchance / kubernetes

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
克隆/下载
meta.pb.go 33.31 KB
一键复制 编辑 原始数据 按行查看 历史
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167
// Code generated by protoc-gen-gogo.
// source: internal/meta.proto
// DO NOT EDIT!
/*
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
Response
*/
package internal
import proto "github.com/gogo/protobuf/proto"
import math "math"
// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = math.Inf
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
)
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",
}
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,
}
func (x Command_Type) Enum() *Command_Type {
p := new(Command_Type)
*p = x
return p
}
func (x Command_Type) String() string {
return proto.EnumName(Command_Type_name, int32(x))
}
func (x *Command_Type) UnmarshalJSON(data []byte) error {
value, err := proto.UnmarshalJSONEnum(Command_Type_value, data, "Command_Type")
if err != nil {
return err
}
*x = Command_Type(value)
return nil
}
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 (m *Data) Reset() { *m = Data{} }
func (m *Data) String() string { return proto.CompactTextString(m) }
func (*Data) ProtoMessage() {}
func (m *Data) GetTerm() uint64 {
if m != nil && m.Term != nil {
return *m.Term
}
return 0
}
func (m *Data) GetIndex() uint64 {
if m != nil && m.Index != nil {
return *m.Index
}
return 0
}
func (m *Data) GetClusterID() uint64 {
if m != nil && m.ClusterID != nil {
return *m.ClusterID
}
return 0
}
func (m *Data) GetNodes() []*NodeInfo {
if m != nil {
return m.Nodes
}
return nil
}
func (m *Data) GetDatabases() []*DatabaseInfo {
if m != nil {
return m.Databases
}
return nil
}
func (m *Data) GetUsers() []*UserInfo {
if m != nil {
return m.Users
}
return nil
}
func (m *Data) GetMaxNodeID() uint64 {
if m != nil && m.MaxNodeID != nil {
return *m.MaxNodeID
}
return 0
}
func (m *Data) GetMaxShardGroupID() uint64 {
if m != nil && m.MaxShardGroupID != nil {
return *m.MaxShardGroupID
}
return 0
}
func (m *Data) GetMaxShardID() uint64 {
if m != nil && m.MaxShardID != nil {
return *m.MaxShardID
}
return 0
}
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 (m *NodeInfo) Reset() { *m = NodeInfo{} }
func (m *NodeInfo) String() string { return proto.CompactTextString(m) }
func (*NodeInfo) ProtoMessage() {}
func (m *NodeInfo) GetID() uint64 {
if m != nil && m.ID != nil {
return *m.ID
}
return 0
}
func (m *NodeInfo) GetHost() string {
if m != nil && m.Host != nil {
return *m.Host
}
return ""
}
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 (m *DatabaseInfo) Reset() { *m = DatabaseInfo{} }
func (m *DatabaseInfo) String() string { return proto.CompactTextString(m) }
func (*DatabaseInfo) ProtoMessage() {}
func (m *DatabaseInfo) GetName() string {
if m != nil && m.Name != nil {
return *m.Name
}
return ""
}
func (m *DatabaseInfo) GetDefaultRetentionPolicy() string {
if m != nil && m.DefaultRetentionPolicy != nil {
return *m.DefaultRetentionPolicy
}
return ""
}
func (m *DatabaseInfo) GetRetentionPolicies() []*RetentionPolicyInfo {
if m != nil {
return m.RetentionPolicies
}
return nil
}
func (m *DatabaseInfo) GetContinuousQueries() []*ContinuousQueryInfo {
if m != nil {
return m.ContinuousQueries
}
return nil
}
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 (m *RetentionPolicyInfo) Reset() { *m = RetentionPolicyInfo{} }
func (m *RetentionPolicyInfo) String() string { return proto.CompactTextString(m) }
func (*RetentionPolicyInfo) ProtoMessage() {}
func (m *RetentionPolicyInfo) GetName() string {
if m != nil && m.Name != nil {
return *m.Name
}
return ""
}
func (m *RetentionPolicyInfo) GetDuration() int64 {
if m != nil && m.Duration != nil {
return *m.Duration
}
return 0
}
func (m *RetentionPolicyInfo) GetShardGroupDuration() int64 {
if m != nil && m.ShardGroupDuration != nil {
return *m.ShardGroupDuration
}
return 0
}
func (m *RetentionPolicyInfo) GetReplicaN() uint32 {
if m != nil && m.ReplicaN != nil {
return *m.ReplicaN
}
return 0
}
func (m *RetentionPolicyInfo) GetShardGroups() []*ShardGroupInfo {
if m != nil {
return m.ShardGroups
}
return nil
}
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 (m *ShardGroupInfo) Reset() { *m = ShardGroupInfo{} }
func (m *ShardGroupInfo) String() string { return proto.CompactTextString(m) }
func (*ShardGroupInfo) ProtoMessage() {}
func (m *ShardGroupInfo) GetID() uint64 {
if m != nil && m.ID != nil {
return *m.ID
}
return 0
}
func (m *ShardGroupInfo) GetStartTime() int64 {
if m != nil && m.StartTime != nil {
return *m.StartTime
}
return 0
}
func (m *ShardGroupInfo) GetEndTime() int64 {
if m != nil && m.EndTime != nil {
return *m.EndTime
}
return 0
}
func (m *ShardGroupInfo) GetDeletedAt() int64 {
if m != nil && m.DeletedAt != nil {
return *m.DeletedAt
}
return 0
}
func (m *ShardGroupInfo) GetShards() []*ShardInfo {
if m != nil {
return m.Shards
}
return nil
}
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 (m *ShardInfo) Reset() { *m = ShardInfo{} }
func (m *ShardInfo) String() string { return proto.CompactTextString(m) }
func (*ShardInfo) ProtoMessage() {}
func (m *ShardInfo) GetID() uint64 {
if m != nil && m.ID != nil {
return *m.ID
}
return 0
}
func (m *ShardInfo) GetOwnerIDs() []uint64 {
if m != nil {
return m.OwnerIDs
}
return nil
}
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 (m *ContinuousQueryInfo) Reset() { *m = ContinuousQueryInfo{} }
func (m *ContinuousQueryInfo) String() string { return proto.CompactTextString(m) }
func (*ContinuousQueryInfo) ProtoMessage() {}
func (m *ContinuousQueryInfo) GetName() string {
if m != nil && m.Name != nil {
return *m.Name
}
return ""
}
func (m *ContinuousQueryInfo) GetQuery() string {
if m != nil && m.Query != nil {
return *m.Query
}
return ""
}
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 (m *UserInfo) Reset() { *m = UserInfo{} }
func (m *UserInfo) String() string { return proto.CompactTextString(m) }
func (*UserInfo) ProtoMessage() {}
func (m *UserInfo) GetName() string {
if m != nil && m.Name != nil {
return *m.Name
}
return ""
}
func (m *UserInfo) GetHash() string {
if m != nil && m.Hash != nil {
return *m.Hash
}
return ""
}
func (m *UserInfo) GetAdmin() bool {
if m != nil && m.Admin != nil {
return *m.Admin
}
return false
}
func (m *UserInfo) GetPrivileges() []*UserPrivilege {
if m != nil {
return m.Privileges
}
return nil
}
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 (m *UserPrivilege) Reset() { *m = UserPrivilege{} }
func (m *UserPrivilege) String() string { return proto.CompactTextString(m) }
func (*UserPrivilege) ProtoMessage() {}
func (m *UserPrivilege) GetDatabase() string {
if m != nil && m.Database != nil {
return *m.Database
}
return ""
}
func (m *UserPrivilege) GetPrivilege() int32 {
if m != nil && m.Privilege != nil {
return *m.Privilege
}
return 0
}
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 (m *Command) Reset() { *m = Command{} }
func (m *Command) String() string { return proto.CompactTextString(m) }
func (*Command) ProtoMessage() {}
var extRange_Command = []proto.ExtensionRange{
{100, 536870911},
}
func (*Command) ExtensionRangeArray() []proto.ExtensionRange {
return extRange_Command
}
func (m *Command) ExtensionMap() map[int32]proto.Extension {
if m.XXX_extensions == nil {
m.XXX_extensions = make(map[int32]proto.Extension)
}
return m.XXX_extensions
}
func (m *Command) GetType() Command_Type {
if m != nil && m.Type != nil {
return *m.Type
}
return Command_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 (m *CreateNodeCommand) Reset() { *m = CreateNodeCommand{} }
func (m *CreateNodeCommand) String() string { return proto.CompactTextString(m) }
func (*CreateNodeCommand) ProtoMessage() {}
func (m *CreateNodeCommand) GetHost() string {
if m != nil && m.Host != nil {
return *m.Host
}
return ""
}
func (m *CreateNodeCommand) GetRand() uint64 {
if m != nil && m.Rand != nil {
return *m.Rand
}
return 0
}
var E_CreateNodeCommand_Command = &proto.ExtensionDesc{
ExtendedType: (*Command)(nil),
ExtensionType: (*CreateNodeCommand)(nil),
Field: 101,
Name: "internal.CreateNodeCommand.command",
Tag: "bytes,101,opt,name=command",
}
type DeleteNodeCommand struct {
ID *uint64 `protobuf:"varint,1,req" json:"ID,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *DeleteNodeCommand) Reset() { *m = DeleteNodeCommand{} }
func (m *DeleteNodeCommand) String() string { return proto.CompactTextString(m) }
func (*DeleteNodeCommand) ProtoMessage() {}
func (m *DeleteNodeCommand) GetID() uint64 {
if m != nil && m.ID != nil {
return *m.ID
}
return 0
}
var E_DeleteNodeCommand_Command = &proto.ExtensionDesc{
ExtendedType: (*Command)(nil),
ExtensionType: (*DeleteNodeCommand)(nil),
Field: 102,
Name: "internal.DeleteNodeCommand.command",
Tag: "bytes,102,opt,name=command",
}
type CreateDatabaseCommand struct {
Name *string `protobuf:"bytes,1,req" json:"Name,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *CreateDatabaseCommand) Reset() { *m = CreateDatabaseCommand{} }
func (m *CreateDatabaseCommand) String() string { return proto.CompactTextString(m) }
func (*CreateDatabaseCommand) ProtoMessage() {}
func (m *CreateDatabaseCommand) GetName() string {
if m != nil && m.Name != nil {
return *m.Name
}
return ""
}
var E_CreateDatabaseCommand_Command = &proto.ExtensionDesc{
ExtendedType: (*Command)(nil),
ExtensionType: (*CreateDatabaseCommand)(nil),
Field: 103,
Name: "internal.CreateDatabaseCommand.command",
Tag: "bytes,103,opt,name=command",
}
type DropDatabaseCommand struct {
Name *string `protobuf:"bytes,1,req" json:"Name,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *DropDatabaseCommand) Reset() { *m = DropDatabaseCommand{} }
func (m *DropDatabaseCommand) String() string { return proto.CompactTextString(m) }
func (*DropDatabaseCommand) ProtoMessage() {}
func (m *DropDatabaseCommand) GetName() string {
if m != nil && m.Name != nil {
return *m.Name
}
return ""
}
var E_DropDatabaseCommand_Command = &proto.ExtensionDesc{
ExtendedType: (*Command)(nil),
ExtensionType: (*DropDatabaseCommand)(nil),
Field: 104,
Name: "internal.DropDatabaseCommand.command",
Tag: "bytes,104,opt,name=command",
}
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 (m *CreateRetentionPolicyCommand) Reset() { *m = CreateRetentionPolicyCommand{} }
func (m *CreateRetentionPolicyCommand) String() string { return proto.CompactTextString(m) }
func (*CreateRetentionPolicyCommand) ProtoMessage() {}
func (m *CreateRetentionPolicyCommand) GetDatabase() string {
if m != nil && m.Database != nil {
return *m.Database
}
return ""
}
func (m *CreateRetentionPolicyCommand) GetRetentionPolicy() *RetentionPolicyInfo {
if m != nil {
return m.RetentionPolicy
}
return nil
}
var E_CreateRetentionPolicyCommand_Command = &proto.ExtensionDesc{
ExtendedType: (*Command)(nil),
ExtensionType: (*CreateRetentionPolicyCommand)(nil),
Field: 105,
Name: "internal.CreateRetentionPolicyCommand.command",
Tag: "bytes,105,opt,name=command",
}
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 (m *DropRetentionPolicyCommand) Reset() { *m = DropRetentionPolicyCommand{} }
func (m *DropRetentionPolicyCommand) String() string { return proto.CompactTextString(m) }
func (*DropRetentionPolicyCommand) ProtoMessage() {}
func (m *DropRetentionPolicyCommand) GetDatabase() string {
if m != nil && m.Database != nil {
return *m.Database
}
return ""
}
func (m *DropRetentionPolicyCommand) GetName() string {
if m != nil && m.Name != nil {
return *m.Name
}
return ""
}
var E_DropRetentionPolicyCommand_Command = &proto.ExtensionDesc{
ExtendedType: (*Command)(nil),
ExtensionType: (*DropRetentionPolicyCommand)(nil),
Field: 106,
Name: "internal.DropRetentionPolicyCommand.command",
Tag: "bytes,106,opt,name=command",
}
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 (m *SetDefaultRetentionPolicyCommand) Reset() { *m = SetDefaultRetentionPolicyCommand{} }
func (m *SetDefaultRetentionPolicyCommand) String() string { return proto.CompactTextString(m) }
func (*SetDefaultRetentionPolicyCommand) ProtoMessage() {}
func (m *SetDefaultRetentionPolicyCommand) GetDatabase() string {
if m != nil && m.Database != nil {
return *m.Database
}
return ""
}
func (m *SetDefaultRetentionPolicyCommand) GetName() string {
if m != nil && m.Name != nil {
return *m.Name
}
return ""
}
var E_SetDefaultRetentionPolicyCommand_Command = &proto.ExtensionDesc{
ExtendedType: (*Command)(nil),
ExtensionType: (*SetDefaultRetentionPolicyCommand)(nil),
Field: 107,
Name: "internal.SetDefaultRetentionPolicyCommand.command",
Tag: "bytes,107,opt,name=command",
}
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 (m *UpdateRetentionPolicyCommand) Reset() { *m = UpdateRetentionPolicyCommand{} }
func (m *UpdateRetentionPolicyCommand) String() string { return proto.CompactTextString(m) }
func (*UpdateRetentionPolicyCommand) ProtoMessage() {}
func (m *UpdateRetentionPolicyCommand) GetDatabase() string {
if m != nil && m.Database != nil {
return *m.Database
}
return ""
}
func (m *UpdateRetentionPolicyCommand) GetName() string {
if m != nil && m.Name != nil {
return *m.Name
}
return ""
}
func (m *UpdateRetentionPolicyCommand) GetNewName() string {
if m != nil && m.NewName != nil {
return *m.NewName
}
return ""
}
func (m *UpdateRetentionPolicyCommand) GetDuration() int64 {
if m != nil && m.Duration != nil {
return *m.Duration
}
return 0
}
func (m *UpdateRetentionPolicyCommand) GetReplicaN() uint32 {
if m != nil && m.ReplicaN != nil {
return *m.ReplicaN
}
return 0
}
var E_UpdateRetentionPolicyCommand_Command = &proto.ExtensionDesc{
ExtendedType: (*Command)(nil),
ExtensionType: (*UpdateRetentionPolicyCommand)(nil),
Field: 108,
Name: "internal.UpdateRetentionPolicyCommand.command",
Tag: "bytes,108,opt,name=command",
}
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 (m *CreateShardGroupCommand) Reset() { *m = CreateShardGroupCommand{} }
func (m *CreateShardGroupCommand) String() string { return proto.CompactTextString(m) }
func (*CreateShardGroupCommand) ProtoMessage() {}
func (m *CreateShardGroupCommand) GetDatabase() string {
if m != nil && m.Database != nil {
return *m.Database
}
return ""
}
func (m *CreateShardGroupCommand) GetPolicy() string {
if m != nil && m.Policy != nil {
return *m.Policy
}
return ""
}
func (m *CreateShardGroupCommand) GetTimestamp() int64 {
if m != nil && m.Timestamp != nil {
return *m.Timestamp
}
return 0
}
var E_CreateShardGroupCommand_Command = &proto.ExtensionDesc{
ExtendedType: (*Command)(nil),
ExtensionType: (*CreateShardGroupCommand)(nil),
Field: 109,
Name: "internal.CreateShardGroupCommand.command",
Tag: "bytes,109,opt,name=command",
}
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 (m *DeleteShardGroupCommand) Reset() { *m = DeleteShardGroupCommand{} }
func (m *DeleteShardGroupCommand) String() string { return proto.CompactTextString(m) }
func (*DeleteShardGroupCommand) ProtoMessage() {}
func (m *DeleteShardGroupCommand) GetDatabase() string {
if m != nil && m.Database != nil {
return *m.Database
}
return ""
}
func (m *DeleteShardGroupCommand) GetPolicy() string {
if m != nil && m.Policy != nil {
return *m.Policy
}
return ""
}
func (m *DeleteShardGroupCommand) GetShardGroupID() uint64 {
if m != nil && m.ShardGroupID != nil {
return *m.ShardGroupID
}
return 0
}
var E_DeleteShardGroupCommand_Command = &proto.ExtensionDesc{
ExtendedType: (*Command)(nil),
ExtensionType: (*DeleteShardGroupCommand)(nil),
Field: 110,
Name: "internal.DeleteShardGroupCommand.command",
Tag: "bytes,110,opt,name=command",
}
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 (m *CreateContinuousQueryCommand) Reset() { *m = CreateContinuousQueryCommand{} }
func (m *CreateContinuousQueryCommand) String() string { return proto.CompactTextString(m) }
func (*CreateContinuousQueryCommand) ProtoMessage() {}
func (m *CreateContinuousQueryCommand) GetDatabase() string {
if m != nil && m.Database != nil {
return *m.Database
}
return ""
}
func (m *CreateContinuousQueryCommand) GetName() string {
if m != nil && m.Name != nil {
return *m.Name
}
return ""
}
func (m *CreateContinuousQueryCommand) GetQuery() string {
if m != nil && m.Query != nil {
return *m.Query
}
return ""
}
var E_CreateContinuousQueryCommand_Command = &proto.ExtensionDesc{
ExtendedType: (*Command)(nil),
ExtensionType: (*CreateContinuousQueryCommand)(nil),
Field: 111,
Name: "internal.CreateContinuousQueryCommand.command",
Tag: "bytes,111,opt,name=command",
}
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 (m *DropContinuousQueryCommand) Reset() { *m = DropContinuousQueryCommand{} }
func (m *DropContinuousQueryCommand) String() string { return proto.CompactTextString(m) }
func (*DropContinuousQueryCommand) ProtoMessage() {}
func (m *DropContinuousQueryCommand) GetDatabase() string {
if m != nil && m.Database != nil {
return *m.Database
}
return ""
}
func (m *DropContinuousQueryCommand) GetName() string {
if m != nil && m.Name != nil {
return *m.Name
}
return ""
}
var E_DropContinuousQueryCommand_Command = &proto.ExtensionDesc{
ExtendedType: (*Command)(nil),
ExtensionType: (*DropContinuousQueryCommand)(nil),
Field: 112,
Name: "internal.DropContinuousQueryCommand.command",
Tag: "bytes,112,opt,name=command",
}
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 (m *CreateUserCommand) Reset() { *m = CreateUserCommand{} }
func (m *CreateUserCommand) String() string { return proto.CompactTextString(m) }
func (*CreateUserCommand) ProtoMessage() {}
func (m *CreateUserCommand) GetName() string {
if m != nil && m.Name != nil {
return *m.Name
}
return ""
}
func (m *CreateUserCommand) GetHash() string {
if m != nil && m.Hash != nil {
return *m.Hash
}
return ""
}
func (m *CreateUserCommand) GetAdmin() bool {
if m != nil && m.Admin != nil {
return *m.Admin
}
return false
}
var E_CreateUserCommand_Command = &proto.ExtensionDesc{
ExtendedType: (*Command)(nil),
ExtensionType: (*CreateUserCommand)(nil),
Field: 113,
Name: "internal.CreateUserCommand.command",
Tag: "bytes,113,opt,name=command",
}
type DropUserCommand struct {
Name *string `protobuf:"bytes,1,req" json:"Name,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *DropUserCommand) Reset() { *m = DropUserCommand{} }
func (m *DropUserCommand) String() string { return proto.CompactTextString(m) }
func (*DropUserCommand) ProtoMessage() {}
func (m *DropUserCommand) GetName() string {
if m != nil && m.Name != nil {
return *m.Name
}
return ""
}
var E_DropUserCommand_Command = &proto.ExtensionDesc{
ExtendedType: (*Command)(nil),
ExtensionType: (*DropUserCommand)(nil),
Field: 114,
Name: "internal.DropUserCommand.command",
Tag: "bytes,114,opt,name=command",
}
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 (m *UpdateUserCommand) Reset() { *m = UpdateUserCommand{} }
func (m *UpdateUserCommand) String() string { return proto.CompactTextString(m) }
func (*UpdateUserCommand) ProtoMessage() {}
func (m *UpdateUserCommand) GetName() string {
if m != nil && m.Name != nil {
return *m.Name
}
return ""
}
func (m *UpdateUserCommand) GetHash() string {
if m != nil && m.Hash != nil {
return *m.Hash
}
return ""
}
var E_UpdateUserCommand_Command = &proto.ExtensionDesc{
ExtendedType: (*Command)(nil),
ExtensionType: (*UpdateUserCommand)(nil),
Field: 115,
Name: "internal.UpdateUserCommand.command",
Tag: "bytes,115,opt,name=command",
}
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 (m *SetPrivilegeCommand) Reset() { *m = SetPrivilegeCommand{} }
func (m *SetPrivilegeCommand) String() string { return proto.CompactTextString(m) }
func (*SetPrivilegeCommand) ProtoMessage() {}
func (m *SetPrivilegeCommand) GetUsername() string {
if m != nil && m.Username != nil {
return *m.Username
}
return ""
}
func (m *SetPrivilegeCommand) GetDatabase() string {
if m != nil && m.Database != nil {
return *m.Database
}
return ""
}
func (m *SetPrivilegeCommand) GetPrivilege() int32 {
if m != nil && m.Privilege != nil {
return *m.Privilege
}
return 0
}
var E_SetPrivilegeCommand_Command = &proto.ExtensionDesc{
ExtendedType: (*Command)(nil),
ExtensionType: (*SetPrivilegeCommand)(nil),
Field: 116,
Name: "internal.SetPrivilegeCommand.command",
Tag: "bytes,116,opt,name=command",
}
type SetDataCommand struct {
Data *Data `protobuf:"bytes,1,req" json:"Data,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *SetDataCommand) Reset() { *m = SetDataCommand{} }
func (m *SetDataCommand) String() string { return proto.CompactTextString(m) }
func (*SetDataCommand) ProtoMessage() {}
func (m *SetDataCommand) GetData() *Data {
if m != nil {
return m.Data
}
return nil
}
var E_SetDataCommand_Command = &proto.ExtensionDesc{
ExtendedType: (*Command)(nil),
ExtensionType: (*SetDataCommand)(nil),
Field: 117,
Name: "internal.SetDataCommand.command",
Tag: "bytes,117,opt,name=command",
}
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 (m *SetAdminPrivilegeCommand) Reset() { *m = SetAdminPrivilegeCommand{} }
func (m *SetAdminPrivilegeCommand) String() string { return proto.CompactTextString(m) }
func (*SetAdminPrivilegeCommand) ProtoMessage() {}
func (m *SetAdminPrivilegeCommand) GetUsername() string {
if m != nil && m.Username != nil {
return *m.Username
}
return ""
}
func (m *SetAdminPrivilegeCommand) GetAdmin() bool {
if m != nil && m.Admin != nil {
return *m.Admin
}
return false
}
var E_SetAdminPrivilegeCommand_Command = &proto.ExtensionDesc{
ExtendedType: (*Command)(nil),
ExtensionType: (*SetAdminPrivilegeCommand)(nil),
Field: 118,
Name: "internal.SetAdminPrivilegeCommand.command",
Tag: "bytes,118,opt,name=command",
}
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 (m *Response) Reset() { *m = Response{} }
func (m *Response) String() string { return proto.CompactTextString(m) }
func (*Response) ProtoMessage() {}
func (m *Response) GetOK() bool {
if m != nil && m.OK != nil {
return *m.OK
}
return false
}
func (m *Response) GetError() string {
if m != nil && m.Error != nil {
return *m.Error
}
return ""
}
func (m *Response) GetIndex() uint64 {
if m != nil && m.Index != nil {
return *m.Index
}
return 0
}
func init() {
proto.RegisterEnum("internal.Command_Type", Command_Type_name, Command_Type_value)
proto.RegisterExtension(E_CreateNodeCommand_Command)
proto.RegisterExtension(E_DeleteNodeCommand_Command)
proto.RegisterExtension(E_CreateDatabaseCommand_Command)
proto.RegisterExtension(E_DropDatabaseCommand_Command)
proto.RegisterExtension(E_CreateRetentionPolicyCommand_Command)
proto.RegisterExtension(E_DropRetentionPolicyCommand_Command)
proto.RegisterExtension(E_SetDefaultRetentionPolicyCommand_Command)
proto.RegisterExtension(E_UpdateRetentionPolicyCommand_Command)
proto.RegisterExtension(E_CreateShardGroupCommand_Command)
proto.RegisterExtension(E_DeleteShardGroupCommand_Command)
proto.RegisterExtension(E_CreateContinuousQueryCommand_Command)
proto.RegisterExtension(E_DropContinuousQueryCommand_Command)
proto.RegisterExtension(E_CreateUserCommand_Command)
proto.RegisterExtension(E_DropUserCommand_Command)
proto.RegisterExtension(E_UpdateUserCommand_Command)
proto.RegisterExtension(E_SetPrivilegeCommand_Command)
proto.RegisterExtension(E_SetDataCommand_Command)
proto.RegisterExtension(E_SetAdminPrivilegeCommand_Command)
}
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
Go
1
https://gitee.com/meoom/kubernetes.git
git@gitee.com:meoom/kubernetes.git
meoom
kubernetes
kubernetes
v1.2.0

搜索帮助

344bd9b3 5694891 D2dac590 5694891