-
Notifications
You must be signed in to change notification settings - Fork 51
/
Copy pathtypes.go
1623 lines (1442 loc) · 54.9 KB
/
types.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
740
741
742
743
744
745
746
747
748
749
750
751
752
753
754
755
756
757
758
759
760
761
762
763
764
765
766
767
768
769
770
771
772
773
774
775
776
777
778
779
780
781
782
783
784
785
786
787
788
789
790
791
792
793
794
795
796
797
798
799
800
801
802
803
804
805
806
807
808
809
810
811
812
813
814
815
816
817
818
819
820
821
822
823
824
825
826
827
828
829
830
831
832
833
834
835
836
837
838
839
840
841
842
843
844
845
846
847
848
849
850
851
852
853
854
855
856
857
858
859
860
861
862
863
864
865
866
867
868
869
870
871
872
873
874
875
876
877
878
879
880
881
882
883
884
885
886
887
888
889
890
891
892
893
894
895
896
897
898
899
900
901
902
903
904
905
906
907
908
909
910
911
912
913
914
915
916
917
918
919
920
921
922
923
924
925
926
927
928
929
930
931
932
933
934
935
936
937
938
939
940
941
942
943
944
945
946
947
948
949
950
951
952
953
954
955
956
957
958
959
960
961
962
963
964
965
966
967
968
969
970
971
972
973
974
975
976
977
978
979
980
981
982
983
984
985
986
987
988
989
990
991
992
993
994
995
996
997
998
999
1000
package proxmox
import (
"context"
"encoding/json"
"fmt"
"math"
"regexp"
"strconv"
"strings"
"time"
"github.com/jinzhu/copier"
)
var (
isFloat = regexp.MustCompile(`^[0-9.]*$`)
)
type Credentials struct {
Username string `json:"username"`
Password string `json:"password"`
Otp string `json:"otp,omitempty"` // One-time password for Two-factor authentication.
Path string `json:"path,omitempty"`
Privs string `json:"privs,omitempty"`
Realm string `json:"realm,omitempty"`
}
type Permission map[string]IntOrBool
type Permissions map[string]Permission
type PermissionsOptions struct {
Path string // path to limit the return e.g. / or /nodes
UserID string // username e.g. root@pam or token
}
type Session struct {
Username string `json:"username"`
CSRFPreventionToken string `json:"CSRFPreventionToken,omitempty"`
// Cap is being returned but not documented in the API docs, likely will get rewritten later with better types
Cap map[string]map[string]int `json:"cap,omitempty"`
ClusterName string `json:"clustername,omitempty"`
Ticket string `json:"ticket,omitempty"`
}
type Version struct {
Release string `json:"release"`
RepoID string `json:"repoid"`
Version string `json:"version"`
}
type Term struct {
Port StringOrInt
Ticket string
UPID string
User string
}
type VNCConfig struct {
GeneratePassword bool `json:"generate-password,omitempty"`
Websocket bool `json:"websocket,omitempty"`
}
type VNC struct {
Cert string
Port StringOrInt
Ticket string
UPID string
User string
Password string `json:",omitempty"`
}
type Cluster struct {
client *Client
Version int
Quorate int
Nodes NodeStatuses
Name string
ID string
}
func (cl *Cluster) UnmarshalJSON(b []byte) error {
var tmp []map[string]interface{}
if err := json.Unmarshal(b, &tmp); err != nil {
return err
}
for _, d := range tmp {
t, ok := d["type"]
if !ok {
break
}
switch t.(string) {
case "cluster":
if v, ok := d["id"]; ok {
cl.ID = v.(string)
}
if v, ok := d["name"]; ok {
cl.Name = v.(string)
}
if v, ok := d["version"]; ok {
cl.Version = int(v.(float64))
}
if v, ok := d["quorate"]; ok {
cl.Quorate = int(v.(float64))
}
case "node":
ns := NodeStatus{
Status: "offline",
Type: "node",
}
if v, ok := d["name"]; ok {
ns.Name = v.(string)
}
if v, ok := d["level"]; ok {
ns.Level = v.(string)
}
if v, ok := d["online"]; ok {
ns.Online = int(v.(float64))
if ns.Online == 1 {
ns.Status = "online"
}
}
if v, ok := d["id"]; ok {
ns.ID = v.(string)
}
if v, ok := d["ip"]; ok {
ns.IP = v.(string)
}
if v, ok := d["local"]; ok {
ns.Local = int(v.(float64))
}
cl.Nodes = append(cl.Nodes, &ns)
}
}
return nil
}
type ClusterResources []*ClusterResource
type ClusterResource struct {
ID string `jsont:"id"`
Type string `json:"type"`
CGroupMode uint64 `json:"cgroup-mode,omitempty"`
Content string `json:",omitempty"`
CPU float64 `json:",omitempty"`
Disk uint64 `json:",omitempty"` // documented as string but this is an int
DiskRead uint64 `json:",omitempty"`
DiskWrite uint64 `json:",omitempty"`
HAstate string `json:",omitempty"`
Level string `json:",omitempty"`
MaxCPU uint64 `json:",omitempty"`
MaxDisk uint64 `json:",omitempty"`
MaxMem uint64 `json:",omitempty"`
Mem uint64 `json:",omitempty"` // documented as string but this is an int
Name string `json:",omitempty"`
NetIn uint64 `json:",omitempty"`
NetOut uint64 `json:",omitempty"`
Node string `json:",omitempty"`
PluginType string `json:",omitempty"`
Pool string `json:",omitempty"`
Shared uint64 `json:",omitempty"`
Status string `json:",omitempty"`
Storage string `json:",omitempty"`
Tags string `json:",omitempty"`
Template uint64 `json:",omitempty"`
Uptime uint64 `json:",omitempty"`
VMID uint64 `json:",omitempty"`
}
type NodeStatuses []*NodeStatus
type NodeStatus struct {
// shared
Status string `json:",omitempty"`
Level string `json:",omitempty"`
ID string `json:",omitempty"` // format "node/<name>"
// from /nodes endpoint
Node string `json:",omitempty"`
Type string `json:",omitempty"`
MaxCPU int `json:",omitempty"`
MaxMem uint64 `json:",omitempty"`
Disk uint64 `json:",omitempty"`
SSLFingerprint string `json:"ssl_fingerprint,omitempty"`
MaxDisk uint64 `json:",omitempty"`
Mem uint64 `json:",omitempty"`
CPU float64 `json:",omitempty"`
Uptime uint64 `json:",omitempty"`
// from /cluster endpoint
NodeID int `json:",omitempty"` // the internal id of the node
Name string `json:",omitempty"`
IP string `json:",omitempty"`
Online int `json:",omitempty"`
Local int `json:",omitempty"`
}
type Node struct {
Name string
client *Client
Kversion string
LoadAvg []string
CPU float64
RootFS RootFS
PVEVersion string
CPUInfo CPUInfo
Swap Memory
Idle int
Memory Memory
Ksm Ksm
Uptime uint64
Wait float64
}
type VirtualMachines []*VirtualMachine
type VirtualMachine struct {
client *Client
VirtualMachineConfig *VirtualMachineConfig
Name string
Node string
Agent IntOrBool
NetIn uint64
CPUs int
DiskWrite uint64
Status string
Lock string `json:",omitempty"`
VMID StringOrUint64
PID StringOrUint64
Netout uint64
Disk uint64
Mem uint64
CPU float64
MaxMem uint64
MaxDisk uint64
DiskRead uint64
QMPStatus string `json:"qmpstatus,omitempty"`
RunningMachine string `json:"running-machine,omitempty"`
RunningQemu string `json:"running-qemu,omitempty"`
Tags string `json:"tags,omitempty"`
Uptime uint64
Template IsTemplate // empty str if a vm, int 1 if a template
HA HA `json:",omitempty"`
}
type HA struct {
Managed int
}
type RootFS struct {
Avail uint64
Total uint64
Free uint64
Used uint64
}
type CPUInfo struct {
UserHz int `json:"user_hz"`
MHZ StringOrInt
Mode string
Cores int
Sockets int
Flags string
CPUs int
HVM string
}
type Memory struct {
Used uint64
Free uint64
Total uint64
}
type Ksm struct {
Shared int64
}
type Time struct {
Timezone string
Time uint64
Localtime uint64
}
type Timeframe string
const (
TimeframeHour = Timeframe("hour")
TimeframeDay = Timeframe("day")
TimeframeWeek = Timeframe("week")
TimeframeMonth = Timeframe("month")
TimeframeYear = Timeframe("year")
)
type ConsolidationFunction string
const (
AVERAGE = ConsolidationFunction("AVERAGE")
MAX = ConsolidationFunction("MAX")
)
type RRDData struct {
MaxCPU int
MaxMem uint64
Disk int
MaxDisk uint64
Time uint64
}
// VirtualMachineOptions A key/value pair used to modify a virtual machine config
// Refer to https://pve.proxmox.com/pve-docs/api-viewer/#/nodes/{node}/qemu/{vmid}/config for a list of valid values
type VirtualMachineOptions []*VirtualMachineOption
type VirtualMachineOption struct {
Name string
Value interface{}
}
type VirtualMachineConfig struct {
// PVE Metadata
Digest string `json:"digest"`
Name string `json:"name,omitempty"`
Description string `json:"description,omitempty"`
Meta string `json:"meta,omitempty"`
VMGenID string `json:"vmgenid,omitempty"`
Hookscript string `json:"hookscript,omitempty"`
Hotplug string `json:"hotplug,omitempty"`
Template int `json:"template,omitempty"`
Agent string `json:"agent,omitempty"`
Autostart int `json:"autostart,omitempty"`
Tablet int `json:"tablet,omitempty"`
KVM int `json:"kvm,omitempty"`
Tags string `json:"tags,omitempty"`
TagsSlice []string `json:"-"` // internal helper to manage tags easier
Protection int `json:"protection,omitempty"`
Lock string `json:"lock,omitempty"`
// Boot configuration
Boot string `json:"boot,omitempty"`
OnBoot int `json:"onboot,omitempty"`
// Qemu general specs
OSType string `json:"ostype,omitempty"`
Machine string `json:"machine,omitempty"`
Args string `json:"args,omitempty"`
// Qemu firmware specs
Bios string `json:"bios,omitempty"`
EFIDisk0 string `json:"efidisk0,omitempty"`
SMBios1 string `json:"smbios1,omitempty"`
Acpi int `json:"acpi,omitempty"`
// Qemu CPU specs
Sockets int `json:"sockets,omitempty"`
Cores int `json:"cores,omitempty"`
CPU string `json:"cpu,omitempty"`
CPULimit StringOrFloat64 `json:"cpulimit,omitempty"`
CPUUnits int `json:"cpuunits,omitempty"`
Vcpus int `json:"vcpus,omitempty"`
Affinity string `json:"affinity,omitempty"`
// Qemu memory specs
Numa int `json:"numa,omitempty"`
Memory StringOrInt `json:"memory,omitempty"` // See commit 7f8c808772979f274cdfac1dc7264771a3b7a7ae on qemu-server
Hugepages string `json:"hugepages,omitempty"`
Balloon int `json:"balloon,omitempty"`
// Other Qemu devices
VGA string `json:"vga,omitempty"`
SCSIHW string `json:"scsihw,omitempty"`
TPMState0 string `json:"tpmstate0,omitempty"`
Rng0 string `json:"rng0,omitempty"`
Audio0 string `json:"audio0,omitempty"`
// Disk devices
IDEs map[string]string `json:"-"`
IDE0 string `json:"ide0,omitempty"`
IDE1 string `json:"ide1,omitempty"`
IDE2 string `json:"ide2,omitempty"`
IDE3 string `json:"ide3,omitempty"`
SCSIs map[string]string `json:"-"`
SCSI0 string `json:"scsi0,omitempty"`
SCSI1 string `json:"scsi1,omitempty"`
SCSI2 string `json:"scsi2,omitempty"`
SCSI3 string `json:"scsi3,omitempty"`
SCSI4 string `json:"scsi4,omitempty"`
SCSI5 string `json:"scsi5,omitempty"`
SCSI6 string `json:"scsi6,omitempty"`
SCSI7 string `json:"scsi7,omitempty"`
SCSI8 string `json:"scsi8,omitempty"`
SCSI9 string `json:"scsi9,omitempty"`
SCSI10 string `json:"scsi10,omitempty"`
SCSI11 string `json:"scsi11,omitempty"`
SCSI12 string `json:"scsi12,omitempty"`
SCSI13 string `json:"scsi13,omitempty"`
SCSI14 string `json:"scsi14,omitempty"`
SCSI15 string `json:"scsi15,omitempty"`
SCSI16 string `json:"scsi16,omitempty"`
SCSI17 string `json:"scsi17,omitempty"`
SCSI18 string `json:"scsi18,omitempty"`
SCSI19 string `json:"scsi19,omitempty"`
SCSI20 string `json:"scsi20,omitempty"`
SCSI21 string `json:"scsi21,omitempty"`
SCSI22 string `json:"scsi22,omitempty"`
SCSI23 string `json:"scsi23,omitempty"`
SCSI24 string `json:"scsi24,omitempty"`
SCSI25 string `json:"scsi25,omitempty"`
SCSI26 string `json:"scsi26,omitempty"`
SCSI27 string `json:"scsi27,omitempty"`
SCSI28 string `json:"scsi28,omitempty"`
SCSI29 string `json:"scsi29,omitempty"`
SCSI30 string `json:"scsi30,omitempty"`
SATAs map[string]string `json:"-"`
SATA0 string `json:"sata0,omitempty"`
SATA1 string `json:"sata1,omitempty"`
SATA2 string `json:"sata2,omitempty"`
SATA3 string `json:"sata3,omitempty"`
SATA4 string `json:"sata4,omitempty"`
SATA5 string `json:"sata5,omitempty"`
VirtIOs map[string]string `json:"-"`
VirtIO0 string `json:"virtio0,omitempty"`
VirtIO1 string `json:"virtio1,omitempty"`
VirtIO2 string `json:"virtio2,omitempty"`
VirtIO3 string `json:"virtio3,omitempty"`
VirtIO4 string `json:"virtio4,omitempty"`
VirtIO5 string `json:"virtio5,omitempty"`
VirtIO6 string `json:"virtio6,omitempty"`
VirtIO7 string `json:"virtio7,omitempty"`
VirtIO8 string `json:"virtio8,omitempty"`
VirtIO9 string `json:"virtio9,omitempty"`
VirtIO10 string `json:"virtio10,omitempty"`
VirtIO11 string `json:"virtio11,omitempty"`
VirtIO12 string `json:"virtio12,omitempty"`
VirtIO13 string `json:"virtio13,omitempty"`
VirtIO14 string `json:"virtio14,omitempty"`
VirtIO15 string `json:"virtio15,omitempty"`
Unuseds map[string]string `json:"-"`
Unused0 string `json:"unused0,omitempty"`
Unused1 string `json:"unused1,omitempty"`
Unused2 string `json:"unused2,omitempty"`
Unused3 string `json:"unused3,omitempty"`
Unused4 string `json:"unused4,omitempty"`
Unused5 string `json:"unused5,omitempty"`
Unused6 string `json:"unused6,omitempty"`
Unused7 string `json:"unused7,omitempty"`
Unused8 string `json:"unused8,omitempty"`
Unused9 string `json:"unused9,omitempty"`
// Network devices
Nets map[string]string `json:"-"`
Net0 string `json:"net0,omitempty"`
Net1 string `json:"net1,omitempty"`
Net2 string `json:"net2,omitempty"`
Net3 string `json:"net3,omitempty"`
Net4 string `json:"net4,omitempty"`
Net5 string `json:"net5,omitempty"`
Net6 string `json:"net6,omitempty"`
Net7 string `json:"net7,omitempty"`
Net8 string `json:"net8,omitempty"`
Net9 string `json:"net9,omitempty"`
// NUMA topology
Numas map[string]string `json:"-"`
Numa0 string `json:"numa0,omitempty"`
Numa1 string `json:"numa1,omitempty"`
Numa2 string `json:"numa2,omitempty"`
Numa3 string `json:"numa3,omitempty"`
Numa4 string `json:"numa4,omitempty"`
Numa5 string `json:"numa5,omitempty"`
Numa6 string `json:"numa6,omitempty"`
Numa7 string `json:"numa7,omitempty"`
Numa8 string `json:"numa8,omitempty"`
Numa9 string `json:"numa9,omitempty"`
// Host PCI devices
HostPCIs map[string]string `json:"-"`
HostPCI0 string `json:"hostpci0,omitempty"`
HostPCI1 string `json:"hostpci1,omitempty"`
HostPCI2 string `json:"hostpci2,omitempty"`
HostPCI3 string `json:"hostpci3,omitempty"`
HostPCI4 string `json:"hostpci4,omitempty"`
HostPCI5 string `json:"hostpci5,omitempty"`
HostPCI6 string `json:"hostpci6,omitempty"`
HostPCI7 string `json:"hostpci7,omitempty"`
HostPCI8 string `json:"hostpci8,omitempty"`
HostPCI9 string `json:"hostpci9,omitempty"`
// Serial devices
Serials map[string]string `json:"-"`
Serial0 string `json:"serial0,omitempty"`
Serial1 string `json:"serial1,omitempty"`
Serial2 string `json:"serial2,omitempty"`
Serial3 string `json:"serial3,omitempty"`
// USB devices
USBs map[string]string `json:"-"`
USB0 string `json:"usb0,omitempty"`
USB1 string `json:"usb1,omitempty"`
USB2 string `json:"usb2,omitempty"`
USB3 string `json:"usb3,omitempty"`
USB4 string `json:"usb4,omitempty"`
USB5 string `json:"usb5,omitempty"`
USB6 string `json:"usb6,omitempty"`
USB7 string `json:"usb7,omitempty"`
USB8 string `json:"usb8,omitempty"`
USB9 string `json:"usb9,omitempty"`
USB10 string `json:"usb10,omitempty"`
USB11 string `json:"usb11,omitempty"`
USB12 string `json:"usb12,omitempty"`
USB13 string `json:"usb13,omitempty"`
USB14 string `json:"usb14,omitempty"`
// Parallel devices
Parallels map[string]string `json:"-"`
Parallel0 string `json:"parallel0,omitempty"`
Parallel1 string `json:"parallel1,omitempty"`
Parallel2 string `json:"parallel2,omitempty"`
// Cloud-init
CIType string `json:"citype,omitempty"`
CIUser string `json:"ciuser,omitempty"`
CIPassword string `json:"cipassword,omitempty"`
Nameserver string `json:"nameserver,omitempty"`
Searchdomain string `json:"searchdomain,omitempty"`
SSHKeys string `json:"sshkeys,omitempty"`
CICustom string `json:"cicustom,omitempty"`
CIUpgrade int `json:"ciupgrade,omitempty"`
// Cloud-init interfaces
IPConfigs map[string]string `json:"-"`
IPConfig0 string `json:"ipconfig0,omitempty"`
IPConfig1 string `json:"ipconfig1,omitempty"`
IPConfig2 string `json:"ipconfig2,omitempty"`
IPConfig3 string `json:"ipconfig3,omitempty"`
IPConfig4 string `json:"ipconfig4,omitempty"`
IPConfig5 string `json:"ipconfig5,omitempty"`
IPConfig6 string `json:"ipconfig6,omitempty"`
IPConfig7 string `json:"ipconfig7,omitempty"`
IPConfig8 string `json:"ipconfig8,omitempty"`
IPConfig9 string `json:"ipconfig9,omitempty"`
}
type VirtualMachineMigrateOptions struct {
Target string `json:"target"`
BWLimit uint64 `json:"bwlimit,omitempty"`
Force IntOrBool `json:"force,omitempty"`
MigrationNetwork string `json:"migration_network,omitempty"`
MigrationType string `json:"migration_type,omitempty"`
Online IntOrBool `json:"online,omitempty"`
TargetStorage string `json:"targetstorage,omitempty"`
WithLocalDisks IntOrBool `json:"with-local-disks,omitempty"`
}
type ContainerMigrateOptions struct {
Target string `json:"target"`
BWLimit uint64 `json:"bwlimit,omitempty"`
Online IntOrBool `json:"online,omitempty"`
Restart IntOrBool `json:"restart,omitempty"`
}
type VirtualMachineCloneOptions struct {
NewID int `json:"newid"`
BWLimit uint64 `json:"bwlimit,omitempty"`
Description string `json:"description,omitempty"`
Format string `json:"format,omitempty"`
Full uint8 `json:"full,omitempty"`
Name string `json:"name,omitempty"`
Pool string `json:"pool,omitempty"`
SnapName string `json:"snapname,omitempty"`
Storage string `json:"storage,omitempty"`
Target string `json:"target,omitempty"`
}
type VirtualMachineMoveDiskOptions struct {
Disk string `json:"disk"`
BWLimit uint64 `json:"bwlimit,omitempty"`
Delete uint8 `json:"delete,omitempty"`
Digest string `json:"digest,omitempty"`
Format string `json:"format,omitempty"`
Storage string `json:"storage,omitempty"`
TargetDigest string `json:"target-digest,omitempty"`
TargetDisk string `json:"target-disk,omitempty"`
TargetVMID int `json:"target-vmid,omitempty"`
}
type UPID string
type Tasks []*Task
type Task struct {
client *Client
UPID UPID
ID string
Type string
User string
Status string
Node string
PID uint64 `json:",omitempty"`
PStart uint64 `json:",omitempty"`
Saved string `json:",omitempty"`
ExitStatus string `json:",omitempty"`
IsCompleted bool
IsRunning bool
IsFailed bool
IsSuccessful bool
StartTime time.Time `json:"-"`
EndTime time.Time `json:"-"`
Duration time.Duration `json:"-"`
}
func (t *Task) UnmarshalJSON(b []byte) error {
var tmp map[string]interface{}
if err := json.Unmarshal(b, &tmp); err != nil {
return err
}
type TempTask Task
var task TempTask
if err := json.Unmarshal(b, &task); err != nil {
return err
}
if starttime, ok := tmp["starttime"]; ok {
task.StartTime = time.Unix(int64(starttime.(float64)), 0)
}
if endtime, ok := tmp["endtime"]; ok {
task.EndTime = time.Unix(int64(endtime.(float64)), 0)
}
if !task.StartTime.IsZero() && !task.EndTime.IsZero() {
task.Duration = task.EndTime.Sub(task.StartTime)
}
c := Task(task)
return copier.Copy(t, &c)
}
type Log map[int]string
// line numbers in the response start a 1 but the start param indexes from 0 so converting to that
func (l *Log) UnmarshalJSON(b []byte) error {
var data []map[string]interface{}
if err := json.Unmarshal(b, &data); err != nil {
return err
}
log := make(map[int]string, len(data))
for _, row := range data {
if n, ok := row["n"]; ok {
if t, ok := row["t"]; ok {
log[int(n.(float64))-1] = t.(string)
}
}
}
return copier.Copy(l, Log(log))
}
type Containers []*Container
type Container struct {
client *Client
ContainerConfig *ContainerConfig
CPUs int
MaxDisk uint64
MaxMem uint64
MaxSwap uint64
Name string
Node string
Status string
Tags string
Uptime uint64
VMID StringOrUint64
}
type ContainerInterfaces []*ContainerInterface
type ContainerInterface struct {
HWAddr string `json:"hwaddr,omitempty"`
Name string `json:"name,omitempty"`
Inet string `json:"inet,omitempty"`
Inet6 string `json:"inet6,omitempty"`
}
type ContainerCloneOptions struct {
NewID int `json:"newid"`
BWLimit uint64 `json:"bwlimit,omitempty"`
Description string `json:"description,omitempty"`
Full uint8 `json:"full,omitempty"`
Hostname string `json:"hostname,omitempty"`
Pool string `json:"pool,omitempty"`
SnapName string `json:"snapname,omitempty"`
Storage string `json:"storage,omitempty"`
Target string `json:"target,omitempty"`
}
type ContainerConfig struct {
Arch string `json:"arch,omitempty"`
CMode string `json:"cmode,omitempty"`
Console IntOrBool `json:"console,omitempty"`
Cores int `json:"cores,omitempty"`
CPULimit int `json:"cpulimit,omitempty"`
CPUUnits int `json:"cpuunits,omitempty"`
Debug IntOrBool `json:"debug,omitempty"`
Description string `json:"description,omitempty"`
Devs map[string]string `json:"-"` // internal helper for Dev0..9
Dev0 string `json:"dev0,omitempty"`
Dev1 string `json:"dev1,omitempty"`
Dev2 string `json:"dev2,omitempty"`
Dev3 string `json:"dev3,omitempty"`
Dev4 string `json:"dev4,omitempty"`
Dev5 string `json:"dev5,omitempty"`
Dev6 string `json:"dev6,omitempty"`
Dev7 string `json:"dev7,omitempty"`
Dev8 string `json:"dev8,omitempty"`
Dev9 string `json:"dev9,omitempty"`
Digest string `json:"digest"`
Features string `json:"features,omitempty"`
HookScript string `json:"hookscript,omitempty"`
LXC [][]string `json:"lxc,omitempty"`
Hostname string `json:"hostname,omitempty"`
Lock string `json:"lock,omitempty"`
Memory int `json:"memory,omitempty"`
Mps map[string]string `json:"-"` // internal helper for Mp0..9
Mp0 string `json:"mp0,omitempty"`
Mp1 string `json:"mp1,omitempty"`
Mp2 string `json:"mp2,omitempty"`
Mp3 string `json:"mp3,omitempty"`
Mp4 string `json:"mp4,omitempty"`
Mp5 string `json:"mp5,omitempty"`
Mp6 string `json:"mp6,omitempty"`
Mp7 string `json:"mp7,omitempty"`
Mp8 string `json:"mp8,omitempty"`
Mp9 string `json:"mp9,omitempty"`
Nameserver string `json:"nameserver,omitempty"`
Nets map[string]string `json:"-"` // internal helper for Net0..9
Net0 string `json:"net0,omitempty"`
Net1 string `json:"net1,omitempty"`
Net2 string `json:"net2,omitempty"`
Net3 string `json:"net3,omitempty"`
Net4 string `json:"net4,omitempty"`
Net5 string `json:"net5,omitempty"`
Net6 string `json:"net6,omitempty"`
Net7 string `json:"net7,omitempty"`
Net8 string `json:"net8,omitempty"`
Net9 string `json:"net9,omitempty"`
OnBoot IntOrBool `json:"onboot,omitempty"`
OSType string `json:"ostype,omitempty"`
Protection IntOrBool `json:"protection,omitempty"`
RootFS string `json:"rootfs,omitempty"`
SearchDomain string `json:"searchdomain:omitempty"`
Startup string `json:"startup:omitempty"`
Swap int `json:"swap,omitempty"`
TagsSlice []string `json:"-"` // internal helper to manage tags easier
Tags string `json:"tags,omitempty"`
Template IntOrBool `json:"template,omitempty"`
Timezone string `json:"timezone,omitempty"`
TTY int `json:"tty,omitempty"`
Unprivileged IntOrBool `json:"unprivileged,omitempty"`
Unuseds map[string]string `json:"-"` // internal helper
Unused0 string `json:"unused0,omitempty"`
Unused1 string `json:"unused1,omitempty"`
Unused2 string `json:"unused2,omitempty"`
Unused3 string `json:"unused3,omitempty"`
Unused4 string `json:"unused4,omitempty"`
Unused5 string `json:"unused5,omitempty"`
Unused6 string `json:"unused6,omitempty"`
Unused7 string `json:"unused7,omitempty"`
Unused8 string `json:"unused8,omitempty"`
Unused9 string `json:"unused9,omitempty"`
}
func (cc *ContainerConfig) UnmarshalJSON(data []byte) error {
type tmpContainerConfig ContainerConfig
// create a struct and embed temporary alias of ContainerConfig to avoid recursion
// this will also populate the rest of the fields using the built in unmarshal function
tmp := &struct {
*tmpContainerConfig
}{
tmpContainerConfig: (*tmpContainerConfig)(cc),
}
if err := json.Unmarshal(data, &tmp); err != nil {
return err
}
// Split the tags on TagSeparator and populate TagsSlice
cc.TagsSlice = strings.Split(cc.Tags, TagSeperator)
// Populate the indexed fields into helper maps
cc.MergeDevs()
cc.MergeMps()
cc.MergeNets()
cc.MergeUnuseds()
return nil
}
// ContainerOptions A key/value pair used to modify a container(LXC) config
// Refer to https://pve.proxmox.com/pve-docs/api-viewer/#/nodes/{node}/lxc/{vmid}/config for a list of valid values
type ContainerOptions []*ContainerOption
type ContainerOption struct {
Name string
Value interface{}
}
type Appliances []*Appliance
type Appliance struct {
client *Client
Node string `json:",omitempty"`
Os string
Source string
Type string
SHA512Sum string
Package string
Template string
Architecture string
InfoPage string
Description string
ManageURL string
Version string
Section string
Headline string
}
type Storages []*Storage
type Storage struct {
client *Client
Node string
Name string `json:"storage"`
Enabled int
UsedFraction float64 `json:"used_fraction"`
Active int
Content string
Shared int
Avail uint64
Type string
Used uint64
Total uint64
Storage string
}
type ClusterStorages []*ClusterStorage
type ClusterStorage struct {
client *Client
Content string
Digest string
Storage string
Type string
Thinpool string `json:",omitempty"`
Path string `json:",omitempty"`
VgName string `json:",omitempty"`
}
type ClusterStorageOptions struct {
Name string
Value string
}
type Volume interface {
Delete() error
}
type ISOs []*ISO
type ISO struct{ Content }
type VzTmpls []*VzTmpl
type VzTmpl struct{ Content }
type Backups []*Backup
type Backup struct{ Content }
type Content struct {
client *Client
URL string
Node string
Storage string `json:",omitempty"`
Content string `json:",omitempty"`
VolID string `json:",omitempty"`
CTime uint64 `json:",omitempty"`
Format string
Size StringOrUint64
Used StringOrUint64 `json:",omitempty"`
Path string `json:",omitempty"`
Notes string `json:",omitempty"`
}
type IsTemplate bool
func (it *IsTemplate) UnmarshalJSON(b []byte) error {
*it = true
if string(b) == "\"\"" {
*it = false
}
return nil
}
type StringOrInt int
func (d *StringOrInt) UnmarshalJSON(b []byte) error {
str := strings.Replace(string(b), "\"", "", -1)
if str == "" {
*d = StringOrInt(0)
return nil
}
if !isFloat.MatchString(str) {
return fmt.Errorf("failed to match %s: %s", isFloat.String(), str)
}
parsed, err := strconv.ParseFloat(str, 64)
if err != nil {
return err
}
*d = StringOrInt(math.Trunc(parsed)) // truncate to make an int
return nil
}
type StringOrUint64 uint64
func (d *StringOrUint64) UnmarshalJSON(b []byte) error {
str := strings.Replace(string(b), "\"", "", -1)
if str == "" {
*d = StringOrUint64(0)
return nil
}
if !isFloat.MatchString(str) {
return fmt.Errorf("failed to match %s: %s", isFloat.String(), str)
}
parsed, err := strconv.ParseFloat(str, 64)
if err != nil {
return err
}
*d = StringOrUint64(math.Trunc(parsed)) // truncate to make an int
return nil
}
type StringOrFloat64 float64
func (d *StringOrFloat64) UnmarshalJSON(b []byte) error {
str := strings.Replace(string(b), "\"", "", -1)
if str == "" {
*d = StringOrFloat64(0)
return nil
}
if !isFloat.MatchString(str) {
return fmt.Errorf("failed to match %s: %s", isFloat.String(), str)
}
parsed, err := strconv.ParseFloat(str, 64)
if err != nil {
return err
}
*d = StringOrFloat64(parsed)
return nil
}
type IntOrBool bool
func (b *IntOrBool) UnmarshalJSON(i []byte) error {
parsed, err := strconv.ParseBool(string(i))
if err != nil {
return err
}
*b = IntOrBool(parsed)
return nil
}
func (b *IntOrBool) MarshalJSON() ([]byte, error) {
if *b {
return []byte("1"), nil
}
return []byte("0"), nil
}
type NodeNetworks []*NodeNetwork
type NodeNetwork struct {
client *Client
Node string `json:"-"`
NodeAPI *Node `json:"-"`
Iface string `json:"iface,omitempty"`
Autostart int `json:"autostart,omitempty"`