Versions in this module Expand all Collapse all v0 v0.1.1 Nov 7, 2020 v0.1.0 Nov 7, 2020 Changes in this version + var GoUnusedProtection__ int + var MasterMetaServiceSetMetaIDResult_Success_DEFAULT bool + var TBSGenericDataServiceBsgBulkLoadResult_Success_DEFAULT bool + var TBSGenericDataServiceBsgRemoveItemResult_Success_DEFAULT bool + var TBSGenericDataServiceGetTotalCountResult_Success_DEFAULT int64 + var TBSGenericDataServiceRemoveAllResult_Success_DEFAULT int64 + var TBigSetGenericData_Children_DEFAULT []*TMetaItem + var TCluserOrdinatorServicePutResult_Success_DEFAULT int32 + var TIBSDataServiceBulkLoadResult_Success_DEFAULT bool + var TIBSDataServiceGetTotalCountResult_Success_DEFAULT int64 + var TIBSDataServiceRemoveAllResult_Success_DEFAULT int64 + var TIBSDataServiceRemoveItemResult_Success_DEFAULT bool + var TMultiPutItemResult__Added_DEFAULT []TItemKey + var TMultiPutItemResult__Replaced_DEFAULT []*TItem + var TStringBigSetInfo_Count_DEFAULT int64 + var TStringBigSetKVServiceBsBulkLoadResult_Success_DEFAULT bool + var TStringBigSetKVServiceBsRemoveItemResult_Success_DEFAULT bool + var TStringBigSetKVServiceGetListKeyFromResult_Success_DEFAULT []TStringKey + var TStringBigSetKVServiceGetListKeyResult_Success_DEFAULT []TStringKey + var TStringBigSetKVServiceGetTotalCountResult_Success_DEFAULT int64 + var TStringBigSetKVServiceRemoveAllResult_Success_DEFAULT int64 + var TStringBigSetKVServiceTotalStringKeyCountResult_Success_DEFAULT int64 + type BSNotificationPool interface + GetJob func(ctx context.Context) (r *SplitJob, err error) + NeedSplit func(ctx context.Context, rootID TContainerKey, splitInfo *TNeedSplitInfo) (err error) + SplitInfoUpdated func(ctx context.Context, rootID TContainerKey) (err error) + type BSNotificationPoolClient struct + func NewBSNotificationPoolClient(c thrift.TClient) *BSNotificationPoolClient + func NewBSNotificationPoolClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *BSNotificationPoolClient + func NewBSNotificationPoolClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *BSNotificationPoolClient + func (p *BSNotificationPoolClient) Client_() thrift.TClient + func (p *BSNotificationPoolClient) GetJob(ctx context.Context) (r *SplitJob, err error) + func (p *BSNotificationPoolClient) NeedSplit(ctx context.Context, rootID TContainerKey, splitInfo *TNeedSplitInfo) (err error) + func (p *BSNotificationPoolClient) SplitInfoUpdated(ctx context.Context, rootID TContainerKey) (err error) + type BSNotificationPoolGetJobArgs struct + func NewBSNotificationPoolGetJobArgs() *BSNotificationPoolGetJobArgs + func (p *BSNotificationPoolGetJobArgs) Read(iprot thrift.TProtocol) error + func (p *BSNotificationPoolGetJobArgs) String() string + func (p *BSNotificationPoolGetJobArgs) Write(oprot thrift.TProtocol) error + type BSNotificationPoolGetJobResult struct + Success *SplitJob + func NewBSNotificationPoolGetJobResult() *BSNotificationPoolGetJobResult + func (p *BSNotificationPoolGetJobResult) GetSuccess() *SplitJob + func (p *BSNotificationPoolGetJobResult) IsSetSuccess() bool + func (p *BSNotificationPoolGetJobResult) Read(iprot thrift.TProtocol) error + func (p *BSNotificationPoolGetJobResult) ReadField0(iprot thrift.TProtocol) error + func (p *BSNotificationPoolGetJobResult) String() string + func (p *BSNotificationPoolGetJobResult) Write(oprot thrift.TProtocol) error + type BSNotificationPoolNeedSplitArgs struct + RootID TContainerKey + SplitInfo *TNeedSplitInfo + func NewBSNotificationPoolNeedSplitArgs() *BSNotificationPoolNeedSplitArgs + func (p *BSNotificationPoolNeedSplitArgs) GetRootID() TContainerKey + func (p *BSNotificationPoolNeedSplitArgs) GetSplitInfo() *TNeedSplitInfo + func (p *BSNotificationPoolNeedSplitArgs) IsSetSplitInfo() bool + func (p *BSNotificationPoolNeedSplitArgs) Read(iprot thrift.TProtocol) error + func (p *BSNotificationPoolNeedSplitArgs) ReadField1(iprot thrift.TProtocol) error + func (p *BSNotificationPoolNeedSplitArgs) ReadField2(iprot thrift.TProtocol) error + func (p *BSNotificationPoolNeedSplitArgs) String() string + func (p *BSNotificationPoolNeedSplitArgs) Write(oprot thrift.TProtocol) error + type BSNotificationPoolNeedSplitResult struct + func NewBSNotificationPoolNeedSplitResult() *BSNotificationPoolNeedSplitResult + func (p *BSNotificationPoolNeedSplitResult) Read(iprot thrift.TProtocol) error + func (p *BSNotificationPoolNeedSplitResult) String() string + func (p *BSNotificationPoolNeedSplitResult) Write(oprot thrift.TProtocol) error + type BSNotificationPoolProcessor struct + func NewBSNotificationPoolProcessor(handler BSNotificationPool) *BSNotificationPoolProcessor + func (p *BSNotificationPoolProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction) + func (p *BSNotificationPoolProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool) + func (p *BSNotificationPoolProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) + func (p *BSNotificationPoolProcessor) ProcessorMap() map[string]thrift.TProcessorFunction + type BSNotificationPoolSplitInfoUpdatedArgs struct + RootID TContainerKey + func NewBSNotificationPoolSplitInfoUpdatedArgs() *BSNotificationPoolSplitInfoUpdatedArgs + func (p *BSNotificationPoolSplitInfoUpdatedArgs) GetRootID() TContainerKey + func (p *BSNotificationPoolSplitInfoUpdatedArgs) Read(iprot thrift.TProtocol) error + func (p *BSNotificationPoolSplitInfoUpdatedArgs) ReadField1(iprot thrift.TProtocol) error + func (p *BSNotificationPoolSplitInfoUpdatedArgs) String() string + func (p *BSNotificationPoolSplitInfoUpdatedArgs) Write(oprot thrift.TProtocol) error + type BSNotificationPoolSplitInfoUpdatedResult struct + func NewBSNotificationPoolSplitInfoUpdatedResult() *BSNotificationPoolSplitInfoUpdatedResult + func (p *BSNotificationPoolSplitInfoUpdatedResult) Read(iprot thrift.TProtocol) error + func (p *BSNotificationPoolSplitInfoUpdatedResult) String() string + func (p *BSNotificationPoolSplitInfoUpdatedResult) Write(oprot thrift.TProtocol) error + type MasterMetaService interface + GetMetaID func(ctx context.Context, key TKey) (r TMetaKey, err error) + SetMetaID func(ctx context.Context, key TKey, metaID TMetaKey) (r bool, err error) + type MasterMetaServiceClient struct + func NewMasterMetaServiceClient(c thrift.TClient) *MasterMetaServiceClient + func NewMasterMetaServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *MasterMetaServiceClient + func NewMasterMetaServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *MasterMetaServiceClient + func (p *MasterMetaServiceClient) Client_() thrift.TClient + func (p *MasterMetaServiceClient) GetMetaID(ctx context.Context, key TKey) (r TMetaKey, err error) + func (p *MasterMetaServiceClient) SetMetaID(ctx context.Context, key TKey, metaID TMetaKey) (r bool, err error) + type MasterMetaServiceGetMetaIDArgs struct + Key TKey + func NewMasterMetaServiceGetMetaIDArgs() *MasterMetaServiceGetMetaIDArgs + func (p *MasterMetaServiceGetMetaIDArgs) GetKey() TKey + func (p *MasterMetaServiceGetMetaIDArgs) Read(iprot thrift.TProtocol) error + func (p *MasterMetaServiceGetMetaIDArgs) ReadField1(iprot thrift.TProtocol) error + func (p *MasterMetaServiceGetMetaIDArgs) String() string + func (p *MasterMetaServiceGetMetaIDArgs) Write(oprot thrift.TProtocol) error + type MasterMetaServiceGetMetaIDResult struct + Success *TMetaKey + func NewMasterMetaServiceGetMetaIDResult() *MasterMetaServiceGetMetaIDResult + func (p *MasterMetaServiceGetMetaIDResult) GetSuccess() TMetaKey + func (p *MasterMetaServiceGetMetaIDResult) IsSetSuccess() bool + func (p *MasterMetaServiceGetMetaIDResult) Read(iprot thrift.TProtocol) error + func (p *MasterMetaServiceGetMetaIDResult) ReadField0(iprot thrift.TProtocol) error + func (p *MasterMetaServiceGetMetaIDResult) String() string + func (p *MasterMetaServiceGetMetaIDResult) Write(oprot thrift.TProtocol) error + type MasterMetaServiceProcessor struct + func NewMasterMetaServiceProcessor(handler MasterMetaService) *MasterMetaServiceProcessor + func (p *MasterMetaServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction) + func (p *MasterMetaServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool) + func (p *MasterMetaServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) + func (p *MasterMetaServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction + type MasterMetaServiceSetMetaIDArgs struct + Key TKey + MetaID TMetaKey + func NewMasterMetaServiceSetMetaIDArgs() *MasterMetaServiceSetMetaIDArgs + func (p *MasterMetaServiceSetMetaIDArgs) GetKey() TKey + func (p *MasterMetaServiceSetMetaIDArgs) GetMetaID() TMetaKey + func (p *MasterMetaServiceSetMetaIDArgs) Read(iprot thrift.TProtocol) error + func (p *MasterMetaServiceSetMetaIDArgs) ReadField1(iprot thrift.TProtocol) error + func (p *MasterMetaServiceSetMetaIDArgs) ReadField2(iprot thrift.TProtocol) error + func (p *MasterMetaServiceSetMetaIDArgs) String() string + func (p *MasterMetaServiceSetMetaIDArgs) Write(oprot thrift.TProtocol) error + type MasterMetaServiceSetMetaIDResult struct + Success *bool + func NewMasterMetaServiceSetMetaIDResult() *MasterMetaServiceSetMetaIDResult + func (p *MasterMetaServiceSetMetaIDResult) GetSuccess() bool + func (p *MasterMetaServiceSetMetaIDResult) IsSetSuccess() bool + func (p *MasterMetaServiceSetMetaIDResult) Read(iprot thrift.TProtocol) error + func (p *MasterMetaServiceSetMetaIDResult) ReadField0(iprot thrift.TProtocol) error + func (p *MasterMetaServiceSetMetaIDResult) String() string + func (p *MasterMetaServiceSetMetaIDResult) Write(oprot thrift.TProtocol) error + type SplitJob struct + RootID TContainerKey + SplitInfo *TNeedSplitInfo + var BSNotificationPoolGetJobResult_Success_DEFAULT *SplitJob + func NewSplitJob() *SplitJob + func (p *SplitJob) GetRootID() TContainerKey + func (p *SplitJob) GetSplitInfo() *TNeedSplitInfo + func (p *SplitJob) IsSetSplitInfo() bool + func (p *SplitJob) Read(iprot thrift.TProtocol) error + func (p *SplitJob) ReadField1(iprot thrift.TProtocol) error + func (p *SplitJob) ReadField2(iprot thrift.TProtocol) error + func (p *SplitJob) String() string + func (p *SplitJob) Write(oprot thrift.TProtocol) error + type TBSBigValueService interface + type TBSBigValueServiceClient struct + func NewTBSBigValueServiceClient(c thrift.TClient) *TBSBigValueServiceClient + func NewTBSBigValueServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *TBSBigValueServiceClient + func NewTBSBigValueServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *TBSBigValueServiceClient + func (p *TBSBigValueServiceClient) Client_() thrift.TClient + type TBSBigValueServiceProcessor struct + func NewTBSBigValueServiceProcessor(handler TBSBigValueService) *TBSBigValueServiceProcessor + func (p *TBSBigValueServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction) + func (p *TBSBigValueServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool) + func (p *TBSBigValueServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) + func (p *TBSBigValueServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction + type TBSGenericDataService interface + BsgBulkLoad func(ctx context.Context, rootID TContainerKey, setData *TItemSet) (r bool, err error) + BsgExisted func(ctx context.Context, rootID TContainerKey, itemKey TItemKey) (r *TExistedResult_, err error) + BsgGetItem func(ctx context.Context, rootID TContainerKey, itemKey TItemKey) (r *TItemResult_, err error) + BsgGetSlice func(ctx context.Context, rootID TContainerKey, fromIdx int32, count int32) (r *TItemSetResult_, err error) + BsgGetSliceFromItem func(ctx context.Context, rootID TContainerKey, fromKey TItemKey, count int32) (r *TItemSetResult_, err error) + BsgGetSliceFromItemR func(ctx context.Context, rootID TContainerKey, fromKey TItemKey, count int32) (r *TItemSetResult_, err error) + BsgGetSliceR func(ctx context.Context, rootID TContainerKey, fromIdx int32, count int32) (r *TItemSetResult_, err error) + BsgMultiPut func(ctx context.Context, rootID TContainerKey, setData *TItemSet, ...) (r *TMultiPutItemResult_, err error) + BsgPutItem func(ctx context.Context, rootID TContainerKey, item *TItem) (r *TPutItemResult_, err error) + BsgRangeQuery func(ctx context.Context, rootID TContainerKey, startKey TItemKey, endKey TItemKey) (r *TItemSetResult_, err error) + BsgRemoveItem func(ctx context.Context, key TMetaKey, itemKey TItemKey) (r bool, err error) + GetSetGenData func(ctx context.Context, metaID TMetaKey) (r *TBigSetGenericData, err error) + GetTotalCount func(ctx context.Context, rootID TContainerKey) (r int64, err error) + PutSetGenData func(ctx context.Context, metaID TMetaKey, metadata *TBigSetGenericData) (err error) + RemoveAll func(ctx context.Context, rootID TContainerKey) (r int64, err error) + SplitBigSet func(ctx context.Context, rootID TContainerKey, brotherRootID TContainerKey, ...) (r *TSplitBigSetResult_, err error) + type TBSGenericDataServiceBsgBulkLoadArgs struct + RootID TContainerKey + SetData *TItemSet + func NewTBSGenericDataServiceBsgBulkLoadArgs() *TBSGenericDataServiceBsgBulkLoadArgs + func (p *TBSGenericDataServiceBsgBulkLoadArgs) GetRootID() TContainerKey + func (p *TBSGenericDataServiceBsgBulkLoadArgs) GetSetData() *TItemSet + func (p *TBSGenericDataServiceBsgBulkLoadArgs) IsSetSetData() bool + func (p *TBSGenericDataServiceBsgBulkLoadArgs) Read(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgBulkLoadArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgBulkLoadArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgBulkLoadArgs) String() string + func (p *TBSGenericDataServiceBsgBulkLoadArgs) Write(oprot thrift.TProtocol) error + type TBSGenericDataServiceBsgBulkLoadResult struct + Success *bool + func NewTBSGenericDataServiceBsgBulkLoadResult() *TBSGenericDataServiceBsgBulkLoadResult + func (p *TBSGenericDataServiceBsgBulkLoadResult) GetSuccess() bool + func (p *TBSGenericDataServiceBsgBulkLoadResult) IsSetSuccess() bool + func (p *TBSGenericDataServiceBsgBulkLoadResult) Read(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgBulkLoadResult) ReadField0(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgBulkLoadResult) String() string + func (p *TBSGenericDataServiceBsgBulkLoadResult) Write(oprot thrift.TProtocol) error + type TBSGenericDataServiceBsgExistedArgs struct + ItemKey TItemKey + RootID TContainerKey + func NewTBSGenericDataServiceBsgExistedArgs() *TBSGenericDataServiceBsgExistedArgs + func (p *TBSGenericDataServiceBsgExistedArgs) GetItemKey() TItemKey + func (p *TBSGenericDataServiceBsgExistedArgs) GetRootID() TContainerKey + func (p *TBSGenericDataServiceBsgExistedArgs) Read(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgExistedArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgExistedArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgExistedArgs) String() string + func (p *TBSGenericDataServiceBsgExistedArgs) Write(oprot thrift.TProtocol) error + type TBSGenericDataServiceBsgExistedResult struct + Success *TExistedResult_ + func NewTBSGenericDataServiceBsgExistedResult() *TBSGenericDataServiceBsgExistedResult + func (p *TBSGenericDataServiceBsgExistedResult) GetSuccess() *TExistedResult_ + func (p *TBSGenericDataServiceBsgExistedResult) IsSetSuccess() bool + func (p *TBSGenericDataServiceBsgExistedResult) Read(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgExistedResult) ReadField0(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgExistedResult) String() string + func (p *TBSGenericDataServiceBsgExistedResult) Write(oprot thrift.TProtocol) error + type TBSGenericDataServiceBsgGetItemArgs struct + ItemKey TItemKey + RootID TContainerKey + func NewTBSGenericDataServiceBsgGetItemArgs() *TBSGenericDataServiceBsgGetItemArgs + func (p *TBSGenericDataServiceBsgGetItemArgs) GetItemKey() TItemKey + func (p *TBSGenericDataServiceBsgGetItemArgs) GetRootID() TContainerKey + func (p *TBSGenericDataServiceBsgGetItemArgs) Read(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgGetItemArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgGetItemArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgGetItemArgs) String() string + func (p *TBSGenericDataServiceBsgGetItemArgs) Write(oprot thrift.TProtocol) error + type TBSGenericDataServiceBsgGetItemResult struct + Success *TItemResult_ + func NewTBSGenericDataServiceBsgGetItemResult() *TBSGenericDataServiceBsgGetItemResult + func (p *TBSGenericDataServiceBsgGetItemResult) GetSuccess() *TItemResult_ + func (p *TBSGenericDataServiceBsgGetItemResult) IsSetSuccess() bool + func (p *TBSGenericDataServiceBsgGetItemResult) Read(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgGetItemResult) ReadField0(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgGetItemResult) String() string + func (p *TBSGenericDataServiceBsgGetItemResult) Write(oprot thrift.TProtocol) error + type TBSGenericDataServiceBsgGetSliceArgs struct + Count int32 + FromIdx int32 + RootID TContainerKey + func NewTBSGenericDataServiceBsgGetSliceArgs() *TBSGenericDataServiceBsgGetSliceArgs + func (p *TBSGenericDataServiceBsgGetSliceArgs) GetCount() int32 + func (p *TBSGenericDataServiceBsgGetSliceArgs) GetFromIdx() int32 + func (p *TBSGenericDataServiceBsgGetSliceArgs) GetRootID() TContainerKey + func (p *TBSGenericDataServiceBsgGetSliceArgs) Read(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgGetSliceArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgGetSliceArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgGetSliceArgs) ReadField3(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgGetSliceArgs) String() string + func (p *TBSGenericDataServiceBsgGetSliceArgs) Write(oprot thrift.TProtocol) error + type TBSGenericDataServiceBsgGetSliceFromItemArgs struct + Count int32 + FromKey TItemKey + RootID TContainerKey + func NewTBSGenericDataServiceBsgGetSliceFromItemArgs() *TBSGenericDataServiceBsgGetSliceFromItemArgs + func (p *TBSGenericDataServiceBsgGetSliceFromItemArgs) GetCount() int32 + func (p *TBSGenericDataServiceBsgGetSliceFromItemArgs) GetFromKey() TItemKey + func (p *TBSGenericDataServiceBsgGetSliceFromItemArgs) GetRootID() TContainerKey + func (p *TBSGenericDataServiceBsgGetSliceFromItemArgs) Read(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgGetSliceFromItemArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgGetSliceFromItemArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgGetSliceFromItemArgs) ReadField3(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgGetSliceFromItemArgs) String() string + func (p *TBSGenericDataServiceBsgGetSliceFromItemArgs) Write(oprot thrift.TProtocol) error + type TBSGenericDataServiceBsgGetSliceFromItemRArgs struct + Count int32 + FromKey TItemKey + RootID TContainerKey + func NewTBSGenericDataServiceBsgGetSliceFromItemRArgs() *TBSGenericDataServiceBsgGetSliceFromItemRArgs + func (p *TBSGenericDataServiceBsgGetSliceFromItemRArgs) GetCount() int32 + func (p *TBSGenericDataServiceBsgGetSliceFromItemRArgs) GetFromKey() TItemKey + func (p *TBSGenericDataServiceBsgGetSliceFromItemRArgs) GetRootID() TContainerKey + func (p *TBSGenericDataServiceBsgGetSliceFromItemRArgs) Read(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgGetSliceFromItemRArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgGetSliceFromItemRArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgGetSliceFromItemRArgs) ReadField3(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgGetSliceFromItemRArgs) String() string + func (p *TBSGenericDataServiceBsgGetSliceFromItemRArgs) Write(oprot thrift.TProtocol) error + type TBSGenericDataServiceBsgGetSliceFromItemRResult struct + Success *TItemSetResult_ + func NewTBSGenericDataServiceBsgGetSliceFromItemRResult() *TBSGenericDataServiceBsgGetSliceFromItemRResult + func (p *TBSGenericDataServiceBsgGetSliceFromItemRResult) GetSuccess() *TItemSetResult_ + func (p *TBSGenericDataServiceBsgGetSliceFromItemRResult) IsSetSuccess() bool + func (p *TBSGenericDataServiceBsgGetSliceFromItemRResult) Read(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgGetSliceFromItemRResult) ReadField0(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgGetSliceFromItemRResult) String() string + func (p *TBSGenericDataServiceBsgGetSliceFromItemRResult) Write(oprot thrift.TProtocol) error + type TBSGenericDataServiceBsgGetSliceFromItemResult struct + Success *TItemSetResult_ + func NewTBSGenericDataServiceBsgGetSliceFromItemResult() *TBSGenericDataServiceBsgGetSliceFromItemResult + func (p *TBSGenericDataServiceBsgGetSliceFromItemResult) GetSuccess() *TItemSetResult_ + func (p *TBSGenericDataServiceBsgGetSliceFromItemResult) IsSetSuccess() bool + func (p *TBSGenericDataServiceBsgGetSliceFromItemResult) Read(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgGetSliceFromItemResult) ReadField0(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgGetSliceFromItemResult) String() string + func (p *TBSGenericDataServiceBsgGetSliceFromItemResult) Write(oprot thrift.TProtocol) error + type TBSGenericDataServiceBsgGetSliceRArgs struct + Count int32 + FromIdx int32 + RootID TContainerKey + func NewTBSGenericDataServiceBsgGetSliceRArgs() *TBSGenericDataServiceBsgGetSliceRArgs + func (p *TBSGenericDataServiceBsgGetSliceRArgs) GetCount() int32 + func (p *TBSGenericDataServiceBsgGetSliceRArgs) GetFromIdx() int32 + func (p *TBSGenericDataServiceBsgGetSliceRArgs) GetRootID() TContainerKey + func (p *TBSGenericDataServiceBsgGetSliceRArgs) Read(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgGetSliceRArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgGetSliceRArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgGetSliceRArgs) ReadField3(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgGetSliceRArgs) String() string + func (p *TBSGenericDataServiceBsgGetSliceRArgs) Write(oprot thrift.TProtocol) error + type TBSGenericDataServiceBsgGetSliceRResult struct + Success *TItemSetResult_ + func NewTBSGenericDataServiceBsgGetSliceRResult() *TBSGenericDataServiceBsgGetSliceRResult + func (p *TBSGenericDataServiceBsgGetSliceRResult) GetSuccess() *TItemSetResult_ + func (p *TBSGenericDataServiceBsgGetSliceRResult) IsSetSuccess() bool + func (p *TBSGenericDataServiceBsgGetSliceRResult) Read(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgGetSliceRResult) ReadField0(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgGetSliceRResult) String() string + func (p *TBSGenericDataServiceBsgGetSliceRResult) Write(oprot thrift.TProtocol) error + type TBSGenericDataServiceBsgGetSliceResult struct + Success *TItemSetResult_ + func NewTBSGenericDataServiceBsgGetSliceResult() *TBSGenericDataServiceBsgGetSliceResult + func (p *TBSGenericDataServiceBsgGetSliceResult) GetSuccess() *TItemSetResult_ + func (p *TBSGenericDataServiceBsgGetSliceResult) IsSetSuccess() bool + func (p *TBSGenericDataServiceBsgGetSliceResult) Read(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgGetSliceResult) ReadField0(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgGetSliceResult) String() string + func (p *TBSGenericDataServiceBsgGetSliceResult) Write(oprot thrift.TProtocol) error + type TBSGenericDataServiceBsgMultiPutArgs struct + GetAddedItems bool + GetReplacedItems bool + RootID TContainerKey + SetData *TItemSet + func NewTBSGenericDataServiceBsgMultiPutArgs() *TBSGenericDataServiceBsgMultiPutArgs + func (p *TBSGenericDataServiceBsgMultiPutArgs) GetGetAddedItems() bool + func (p *TBSGenericDataServiceBsgMultiPutArgs) GetGetReplacedItems() bool + func (p *TBSGenericDataServiceBsgMultiPutArgs) GetRootID() TContainerKey + func (p *TBSGenericDataServiceBsgMultiPutArgs) GetSetData() *TItemSet + func (p *TBSGenericDataServiceBsgMultiPutArgs) IsSetSetData() bool + func (p *TBSGenericDataServiceBsgMultiPutArgs) Read(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgMultiPutArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgMultiPutArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgMultiPutArgs) ReadField3(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgMultiPutArgs) ReadField4(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgMultiPutArgs) String() string + func (p *TBSGenericDataServiceBsgMultiPutArgs) Write(oprot thrift.TProtocol) error + type TBSGenericDataServiceBsgMultiPutResult struct + Success *TMultiPutItemResult_ + func NewTBSGenericDataServiceBsgMultiPutResult() *TBSGenericDataServiceBsgMultiPutResult + func (p *TBSGenericDataServiceBsgMultiPutResult) GetSuccess() *TMultiPutItemResult_ + func (p *TBSGenericDataServiceBsgMultiPutResult) IsSetSuccess() bool + func (p *TBSGenericDataServiceBsgMultiPutResult) Read(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgMultiPutResult) ReadField0(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgMultiPutResult) String() string + func (p *TBSGenericDataServiceBsgMultiPutResult) Write(oprot thrift.TProtocol) error + type TBSGenericDataServiceBsgPutItemArgs struct + Item *TItem + RootID TContainerKey + func NewTBSGenericDataServiceBsgPutItemArgs() *TBSGenericDataServiceBsgPutItemArgs + func (p *TBSGenericDataServiceBsgPutItemArgs) GetItem() *TItem + func (p *TBSGenericDataServiceBsgPutItemArgs) GetRootID() TContainerKey + func (p *TBSGenericDataServiceBsgPutItemArgs) IsSetItem() bool + func (p *TBSGenericDataServiceBsgPutItemArgs) Read(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgPutItemArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgPutItemArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgPutItemArgs) String() string + func (p *TBSGenericDataServiceBsgPutItemArgs) Write(oprot thrift.TProtocol) error + type TBSGenericDataServiceBsgPutItemResult struct + Success *TPutItemResult_ + func NewTBSGenericDataServiceBsgPutItemResult() *TBSGenericDataServiceBsgPutItemResult + func (p *TBSGenericDataServiceBsgPutItemResult) GetSuccess() *TPutItemResult_ + func (p *TBSGenericDataServiceBsgPutItemResult) IsSetSuccess() bool + func (p *TBSGenericDataServiceBsgPutItemResult) Read(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgPutItemResult) ReadField0(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgPutItemResult) String() string + func (p *TBSGenericDataServiceBsgPutItemResult) Write(oprot thrift.TProtocol) error + type TBSGenericDataServiceBsgRangeQueryArgs struct + EndKey TItemKey + RootID TContainerKey + StartKey TItemKey + func NewTBSGenericDataServiceBsgRangeQueryArgs() *TBSGenericDataServiceBsgRangeQueryArgs + func (p *TBSGenericDataServiceBsgRangeQueryArgs) GetEndKey() TItemKey + func (p *TBSGenericDataServiceBsgRangeQueryArgs) GetRootID() TContainerKey + func (p *TBSGenericDataServiceBsgRangeQueryArgs) GetStartKey() TItemKey + func (p *TBSGenericDataServiceBsgRangeQueryArgs) Read(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgRangeQueryArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgRangeQueryArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgRangeQueryArgs) ReadField3(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgRangeQueryArgs) String() string + func (p *TBSGenericDataServiceBsgRangeQueryArgs) Write(oprot thrift.TProtocol) error + type TBSGenericDataServiceBsgRangeQueryResult struct + Success *TItemSetResult_ + func NewTBSGenericDataServiceBsgRangeQueryResult() *TBSGenericDataServiceBsgRangeQueryResult + func (p *TBSGenericDataServiceBsgRangeQueryResult) GetSuccess() *TItemSetResult_ + func (p *TBSGenericDataServiceBsgRangeQueryResult) IsSetSuccess() bool + func (p *TBSGenericDataServiceBsgRangeQueryResult) Read(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgRangeQueryResult) ReadField0(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgRangeQueryResult) String() string + func (p *TBSGenericDataServiceBsgRangeQueryResult) Write(oprot thrift.TProtocol) error + type TBSGenericDataServiceBsgRemoveItemArgs struct + ItemKey TItemKey + Key TMetaKey + func NewTBSGenericDataServiceBsgRemoveItemArgs() *TBSGenericDataServiceBsgRemoveItemArgs + func (p *TBSGenericDataServiceBsgRemoveItemArgs) GetItemKey() TItemKey + func (p *TBSGenericDataServiceBsgRemoveItemArgs) GetKey() TMetaKey + func (p *TBSGenericDataServiceBsgRemoveItemArgs) Read(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgRemoveItemArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgRemoveItemArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgRemoveItemArgs) String() string + func (p *TBSGenericDataServiceBsgRemoveItemArgs) Write(oprot thrift.TProtocol) error + type TBSGenericDataServiceBsgRemoveItemResult struct + Success *bool + func NewTBSGenericDataServiceBsgRemoveItemResult() *TBSGenericDataServiceBsgRemoveItemResult + func (p *TBSGenericDataServiceBsgRemoveItemResult) GetSuccess() bool + func (p *TBSGenericDataServiceBsgRemoveItemResult) IsSetSuccess() bool + func (p *TBSGenericDataServiceBsgRemoveItemResult) Read(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgRemoveItemResult) ReadField0(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceBsgRemoveItemResult) String() string + func (p *TBSGenericDataServiceBsgRemoveItemResult) Write(oprot thrift.TProtocol) error + type TBSGenericDataServiceClient struct + func NewTBSGenericDataServiceClient(c thrift.TClient) *TBSGenericDataServiceClient + func NewTBSGenericDataServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *TBSGenericDataServiceClient + func NewTBSGenericDataServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *TBSGenericDataServiceClient + func (p *TBSGenericDataServiceClient) BsgBulkLoad(ctx context.Context, rootID TContainerKey, setData *TItemSet) (r bool, err error) + func (p *TBSGenericDataServiceClient) BsgExisted(ctx context.Context, rootID TContainerKey, itemKey TItemKey) (r *TExistedResult_, err error) + func (p *TBSGenericDataServiceClient) BsgGetItem(ctx context.Context, rootID TContainerKey, itemKey TItemKey) (r *TItemResult_, err error) + func (p *TBSGenericDataServiceClient) BsgGetSlice(ctx context.Context, rootID TContainerKey, fromIdx int32, count int32) (r *TItemSetResult_, err error) + func (p *TBSGenericDataServiceClient) BsgGetSliceFromItem(ctx context.Context, rootID TContainerKey, fromKey TItemKey, count int32) (r *TItemSetResult_, err error) + func (p *TBSGenericDataServiceClient) BsgGetSliceFromItemR(ctx context.Context, rootID TContainerKey, fromKey TItemKey, count int32) (r *TItemSetResult_, err error) + func (p *TBSGenericDataServiceClient) BsgGetSliceR(ctx context.Context, rootID TContainerKey, fromIdx int32, count int32) (r *TItemSetResult_, err error) + func (p *TBSGenericDataServiceClient) BsgMultiPut(ctx context.Context, rootID TContainerKey, setData *TItemSet, ...) (r *TMultiPutItemResult_, err error) + func (p *TBSGenericDataServiceClient) BsgPutItem(ctx context.Context, rootID TContainerKey, item *TItem) (r *TPutItemResult_, err error) + func (p *TBSGenericDataServiceClient) BsgRangeQuery(ctx context.Context, rootID TContainerKey, startKey TItemKey, endKey TItemKey) (r *TItemSetResult_, err error) + func (p *TBSGenericDataServiceClient) BsgRemoveItem(ctx context.Context, key TMetaKey, itemKey TItemKey) (r bool, err error) + func (p *TBSGenericDataServiceClient) Client_() thrift.TClient + func (p *TBSGenericDataServiceClient) GetSetGenData(ctx context.Context, metaID TMetaKey) (r *TBigSetGenericData, err error) + func (p *TBSGenericDataServiceClient) GetTotalCount(ctx context.Context, rootID TContainerKey) (r int64, err error) + func (p *TBSGenericDataServiceClient) PutSetGenData(ctx context.Context, metaID TMetaKey, metadata *TBigSetGenericData) (err error) + func (p *TBSGenericDataServiceClient) RemoveAll(ctx context.Context, rootID TContainerKey) (r int64, err error) + func (p *TBSGenericDataServiceClient) SplitBigSet(ctx context.Context, rootID TContainerKey, brotherRootID TContainerKey, ...) (r *TSplitBigSetResult_, err error) + type TBSGenericDataServiceGetSetGenDataArgs struct + MetaID TMetaKey + func NewTBSGenericDataServiceGetSetGenDataArgs() *TBSGenericDataServiceGetSetGenDataArgs + func (p *TBSGenericDataServiceGetSetGenDataArgs) GetMetaID() TMetaKey + func (p *TBSGenericDataServiceGetSetGenDataArgs) Read(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceGetSetGenDataArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceGetSetGenDataArgs) String() string + func (p *TBSGenericDataServiceGetSetGenDataArgs) Write(oprot thrift.TProtocol) error + type TBSGenericDataServiceGetSetGenDataResult struct + Success *TBigSetGenericData + func NewTBSGenericDataServiceGetSetGenDataResult() *TBSGenericDataServiceGetSetGenDataResult + func (p *TBSGenericDataServiceGetSetGenDataResult) GetSuccess() *TBigSetGenericData + func (p *TBSGenericDataServiceGetSetGenDataResult) IsSetSuccess() bool + func (p *TBSGenericDataServiceGetSetGenDataResult) Read(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceGetSetGenDataResult) ReadField0(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceGetSetGenDataResult) String() string + func (p *TBSGenericDataServiceGetSetGenDataResult) Write(oprot thrift.TProtocol) error + type TBSGenericDataServiceGetTotalCountArgs struct + RootID TContainerKey + func NewTBSGenericDataServiceGetTotalCountArgs() *TBSGenericDataServiceGetTotalCountArgs + func (p *TBSGenericDataServiceGetTotalCountArgs) GetRootID() TContainerKey + func (p *TBSGenericDataServiceGetTotalCountArgs) Read(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceGetTotalCountArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceGetTotalCountArgs) String() string + func (p *TBSGenericDataServiceGetTotalCountArgs) Write(oprot thrift.TProtocol) error + type TBSGenericDataServiceGetTotalCountResult struct + Success *int64 + func NewTBSGenericDataServiceGetTotalCountResult() *TBSGenericDataServiceGetTotalCountResult + func (p *TBSGenericDataServiceGetTotalCountResult) GetSuccess() int64 + func (p *TBSGenericDataServiceGetTotalCountResult) IsSetSuccess() bool + func (p *TBSGenericDataServiceGetTotalCountResult) Read(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceGetTotalCountResult) ReadField0(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceGetTotalCountResult) String() string + func (p *TBSGenericDataServiceGetTotalCountResult) Write(oprot thrift.TProtocol) error + type TBSGenericDataServiceProcessor struct + func NewTBSGenericDataServiceProcessor(handler TBSGenericDataService) *TBSGenericDataServiceProcessor + func (p *TBSGenericDataServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction) + func (p *TBSGenericDataServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool) + func (p *TBSGenericDataServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) + func (p *TBSGenericDataServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction + type TBSGenericDataServicePutSetGenDataArgs struct + MetaID TMetaKey + Metadata *TBigSetGenericData + func NewTBSGenericDataServicePutSetGenDataArgs() *TBSGenericDataServicePutSetGenDataArgs + func (p *TBSGenericDataServicePutSetGenDataArgs) GetMetaID() TMetaKey + func (p *TBSGenericDataServicePutSetGenDataArgs) GetMetadata() *TBigSetGenericData + func (p *TBSGenericDataServicePutSetGenDataArgs) IsSetMetadata() bool + func (p *TBSGenericDataServicePutSetGenDataArgs) Read(iprot thrift.TProtocol) error + func (p *TBSGenericDataServicePutSetGenDataArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TBSGenericDataServicePutSetGenDataArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TBSGenericDataServicePutSetGenDataArgs) String() string + func (p *TBSGenericDataServicePutSetGenDataArgs) Write(oprot thrift.TProtocol) error + type TBSGenericDataServicePutSetGenDataResult struct + func NewTBSGenericDataServicePutSetGenDataResult() *TBSGenericDataServicePutSetGenDataResult + func (p *TBSGenericDataServicePutSetGenDataResult) Read(iprot thrift.TProtocol) error + func (p *TBSGenericDataServicePutSetGenDataResult) String() string + func (p *TBSGenericDataServicePutSetGenDataResult) Write(oprot thrift.TProtocol) error + type TBSGenericDataServiceRemoveAllArgs struct + RootID TContainerKey + func NewTBSGenericDataServiceRemoveAllArgs() *TBSGenericDataServiceRemoveAllArgs + func (p *TBSGenericDataServiceRemoveAllArgs) GetRootID() TContainerKey + func (p *TBSGenericDataServiceRemoveAllArgs) Read(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceRemoveAllArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceRemoveAllArgs) String() string + func (p *TBSGenericDataServiceRemoveAllArgs) Write(oprot thrift.TProtocol) error + type TBSGenericDataServiceRemoveAllResult struct + Success *int64 + func NewTBSGenericDataServiceRemoveAllResult() *TBSGenericDataServiceRemoveAllResult + func (p *TBSGenericDataServiceRemoveAllResult) GetSuccess() int64 + func (p *TBSGenericDataServiceRemoveAllResult) IsSetSuccess() bool + func (p *TBSGenericDataServiceRemoveAllResult) Read(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceRemoveAllResult) ReadField0(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceRemoveAllResult) String() string + func (p *TBSGenericDataServiceRemoveAllResult) Write(oprot thrift.TProtocol) error + type TBSGenericDataServiceSplitBigSetArgs struct + BrotherRootID TContainerKey + CurrentSize int64 + RootID TContainerKey + func NewTBSGenericDataServiceSplitBigSetArgs() *TBSGenericDataServiceSplitBigSetArgs + func (p *TBSGenericDataServiceSplitBigSetArgs) GetBrotherRootID() TContainerKey + func (p *TBSGenericDataServiceSplitBigSetArgs) GetCurrentSize() int64 + func (p *TBSGenericDataServiceSplitBigSetArgs) GetRootID() TContainerKey + func (p *TBSGenericDataServiceSplitBigSetArgs) Read(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceSplitBigSetArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceSplitBigSetArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceSplitBigSetArgs) ReadField3(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceSplitBigSetArgs) String() string + func (p *TBSGenericDataServiceSplitBigSetArgs) Write(oprot thrift.TProtocol) error + type TBSGenericDataServiceSplitBigSetResult struct + Success *TSplitBigSetResult_ + func NewTBSGenericDataServiceSplitBigSetResult() *TBSGenericDataServiceSplitBigSetResult + func (p *TBSGenericDataServiceSplitBigSetResult) GetSuccess() *TSplitBigSetResult_ + func (p *TBSGenericDataServiceSplitBigSetResult) IsSetSuccess() bool + func (p *TBSGenericDataServiceSplitBigSetResult) Read(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceSplitBigSetResult) ReadField0(iprot thrift.TProtocol) error + func (p *TBSGenericDataServiceSplitBigSetResult) String() string + func (p *TBSGenericDataServiceSplitBigSetResult) Write(oprot thrift.TProtocol) error + type TBigSetGenericData struct + Children []*TMetaItem + Level TLevelType + ParentID TContainerKey + Smallset *TSmallSet + Splitinfo *TNeedSplitInfo + var TBSGenericDataServiceGetSetGenDataResult_Success_DEFAULT *TBigSetGenericData + var TBSGenericDataServicePutSetGenDataArgs_Metadata_DEFAULT *TBigSetGenericData + func NewTBigSetGenericData() *TBigSetGenericData + func (p *TBigSetGenericData) GetChildren() []*TMetaItem + func (p *TBigSetGenericData) GetLevel() TLevelType + func (p *TBigSetGenericData) GetParentID() TContainerKey + func (p *TBigSetGenericData) GetSmallset() *TSmallSet + func (p *TBigSetGenericData) GetSplitinfo() *TNeedSplitInfo + func (p *TBigSetGenericData) IsSetChildren() bool + func (p *TBigSetGenericData) IsSetSmallset() bool + func (p *TBigSetGenericData) IsSetSplitinfo() bool + func (p *TBigSetGenericData) Read(iprot thrift.TProtocol) error + func (p *TBigSetGenericData) ReadField1(iprot thrift.TProtocol) error + func (p *TBigSetGenericData) ReadField2(iprot thrift.TProtocol) error + func (p *TBigSetGenericData) ReadField3(iprot thrift.TProtocol) error + func (p *TBigSetGenericData) ReadField4(iprot thrift.TProtocol) error + func (p *TBigSetGenericData) ReadField5(iprot thrift.TProtocol) error + func (p *TBigSetGenericData) String() string + func (p *TBigSetGenericData) Write(oprot thrift.TProtocol) error + type TBigSetInfoResult_ struct + Error TErrorCode + Info *TStringBigSetInfo + var TStringBigSetKVServiceAssignBigSetNameResult_Success_DEFAULT *TBigSetInfoResult_ + var TStringBigSetKVServiceCreateStringBigSetResult_Success_DEFAULT *TBigSetInfoResult_ + var TStringBigSetKVServiceGetBigSetInfoByNameResult_Success_DEFAULT *TBigSetInfoResult_ + func NewTBigSetInfoResult_() *TBigSetInfoResult_ + func (p *TBigSetInfoResult_) GetError() TErrorCode + func (p *TBigSetInfoResult_) GetInfo() *TStringBigSetInfo + func (p *TBigSetInfoResult_) IsSetInfo() bool + func (p *TBigSetInfoResult_) Read(iprot thrift.TProtocol) error + func (p *TBigSetInfoResult_) ReadField1(iprot thrift.TProtocol) error + func (p *TBigSetInfoResult_) ReadField2(iprot thrift.TProtocol) error + func (p *TBigSetInfoResult_) String() string + func (p *TBigSetInfoResult_) Write(oprot thrift.TProtocol) error + type TCaSItem struct + ItemKey TItemKey + NewValue_ TItemValue + OldValue TItemValue + func NewTCaSItem() *TCaSItem + func (p *TCaSItem) GetItemKey() TItemKey + func (p *TCaSItem) GetNewValue_() TItemValue + func (p *TCaSItem) GetOldValue() TItemValue + func (p *TCaSItem) Read(iprot thrift.TProtocol) error + func (p *TCaSItem) ReadField1(iprot thrift.TProtocol) error + func (p *TCaSItem) ReadField2(iprot thrift.TProtocol) error + func (p *TCaSItem) ReadField3(iprot thrift.TProtocol) error + func (p *TCaSItem) String() string + func (p *TCaSItem) Write(oprot thrift.TProtocol) error + type TCluserOrdinatorService interface + Put func(ctx context.Context, key []byte, value []byte) (r int32, err error) + RemoveCache func(ctx context.Context, key TContainerKey) (err error) + type TCluserOrdinatorServiceClient struct + func NewTCluserOrdinatorServiceClient(c thrift.TClient) *TCluserOrdinatorServiceClient + func NewTCluserOrdinatorServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *TCluserOrdinatorServiceClient + func NewTCluserOrdinatorServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *TCluserOrdinatorServiceClient + func (p *TCluserOrdinatorServiceClient) Client_() thrift.TClient + func (p *TCluserOrdinatorServiceClient) Put(ctx context.Context, key []byte, value []byte) (r int32, err error) + func (p *TCluserOrdinatorServiceClient) RemoveCache(ctx context.Context, key TContainerKey) (err error) + type TCluserOrdinatorServiceProcessor struct + func NewTCluserOrdinatorServiceProcessor(handler TCluserOrdinatorService) *TCluserOrdinatorServiceProcessor + func (p *TCluserOrdinatorServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction) + func (p *TCluserOrdinatorServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool) + func (p *TCluserOrdinatorServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) + func (p *TCluserOrdinatorServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction + type TCluserOrdinatorServicePutArgs struct + Key []byte + Value []byte + func NewTCluserOrdinatorServicePutArgs() *TCluserOrdinatorServicePutArgs + func (p *TCluserOrdinatorServicePutArgs) GetKey() []byte + func (p *TCluserOrdinatorServicePutArgs) GetValue() []byte + func (p *TCluserOrdinatorServicePutArgs) Read(iprot thrift.TProtocol) error + func (p *TCluserOrdinatorServicePutArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TCluserOrdinatorServicePutArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TCluserOrdinatorServicePutArgs) String() string + func (p *TCluserOrdinatorServicePutArgs) Write(oprot thrift.TProtocol) error + type TCluserOrdinatorServicePutResult struct + Success *int32 + func NewTCluserOrdinatorServicePutResult() *TCluserOrdinatorServicePutResult + func (p *TCluserOrdinatorServicePutResult) GetSuccess() int32 + func (p *TCluserOrdinatorServicePutResult) IsSetSuccess() bool + func (p *TCluserOrdinatorServicePutResult) Read(iprot thrift.TProtocol) error + func (p *TCluserOrdinatorServicePutResult) ReadField0(iprot thrift.TProtocol) error + func (p *TCluserOrdinatorServicePutResult) String() string + func (p *TCluserOrdinatorServicePutResult) Write(oprot thrift.TProtocol) error + type TCluserOrdinatorServiceRemoveCacheArgs struct + Key TContainerKey + func NewTCluserOrdinatorServiceRemoveCacheArgs() *TCluserOrdinatorServiceRemoveCacheArgs + func (p *TCluserOrdinatorServiceRemoveCacheArgs) GetKey() TContainerKey + func (p *TCluserOrdinatorServiceRemoveCacheArgs) Read(iprot thrift.TProtocol) error + func (p *TCluserOrdinatorServiceRemoveCacheArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TCluserOrdinatorServiceRemoveCacheArgs) String() string + func (p *TCluserOrdinatorServiceRemoveCacheArgs) Write(oprot thrift.TProtocol) error + type TContainerKey int64 + func TContainerKeyPtr(v TContainerKey) *TContainerKey + type TErrorCode int64 + const TErrorCode_EBigSetAlreadyExisted + const TErrorCode_EBigSetAssigned + const TErrorCode_EBigSetCreated + const TErrorCode_EBigSetNotExisted + const TErrorCode_ECouldNotConnectIDGen + const TErrorCode_ECouldNotConnectMetadata + const TErrorCode_ECouldNotConnectRootMetaMapping + const TErrorCode_ECouldNotConnectSmallSet + const TErrorCode_EGood + const TErrorCode_EItemNotExisted + const TErrorCode_ENoRootMeta + const TErrorCode_EUnknownException + func TErrorCodeFromString(s string) (TErrorCode, error) + func TErrorCodePtr(v TErrorCode) *TErrorCode + func (p *TErrorCode) Scan(value interface{}) error + func (p *TErrorCode) UnmarshalText(text []byte) error + func (p *TErrorCode) Value() (driver.Value, error) + func (p TErrorCode) MarshalText() ([]byte, error) + func (p TErrorCode) String() string + type TExistedResult_ struct + Error TErrorCode + Existed bool + var TBSGenericDataServiceBsgExistedResult_Success_DEFAULT *TExistedResult_ + var TIBSDataServiceExistedResult_Success_DEFAULT *TExistedResult_ + var TStringBigSetKVServiceBsExistedResult_Success_DEFAULT *TExistedResult_ + func NewTExistedResult_() *TExistedResult_ + func (p *TExistedResult_) GetError() TErrorCode + func (p *TExistedResult_) GetExisted() bool + func (p *TExistedResult_) Read(iprot thrift.TProtocol) error + func (p *TExistedResult_) ReadField1(iprot thrift.TProtocol) error + func (p *TExistedResult_) ReadField2(iprot thrift.TProtocol) error + func (p *TExistedResult_) String() string + func (p *TExistedResult_) Write(oprot thrift.TProtocol) error + type TGetSliceInfo struct + FirstIdxFrom int32 + SmallSetIDs []TMetaKey + func NewTGetSliceInfo() *TGetSliceInfo + func (p *TGetSliceInfo) GetFirstIdxFrom() int32 + func (p *TGetSliceInfo) GetSmallSetIDs() []TMetaKey + func (p *TGetSliceInfo) Read(iprot thrift.TProtocol) error + func (p *TGetSliceInfo) ReadField1(iprot thrift.TProtocol) error + func (p *TGetSliceInfo) ReadField2(iprot thrift.TProtocol) error + func (p *TGetSliceInfo) String() string + func (p *TGetSliceInfo) Write(oprot thrift.TProtocol) error + type TIBSDataService interface + BulkLoad func(ctx context.Context, bigsetID TKey, setData *TItemSet) (r bool, err error) + Existed func(ctx context.Context, bigsetID TKey, itemKey TItemKey) (r *TExistedResult_, err error) + GetItem func(ctx context.Context, bigsetID TKey, itemKey TItemKey) (r *TItemResult_, err error) + GetSlice func(ctx context.Context, bigsetID TKey, fromPos int32, count int32) (r *TItemSetResult_, err error) + GetSliceFromItem func(ctx context.Context, bigsetID TKey, fromKey TItemKey, count int32) (r *TItemSetResult_, err error) + GetSliceFromItemR func(ctx context.Context, bigsetID TKey, fromKey TItemKey, count int32) (r *TItemSetResult_, err error) + GetSliceR func(ctx context.Context, bigsetID TKey, fromPos int32, count int32) (r *TItemSetResult_, err error) + GetTotalCount func(ctx context.Context, bigsetID TKey) (r int64, err error) + MultiPut func(ctx context.Context, bigsetID TKey, setData *TItemSet, getAddedItems bool, ...) (r *TMultiPutItemResult_, err error) + PutItem func(ctx context.Context, bigsetID TKey, item *TItem) (r *TPutItemResult_, err error) + RangeQuery func(ctx context.Context, bigsetID TKey, startKey TItemKey, endKey TItemKey) (r *TItemSetResult_, err error) + RemoveAll func(ctx context.Context, bigsetID TKey) (r int64, err error) + RemoveItem func(ctx context.Context, bigsetID TKey, itemKey TItemKey) (r bool, err error) + type TIBSDataServiceBulkLoadArgs struct + BigsetID TKey + SetData *TItemSet + func NewTIBSDataServiceBulkLoadArgs() *TIBSDataServiceBulkLoadArgs + func (p *TIBSDataServiceBulkLoadArgs) GetBigsetID() TKey + func (p *TIBSDataServiceBulkLoadArgs) GetSetData() *TItemSet + func (p *TIBSDataServiceBulkLoadArgs) IsSetSetData() bool + func (p *TIBSDataServiceBulkLoadArgs) Read(iprot thrift.TProtocol) error + func (p *TIBSDataServiceBulkLoadArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TIBSDataServiceBulkLoadArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TIBSDataServiceBulkLoadArgs) String() string + func (p *TIBSDataServiceBulkLoadArgs) Write(oprot thrift.TProtocol) error + type TIBSDataServiceBulkLoadResult struct + Success *bool + func NewTIBSDataServiceBulkLoadResult() *TIBSDataServiceBulkLoadResult + func (p *TIBSDataServiceBulkLoadResult) GetSuccess() bool + func (p *TIBSDataServiceBulkLoadResult) IsSetSuccess() bool + func (p *TIBSDataServiceBulkLoadResult) Read(iprot thrift.TProtocol) error + func (p *TIBSDataServiceBulkLoadResult) ReadField0(iprot thrift.TProtocol) error + func (p *TIBSDataServiceBulkLoadResult) String() string + func (p *TIBSDataServiceBulkLoadResult) Write(oprot thrift.TProtocol) error + type TIBSDataServiceClient struct + func NewTIBSDataServiceClient(c thrift.TClient) *TIBSDataServiceClient + func NewTIBSDataServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *TIBSDataServiceClient + func NewTIBSDataServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *TIBSDataServiceClient + func (p *TIBSDataServiceClient) BulkLoad(ctx context.Context, bigsetID TKey, setData *TItemSet) (r bool, err error) + func (p *TIBSDataServiceClient) Client_() thrift.TClient + func (p *TIBSDataServiceClient) Existed(ctx context.Context, bigsetID TKey, itemKey TItemKey) (r *TExistedResult_, err error) + func (p *TIBSDataServiceClient) GetItem(ctx context.Context, bigsetID TKey, itemKey TItemKey) (r *TItemResult_, err error) + func (p *TIBSDataServiceClient) GetSlice(ctx context.Context, bigsetID TKey, fromPos int32, count int32) (r *TItemSetResult_, err error) + func (p *TIBSDataServiceClient) GetSliceFromItem(ctx context.Context, bigsetID TKey, fromKey TItemKey, count int32) (r *TItemSetResult_, err error) + func (p *TIBSDataServiceClient) GetSliceFromItemR(ctx context.Context, bigsetID TKey, fromKey TItemKey, count int32) (r *TItemSetResult_, err error) + func (p *TIBSDataServiceClient) GetSliceR(ctx context.Context, bigsetID TKey, fromPos int32, count int32) (r *TItemSetResult_, err error) + func (p *TIBSDataServiceClient) GetTotalCount(ctx context.Context, bigsetID TKey) (r int64, err error) + func (p *TIBSDataServiceClient) MultiPut(ctx context.Context, bigsetID TKey, setData *TItemSet, getAddedItems bool, ...) (r *TMultiPutItemResult_, err error) + func (p *TIBSDataServiceClient) PutItem(ctx context.Context, bigsetID TKey, item *TItem) (r *TPutItemResult_, err error) + func (p *TIBSDataServiceClient) RangeQuery(ctx context.Context, bigsetID TKey, startKey TItemKey, endKey TItemKey) (r *TItemSetResult_, err error) + func (p *TIBSDataServiceClient) RemoveAll(ctx context.Context, bigsetID TKey) (r int64, err error) + func (p *TIBSDataServiceClient) RemoveItem(ctx context.Context, bigsetID TKey, itemKey TItemKey) (r bool, err error) + type TIBSDataServiceExistedArgs struct + BigsetID TKey + ItemKey TItemKey + func NewTIBSDataServiceExistedArgs() *TIBSDataServiceExistedArgs + func (p *TIBSDataServiceExistedArgs) GetBigsetID() TKey + func (p *TIBSDataServiceExistedArgs) GetItemKey() TItemKey + func (p *TIBSDataServiceExistedArgs) Read(iprot thrift.TProtocol) error + func (p *TIBSDataServiceExistedArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TIBSDataServiceExistedArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TIBSDataServiceExistedArgs) String() string + func (p *TIBSDataServiceExistedArgs) Write(oprot thrift.TProtocol) error + type TIBSDataServiceExistedResult struct + Success *TExistedResult_ + func NewTIBSDataServiceExistedResult() *TIBSDataServiceExistedResult + func (p *TIBSDataServiceExistedResult) GetSuccess() *TExistedResult_ + func (p *TIBSDataServiceExistedResult) IsSetSuccess() bool + func (p *TIBSDataServiceExistedResult) Read(iprot thrift.TProtocol) error + func (p *TIBSDataServiceExistedResult) ReadField0(iprot thrift.TProtocol) error + func (p *TIBSDataServiceExistedResult) String() string + func (p *TIBSDataServiceExistedResult) Write(oprot thrift.TProtocol) error + type TIBSDataServiceGetItemArgs struct + BigsetID TKey + ItemKey TItemKey + func NewTIBSDataServiceGetItemArgs() *TIBSDataServiceGetItemArgs + func (p *TIBSDataServiceGetItemArgs) GetBigsetID() TKey + func (p *TIBSDataServiceGetItemArgs) GetItemKey() TItemKey + func (p *TIBSDataServiceGetItemArgs) Read(iprot thrift.TProtocol) error + func (p *TIBSDataServiceGetItemArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TIBSDataServiceGetItemArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TIBSDataServiceGetItemArgs) String() string + func (p *TIBSDataServiceGetItemArgs) Write(oprot thrift.TProtocol) error + type TIBSDataServiceGetItemResult struct + Success *TItemResult_ + func NewTIBSDataServiceGetItemResult() *TIBSDataServiceGetItemResult + func (p *TIBSDataServiceGetItemResult) GetSuccess() *TItemResult_ + func (p *TIBSDataServiceGetItemResult) IsSetSuccess() bool + func (p *TIBSDataServiceGetItemResult) Read(iprot thrift.TProtocol) error + func (p *TIBSDataServiceGetItemResult) ReadField0(iprot thrift.TProtocol) error + func (p *TIBSDataServiceGetItemResult) String() string + func (p *TIBSDataServiceGetItemResult) Write(oprot thrift.TProtocol) error + type TIBSDataServiceGetSliceArgs struct + BigsetID TKey + Count int32 + FromPos int32 + func NewTIBSDataServiceGetSliceArgs() *TIBSDataServiceGetSliceArgs + func (p *TIBSDataServiceGetSliceArgs) GetBigsetID() TKey + func (p *TIBSDataServiceGetSliceArgs) GetCount() int32 + func (p *TIBSDataServiceGetSliceArgs) GetFromPos() int32 + func (p *TIBSDataServiceGetSliceArgs) Read(iprot thrift.TProtocol) error + func (p *TIBSDataServiceGetSliceArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TIBSDataServiceGetSliceArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TIBSDataServiceGetSliceArgs) ReadField3(iprot thrift.TProtocol) error + func (p *TIBSDataServiceGetSliceArgs) String() string + func (p *TIBSDataServiceGetSliceArgs) Write(oprot thrift.TProtocol) error + type TIBSDataServiceGetSliceFromItemArgs struct + BigsetID TKey + Count int32 + FromKey TItemKey + func NewTIBSDataServiceGetSliceFromItemArgs() *TIBSDataServiceGetSliceFromItemArgs + func (p *TIBSDataServiceGetSliceFromItemArgs) GetBigsetID() TKey + func (p *TIBSDataServiceGetSliceFromItemArgs) GetCount() int32 + func (p *TIBSDataServiceGetSliceFromItemArgs) GetFromKey() TItemKey + func (p *TIBSDataServiceGetSliceFromItemArgs) Read(iprot thrift.TProtocol) error + func (p *TIBSDataServiceGetSliceFromItemArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TIBSDataServiceGetSliceFromItemArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TIBSDataServiceGetSliceFromItemArgs) ReadField3(iprot thrift.TProtocol) error + func (p *TIBSDataServiceGetSliceFromItemArgs) String() string + func (p *TIBSDataServiceGetSliceFromItemArgs) Write(oprot thrift.TProtocol) error + type TIBSDataServiceGetSliceFromItemRArgs struct + BigsetID TKey + Count int32 + FromKey TItemKey + func NewTIBSDataServiceGetSliceFromItemRArgs() *TIBSDataServiceGetSliceFromItemRArgs + func (p *TIBSDataServiceGetSliceFromItemRArgs) GetBigsetID() TKey + func (p *TIBSDataServiceGetSliceFromItemRArgs) GetCount() int32 + func (p *TIBSDataServiceGetSliceFromItemRArgs) GetFromKey() TItemKey + func (p *TIBSDataServiceGetSliceFromItemRArgs) Read(iprot thrift.TProtocol) error + func (p *TIBSDataServiceGetSliceFromItemRArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TIBSDataServiceGetSliceFromItemRArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TIBSDataServiceGetSliceFromItemRArgs) ReadField3(iprot thrift.TProtocol) error + func (p *TIBSDataServiceGetSliceFromItemRArgs) String() string + func (p *TIBSDataServiceGetSliceFromItemRArgs) Write(oprot thrift.TProtocol) error + type TIBSDataServiceGetSliceFromItemRResult struct + Success *TItemSetResult_ + func NewTIBSDataServiceGetSliceFromItemRResult() *TIBSDataServiceGetSliceFromItemRResult + func (p *TIBSDataServiceGetSliceFromItemRResult) GetSuccess() *TItemSetResult_ + func (p *TIBSDataServiceGetSliceFromItemRResult) IsSetSuccess() bool + func (p *TIBSDataServiceGetSliceFromItemRResult) Read(iprot thrift.TProtocol) error + func (p *TIBSDataServiceGetSliceFromItemRResult) ReadField0(iprot thrift.TProtocol) error + func (p *TIBSDataServiceGetSliceFromItemRResult) String() string + func (p *TIBSDataServiceGetSliceFromItemRResult) Write(oprot thrift.TProtocol) error + type TIBSDataServiceGetSliceFromItemResult struct + Success *TItemSetResult_ + func NewTIBSDataServiceGetSliceFromItemResult() *TIBSDataServiceGetSliceFromItemResult + func (p *TIBSDataServiceGetSliceFromItemResult) GetSuccess() *TItemSetResult_ + func (p *TIBSDataServiceGetSliceFromItemResult) IsSetSuccess() bool + func (p *TIBSDataServiceGetSliceFromItemResult) Read(iprot thrift.TProtocol) error + func (p *TIBSDataServiceGetSliceFromItemResult) ReadField0(iprot thrift.TProtocol) error + func (p *TIBSDataServiceGetSliceFromItemResult) String() string + func (p *TIBSDataServiceGetSliceFromItemResult) Write(oprot thrift.TProtocol) error + type TIBSDataServiceGetSliceRArgs struct + BigsetID TKey + Count int32 + FromPos int32 + func NewTIBSDataServiceGetSliceRArgs() *TIBSDataServiceGetSliceRArgs + func (p *TIBSDataServiceGetSliceRArgs) GetBigsetID() TKey + func (p *TIBSDataServiceGetSliceRArgs) GetCount() int32 + func (p *TIBSDataServiceGetSliceRArgs) GetFromPos() int32 + func (p *TIBSDataServiceGetSliceRArgs) Read(iprot thrift.TProtocol) error + func (p *TIBSDataServiceGetSliceRArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TIBSDataServiceGetSliceRArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TIBSDataServiceGetSliceRArgs) ReadField3(iprot thrift.TProtocol) error + func (p *TIBSDataServiceGetSliceRArgs) String() string + func (p *TIBSDataServiceGetSliceRArgs) Write(oprot thrift.TProtocol) error + type TIBSDataServiceGetSliceRResult struct + Success *TItemSetResult_ + func NewTIBSDataServiceGetSliceRResult() *TIBSDataServiceGetSliceRResult + func (p *TIBSDataServiceGetSliceRResult) GetSuccess() *TItemSetResult_ + func (p *TIBSDataServiceGetSliceRResult) IsSetSuccess() bool + func (p *TIBSDataServiceGetSliceRResult) Read(iprot thrift.TProtocol) error + func (p *TIBSDataServiceGetSliceRResult) ReadField0(iprot thrift.TProtocol) error + func (p *TIBSDataServiceGetSliceRResult) String() string + func (p *TIBSDataServiceGetSliceRResult) Write(oprot thrift.TProtocol) error + type TIBSDataServiceGetSliceResult struct + Success *TItemSetResult_ + func NewTIBSDataServiceGetSliceResult() *TIBSDataServiceGetSliceResult + func (p *TIBSDataServiceGetSliceResult) GetSuccess() *TItemSetResult_ + func (p *TIBSDataServiceGetSliceResult) IsSetSuccess() bool + func (p *TIBSDataServiceGetSliceResult) Read(iprot thrift.TProtocol) error + func (p *TIBSDataServiceGetSliceResult) ReadField0(iprot thrift.TProtocol) error + func (p *TIBSDataServiceGetSliceResult) String() string + func (p *TIBSDataServiceGetSliceResult) Write(oprot thrift.TProtocol) error + type TIBSDataServiceGetTotalCountArgs struct + BigsetID TKey + func NewTIBSDataServiceGetTotalCountArgs() *TIBSDataServiceGetTotalCountArgs + func (p *TIBSDataServiceGetTotalCountArgs) GetBigsetID() TKey + func (p *TIBSDataServiceGetTotalCountArgs) Read(iprot thrift.TProtocol) error + func (p *TIBSDataServiceGetTotalCountArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TIBSDataServiceGetTotalCountArgs) String() string + func (p *TIBSDataServiceGetTotalCountArgs) Write(oprot thrift.TProtocol) error + type TIBSDataServiceGetTotalCountResult struct + Success *int64 + func NewTIBSDataServiceGetTotalCountResult() *TIBSDataServiceGetTotalCountResult + func (p *TIBSDataServiceGetTotalCountResult) GetSuccess() int64 + func (p *TIBSDataServiceGetTotalCountResult) IsSetSuccess() bool + func (p *TIBSDataServiceGetTotalCountResult) Read(iprot thrift.TProtocol) error + func (p *TIBSDataServiceGetTotalCountResult) ReadField0(iprot thrift.TProtocol) error + func (p *TIBSDataServiceGetTotalCountResult) String() string + func (p *TIBSDataServiceGetTotalCountResult) Write(oprot thrift.TProtocol) error + type TIBSDataServiceMultiPutArgs struct + BigsetID TKey + GetAddedItems bool + GetReplacedItems bool + SetData *TItemSet + func NewTIBSDataServiceMultiPutArgs() *TIBSDataServiceMultiPutArgs + func (p *TIBSDataServiceMultiPutArgs) GetBigsetID() TKey + func (p *TIBSDataServiceMultiPutArgs) GetGetAddedItems() bool + func (p *TIBSDataServiceMultiPutArgs) GetGetReplacedItems() bool + func (p *TIBSDataServiceMultiPutArgs) GetSetData() *TItemSet + func (p *TIBSDataServiceMultiPutArgs) IsSetSetData() bool + func (p *TIBSDataServiceMultiPutArgs) Read(iprot thrift.TProtocol) error + func (p *TIBSDataServiceMultiPutArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TIBSDataServiceMultiPutArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TIBSDataServiceMultiPutArgs) ReadField3(iprot thrift.TProtocol) error + func (p *TIBSDataServiceMultiPutArgs) ReadField4(iprot thrift.TProtocol) error + func (p *TIBSDataServiceMultiPutArgs) String() string + func (p *TIBSDataServiceMultiPutArgs) Write(oprot thrift.TProtocol) error + type TIBSDataServiceMultiPutResult struct + Success *TMultiPutItemResult_ + func NewTIBSDataServiceMultiPutResult() *TIBSDataServiceMultiPutResult + func (p *TIBSDataServiceMultiPutResult) GetSuccess() *TMultiPutItemResult_ + func (p *TIBSDataServiceMultiPutResult) IsSetSuccess() bool + func (p *TIBSDataServiceMultiPutResult) Read(iprot thrift.TProtocol) error + func (p *TIBSDataServiceMultiPutResult) ReadField0(iprot thrift.TProtocol) error + func (p *TIBSDataServiceMultiPutResult) String() string + func (p *TIBSDataServiceMultiPutResult) Write(oprot thrift.TProtocol) error + type TIBSDataServiceProcessor struct + func NewTIBSDataServiceProcessor(handler TIBSDataService) *TIBSDataServiceProcessor + func (p *TIBSDataServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction) + func (p *TIBSDataServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool) + func (p *TIBSDataServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) + func (p *TIBSDataServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction + type TIBSDataServicePutItemArgs struct + BigsetID TKey + Item *TItem + func NewTIBSDataServicePutItemArgs() *TIBSDataServicePutItemArgs + func (p *TIBSDataServicePutItemArgs) GetBigsetID() TKey + func (p *TIBSDataServicePutItemArgs) GetItem() *TItem + func (p *TIBSDataServicePutItemArgs) IsSetItem() bool + func (p *TIBSDataServicePutItemArgs) Read(iprot thrift.TProtocol) error + func (p *TIBSDataServicePutItemArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TIBSDataServicePutItemArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TIBSDataServicePutItemArgs) String() string + func (p *TIBSDataServicePutItemArgs) Write(oprot thrift.TProtocol) error + type TIBSDataServicePutItemResult struct + Success *TPutItemResult_ + func NewTIBSDataServicePutItemResult() *TIBSDataServicePutItemResult + func (p *TIBSDataServicePutItemResult) GetSuccess() *TPutItemResult_ + func (p *TIBSDataServicePutItemResult) IsSetSuccess() bool + func (p *TIBSDataServicePutItemResult) Read(iprot thrift.TProtocol) error + func (p *TIBSDataServicePutItemResult) ReadField0(iprot thrift.TProtocol) error + func (p *TIBSDataServicePutItemResult) String() string + func (p *TIBSDataServicePutItemResult) Write(oprot thrift.TProtocol) error + type TIBSDataServiceRangeQueryArgs struct + BigsetID TKey + EndKey TItemKey + StartKey TItemKey + func NewTIBSDataServiceRangeQueryArgs() *TIBSDataServiceRangeQueryArgs + func (p *TIBSDataServiceRangeQueryArgs) GetBigsetID() TKey + func (p *TIBSDataServiceRangeQueryArgs) GetEndKey() TItemKey + func (p *TIBSDataServiceRangeQueryArgs) GetStartKey() TItemKey + func (p *TIBSDataServiceRangeQueryArgs) Read(iprot thrift.TProtocol) error + func (p *TIBSDataServiceRangeQueryArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TIBSDataServiceRangeQueryArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TIBSDataServiceRangeQueryArgs) ReadField3(iprot thrift.TProtocol) error + func (p *TIBSDataServiceRangeQueryArgs) String() string + func (p *TIBSDataServiceRangeQueryArgs) Write(oprot thrift.TProtocol) error + type TIBSDataServiceRangeQueryResult struct + Success *TItemSetResult_ + func NewTIBSDataServiceRangeQueryResult() *TIBSDataServiceRangeQueryResult + func (p *TIBSDataServiceRangeQueryResult) GetSuccess() *TItemSetResult_ + func (p *TIBSDataServiceRangeQueryResult) IsSetSuccess() bool + func (p *TIBSDataServiceRangeQueryResult) Read(iprot thrift.TProtocol) error + func (p *TIBSDataServiceRangeQueryResult) ReadField0(iprot thrift.TProtocol) error + func (p *TIBSDataServiceRangeQueryResult) String() string + func (p *TIBSDataServiceRangeQueryResult) Write(oprot thrift.TProtocol) error + type TIBSDataServiceRemoveAllArgs struct + BigsetID TKey + func NewTIBSDataServiceRemoveAllArgs() *TIBSDataServiceRemoveAllArgs + func (p *TIBSDataServiceRemoveAllArgs) GetBigsetID() TKey + func (p *TIBSDataServiceRemoveAllArgs) Read(iprot thrift.TProtocol) error + func (p *TIBSDataServiceRemoveAllArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TIBSDataServiceRemoveAllArgs) String() string + func (p *TIBSDataServiceRemoveAllArgs) Write(oprot thrift.TProtocol) error + type TIBSDataServiceRemoveAllResult struct + Success *int64 + func NewTIBSDataServiceRemoveAllResult() *TIBSDataServiceRemoveAllResult + func (p *TIBSDataServiceRemoveAllResult) GetSuccess() int64 + func (p *TIBSDataServiceRemoveAllResult) IsSetSuccess() bool + func (p *TIBSDataServiceRemoveAllResult) Read(iprot thrift.TProtocol) error + func (p *TIBSDataServiceRemoveAllResult) ReadField0(iprot thrift.TProtocol) error + func (p *TIBSDataServiceRemoveAllResult) String() string + func (p *TIBSDataServiceRemoveAllResult) Write(oprot thrift.TProtocol) error + type TIBSDataServiceRemoveItemArgs struct + BigsetID TKey + ItemKey TItemKey + func NewTIBSDataServiceRemoveItemArgs() *TIBSDataServiceRemoveItemArgs + func (p *TIBSDataServiceRemoveItemArgs) GetBigsetID() TKey + func (p *TIBSDataServiceRemoveItemArgs) GetItemKey() TItemKey + func (p *TIBSDataServiceRemoveItemArgs) Read(iprot thrift.TProtocol) error + func (p *TIBSDataServiceRemoveItemArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TIBSDataServiceRemoveItemArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TIBSDataServiceRemoveItemArgs) String() string + func (p *TIBSDataServiceRemoveItemArgs) Write(oprot thrift.TProtocol) error + type TIBSDataServiceRemoveItemResult struct + Success *bool + func NewTIBSDataServiceRemoveItemResult() *TIBSDataServiceRemoveItemResult + func (p *TIBSDataServiceRemoveItemResult) GetSuccess() bool + func (p *TIBSDataServiceRemoveItemResult) IsSetSuccess() bool + func (p *TIBSDataServiceRemoveItemResult) Read(iprot thrift.TProtocol) error + func (p *TIBSDataServiceRemoveItemResult) ReadField0(iprot thrift.TProtocol) error + func (p *TIBSDataServiceRemoveItemResult) String() string + func (p *TIBSDataServiceRemoveItemResult) Write(oprot thrift.TProtocol) error + type TItem struct + Key []byte + Value []byte + var TBSGenericDataServiceBsgPutItemArgs_Item_DEFAULT *TItem + var TIBSDataServicePutItemArgs_Item_DEFAULT *TItem + var TItemResult__Item_DEFAULT *TItem + var TPutItemResult__OldItem_DEFAULT *TItem + var TStringBigSetKVServiceBsPutItemArgs_Item_DEFAULT *TItem + func NewTItem() *TItem + func (p *TItem) GetKey() []byte + func (p *TItem) GetValue() []byte + func (p *TItem) Read(iprot thrift.TProtocol) error + func (p *TItem) ReadField1(iprot thrift.TProtocol) error + func (p *TItem) ReadField2(iprot thrift.TProtocol) error + func (p *TItem) String() string + func (p *TItem) Write(oprot thrift.TProtocol) error + type TItemKey []byte + func TItemKeyPtr(v TItemKey) *TItemKey + type TItemKeySet []TItemKey + func TItemKeySetPtr(v TItemKeySet) *TItemKeySet + type TItemList []*TItem + func TItemListPtr(v TItemList) *TItemList + type TItemResult_ struct + Error TErrorCode + Item *TItem + var TBSGenericDataServiceBsgGetItemResult_Success_DEFAULT *TItemResult_ + var TIBSDataServiceGetItemResult_Success_DEFAULT *TItemResult_ + var TStringBigSetKVServiceBsGetItemResult_Success_DEFAULT *TItemResult_ + func NewTItemResult_() *TItemResult_ + func (p *TItemResult_) GetError() TErrorCode + func (p *TItemResult_) GetItem() *TItem + func (p *TItemResult_) IsSetItem() bool + func (p *TItemResult_) Read(iprot thrift.TProtocol) error + func (p *TItemResult_) ReadField1(iprot thrift.TProtocol) error + func (p *TItemResult_) ReadField2(iprot thrift.TProtocol) error + func (p *TItemResult_) String() string + func (p *TItemResult_) Write(oprot thrift.TProtocol) error + type TItemSet struct + Items []*TItem + var TBSGenericDataServiceBsgBulkLoadArgs_SetData_DEFAULT *TItemSet + var TBSGenericDataServiceBsgMultiPutArgs_SetData_DEFAULT *TItemSet + var TIBSDataServiceBulkLoadArgs_SetData_DEFAULT *TItemSet + var TIBSDataServiceMultiPutArgs_SetData_DEFAULT *TItemSet + var TItemSetResult__Items_DEFAULT *TItemSet + var TStringBigSetKVServiceBsBulkLoadArgs_SetData_DEFAULT *TItemSet + var TStringBigSetKVServiceBsMultiPutArgs_SetData_DEFAULT *TItemSet + func NewTItemSet() *TItemSet + func (p *TItemSet) GetItems() []*TItem + func (p *TItemSet) Read(iprot thrift.TProtocol) error + func (p *TItemSet) ReadField1(iprot thrift.TProtocol) error + func (p *TItemSet) String() string + func (p *TItemSet) Write(oprot thrift.TProtocol) error + type TItemSetResult_ struct + Error TErrorCode + Items *TItemSet + var TBSGenericDataServiceBsgGetSliceFromItemRResult_Success_DEFAULT *TItemSetResult_ + var TBSGenericDataServiceBsgGetSliceFromItemResult_Success_DEFAULT *TItemSetResult_ + var TBSGenericDataServiceBsgGetSliceRResult_Success_DEFAULT *TItemSetResult_ + var TBSGenericDataServiceBsgGetSliceResult_Success_DEFAULT *TItemSetResult_ + var TBSGenericDataServiceBsgRangeQueryResult_Success_DEFAULT *TItemSetResult_ + var TIBSDataServiceGetSliceFromItemRResult_Success_DEFAULT *TItemSetResult_ + var TIBSDataServiceGetSliceFromItemResult_Success_DEFAULT *TItemSetResult_ + var TIBSDataServiceGetSliceRResult_Success_DEFAULT *TItemSetResult_ + var TIBSDataServiceGetSliceResult_Success_DEFAULT *TItemSetResult_ + var TIBSDataServiceRangeQueryResult_Success_DEFAULT *TItemSetResult_ + var TStringBigSetKVServiceBsGetSliceFromItemRResult_Success_DEFAULT *TItemSetResult_ + var TStringBigSetKVServiceBsGetSliceFromItemResult_Success_DEFAULT *TItemSetResult_ + var TStringBigSetKVServiceBsGetSliceRResult_Success_DEFAULT *TItemSetResult_ + var TStringBigSetKVServiceBsGetSliceResult_Success_DEFAULT *TItemSetResult_ + var TStringBigSetKVServiceBsRangeQueryResult_Success_DEFAULT *TItemSetResult_ + func NewTItemSetResult_() *TItemSetResult_ + func (p *TItemSetResult_) GetError() TErrorCode + func (p *TItemSetResult_) GetItems() *TItemSet + func (p *TItemSetResult_) IsSetItems() bool + func (p *TItemSetResult_) Read(iprot thrift.TProtocol) error + func (p *TItemSetResult_) ReadField1(iprot thrift.TProtocol) error + func (p *TItemSetResult_) ReadField2(iprot thrift.TProtocol) error + func (p *TItemSetResult_) String() string + func (p *TItemSetResult_) Write(oprot thrift.TProtocol) error + type TItemValue []byte + func TItemValuePtr(v TItemValue) *TItemValue + type TKey int64 + func TKeyPtr(v TKey) *TKey + type TLevelType int16 + func TLevelTypePtr(v TLevelType) *TLevelType + type TMetaItem struct + Count int32 + MetaID int64 + MinItem TItemKey + func NewTMetaItem() *TMetaItem + func (p *TMetaItem) GetCount() int32 + func (p *TMetaItem) GetMetaID() int64 + func (p *TMetaItem) GetMinItem() TItemKey + func (p *TMetaItem) Read(iprot thrift.TProtocol) error + func (p *TMetaItem) ReadField1(iprot thrift.TProtocol) error + func (p *TMetaItem) ReadField2(iprot thrift.TProtocol) error + func (p *TMetaItem) ReadField3(iprot thrift.TProtocol) error + func (p *TMetaItem) String() string + func (p *TMetaItem) Write(oprot thrift.TProtocol) error + type TMetaKey TContainerKey + var MasterMetaServiceGetMetaIDResult_Success_DEFAULT TMetaKey + func TMetaKeyPtr(v TMetaKey) *TMetaKey + type TMultiPutItemResult_ struct + Added []TItemKey + Error TErrorCode + Replaced []*TItem + var TBSGenericDataServiceBsgMultiPutResult_Success_DEFAULT *TMultiPutItemResult_ + var TIBSDataServiceMultiPutResult_Success_DEFAULT *TMultiPutItemResult_ + var TStringBigSetKVServiceBsMultiPutResult_Success_DEFAULT *TMultiPutItemResult_ + func NewTMultiPutItemResult_() *TMultiPutItemResult_ + func (p *TMultiPutItemResult_) GetAdded() []TItemKey + func (p *TMultiPutItemResult_) GetError() TErrorCode + func (p *TMultiPutItemResult_) GetReplaced() []*TItem + func (p *TMultiPutItemResult_) IsSetAdded() bool + func (p *TMultiPutItemResult_) IsSetReplaced() bool + func (p *TMultiPutItemResult_) Read(iprot thrift.TProtocol) error + func (p *TMultiPutItemResult_) ReadField1(iprot thrift.TProtocol) error + func (p *TMultiPutItemResult_) ReadField2(iprot thrift.TProtocol) error + func (p *TMultiPutItemResult_) ReadField3(iprot thrift.TProtocol) error + func (p *TMultiPutItemResult_) String() string + func (p *TMultiPutItemResult_) Write(oprot thrift.TProtocol) error + type TNeedSplitInfo struct + ChildCount int32 + IsSmallSet bool + MetaID TMetaKey + ParentID TMetaKey + var BSNotificationPoolNeedSplitArgs_SplitInfo_DEFAULT *TNeedSplitInfo + var SplitJob_SplitInfo_DEFAULT *TNeedSplitInfo + var TBigSetGenericData_Splitinfo_DEFAULT *TNeedSplitInfo + var TSetMetaPath_SplitInfo_DEFAULT *TNeedSplitInfo + func NewTNeedSplitInfo() *TNeedSplitInfo + func (p *TNeedSplitInfo) GetChildCount() int32 + func (p *TNeedSplitInfo) GetIsSmallSet() bool + func (p *TNeedSplitInfo) GetMetaID() TMetaKey + func (p *TNeedSplitInfo) GetParentID() TMetaKey + func (p *TNeedSplitInfo) Read(iprot thrift.TProtocol) error + func (p *TNeedSplitInfo) ReadField1(iprot thrift.TProtocol) error + func (p *TNeedSplitInfo) ReadField2(iprot thrift.TProtocol) error + func (p *TNeedSplitInfo) ReadField3(iprot thrift.TProtocol) error + func (p *TNeedSplitInfo) ReadField4(iprot thrift.TProtocol) error + func (p *TNeedSplitInfo) String() string + func (p *TNeedSplitInfo) Write(oprot thrift.TProtocol) error + type TPutItemResult_ struct + Error TErrorCode + Ok bool + OldItem *TItem + var TBSGenericDataServiceBsgPutItemResult_Success_DEFAULT *TPutItemResult_ + var TIBSDataServicePutItemResult_Success_DEFAULT *TPutItemResult_ + var TStringBigSetKVServiceBsPutItemResult_Success_DEFAULT *TPutItemResult_ + func NewTPutItemResult_() *TPutItemResult_ + func (p *TPutItemResult_) GetError() TErrorCode + func (p *TPutItemResult_) GetOk() bool + func (p *TPutItemResult_) GetOldItem() *TItem + func (p *TPutItemResult_) IsSetOldItem() bool + func (p *TPutItemResult_) Read(iprot thrift.TProtocol) error + func (p *TPutItemResult_) ReadField1(iprot thrift.TProtocol) error + func (p *TPutItemResult_) ReadField2(iprot thrift.TProtocol) error + func (p *TPutItemResult_) ReadField3(iprot thrift.TProtocol) error + func (p *TPutItemResult_) String() string + func (p *TPutItemResult_) Write(oprot thrift.TProtocol) error + type TSetMetaPath struct + MetaPath []*TSetMetaPathItem + SmallSetInfo *TSetMetaPathItem + SplitInfo *TNeedSplitInfo + func NewTSetMetaPath() *TSetMetaPath + func (p *TSetMetaPath) GetMetaPath() []*TSetMetaPathItem + func (p *TSetMetaPath) GetSmallSetInfo() *TSetMetaPathItem + func (p *TSetMetaPath) GetSplitInfo() *TNeedSplitInfo + func (p *TSetMetaPath) IsSetSmallSetInfo() bool + func (p *TSetMetaPath) IsSetSplitInfo() bool + func (p *TSetMetaPath) Read(iprot thrift.TProtocol) error + func (p *TSetMetaPath) ReadField1(iprot thrift.TProtocol) error + func (p *TSetMetaPath) ReadField2(iprot thrift.TProtocol) error + func (p *TSetMetaPath) ReadField3(iprot thrift.TProtocol) error + func (p *TSetMetaPath) String() string + func (p *TSetMetaPath) Write(oprot thrift.TProtocol) error + type TSetMetaPathItem struct + Level int8 + MetaID int64 + MinItem TItemKey + var TSetMetaPath_SmallSetInfo_DEFAULT *TSetMetaPathItem + func NewTSetMetaPathItem() *TSetMetaPathItem + func (p *TSetMetaPathItem) GetLevel() int8 + func (p *TSetMetaPathItem) GetMetaID() int64 + func (p *TSetMetaPathItem) GetMinItem() TItemKey + func (p *TSetMetaPathItem) Read(iprot thrift.TProtocol) error + func (p *TSetMetaPathItem) ReadField1(iprot thrift.TProtocol) error + func (p *TSetMetaPathItem) ReadField2(iprot thrift.TProtocol) error + func (p *TSetMetaPathItem) ReadField3(iprot thrift.TProtocol) error + func (p *TSetMetaPathItem) String() string + func (p *TSetMetaPathItem) Write(oprot thrift.TProtocol) error + type TSmallSet struct + Entries TItemList + Nxt *TSmallSetIDKey + Prev *TSmallSetIDKey + var TBigSetGenericData_Smallset_DEFAULT *TSmallSet + func NewTSmallSet() *TSmallSet + func (p *TSmallSet) GetEntries() TItemList + func (p *TSmallSet) GetNxt() TSmallSetIDKey + func (p *TSmallSet) GetPrev() TSmallSetIDKey + func (p *TSmallSet) IsSetNxt() bool + func (p *TSmallSet) IsSetPrev() bool + func (p *TSmallSet) Read(iprot thrift.TProtocol) error + func (p *TSmallSet) ReadField1(iprot thrift.TProtocol) error + func (p *TSmallSet) ReadField2(iprot thrift.TProtocol) error + func (p *TSmallSet) ReadField3(iprot thrift.TProtocol) error + func (p *TSmallSet) String() string + func (p *TSmallSet) Write(oprot thrift.TProtocol) error + type TSmallSetIDKey TContainerKey + var TSmallSetInfo_Nxt_DEFAULT TSmallSetIDKey = 0 + var TSmallSetInfo_Prev_DEFAULT TSmallSetIDKey = 0 + var TSmallSet_Nxt_DEFAULT TSmallSetIDKey + var TSmallSet_Prev_DEFAULT TSmallSetIDKey + func TSmallSetIDKeyPtr(v TSmallSetIDKey) *TSmallSetIDKey + type TSmallSetInfo struct + Count int32 + CountFromMid int32 + MidItem TItemKey + Nxt TSmallSetIDKey + Prev TSmallSetIDKey + func NewTSmallSetInfo() *TSmallSetInfo + func (p *TSmallSetInfo) GetCount() int32 + func (p *TSmallSetInfo) GetCountFromMid() int32 + func (p *TSmallSetInfo) GetMidItem() TItemKey + func (p *TSmallSetInfo) GetNxt() TSmallSetIDKey + func (p *TSmallSetInfo) GetPrev() TSmallSetIDKey + func (p *TSmallSetInfo) IsSetNxt() bool + func (p *TSmallSetInfo) IsSetPrev() bool + func (p *TSmallSetInfo) Read(iprot thrift.TProtocol) error + func (p *TSmallSetInfo) ReadField1(iprot thrift.TProtocol) error + func (p *TSmallSetInfo) ReadField2(iprot thrift.TProtocol) error + func (p *TSmallSetInfo) ReadField3(iprot thrift.TProtocol) error + func (p *TSmallSetInfo) ReadField4(iprot thrift.TProtocol) error + func (p *TSmallSetInfo) ReadField5(iprot thrift.TProtocol) error + func (p *TSmallSetInfo) String() string + func (p *TSmallSetInfo) Write(oprot thrift.TProtocol) error + type TSplitBigSetResult_ struct + Count int64 + Error TErrorCode + MinItem TItemKey + NewRootID_ TContainerKey + Splited bool + var TBSGenericDataServiceSplitBigSetResult_Success_DEFAULT *TSplitBigSetResult_ + func NewTSplitBigSetResult_() *TSplitBigSetResult_ + func (p *TSplitBigSetResult_) GetCount() int64 + func (p *TSplitBigSetResult_) GetError() TErrorCode + func (p *TSplitBigSetResult_) GetMinItem() TItemKey + func (p *TSplitBigSetResult_) GetNewRootID_() TContainerKey + func (p *TSplitBigSetResult_) GetSplited() bool + func (p *TSplitBigSetResult_) Read(iprot thrift.TProtocol) error + func (p *TSplitBigSetResult_) ReadField1(iprot thrift.TProtocol) error + func (p *TSplitBigSetResult_) ReadField2(iprot thrift.TProtocol) error + func (p *TSplitBigSetResult_) ReadField3(iprot thrift.TProtocol) error + func (p *TSplitBigSetResult_) ReadField4(iprot thrift.TProtocol) error + func (p *TSplitBigSetResult_) ReadField5(iprot thrift.TProtocol) error + func (p *TSplitBigSetResult_) String() string + func (p *TSplitBigSetResult_) Write(oprot thrift.TProtocol) error + type TStringBigSetInfo struct + BigsetID TContainerKey + BigsetName TStringKey + Count *int64 + var TBigSetInfoResult__Info_DEFAULT *TStringBigSetInfo + func NewTStringBigSetInfo() *TStringBigSetInfo + func (p *TStringBigSetInfo) GetBigsetID() TContainerKey + func (p *TStringBigSetInfo) GetBigsetName() TStringKey + func (p *TStringBigSetInfo) GetCount() int64 + func (p *TStringBigSetInfo) IsSetCount() bool + func (p *TStringBigSetInfo) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetInfo) ReadField1(iprot thrift.TProtocol) error + func (p *TStringBigSetInfo) ReadField2(iprot thrift.TProtocol) error + func (p *TStringBigSetInfo) ReadField3(iprot thrift.TProtocol) error + func (p *TStringBigSetInfo) String() string + func (p *TStringBigSetInfo) Write(oprot thrift.TProtocol) error + type TStringBigSetKVService interface + AssignBigSetName func(ctx context.Context, bsName TStringKey, bigsetID TContainerKey) (r *TBigSetInfoResult_, err error) + BsBulkLoad func(ctx context.Context, bsName TStringKey, setData *TItemSet) (r bool, err error) + BsExisted func(ctx context.Context, bsName TStringKey, itemKey TItemKey) (r *TExistedResult_, err error) + BsGetItem func(ctx context.Context, bsName TStringKey, itemKey TItemKey) (r *TItemResult_, err error) + BsGetSlice func(ctx context.Context, bsName TStringKey, fromPos int32, count int32) (r *TItemSetResult_, err error) + BsGetSliceFromItem func(ctx context.Context, bsName TStringKey, fromKey TItemKey, count int32) (r *TItemSetResult_, err error) + BsGetSliceFromItemR func(ctx context.Context, bsName TStringKey, fromKey TItemKey, count int32) (r *TItemSetResult_, err error) + BsGetSliceR func(ctx context.Context, bsName TStringKey, fromPos int32, count int32) (r *TItemSetResult_, err error) + BsMultiPut func(ctx context.Context, bsName TStringKey, setData *TItemSet, getAddedItems bool, ...) (r *TMultiPutItemResult_, err error) + BsPutItem func(ctx context.Context, bsName TStringKey, item *TItem) (r *TPutItemResult_, err error) + BsRangeQuery func(ctx context.Context, bsName TStringKey, startKey TItemKey, endKey TItemKey) (r *TItemSetResult_, err error) + BsRemoveItem func(ctx context.Context, bsName TStringKey, itemKey TItemKey) (r bool, err error) + CreateStringBigSet func(ctx context.Context, bsName TStringKey) (r *TBigSetInfoResult_, err error) + GetBigSetInfoByName func(ctx context.Context, bsName TStringKey) (r *TBigSetInfoResult_, err error) + GetListKey func(ctx context.Context, fromIndex int64, count int32) (r []TStringKey, err error) + GetListKeyFrom func(ctx context.Context, keyFrom TStringKey, count int32) (r []TStringKey, err error) + GetTotalCount func(ctx context.Context, bsName TStringKey) (r int64, err error) + RemoveAll func(ctx context.Context, bsName TStringKey) (r int64, err error) + TotalStringKeyCount func(ctx context.Context) (r int64, err error) + type TStringBigSetKVServiceAssignBigSetNameArgs struct + BigsetID TContainerKey + BsName TStringKey + func NewTStringBigSetKVServiceAssignBigSetNameArgs() *TStringBigSetKVServiceAssignBigSetNameArgs + func (p *TStringBigSetKVServiceAssignBigSetNameArgs) GetBigsetID() TContainerKey + func (p *TStringBigSetKVServiceAssignBigSetNameArgs) GetBsName() TStringKey + func (p *TStringBigSetKVServiceAssignBigSetNameArgs) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceAssignBigSetNameArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceAssignBigSetNameArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceAssignBigSetNameArgs) String() string + func (p *TStringBigSetKVServiceAssignBigSetNameArgs) Write(oprot thrift.TProtocol) error + type TStringBigSetKVServiceAssignBigSetNameResult struct + Success *TBigSetInfoResult_ + func NewTStringBigSetKVServiceAssignBigSetNameResult() *TStringBigSetKVServiceAssignBigSetNameResult + func (p *TStringBigSetKVServiceAssignBigSetNameResult) GetSuccess() *TBigSetInfoResult_ + func (p *TStringBigSetKVServiceAssignBigSetNameResult) IsSetSuccess() bool + func (p *TStringBigSetKVServiceAssignBigSetNameResult) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceAssignBigSetNameResult) ReadField0(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceAssignBigSetNameResult) String() string + func (p *TStringBigSetKVServiceAssignBigSetNameResult) Write(oprot thrift.TProtocol) error + type TStringBigSetKVServiceBsBulkLoadArgs struct + BsName TStringKey + SetData *TItemSet + func NewTStringBigSetKVServiceBsBulkLoadArgs() *TStringBigSetKVServiceBsBulkLoadArgs + func (p *TStringBigSetKVServiceBsBulkLoadArgs) GetBsName() TStringKey + func (p *TStringBigSetKVServiceBsBulkLoadArgs) GetSetData() *TItemSet + func (p *TStringBigSetKVServiceBsBulkLoadArgs) IsSetSetData() bool + func (p *TStringBigSetKVServiceBsBulkLoadArgs) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsBulkLoadArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsBulkLoadArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsBulkLoadArgs) String() string + func (p *TStringBigSetKVServiceBsBulkLoadArgs) Write(oprot thrift.TProtocol) error + type TStringBigSetKVServiceBsBulkLoadResult struct + Success *bool + func NewTStringBigSetKVServiceBsBulkLoadResult() *TStringBigSetKVServiceBsBulkLoadResult + func (p *TStringBigSetKVServiceBsBulkLoadResult) GetSuccess() bool + func (p *TStringBigSetKVServiceBsBulkLoadResult) IsSetSuccess() bool + func (p *TStringBigSetKVServiceBsBulkLoadResult) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsBulkLoadResult) ReadField0(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsBulkLoadResult) String() string + func (p *TStringBigSetKVServiceBsBulkLoadResult) Write(oprot thrift.TProtocol) error + type TStringBigSetKVServiceBsExistedArgs struct + BsName TStringKey + ItemKey TItemKey + func NewTStringBigSetKVServiceBsExistedArgs() *TStringBigSetKVServiceBsExistedArgs + func (p *TStringBigSetKVServiceBsExistedArgs) GetBsName() TStringKey + func (p *TStringBigSetKVServiceBsExistedArgs) GetItemKey() TItemKey + func (p *TStringBigSetKVServiceBsExistedArgs) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsExistedArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsExistedArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsExistedArgs) String() string + func (p *TStringBigSetKVServiceBsExistedArgs) Write(oprot thrift.TProtocol) error + type TStringBigSetKVServiceBsExistedResult struct + Success *TExistedResult_ + func NewTStringBigSetKVServiceBsExistedResult() *TStringBigSetKVServiceBsExistedResult + func (p *TStringBigSetKVServiceBsExistedResult) GetSuccess() *TExistedResult_ + func (p *TStringBigSetKVServiceBsExistedResult) IsSetSuccess() bool + func (p *TStringBigSetKVServiceBsExistedResult) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsExistedResult) ReadField0(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsExistedResult) String() string + func (p *TStringBigSetKVServiceBsExistedResult) Write(oprot thrift.TProtocol) error + type TStringBigSetKVServiceBsGetItemArgs struct + BsName TStringKey + ItemKey TItemKey + func NewTStringBigSetKVServiceBsGetItemArgs() *TStringBigSetKVServiceBsGetItemArgs + func (p *TStringBigSetKVServiceBsGetItemArgs) GetBsName() TStringKey + func (p *TStringBigSetKVServiceBsGetItemArgs) GetItemKey() TItemKey + func (p *TStringBigSetKVServiceBsGetItemArgs) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsGetItemArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsGetItemArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsGetItemArgs) String() string + func (p *TStringBigSetKVServiceBsGetItemArgs) Write(oprot thrift.TProtocol) error + type TStringBigSetKVServiceBsGetItemResult struct + Success *TItemResult_ + func NewTStringBigSetKVServiceBsGetItemResult() *TStringBigSetKVServiceBsGetItemResult + func (p *TStringBigSetKVServiceBsGetItemResult) GetSuccess() *TItemResult_ + func (p *TStringBigSetKVServiceBsGetItemResult) IsSetSuccess() bool + func (p *TStringBigSetKVServiceBsGetItemResult) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsGetItemResult) ReadField0(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsGetItemResult) String() string + func (p *TStringBigSetKVServiceBsGetItemResult) Write(oprot thrift.TProtocol) error + type TStringBigSetKVServiceBsGetSliceArgs struct + BsName TStringKey + Count int32 + FromPos int32 + func NewTStringBigSetKVServiceBsGetSliceArgs() *TStringBigSetKVServiceBsGetSliceArgs + func (p *TStringBigSetKVServiceBsGetSliceArgs) GetBsName() TStringKey + func (p *TStringBigSetKVServiceBsGetSliceArgs) GetCount() int32 + func (p *TStringBigSetKVServiceBsGetSliceArgs) GetFromPos() int32 + func (p *TStringBigSetKVServiceBsGetSliceArgs) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsGetSliceArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsGetSliceArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsGetSliceArgs) ReadField3(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsGetSliceArgs) String() string + func (p *TStringBigSetKVServiceBsGetSliceArgs) Write(oprot thrift.TProtocol) error + type TStringBigSetKVServiceBsGetSliceFromItemArgs struct + BsName TStringKey + Count int32 + FromKey TItemKey + func NewTStringBigSetKVServiceBsGetSliceFromItemArgs() *TStringBigSetKVServiceBsGetSliceFromItemArgs + func (p *TStringBigSetKVServiceBsGetSliceFromItemArgs) GetBsName() TStringKey + func (p *TStringBigSetKVServiceBsGetSliceFromItemArgs) GetCount() int32 + func (p *TStringBigSetKVServiceBsGetSliceFromItemArgs) GetFromKey() TItemKey + func (p *TStringBigSetKVServiceBsGetSliceFromItemArgs) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsGetSliceFromItemArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsGetSliceFromItemArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsGetSliceFromItemArgs) ReadField3(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsGetSliceFromItemArgs) String() string + func (p *TStringBigSetKVServiceBsGetSliceFromItemArgs) Write(oprot thrift.TProtocol) error + type TStringBigSetKVServiceBsGetSliceFromItemRArgs struct + BsName TStringKey + Count int32 + FromKey TItemKey + func NewTStringBigSetKVServiceBsGetSliceFromItemRArgs() *TStringBigSetKVServiceBsGetSliceFromItemRArgs + func (p *TStringBigSetKVServiceBsGetSliceFromItemRArgs) GetBsName() TStringKey + func (p *TStringBigSetKVServiceBsGetSliceFromItemRArgs) GetCount() int32 + func (p *TStringBigSetKVServiceBsGetSliceFromItemRArgs) GetFromKey() TItemKey + func (p *TStringBigSetKVServiceBsGetSliceFromItemRArgs) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsGetSliceFromItemRArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsGetSliceFromItemRArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsGetSliceFromItemRArgs) ReadField3(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsGetSliceFromItemRArgs) String() string + func (p *TStringBigSetKVServiceBsGetSliceFromItemRArgs) Write(oprot thrift.TProtocol) error + type TStringBigSetKVServiceBsGetSliceFromItemRResult struct + Success *TItemSetResult_ + func NewTStringBigSetKVServiceBsGetSliceFromItemRResult() *TStringBigSetKVServiceBsGetSliceFromItemRResult + func (p *TStringBigSetKVServiceBsGetSliceFromItemRResult) GetSuccess() *TItemSetResult_ + func (p *TStringBigSetKVServiceBsGetSliceFromItemRResult) IsSetSuccess() bool + func (p *TStringBigSetKVServiceBsGetSliceFromItemRResult) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsGetSliceFromItemRResult) ReadField0(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsGetSliceFromItemRResult) String() string + func (p *TStringBigSetKVServiceBsGetSliceFromItemRResult) Write(oprot thrift.TProtocol) error + type TStringBigSetKVServiceBsGetSliceFromItemResult struct + Success *TItemSetResult_ + func NewTStringBigSetKVServiceBsGetSliceFromItemResult() *TStringBigSetKVServiceBsGetSliceFromItemResult + func (p *TStringBigSetKVServiceBsGetSliceFromItemResult) GetSuccess() *TItemSetResult_ + func (p *TStringBigSetKVServiceBsGetSliceFromItemResult) IsSetSuccess() bool + func (p *TStringBigSetKVServiceBsGetSliceFromItemResult) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsGetSliceFromItemResult) ReadField0(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsGetSliceFromItemResult) String() string + func (p *TStringBigSetKVServiceBsGetSliceFromItemResult) Write(oprot thrift.TProtocol) error + type TStringBigSetKVServiceBsGetSliceRArgs struct + BsName TStringKey + Count int32 + FromPos int32 + func NewTStringBigSetKVServiceBsGetSliceRArgs() *TStringBigSetKVServiceBsGetSliceRArgs + func (p *TStringBigSetKVServiceBsGetSliceRArgs) GetBsName() TStringKey + func (p *TStringBigSetKVServiceBsGetSliceRArgs) GetCount() int32 + func (p *TStringBigSetKVServiceBsGetSliceRArgs) GetFromPos() int32 + func (p *TStringBigSetKVServiceBsGetSliceRArgs) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsGetSliceRArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsGetSliceRArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsGetSliceRArgs) ReadField3(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsGetSliceRArgs) String() string + func (p *TStringBigSetKVServiceBsGetSliceRArgs) Write(oprot thrift.TProtocol) error + type TStringBigSetKVServiceBsGetSliceRResult struct + Success *TItemSetResult_ + func NewTStringBigSetKVServiceBsGetSliceRResult() *TStringBigSetKVServiceBsGetSliceRResult + func (p *TStringBigSetKVServiceBsGetSliceRResult) GetSuccess() *TItemSetResult_ + func (p *TStringBigSetKVServiceBsGetSliceRResult) IsSetSuccess() bool + func (p *TStringBigSetKVServiceBsGetSliceRResult) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsGetSliceRResult) ReadField0(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsGetSliceRResult) String() string + func (p *TStringBigSetKVServiceBsGetSliceRResult) Write(oprot thrift.TProtocol) error + type TStringBigSetKVServiceBsGetSliceResult struct + Success *TItemSetResult_ + func NewTStringBigSetKVServiceBsGetSliceResult() *TStringBigSetKVServiceBsGetSliceResult + func (p *TStringBigSetKVServiceBsGetSliceResult) GetSuccess() *TItemSetResult_ + func (p *TStringBigSetKVServiceBsGetSliceResult) IsSetSuccess() bool + func (p *TStringBigSetKVServiceBsGetSliceResult) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsGetSliceResult) ReadField0(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsGetSliceResult) String() string + func (p *TStringBigSetKVServiceBsGetSliceResult) Write(oprot thrift.TProtocol) error + type TStringBigSetKVServiceBsMultiPutArgs struct + BsName TStringKey + GetAddedItems bool + GetReplacedItems bool + SetData *TItemSet + func NewTStringBigSetKVServiceBsMultiPutArgs() *TStringBigSetKVServiceBsMultiPutArgs + func (p *TStringBigSetKVServiceBsMultiPutArgs) GetBsName() TStringKey + func (p *TStringBigSetKVServiceBsMultiPutArgs) GetGetAddedItems() bool + func (p *TStringBigSetKVServiceBsMultiPutArgs) GetGetReplacedItems() bool + func (p *TStringBigSetKVServiceBsMultiPutArgs) GetSetData() *TItemSet + func (p *TStringBigSetKVServiceBsMultiPutArgs) IsSetSetData() bool + func (p *TStringBigSetKVServiceBsMultiPutArgs) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsMultiPutArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsMultiPutArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsMultiPutArgs) ReadField3(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsMultiPutArgs) ReadField4(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsMultiPutArgs) String() string + func (p *TStringBigSetKVServiceBsMultiPutArgs) Write(oprot thrift.TProtocol) error + type TStringBigSetKVServiceBsMultiPutResult struct + Success *TMultiPutItemResult_ + func NewTStringBigSetKVServiceBsMultiPutResult() *TStringBigSetKVServiceBsMultiPutResult + func (p *TStringBigSetKVServiceBsMultiPutResult) GetSuccess() *TMultiPutItemResult_ + func (p *TStringBigSetKVServiceBsMultiPutResult) IsSetSuccess() bool + func (p *TStringBigSetKVServiceBsMultiPutResult) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsMultiPutResult) ReadField0(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsMultiPutResult) String() string + func (p *TStringBigSetKVServiceBsMultiPutResult) Write(oprot thrift.TProtocol) error + type TStringBigSetKVServiceBsPutItemArgs struct + BsName TStringKey + Item *TItem + func NewTStringBigSetKVServiceBsPutItemArgs() *TStringBigSetKVServiceBsPutItemArgs + func (p *TStringBigSetKVServiceBsPutItemArgs) GetBsName() TStringKey + func (p *TStringBigSetKVServiceBsPutItemArgs) GetItem() *TItem + func (p *TStringBigSetKVServiceBsPutItemArgs) IsSetItem() bool + func (p *TStringBigSetKVServiceBsPutItemArgs) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsPutItemArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsPutItemArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsPutItemArgs) String() string + func (p *TStringBigSetKVServiceBsPutItemArgs) Write(oprot thrift.TProtocol) error + type TStringBigSetKVServiceBsPutItemResult struct + Success *TPutItemResult_ + func NewTStringBigSetKVServiceBsPutItemResult() *TStringBigSetKVServiceBsPutItemResult + func (p *TStringBigSetKVServiceBsPutItemResult) GetSuccess() *TPutItemResult_ + func (p *TStringBigSetKVServiceBsPutItemResult) IsSetSuccess() bool + func (p *TStringBigSetKVServiceBsPutItemResult) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsPutItemResult) ReadField0(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsPutItemResult) String() string + func (p *TStringBigSetKVServiceBsPutItemResult) Write(oprot thrift.TProtocol) error + type TStringBigSetKVServiceBsRangeQueryArgs struct + BsName TStringKey + EndKey TItemKey + StartKey TItemKey + func NewTStringBigSetKVServiceBsRangeQueryArgs() *TStringBigSetKVServiceBsRangeQueryArgs + func (p *TStringBigSetKVServiceBsRangeQueryArgs) GetBsName() TStringKey + func (p *TStringBigSetKVServiceBsRangeQueryArgs) GetEndKey() TItemKey + func (p *TStringBigSetKVServiceBsRangeQueryArgs) GetStartKey() TItemKey + func (p *TStringBigSetKVServiceBsRangeQueryArgs) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsRangeQueryArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsRangeQueryArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsRangeQueryArgs) ReadField3(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsRangeQueryArgs) String() string + func (p *TStringBigSetKVServiceBsRangeQueryArgs) Write(oprot thrift.TProtocol) error + type TStringBigSetKVServiceBsRangeQueryResult struct + Success *TItemSetResult_ + func NewTStringBigSetKVServiceBsRangeQueryResult() *TStringBigSetKVServiceBsRangeQueryResult + func (p *TStringBigSetKVServiceBsRangeQueryResult) GetSuccess() *TItemSetResult_ + func (p *TStringBigSetKVServiceBsRangeQueryResult) IsSetSuccess() bool + func (p *TStringBigSetKVServiceBsRangeQueryResult) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsRangeQueryResult) ReadField0(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsRangeQueryResult) String() string + func (p *TStringBigSetKVServiceBsRangeQueryResult) Write(oprot thrift.TProtocol) error + type TStringBigSetKVServiceBsRemoveItemArgs struct + BsName TStringKey + ItemKey TItemKey + func NewTStringBigSetKVServiceBsRemoveItemArgs() *TStringBigSetKVServiceBsRemoveItemArgs + func (p *TStringBigSetKVServiceBsRemoveItemArgs) GetBsName() TStringKey + func (p *TStringBigSetKVServiceBsRemoveItemArgs) GetItemKey() TItemKey + func (p *TStringBigSetKVServiceBsRemoveItemArgs) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsRemoveItemArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsRemoveItemArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsRemoveItemArgs) String() string + func (p *TStringBigSetKVServiceBsRemoveItemArgs) Write(oprot thrift.TProtocol) error + type TStringBigSetKVServiceBsRemoveItemResult struct + Success *bool + func NewTStringBigSetKVServiceBsRemoveItemResult() *TStringBigSetKVServiceBsRemoveItemResult + func (p *TStringBigSetKVServiceBsRemoveItemResult) GetSuccess() bool + func (p *TStringBigSetKVServiceBsRemoveItemResult) IsSetSuccess() bool + func (p *TStringBigSetKVServiceBsRemoveItemResult) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsRemoveItemResult) ReadField0(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceBsRemoveItemResult) String() string + func (p *TStringBigSetKVServiceBsRemoveItemResult) Write(oprot thrift.TProtocol) error + type TStringBigSetKVServiceClient struct + func NewTStringBigSetKVServiceClient(c thrift.TClient) *TStringBigSetKVServiceClient + func NewTStringBigSetKVServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *TStringBigSetKVServiceClient + func NewTStringBigSetKVServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *TStringBigSetKVServiceClient + func (p *TStringBigSetKVServiceClient) AssignBigSetName(ctx context.Context, bsName TStringKey, bigsetID TContainerKey) (r *TBigSetInfoResult_, err error) + func (p *TStringBigSetKVServiceClient) BsBulkLoad(ctx context.Context, bsName TStringKey, setData *TItemSet) (r bool, err error) + func (p *TStringBigSetKVServiceClient) BsExisted(ctx context.Context, bsName TStringKey, itemKey TItemKey) (r *TExistedResult_, err error) + func (p *TStringBigSetKVServiceClient) BsGetItem(ctx context.Context, bsName TStringKey, itemKey TItemKey) (r *TItemResult_, err error) + func (p *TStringBigSetKVServiceClient) BsGetSlice(ctx context.Context, bsName TStringKey, fromPos int32, count int32) (r *TItemSetResult_, err error) + func (p *TStringBigSetKVServiceClient) BsGetSliceFromItem(ctx context.Context, bsName TStringKey, fromKey TItemKey, count int32) (r *TItemSetResult_, err error) + func (p *TStringBigSetKVServiceClient) BsGetSliceFromItemR(ctx context.Context, bsName TStringKey, fromKey TItemKey, count int32) (r *TItemSetResult_, err error) + func (p *TStringBigSetKVServiceClient) BsGetSliceR(ctx context.Context, bsName TStringKey, fromPos int32, count int32) (r *TItemSetResult_, err error) + func (p *TStringBigSetKVServiceClient) BsMultiPut(ctx context.Context, bsName TStringKey, setData *TItemSet, getAddedItems bool, ...) (r *TMultiPutItemResult_, err error) + func (p *TStringBigSetKVServiceClient) BsPutItem(ctx context.Context, bsName TStringKey, item *TItem) (r *TPutItemResult_, err error) + func (p *TStringBigSetKVServiceClient) BsRangeQuery(ctx context.Context, bsName TStringKey, startKey TItemKey, endKey TItemKey) (r *TItemSetResult_, err error) + func (p *TStringBigSetKVServiceClient) BsRemoveItem(ctx context.Context, bsName TStringKey, itemKey TItemKey) (r bool, err error) + func (p *TStringBigSetKVServiceClient) Client_() thrift.TClient + func (p *TStringBigSetKVServiceClient) CreateStringBigSet(ctx context.Context, bsName TStringKey) (r *TBigSetInfoResult_, err error) + func (p *TStringBigSetKVServiceClient) GetBigSetInfoByName(ctx context.Context, bsName TStringKey) (r *TBigSetInfoResult_, err error) + func (p *TStringBigSetKVServiceClient) GetListKey(ctx context.Context, fromIndex int64, count int32) (r []TStringKey, err error) + func (p *TStringBigSetKVServiceClient) GetListKeyFrom(ctx context.Context, keyFrom TStringKey, count int32) (r []TStringKey, err error) + func (p *TStringBigSetKVServiceClient) GetTotalCount(ctx context.Context, bsName TStringKey) (r int64, err error) + func (p *TStringBigSetKVServiceClient) RemoveAll(ctx context.Context, bsName TStringKey) (r int64, err error) + func (p *TStringBigSetKVServiceClient) TotalStringKeyCount(ctx context.Context) (r int64, err error) + type TStringBigSetKVServiceCreateStringBigSetArgs struct + BsName TStringKey + func NewTStringBigSetKVServiceCreateStringBigSetArgs() *TStringBigSetKVServiceCreateStringBigSetArgs + func (p *TStringBigSetKVServiceCreateStringBigSetArgs) GetBsName() TStringKey + func (p *TStringBigSetKVServiceCreateStringBigSetArgs) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceCreateStringBigSetArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceCreateStringBigSetArgs) String() string + func (p *TStringBigSetKVServiceCreateStringBigSetArgs) Write(oprot thrift.TProtocol) error + type TStringBigSetKVServiceCreateStringBigSetResult struct + Success *TBigSetInfoResult_ + func NewTStringBigSetKVServiceCreateStringBigSetResult() *TStringBigSetKVServiceCreateStringBigSetResult + func (p *TStringBigSetKVServiceCreateStringBigSetResult) GetSuccess() *TBigSetInfoResult_ + func (p *TStringBigSetKVServiceCreateStringBigSetResult) IsSetSuccess() bool + func (p *TStringBigSetKVServiceCreateStringBigSetResult) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceCreateStringBigSetResult) ReadField0(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceCreateStringBigSetResult) String() string + func (p *TStringBigSetKVServiceCreateStringBigSetResult) Write(oprot thrift.TProtocol) error + type TStringBigSetKVServiceGetBigSetInfoByNameArgs struct + BsName TStringKey + func NewTStringBigSetKVServiceGetBigSetInfoByNameArgs() *TStringBigSetKVServiceGetBigSetInfoByNameArgs + func (p *TStringBigSetKVServiceGetBigSetInfoByNameArgs) GetBsName() TStringKey + func (p *TStringBigSetKVServiceGetBigSetInfoByNameArgs) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceGetBigSetInfoByNameArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceGetBigSetInfoByNameArgs) String() string + func (p *TStringBigSetKVServiceGetBigSetInfoByNameArgs) Write(oprot thrift.TProtocol) error + type TStringBigSetKVServiceGetBigSetInfoByNameResult struct + Success *TBigSetInfoResult_ + func NewTStringBigSetKVServiceGetBigSetInfoByNameResult() *TStringBigSetKVServiceGetBigSetInfoByNameResult + func (p *TStringBigSetKVServiceGetBigSetInfoByNameResult) GetSuccess() *TBigSetInfoResult_ + func (p *TStringBigSetKVServiceGetBigSetInfoByNameResult) IsSetSuccess() bool + func (p *TStringBigSetKVServiceGetBigSetInfoByNameResult) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceGetBigSetInfoByNameResult) ReadField0(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceGetBigSetInfoByNameResult) String() string + func (p *TStringBigSetKVServiceGetBigSetInfoByNameResult) Write(oprot thrift.TProtocol) error + type TStringBigSetKVServiceGetListKeyArgs struct + Count int32 + FromIndex int64 + func NewTStringBigSetKVServiceGetListKeyArgs() *TStringBigSetKVServiceGetListKeyArgs + func (p *TStringBigSetKVServiceGetListKeyArgs) GetCount() int32 + func (p *TStringBigSetKVServiceGetListKeyArgs) GetFromIndex() int64 + func (p *TStringBigSetKVServiceGetListKeyArgs) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceGetListKeyArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceGetListKeyArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceGetListKeyArgs) String() string + func (p *TStringBigSetKVServiceGetListKeyArgs) Write(oprot thrift.TProtocol) error + type TStringBigSetKVServiceGetListKeyFromArgs struct + Count int32 + KeyFrom TStringKey + func NewTStringBigSetKVServiceGetListKeyFromArgs() *TStringBigSetKVServiceGetListKeyFromArgs + func (p *TStringBigSetKVServiceGetListKeyFromArgs) GetCount() int32 + func (p *TStringBigSetKVServiceGetListKeyFromArgs) GetKeyFrom() TStringKey + func (p *TStringBigSetKVServiceGetListKeyFromArgs) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceGetListKeyFromArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceGetListKeyFromArgs) ReadField2(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceGetListKeyFromArgs) String() string + func (p *TStringBigSetKVServiceGetListKeyFromArgs) Write(oprot thrift.TProtocol) error + type TStringBigSetKVServiceGetListKeyFromResult struct + Success []TStringKey + func NewTStringBigSetKVServiceGetListKeyFromResult() *TStringBigSetKVServiceGetListKeyFromResult + func (p *TStringBigSetKVServiceGetListKeyFromResult) GetSuccess() []TStringKey + func (p *TStringBigSetKVServiceGetListKeyFromResult) IsSetSuccess() bool + func (p *TStringBigSetKVServiceGetListKeyFromResult) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceGetListKeyFromResult) ReadField0(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceGetListKeyFromResult) String() string + func (p *TStringBigSetKVServiceGetListKeyFromResult) Write(oprot thrift.TProtocol) error + type TStringBigSetKVServiceGetListKeyResult struct + Success []TStringKey + func NewTStringBigSetKVServiceGetListKeyResult() *TStringBigSetKVServiceGetListKeyResult + func (p *TStringBigSetKVServiceGetListKeyResult) GetSuccess() []TStringKey + func (p *TStringBigSetKVServiceGetListKeyResult) IsSetSuccess() bool + func (p *TStringBigSetKVServiceGetListKeyResult) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceGetListKeyResult) ReadField0(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceGetListKeyResult) String() string + func (p *TStringBigSetKVServiceGetListKeyResult) Write(oprot thrift.TProtocol) error + type TStringBigSetKVServiceGetTotalCountArgs struct + BsName TStringKey + func NewTStringBigSetKVServiceGetTotalCountArgs() *TStringBigSetKVServiceGetTotalCountArgs + func (p *TStringBigSetKVServiceGetTotalCountArgs) GetBsName() TStringKey + func (p *TStringBigSetKVServiceGetTotalCountArgs) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceGetTotalCountArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceGetTotalCountArgs) String() string + func (p *TStringBigSetKVServiceGetTotalCountArgs) Write(oprot thrift.TProtocol) error + type TStringBigSetKVServiceGetTotalCountResult struct + Success *int64 + func NewTStringBigSetKVServiceGetTotalCountResult() *TStringBigSetKVServiceGetTotalCountResult + func (p *TStringBigSetKVServiceGetTotalCountResult) GetSuccess() int64 + func (p *TStringBigSetKVServiceGetTotalCountResult) IsSetSuccess() bool + func (p *TStringBigSetKVServiceGetTotalCountResult) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceGetTotalCountResult) ReadField0(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceGetTotalCountResult) String() string + func (p *TStringBigSetKVServiceGetTotalCountResult) Write(oprot thrift.TProtocol) error + type TStringBigSetKVServiceProcessor struct + func NewTStringBigSetKVServiceProcessor(handler TStringBigSetKVService) *TStringBigSetKVServiceProcessor + func (p *TStringBigSetKVServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction) + func (p *TStringBigSetKVServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool) + func (p *TStringBigSetKVServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) + func (p *TStringBigSetKVServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction + type TStringBigSetKVServiceRemoveAllArgs struct + BsName TStringKey + func NewTStringBigSetKVServiceRemoveAllArgs() *TStringBigSetKVServiceRemoveAllArgs + func (p *TStringBigSetKVServiceRemoveAllArgs) GetBsName() TStringKey + func (p *TStringBigSetKVServiceRemoveAllArgs) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceRemoveAllArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceRemoveAllArgs) String() string + func (p *TStringBigSetKVServiceRemoveAllArgs) Write(oprot thrift.TProtocol) error + type TStringBigSetKVServiceRemoveAllResult struct + Success *int64 + func NewTStringBigSetKVServiceRemoveAllResult() *TStringBigSetKVServiceRemoveAllResult + func (p *TStringBigSetKVServiceRemoveAllResult) GetSuccess() int64 + func (p *TStringBigSetKVServiceRemoveAllResult) IsSetSuccess() bool + func (p *TStringBigSetKVServiceRemoveAllResult) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceRemoveAllResult) ReadField0(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceRemoveAllResult) String() string + func (p *TStringBigSetKVServiceRemoveAllResult) Write(oprot thrift.TProtocol) error + type TStringBigSetKVServiceTotalStringKeyCountArgs struct + func NewTStringBigSetKVServiceTotalStringKeyCountArgs() *TStringBigSetKVServiceTotalStringKeyCountArgs + func (p *TStringBigSetKVServiceTotalStringKeyCountArgs) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceTotalStringKeyCountArgs) String() string + func (p *TStringBigSetKVServiceTotalStringKeyCountArgs) Write(oprot thrift.TProtocol) error + type TStringBigSetKVServiceTotalStringKeyCountResult struct + Success *int64 + func NewTStringBigSetKVServiceTotalStringKeyCountResult() *TStringBigSetKVServiceTotalStringKeyCountResult + func (p *TStringBigSetKVServiceTotalStringKeyCountResult) GetSuccess() int64 + func (p *TStringBigSetKVServiceTotalStringKeyCountResult) IsSetSuccess() bool + func (p *TStringBigSetKVServiceTotalStringKeyCountResult) Read(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceTotalStringKeyCountResult) ReadField0(iprot thrift.TProtocol) error + func (p *TStringBigSetKVServiceTotalStringKeyCountResult) String() string + func (p *TStringBigSetKVServiceTotalStringKeyCountResult) Write(oprot thrift.TProtocol) error + type TStringKey string + func TStringKeyPtr(v TStringKey) *TStringKey