-
Notifications
You must be signed in to change notification settings - Fork 2
/
i64listi64.go
9529 lines (8680 loc) · 301 KB
/
i64listi64.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
// Autogenerated by Thrift Compiler (0.11.0)
// DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
package i64listi64
import (
"bytes"
"reflect"
"database/sql/driver"
"errors"
"context"
"fmt"
"git.apache.org/thrift.git/lib/go/thrift"
)
// (needed to ensure safety because of naive import list construction.)
var _ = thrift.ZERO
var _ = fmt.Printf
var _ = context.Background
var _ = reflect.DeepEqual
var _ = bytes.Equal
type LimitPolicy int64
const (
LimitPolicy_REJECT LimitPolicy = 0
LimitPolicy_EVICT_FRONT LimitPolicy = 1
LimitPolicy_EVICT_BACK LimitPolicy = 2
)
func (p LimitPolicy) String() string {
switch p {
case LimitPolicy_REJECT: return "REJECT"
case LimitPolicy_EVICT_FRONT: return "EVICT_FRONT"
case LimitPolicy_EVICT_BACK: return "EVICT_BACK"
}
return "<UNSET>"
}
func LimitPolicyFromString(s string) (LimitPolicy, error) {
switch s {
case "REJECT": return LimitPolicy_REJECT, nil
case "EVICT_FRONT": return LimitPolicy_EVICT_FRONT, nil
case "EVICT_BACK": return LimitPolicy_EVICT_BACK, nil
}
return LimitPolicy(0), fmt.Errorf("not a valid LimitPolicy string")
}
func LimitPolicyPtr(v LimitPolicy) *LimitPolicy { return &v }
func (p LimitPolicy) MarshalText() ([]byte, error) {
return []byte(p.String()), nil
}
func (p *LimitPolicy) UnmarshalText(text []byte) error {
q, err := LimitPolicyFromString(string(text))
if (err != nil) {
return err
}
*p = q
return nil
}
func (p *LimitPolicy) Scan(value interface{}) error {
v, ok := value.(int64)
if !ok {
return errors.New("Scan value is not int64")
}
*p = LimitPolicy(v)
return nil
}
func (p * LimitPolicy) Value() (driver.Value, error) {
if p == nil {
return nil, nil
}
return int64(*p), nil
}
type TEntry int64
func TEntryPtr(v TEntry) *TEntry { return &v }
type TKey int64
func TKeyPtr(v TKey) *TKey { return &v }
type TKeyList []TKey
func TKeyListPtr(v TKeyList) *TKeyList { return &v }
type TEntryList []TEntry
func TEntryListPtr(v TEntryList) *TEntryList { return &v }
// Attributes:
// - Entries
type TValue struct {
Entries TEntryList `thrift:"entries,1" db:"entries" json:"entries"`
}
func NewTValue() *TValue {
return &TValue{}
}
func (p *TValue) GetEntries() TEntryList {
return p.Entries
}
func (p *TValue) Read(iprot thrift.TProtocol) error {
if _, err := iprot.ReadStructBegin(); err != nil {
return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err)
}
for {
_, fieldTypeId, fieldId, err := iprot.ReadFieldBegin()
if err != nil {
return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err)
}
if fieldTypeId == thrift.STOP { break; }
switch fieldId {
case 1:
if fieldTypeId == thrift.LIST {
if err := p.ReadField1(iprot); err != nil {
return err
}
} else {
if err := iprot.Skip(fieldTypeId); err != nil {
return err
}
}
default:
if err := iprot.Skip(fieldTypeId); err != nil {
return err
}
}
if err := iprot.ReadFieldEnd(); err != nil {
return err
}
}
if err := iprot.ReadStructEnd(); err != nil {
return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err)
}
return nil
}
func (p *TValue) ReadField1(iprot thrift.TProtocol) error {
_, size, err := iprot.ReadListBegin()
if err != nil {
return thrift.PrependError("error reading list begin: ", err)
}
tSlice := make(TEntryList, 0, size)
p.Entries = tSlice
for i := 0; i < size; i ++ {
var _elem0 TEntry
if v, err := iprot.ReadI64(); err != nil {
return thrift.PrependError("error reading field 0: ", err)
} else {
temp := TEntry(v)
_elem0 = temp
}
p.Entries = append(p.Entries, _elem0)
}
if err := iprot.ReadListEnd(); err != nil {
return thrift.PrependError("error reading list end: ", err)
}
return nil
}
func (p *TValue) Write(oprot thrift.TProtocol) error {
if err := oprot.WriteStructBegin("TValue"); err != nil {
return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) }
if p != nil {
if err := p.writeField1(oprot); err != nil { return err }
}
if err := oprot.WriteFieldStop(); err != nil {
return thrift.PrependError("write field stop error: ", err) }
if err := oprot.WriteStructEnd(); err != nil {
return thrift.PrependError("write struct stop error: ", err) }
return nil
}
func (p *TValue) writeField1(oprot thrift.TProtocol) (err error) {
if err := oprot.WriteFieldBegin("entries", thrift.LIST, 1); err != nil {
return thrift.PrependError(fmt.Sprintf("%T write field begin error 1:entries: ", p), err) }
if err := oprot.WriteListBegin(thrift.I64, len(p.Entries)); err != nil {
return thrift.PrependError("error writing list begin: ", err)
}
for _, v := range p.Entries {
if err := oprot.WriteI64(int64(v)); err != nil {
return thrift.PrependError(fmt.Sprintf("%T. (0) field write error: ", p), err) }
}
if err := oprot.WriteListEnd(); err != nil {
return thrift.PrependError("error writing list end: ", err)
}
if err := oprot.WriteFieldEnd(); err != nil {
return thrift.PrependError(fmt.Sprintf("%T write field end error 1:entries: ", p), err) }
return err
}
func (p *TValue) String() string {
if p == nil {
return "<nil>"
}
return fmt.Sprintf("TValue(%+v)", *p)
}
type I64ListI64Service interface {
// Count entry number
//
// Parameters:
// - Key
Count(ctx context.Context, key TKey) (r int32, err error)
// Test entry existence
//
// Parameters:
// - Key
// - Entry
Existed(ctx context.Context, key TKey, entry TEntry) (r bool, err error)
// Get list of all entries
//
// Parameters:
// - Key
GetListAll(ctx context.Context, key TKey) (r TEntryList, err error)
// Parameters:
// - Key
GetAll(ctx context.Context, key TKey) (r TEntryList, err error)
// Get list entry slice
//
// Parameters:
// - Key
// - Start
// - Length
GetSlice(ctx context.Context, key TKey, start int32, length int32) (r TEntryList, err error)
// Parameters:
// - Key
// - EntryStart
// - Length
GetSliceFromEntry(ctx context.Context, key TKey, entryStart TEntry, length int32) (r TEntryList, err error)
// Parameters:
// - Key
// - EntryStart
// - Length
GetSliceFromId(ctx context.Context, key TKey, entryStart TEntry, length int32) (r TEntryList, err error)
// Parameters:
// - Key
// - Start
// - Length
GetSliceReverse(ctx context.Context, key TKey, start int32, length int32) (r TEntryList, err error)
// Parameters:
// - Key
// - EntryStart
// - Length
GetSliceFromEntryReverse(ctx context.Context, key TKey, entryStart TEntry, length int32) (r TEntryList, err error)
// Parameters:
// - Key
// - EntryStart
// - Length
GetSliceFromIdReverse(ctx context.Context, key TKey, entryStart TEntry, length int32) (r TEntryList, err error)
// Put an entry, update on entry existence
// For unsorted list this insert at end()
//
// Parameters:
// - Key
// - Entry
Put(ctx context.Context, key TKey, entry TEntry) (r bool, err error)
// Clear old data, put new value on the key
//
// Parameters:
// - Key
// - Value
PutValue(ctx context.Context, key TKey, value *TValue) (r bool, err error)
// Put list of entry, update on entry existence
//
// Parameters:
// - Key
// - EntryList
PutList(ctx context.Context, key TKey, entryList TEntryList) (r bool, err error)
// Insert an entry, return false on key existence
// @return true on successful insertion, false otherwise (due to length limit or entry existed on sorted list)
// For unsorted list this insert at end()
//
// Parameters:
// - Key
// - Entry
Insert(ctx context.Context, key TKey, entry TEntry) (r bool, err error)
// Insert an entry at index
// @param index considered count from begin if non-negative, count from end otherwise
// the entry will have index = start after insertion
// e.g. 0 = push_front, -1 = push_back, -2 = the entry before last entry
// For sorted list this calls insert
//
// Parameters:
// - Key
// - Entry
// - Index
InsertAt(ctx context.Context, key TKey, entry TEntry, index int32) (r bool, err error)
// Remove an entry, return false if entry not found
//
// Parameters:
// - Key
// - Entry
Remove(ctx context.Context, key TKey, entry TEntry) (r bool, err error)
// Remove entry by index
// @param index similar to insertAt
//
// Parameters:
// - Key
// - Index
RemoveAt(ctx context.Context, key TKey, index int32) (r bool, err error)
// Make an entry the first in unsorted list and return true if it existed, do nothing on sorted list return false
//
// Parameters:
// - Key
// - Entry
BumpUp(ctx context.Context, key TKey, entry TEntry) (r bool, err error)
// Remove entry list
//
// Parameters:
// - Key
// - EntryList
RemoveList(ctx context.Context, key TKey, entryList TEntryList) (r bool, err error)
// Clear data on given key
//
// Parameters:
// - Key
ClearData(ctx context.Context, key TKey) (err error)
// Split the list into 2, return first entry of new list, or -1 if fails
//
// Parameters:
// - OldKey
// - NewKey_
// - OrigLength
Split(ctx context.Context, oldKey TKey, newKey TKey, origLength int32) (r TEntry, err error)
// Parameters:
// - KeyList
MultiCount(ctx context.Context, keyList TKeyList) (r map[TKey]int32, err error)
// Parameters:
// - KeyList
// - Entry
MultiExisted(ctx context.Context, keyList TKeyList, entry TEntry) (r map[TKey]bool, err error)
// Parameters:
// - KeyList
MultiGetListAll(ctx context.Context, keyList TKeyList) (r map[TKey]TEntryList, err error)
// Parameters:
// - KeyList
// - Start
// - Length
MultiGetSlice(ctx context.Context, keyList TKeyList, start int32, length int32) (r map[TKey]TEntryList, err error)
// Parameters:
// - KeyList
// - Start
// - Length
MultiGetSliceReverse(ctx context.Context, keyList TKeyList, start int32, length int32) (r map[TKey]TEntryList, err error)
// Put same entry to multiple keys
//
// Parameters:
// - KeyList
// - Entry
MultiPut(ctx context.Context, keyList TKeyList, entry TEntry) (r map[TKey]bool, err error)
// Parameters:
// - Key
// - Entry
PutOw(ctx context.Context, key TKey, entry TEntry) (err error)
// Parameters:
// - UidList
// - Entry
PutMultiKeyOw(ctx context.Context, uidList TKeyList, entry TEntry) (err error)
// Parameters:
// - Key
// - Entry
RemoveOw(ctx context.Context, key TKey, entry TEntry) (err error)
}
type I64ListI64ServiceClient struct {
c thrift.TClient
}
// Deprecated: Use NewI64ListI64Service instead
func NewI64ListI64ServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *I64ListI64ServiceClient {
return &I64ListI64ServiceClient{
c: thrift.NewTStandardClient(f.GetProtocol(t), f.GetProtocol(t)),
}
}
// Deprecated: Use NewI64ListI64Service instead
func NewI64ListI64ServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *I64ListI64ServiceClient {
return &I64ListI64ServiceClient{
c: thrift.NewTStandardClient(iprot, oprot),
}
}
func NewI64ListI64ServiceClient(c thrift.TClient) *I64ListI64ServiceClient {
return &I64ListI64ServiceClient{
c: c,
}
}
// Count entry number
//
// Parameters:
// - Key
func (p *I64ListI64ServiceClient) Count(ctx context.Context, key TKey) (r int32, err error) {
var _args1 I64ListI64ServiceCountArgs
_args1.Key = key
var _result2 I64ListI64ServiceCountResult
if err = p.c.Call(ctx, "count", &_args1, &_result2); err != nil {
return
}
return _result2.GetSuccess(), nil
}
// Test entry existence
//
// Parameters:
// - Key
// - Entry
func (p *I64ListI64ServiceClient) Existed(ctx context.Context, key TKey, entry TEntry) (r bool, err error) {
var _args3 I64ListI64ServiceExistedArgs
_args3.Key = key
_args3.Entry = entry
var _result4 I64ListI64ServiceExistedResult
if err = p.c.Call(ctx, "existed", &_args3, &_result4); err != nil {
return
}
return _result4.GetSuccess(), nil
}
// Get list of all entries
//
// Parameters:
// - Key
func (p *I64ListI64ServiceClient) GetListAll(ctx context.Context, key TKey) (r TEntryList, err error) {
var _args5 I64ListI64ServiceGetListAllArgs
_args5.Key = key
var _result6 I64ListI64ServiceGetListAllResult
if err = p.c.Call(ctx, "getListAll", &_args5, &_result6); err != nil {
return
}
return _result6.GetSuccess(), nil
}
// Parameters:
// - Key
func (p *I64ListI64ServiceClient) GetAll(ctx context.Context, key TKey) (r TEntryList, err error) {
var _args7 I64ListI64ServiceGetAllArgs
_args7.Key = key
var _result8 I64ListI64ServiceGetAllResult
if err = p.c.Call(ctx, "getAll", &_args7, &_result8); err != nil {
return
}
return _result8.GetSuccess(), nil
}
// Get list entry slice
//
// Parameters:
// - Key
// - Start
// - Length
func (p *I64ListI64ServiceClient) GetSlice(ctx context.Context, key TKey, start int32, length int32) (r TEntryList, err error) {
var _args9 I64ListI64ServiceGetSliceArgs
_args9.Key = key
_args9.Start = start
_args9.Length = length
var _result10 I64ListI64ServiceGetSliceResult
if err = p.c.Call(ctx, "getSlice", &_args9, &_result10); err != nil {
return
}
return _result10.GetSuccess(), nil
}
// Parameters:
// - Key
// - EntryStart
// - Length
func (p *I64ListI64ServiceClient) GetSliceFromEntry(ctx context.Context, key TKey, entryStart TEntry, length int32) (r TEntryList, err error) {
var _args11 I64ListI64ServiceGetSliceFromEntryArgs
_args11.Key = key
_args11.EntryStart = entryStart
_args11.Length = length
var _result12 I64ListI64ServiceGetSliceFromEntryResult
if err = p.c.Call(ctx, "getSliceFromEntry", &_args11, &_result12); err != nil {
return
}
return _result12.GetSuccess(), nil
}
// Parameters:
// - Key
// - EntryStart
// - Length
func (p *I64ListI64ServiceClient) GetSliceFromId(ctx context.Context, key TKey, entryStart TEntry, length int32) (r TEntryList, err error) {
var _args13 I64ListI64ServiceGetSliceFromIdArgs
_args13.Key = key
_args13.EntryStart = entryStart
_args13.Length = length
var _result14 I64ListI64ServiceGetSliceFromIdResult
if err = p.c.Call(ctx, "getSliceFromId", &_args13, &_result14); err != nil {
return
}
return _result14.GetSuccess(), nil
}
// Parameters:
// - Key
// - Start
// - Length
func (p *I64ListI64ServiceClient) GetSliceReverse(ctx context.Context, key TKey, start int32, length int32) (r TEntryList, err error) {
var _args15 I64ListI64ServiceGetSliceReverseArgs
_args15.Key = key
_args15.Start = start
_args15.Length = length
var _result16 I64ListI64ServiceGetSliceReverseResult
if err = p.c.Call(ctx, "getSliceReverse", &_args15, &_result16); err != nil {
return
}
return _result16.GetSuccess(), nil
}
// Parameters:
// - Key
// - EntryStart
// - Length
func (p *I64ListI64ServiceClient) GetSliceFromEntryReverse(ctx context.Context, key TKey, entryStart TEntry, length int32) (r TEntryList, err error) {
var _args17 I64ListI64ServiceGetSliceFromEntryReverseArgs
_args17.Key = key
_args17.EntryStart = entryStart
_args17.Length = length
var _result18 I64ListI64ServiceGetSliceFromEntryReverseResult
if err = p.c.Call(ctx, "getSliceFromEntryReverse", &_args17, &_result18); err != nil {
return
}
return _result18.GetSuccess(), nil
}
// Parameters:
// - Key
// - EntryStart
// - Length
func (p *I64ListI64ServiceClient) GetSliceFromIdReverse(ctx context.Context, key TKey, entryStart TEntry, length int32) (r TEntryList, err error) {
var _args19 I64ListI64ServiceGetSliceFromIdReverseArgs
_args19.Key = key
_args19.EntryStart = entryStart
_args19.Length = length
var _result20 I64ListI64ServiceGetSliceFromIdReverseResult
if err = p.c.Call(ctx, "getSliceFromIdReverse", &_args19, &_result20); err != nil {
return
}
return _result20.GetSuccess(), nil
}
// Put an entry, update on entry existence
// For unsorted list this insert at end()
//
// Parameters:
// - Key
// - Entry
func (p *I64ListI64ServiceClient) Put(ctx context.Context, key TKey, entry TEntry) (r bool, err error) {
var _args21 I64ListI64ServicePutArgs
_args21.Key = key
_args21.Entry = entry
var _result22 I64ListI64ServicePutResult
if err = p.c.Call(ctx, "put", &_args21, &_result22); err != nil {
return
}
return _result22.GetSuccess(), nil
}
// Clear old data, put new value on the key
//
// Parameters:
// - Key
// - Value
func (p *I64ListI64ServiceClient) PutValue(ctx context.Context, key TKey, value *TValue) (r bool, err error) {
var _args23 I64ListI64ServicePutValueArgs
_args23.Key = key
_args23.Value = value
var _result24 I64ListI64ServicePutValueResult
if err = p.c.Call(ctx, "putValue", &_args23, &_result24); err != nil {
return
}
return _result24.GetSuccess(), nil
}
// Put list of entry, update on entry existence
//
// Parameters:
// - Key
// - EntryList
func (p *I64ListI64ServiceClient) PutList(ctx context.Context, key TKey, entryList TEntryList) (r bool, err error) {
var _args25 I64ListI64ServicePutListArgs
_args25.Key = key
_args25.EntryList = entryList
var _result26 I64ListI64ServicePutListResult
if err = p.c.Call(ctx, "putList", &_args25, &_result26); err != nil {
return
}
return _result26.GetSuccess(), nil
}
// Insert an entry, return false on key existence
// @return true on successful insertion, false otherwise (due to length limit or entry existed on sorted list)
// For unsorted list this insert at end()
//
// Parameters:
// - Key
// - Entry
func (p *I64ListI64ServiceClient) Insert(ctx context.Context, key TKey, entry TEntry) (r bool, err error) {
var _args27 I64ListI64ServiceInsertArgs
_args27.Key = key
_args27.Entry = entry
var _result28 I64ListI64ServiceInsertResult
if err = p.c.Call(ctx, "insert", &_args27, &_result28); err != nil {
return
}
return _result28.GetSuccess(), nil
}
// Insert an entry at index
// @param index considered count from begin if non-negative, count from end otherwise
// the entry will have index = start after insertion
// e.g. 0 = push_front, -1 = push_back, -2 = the entry before last entry
// For sorted list this calls insert
//
// Parameters:
// - Key
// - Entry
// - Index
func (p *I64ListI64ServiceClient) InsertAt(ctx context.Context, key TKey, entry TEntry, index int32) (r bool, err error) {
var _args29 I64ListI64ServiceInsertAtArgs
_args29.Key = key
_args29.Entry = entry
_args29.Index = index
var _result30 I64ListI64ServiceInsertAtResult
if err = p.c.Call(ctx, "insertAt", &_args29, &_result30); err != nil {
return
}
return _result30.GetSuccess(), nil
}
// Remove an entry, return false if entry not found
//
// Parameters:
// - Key
// - Entry
func (p *I64ListI64ServiceClient) Remove(ctx context.Context, key TKey, entry TEntry) (r bool, err error) {
var _args31 I64ListI64ServiceRemoveArgs
_args31.Key = key
_args31.Entry = entry
var _result32 I64ListI64ServiceRemoveResult
if err = p.c.Call(ctx, "remove", &_args31, &_result32); err != nil {
return
}
return _result32.GetSuccess(), nil
}
// Remove entry by index
// @param index similar to insertAt
//
// Parameters:
// - Key
// - Index
func (p *I64ListI64ServiceClient) RemoveAt(ctx context.Context, key TKey, index int32) (r bool, err error) {
var _args33 I64ListI64ServiceRemoveAtArgs
_args33.Key = key
_args33.Index = index
var _result34 I64ListI64ServiceRemoveAtResult
if err = p.c.Call(ctx, "removeAt", &_args33, &_result34); err != nil {
return
}
return _result34.GetSuccess(), nil
}
// Make an entry the first in unsorted list and return true if it existed, do nothing on sorted list return false
//
// Parameters:
// - Key
// - Entry
func (p *I64ListI64ServiceClient) BumpUp(ctx context.Context, key TKey, entry TEntry) (r bool, err error) {
var _args35 I64ListI64ServiceBumpUpArgs
_args35.Key = key
_args35.Entry = entry
var _result36 I64ListI64ServiceBumpUpResult
if err = p.c.Call(ctx, "bumpUp", &_args35, &_result36); err != nil {
return
}
return _result36.GetSuccess(), nil
}
// Remove entry list
//
// Parameters:
// - Key
// - EntryList
func (p *I64ListI64ServiceClient) RemoveList(ctx context.Context, key TKey, entryList TEntryList) (r bool, err error) {
var _args37 I64ListI64ServiceRemoveListArgs
_args37.Key = key
_args37.EntryList = entryList
var _result38 I64ListI64ServiceRemoveListResult
if err = p.c.Call(ctx, "removeList", &_args37, &_result38); err != nil {
return
}
return _result38.GetSuccess(), nil
}
// Clear data on given key
//
// Parameters:
// - Key
func (p *I64ListI64ServiceClient) ClearData(ctx context.Context, key TKey) (err error) {
var _args39 I64ListI64ServiceClearDataArgs
_args39.Key = key
var _result40 I64ListI64ServiceClearDataResult
if err = p.c.Call(ctx, "clearData", &_args39, &_result40); err != nil {
return
}
return nil
}
// Split the list into 2, return first entry of new list, or -1 if fails
//
// Parameters:
// - OldKey
// - NewKey_
// - OrigLength
func (p *I64ListI64ServiceClient) Split(ctx context.Context, oldKey TKey, newKey TKey, origLength int32) (r TEntry, err error) {
var _args41 I64ListI64ServiceSplitArgs
_args41.OldKey = oldKey
_args41.NewKey_ = newKey
_args41.OrigLength = origLength
var _result42 I64ListI64ServiceSplitResult
if err = p.c.Call(ctx, "split", &_args41, &_result42); err != nil {
return
}
return _result42.GetSuccess(), nil
}
// Parameters:
// - KeyList
func (p *I64ListI64ServiceClient) MultiCount(ctx context.Context, keyList TKeyList) (r map[TKey]int32, err error) {
var _args43 I64ListI64ServiceMultiCountArgs
_args43.KeyList = keyList
var _result44 I64ListI64ServiceMultiCountResult
if err = p.c.Call(ctx, "multiCount", &_args43, &_result44); err != nil {
return
}
return _result44.GetSuccess(), nil
}
// Parameters:
// - KeyList
// - Entry
func (p *I64ListI64ServiceClient) MultiExisted(ctx context.Context, keyList TKeyList, entry TEntry) (r map[TKey]bool, err error) {
var _args45 I64ListI64ServiceMultiExistedArgs
_args45.KeyList = keyList
_args45.Entry = entry
var _result46 I64ListI64ServiceMultiExistedResult
if err = p.c.Call(ctx, "multiExisted", &_args45, &_result46); err != nil {
return
}
return _result46.GetSuccess(), nil
}
// Parameters:
// - KeyList
func (p *I64ListI64ServiceClient) MultiGetListAll(ctx context.Context, keyList TKeyList) (r map[TKey]TEntryList, err error) {
var _args47 I64ListI64ServiceMultiGetListAllArgs
_args47.KeyList = keyList
var _result48 I64ListI64ServiceMultiGetListAllResult
if err = p.c.Call(ctx, "multiGetListAll", &_args47, &_result48); err != nil {
return
}
return _result48.GetSuccess(), nil
}
// Parameters:
// - KeyList
// - Start
// - Length
func (p *I64ListI64ServiceClient) MultiGetSlice(ctx context.Context, keyList TKeyList, start int32, length int32) (r map[TKey]TEntryList, err error) {
var _args49 I64ListI64ServiceMultiGetSliceArgs
_args49.KeyList = keyList
_args49.Start = start
_args49.Length = length
var _result50 I64ListI64ServiceMultiGetSliceResult
if err = p.c.Call(ctx, "multiGetSlice", &_args49, &_result50); err != nil {
return
}
return _result50.GetSuccess(), nil
}
// Parameters:
// - KeyList
// - Start
// - Length
func (p *I64ListI64ServiceClient) MultiGetSliceReverse(ctx context.Context, keyList TKeyList, start int32, length int32) (r map[TKey]TEntryList, err error) {
var _args51 I64ListI64ServiceMultiGetSliceReverseArgs
_args51.KeyList = keyList
_args51.Start = start
_args51.Length = length
var _result52 I64ListI64ServiceMultiGetSliceReverseResult
if err = p.c.Call(ctx, "multiGetSliceReverse", &_args51, &_result52); err != nil {
return
}
return _result52.GetSuccess(), nil
}
// Put same entry to multiple keys
//
// Parameters:
// - KeyList
// - Entry
func (p *I64ListI64ServiceClient) MultiPut(ctx context.Context, keyList TKeyList, entry TEntry) (r map[TKey]bool, err error) {
var _args53 I64ListI64ServiceMultiPutArgs
_args53.KeyList = keyList
_args53.Entry = entry
var _result54 I64ListI64ServiceMultiPutResult
if err = p.c.Call(ctx, "multiPut", &_args53, &_result54); err != nil {
return
}
return _result54.GetSuccess(), nil
}
// Parameters:
// - Key
// - Entry
func (p *I64ListI64ServiceClient) PutOw(ctx context.Context, key TKey, entry TEntry) (err error) {
var _args55 I64ListI64ServicePutOwArgs
_args55.Key = key
_args55.Entry = entry
if err := p.c.Call(ctx, "put_ow", &_args55, nil); err != nil {
return err
}
return nil
}
// Parameters:
// - UidList
// - Entry
func (p *I64ListI64ServiceClient) PutMultiKeyOw(ctx context.Context, uidList TKeyList, entry TEntry) (err error) {
var _args56 I64ListI64ServicePutMultiKeyOwArgs
_args56.UidList = uidList
_args56.Entry = entry
if err := p.c.Call(ctx, "putMultiKey_ow", &_args56, nil); err != nil {
return err
}
return nil
}
// Parameters:
// - Key
// - Entry
func (p *I64ListI64ServiceClient) RemoveOw(ctx context.Context, key TKey, entry TEntry) (err error) {
var _args57 I64ListI64ServiceRemoveOwArgs
_args57.Key = key
_args57.Entry = entry
if err := p.c.Call(ctx, "remove_ow", &_args57, nil); err != nil {
return err
}
return nil
}
type I64ListI64ServiceProcessor struct {
processorMap map[string]thrift.TProcessorFunction
handler I64ListI64Service
}
func (p *I64ListI64ServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction) {
p.processorMap[key] = processor
}
func (p *I64ListI64ServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool) {
processor, ok = p.processorMap[key]
return processor, ok
}
func (p *I64ListI64ServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction {
return p.processorMap
}
func NewI64ListI64ServiceProcessor(handler I64ListI64Service) *I64ListI64ServiceProcessor {
self58 := &I64ListI64ServiceProcessor{handler:handler, processorMap:make(map[string]thrift.TProcessorFunction)}
self58.processorMap["count"] = &i64ListI64ServiceProcessorCount{handler:handler}
self58.processorMap["existed"] = &i64ListI64ServiceProcessorExisted{handler:handler}
self58.processorMap["getListAll"] = &i64ListI64ServiceProcessorGetListAll{handler:handler}
self58.processorMap["getAll"] = &i64ListI64ServiceProcessorGetAll{handler:handler}
self58.processorMap["getSlice"] = &i64ListI64ServiceProcessorGetSlice{handler:handler}
self58.processorMap["getSliceFromEntry"] = &i64ListI64ServiceProcessorGetSliceFromEntry{handler:handler}
self58.processorMap["getSliceFromId"] = &i64ListI64ServiceProcessorGetSliceFromId{handler:handler}
self58.processorMap["getSliceReverse"] = &i64ListI64ServiceProcessorGetSliceReverse{handler:handler}
self58.processorMap["getSliceFromEntryReverse"] = &i64ListI64ServiceProcessorGetSliceFromEntryReverse{handler:handler}
self58.processorMap["getSliceFromIdReverse"] = &i64ListI64ServiceProcessorGetSliceFromIdReverse{handler:handler}
self58.processorMap["put"] = &i64ListI64ServiceProcessorPut{handler:handler}
self58.processorMap["putValue"] = &i64ListI64ServiceProcessorPutValue{handler:handler}
self58.processorMap["putList"] = &i64ListI64ServiceProcessorPutList{handler:handler}
self58.processorMap["insert"] = &i64ListI64ServiceProcessorInsert{handler:handler}
self58.processorMap["insertAt"] = &i64ListI64ServiceProcessorInsertAt{handler:handler}
self58.processorMap["remove"] = &i64ListI64ServiceProcessorRemove{handler:handler}
self58.processorMap["removeAt"] = &i64ListI64ServiceProcessorRemoveAt{handler:handler}
self58.processorMap["bumpUp"] = &i64ListI64ServiceProcessorBumpUp{handler:handler}
self58.processorMap["removeList"] = &i64ListI64ServiceProcessorRemoveList{handler:handler}
self58.processorMap["clearData"] = &i64ListI64ServiceProcessorClearData{handler:handler}
self58.processorMap["split"] = &i64ListI64ServiceProcessorSplit{handler:handler}
self58.processorMap["multiCount"] = &i64ListI64ServiceProcessorMultiCount{handler:handler}
self58.processorMap["multiExisted"] = &i64ListI64ServiceProcessorMultiExisted{handler:handler}
self58.processorMap["multiGetListAll"] = &i64ListI64ServiceProcessorMultiGetListAll{handler:handler}
self58.processorMap["multiGetSlice"] = &i64ListI64ServiceProcessorMultiGetSlice{handler:handler}
self58.processorMap["multiGetSliceReverse"] = &i64ListI64ServiceProcessorMultiGetSliceReverse{handler:handler}
self58.processorMap["multiPut"] = &i64ListI64ServiceProcessorMultiPut{handler:handler}
self58.processorMap["put_ow"] = &i64ListI64ServiceProcessorPutOw{handler:handler}
self58.processorMap["putMultiKey_ow"] = &i64ListI64ServiceProcessorPutMultiKeyOw{handler:handler}
self58.processorMap["remove_ow"] = &i64ListI64ServiceProcessorRemoveOw{handler:handler}
return self58
}
func (p *I64ListI64ServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) {
name, _, seqId, err := iprot.ReadMessageBegin()
if err != nil { return false, err }
if processor, ok := p.GetProcessorFunction(name); ok {
return processor.Process(ctx, seqId, iprot, oprot)
}
iprot.Skip(thrift.STRUCT)
iprot.ReadMessageEnd()
x59 := thrift.NewTApplicationException(thrift.UNKNOWN_METHOD, "Unknown function " + name)
oprot.WriteMessageBegin(name, thrift.EXCEPTION, seqId)
x59.Write(oprot)
oprot.WriteMessageEnd()
oprot.Flush()
return false, x59
}
type i64ListI64ServiceProcessorCount struct {
handler I64ListI64Service
}
func (p *i64ListI64ServiceProcessorCount) Process(ctx context.Context, seqId int32, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) {
args := I64ListI64ServiceCountArgs{}
if err = args.Read(iprot); err != nil {
iprot.ReadMessageEnd()
x := thrift.NewTApplicationException(thrift.PROTOCOL_ERROR, err.Error())
oprot.WriteMessageBegin("count", thrift.EXCEPTION, seqId)
x.Write(oprot)
oprot.WriteMessageEnd()
oprot.Flush()
return false, err
}
iprot.ReadMessageEnd()
result := I64ListI64ServiceCountResult{}
var retval int32
var err2 error
if retval, err2 = p.handler.Count(ctx, args.Key); err2 != nil {
x := thrift.NewTApplicationException(thrift.INTERNAL_ERROR, "Internal error processing count: " + err2.Error())
oprot.WriteMessageBegin("count", thrift.EXCEPTION, seqId)
x.Write(oprot)
oprot.WriteMessageEnd()
oprot.Flush()
return true, err2
} else {
result.Success = &retval
}
if err2 = oprot.WriteMessageBegin("count", thrift.REPLY, seqId); err2 != nil {
err = err2
}
if err2 = result.Write(oprot); err == nil && err2 != nil {
err = err2
}
if err2 = oprot.WriteMessageEnd(); err == nil && err2 != nil {
err = err2
}
if err2 = oprot.Flush(); err == nil && err2 != nil {
err = err2
}
if err != nil {
return
}
return true, err
}
type i64ListI64ServiceProcessorExisted struct {
handler I64ListI64Service
}
func (p *i64ListI64ServiceProcessorExisted) Process(ctx context.Context, seqId int32, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) {
args := I64ListI64ServiceExistedArgs{}
if err = args.Read(iprot); err != nil {
iprot.ReadMessageEnd()
x := thrift.NewTApplicationException(thrift.PROTOCOL_ERROR, err.Error())
oprot.WriteMessageBegin("existed", thrift.EXCEPTION, seqId)
x.Write(oprot)
oprot.WriteMessageEnd()
oprot.Flush()
return false, err
}
iprot.ReadMessageEnd()
result := I64ListI64ServiceExistedResult{}