123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043 |
- // Code generated by protoc-gen-go.
- // source: master.proto
- // DO NOT EDIT!
- /*
- Package master_pb is a generated protocol buffer package.
- It is generated from these files:
- master.proto
- It has these top-level messages:
- Heartbeat
- HeartbeatResponse
- VolumeInformationMessage
- VolumeShortInformationMessage
- VolumeEcShardInformationMessage
- StorageBackend
- Empty
- SuperBlockExtra
- KeepConnectedRequest
- VolumeLocation
- LookupVolumeRequest
- LookupVolumeResponse
- Location
- AssignRequest
- AssignResponse
- StatisticsRequest
- StatisticsResponse
- StorageType
- Collection
- CollectionListRequest
- CollectionListResponse
- CollectionDeleteRequest
- CollectionDeleteResponse
- DataNodeInfo
- RackInfo
- DataCenterInfo
- TopologyInfo
- VolumeListRequest
- VolumeListResponse
- LookupEcVolumeRequest
- LookupEcVolumeResponse
- GetMasterConfigurationRequest
- GetMasterConfigurationResponse
- */
- package master_pb
- import proto "github.com/golang/protobuf/proto"
- import fmt "fmt"
- import math "math"
- import (
- context "golang.org/x/net/context"
- grpc "google.golang.org/grpc"
- )
- // Reference imports to suppress errors if they are not otherwise used.
- var _ = proto.Marshal
- var _ = fmt.Errorf
- var _ = math.Inf
- // This is a compile-time assertion to ensure that this generated file
- // is compatible with the proto package it is being compiled against.
- // A compilation error at this line likely means your copy of the
- // proto package needs to be updated.
- const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package
- type Heartbeat struct {
- Ip string `protobuf:"bytes,1,opt,name=ip" json:"ip,omitempty"`
- Port uint32 `protobuf:"varint,2,opt,name=port" json:"port,omitempty"`
- PublicUrl string `protobuf:"bytes,3,opt,name=public_url,json=publicUrl" json:"public_url,omitempty"`
- MaxVolumeCount uint32 `protobuf:"varint,4,opt,name=max_volume_count,json=maxVolumeCount" json:"max_volume_count,omitempty"`
- MaxFileKey uint64 `protobuf:"varint,5,opt,name=max_file_key,json=maxFileKey" json:"max_file_key,omitempty"`
- DataCenter string `protobuf:"bytes,6,opt,name=data_center,json=dataCenter" json:"data_center,omitempty"`
- Rack string `protobuf:"bytes,7,opt,name=rack" json:"rack,omitempty"`
- AdminPort uint32 `protobuf:"varint,8,opt,name=admin_port,json=adminPort" json:"admin_port,omitempty"`
- Volumes []*VolumeInformationMessage `protobuf:"bytes,9,rep,name=volumes" json:"volumes,omitempty"`
- // delta volumes
- NewVolumes []*VolumeShortInformationMessage `protobuf:"bytes,10,rep,name=new_volumes,json=newVolumes" json:"new_volumes,omitempty"`
- DeletedVolumes []*VolumeShortInformationMessage `protobuf:"bytes,11,rep,name=deleted_volumes,json=deletedVolumes" json:"deleted_volumes,omitempty"`
- HasNoVolumes bool `protobuf:"varint,12,opt,name=has_no_volumes,json=hasNoVolumes" json:"has_no_volumes,omitempty"`
- // erasure coding
- EcShards []*VolumeEcShardInformationMessage `protobuf:"bytes,16,rep,name=ec_shards,json=ecShards" json:"ec_shards,omitempty"`
- // delta erasure coding shards
- NewEcShards []*VolumeEcShardInformationMessage `protobuf:"bytes,17,rep,name=new_ec_shards,json=newEcShards" json:"new_ec_shards,omitempty"`
- DeletedEcShards []*VolumeEcShardInformationMessage `protobuf:"bytes,18,rep,name=deleted_ec_shards,json=deletedEcShards" json:"deleted_ec_shards,omitempty"`
- HasNoEcShards bool `protobuf:"varint,19,opt,name=has_no_ec_shards,json=hasNoEcShards" json:"has_no_ec_shards,omitempty"`
- }
- func (m *Heartbeat) Reset() { *m = Heartbeat{} }
- func (m *Heartbeat) String() string { return proto.CompactTextString(m) }
- func (*Heartbeat) ProtoMessage() {}
- func (*Heartbeat) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{0} }
- func (m *Heartbeat) GetIp() string {
- if m != nil {
- return m.Ip
- }
- return ""
- }
- func (m *Heartbeat) GetPort() uint32 {
- if m != nil {
- return m.Port
- }
- return 0
- }
- func (m *Heartbeat) GetPublicUrl() string {
- if m != nil {
- return m.PublicUrl
- }
- return ""
- }
- func (m *Heartbeat) GetMaxVolumeCount() uint32 {
- if m != nil {
- return m.MaxVolumeCount
- }
- return 0
- }
- func (m *Heartbeat) GetMaxFileKey() uint64 {
- if m != nil {
- return m.MaxFileKey
- }
- return 0
- }
- func (m *Heartbeat) GetDataCenter() string {
- if m != nil {
- return m.DataCenter
- }
- return ""
- }
- func (m *Heartbeat) GetRack() string {
- if m != nil {
- return m.Rack
- }
- return ""
- }
- func (m *Heartbeat) GetAdminPort() uint32 {
- if m != nil {
- return m.AdminPort
- }
- return 0
- }
- func (m *Heartbeat) GetVolumes() []*VolumeInformationMessage {
- if m != nil {
- return m.Volumes
- }
- return nil
- }
- func (m *Heartbeat) GetNewVolumes() []*VolumeShortInformationMessage {
- if m != nil {
- return m.NewVolumes
- }
- return nil
- }
- func (m *Heartbeat) GetDeletedVolumes() []*VolumeShortInformationMessage {
- if m != nil {
- return m.DeletedVolumes
- }
- return nil
- }
- func (m *Heartbeat) GetHasNoVolumes() bool {
- if m != nil {
- return m.HasNoVolumes
- }
- return false
- }
- func (m *Heartbeat) GetEcShards() []*VolumeEcShardInformationMessage {
- if m != nil {
- return m.EcShards
- }
- return nil
- }
- func (m *Heartbeat) GetNewEcShards() []*VolumeEcShardInformationMessage {
- if m != nil {
- return m.NewEcShards
- }
- return nil
- }
- func (m *Heartbeat) GetDeletedEcShards() []*VolumeEcShardInformationMessage {
- if m != nil {
- return m.DeletedEcShards
- }
- return nil
- }
- func (m *Heartbeat) GetHasNoEcShards() bool {
- if m != nil {
- return m.HasNoEcShards
- }
- return false
- }
- type HeartbeatResponse struct {
- VolumeSizeLimit uint64 `protobuf:"varint,1,opt,name=volume_size_limit,json=volumeSizeLimit" json:"volume_size_limit,omitempty"`
- Leader string `protobuf:"bytes,2,opt,name=leader" json:"leader,omitempty"`
- MetricsAddress string `protobuf:"bytes,3,opt,name=metrics_address,json=metricsAddress" json:"metrics_address,omitempty"`
- MetricsIntervalSeconds uint32 `protobuf:"varint,4,opt,name=metrics_interval_seconds,json=metricsIntervalSeconds" json:"metrics_interval_seconds,omitempty"`
- StorageBackends []*StorageBackend `protobuf:"bytes,5,rep,name=storage_backends,json=storageBackends" json:"storage_backends,omitempty"`
- }
- func (m *HeartbeatResponse) Reset() { *m = HeartbeatResponse{} }
- func (m *HeartbeatResponse) String() string { return proto.CompactTextString(m) }
- func (*HeartbeatResponse) ProtoMessage() {}
- func (*HeartbeatResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{1} }
- func (m *HeartbeatResponse) GetVolumeSizeLimit() uint64 {
- if m != nil {
- return m.VolumeSizeLimit
- }
- return 0
- }
- func (m *HeartbeatResponse) GetLeader() string {
- if m != nil {
- return m.Leader
- }
- return ""
- }
- func (m *HeartbeatResponse) GetMetricsAddress() string {
- if m != nil {
- return m.MetricsAddress
- }
- return ""
- }
- func (m *HeartbeatResponse) GetMetricsIntervalSeconds() uint32 {
- if m != nil {
- return m.MetricsIntervalSeconds
- }
- return 0
- }
- func (m *HeartbeatResponse) GetStorageBackends() []*StorageBackend {
- if m != nil {
- return m.StorageBackends
- }
- return nil
- }
- type VolumeInformationMessage struct {
- Id uint32 `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
- Size uint64 `protobuf:"varint,2,opt,name=size" json:"size,omitempty"`
- Collection string `protobuf:"bytes,3,opt,name=collection" json:"collection,omitempty"`
- FileCount uint64 `protobuf:"varint,4,opt,name=file_count,json=fileCount" json:"file_count,omitempty"`
- DeleteCount uint64 `protobuf:"varint,5,opt,name=delete_count,json=deleteCount" json:"delete_count,omitempty"`
- DeletedByteCount uint64 `protobuf:"varint,6,opt,name=deleted_byte_count,json=deletedByteCount" json:"deleted_byte_count,omitempty"`
- ReadOnly bool `protobuf:"varint,7,opt,name=read_only,json=readOnly" json:"read_only,omitempty"`
- ReplicaPlacement uint32 `protobuf:"varint,8,opt,name=replica_placement,json=replicaPlacement" json:"replica_placement,omitempty"`
- Version uint32 `protobuf:"varint,9,opt,name=version" json:"version,omitempty"`
- Ttl uint32 `protobuf:"varint,10,opt,name=ttl" json:"ttl,omitempty"`
- CompactRevision uint32 `protobuf:"varint,11,opt,name=compact_revision,json=compactRevision" json:"compact_revision,omitempty"`
- ModifiedAtSecond int64 `protobuf:"varint,12,opt,name=modified_at_second,json=modifiedAtSecond" json:"modified_at_second,omitempty"`
- RemoteStorageName string `protobuf:"bytes,13,opt,name=remote_storage_name,json=remoteStorageName" json:"remote_storage_name,omitempty"`
- RemoteStorageKey string `protobuf:"bytes,14,opt,name=remote_storage_key,json=remoteStorageKey" json:"remote_storage_key,omitempty"`
- }
- func (m *VolumeInformationMessage) Reset() { *m = VolumeInformationMessage{} }
- func (m *VolumeInformationMessage) String() string { return proto.CompactTextString(m) }
- func (*VolumeInformationMessage) ProtoMessage() {}
- func (*VolumeInformationMessage) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{2} }
- func (m *VolumeInformationMessage) GetId() uint32 {
- if m != nil {
- return m.Id
- }
- return 0
- }
- func (m *VolumeInformationMessage) GetSize() uint64 {
- if m != nil {
- return m.Size
- }
- return 0
- }
- func (m *VolumeInformationMessage) GetCollection() string {
- if m != nil {
- return m.Collection
- }
- return ""
- }
- func (m *VolumeInformationMessage) GetFileCount() uint64 {
- if m != nil {
- return m.FileCount
- }
- return 0
- }
- func (m *VolumeInformationMessage) GetDeleteCount() uint64 {
- if m != nil {
- return m.DeleteCount
- }
- return 0
- }
- func (m *VolumeInformationMessage) GetDeletedByteCount() uint64 {
- if m != nil {
- return m.DeletedByteCount
- }
- return 0
- }
- func (m *VolumeInformationMessage) GetReadOnly() bool {
- if m != nil {
- return m.ReadOnly
- }
- return false
- }
- func (m *VolumeInformationMessage) GetReplicaPlacement() uint32 {
- if m != nil {
- return m.ReplicaPlacement
- }
- return 0
- }
- func (m *VolumeInformationMessage) GetVersion() uint32 {
- if m != nil {
- return m.Version
- }
- return 0
- }
- func (m *VolumeInformationMessage) GetTtl() uint32 {
- if m != nil {
- return m.Ttl
- }
- return 0
- }
- func (m *VolumeInformationMessage) GetCompactRevision() uint32 {
- if m != nil {
- return m.CompactRevision
- }
- return 0
- }
- func (m *VolumeInformationMessage) GetModifiedAtSecond() int64 {
- if m != nil {
- return m.ModifiedAtSecond
- }
- return 0
- }
- func (m *VolumeInformationMessage) GetRemoteStorageName() string {
- if m != nil {
- return m.RemoteStorageName
- }
- return ""
- }
- func (m *VolumeInformationMessage) GetRemoteStorageKey() string {
- if m != nil {
- return m.RemoteStorageKey
- }
- return ""
- }
- type VolumeShortInformationMessage struct {
- Id uint32 `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
- Collection string `protobuf:"bytes,3,opt,name=collection" json:"collection,omitempty"`
- ReplicaPlacement uint32 `protobuf:"varint,8,opt,name=replica_placement,json=replicaPlacement" json:"replica_placement,omitempty"`
- Version uint32 `protobuf:"varint,9,opt,name=version" json:"version,omitempty"`
- Ttl uint32 `protobuf:"varint,10,opt,name=ttl" json:"ttl,omitempty"`
- }
- func (m *VolumeShortInformationMessage) Reset() { *m = VolumeShortInformationMessage{} }
- func (m *VolumeShortInformationMessage) String() string { return proto.CompactTextString(m) }
- func (*VolumeShortInformationMessage) ProtoMessage() {}
- func (*VolumeShortInformationMessage) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{3} }
- func (m *VolumeShortInformationMessage) GetId() uint32 {
- if m != nil {
- return m.Id
- }
- return 0
- }
- func (m *VolumeShortInformationMessage) GetCollection() string {
- if m != nil {
- return m.Collection
- }
- return ""
- }
- func (m *VolumeShortInformationMessage) GetReplicaPlacement() uint32 {
- if m != nil {
- return m.ReplicaPlacement
- }
- return 0
- }
- func (m *VolumeShortInformationMessage) GetVersion() uint32 {
- if m != nil {
- return m.Version
- }
- return 0
- }
- func (m *VolumeShortInformationMessage) GetTtl() uint32 {
- if m != nil {
- return m.Ttl
- }
- return 0
- }
- type VolumeEcShardInformationMessage struct {
- Id uint32 `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
- Collection string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
- EcIndexBits uint32 `protobuf:"varint,3,opt,name=ec_index_bits,json=ecIndexBits" json:"ec_index_bits,omitempty"`
- }
- func (m *VolumeEcShardInformationMessage) Reset() { *m = VolumeEcShardInformationMessage{} }
- func (m *VolumeEcShardInformationMessage) String() string { return proto.CompactTextString(m) }
- func (*VolumeEcShardInformationMessage) ProtoMessage() {}
- func (*VolumeEcShardInformationMessage) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{4} }
- func (m *VolumeEcShardInformationMessage) GetId() uint32 {
- if m != nil {
- return m.Id
- }
- return 0
- }
- func (m *VolumeEcShardInformationMessage) GetCollection() string {
- if m != nil {
- return m.Collection
- }
- return ""
- }
- func (m *VolumeEcShardInformationMessage) GetEcIndexBits() uint32 {
- if m != nil {
- return m.EcIndexBits
- }
- return 0
- }
- type StorageBackend struct {
- Type string `protobuf:"bytes,1,opt,name=type" json:"type,omitempty"`
- Id string `protobuf:"bytes,2,opt,name=id" json:"id,omitempty"`
- Properties map[string]string `protobuf:"bytes,3,rep,name=properties" json:"properties,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
- }
- func (m *StorageBackend) Reset() { *m = StorageBackend{} }
- func (m *StorageBackend) String() string { return proto.CompactTextString(m) }
- func (*StorageBackend) ProtoMessage() {}
- func (*StorageBackend) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{5} }
- func (m *StorageBackend) GetType() string {
- if m != nil {
- return m.Type
- }
- return ""
- }
- func (m *StorageBackend) GetId() string {
- if m != nil {
- return m.Id
- }
- return ""
- }
- func (m *StorageBackend) GetProperties() map[string]string {
- if m != nil {
- return m.Properties
- }
- return nil
- }
- type Empty struct {
- }
- func (m *Empty) Reset() { *m = Empty{} }
- func (m *Empty) String() string { return proto.CompactTextString(m) }
- func (*Empty) ProtoMessage() {}
- func (*Empty) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{6} }
- type SuperBlockExtra struct {
- ErasureCoding *SuperBlockExtra_ErasureCoding `protobuf:"bytes,1,opt,name=erasure_coding,json=erasureCoding" json:"erasure_coding,omitempty"`
- }
- func (m *SuperBlockExtra) Reset() { *m = SuperBlockExtra{} }
- func (m *SuperBlockExtra) String() string { return proto.CompactTextString(m) }
- func (*SuperBlockExtra) ProtoMessage() {}
- func (*SuperBlockExtra) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{7} }
- func (m *SuperBlockExtra) GetErasureCoding() *SuperBlockExtra_ErasureCoding {
- if m != nil {
- return m.ErasureCoding
- }
- return nil
- }
- type SuperBlockExtra_ErasureCoding struct {
- Data uint32 `protobuf:"varint,1,opt,name=data" json:"data,omitempty"`
- Parity uint32 `protobuf:"varint,2,opt,name=parity" json:"parity,omitempty"`
- VolumeIds []uint32 `protobuf:"varint,3,rep,packed,name=volume_ids,json=volumeIds" json:"volume_ids,omitempty"`
- }
- func (m *SuperBlockExtra_ErasureCoding) Reset() { *m = SuperBlockExtra_ErasureCoding{} }
- func (m *SuperBlockExtra_ErasureCoding) String() string { return proto.CompactTextString(m) }
- func (*SuperBlockExtra_ErasureCoding) ProtoMessage() {}
- func (*SuperBlockExtra_ErasureCoding) Descriptor() ([]byte, []int) {
- return fileDescriptor0, []int{7, 0}
- }
- func (m *SuperBlockExtra_ErasureCoding) GetData() uint32 {
- if m != nil {
- return m.Data
- }
- return 0
- }
- func (m *SuperBlockExtra_ErasureCoding) GetParity() uint32 {
- if m != nil {
- return m.Parity
- }
- return 0
- }
- func (m *SuperBlockExtra_ErasureCoding) GetVolumeIds() []uint32 {
- if m != nil {
- return m.VolumeIds
- }
- return nil
- }
- type KeepConnectedRequest struct {
- Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
- }
- func (m *KeepConnectedRequest) Reset() { *m = KeepConnectedRequest{} }
- func (m *KeepConnectedRequest) String() string { return proto.CompactTextString(m) }
- func (*KeepConnectedRequest) ProtoMessage() {}
- func (*KeepConnectedRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{8} }
- func (m *KeepConnectedRequest) GetName() string {
- if m != nil {
- return m.Name
- }
- return ""
- }
- type VolumeLocation struct {
- Url string `protobuf:"bytes,1,opt,name=url" json:"url,omitempty"`
- PublicUrl string `protobuf:"bytes,2,opt,name=public_url,json=publicUrl" json:"public_url,omitempty"`
- NewVids []uint32 `protobuf:"varint,3,rep,packed,name=new_vids,json=newVids" json:"new_vids,omitempty"`
- DeletedVids []uint32 `protobuf:"varint,4,rep,packed,name=deleted_vids,json=deletedVids" json:"deleted_vids,omitempty"`
- Leader string `protobuf:"bytes,5,opt,name=leader" json:"leader,omitempty"`
- }
- func (m *VolumeLocation) Reset() { *m = VolumeLocation{} }
- func (m *VolumeLocation) String() string { return proto.CompactTextString(m) }
- func (*VolumeLocation) ProtoMessage() {}
- func (*VolumeLocation) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{9} }
- func (m *VolumeLocation) GetUrl() string {
- if m != nil {
- return m.Url
- }
- return ""
- }
- func (m *VolumeLocation) GetPublicUrl() string {
- if m != nil {
- return m.PublicUrl
- }
- return ""
- }
- func (m *VolumeLocation) GetNewVids() []uint32 {
- if m != nil {
- return m.NewVids
- }
- return nil
- }
- func (m *VolumeLocation) GetDeletedVids() []uint32 {
- if m != nil {
- return m.DeletedVids
- }
- return nil
- }
- func (m *VolumeLocation) GetLeader() string {
- if m != nil {
- return m.Leader
- }
- return ""
- }
- type LookupVolumeRequest struct {
- VolumeIds []string `protobuf:"bytes,1,rep,name=volume_ids,json=volumeIds" json:"volume_ids,omitempty"`
- Collection string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
- }
- func (m *LookupVolumeRequest) Reset() { *m = LookupVolumeRequest{} }
- func (m *LookupVolumeRequest) String() string { return proto.CompactTextString(m) }
- func (*LookupVolumeRequest) ProtoMessage() {}
- func (*LookupVolumeRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{10} }
- func (m *LookupVolumeRequest) GetVolumeIds() []string {
- if m != nil {
- return m.VolumeIds
- }
- return nil
- }
- func (m *LookupVolumeRequest) GetCollection() string {
- if m != nil {
- return m.Collection
- }
- return ""
- }
- type LookupVolumeResponse struct {
- VolumeIdLocations []*LookupVolumeResponse_VolumeIdLocation `protobuf:"bytes,1,rep,name=volume_id_locations,json=volumeIdLocations" json:"volume_id_locations,omitempty"`
- }
- func (m *LookupVolumeResponse) Reset() { *m = LookupVolumeResponse{} }
- func (m *LookupVolumeResponse) String() string { return proto.CompactTextString(m) }
- func (*LookupVolumeResponse) ProtoMessage() {}
- func (*LookupVolumeResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{11} }
- func (m *LookupVolumeResponse) GetVolumeIdLocations() []*LookupVolumeResponse_VolumeIdLocation {
- if m != nil {
- return m.VolumeIdLocations
- }
- return nil
- }
- type LookupVolumeResponse_VolumeIdLocation struct {
- VolumeId string `protobuf:"bytes,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
- Locations []*Location `protobuf:"bytes,2,rep,name=locations" json:"locations,omitempty"`
- Error string `protobuf:"bytes,3,opt,name=error" json:"error,omitempty"`
- }
- func (m *LookupVolumeResponse_VolumeIdLocation) Reset() { *m = LookupVolumeResponse_VolumeIdLocation{} }
- func (m *LookupVolumeResponse_VolumeIdLocation) String() string { return proto.CompactTextString(m) }
- func (*LookupVolumeResponse_VolumeIdLocation) ProtoMessage() {}
- func (*LookupVolumeResponse_VolumeIdLocation) Descriptor() ([]byte, []int) {
- return fileDescriptor0, []int{11, 0}
- }
- func (m *LookupVolumeResponse_VolumeIdLocation) GetVolumeId() string {
- if m != nil {
- return m.VolumeId
- }
- return ""
- }
- func (m *LookupVolumeResponse_VolumeIdLocation) GetLocations() []*Location {
- if m != nil {
- return m.Locations
- }
- return nil
- }
- func (m *LookupVolumeResponse_VolumeIdLocation) GetError() string {
- if m != nil {
- return m.Error
- }
- return ""
- }
- type Location struct {
- Url string `protobuf:"bytes,1,opt,name=url" json:"url,omitempty"`
- PublicUrl string `protobuf:"bytes,2,opt,name=public_url,json=publicUrl" json:"public_url,omitempty"`
- }
- func (m *Location) Reset() { *m = Location{} }
- func (m *Location) String() string { return proto.CompactTextString(m) }
- func (*Location) ProtoMessage() {}
- func (*Location) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{12} }
- func (m *Location) GetUrl() string {
- if m != nil {
- return m.Url
- }
- return ""
- }
- func (m *Location) GetPublicUrl() string {
- if m != nil {
- return m.PublicUrl
- }
- return ""
- }
- type AssignRequest struct {
- Count uint64 `protobuf:"varint,1,opt,name=count" json:"count,omitempty"`
- Replication string `protobuf:"bytes,2,opt,name=replication" json:"replication,omitempty"`
- Collection string `protobuf:"bytes,3,opt,name=collection" json:"collection,omitempty"`
- Ttl string `protobuf:"bytes,4,opt,name=ttl" json:"ttl,omitempty"`
- DataCenter string `protobuf:"bytes,5,opt,name=data_center,json=dataCenter" json:"data_center,omitempty"`
- Rack string `protobuf:"bytes,6,opt,name=rack" json:"rack,omitempty"`
- DataNode string `protobuf:"bytes,7,opt,name=data_node,json=dataNode" json:"data_node,omitempty"`
- MemoryMapMaxSizeMb uint32 `protobuf:"varint,8,opt,name=memory_map_max_size_mb,json=memoryMapMaxSizeMb" json:"memory_map_max_size_mb,omitempty"`
- WritableVolumeCount uint32 `protobuf:"varint,9,opt,name=Writable_volume_count,json=WritableVolumeCount" json:"Writable_volume_count,omitempty"`
- }
- func (m *AssignRequest) Reset() { *m = AssignRequest{} }
- func (m *AssignRequest) String() string { return proto.CompactTextString(m) }
- func (*AssignRequest) ProtoMessage() {}
- func (*AssignRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{13} }
- func (m *AssignRequest) GetCount() uint64 {
- if m != nil {
- return m.Count
- }
- return 0
- }
- func (m *AssignRequest) GetReplication() string {
- if m != nil {
- return m.Replication
- }
- return ""
- }
- func (m *AssignRequest) GetCollection() string {
- if m != nil {
- return m.Collection
- }
- return ""
- }
- func (m *AssignRequest) GetTtl() string {
- if m != nil {
- return m.Ttl
- }
- return ""
- }
- func (m *AssignRequest) GetDataCenter() string {
- if m != nil {
- return m.DataCenter
- }
- return ""
- }
- func (m *AssignRequest) GetRack() string {
- if m != nil {
- return m.Rack
- }
- return ""
- }
- func (m *AssignRequest) GetDataNode() string {
- if m != nil {
- return m.DataNode
- }
- return ""
- }
- func (m *AssignRequest) GetMemoryMapMaxSizeMb() uint32 {
- if m != nil {
- return m.MemoryMapMaxSizeMb
- }
- return 0
- }
- func (m *AssignRequest) GetWritableVolumeCount() uint32 {
- if m != nil {
- return m.WritableVolumeCount
- }
- return 0
- }
- type AssignResponse struct {
- Fid string `protobuf:"bytes,1,opt,name=fid" json:"fid,omitempty"`
- Url string `protobuf:"bytes,2,opt,name=url" json:"url,omitempty"`
- PublicUrl string `protobuf:"bytes,3,opt,name=public_url,json=publicUrl" json:"public_url,omitempty"`
- Count uint64 `protobuf:"varint,4,opt,name=count" json:"count,omitempty"`
- Error string `protobuf:"bytes,5,opt,name=error" json:"error,omitempty"`
- Auth string `protobuf:"bytes,6,opt,name=auth" json:"auth,omitempty"`
- }
- func (m *AssignResponse) Reset() { *m = AssignResponse{} }
- func (m *AssignResponse) String() string { return proto.CompactTextString(m) }
- func (*AssignResponse) ProtoMessage() {}
- func (*AssignResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{14} }
- func (m *AssignResponse) GetFid() string {
- if m != nil {
- return m.Fid
- }
- return ""
- }
- func (m *AssignResponse) GetUrl() string {
- if m != nil {
- return m.Url
- }
- return ""
- }
- func (m *AssignResponse) GetPublicUrl() string {
- if m != nil {
- return m.PublicUrl
- }
- return ""
- }
- func (m *AssignResponse) GetCount() uint64 {
- if m != nil {
- return m.Count
- }
- return 0
- }
- func (m *AssignResponse) GetError() string {
- if m != nil {
- return m.Error
- }
- return ""
- }
- func (m *AssignResponse) GetAuth() string {
- if m != nil {
- return m.Auth
- }
- return ""
- }
- type StatisticsRequest struct {
- Replication string `protobuf:"bytes,1,opt,name=replication" json:"replication,omitempty"`
- Collection string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
- Ttl string `protobuf:"bytes,3,opt,name=ttl" json:"ttl,omitempty"`
- }
- func (m *StatisticsRequest) Reset() { *m = StatisticsRequest{} }
- func (m *StatisticsRequest) String() string { return proto.CompactTextString(m) }
- func (*StatisticsRequest) ProtoMessage() {}
- func (*StatisticsRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{15} }
- func (m *StatisticsRequest) GetReplication() string {
- if m != nil {
- return m.Replication
- }
- return ""
- }
- func (m *StatisticsRequest) GetCollection() string {
- if m != nil {
- return m.Collection
- }
- return ""
- }
- func (m *StatisticsRequest) GetTtl() string {
- if m != nil {
- return m.Ttl
- }
- return ""
- }
- type StatisticsResponse struct {
- Replication string `protobuf:"bytes,1,opt,name=replication" json:"replication,omitempty"`
- Collection string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
- Ttl string `protobuf:"bytes,3,opt,name=ttl" json:"ttl,omitempty"`
- TotalSize uint64 `protobuf:"varint,4,opt,name=total_size,json=totalSize" json:"total_size,omitempty"`
- UsedSize uint64 `protobuf:"varint,5,opt,name=used_size,json=usedSize" json:"used_size,omitempty"`
- FileCount uint64 `protobuf:"varint,6,opt,name=file_count,json=fileCount" json:"file_count,omitempty"`
- }
- func (m *StatisticsResponse) Reset() { *m = StatisticsResponse{} }
- func (m *StatisticsResponse) String() string { return proto.CompactTextString(m) }
- func (*StatisticsResponse) ProtoMessage() {}
- func (*StatisticsResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{16} }
- func (m *StatisticsResponse) GetReplication() string {
- if m != nil {
- return m.Replication
- }
- return ""
- }
- func (m *StatisticsResponse) GetCollection() string {
- if m != nil {
- return m.Collection
- }
- return ""
- }
- func (m *StatisticsResponse) GetTtl() string {
- if m != nil {
- return m.Ttl
- }
- return ""
- }
- func (m *StatisticsResponse) GetTotalSize() uint64 {
- if m != nil {
- return m.TotalSize
- }
- return 0
- }
- func (m *StatisticsResponse) GetUsedSize() uint64 {
- if m != nil {
- return m.UsedSize
- }
- return 0
- }
- func (m *StatisticsResponse) GetFileCount() uint64 {
- if m != nil {
- return m.FileCount
- }
- return 0
- }
- type StorageType struct {
- Replication string `protobuf:"bytes,1,opt,name=replication" json:"replication,omitempty"`
- Ttl string `protobuf:"bytes,2,opt,name=ttl" json:"ttl,omitempty"`
- }
- func (m *StorageType) Reset() { *m = StorageType{} }
- func (m *StorageType) String() string { return proto.CompactTextString(m) }
- func (*StorageType) ProtoMessage() {}
- func (*StorageType) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{17} }
- func (m *StorageType) GetReplication() string {
- if m != nil {
- return m.Replication
- }
- return ""
- }
- func (m *StorageType) GetTtl() string {
- if m != nil {
- return m.Ttl
- }
- return ""
- }
- type Collection struct {
- Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
- }
- func (m *Collection) Reset() { *m = Collection{} }
- func (m *Collection) String() string { return proto.CompactTextString(m) }
- func (*Collection) ProtoMessage() {}
- func (*Collection) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{18} }
- func (m *Collection) GetName() string {
- if m != nil {
- return m.Name
- }
- return ""
- }
- type CollectionListRequest struct {
- IncludeNormalVolumes bool `protobuf:"varint,1,opt,name=include_normal_volumes,json=includeNormalVolumes" json:"include_normal_volumes,omitempty"`
- IncludeEcVolumes bool `protobuf:"varint,2,opt,name=include_ec_volumes,json=includeEcVolumes" json:"include_ec_volumes,omitempty"`
- }
- func (m *CollectionListRequest) Reset() { *m = CollectionListRequest{} }
- func (m *CollectionListRequest) String() string { return proto.CompactTextString(m) }
- func (*CollectionListRequest) ProtoMessage() {}
- func (*CollectionListRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{19} }
- func (m *CollectionListRequest) GetIncludeNormalVolumes() bool {
- if m != nil {
- return m.IncludeNormalVolumes
- }
- return false
- }
- func (m *CollectionListRequest) GetIncludeEcVolumes() bool {
- if m != nil {
- return m.IncludeEcVolumes
- }
- return false
- }
- type CollectionListResponse struct {
- Collections []*Collection `protobuf:"bytes,1,rep,name=collections" json:"collections,omitempty"`
- }
- func (m *CollectionListResponse) Reset() { *m = CollectionListResponse{} }
- func (m *CollectionListResponse) String() string { return proto.CompactTextString(m) }
- func (*CollectionListResponse) ProtoMessage() {}
- func (*CollectionListResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{20} }
- func (m *CollectionListResponse) GetCollections() []*Collection {
- if m != nil {
- return m.Collections
- }
- return nil
- }
- type CollectionDeleteRequest struct {
- Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
- }
- func (m *CollectionDeleteRequest) Reset() { *m = CollectionDeleteRequest{} }
- func (m *CollectionDeleteRequest) String() string { return proto.CompactTextString(m) }
- func (*CollectionDeleteRequest) ProtoMessage() {}
- func (*CollectionDeleteRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{21} }
- func (m *CollectionDeleteRequest) GetName() string {
- if m != nil {
- return m.Name
- }
- return ""
- }
- type CollectionDeleteResponse struct {
- }
- func (m *CollectionDeleteResponse) Reset() { *m = CollectionDeleteResponse{} }
- func (m *CollectionDeleteResponse) String() string { return proto.CompactTextString(m) }
- func (*CollectionDeleteResponse) ProtoMessage() {}
- func (*CollectionDeleteResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{22} }
- //
- // volume related
- //
- type DataNodeInfo struct {
- Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
- VolumeCount uint64 `protobuf:"varint,2,opt,name=volume_count,json=volumeCount" json:"volume_count,omitempty"`
- MaxVolumeCount uint64 `protobuf:"varint,3,opt,name=max_volume_count,json=maxVolumeCount" json:"max_volume_count,omitempty"`
- FreeVolumeCount uint64 `protobuf:"varint,4,opt,name=free_volume_count,json=freeVolumeCount" json:"free_volume_count,omitempty"`
- ActiveVolumeCount uint64 `protobuf:"varint,5,opt,name=active_volume_count,json=activeVolumeCount" json:"active_volume_count,omitempty"`
- VolumeInfos []*VolumeInformationMessage `protobuf:"bytes,6,rep,name=volume_infos,json=volumeInfos" json:"volume_infos,omitempty"`
- EcShardInfos []*VolumeEcShardInformationMessage `protobuf:"bytes,7,rep,name=ec_shard_infos,json=ecShardInfos" json:"ec_shard_infos,omitempty"`
- RemoteVolumeCount uint64 `protobuf:"varint,8,opt,name=remote_volume_count,json=remoteVolumeCount" json:"remote_volume_count,omitempty"`
- }
- func (m *DataNodeInfo) Reset() { *m = DataNodeInfo{} }
- func (m *DataNodeInfo) String() string { return proto.CompactTextString(m) }
- func (*DataNodeInfo) ProtoMessage() {}
- func (*DataNodeInfo) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{23} }
- func (m *DataNodeInfo) GetId() string {
- if m != nil {
- return m.Id
- }
- return ""
- }
- func (m *DataNodeInfo) GetVolumeCount() uint64 {
- if m != nil {
- return m.VolumeCount
- }
- return 0
- }
- func (m *DataNodeInfo) GetMaxVolumeCount() uint64 {
- if m != nil {
- return m.MaxVolumeCount
- }
- return 0
- }
- func (m *DataNodeInfo) GetFreeVolumeCount() uint64 {
- if m != nil {
- return m.FreeVolumeCount
- }
- return 0
- }
- func (m *DataNodeInfo) GetActiveVolumeCount() uint64 {
- if m != nil {
- return m.ActiveVolumeCount
- }
- return 0
- }
- func (m *DataNodeInfo) GetVolumeInfos() []*VolumeInformationMessage {
- if m != nil {
- return m.VolumeInfos
- }
- return nil
- }
- func (m *DataNodeInfo) GetEcShardInfos() []*VolumeEcShardInformationMessage {
- if m != nil {
- return m.EcShardInfos
- }
- return nil
- }
- func (m *DataNodeInfo) GetRemoteVolumeCount() uint64 {
- if m != nil {
- return m.RemoteVolumeCount
- }
- return 0
- }
- type RackInfo struct {
- Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
- VolumeCount uint64 `protobuf:"varint,2,opt,name=volume_count,json=volumeCount" json:"volume_count,omitempty"`
- MaxVolumeCount uint64 `protobuf:"varint,3,opt,name=max_volume_count,json=maxVolumeCount" json:"max_volume_count,omitempty"`
- FreeVolumeCount uint64 `protobuf:"varint,4,opt,name=free_volume_count,json=freeVolumeCount" json:"free_volume_count,omitempty"`
- ActiveVolumeCount uint64 `protobuf:"varint,5,opt,name=active_volume_count,json=activeVolumeCount" json:"active_volume_count,omitempty"`
- DataNodeInfos []*DataNodeInfo `protobuf:"bytes,6,rep,name=data_node_infos,json=dataNodeInfos" json:"data_node_infos,omitempty"`
- RemoteVolumeCount uint64 `protobuf:"varint,7,opt,name=remote_volume_count,json=remoteVolumeCount" json:"remote_volume_count,omitempty"`
- }
- func (m *RackInfo) Reset() { *m = RackInfo{} }
- func (m *RackInfo) String() string { return proto.CompactTextString(m) }
- func (*RackInfo) ProtoMessage() {}
- func (*RackInfo) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{24} }
- func (m *RackInfo) GetId() string {
- if m != nil {
- return m.Id
- }
- return ""
- }
- func (m *RackInfo) GetVolumeCount() uint64 {
- if m != nil {
- return m.VolumeCount
- }
- return 0
- }
- func (m *RackInfo) GetMaxVolumeCount() uint64 {
- if m != nil {
- return m.MaxVolumeCount
- }
- return 0
- }
- func (m *RackInfo) GetFreeVolumeCount() uint64 {
- if m != nil {
- return m.FreeVolumeCount
- }
- return 0
- }
- func (m *RackInfo) GetActiveVolumeCount() uint64 {
- if m != nil {
- return m.ActiveVolumeCount
- }
- return 0
- }
- func (m *RackInfo) GetDataNodeInfos() []*DataNodeInfo {
- if m != nil {
- return m.DataNodeInfos
- }
- return nil
- }
- func (m *RackInfo) GetRemoteVolumeCount() uint64 {
- if m != nil {
- return m.RemoteVolumeCount
- }
- return 0
- }
- type DataCenterInfo struct {
- Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
- VolumeCount uint64 `protobuf:"varint,2,opt,name=volume_count,json=volumeCount" json:"volume_count,omitempty"`
- MaxVolumeCount uint64 `protobuf:"varint,3,opt,name=max_volume_count,json=maxVolumeCount" json:"max_volume_count,omitempty"`
- FreeVolumeCount uint64 `protobuf:"varint,4,opt,name=free_volume_count,json=freeVolumeCount" json:"free_volume_count,omitempty"`
- ActiveVolumeCount uint64 `protobuf:"varint,5,opt,name=active_volume_count,json=activeVolumeCount" json:"active_volume_count,omitempty"`
- RackInfos []*RackInfo `protobuf:"bytes,6,rep,name=rack_infos,json=rackInfos" json:"rack_infos,omitempty"`
- RemoteVolumeCount uint64 `protobuf:"varint,7,opt,name=remote_volume_count,json=remoteVolumeCount" json:"remote_volume_count,omitempty"`
- }
- func (m *DataCenterInfo) Reset() { *m = DataCenterInfo{} }
- func (m *DataCenterInfo) String() string { return proto.CompactTextString(m) }
- func (*DataCenterInfo) ProtoMessage() {}
- func (*DataCenterInfo) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{25} }
- func (m *DataCenterInfo) GetId() string {
- if m != nil {
- return m.Id
- }
- return ""
- }
- func (m *DataCenterInfo) GetVolumeCount() uint64 {
- if m != nil {
- return m.VolumeCount
- }
- return 0
- }
- func (m *DataCenterInfo) GetMaxVolumeCount() uint64 {
- if m != nil {
- return m.MaxVolumeCount
- }
- return 0
- }
- func (m *DataCenterInfo) GetFreeVolumeCount() uint64 {
- if m != nil {
- return m.FreeVolumeCount
- }
- return 0
- }
- func (m *DataCenterInfo) GetActiveVolumeCount() uint64 {
- if m != nil {
- return m.ActiveVolumeCount
- }
- return 0
- }
- func (m *DataCenterInfo) GetRackInfos() []*RackInfo {
- if m != nil {
- return m.RackInfos
- }
- return nil
- }
- func (m *DataCenterInfo) GetRemoteVolumeCount() uint64 {
- if m != nil {
- return m.RemoteVolumeCount
- }
- return 0
- }
- type TopologyInfo struct {
- Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
- VolumeCount uint64 `protobuf:"varint,2,opt,name=volume_count,json=volumeCount" json:"volume_count,omitempty"`
- MaxVolumeCount uint64 `protobuf:"varint,3,opt,name=max_volume_count,json=maxVolumeCount" json:"max_volume_count,omitempty"`
- FreeVolumeCount uint64 `protobuf:"varint,4,opt,name=free_volume_count,json=freeVolumeCount" json:"free_volume_count,omitempty"`
- ActiveVolumeCount uint64 `protobuf:"varint,5,opt,name=active_volume_count,json=activeVolumeCount" json:"active_volume_count,omitempty"`
- DataCenterInfos []*DataCenterInfo `protobuf:"bytes,6,rep,name=data_center_infos,json=dataCenterInfos" json:"data_center_infos,omitempty"`
- RemoteVolumeCount uint64 `protobuf:"varint,7,opt,name=remote_volume_count,json=remoteVolumeCount" json:"remote_volume_count,omitempty"`
- }
- func (m *TopologyInfo) Reset() { *m = TopologyInfo{} }
- func (m *TopologyInfo) String() string { return proto.CompactTextString(m) }
- func (*TopologyInfo) ProtoMessage() {}
- func (*TopologyInfo) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{26} }
- func (m *TopologyInfo) GetId() string {
- if m != nil {
- return m.Id
- }
- return ""
- }
- func (m *TopologyInfo) GetVolumeCount() uint64 {
- if m != nil {
- return m.VolumeCount
- }
- return 0
- }
- func (m *TopologyInfo) GetMaxVolumeCount() uint64 {
- if m != nil {
- return m.MaxVolumeCount
- }
- return 0
- }
- func (m *TopologyInfo) GetFreeVolumeCount() uint64 {
- if m != nil {
- return m.FreeVolumeCount
- }
- return 0
- }
- func (m *TopologyInfo) GetActiveVolumeCount() uint64 {
- if m != nil {
- return m.ActiveVolumeCount
- }
- return 0
- }
- func (m *TopologyInfo) GetDataCenterInfos() []*DataCenterInfo {
- if m != nil {
- return m.DataCenterInfos
- }
- return nil
- }
- func (m *TopologyInfo) GetRemoteVolumeCount() uint64 {
- if m != nil {
- return m.RemoteVolumeCount
- }
- return 0
- }
- type VolumeListRequest struct {
- }
- func (m *VolumeListRequest) Reset() { *m = VolumeListRequest{} }
- func (m *VolumeListRequest) String() string { return proto.CompactTextString(m) }
- func (*VolumeListRequest) ProtoMessage() {}
- func (*VolumeListRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{27} }
- type VolumeListResponse struct {
- TopologyInfo *TopologyInfo `protobuf:"bytes,1,opt,name=topology_info,json=topologyInfo" json:"topology_info,omitempty"`
- VolumeSizeLimitMb uint64 `protobuf:"varint,2,opt,name=volume_size_limit_mb,json=volumeSizeLimitMb" json:"volume_size_limit_mb,omitempty"`
- }
- func (m *VolumeListResponse) Reset() { *m = VolumeListResponse{} }
- func (m *VolumeListResponse) String() string { return proto.CompactTextString(m) }
- func (*VolumeListResponse) ProtoMessage() {}
- func (*VolumeListResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{28} }
- func (m *VolumeListResponse) GetTopologyInfo() *TopologyInfo {
- if m != nil {
- return m.TopologyInfo
- }
- return nil
- }
- func (m *VolumeListResponse) GetVolumeSizeLimitMb() uint64 {
- if m != nil {
- return m.VolumeSizeLimitMb
- }
- return 0
- }
- type LookupEcVolumeRequest struct {
- VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
- }
- func (m *LookupEcVolumeRequest) Reset() { *m = LookupEcVolumeRequest{} }
- func (m *LookupEcVolumeRequest) String() string { return proto.CompactTextString(m) }
- func (*LookupEcVolumeRequest) ProtoMessage() {}
- func (*LookupEcVolumeRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{29} }
- func (m *LookupEcVolumeRequest) GetVolumeId() uint32 {
- if m != nil {
- return m.VolumeId
- }
- return 0
- }
- type LookupEcVolumeResponse struct {
- VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
- ShardIdLocations []*LookupEcVolumeResponse_EcShardIdLocation `protobuf:"bytes,2,rep,name=shard_id_locations,json=shardIdLocations" json:"shard_id_locations,omitempty"`
- }
- func (m *LookupEcVolumeResponse) Reset() { *m = LookupEcVolumeResponse{} }
- func (m *LookupEcVolumeResponse) String() string { return proto.CompactTextString(m) }
- func (*LookupEcVolumeResponse) ProtoMessage() {}
- func (*LookupEcVolumeResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{30} }
- func (m *LookupEcVolumeResponse) GetVolumeId() uint32 {
- if m != nil {
- return m.VolumeId
- }
- return 0
- }
- func (m *LookupEcVolumeResponse) GetShardIdLocations() []*LookupEcVolumeResponse_EcShardIdLocation {
- if m != nil {
- return m.ShardIdLocations
- }
- return nil
- }
- type LookupEcVolumeResponse_EcShardIdLocation struct {
- ShardId uint32 `protobuf:"varint,1,opt,name=shard_id,json=shardId" json:"shard_id,omitempty"`
- Locations []*Location `protobuf:"bytes,2,rep,name=locations" json:"locations,omitempty"`
- }
- func (m *LookupEcVolumeResponse_EcShardIdLocation) Reset() {
- *m = LookupEcVolumeResponse_EcShardIdLocation{}
- }
- func (m *LookupEcVolumeResponse_EcShardIdLocation) String() string { return proto.CompactTextString(m) }
- func (*LookupEcVolumeResponse_EcShardIdLocation) ProtoMessage() {}
- func (*LookupEcVolumeResponse_EcShardIdLocation) Descriptor() ([]byte, []int) {
- return fileDescriptor0, []int{30, 0}
- }
- func (m *LookupEcVolumeResponse_EcShardIdLocation) GetShardId() uint32 {
- if m != nil {
- return m.ShardId
- }
- return 0
- }
- func (m *LookupEcVolumeResponse_EcShardIdLocation) GetLocations() []*Location {
- if m != nil {
- return m.Locations
- }
- return nil
- }
- type GetMasterConfigurationRequest struct {
- }
- func (m *GetMasterConfigurationRequest) Reset() { *m = GetMasterConfigurationRequest{} }
- func (m *GetMasterConfigurationRequest) String() string { return proto.CompactTextString(m) }
- func (*GetMasterConfigurationRequest) ProtoMessage() {}
- func (*GetMasterConfigurationRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{31} }
- type GetMasterConfigurationResponse struct {
- MetricsAddress string `protobuf:"bytes,1,opt,name=metrics_address,json=metricsAddress" json:"metrics_address,omitempty"`
- MetricsIntervalSeconds uint32 `protobuf:"varint,2,opt,name=metrics_interval_seconds,json=metricsIntervalSeconds" json:"metrics_interval_seconds,omitempty"`
- }
- func (m *GetMasterConfigurationResponse) Reset() { *m = GetMasterConfigurationResponse{} }
- func (m *GetMasterConfigurationResponse) String() string { return proto.CompactTextString(m) }
- func (*GetMasterConfigurationResponse) ProtoMessage() {}
- func (*GetMasterConfigurationResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{32} }
- func (m *GetMasterConfigurationResponse) GetMetricsAddress() string {
- if m != nil {
- return m.MetricsAddress
- }
- return ""
- }
- func (m *GetMasterConfigurationResponse) GetMetricsIntervalSeconds() uint32 {
- if m != nil {
- return m.MetricsIntervalSeconds
- }
- return 0
- }
- func init() {
- proto.RegisterType((*Heartbeat)(nil), "master_pb.Heartbeat")
- proto.RegisterType((*HeartbeatResponse)(nil), "master_pb.HeartbeatResponse")
- proto.RegisterType((*VolumeInformationMessage)(nil), "master_pb.VolumeInformationMessage")
- proto.RegisterType((*VolumeShortInformationMessage)(nil), "master_pb.VolumeShortInformationMessage")
- proto.RegisterType((*VolumeEcShardInformationMessage)(nil), "master_pb.VolumeEcShardInformationMessage")
- proto.RegisterType((*StorageBackend)(nil), "master_pb.StorageBackend")
- proto.RegisterType((*Empty)(nil), "master_pb.Empty")
- proto.RegisterType((*SuperBlockExtra)(nil), "master_pb.SuperBlockExtra")
- proto.RegisterType((*SuperBlockExtra_ErasureCoding)(nil), "master_pb.SuperBlockExtra.ErasureCoding")
- proto.RegisterType((*KeepConnectedRequest)(nil), "master_pb.KeepConnectedRequest")
- proto.RegisterType((*VolumeLocation)(nil), "master_pb.VolumeLocation")
- proto.RegisterType((*LookupVolumeRequest)(nil), "master_pb.LookupVolumeRequest")
- proto.RegisterType((*LookupVolumeResponse)(nil), "master_pb.LookupVolumeResponse")
- proto.RegisterType((*LookupVolumeResponse_VolumeIdLocation)(nil), "master_pb.LookupVolumeResponse.VolumeIdLocation")
- proto.RegisterType((*Location)(nil), "master_pb.Location")
- proto.RegisterType((*AssignRequest)(nil), "master_pb.AssignRequest")
- proto.RegisterType((*AssignResponse)(nil), "master_pb.AssignResponse")
- proto.RegisterType((*StatisticsRequest)(nil), "master_pb.StatisticsRequest")
- proto.RegisterType((*StatisticsResponse)(nil), "master_pb.StatisticsResponse")
- proto.RegisterType((*StorageType)(nil), "master_pb.StorageType")
- proto.RegisterType((*Collection)(nil), "master_pb.Collection")
- proto.RegisterType((*CollectionListRequest)(nil), "master_pb.CollectionListRequest")
- proto.RegisterType((*CollectionListResponse)(nil), "master_pb.CollectionListResponse")
- proto.RegisterType((*CollectionDeleteRequest)(nil), "master_pb.CollectionDeleteRequest")
- proto.RegisterType((*CollectionDeleteResponse)(nil), "master_pb.CollectionDeleteResponse")
- proto.RegisterType((*DataNodeInfo)(nil), "master_pb.DataNodeInfo")
- proto.RegisterType((*RackInfo)(nil), "master_pb.RackInfo")
- proto.RegisterType((*DataCenterInfo)(nil), "master_pb.DataCenterInfo")
- proto.RegisterType((*TopologyInfo)(nil), "master_pb.TopologyInfo")
- proto.RegisterType((*VolumeListRequest)(nil), "master_pb.VolumeListRequest")
- proto.RegisterType((*VolumeListResponse)(nil), "master_pb.VolumeListResponse")
- proto.RegisterType((*LookupEcVolumeRequest)(nil), "master_pb.LookupEcVolumeRequest")
- proto.RegisterType((*LookupEcVolumeResponse)(nil), "master_pb.LookupEcVolumeResponse")
- proto.RegisterType((*LookupEcVolumeResponse_EcShardIdLocation)(nil), "master_pb.LookupEcVolumeResponse.EcShardIdLocation")
- proto.RegisterType((*GetMasterConfigurationRequest)(nil), "master_pb.GetMasterConfigurationRequest")
- proto.RegisterType((*GetMasterConfigurationResponse)(nil), "master_pb.GetMasterConfigurationResponse")
- }
- // Reference imports to suppress errors if they are not otherwise used.
- var _ context.Context
- var _ grpc.ClientConn
- // This is a compile-time assertion to ensure that this generated file
- // is compatible with the grpc package it is being compiled against.
- const _ = grpc.SupportPackageIsVersion4
- // Client API for Seaweed service
- type SeaweedClient interface {
- SendHeartbeat(ctx context.Context, opts ...grpc.CallOption) (Seaweed_SendHeartbeatClient, error)
- KeepConnected(ctx context.Context, opts ...grpc.CallOption) (Seaweed_KeepConnectedClient, error)
- LookupVolume(ctx context.Context, in *LookupVolumeRequest, opts ...grpc.CallOption) (*LookupVolumeResponse, error)
- Assign(ctx context.Context, in *AssignRequest, opts ...grpc.CallOption) (*AssignResponse, error)
- Statistics(ctx context.Context, in *StatisticsRequest, opts ...grpc.CallOption) (*StatisticsResponse, error)
- CollectionList(ctx context.Context, in *CollectionListRequest, opts ...grpc.CallOption) (*CollectionListResponse, error)
- CollectionDelete(ctx context.Context, in *CollectionDeleteRequest, opts ...grpc.CallOption) (*CollectionDeleteResponse, error)
- VolumeList(ctx context.Context, in *VolumeListRequest, opts ...grpc.CallOption) (*VolumeListResponse, error)
- LookupEcVolume(ctx context.Context, in *LookupEcVolumeRequest, opts ...grpc.CallOption) (*LookupEcVolumeResponse, error)
- GetMasterConfiguration(ctx context.Context, in *GetMasterConfigurationRequest, opts ...grpc.CallOption) (*GetMasterConfigurationResponse, error)
- }
- type seaweedClient struct {
- cc *grpc.ClientConn
- }
- func NewSeaweedClient(cc *grpc.ClientConn) SeaweedClient {
- return &seaweedClient{cc}
- }
- func (c *seaweedClient) SendHeartbeat(ctx context.Context, opts ...grpc.CallOption) (Seaweed_SendHeartbeatClient, error) {
- stream, err := grpc.NewClientStream(ctx, &_Seaweed_serviceDesc.Streams[0], c.cc, "/master_pb.Seaweed/SendHeartbeat", opts...)
- if err != nil {
- return nil, err
- }
- x := &seaweedSendHeartbeatClient{stream}
- return x, nil
- }
- type Seaweed_SendHeartbeatClient interface {
- Send(*Heartbeat) error
- Recv() (*HeartbeatResponse, error)
- grpc.ClientStream
- }
- type seaweedSendHeartbeatClient struct {
- grpc.ClientStream
- }
- func (x *seaweedSendHeartbeatClient) Send(m *Heartbeat) error {
- return x.ClientStream.SendMsg(m)
- }
- func (x *seaweedSendHeartbeatClient) Recv() (*HeartbeatResponse, error) {
- m := new(HeartbeatResponse)
- if err := x.ClientStream.RecvMsg(m); err != nil {
- return nil, err
- }
- return m, nil
- }
- func (c *seaweedClient) KeepConnected(ctx context.Context, opts ...grpc.CallOption) (Seaweed_KeepConnectedClient, error) {
- stream, err := grpc.NewClientStream(ctx, &_Seaweed_serviceDesc.Streams[1], c.cc, "/master_pb.Seaweed/KeepConnected", opts...)
- if err != nil {
- return nil, err
- }
- x := &seaweedKeepConnectedClient{stream}
- return x, nil
- }
- type Seaweed_KeepConnectedClient interface {
- Send(*KeepConnectedRequest) error
- Recv() (*VolumeLocation, error)
- grpc.ClientStream
- }
- type seaweedKeepConnectedClient struct {
- grpc.ClientStream
- }
- func (x *seaweedKeepConnectedClient) Send(m *KeepConnectedRequest) error {
- return x.ClientStream.SendMsg(m)
- }
- func (x *seaweedKeepConnectedClient) Recv() (*VolumeLocation, error) {
- m := new(VolumeLocation)
- if err := x.ClientStream.RecvMsg(m); err != nil {
- return nil, err
- }
- return m, nil
- }
- func (c *seaweedClient) LookupVolume(ctx context.Context, in *LookupVolumeRequest, opts ...grpc.CallOption) (*LookupVolumeResponse, error) {
- out := new(LookupVolumeResponse)
- err := grpc.Invoke(ctx, "/master_pb.Seaweed/LookupVolume", in, out, c.cc, opts...)
- if err != nil {
- return nil, err
- }
- return out, nil
- }
- func (c *seaweedClient) Assign(ctx context.Context, in *AssignRequest, opts ...grpc.CallOption) (*AssignResponse, error) {
- out := new(AssignResponse)
- err := grpc.Invoke(ctx, "/master_pb.Seaweed/Assign", in, out, c.cc, opts...)
- if err != nil {
- return nil, err
- }
- return out, nil
- }
- func (c *seaweedClient) Statistics(ctx context.Context, in *StatisticsRequest, opts ...grpc.CallOption) (*StatisticsResponse, error) {
- out := new(StatisticsResponse)
- err := grpc.Invoke(ctx, "/master_pb.Seaweed/Statistics", in, out, c.cc, opts...)
- if err != nil {
- return nil, err
- }
- return out, nil
- }
- func (c *seaweedClient) CollectionList(ctx context.Context, in *CollectionListRequest, opts ...grpc.CallOption) (*CollectionListResponse, error) {
- out := new(CollectionListResponse)
- err := grpc.Invoke(ctx, "/master_pb.Seaweed/CollectionList", in, out, c.cc, opts...)
- if err != nil {
- return nil, err
- }
- return out, nil
- }
- func (c *seaweedClient) CollectionDelete(ctx context.Context, in *CollectionDeleteRequest, opts ...grpc.CallOption) (*CollectionDeleteResponse, error) {
- out := new(CollectionDeleteResponse)
- err := grpc.Invoke(ctx, "/master_pb.Seaweed/CollectionDelete", in, out, c.cc, opts...)
- if err != nil {
- return nil, err
- }
- return out, nil
- }
- func (c *seaweedClient) VolumeList(ctx context.Context, in *VolumeListRequest, opts ...grpc.CallOption) (*VolumeListResponse, error) {
- out := new(VolumeListResponse)
- err := grpc.Invoke(ctx, "/master_pb.Seaweed/VolumeList", in, out, c.cc, opts...)
- if err != nil {
- return nil, err
- }
- return out, nil
- }
- func (c *seaweedClient) LookupEcVolume(ctx context.Context, in *LookupEcVolumeRequest, opts ...grpc.CallOption) (*LookupEcVolumeResponse, error) {
- out := new(LookupEcVolumeResponse)
- err := grpc.Invoke(ctx, "/master_pb.Seaweed/LookupEcVolume", in, out, c.cc, opts...)
- if err != nil {
- return nil, err
- }
- return out, nil
- }
- func (c *seaweedClient) GetMasterConfiguration(ctx context.Context, in *GetMasterConfigurationRequest, opts ...grpc.CallOption) (*GetMasterConfigurationResponse, error) {
- out := new(GetMasterConfigurationResponse)
- err := grpc.Invoke(ctx, "/master_pb.Seaweed/GetMasterConfiguration", in, out, c.cc, opts...)
- if err != nil {
- return nil, err
- }
- return out, nil
- }
- // Server API for Seaweed service
- type SeaweedServer interface {
- SendHeartbeat(Seaweed_SendHeartbeatServer) error
- KeepConnected(Seaweed_KeepConnectedServer) error
- LookupVolume(context.Context, *LookupVolumeRequest) (*LookupVolumeResponse, error)
- Assign(context.Context, *AssignRequest) (*AssignResponse, error)
- Statistics(context.Context, *StatisticsRequest) (*StatisticsResponse, error)
- CollectionList(context.Context, *CollectionListRequest) (*CollectionListResponse, error)
- CollectionDelete(context.Context, *CollectionDeleteRequest) (*CollectionDeleteResponse, error)
- VolumeList(context.Context, *VolumeListRequest) (*VolumeListResponse, error)
- LookupEcVolume(context.Context, *LookupEcVolumeRequest) (*LookupEcVolumeResponse, error)
- GetMasterConfiguration(context.Context, *GetMasterConfigurationRequest) (*GetMasterConfigurationResponse, error)
- }
- func RegisterSeaweedServer(s *grpc.Server, srv SeaweedServer) {
- s.RegisterService(&_Seaweed_serviceDesc, srv)
- }
- func _Seaweed_SendHeartbeat_Handler(srv interface{}, stream grpc.ServerStream) error {
- return srv.(SeaweedServer).SendHeartbeat(&seaweedSendHeartbeatServer{stream})
- }
- type Seaweed_SendHeartbeatServer interface {
- Send(*HeartbeatResponse) error
- Recv() (*Heartbeat, error)
- grpc.ServerStream
- }
- type seaweedSendHeartbeatServer struct {
- grpc.ServerStream
- }
- func (x *seaweedSendHeartbeatServer) Send(m *HeartbeatResponse) error {
- return x.ServerStream.SendMsg(m)
- }
- func (x *seaweedSendHeartbeatServer) Recv() (*Heartbeat, error) {
- m := new(Heartbeat)
- if err := x.ServerStream.RecvMsg(m); err != nil {
- return nil, err
- }
- return m, nil
- }
- func _Seaweed_KeepConnected_Handler(srv interface{}, stream grpc.ServerStream) error {
- return srv.(SeaweedServer).KeepConnected(&seaweedKeepConnectedServer{stream})
- }
- type Seaweed_KeepConnectedServer interface {
- Send(*VolumeLocation) error
- Recv() (*KeepConnectedRequest, error)
- grpc.ServerStream
- }
- type seaweedKeepConnectedServer struct {
- grpc.ServerStream
- }
- func (x *seaweedKeepConnectedServer) Send(m *VolumeLocation) error {
- return x.ServerStream.SendMsg(m)
- }
- func (x *seaweedKeepConnectedServer) Recv() (*KeepConnectedRequest, error) {
- m := new(KeepConnectedRequest)
- if err := x.ServerStream.RecvMsg(m); err != nil {
- return nil, err
- }
- return m, nil
- }
- func _Seaweed_LookupVolume_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
- in := new(LookupVolumeRequest)
- if err := dec(in); err != nil {
- return nil, err
- }
- if interceptor == nil {
- return srv.(SeaweedServer).LookupVolume(ctx, in)
- }
- info := &grpc.UnaryServerInfo{
- Server: srv,
- FullMethod: "/master_pb.Seaweed/LookupVolume",
- }
- handler := func(ctx context.Context, req interface{}) (interface{}, error) {
- return srv.(SeaweedServer).LookupVolume(ctx, req.(*LookupVolumeRequest))
- }
- return interceptor(ctx, in, info, handler)
- }
- func _Seaweed_Assign_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
- in := new(AssignRequest)
- if err := dec(in); err != nil {
- return nil, err
- }
- if interceptor == nil {
- return srv.(SeaweedServer).Assign(ctx, in)
- }
- info := &grpc.UnaryServerInfo{
- Server: srv,
- FullMethod: "/master_pb.Seaweed/Assign",
- }
- handler := func(ctx context.Context, req interface{}) (interface{}, error) {
- return srv.(SeaweedServer).Assign(ctx, req.(*AssignRequest))
- }
- return interceptor(ctx, in, info, handler)
- }
- func _Seaweed_Statistics_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
- in := new(StatisticsRequest)
- if err := dec(in); err != nil {
- return nil, err
- }
- if interceptor == nil {
- return srv.(SeaweedServer).Statistics(ctx, in)
- }
- info := &grpc.UnaryServerInfo{
- Server: srv,
- FullMethod: "/master_pb.Seaweed/Statistics",
- }
- handler := func(ctx context.Context, req interface{}) (interface{}, error) {
- return srv.(SeaweedServer).Statistics(ctx, req.(*StatisticsRequest))
- }
- return interceptor(ctx, in, info, handler)
- }
- func _Seaweed_CollectionList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
- in := new(CollectionListRequest)
- if err := dec(in); err != nil {
- return nil, err
- }
- if interceptor == nil {
- return srv.(SeaweedServer).CollectionList(ctx, in)
- }
- info := &grpc.UnaryServerInfo{
- Server: srv,
- FullMethod: "/master_pb.Seaweed/CollectionList",
- }
- handler := func(ctx context.Context, req interface{}) (interface{}, error) {
- return srv.(SeaweedServer).CollectionList(ctx, req.(*CollectionListRequest))
- }
- return interceptor(ctx, in, info, handler)
- }
- func _Seaweed_CollectionDelete_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
- in := new(CollectionDeleteRequest)
- if err := dec(in); err != nil {
- return nil, err
- }
- if interceptor == nil {
- return srv.(SeaweedServer).CollectionDelete(ctx, in)
- }
- info := &grpc.UnaryServerInfo{
- Server: srv,
- FullMethod: "/master_pb.Seaweed/CollectionDelete",
- }
- handler := func(ctx context.Context, req interface{}) (interface{}, error) {
- return srv.(SeaweedServer).CollectionDelete(ctx, req.(*CollectionDeleteRequest))
- }
- return interceptor(ctx, in, info, handler)
- }
- func _Seaweed_VolumeList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
- in := new(VolumeListRequest)
- if err := dec(in); err != nil {
- return nil, err
- }
- if interceptor == nil {
- return srv.(SeaweedServer).VolumeList(ctx, in)
- }
- info := &grpc.UnaryServerInfo{
- Server: srv,
- FullMethod: "/master_pb.Seaweed/VolumeList",
- }
- handler := func(ctx context.Context, req interface{}) (interface{}, error) {
- return srv.(SeaweedServer).VolumeList(ctx, req.(*VolumeListRequest))
- }
- return interceptor(ctx, in, info, handler)
- }
- func _Seaweed_LookupEcVolume_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
- in := new(LookupEcVolumeRequest)
- if err := dec(in); err != nil {
- return nil, err
- }
- if interceptor == nil {
- return srv.(SeaweedServer).LookupEcVolume(ctx, in)
- }
- info := &grpc.UnaryServerInfo{
- Server: srv,
- FullMethod: "/master_pb.Seaweed/LookupEcVolume",
- }
- handler := func(ctx context.Context, req interface{}) (interface{}, error) {
- return srv.(SeaweedServer).LookupEcVolume(ctx, req.(*LookupEcVolumeRequest))
- }
- return interceptor(ctx, in, info, handler)
- }
- func _Seaweed_GetMasterConfiguration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
- in := new(GetMasterConfigurationRequest)
- if err := dec(in); err != nil {
- return nil, err
- }
- if interceptor == nil {
- return srv.(SeaweedServer).GetMasterConfiguration(ctx, in)
- }
- info := &grpc.UnaryServerInfo{
- Server: srv,
- FullMethod: "/master_pb.Seaweed/GetMasterConfiguration",
- }
- handler := func(ctx context.Context, req interface{}) (interface{}, error) {
- return srv.(SeaweedServer).GetMasterConfiguration(ctx, req.(*GetMasterConfigurationRequest))
- }
- return interceptor(ctx, in, info, handler)
- }
- var _Seaweed_serviceDesc = grpc.ServiceDesc{
- ServiceName: "master_pb.Seaweed",
- HandlerType: (*SeaweedServer)(nil),
- Methods: []grpc.MethodDesc{
- {
- MethodName: "LookupVolume",
- Handler: _Seaweed_LookupVolume_Handler,
- },
- {
- MethodName: "Assign",
- Handler: _Seaweed_Assign_Handler,
- },
- {
- MethodName: "Statistics",
- Handler: _Seaweed_Statistics_Handler,
- },
- {
- MethodName: "CollectionList",
- Handler: _Seaweed_CollectionList_Handler,
- },
- {
- MethodName: "CollectionDelete",
- Handler: _Seaweed_CollectionDelete_Handler,
- },
- {
- MethodName: "VolumeList",
- Handler: _Seaweed_VolumeList_Handler,
- },
- {
- MethodName: "LookupEcVolume",
- Handler: _Seaweed_LookupEcVolume_Handler,
- },
- {
- MethodName: "GetMasterConfiguration",
- Handler: _Seaweed_GetMasterConfiguration_Handler,
- },
- },
- Streams: []grpc.StreamDesc{
- {
- StreamName: "SendHeartbeat",
- Handler: _Seaweed_SendHeartbeat_Handler,
- ServerStreams: true,
- ClientStreams: true,
- },
- {
- StreamName: "KeepConnected",
- Handler: _Seaweed_KeepConnected_Handler,
- ServerStreams: true,
- ClientStreams: true,
- },
- },
- Metadata: "master.proto",
- }
- func init() { proto.RegisterFile("master.proto", fileDescriptor0) }
- var fileDescriptor0 = []byte{
- // 2102 bytes of a gzipped FileDescriptorProto
- 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x09, 0x6e, 0x88, 0x02, 0xff, 0xd4, 0x59, 0x4b, 0x6f, 0x1c, 0xc7,
- 0x11, 0xd6, 0xec, 0x2e, 0x97, 0xbb, 0xb5, 0xef, 0x26, 0x45, 0xaf, 0xd6, 0x96, 0xb5, 0x1a, 0x07,
- 0x30, 0xa5, 0x38, 0x8c, 0x43, 0x1b, 0x88, 0x91, 0xc4, 0x30, 0x24, 0x8a, 0x76, 0x08, 0x89, 0xb4,
- 0x34, 0x54, 0x64, 0x20, 0x40, 0x30, 0xe9, 0x9d, 0x69, 0x92, 0x03, 0xce, 0x2b, 0xd3, 0xbd, 0x14,
- 0xd7, 0xb9, 0x04, 0xc8, 0x31, 0xa7, 0x20, 0x87, 0xfc, 0x85, 0x5c, 0x72, 0x4a, 0xce, 0xbe, 0xe4,
- 0x47, 0xe4, 0x7f, 0xe4, 0xea, 0x4b, 0xd0, 0xaf, 0x99, 0x9e, 0x7d, 0x90, 0xa6, 0x01, 0x1f, 0x74,
- 0x9b, 0xae, 0xaa, 0xae, 0xae, 0xfe, 0xaa, 0xbb, 0xea, 0xeb, 0x5d, 0x68, 0x47, 0x98, 0x32, 0x92,
- 0xed, 0xa4, 0x59, 0xc2, 0x12, 0xd4, 0x94, 0x23, 0x37, 0x9d, 0xd8, 0x7f, 0xa9, 0x43, 0xf3, 0xd7,
- 0x04, 0x67, 0x6c, 0x42, 0x30, 0x43, 0x5d, 0xa8, 0x04, 0xe9, 0xd0, 0x1a, 0x5b, 0xdb, 0x4d, 0xa7,
- 0x12, 0xa4, 0x08, 0x41, 0x2d, 0x4d, 0x32, 0x36, 0xac, 0x8c, 0xad, 0xed, 0x8e, 0x23, 0xbe, 0xd1,
- 0x5d, 0x80, 0x74, 0x3a, 0x09, 0x03, 0xcf, 0x9d, 0x66, 0xe1, 0xb0, 0x2a, 0x6c, 0x9b, 0x52, 0xf2,
- 0x9b, 0x2c, 0x44, 0xdb, 0xd0, 0x8f, 0xf0, 0xa5, 0x7b, 0x91, 0x84, 0xd3, 0x88, 0xb8, 0x5e, 0x32,
- 0x8d, 0xd9, 0xb0, 0x26, 0xa6, 0x77, 0x23, 0x7c, 0xf9, 0x4a, 0x88, 0xf7, 0xb8, 0x14, 0x8d, 0x79,
- 0x54, 0x97, 0xee, 0x49, 0x10, 0x12, 0xf7, 0x9c, 0xcc, 0x86, 0x6b, 0x63, 0x6b, 0xbb, 0xe6, 0x40,
- 0x84, 0x2f, 0x3f, 0x0f, 0x42, 0xf2, 0x94, 0xcc, 0xd0, 0x3d, 0x68, 0xf9, 0x98, 0x61, 0xd7, 0x23,
- 0x31, 0x23, 0xd9, 0xb0, 0x2e, 0xd6, 0x02, 0x2e, 0xda, 0x13, 0x12, 0x1e, 0x5f, 0x86, 0xbd, 0xf3,
- 0xe1, 0xba, 0xd0, 0x88, 0x6f, 0x1e, 0x1f, 0xf6, 0xa3, 0x20, 0x76, 0x45, 0xe4, 0x0d, 0xb1, 0x74,
- 0x53, 0x48, 0x9e, 0xf3, 0xf0, 0x3f, 0x85, 0x75, 0x19, 0x1b, 0x1d, 0x36, 0xc7, 0xd5, 0xed, 0xd6,
- 0xee, 0x7b, 0x3b, 0x39, 0x1a, 0x3b, 0x32, 0xbc, 0x83, 0xf8, 0x24, 0xc9, 0x22, 0xcc, 0x82, 0x24,
- 0x3e, 0x24, 0x94, 0xe2, 0x53, 0xe2, 0xe8, 0x39, 0xe8, 0x00, 0x5a, 0x31, 0x79, 0xed, 0x6a, 0x17,
- 0x20, 0x5c, 0x6c, 0x2f, 0xb8, 0x38, 0x3e, 0x4b, 0x32, 0xb6, 0xc4, 0x0f, 0xc4, 0xe4, 0xf5, 0x2b,
- 0xe5, 0xea, 0x05, 0xf4, 0x7c, 0x12, 0x12, 0x46, 0xfc, 0xdc, 0x5d, 0xeb, 0x86, 0xee, 0xba, 0xca,
- 0x81, 0x76, 0xf9, 0x23, 0xe8, 0x9e, 0x61, 0xea, 0xc6, 0x49, 0xee, 0xb1, 0x3d, 0xb6, 0xb6, 0x1b,
- 0x4e, 0xfb, 0x0c, 0xd3, 0xa3, 0x44, 0x5b, 0x7d, 0x01, 0x4d, 0xe2, 0xb9, 0xf4, 0x0c, 0x67, 0x3e,
- 0x1d, 0xf6, 0xc5, 0x92, 0x0f, 0x17, 0x96, 0xdc, 0xf7, 0x8e, 0xb9, 0xc1, 0x92, 0x45, 0x1b, 0x44,
- 0xaa, 0x28, 0x3a, 0x82, 0x0e, 0x07, 0xa3, 0x70, 0x36, 0xb8, 0xb1, 0x33, 0x8e, 0xe6, 0xbe, 0xf6,
- 0xf7, 0x0a, 0x06, 0x1a, 0x91, 0xc2, 0x27, 0xba, 0xb1, 0x4f, 0x0d, 0x6b, 0xee, 0xf7, 0x7d, 0xe8,
- 0x2b, 0x58, 0x0a, 0xb7, 0x1b, 0x02, 0x98, 0x8e, 0x00, 0x46, 0x1b, 0xda, 0x7f, 0xaa, 0xc0, 0x20,
- 0xbf, 0x0d, 0x0e, 0xa1, 0x69, 0x12, 0x53, 0x82, 0x1e, 0xc2, 0x40, 0x1d, 0x67, 0x1a, 0x7c, 0x4d,
- 0xdc, 0x30, 0x88, 0x02, 0x26, 0x2e, 0x49, 0xcd, 0xe9, 0x49, 0xc5, 0x71, 0xf0, 0x35, 0x79, 0xc6,
- 0xc5, 0x68, 0x0b, 0xea, 0x21, 0xc1, 0x3e, 0xc9, 0xc4, 0x9d, 0x69, 0x3a, 0x6a, 0x84, 0xde, 0x87,
- 0x5e, 0x44, 0x58, 0x16, 0x78, 0xd4, 0xc5, 0xbe, 0x9f, 0x11, 0x4a, 0xd5, 0xd5, 0xe9, 0x2a, 0xf1,
- 0x23, 0x29, 0x45, 0x9f, 0xc0, 0x50, 0x1b, 0x06, 0xfc, 0x8c, 0x5f, 0xe0, 0xd0, 0xa5, 0xc4, 0x4b,
- 0x62, 0x9f, 0xaa, 0x7b, 0xb4, 0xa5, 0xf4, 0x07, 0x4a, 0x7d, 0x2c, 0xb5, 0xe8, 0x09, 0xf4, 0x29,
- 0x4b, 0x32, 0x7c, 0x4a, 0xdc, 0x09, 0xf6, 0xce, 0x09, 0x9f, 0xb1, 0x26, 0xc0, 0xbb, 0x63, 0x80,
- 0x77, 0x2c, 0x4d, 0x1e, 0x4b, 0x0b, 0xa7, 0x47, 0x4b, 0x63, 0x6a, 0x7f, 0x5b, 0x85, 0xe1, 0xaa,
- 0x6b, 0x20, 0xea, 0x83, 0x2f, 0xb6, 0xde, 0x71, 0x2a, 0x81, 0xcf, 0xef, 0x1f, 0x87, 0x44, 0xec,
- 0xb5, 0xe6, 0x88, 0x6f, 0xf4, 0x2e, 0x80, 0x97, 0x84, 0x21, 0xf1, 0xf8, 0x44, 0xb5, 0x49, 0x43,
- 0xc2, 0xef, 0xa7, 0xb8, 0xf2, 0x45, 0x69, 0xa8, 0x39, 0x4d, 0x2e, 0x91, 0x55, 0xe1, 0x3e, 0xb4,
- 0x65, 0xfa, 0x94, 0x81, 0xac, 0x0a, 0x2d, 0x29, 0x93, 0x26, 0x1f, 0x00, 0xd2, 0xc7, 0x64, 0x32,
- 0xcb, 0x0d, 0xeb, 0xc2, 0xb0, 0xaf, 0x34, 0x8f, 0x67, 0xda, 0xfa, 0x6d, 0x68, 0x66, 0x04, 0xfb,
- 0x6e, 0x12, 0x87, 0x33, 0x51, 0x28, 0x1a, 0x4e, 0x83, 0x0b, 0xbe, 0x8c, 0xc3, 0x19, 0xfa, 0x31,
- 0x0c, 0x32, 0x92, 0x86, 0x81, 0x87, 0xdd, 0x34, 0xc4, 0x1e, 0x89, 0x48, 0xac, 0x6b, 0x46, 0x5f,
- 0x29, 0x9e, 0x6b, 0x39, 0x1a, 0xc2, 0xfa, 0x05, 0xc9, 0x28, 0xdf, 0x56, 0x53, 0x98, 0xe8, 0x21,
- 0xea, 0x43, 0x95, 0xb1, 0x70, 0x08, 0x42, 0xca, 0x3f, 0xd1, 0x03, 0xe8, 0x7b, 0x49, 0x94, 0x62,
- 0x8f, 0xb9, 0x19, 0xb9, 0x08, 0xc4, 0xa4, 0x96, 0x50, 0xf7, 0x94, 0xdc, 0x51, 0x62, 0xbe, 0x9d,
- 0x28, 0xf1, 0x83, 0x93, 0x80, 0xf8, 0x2e, 0x66, 0x2a, 0xd9, 0xe2, 0xe2, 0x56, 0x9d, 0xbe, 0xd6,
- 0x3c, 0x62, 0x32, 0xcd, 0x68, 0x07, 0x36, 0x32, 0x12, 0x25, 0x8c, 0xb8, 0x3a, 0xd9, 0x31, 0x8e,
- 0xc8, 0xb0, 0x23, 0x70, 0x1e, 0x48, 0x95, 0xca, 0xf1, 0x11, 0x8e, 0x08, 0xf7, 0x3e, 0x67, 0xcf,
- 0x6b, 0x6d, 0x57, 0x98, 0xf7, 0x4b, 0xe6, 0x4f, 0xc9, 0xcc, 0xfe, 0x87, 0x05, 0x77, 0xaf, 0x2c,
- 0x39, 0x0b, 0x47, 0xe0, 0xba, 0x74, 0xff, 0x50, 0x08, 0xdb, 0x53, 0xb8, 0x77, 0x4d, 0x21, 0xb8,
- 0x26, 0xd6, 0xca, 0x42, 0xac, 0x36, 0x74, 0x88, 0xe7, 0x06, 0xb1, 0x4f, 0x2e, 0xdd, 0x49, 0xc0,
- 0xe4, 0x15, 0xed, 0x38, 0x2d, 0xe2, 0x1d, 0x70, 0xd9, 0xe3, 0x80, 0x51, 0xfb, 0x1b, 0x0b, 0xba,
- 0xe5, 0x3b, 0xc4, 0x6f, 0x01, 0x9b, 0xa5, 0x44, 0xf5, 0x4d, 0xf1, 0xad, 0x96, 0xae, 0xa8, 0x4e,
- 0xea, 0xa3, 0x03, 0x80, 0x34, 0x4b, 0x52, 0x92, 0xb1, 0x80, 0x70, 0xbf, 0xfc, 0x5a, 0x3e, 0x58,
- 0x79, 0x2d, 0x77, 0x9e, 0xe7, 0xb6, 0xfb, 0x31, 0xcb, 0x66, 0x8e, 0x31, 0x79, 0xf4, 0x29, 0xf4,
- 0xe6, 0xd4, 0x1c, 0x1d, 0x9e, 0x55, 0x19, 0x00, 0xff, 0x44, 0x9b, 0xb0, 0x76, 0x81, 0xc3, 0x29,
- 0x51, 0x21, 0xc8, 0xc1, 0x2f, 0x2a, 0x9f, 0x58, 0xf6, 0x3a, 0xac, 0xed, 0x47, 0x29, 0x9b, 0xf1,
- 0x9d, 0xf4, 0x8e, 0xa7, 0x29, 0xc9, 0x1e, 0x87, 0x89, 0x77, 0xbe, 0x7f, 0xc9, 0x32, 0x8c, 0xbe,
- 0x84, 0x2e, 0xc9, 0x30, 0x9d, 0x66, 0xfc, 0x56, 0xf9, 0x41, 0x7c, 0x2a, 0x7c, 0x96, 0x5b, 0xd2,
- 0xdc, 0x9c, 0x9d, 0x7d, 0x39, 0x61, 0x4f, 0xd8, 0x3b, 0x1d, 0x62, 0x0e, 0x47, 0xbf, 0x85, 0x4e,
- 0x49, 0xcf, 0xc1, 0xe2, 0x0d, 0x5c, 0x65, 0x45, 0x7c, 0xf3, 0xa2, 0x99, 0xe2, 0x2c, 0x60, 0x33,
- 0x45, 0x34, 0xd4, 0x88, 0x97, 0x0a, 0x55, 0x78, 0x03, 0x5f, 0x82, 0xd6, 0x71, 0x9a, 0x52, 0x72,
- 0xe0, 0x53, 0xfb, 0x21, 0x6c, 0x3e, 0x25, 0x24, 0xdd, 0x4b, 0xe2, 0x98, 0x78, 0x8c, 0xf8, 0x0e,
- 0xf9, 0xc3, 0x94, 0x50, 0xc6, 0x97, 0x10, 0x77, 0x42, 0xe5, 0x83, 0x7f, 0xdb, 0x7f, 0xb7, 0xa0,
- 0x2b, 0x8f, 0xcb, 0xb3, 0xc4, 0x13, 0x87, 0x84, 0x83, 0xc6, 0x19, 0x8c, 0x02, 0x6d, 0x9a, 0x85,
- 0x73, 0xd4, 0xa6, 0x32, 0x4f, 0x6d, 0xee, 0x40, 0x43, 0xf4, 0xfe, 0x22, 0x98, 0x75, 0xde, 0xce,
- 0x03, 0x9f, 0x16, 0x55, 0xcb, 0x97, 0xea, 0x9a, 0x50, 0xb7, 0x74, 0x7b, 0xe6, 0x26, 0x45, 0x67,
- 0x58, 0x33, 0x3b, 0x83, 0xfd, 0x12, 0x36, 0x9e, 0x25, 0xc9, 0xf9, 0x34, 0x95, 0xe1, 0xe9, 0x4d,
- 0x94, 0xf7, 0x6e, 0x8d, 0xab, 0x3c, 0x96, 0x7c, 0xef, 0xd7, 0x1d, 0x65, 0xfb, 0x7f, 0x16, 0x6c,
- 0x96, 0xdd, 0xaa, 0x66, 0xf6, 0x7b, 0xd8, 0xc8, 0xfd, 0xba, 0xa1, 0xc2, 0x42, 0x2e, 0xd0, 0xda,
- 0xfd, 0xd0, 0x48, 0xf3, 0xb2, 0xd9, 0x9a, 0x20, 0xf9, 0x1a, 0x44, 0x67, 0x70, 0x31, 0x27, 0xa1,
- 0xa3, 0x4b, 0xe8, 0xcf, 0x9b, 0xf1, 0x22, 0x9c, 0xaf, 0xaa, 0x10, 0x6f, 0xe8, 0x99, 0xe8, 0x67,
- 0xd0, 0x2c, 0x02, 0xa9, 0x88, 0x40, 0x36, 0x4a, 0x81, 0xa8, 0xb5, 0x0a, 0x2b, 0x7e, 0xbc, 0x49,
- 0x96, 0x25, 0x99, 0x2a, 0x38, 0x72, 0x60, 0xff, 0x12, 0x1a, 0xdf, 0x3b, 0xbb, 0xf6, 0xbf, 0x2a,
- 0xd0, 0x79, 0x44, 0x69, 0x70, 0x1a, 0xeb, 0x14, 0x6c, 0xc2, 0x9a, 0x6c, 0x2d, 0xb2, 0xd7, 0xcb,
- 0x01, 0x1a, 0x43, 0x4b, 0xd5, 0x2d, 0x03, 0x7a, 0x53, 0x74, 0x6d, 0x49, 0x54, 0xb5, 0xac, 0x26,
- 0x43, 0xe3, 0xdd, 0x62, 0x8e, 0xe8, 0xae, 0xad, 0x24, 0xba, 0x75, 0x83, 0xe8, 0xbe, 0x0d, 0x4d,
- 0x31, 0x29, 0x4e, 0x7c, 0xa2, 0x18, 0x70, 0x83, 0x0b, 0x8e, 0x12, 0x9f, 0xa0, 0x5d, 0xd8, 0x8a,
- 0x48, 0x94, 0x64, 0x33, 0x37, 0xc2, 0xa9, 0xcb, 0x79, 0xb6, 0xe0, 0x2e, 0xd1, 0x44, 0xd5, 0x5e,
- 0x24, 0xb5, 0x87, 0x38, 0x3d, 0xc4, 0x97, 0x9c, 0xbe, 0x1c, 0x4e, 0xd0, 0x2e, 0xdc, 0xfe, 0x2a,
- 0x0b, 0x18, 0x9e, 0x84, 0xa4, 0xcc, 0xdf, 0x65, 0x2d, 0xde, 0xd0, 0x4a, 0x83, 0xc4, 0xdb, 0x7f,
- 0xb3, 0xa0, 0xab, 0x51, 0x53, 0x27, 0xac, 0x0f, 0xd5, 0x93, 0x3c, 0xcb, 0xfc, 0x53, 0xe7, 0xa2,
- 0xb2, 0x2a, 0x17, 0x0b, 0x8f, 0x88, 0x1c, 0xf9, 0x9a, 0x89, 0x7c, 0x9e, 0xf4, 0x35, 0x23, 0xe9,
- 0x1c, 0x1a, 0x3c, 0x65, 0x67, 0x1a, 0x1a, 0xfe, 0x6d, 0x9f, 0xc2, 0xe0, 0x98, 0x61, 0x16, 0x50,
- 0x16, 0x78, 0x54, 0xa7, 0x73, 0x2e, 0x71, 0xd6, 0x75, 0x89, 0xab, 0xac, 0x4a, 0x5c, 0x35, 0x4f,
- 0x9c, 0xfd, 0x1f, 0x0b, 0x90, 0xb9, 0x92, 0x82, 0xe0, 0x07, 0x58, 0x8a, 0x43, 0xc6, 0x12, 0xc6,
- 0xd9, 0x20, 0x67, 0x5c, 0x8a, 0x37, 0x09, 0x09, 0x4f, 0x1f, 0x3f, 0x0d, 0x53, 0x4a, 0x7c, 0xa9,
- 0x95, 0xa4, 0xa9, 0xc1, 0x05, 0x42, 0x59, 0xe6, 0x5c, 0xf5, 0x39, 0xce, 0x65, 0x3f, 0x82, 0x96,
- 0xea, 0x3f, 0x2f, 0x79, 0xef, 0xba, 0x3e, 0x7a, 0x15, 0x5d, 0xa5, 0x00, 0x62, 0x0c, 0xb0, 0x57,
- 0x44, 0xbf, 0xac, 0x02, 0xff, 0x11, 0x6e, 0x17, 0x16, 0xcf, 0x02, 0xca, 0x74, 0x5e, 0x3e, 0x86,
- 0xad, 0x20, 0xf6, 0xc2, 0xa9, 0x4f, 0xdc, 0x98, 0x77, 0xf0, 0x30, 0x7f, 0xbc, 0x58, 0x82, 0xad,
- 0x6d, 0x2a, 0xed, 0x91, 0x50, 0xea, 0x47, 0xcc, 0x07, 0x80, 0xf4, 0x2c, 0xe2, 0xe5, 0x33, 0x2a,
- 0x62, 0x46, 0x5f, 0x69, 0xf6, 0x3d, 0x65, 0x6d, 0xbf, 0x80, 0xad, 0xf9, 0xc5, 0x55, 0xaa, 0x7e,
- 0x0e, 0xad, 0x02, 0x76, 0x5d, 0x07, 0x6f, 0x1b, 0xe5, 0xa7, 0x98, 0xe7, 0x98, 0x96, 0xf6, 0x4f,
- 0xe0, 0xad, 0x42, 0xf5, 0x44, 0x14, 0xfa, 0xab, 0x1a, 0xd0, 0x08, 0x86, 0x8b, 0xe6, 0x32, 0x06,
- 0xfb, 0xaf, 0x55, 0x68, 0x3f, 0x51, 0x37, 0x97, 0xd3, 0x18, 0x83, 0xb8, 0x48, 0xf6, 0x70, 0x1f,
- 0xda, 0xa5, 0x0b, 0x29, 0xf9, 0x76, 0xeb, 0xc2, 0x78, 0x4d, 0x2f, 0x7b, 0x77, 0x57, 0x85, 0xd9,
- 0xfc, 0xbb, 0xfb, 0x21, 0x0c, 0x4e, 0x32, 0x42, 0x16, 0x9f, 0xe8, 0x35, 0xa7, 0xc7, 0x15, 0xa6,
- 0xed, 0x0e, 0x6c, 0x60, 0x8f, 0x05, 0x17, 0x73, 0xd6, 0xf2, 0x7c, 0x0d, 0xa4, 0xca, 0xb4, 0xff,
- 0x3c, 0x0f, 0x34, 0x88, 0x4f, 0x12, 0x3a, 0xac, 0x7f, 0xf7, 0x27, 0xb6, 0xda, 0x0d, 0xd7, 0x50,
- 0xf4, 0x1c, 0xba, 0xfa, 0xa9, 0xa6, 0x3c, 0xad, 0xdf, 0xf8, 0x19, 0xd8, 0x26, 0x85, 0x8a, 0x1a,
- 0xbc, 0xb9, 0xb4, 0x93, 0x86, 0xdc, 0x89, 0x54, 0x99, 0x85, 0xed, 0xdf, 0x15, 0x68, 0x38, 0xd8,
- 0x3b, 0x7f, 0xb3, 0xf3, 0xf1, 0x19, 0xf4, 0xf2, 0x1e, 0x51, 0x4a, 0xc9, 0x5b, 0x06, 0x90, 0xe6,
- 0xd1, 0x73, 0x3a, 0xbe, 0x31, 0x5a, 0x09, 0xdb, 0xfa, 0x2a, 0xd8, 0xfe, 0x59, 0x81, 0xee, 0x93,
- 0xbc, 0x6f, 0xbd, 0xd9, 0xe0, 0xed, 0x02, 0xf0, 0x46, 0x5b, 0xc2, 0xcd, 0x24, 0x26, 0xfa, 0x78,
- 0x38, 0xcd, 0x4c, 0x7d, 0xdd, 0x1c, 0xaf, 0x6f, 0x2a, 0xd0, 0x7e, 0x99, 0xa4, 0x49, 0x98, 0x9c,
- 0xce, 0xde, 0x6c, 0xb4, 0xf6, 0x61, 0x60, 0x70, 0x98, 0x12, 0x68, 0x77, 0xe6, 0x0e, 0x5b, 0x71,
- 0x38, 0x9c, 0x9e, 0x5f, 0x1a, 0xdf, 0x1c, 0xc0, 0x0d, 0x18, 0x28, 0x5e, 0x5f, 0xb4, 0x14, 0xfb,
- 0xcf, 0x16, 0x20, 0x53, 0xaa, 0x6a, 0xfd, 0xaf, 0xa0, 0xc3, 0x14, 0xd6, 0x22, 0x3e, 0xf5, 0xb8,
- 0x31, 0xef, 0x82, 0x99, 0x0b, 0xa7, 0xcd, 0xcc, 0xcc, 0xfc, 0x14, 0x36, 0x17, 0x7e, 0x06, 0xe2,
- 0x84, 0x4a, 0x66, 0x64, 0x30, 0xf7, 0x4b, 0xd0, 0xe1, 0xc4, 0xfe, 0x18, 0x6e, 0x4b, 0x12, 0xad,
- 0xfb, 0x90, 0xee, 0x0f, 0x0b, 0x6c, 0xb8, 0x53, 0xb0, 0x61, 0xfb, 0x5b, 0x0b, 0xb6, 0xe6, 0xa7,
- 0xa9, 0xf8, 0xaf, 0x9a, 0x87, 0x30, 0x20, 0x55, 0x2f, 0x4d, 0x5e, 0x2f, 0xe9, 0xf4, 0x47, 0x0b,
- 0xbc, 0x7e, 0xde, 0xf7, 0x8e, 0xae, 0xa3, 0x05, 0xb5, 0xef, 0xd3, 0xb2, 0x80, 0x8e, 0x30, 0x0c,
- 0x16, 0xcc, 0xf8, 0xab, 0x48, 0xaf, 0xab, 0x62, 0x5a, 0x57, 0x13, 0xbf, 0x07, 0xb1, 0xb7, 0xef,
- 0xc1, 0xdd, 0x2f, 0x08, 0x3b, 0x14, 0x36, 0x7b, 0x49, 0x7c, 0x12, 0x9c, 0x4e, 0x33, 0x69, 0x54,
- 0xa4, 0xf6, 0xdd, 0x55, 0x16, 0x0a, 0xa6, 0x25, 0xbf, 0xb5, 0x59, 0x37, 0xfe, 0xad, 0xad, 0x72,
- 0xd5, 0x6f, 0x6d, 0xbb, 0xff, 0xad, 0xc3, 0xfa, 0x31, 0xc1, 0xaf, 0x09, 0xe1, 0x4f, 0xfb, 0xce,
- 0x31, 0x89, 0xfd, 0xe2, 0x57, 0xf4, 0x4d, 0x63, 0x8f, 0xb9, 0x74, 0xf4, 0xce, 0x32, 0x69, 0x4e,
- 0x01, 0x6e, 0x6d, 0x5b, 0x1f, 0x5a, 0xe8, 0x05, 0x74, 0x4a, 0x2f, 0x5a, 0x74, 0xcf, 0x98, 0xb4,
- 0xec, 0xad, 0x3b, 0xba, 0xb3, 0xd0, 0x10, 0x35, 0xaa, 0xb9, 0xcb, 0xb6, 0xf9, 0x92, 0x43, 0xef,
- 0xae, 0x7c, 0xe2, 0x49, 0x87, 0xf7, 0xae, 0x79, 0x02, 0xda, 0xb7, 0xd0, 0x67, 0x50, 0x97, 0x94,
- 0x1f, 0x0d, 0x0d, 0xe3, 0xd2, 0xdb, 0xa9, 0x14, 0x57, 0xf9, 0x7d, 0x60, 0xdf, 0x42, 0x4f, 0x01,
- 0x0a, 0xd2, 0x8c, 0xde, 0x29, 0xfd, 0x0c, 0x32, 0xc7, 0xda, 0x47, 0x77, 0x57, 0x68, 0x73, 0x67,
- 0x5f, 0x41, 0xb7, 0x4c, 0xed, 0xd0, 0x78, 0x29, 0x7b, 0x33, 0xea, 0xc3, 0xe8, 0xfe, 0x15, 0x16,
- 0xb9, 0xe3, 0xdf, 0x41, 0x7f, 0x9e, 0xb1, 0x21, 0x7b, 0xe9, 0xc4, 0x12, 0xfb, 0x1b, 0xbd, 0x77,
- 0xa5, 0x8d, 0x09, 0x42, 0x51, 0xa2, 0x4a, 0x20, 0x2c, 0xd4, 0xb3, 0x12, 0x08, 0x8b, 0x75, 0x4d,
- 0x82, 0x50, 0xbe, 0xd7, 0x25, 0x10, 0x96, 0x56, 0xa1, 0x12, 0x08, 0xcb, 0x8b, 0x82, 0x7d, 0x0b,
- 0x25, 0xb0, 0xb5, 0xfc, 0xb6, 0x21, 0xf3, 0x27, 0xa1, 0x2b, 0xaf, 0xec, 0xe8, 0xc1, 0x77, 0xb0,
- 0xd4, 0x0b, 0x4e, 0xea, 0xe2, 0x2f, 0xaa, 0x8f, 0xfe, 0x1f, 0x00, 0x00, 0xff, 0xff, 0x6c, 0x64,
- 0x5c, 0xbc, 0xb2, 0x1a, 0x00, 0x00,
- }
|