generic

package
v0.0.0-...-c5b983b Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 16, 2020 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var GoUnusedProtection__ int
View Source
var MasterMetaServiceSetMetaIDResult_Success_DEFAULT bool
View Source
var TBSGenericDataServiceBsgBulkLoadResult_Success_DEFAULT bool
View Source
var TBSGenericDataServiceBsgRemoveItemResult_Success_DEFAULT bool
View Source
var TBSGenericDataServiceGetTotalCountResult_Success_DEFAULT int64
View Source
var TBSGenericDataServiceRemoveAllResult_Success_DEFAULT int64
View Source
var TBigSetGenericData_Children_DEFAULT []*TMetaItem
View Source
var TCluserOrdinatorServicePutResult_Success_DEFAULT int32
View Source
var TIBSDataServiceBulkLoadResult_Success_DEFAULT bool
View Source
var TIBSDataServiceGetTotalCountResult_Success_DEFAULT int64
View Source
var TIBSDataServiceRemoveAllResult_Success_DEFAULT int64
View Source
var TIBSDataServiceRemoveItemResult_Success_DEFAULT bool
View Source
var TMultiPutItemResult__Added_DEFAULT []TItemKey
View Source
var TMultiPutItemResult__Replaced_DEFAULT []*TItem
View Source
var TStringBigSetInfo_Count_DEFAULT int64
View Source
var TStringBigSetKVServiceBsBulkLoadResult_Success_DEFAULT bool
View Source
var TStringBigSetKVServiceBsRemoveItemResult_Success_DEFAULT bool
View Source
var TStringBigSetKVServiceGetListKeyFromResult_Success_DEFAULT []TStringKey
View Source
var TStringBigSetKVServiceGetListKeyResult_Success_DEFAULT []TStringKey
View Source
var TStringBigSetKVServiceGetTotalCountResult_Success_DEFAULT int64
View Source
var TStringBigSetKVServiceRemoveAllResult_Success_DEFAULT int64
View Source
var TStringBigSetKVServiceTotalStringKeyCountResult_Success_DEFAULT int64

Functions

This section is empty.

Types

type BSNotificationPool

type BSNotificationPool interface {
	// Parameters:
	//  - RootID
	//  - SplitInfo
	NeedSplit(ctx context.Context, rootID TContainerKey, splitInfo *TNeedSplitInfo) (err error)
	// Parameters:
	//  - RootID
	SplitInfoUpdated(ctx context.Context, rootID TContainerKey) (err error)
	GetJob(ctx context.Context) (r *SplitJob, err error)
}

type BSNotificationPoolClient

type BSNotificationPoolClient struct {
	// contains filtered or unexported fields
}

func NewBSNotificationPoolClient

func NewBSNotificationPoolClient(c thrift.TClient) *BSNotificationPoolClient

func NewBSNotificationPoolClientProtocol

func NewBSNotificationPoolClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *BSNotificationPoolClient

func (*BSNotificationPoolClient) Client_

func (*BSNotificationPoolClient) GetJob

func (p *BSNotificationPoolClient) GetJob(ctx context.Context) (r *SplitJob, err error)

func (*BSNotificationPoolClient) NeedSplit

func (p *BSNotificationPoolClient) NeedSplit(ctx context.Context, rootID TContainerKey, splitInfo *TNeedSplitInfo) (err error)

Parameters:

  • RootID
  • SplitInfo

func (*BSNotificationPoolClient) SplitInfoUpdated

func (p *BSNotificationPoolClient) SplitInfoUpdated(ctx context.Context, rootID TContainerKey) (err error)

Parameters:

  • RootID

type BSNotificationPoolGetJobArgs

type BSNotificationPoolGetJobArgs struct {
}

func NewBSNotificationPoolGetJobArgs

func NewBSNotificationPoolGetJobArgs() *BSNotificationPoolGetJobArgs

func (*BSNotificationPoolGetJobArgs) Read

func (*BSNotificationPoolGetJobArgs) String

func (*BSNotificationPoolGetJobArgs) Write

type BSNotificationPoolGetJobResult

type BSNotificationPoolGetJobResult struct {
	Success *SplitJob `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewBSNotificationPoolGetJobResult

func NewBSNotificationPoolGetJobResult() *BSNotificationPoolGetJobResult

func (*BSNotificationPoolGetJobResult) GetSuccess

func (p *BSNotificationPoolGetJobResult) GetSuccess() *SplitJob

func (*BSNotificationPoolGetJobResult) IsSetSuccess

func (p *BSNotificationPoolGetJobResult) IsSetSuccess() bool

func (*BSNotificationPoolGetJobResult) Read

func (*BSNotificationPoolGetJobResult) ReadField0

func (*BSNotificationPoolGetJobResult) String

func (*BSNotificationPoolGetJobResult) Write

type BSNotificationPoolNeedSplitArgs

type BSNotificationPoolNeedSplitArgs struct {
	RootID    TContainerKey   `thrift:"rootID,1" db:"rootID" json:"rootID"`
	SplitInfo *TNeedSplitInfo `thrift:"splitInfo,2" db:"splitInfo" json:"splitInfo"`
}

Attributes:

  • RootID
  • SplitInfo

func NewBSNotificationPoolNeedSplitArgs

func NewBSNotificationPoolNeedSplitArgs() *BSNotificationPoolNeedSplitArgs

func (*BSNotificationPoolNeedSplitArgs) GetRootID

func (*BSNotificationPoolNeedSplitArgs) GetSplitInfo

func (*BSNotificationPoolNeedSplitArgs) IsSetSplitInfo

func (p *BSNotificationPoolNeedSplitArgs) IsSetSplitInfo() bool

func (*BSNotificationPoolNeedSplitArgs) Read

func (*BSNotificationPoolNeedSplitArgs) ReadField1

func (*BSNotificationPoolNeedSplitArgs) ReadField2

func (*BSNotificationPoolNeedSplitArgs) String

func (*BSNotificationPoolNeedSplitArgs) Write

type BSNotificationPoolNeedSplitResult

type BSNotificationPoolNeedSplitResult struct {
}

func NewBSNotificationPoolNeedSplitResult

func NewBSNotificationPoolNeedSplitResult() *BSNotificationPoolNeedSplitResult

func (*BSNotificationPoolNeedSplitResult) Read

func (*BSNotificationPoolNeedSplitResult) String

func (*BSNotificationPoolNeedSplitResult) Write

type BSNotificationPoolProcessor

type BSNotificationPoolProcessor struct {
	// contains filtered or unexported fields
}

func NewBSNotificationPoolProcessor

func NewBSNotificationPoolProcessor(handler BSNotificationPool) *BSNotificationPoolProcessor

func (*BSNotificationPoolProcessor) AddToProcessorMap

func (p *BSNotificationPoolProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)

func (*BSNotificationPoolProcessor) GetProcessorFunction

func (p *BSNotificationPoolProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)

func (*BSNotificationPoolProcessor) Process

func (p *BSNotificationPoolProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*BSNotificationPoolProcessor) ProcessorMap

type BSNotificationPoolSplitInfoUpdatedArgs

type BSNotificationPoolSplitInfoUpdatedArgs struct {
	RootID TContainerKey `thrift:"rootID,1" db:"rootID" json:"rootID"`
}

Attributes:

  • RootID

func NewBSNotificationPoolSplitInfoUpdatedArgs

func NewBSNotificationPoolSplitInfoUpdatedArgs() *BSNotificationPoolSplitInfoUpdatedArgs

func (*BSNotificationPoolSplitInfoUpdatedArgs) GetRootID

func (*BSNotificationPoolSplitInfoUpdatedArgs) Read

func (*BSNotificationPoolSplitInfoUpdatedArgs) ReadField1

func (*BSNotificationPoolSplitInfoUpdatedArgs) String

func (*BSNotificationPoolSplitInfoUpdatedArgs) Write

type BSNotificationPoolSplitInfoUpdatedResult

type BSNotificationPoolSplitInfoUpdatedResult struct {
}

func NewBSNotificationPoolSplitInfoUpdatedResult

func NewBSNotificationPoolSplitInfoUpdatedResult() *BSNotificationPoolSplitInfoUpdatedResult

func (*BSNotificationPoolSplitInfoUpdatedResult) Read

func (*BSNotificationPoolSplitInfoUpdatedResult) String

func (*BSNotificationPoolSplitInfoUpdatedResult) Write

type MasterMetaService

type MasterMetaService interface {
	// Parameters:
	//  - Key
	GetMetaID(ctx context.Context, key TKey) (r TMetaKey, err error)
	// Parameters:
	//  - Key
	//  - MetaID
	SetMetaID(ctx context.Context, key TKey, metaID TMetaKey) (r bool, err error)
}

type MasterMetaServiceClient

type MasterMetaServiceClient struct {
	// contains filtered or unexported fields
}

func NewMasterMetaServiceClient

func NewMasterMetaServiceClient(c thrift.TClient) *MasterMetaServiceClient

func NewMasterMetaServiceClientProtocol

func NewMasterMetaServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *MasterMetaServiceClient

func (*MasterMetaServiceClient) Client_

func (p *MasterMetaServiceClient) Client_() thrift.TClient

func (*MasterMetaServiceClient) GetMetaID

func (p *MasterMetaServiceClient) GetMetaID(ctx context.Context, key TKey) (r TMetaKey, err error)

Parameters:

  • Key

func (*MasterMetaServiceClient) SetMetaID

func (p *MasterMetaServiceClient) SetMetaID(ctx context.Context, key TKey, metaID TMetaKey) (r bool, err error)

Parameters:

  • Key
  • MetaID

type MasterMetaServiceGetMetaIDArgs

type MasterMetaServiceGetMetaIDArgs struct {
	Key TKey `thrift:"key,1" db:"key" json:"key"`
}

Attributes:

  • Key

func NewMasterMetaServiceGetMetaIDArgs

func NewMasterMetaServiceGetMetaIDArgs() *MasterMetaServiceGetMetaIDArgs

func (*MasterMetaServiceGetMetaIDArgs) GetKey

func (*MasterMetaServiceGetMetaIDArgs) Read

func (*MasterMetaServiceGetMetaIDArgs) ReadField1

func (*MasterMetaServiceGetMetaIDArgs) String

func (*MasterMetaServiceGetMetaIDArgs) Write

type MasterMetaServiceGetMetaIDResult

type MasterMetaServiceGetMetaIDResult struct {
	Success *TMetaKey `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewMasterMetaServiceGetMetaIDResult

func NewMasterMetaServiceGetMetaIDResult() *MasterMetaServiceGetMetaIDResult

func (*MasterMetaServiceGetMetaIDResult) GetSuccess

func (*MasterMetaServiceGetMetaIDResult) IsSetSuccess

func (p *MasterMetaServiceGetMetaIDResult) IsSetSuccess() bool

func (*MasterMetaServiceGetMetaIDResult) Read

func (*MasterMetaServiceGetMetaIDResult) ReadField0

func (*MasterMetaServiceGetMetaIDResult) String

func (*MasterMetaServiceGetMetaIDResult) Write

type MasterMetaServiceProcessor

type MasterMetaServiceProcessor struct {
	// contains filtered or unexported fields
}

func NewMasterMetaServiceProcessor

func NewMasterMetaServiceProcessor(handler MasterMetaService) *MasterMetaServiceProcessor

func (*MasterMetaServiceProcessor) AddToProcessorMap

func (p *MasterMetaServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)

func (*MasterMetaServiceProcessor) GetProcessorFunction

func (p *MasterMetaServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)

func (*MasterMetaServiceProcessor) Process

func (p *MasterMetaServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*MasterMetaServiceProcessor) ProcessorMap

type MasterMetaServiceSetMetaIDArgs

type MasterMetaServiceSetMetaIDArgs struct {
	Key    TKey     `thrift:"key,1" db:"key" json:"key"`
	MetaID TMetaKey `thrift:"metaID,2" db:"metaID" json:"metaID"`
}

Attributes:

  • Key
  • MetaID

func NewMasterMetaServiceSetMetaIDArgs

func NewMasterMetaServiceSetMetaIDArgs() *MasterMetaServiceSetMetaIDArgs

func (*MasterMetaServiceSetMetaIDArgs) GetKey

func (*MasterMetaServiceSetMetaIDArgs) GetMetaID

func (*MasterMetaServiceSetMetaIDArgs) Read

func (*MasterMetaServiceSetMetaIDArgs) ReadField1

func (*MasterMetaServiceSetMetaIDArgs) ReadField2

func (*MasterMetaServiceSetMetaIDArgs) String

func (*MasterMetaServiceSetMetaIDArgs) Write

type MasterMetaServiceSetMetaIDResult

type MasterMetaServiceSetMetaIDResult struct {
	Success *bool `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewMasterMetaServiceSetMetaIDResult

func NewMasterMetaServiceSetMetaIDResult() *MasterMetaServiceSetMetaIDResult

func (*MasterMetaServiceSetMetaIDResult) GetSuccess

func (p *MasterMetaServiceSetMetaIDResult) GetSuccess() bool

func (*MasterMetaServiceSetMetaIDResult) IsSetSuccess

func (p *MasterMetaServiceSetMetaIDResult) IsSetSuccess() bool

func (*MasterMetaServiceSetMetaIDResult) Read

func (*MasterMetaServiceSetMetaIDResult) ReadField0

func (*MasterMetaServiceSetMetaIDResult) String

func (*MasterMetaServiceSetMetaIDResult) Write

type SplitJob

type SplitJob struct {
	RootID    TContainerKey   `thrift:"rootID,1,required" db:"rootID" json:"rootID"`
	SplitInfo *TNeedSplitInfo `thrift:"splitInfo,2" db:"splitInfo" json:"splitInfo,omitempty"`
}

Attributes:

  • RootID
  • SplitInfo
var BSNotificationPoolGetJobResult_Success_DEFAULT *SplitJob

func NewSplitJob

func NewSplitJob() *SplitJob

func (*SplitJob) GetRootID

func (p *SplitJob) GetRootID() TContainerKey

func (*SplitJob) GetSplitInfo

func (p *SplitJob) GetSplitInfo() *TNeedSplitInfo

func (*SplitJob) IsSetSplitInfo

func (p *SplitJob) IsSetSplitInfo() bool

func (*SplitJob) Read

func (p *SplitJob) Read(iprot thrift.TProtocol) error

func (*SplitJob) ReadField1

func (p *SplitJob) ReadField1(iprot thrift.TProtocol) error

func (*SplitJob) ReadField2

func (p *SplitJob) ReadField2(iprot thrift.TProtocol) error

func (*SplitJob) String

func (p *SplitJob) String() string

func (*SplitJob) Write

func (p *SplitJob) Write(oprot thrift.TProtocol) error

type TBSBigValueService

type TBSBigValueService interface{}

type TBSBigValueServiceClient

type TBSBigValueServiceClient struct {
	// contains filtered or unexported fields
}

func NewTBSBigValueServiceClient

func NewTBSBigValueServiceClient(c thrift.TClient) *TBSBigValueServiceClient

func NewTBSBigValueServiceClientProtocol

func NewTBSBigValueServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *TBSBigValueServiceClient

func (*TBSBigValueServiceClient) Client_

type TBSBigValueServiceProcessor

type TBSBigValueServiceProcessor struct {
	// contains filtered or unexported fields
}

func NewTBSBigValueServiceProcessor

func NewTBSBigValueServiceProcessor(handler TBSBigValueService) *TBSBigValueServiceProcessor

func (*TBSBigValueServiceProcessor) AddToProcessorMap

func (p *TBSBigValueServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)

func (*TBSBigValueServiceProcessor) GetProcessorFunction

func (p *TBSBigValueServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)

func (*TBSBigValueServiceProcessor) Process

func (p *TBSBigValueServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*TBSBigValueServiceProcessor) ProcessorMap

type TBSGenericDataService

type TBSGenericDataService interface {
	// Parameters:
	//  - RootID
	//  - Item
	BsgPutItem(ctx context.Context, rootID TContainerKey, item *TItem) (r *TPutItemResult_, err error)
	// Parameters:
	//  - Key
	//  - ItemKey
	BsgRemoveItem(ctx context.Context, key TMetaKey, itemKey TItemKey) (r bool, err error)
	// Parameters:
	//  - RootID
	//  - ItemKey
	BsgExisted(ctx context.Context, rootID TContainerKey, itemKey TItemKey) (r *TExistedResult_, err error)
	// Parameters:
	//  - RootID
	//  - ItemKey
	BsgGetItem(ctx context.Context, rootID TContainerKey, itemKey TItemKey) (r *TItemResult_, err error)
	// Parameters:
	//  - RootID
	//  - FromIdx
	//  - Count
	BsgGetSlice(ctx context.Context, rootID TContainerKey, fromIdx int32, count int32) (r *TItemSetResult_, err error)
	// Parameters:
	//  - RootID
	//  - FromKey
	//  - Count
	BsgGetSliceFromItem(ctx context.Context, rootID TContainerKey, fromKey TItemKey, count int32) (r *TItemSetResult_, err error)
	// Parameters:
	//  - RootID
	//  - FromIdx
	//  - Count
	BsgGetSliceR(ctx context.Context, rootID TContainerKey, fromIdx int32, count int32) (r *TItemSetResult_, err error)
	// Parameters:
	//  - RootID
	//  - FromKey
	//  - Count
	BsgGetSliceFromItemR(ctx context.Context, rootID TContainerKey, fromKey TItemKey, count int32) (r *TItemSetResult_, err error)
	// Parameters:
	//  - RootID
	//  - BrotherRootID
	//  - CurrentSize
	SplitBigSet(ctx context.Context, rootID TContainerKey, brotherRootID TContainerKey, currentSize int64) (r *TSplitBigSetResult_, err error)
	// Parameters:
	//  - RootID
	//  - StartKey
	//  - EndKey
	BsgRangeQuery(ctx context.Context, rootID TContainerKey, startKey TItemKey, endKey TItemKey) (r *TItemSetResult_, err error)
	// Parameters:
	//  - RootID
	//  - SetData
	BsgBulkLoad(ctx context.Context, rootID TContainerKey, setData *TItemSet) (r bool, err error)
	// Parameters:
	//  - RootID
	//  - SetData
	//  - GetAddedItems
	//  - GetReplacedItems
	BsgMultiPut(ctx context.Context, rootID TContainerKey, setData *TItemSet, getAddedItems bool, getReplacedItems bool) (r *TMultiPutItemResult_, err error)
	// Parameters:
	//  - MetaID
	GetSetGenData(ctx context.Context, metaID TMetaKey) (r *TBigSetGenericData, err error)
	// Parameters:
	//  - MetaID
	//  - Metadata
	PutSetGenData(ctx context.Context, metaID TMetaKey, metadata *TBigSetGenericData) (err error)
	// Parameters:
	//  - RootID
	GetTotalCount(ctx context.Context, rootID TContainerKey) (r int64, err error)
	// Parameters:
	//  - RootID
	RemoveAll(ctx context.Context, rootID TContainerKey) (r int64, err error)
}

type TBSGenericDataServiceBsgBulkLoadArgs

type TBSGenericDataServiceBsgBulkLoadArgs struct {
	RootID  TContainerKey `thrift:"rootID,1" db:"rootID" json:"rootID"`
	SetData *TItemSet     `thrift:"setData,2" db:"setData" json:"setData"`
}

Attributes:

  • RootID
  • SetData

func NewTBSGenericDataServiceBsgBulkLoadArgs

func NewTBSGenericDataServiceBsgBulkLoadArgs() *TBSGenericDataServiceBsgBulkLoadArgs

func (*TBSGenericDataServiceBsgBulkLoadArgs) GetRootID

func (*TBSGenericDataServiceBsgBulkLoadArgs) GetSetData

func (*TBSGenericDataServiceBsgBulkLoadArgs) IsSetSetData

func (p *TBSGenericDataServiceBsgBulkLoadArgs) IsSetSetData() bool

func (*TBSGenericDataServiceBsgBulkLoadArgs) Read

func (*TBSGenericDataServiceBsgBulkLoadArgs) ReadField1

func (*TBSGenericDataServiceBsgBulkLoadArgs) ReadField2

func (*TBSGenericDataServiceBsgBulkLoadArgs) String

func (*TBSGenericDataServiceBsgBulkLoadArgs) Write

type TBSGenericDataServiceBsgBulkLoadResult

type TBSGenericDataServiceBsgBulkLoadResult struct {
	Success *bool `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTBSGenericDataServiceBsgBulkLoadResult

func NewTBSGenericDataServiceBsgBulkLoadResult() *TBSGenericDataServiceBsgBulkLoadResult

func (*TBSGenericDataServiceBsgBulkLoadResult) GetSuccess

func (*TBSGenericDataServiceBsgBulkLoadResult) IsSetSuccess

func (p *TBSGenericDataServiceBsgBulkLoadResult) IsSetSuccess() bool

func (*TBSGenericDataServiceBsgBulkLoadResult) Read

func (*TBSGenericDataServiceBsgBulkLoadResult) ReadField0

func (*TBSGenericDataServiceBsgBulkLoadResult) String

func (*TBSGenericDataServiceBsgBulkLoadResult) Write

type TBSGenericDataServiceBsgExistedArgs

type TBSGenericDataServiceBsgExistedArgs struct {
	RootID  TContainerKey `thrift:"rootID,1" db:"rootID" json:"rootID"`
	ItemKey TItemKey      `thrift:"itemKey,2" db:"itemKey" json:"itemKey"`
}

Attributes:

  • RootID
  • ItemKey

func NewTBSGenericDataServiceBsgExistedArgs

func NewTBSGenericDataServiceBsgExistedArgs() *TBSGenericDataServiceBsgExistedArgs

func (*TBSGenericDataServiceBsgExistedArgs) GetItemKey

func (*TBSGenericDataServiceBsgExistedArgs) GetRootID

func (*TBSGenericDataServiceBsgExistedArgs) Read

func (*TBSGenericDataServiceBsgExistedArgs) ReadField1

func (*TBSGenericDataServiceBsgExistedArgs) ReadField2

func (*TBSGenericDataServiceBsgExistedArgs) String

func (*TBSGenericDataServiceBsgExistedArgs) Write

type TBSGenericDataServiceBsgExistedResult

type TBSGenericDataServiceBsgExistedResult struct {
	Success *TExistedResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTBSGenericDataServiceBsgExistedResult

func NewTBSGenericDataServiceBsgExistedResult() *TBSGenericDataServiceBsgExistedResult

func (*TBSGenericDataServiceBsgExistedResult) GetSuccess

func (*TBSGenericDataServiceBsgExistedResult) IsSetSuccess

func (p *TBSGenericDataServiceBsgExistedResult) IsSetSuccess() bool

func (*TBSGenericDataServiceBsgExistedResult) Read

func (*TBSGenericDataServiceBsgExistedResult) ReadField0

func (*TBSGenericDataServiceBsgExistedResult) String

func (*TBSGenericDataServiceBsgExistedResult) Write

type TBSGenericDataServiceBsgGetItemArgs

type TBSGenericDataServiceBsgGetItemArgs struct {
	RootID  TContainerKey `thrift:"rootID,1" db:"rootID" json:"rootID"`
	ItemKey TItemKey      `thrift:"itemKey,2" db:"itemKey" json:"itemKey"`
}

Attributes:

  • RootID
  • ItemKey

func NewTBSGenericDataServiceBsgGetItemArgs

func NewTBSGenericDataServiceBsgGetItemArgs() *TBSGenericDataServiceBsgGetItemArgs

func (*TBSGenericDataServiceBsgGetItemArgs) GetItemKey

func (*TBSGenericDataServiceBsgGetItemArgs) GetRootID

func (*TBSGenericDataServiceBsgGetItemArgs) Read

func (*TBSGenericDataServiceBsgGetItemArgs) ReadField1

func (*TBSGenericDataServiceBsgGetItemArgs) ReadField2

func (*TBSGenericDataServiceBsgGetItemArgs) String

func (*TBSGenericDataServiceBsgGetItemArgs) Write

type TBSGenericDataServiceBsgGetItemResult

type TBSGenericDataServiceBsgGetItemResult struct {
	Success *TItemResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTBSGenericDataServiceBsgGetItemResult

func NewTBSGenericDataServiceBsgGetItemResult() *TBSGenericDataServiceBsgGetItemResult

func (*TBSGenericDataServiceBsgGetItemResult) GetSuccess

func (*TBSGenericDataServiceBsgGetItemResult) IsSetSuccess

func (p *TBSGenericDataServiceBsgGetItemResult) IsSetSuccess() bool

func (*TBSGenericDataServiceBsgGetItemResult) Read

func (*TBSGenericDataServiceBsgGetItemResult) ReadField0

func (*TBSGenericDataServiceBsgGetItemResult) String

func (*TBSGenericDataServiceBsgGetItemResult) Write

type TBSGenericDataServiceBsgGetSliceArgs

type TBSGenericDataServiceBsgGetSliceArgs struct {
	RootID  TContainerKey `thrift:"rootID,1" db:"rootID" json:"rootID"`
	FromIdx int32         `thrift:"fromIdx,2" db:"fromIdx" json:"fromIdx"`
	Count   int32         `thrift:"count,3" db:"count" json:"count"`
}

Attributes:

  • RootID
  • FromIdx
  • Count

func NewTBSGenericDataServiceBsgGetSliceArgs

func NewTBSGenericDataServiceBsgGetSliceArgs() *TBSGenericDataServiceBsgGetSliceArgs

func (*TBSGenericDataServiceBsgGetSliceArgs) GetCount

func (*TBSGenericDataServiceBsgGetSliceArgs) GetFromIdx

func (*TBSGenericDataServiceBsgGetSliceArgs) GetRootID

func (*TBSGenericDataServiceBsgGetSliceArgs) Read

func (*TBSGenericDataServiceBsgGetSliceArgs) ReadField1

func (*TBSGenericDataServiceBsgGetSliceArgs) ReadField2

func (*TBSGenericDataServiceBsgGetSliceArgs) ReadField3

func (*TBSGenericDataServiceBsgGetSliceArgs) String

func (*TBSGenericDataServiceBsgGetSliceArgs) Write

type TBSGenericDataServiceBsgGetSliceFromItemArgs

type TBSGenericDataServiceBsgGetSliceFromItemArgs struct {
	RootID  TContainerKey `thrift:"rootID,1" db:"rootID" json:"rootID"`
	FromKey TItemKey      `thrift:"fromKey,2" db:"fromKey" json:"fromKey"`
	Count   int32         `thrift:"count,3" db:"count" json:"count"`
}

Attributes:

  • RootID
  • FromKey
  • Count

func NewTBSGenericDataServiceBsgGetSliceFromItemArgs

func NewTBSGenericDataServiceBsgGetSliceFromItemArgs() *TBSGenericDataServiceBsgGetSliceFromItemArgs

func (*TBSGenericDataServiceBsgGetSliceFromItemArgs) GetCount

func (*TBSGenericDataServiceBsgGetSliceFromItemArgs) GetFromKey

func (*TBSGenericDataServiceBsgGetSliceFromItemArgs) GetRootID

func (*TBSGenericDataServiceBsgGetSliceFromItemArgs) Read

func (*TBSGenericDataServiceBsgGetSliceFromItemArgs) ReadField1

func (*TBSGenericDataServiceBsgGetSliceFromItemArgs) ReadField2

func (*TBSGenericDataServiceBsgGetSliceFromItemArgs) ReadField3

func (*TBSGenericDataServiceBsgGetSliceFromItemArgs) String

func (*TBSGenericDataServiceBsgGetSliceFromItemArgs) Write

type TBSGenericDataServiceBsgGetSliceFromItemRArgs

type TBSGenericDataServiceBsgGetSliceFromItemRArgs struct {
	RootID  TContainerKey `thrift:"rootID,1" db:"rootID" json:"rootID"`
	FromKey TItemKey      `thrift:"fromKey,2" db:"fromKey" json:"fromKey"`
	Count   int32         `thrift:"count,3" db:"count" json:"count"`
}

Attributes:

  • RootID
  • FromKey
  • Count

func NewTBSGenericDataServiceBsgGetSliceFromItemRArgs

func NewTBSGenericDataServiceBsgGetSliceFromItemRArgs() *TBSGenericDataServiceBsgGetSliceFromItemRArgs

func (*TBSGenericDataServiceBsgGetSliceFromItemRArgs) GetCount

func (*TBSGenericDataServiceBsgGetSliceFromItemRArgs) GetFromKey

func (*TBSGenericDataServiceBsgGetSliceFromItemRArgs) GetRootID

func (*TBSGenericDataServiceBsgGetSliceFromItemRArgs) Read

func (*TBSGenericDataServiceBsgGetSliceFromItemRArgs) ReadField1

func (*TBSGenericDataServiceBsgGetSliceFromItemRArgs) ReadField2

func (*TBSGenericDataServiceBsgGetSliceFromItemRArgs) ReadField3

func (*TBSGenericDataServiceBsgGetSliceFromItemRArgs) String

func (*TBSGenericDataServiceBsgGetSliceFromItemRArgs) Write

type TBSGenericDataServiceBsgGetSliceFromItemRResult

type TBSGenericDataServiceBsgGetSliceFromItemRResult struct {
	Success *TItemSetResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTBSGenericDataServiceBsgGetSliceFromItemRResult

func NewTBSGenericDataServiceBsgGetSliceFromItemRResult() *TBSGenericDataServiceBsgGetSliceFromItemRResult

func (*TBSGenericDataServiceBsgGetSliceFromItemRResult) GetSuccess

func (*TBSGenericDataServiceBsgGetSliceFromItemRResult) IsSetSuccess

func (*TBSGenericDataServiceBsgGetSliceFromItemRResult) Read

func (*TBSGenericDataServiceBsgGetSliceFromItemRResult) ReadField0

func (*TBSGenericDataServiceBsgGetSliceFromItemRResult) String

func (*TBSGenericDataServiceBsgGetSliceFromItemRResult) Write

type TBSGenericDataServiceBsgGetSliceFromItemResult

type TBSGenericDataServiceBsgGetSliceFromItemResult struct {
	Success *TItemSetResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTBSGenericDataServiceBsgGetSliceFromItemResult

func NewTBSGenericDataServiceBsgGetSliceFromItemResult() *TBSGenericDataServiceBsgGetSliceFromItemResult

func (*TBSGenericDataServiceBsgGetSliceFromItemResult) GetSuccess

func (*TBSGenericDataServiceBsgGetSliceFromItemResult) IsSetSuccess

func (*TBSGenericDataServiceBsgGetSliceFromItemResult) Read

func (*TBSGenericDataServiceBsgGetSliceFromItemResult) ReadField0

func (*TBSGenericDataServiceBsgGetSliceFromItemResult) String

func (*TBSGenericDataServiceBsgGetSliceFromItemResult) Write

type TBSGenericDataServiceBsgGetSliceRArgs

type TBSGenericDataServiceBsgGetSliceRArgs struct {
	RootID  TContainerKey `thrift:"rootID,1" db:"rootID" json:"rootID"`
	FromIdx int32         `thrift:"fromIdx,2" db:"fromIdx" json:"fromIdx"`
	Count   int32         `thrift:"count,3" db:"count" json:"count"`
}

Attributes:

  • RootID
  • FromIdx
  • Count

func NewTBSGenericDataServiceBsgGetSliceRArgs

func NewTBSGenericDataServiceBsgGetSliceRArgs() *TBSGenericDataServiceBsgGetSliceRArgs

func (*TBSGenericDataServiceBsgGetSliceRArgs) GetCount

func (*TBSGenericDataServiceBsgGetSliceRArgs) GetFromIdx

func (*TBSGenericDataServiceBsgGetSliceRArgs) GetRootID

func (*TBSGenericDataServiceBsgGetSliceRArgs) Read

func (*TBSGenericDataServiceBsgGetSliceRArgs) ReadField1

func (*TBSGenericDataServiceBsgGetSliceRArgs) ReadField2

func (*TBSGenericDataServiceBsgGetSliceRArgs) ReadField3

func (*TBSGenericDataServiceBsgGetSliceRArgs) String

func (*TBSGenericDataServiceBsgGetSliceRArgs) Write

type TBSGenericDataServiceBsgGetSliceRResult

type TBSGenericDataServiceBsgGetSliceRResult struct {
	Success *TItemSetResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTBSGenericDataServiceBsgGetSliceRResult

func NewTBSGenericDataServiceBsgGetSliceRResult() *TBSGenericDataServiceBsgGetSliceRResult

func (*TBSGenericDataServiceBsgGetSliceRResult) GetSuccess

func (*TBSGenericDataServiceBsgGetSliceRResult) IsSetSuccess

func (*TBSGenericDataServiceBsgGetSliceRResult) Read

func (*TBSGenericDataServiceBsgGetSliceRResult) ReadField0

func (*TBSGenericDataServiceBsgGetSliceRResult) String

func (*TBSGenericDataServiceBsgGetSliceRResult) Write

type TBSGenericDataServiceBsgGetSliceResult

type TBSGenericDataServiceBsgGetSliceResult struct {
	Success *TItemSetResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTBSGenericDataServiceBsgGetSliceResult

func NewTBSGenericDataServiceBsgGetSliceResult() *TBSGenericDataServiceBsgGetSliceResult

func (*TBSGenericDataServiceBsgGetSliceResult) GetSuccess

func (*TBSGenericDataServiceBsgGetSliceResult) IsSetSuccess

func (p *TBSGenericDataServiceBsgGetSliceResult) IsSetSuccess() bool

func (*TBSGenericDataServiceBsgGetSliceResult) Read

func (*TBSGenericDataServiceBsgGetSliceResult) ReadField0

func (*TBSGenericDataServiceBsgGetSliceResult) String

func (*TBSGenericDataServiceBsgGetSliceResult) Write

type TBSGenericDataServiceBsgMultiPutArgs

type TBSGenericDataServiceBsgMultiPutArgs struct {
	RootID           TContainerKey `thrift:"rootID,1" db:"rootID" json:"rootID"`
	SetData          *TItemSet     `thrift:"setData,2" db:"setData" json:"setData"`
	GetAddedItems    bool          `thrift:"getAddedItems,3" db:"getAddedItems" json:"getAddedItems"`
	GetReplacedItems bool          `thrift:"getReplacedItems,4" db:"getReplacedItems" json:"getReplacedItems"`
}

Attributes:

  • RootID
  • SetData
  • GetAddedItems
  • GetReplacedItems

func NewTBSGenericDataServiceBsgMultiPutArgs

func NewTBSGenericDataServiceBsgMultiPutArgs() *TBSGenericDataServiceBsgMultiPutArgs

func (*TBSGenericDataServiceBsgMultiPutArgs) GetGetAddedItems

func (p *TBSGenericDataServiceBsgMultiPutArgs) GetGetAddedItems() bool

func (*TBSGenericDataServiceBsgMultiPutArgs) GetGetReplacedItems

func (p *TBSGenericDataServiceBsgMultiPutArgs) GetGetReplacedItems() bool

func (*TBSGenericDataServiceBsgMultiPutArgs) GetRootID

func (*TBSGenericDataServiceBsgMultiPutArgs) GetSetData

func (*TBSGenericDataServiceBsgMultiPutArgs) IsSetSetData

func (p *TBSGenericDataServiceBsgMultiPutArgs) IsSetSetData() bool

func (*TBSGenericDataServiceBsgMultiPutArgs) Read

func (*TBSGenericDataServiceBsgMultiPutArgs) ReadField1

func (*TBSGenericDataServiceBsgMultiPutArgs) ReadField2

func (*TBSGenericDataServiceBsgMultiPutArgs) ReadField3

func (*TBSGenericDataServiceBsgMultiPutArgs) ReadField4

func (*TBSGenericDataServiceBsgMultiPutArgs) String

func (*TBSGenericDataServiceBsgMultiPutArgs) Write

type TBSGenericDataServiceBsgMultiPutResult

type TBSGenericDataServiceBsgMultiPutResult struct {
	Success *TMultiPutItemResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTBSGenericDataServiceBsgMultiPutResult

func NewTBSGenericDataServiceBsgMultiPutResult() *TBSGenericDataServiceBsgMultiPutResult

func (*TBSGenericDataServiceBsgMultiPutResult) GetSuccess

func (*TBSGenericDataServiceBsgMultiPutResult) IsSetSuccess

func (p *TBSGenericDataServiceBsgMultiPutResult) IsSetSuccess() bool

func (*TBSGenericDataServiceBsgMultiPutResult) Read

func (*TBSGenericDataServiceBsgMultiPutResult) ReadField0

func (*TBSGenericDataServiceBsgMultiPutResult) String

func (*TBSGenericDataServiceBsgMultiPutResult) Write

type TBSGenericDataServiceBsgPutItemArgs

type TBSGenericDataServiceBsgPutItemArgs struct {
	RootID TContainerKey `thrift:"rootID,1" db:"rootID" json:"rootID"`
	Item   *TItem        `thrift:"item,2" db:"item" json:"item"`
}

Attributes:

  • RootID
  • Item

func NewTBSGenericDataServiceBsgPutItemArgs

func NewTBSGenericDataServiceBsgPutItemArgs() *TBSGenericDataServiceBsgPutItemArgs

func (*TBSGenericDataServiceBsgPutItemArgs) GetItem

func (*TBSGenericDataServiceBsgPutItemArgs) GetRootID

func (*TBSGenericDataServiceBsgPutItemArgs) IsSetItem

func (*TBSGenericDataServiceBsgPutItemArgs) Read

func (*TBSGenericDataServiceBsgPutItemArgs) ReadField1

func (*TBSGenericDataServiceBsgPutItemArgs) ReadField2

func (*TBSGenericDataServiceBsgPutItemArgs) String

func (*TBSGenericDataServiceBsgPutItemArgs) Write

type TBSGenericDataServiceBsgPutItemResult

type TBSGenericDataServiceBsgPutItemResult struct {
	Success *TPutItemResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTBSGenericDataServiceBsgPutItemResult

func NewTBSGenericDataServiceBsgPutItemResult() *TBSGenericDataServiceBsgPutItemResult

func (*TBSGenericDataServiceBsgPutItemResult) GetSuccess

func (*TBSGenericDataServiceBsgPutItemResult) IsSetSuccess

func (p *TBSGenericDataServiceBsgPutItemResult) IsSetSuccess() bool

func (*TBSGenericDataServiceBsgPutItemResult) Read

func (*TBSGenericDataServiceBsgPutItemResult) ReadField0

func (*TBSGenericDataServiceBsgPutItemResult) String

func (*TBSGenericDataServiceBsgPutItemResult) Write

type TBSGenericDataServiceBsgRangeQueryArgs

type TBSGenericDataServiceBsgRangeQueryArgs struct {
	RootID   TContainerKey `thrift:"rootID,1" db:"rootID" json:"rootID"`
	StartKey TItemKey      `thrift:"startKey,2" db:"startKey" json:"startKey"`
	EndKey   TItemKey      `thrift:"endKey,3" db:"endKey" json:"endKey"`
}

Attributes:

  • RootID
  • StartKey
  • EndKey

func NewTBSGenericDataServiceBsgRangeQueryArgs

func NewTBSGenericDataServiceBsgRangeQueryArgs() *TBSGenericDataServiceBsgRangeQueryArgs

func (*TBSGenericDataServiceBsgRangeQueryArgs) GetEndKey

func (*TBSGenericDataServiceBsgRangeQueryArgs) GetRootID

func (*TBSGenericDataServiceBsgRangeQueryArgs) GetStartKey

func (*TBSGenericDataServiceBsgRangeQueryArgs) Read

func (*TBSGenericDataServiceBsgRangeQueryArgs) ReadField1

func (*TBSGenericDataServiceBsgRangeQueryArgs) ReadField2

func (*TBSGenericDataServiceBsgRangeQueryArgs) ReadField3

func (*TBSGenericDataServiceBsgRangeQueryArgs) String

func (*TBSGenericDataServiceBsgRangeQueryArgs) Write

type TBSGenericDataServiceBsgRangeQueryResult

type TBSGenericDataServiceBsgRangeQueryResult struct {
	Success *TItemSetResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTBSGenericDataServiceBsgRangeQueryResult

func NewTBSGenericDataServiceBsgRangeQueryResult() *TBSGenericDataServiceBsgRangeQueryResult

func (*TBSGenericDataServiceBsgRangeQueryResult) GetSuccess

func (*TBSGenericDataServiceBsgRangeQueryResult) IsSetSuccess

func (*TBSGenericDataServiceBsgRangeQueryResult) Read

func (*TBSGenericDataServiceBsgRangeQueryResult) ReadField0

func (*TBSGenericDataServiceBsgRangeQueryResult) String

func (*TBSGenericDataServiceBsgRangeQueryResult) Write

type TBSGenericDataServiceBsgRemoveItemArgs

type TBSGenericDataServiceBsgRemoveItemArgs struct {
	Key     TMetaKey `thrift:"key,1" db:"key" json:"key"`
	ItemKey TItemKey `thrift:"itemKey,2" db:"itemKey" json:"itemKey"`
}

Attributes:

  • Key
  • ItemKey

func NewTBSGenericDataServiceBsgRemoveItemArgs

func NewTBSGenericDataServiceBsgRemoveItemArgs() *TBSGenericDataServiceBsgRemoveItemArgs

func (*TBSGenericDataServiceBsgRemoveItemArgs) GetItemKey

func (*TBSGenericDataServiceBsgRemoveItemArgs) GetKey

func (*TBSGenericDataServiceBsgRemoveItemArgs) Read

func (*TBSGenericDataServiceBsgRemoveItemArgs) ReadField1

func (*TBSGenericDataServiceBsgRemoveItemArgs) ReadField2

func (*TBSGenericDataServiceBsgRemoveItemArgs) String

func (*TBSGenericDataServiceBsgRemoveItemArgs) Write

type TBSGenericDataServiceBsgRemoveItemResult

type TBSGenericDataServiceBsgRemoveItemResult struct {
	Success *bool `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTBSGenericDataServiceBsgRemoveItemResult

func NewTBSGenericDataServiceBsgRemoveItemResult() *TBSGenericDataServiceBsgRemoveItemResult

func (*TBSGenericDataServiceBsgRemoveItemResult) GetSuccess

func (*TBSGenericDataServiceBsgRemoveItemResult) IsSetSuccess

func (*TBSGenericDataServiceBsgRemoveItemResult) Read

func (*TBSGenericDataServiceBsgRemoveItemResult) ReadField0

func (*TBSGenericDataServiceBsgRemoveItemResult) String

func (*TBSGenericDataServiceBsgRemoveItemResult) Write

type TBSGenericDataServiceClient

type TBSGenericDataServiceClient struct {
	// contains filtered or unexported fields
}

func NewTBSGenericDataServiceClient

func NewTBSGenericDataServiceClient(c thrift.TClient) *TBSGenericDataServiceClient

func NewTBSGenericDataServiceClientProtocol

func NewTBSGenericDataServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *TBSGenericDataServiceClient

func (*TBSGenericDataServiceClient) BsgBulkLoad

func (p *TBSGenericDataServiceClient) BsgBulkLoad(ctx context.Context, rootID TContainerKey, setData *TItemSet) (r bool, err error)

Parameters:

  • RootID
  • SetData

func (*TBSGenericDataServiceClient) BsgExisted

func (p *TBSGenericDataServiceClient) BsgExisted(ctx context.Context, rootID TContainerKey, itemKey TItemKey) (r *TExistedResult_, err error)

Parameters:

  • RootID
  • ItemKey

func (*TBSGenericDataServiceClient) BsgGetItem

func (p *TBSGenericDataServiceClient) BsgGetItem(ctx context.Context, rootID TContainerKey, itemKey TItemKey) (r *TItemResult_, err error)

Parameters:

  • RootID
  • ItemKey

func (*TBSGenericDataServiceClient) BsgGetSlice

func (p *TBSGenericDataServiceClient) BsgGetSlice(ctx context.Context, rootID TContainerKey, fromIdx int32, count int32) (r *TItemSetResult_, err error)

Parameters:

  • RootID
  • FromIdx
  • Count

func (*TBSGenericDataServiceClient) BsgGetSliceFromItem

func (p *TBSGenericDataServiceClient) BsgGetSliceFromItem(ctx context.Context, rootID TContainerKey, fromKey TItemKey, count int32) (r *TItemSetResult_, err error)

Parameters:

  • RootID
  • FromKey
  • Count

func (*TBSGenericDataServiceClient) BsgGetSliceFromItemR

func (p *TBSGenericDataServiceClient) BsgGetSliceFromItemR(ctx context.Context, rootID TContainerKey, fromKey TItemKey, count int32) (r *TItemSetResult_, err error)

Parameters:

  • RootID
  • FromKey
  • Count

func (*TBSGenericDataServiceClient) BsgGetSliceR

func (p *TBSGenericDataServiceClient) BsgGetSliceR(ctx context.Context, rootID TContainerKey, fromIdx int32, count int32) (r *TItemSetResult_, err error)

Parameters:

  • RootID
  • FromIdx
  • Count

func (*TBSGenericDataServiceClient) BsgMultiPut

func (p *TBSGenericDataServiceClient) BsgMultiPut(ctx context.Context, rootID TContainerKey, setData *TItemSet, getAddedItems bool, getReplacedItems bool) (r *TMultiPutItemResult_, err error)

Parameters:

  • RootID
  • SetData
  • GetAddedItems
  • GetReplacedItems

func (*TBSGenericDataServiceClient) BsgPutItem

func (p *TBSGenericDataServiceClient) BsgPutItem(ctx context.Context, rootID TContainerKey, item *TItem) (r *TPutItemResult_, err error)

Parameters:

  • RootID
  • Item

func (*TBSGenericDataServiceClient) BsgRangeQuery

func (p *TBSGenericDataServiceClient) BsgRangeQuery(ctx context.Context, rootID TContainerKey, startKey TItemKey, endKey TItemKey) (r *TItemSetResult_, err error)

Parameters:

  • RootID
  • StartKey
  • EndKey

func (*TBSGenericDataServiceClient) BsgRemoveItem

func (p *TBSGenericDataServiceClient) BsgRemoveItem(ctx context.Context, key TMetaKey, itemKey TItemKey) (r bool, err error)

Parameters:

  • Key
  • ItemKey

func (*TBSGenericDataServiceClient) Client_

func (*TBSGenericDataServiceClient) GetSetGenData

func (p *TBSGenericDataServiceClient) GetSetGenData(ctx context.Context, metaID TMetaKey) (r *TBigSetGenericData, err error)

Parameters:

  • MetaID

func (*TBSGenericDataServiceClient) GetTotalCount

func (p *TBSGenericDataServiceClient) GetTotalCount(ctx context.Context, rootID TContainerKey) (r int64, err error)

Parameters:

  • RootID

func (*TBSGenericDataServiceClient) PutSetGenData

func (p *TBSGenericDataServiceClient) PutSetGenData(ctx context.Context, metaID TMetaKey, metadata *TBigSetGenericData) (err error)

Parameters:

  • MetaID
  • Metadata

func (*TBSGenericDataServiceClient) RemoveAll

func (p *TBSGenericDataServiceClient) RemoveAll(ctx context.Context, rootID TContainerKey) (r int64, err error)

Parameters:

  • RootID

func (*TBSGenericDataServiceClient) SplitBigSet

func (p *TBSGenericDataServiceClient) SplitBigSet(ctx context.Context, rootID TContainerKey, brotherRootID TContainerKey, currentSize int64) (r *TSplitBigSetResult_, err error)

Parameters:

  • RootID
  • BrotherRootID
  • CurrentSize

type TBSGenericDataServiceGetSetGenDataArgs

type TBSGenericDataServiceGetSetGenDataArgs struct {
	MetaID TMetaKey `thrift:"metaID,1" db:"metaID" json:"metaID"`
}

Attributes:

  • MetaID

func NewTBSGenericDataServiceGetSetGenDataArgs

func NewTBSGenericDataServiceGetSetGenDataArgs() *TBSGenericDataServiceGetSetGenDataArgs

func (*TBSGenericDataServiceGetSetGenDataArgs) GetMetaID

func (*TBSGenericDataServiceGetSetGenDataArgs) Read

func (*TBSGenericDataServiceGetSetGenDataArgs) ReadField1

func (*TBSGenericDataServiceGetSetGenDataArgs) String

func (*TBSGenericDataServiceGetSetGenDataArgs) Write

type TBSGenericDataServiceGetSetGenDataResult

type TBSGenericDataServiceGetSetGenDataResult struct {
	Success *TBigSetGenericData `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTBSGenericDataServiceGetSetGenDataResult

func NewTBSGenericDataServiceGetSetGenDataResult() *TBSGenericDataServiceGetSetGenDataResult

func (*TBSGenericDataServiceGetSetGenDataResult) GetSuccess

func (*TBSGenericDataServiceGetSetGenDataResult) IsSetSuccess

func (*TBSGenericDataServiceGetSetGenDataResult) Read

func (*TBSGenericDataServiceGetSetGenDataResult) ReadField0

func (*TBSGenericDataServiceGetSetGenDataResult) String

func (*TBSGenericDataServiceGetSetGenDataResult) Write

type TBSGenericDataServiceGetTotalCountArgs

type TBSGenericDataServiceGetTotalCountArgs struct {
	RootID TContainerKey `thrift:"rootID,1" db:"rootID" json:"rootID"`
}

Attributes:

  • RootID

func NewTBSGenericDataServiceGetTotalCountArgs

func NewTBSGenericDataServiceGetTotalCountArgs() *TBSGenericDataServiceGetTotalCountArgs

func (*TBSGenericDataServiceGetTotalCountArgs) GetRootID

func (*TBSGenericDataServiceGetTotalCountArgs) Read

func (*TBSGenericDataServiceGetTotalCountArgs) ReadField1

func (*TBSGenericDataServiceGetTotalCountArgs) String

func (*TBSGenericDataServiceGetTotalCountArgs) Write

type TBSGenericDataServiceGetTotalCountResult

type TBSGenericDataServiceGetTotalCountResult struct {
	Success *int64 `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTBSGenericDataServiceGetTotalCountResult

func NewTBSGenericDataServiceGetTotalCountResult() *TBSGenericDataServiceGetTotalCountResult

func (*TBSGenericDataServiceGetTotalCountResult) GetSuccess

func (*TBSGenericDataServiceGetTotalCountResult) IsSetSuccess

func (*TBSGenericDataServiceGetTotalCountResult) Read

func (*TBSGenericDataServiceGetTotalCountResult) ReadField0

func (*TBSGenericDataServiceGetTotalCountResult) String

func (*TBSGenericDataServiceGetTotalCountResult) Write

type TBSGenericDataServiceProcessor

type TBSGenericDataServiceProcessor struct {
	// contains filtered or unexported fields
}

func NewTBSGenericDataServiceProcessor

func NewTBSGenericDataServiceProcessor(handler TBSGenericDataService) *TBSGenericDataServiceProcessor

func (*TBSGenericDataServiceProcessor) AddToProcessorMap

func (p *TBSGenericDataServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)

func (*TBSGenericDataServiceProcessor) GetProcessorFunction

func (p *TBSGenericDataServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)

func (*TBSGenericDataServiceProcessor) Process

func (p *TBSGenericDataServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*TBSGenericDataServiceProcessor) ProcessorMap

type TBSGenericDataServicePutSetGenDataArgs

type TBSGenericDataServicePutSetGenDataArgs struct {
	MetaID   TMetaKey            `thrift:"metaID,1" db:"metaID" json:"metaID"`
	Metadata *TBigSetGenericData `thrift:"metadata,2" db:"metadata" json:"metadata"`
}

Attributes:

  • MetaID
  • Metadata

func NewTBSGenericDataServicePutSetGenDataArgs

func NewTBSGenericDataServicePutSetGenDataArgs() *TBSGenericDataServicePutSetGenDataArgs

func (*TBSGenericDataServicePutSetGenDataArgs) GetMetaID

func (*TBSGenericDataServicePutSetGenDataArgs) GetMetadata

func (*TBSGenericDataServicePutSetGenDataArgs) IsSetMetadata

func (p *TBSGenericDataServicePutSetGenDataArgs) IsSetMetadata() bool

func (*TBSGenericDataServicePutSetGenDataArgs) Read

func (*TBSGenericDataServicePutSetGenDataArgs) ReadField1

func (*TBSGenericDataServicePutSetGenDataArgs) ReadField2

func (*TBSGenericDataServicePutSetGenDataArgs) String

func (*TBSGenericDataServicePutSetGenDataArgs) Write

type TBSGenericDataServicePutSetGenDataResult

type TBSGenericDataServicePutSetGenDataResult struct {
}

func NewTBSGenericDataServicePutSetGenDataResult

func NewTBSGenericDataServicePutSetGenDataResult() *TBSGenericDataServicePutSetGenDataResult

func (*TBSGenericDataServicePutSetGenDataResult) Read

func (*TBSGenericDataServicePutSetGenDataResult) String

func (*TBSGenericDataServicePutSetGenDataResult) Write

type TBSGenericDataServiceRemoveAllArgs

type TBSGenericDataServiceRemoveAllArgs struct {
	RootID TContainerKey `thrift:"rootID,1" db:"rootID" json:"rootID"`
}

Attributes:

  • RootID

func NewTBSGenericDataServiceRemoveAllArgs

func NewTBSGenericDataServiceRemoveAllArgs() *TBSGenericDataServiceRemoveAllArgs

func (*TBSGenericDataServiceRemoveAllArgs) GetRootID

func (*TBSGenericDataServiceRemoveAllArgs) Read

func (*TBSGenericDataServiceRemoveAllArgs) ReadField1

func (*TBSGenericDataServiceRemoveAllArgs) String

func (*TBSGenericDataServiceRemoveAllArgs) Write

type TBSGenericDataServiceRemoveAllResult

type TBSGenericDataServiceRemoveAllResult struct {
	Success *int64 `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTBSGenericDataServiceRemoveAllResult

func NewTBSGenericDataServiceRemoveAllResult() *TBSGenericDataServiceRemoveAllResult

func (*TBSGenericDataServiceRemoveAllResult) GetSuccess

func (*TBSGenericDataServiceRemoveAllResult) IsSetSuccess

func (p *TBSGenericDataServiceRemoveAllResult) IsSetSuccess() bool

func (*TBSGenericDataServiceRemoveAllResult) Read

func (*TBSGenericDataServiceRemoveAllResult) ReadField0

func (*TBSGenericDataServiceRemoveAllResult) String

func (*TBSGenericDataServiceRemoveAllResult) Write

type TBSGenericDataServiceSplitBigSetArgs

type TBSGenericDataServiceSplitBigSetArgs struct {
	RootID        TContainerKey `thrift:"rootID,1" db:"rootID" json:"rootID"`
	BrotherRootID TContainerKey `thrift:"brotherRootID,2" db:"brotherRootID" json:"brotherRootID"`
	CurrentSize   int64         `thrift:"currentSize,3" db:"currentSize" json:"currentSize"`
}

Attributes:

  • RootID
  • BrotherRootID
  • CurrentSize

func NewTBSGenericDataServiceSplitBigSetArgs

func NewTBSGenericDataServiceSplitBigSetArgs() *TBSGenericDataServiceSplitBigSetArgs

func (*TBSGenericDataServiceSplitBigSetArgs) GetBrotherRootID

func (*TBSGenericDataServiceSplitBigSetArgs) GetCurrentSize

func (p *TBSGenericDataServiceSplitBigSetArgs) GetCurrentSize() int64

func (*TBSGenericDataServiceSplitBigSetArgs) GetRootID

func (*TBSGenericDataServiceSplitBigSetArgs) Read

func (*TBSGenericDataServiceSplitBigSetArgs) ReadField1

func (*TBSGenericDataServiceSplitBigSetArgs) ReadField2

func (*TBSGenericDataServiceSplitBigSetArgs) ReadField3

func (*TBSGenericDataServiceSplitBigSetArgs) String

func (*TBSGenericDataServiceSplitBigSetArgs) Write

type TBSGenericDataServiceSplitBigSetResult

type TBSGenericDataServiceSplitBigSetResult struct {
	Success *TSplitBigSetResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTBSGenericDataServiceSplitBigSetResult

func NewTBSGenericDataServiceSplitBigSetResult() *TBSGenericDataServiceSplitBigSetResult

func (*TBSGenericDataServiceSplitBigSetResult) GetSuccess

func (*TBSGenericDataServiceSplitBigSetResult) IsSetSuccess

func (p *TBSGenericDataServiceSplitBigSetResult) IsSetSuccess() bool

func (*TBSGenericDataServiceSplitBigSetResult) Read

func (*TBSGenericDataServiceSplitBigSetResult) ReadField0

func (*TBSGenericDataServiceSplitBigSetResult) String

func (*TBSGenericDataServiceSplitBigSetResult) Write

type TBigSetGenericData

type TBigSetGenericData struct {
	ParentID  TContainerKey   `thrift:"parentID,1" db:"parentID" json:"parentID"`
	Level     TLevelType      `thrift:"level,2" db:"level" json:"level"`
	Children  []*TMetaItem    `thrift:"children,3" db:"children" json:"children,omitempty"`
	Smallset  *TSmallSet      `thrift:"smallset,4" db:"smallset" json:"smallset,omitempty"`
	Splitinfo *TNeedSplitInfo `thrift:"splitinfo,5" db:"splitinfo" json:"splitinfo,omitempty"`
}

Attributes:

  • ParentID
  • Level
  • Children
  • Smallset
  • Splitinfo
var TBSGenericDataServiceGetSetGenDataResult_Success_DEFAULT *TBigSetGenericData
var TBSGenericDataServicePutSetGenDataArgs_Metadata_DEFAULT *TBigSetGenericData

func NewTBigSetGenericData

func NewTBigSetGenericData() *TBigSetGenericData

func (*TBigSetGenericData) GetChildren

func (p *TBigSetGenericData) GetChildren() []*TMetaItem

func (*TBigSetGenericData) GetLevel

func (p *TBigSetGenericData) GetLevel() TLevelType

func (*TBigSetGenericData) GetParentID

func (p *TBigSetGenericData) GetParentID() TContainerKey

func (*TBigSetGenericData) GetSmallset

func (p *TBigSetGenericData) GetSmallset() *TSmallSet

func (*TBigSetGenericData) GetSplitinfo

func (p *TBigSetGenericData) GetSplitinfo() *TNeedSplitInfo

func (*TBigSetGenericData) IsSetChildren

func (p *TBigSetGenericData) IsSetChildren() bool

func (*TBigSetGenericData) IsSetSmallset

func (p *TBigSetGenericData) IsSetSmallset() bool

func (*TBigSetGenericData) IsSetSplitinfo

func (p *TBigSetGenericData) IsSetSplitinfo() bool

func (*TBigSetGenericData) Read

func (p *TBigSetGenericData) Read(iprot thrift.TProtocol) error

func (*TBigSetGenericData) ReadField1

func (p *TBigSetGenericData) ReadField1(iprot thrift.TProtocol) error

func (*TBigSetGenericData) ReadField2

func (p *TBigSetGenericData) ReadField2(iprot thrift.TProtocol) error

func (*TBigSetGenericData) ReadField3

func (p *TBigSetGenericData) ReadField3(iprot thrift.TProtocol) error

func (*TBigSetGenericData) ReadField4

func (p *TBigSetGenericData) ReadField4(iprot thrift.TProtocol) error

func (*TBigSetGenericData) ReadField5

func (p *TBigSetGenericData) ReadField5(iprot thrift.TProtocol) error

func (*TBigSetGenericData) String

func (p *TBigSetGenericData) String() string

func (*TBigSetGenericData) Write

func (p *TBigSetGenericData) Write(oprot thrift.TProtocol) error

type TBigSetInfoResult_

type TBigSetInfoResult_ struct {
	Error TErrorCode         `thrift:"error,1,required" db:"error" json:"error"`
	Info  *TStringBigSetInfo `thrift:"info,2" db:"info" json:"info,omitempty"`
}

Attributes:

  • Error
  • Info
var TStringBigSetKVServiceAssignBigSetNameResult_Success_DEFAULT *TBigSetInfoResult_
var TStringBigSetKVServiceCreateStringBigSetResult_Success_DEFAULT *TBigSetInfoResult_
var TStringBigSetKVServiceGetBigSetInfoByNameResult_Success_DEFAULT *TBigSetInfoResult_

func NewTBigSetInfoResult_

func NewTBigSetInfoResult_() *TBigSetInfoResult_

func (*TBigSetInfoResult_) GetError

func (p *TBigSetInfoResult_) GetError() TErrorCode

func (*TBigSetInfoResult_) GetInfo

func (p *TBigSetInfoResult_) GetInfo() *TStringBigSetInfo

func (*TBigSetInfoResult_) IsSetInfo

func (p *TBigSetInfoResult_) IsSetInfo() bool

func (*TBigSetInfoResult_) Read

func (p *TBigSetInfoResult_) Read(iprot thrift.TProtocol) error

func (*TBigSetInfoResult_) ReadField1

func (p *TBigSetInfoResult_) ReadField1(iprot thrift.TProtocol) error

func (*TBigSetInfoResult_) ReadField2

func (p *TBigSetInfoResult_) ReadField2(iprot thrift.TProtocol) error

func (*TBigSetInfoResult_) String

func (p *TBigSetInfoResult_) String() string

func (*TBigSetInfoResult_) Write

func (p *TBigSetInfoResult_) Write(oprot thrift.TProtocol) error

type TCaSItem

type TCaSItem struct {
	ItemKey   TItemKey   `thrift:"itemKey,1" db:"itemKey" json:"itemKey"`
	OldValue  TItemValue `thrift:"oldValue,2" db:"oldValue" json:"oldValue"`
	NewValue_ TItemValue `thrift:"newValue,3" db:"newValue" json:"newValue"`
}

Attributes:

  • ItemKey
  • OldValue
  • NewValue_

func NewTCaSItem

func NewTCaSItem() *TCaSItem

func (*TCaSItem) GetItemKey

func (p *TCaSItem) GetItemKey() TItemKey

func (*TCaSItem) GetNewValue_

func (p *TCaSItem) GetNewValue_() TItemValue

func (*TCaSItem) GetOldValue

func (p *TCaSItem) GetOldValue() TItemValue

func (*TCaSItem) Read

func (p *TCaSItem) Read(iprot thrift.TProtocol) error

func (*TCaSItem) ReadField1

func (p *TCaSItem) ReadField1(iprot thrift.TProtocol) error

func (*TCaSItem) ReadField2

func (p *TCaSItem) ReadField2(iprot thrift.TProtocol) error

func (*TCaSItem) ReadField3

func (p *TCaSItem) ReadField3(iprot thrift.TProtocol) error

func (*TCaSItem) String

func (p *TCaSItem) String() string

func (*TCaSItem) Write

func (p *TCaSItem) Write(oprot thrift.TProtocol) error

type TCluserOrdinatorService

type TCluserOrdinatorService interface {
	// Parameters:
	//  - Key
	RemoveCache(ctx context.Context, key TContainerKey) (err error)
	// Parameters:
	//  - Key
	//  - Value
	Put(ctx context.Context, key []byte, value []byte) (r int32, err error)
}

type TCluserOrdinatorServiceClient

type TCluserOrdinatorServiceClient struct {
	// contains filtered or unexported fields
}

func NewTCluserOrdinatorServiceClient

func NewTCluserOrdinatorServiceClient(c thrift.TClient) *TCluserOrdinatorServiceClient

func NewTCluserOrdinatorServiceClientProtocol

func NewTCluserOrdinatorServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *TCluserOrdinatorServiceClient

func (*TCluserOrdinatorServiceClient) Client_

func (*TCluserOrdinatorServiceClient) Put

func (p *TCluserOrdinatorServiceClient) Put(ctx context.Context, key []byte, value []byte) (r int32, err error)

Parameters:

  • Key
  • Value

func (*TCluserOrdinatorServiceClient) RemoveCache

func (p *TCluserOrdinatorServiceClient) RemoveCache(ctx context.Context, key TContainerKey) (err error)

Parameters:

  • Key

type TCluserOrdinatorServiceProcessor

type TCluserOrdinatorServiceProcessor struct {
	// contains filtered or unexported fields
}

func (*TCluserOrdinatorServiceProcessor) AddToProcessorMap

func (p *TCluserOrdinatorServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)

func (*TCluserOrdinatorServiceProcessor) GetProcessorFunction

func (p *TCluserOrdinatorServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)

func (*TCluserOrdinatorServiceProcessor) Process

func (p *TCluserOrdinatorServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*TCluserOrdinatorServiceProcessor) ProcessorMap

type TCluserOrdinatorServicePutArgs

type TCluserOrdinatorServicePutArgs struct {
	Key   []byte `thrift:"key,1" db:"key" json:"key"`
	Value []byte `thrift:"value,2" db:"value" json:"value"`
}

Attributes:

  • Key
  • Value

func NewTCluserOrdinatorServicePutArgs

func NewTCluserOrdinatorServicePutArgs() *TCluserOrdinatorServicePutArgs

func (*TCluserOrdinatorServicePutArgs) GetKey

func (p *TCluserOrdinatorServicePutArgs) GetKey() []byte

func (*TCluserOrdinatorServicePutArgs) GetValue

func (p *TCluserOrdinatorServicePutArgs) GetValue() []byte

func (*TCluserOrdinatorServicePutArgs) Read

func (*TCluserOrdinatorServicePutArgs) ReadField1

func (*TCluserOrdinatorServicePutArgs) ReadField2

func (*TCluserOrdinatorServicePutArgs) String

func (*TCluserOrdinatorServicePutArgs) Write

type TCluserOrdinatorServicePutResult

type TCluserOrdinatorServicePutResult struct {
	Success *int32 `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTCluserOrdinatorServicePutResult

func NewTCluserOrdinatorServicePutResult() *TCluserOrdinatorServicePutResult

func (*TCluserOrdinatorServicePutResult) GetSuccess

func (p *TCluserOrdinatorServicePutResult) GetSuccess() int32

func (*TCluserOrdinatorServicePutResult) IsSetSuccess

func (p *TCluserOrdinatorServicePutResult) IsSetSuccess() bool

func (*TCluserOrdinatorServicePutResult) Read

func (*TCluserOrdinatorServicePutResult) ReadField0

func (*TCluserOrdinatorServicePutResult) String

func (*TCluserOrdinatorServicePutResult) Write

type TCluserOrdinatorServiceRemoveCacheArgs

type TCluserOrdinatorServiceRemoveCacheArgs struct {
	Key TContainerKey `thrift:"key,1" db:"key" json:"key"`
}

Attributes:

  • Key

func NewTCluserOrdinatorServiceRemoveCacheArgs

func NewTCluserOrdinatorServiceRemoveCacheArgs() *TCluserOrdinatorServiceRemoveCacheArgs

func (*TCluserOrdinatorServiceRemoveCacheArgs) GetKey

func (*TCluserOrdinatorServiceRemoveCacheArgs) Read

func (*TCluserOrdinatorServiceRemoveCacheArgs) ReadField1

func (*TCluserOrdinatorServiceRemoveCacheArgs) String

func (*TCluserOrdinatorServiceRemoveCacheArgs) Write

type TContainerKey

type TContainerKey int64

func TContainerKeyPtr

func TContainerKeyPtr(v TContainerKey) *TContainerKey

type TErrorCode

type TErrorCode int64
const (
	TErrorCode_EGood                           TErrorCode = 0
	TErrorCode_ENoRootMeta                     TErrorCode = 1
	TErrorCode_ECouldNotConnectMetadata        TErrorCode = 2
	TErrorCode_ECouldNotConnectIDGen           TErrorCode = 3
	TErrorCode_ECouldNotConnectSmallSet        TErrorCode = 4
	TErrorCode_ECouldNotConnectRootMetaMapping TErrorCode = 5
	TErrorCode_EItemNotExisted                 TErrorCode = 100
	TErrorCode_EUnknownException               TErrorCode = 10
	TErrorCode_EBigSetNotExisted               TErrorCode = 101
	TErrorCode_EBigSetCreated                  TErrorCode = 102
	TErrorCode_EBigSetAlreadyExisted           TErrorCode = 103
	TErrorCode_EBigSetAssigned                 TErrorCode = 104
)

func TErrorCodeFromString

func TErrorCodeFromString(s string) (TErrorCode, error)

func TErrorCodePtr

func TErrorCodePtr(v TErrorCode) *TErrorCode

func (TErrorCode) MarshalText

func (p TErrorCode) MarshalText() ([]byte, error)

func (*TErrorCode) Scan

func (p *TErrorCode) Scan(value interface{}) error

func (TErrorCode) String

func (p TErrorCode) String() string

func (*TErrorCode) UnmarshalText

func (p *TErrorCode) UnmarshalText(text []byte) error

func (*TErrorCode) Value

func (p *TErrorCode) Value() (driver.Value, error)

type TExistedResult_

type TExistedResult_ struct {
	Error   TErrorCode `thrift:"error,1" db:"error" json:"error"`
	Existed bool       `thrift:"existed,2" db:"existed" json:"existed"`
}

Attributes:

  • Error
  • Existed
var TBSGenericDataServiceBsgExistedResult_Success_DEFAULT *TExistedResult_
var TIBSDataServiceExistedResult_Success_DEFAULT *TExistedResult_
var TStringBigSetKVServiceBsExistedResult_Success_DEFAULT *TExistedResult_

func NewTExistedResult_

func NewTExistedResult_() *TExistedResult_

func (*TExistedResult_) GetError

func (p *TExistedResult_) GetError() TErrorCode

func (*TExistedResult_) GetExisted

func (p *TExistedResult_) GetExisted() bool

func (*TExistedResult_) Read

func (p *TExistedResult_) Read(iprot thrift.TProtocol) error

func (*TExistedResult_) ReadField1

func (p *TExistedResult_) ReadField1(iprot thrift.TProtocol) error

func (*TExistedResult_) ReadField2

func (p *TExistedResult_) ReadField2(iprot thrift.TProtocol) error

func (*TExistedResult_) String

func (p *TExistedResult_) String() string

func (*TExistedResult_) Write

func (p *TExistedResult_) Write(oprot thrift.TProtocol) error

type TGetSliceInfo

type TGetSliceInfo struct {
	SmallSetIDs  []TMetaKey `thrift:"smallSetIDs,1" db:"smallSetIDs" json:"smallSetIDs"`
	FirstIdxFrom int32      `thrift:"firstIdxFrom,2" db:"firstIdxFrom" json:"firstIdxFrom"`
}

Attributes:

  • SmallSetIDs
  • FirstIdxFrom

func NewTGetSliceInfo

func NewTGetSliceInfo() *TGetSliceInfo

func (*TGetSliceInfo) GetFirstIdxFrom

func (p *TGetSliceInfo) GetFirstIdxFrom() int32

func (*TGetSliceInfo) GetSmallSetIDs

func (p *TGetSliceInfo) GetSmallSetIDs() []TMetaKey

func (*TGetSliceInfo) Read

func (p *TGetSliceInfo) Read(iprot thrift.TProtocol) error

func (*TGetSliceInfo) ReadField1

func (p *TGetSliceInfo) ReadField1(iprot thrift.TProtocol) error

func (*TGetSliceInfo) ReadField2

func (p *TGetSliceInfo) ReadField2(iprot thrift.TProtocol) error

func (*TGetSliceInfo) String

func (p *TGetSliceInfo) String() string

func (*TGetSliceInfo) Write

func (p *TGetSliceInfo) Write(oprot thrift.TProtocol) error

type TIBSDataService

type TIBSDataService interface {
	// Parameters:
	//  - BigsetID
	//  - Item
	PutItem(ctx context.Context, bigsetID TKey, item *TItem) (r *TPutItemResult_, err error)
	// Parameters:
	//  - BigsetID
	//  - ItemKey
	RemoveItem(ctx context.Context, bigsetID TKey, itemKey TItemKey) (r bool, err error)
	// Parameters:
	//  - BigsetID
	//  - ItemKey
	Existed(ctx context.Context, bigsetID TKey, itemKey TItemKey) (r *TExistedResult_, err error)
	// Parameters:
	//  - BigsetID
	//  - ItemKey
	GetItem(ctx context.Context, bigsetID TKey, itemKey TItemKey) (r *TItemResult_, err error)
	// Parameters:
	//  - BigsetID
	//  - FromPos
	//  - Count
	GetSlice(ctx context.Context, bigsetID TKey, fromPos int32, count int32) (r *TItemSetResult_, err error)
	// Parameters:
	//  - BigsetID
	//  - FromKey
	//  - Count
	GetSliceFromItem(ctx context.Context, bigsetID TKey, fromKey TItemKey, count int32) (r *TItemSetResult_, err error)
	// Parameters:
	//  - BigsetID
	//  - FromPos
	//  - Count
	GetSliceR(ctx context.Context, bigsetID TKey, fromPos int32, count int32) (r *TItemSetResult_, err error)
	// Parameters:
	//  - BigsetID
	//  - FromKey
	//  - Count
	GetSliceFromItemR(ctx context.Context, bigsetID TKey, fromKey TItemKey, count int32) (r *TItemSetResult_, err error)
	// Parameters:
	//  - BigsetID
	//  - StartKey
	//  - EndKey
	RangeQuery(ctx context.Context, bigsetID TKey, startKey TItemKey, endKey TItemKey) (r *TItemSetResult_, err error)
	// Parameters:
	//  - BigsetID
	//  - SetData
	BulkLoad(ctx context.Context, bigsetID TKey, setData *TItemSet) (r bool, err error)
	// Parameters:
	//  - BigsetID
	//  - SetData
	//  - GetAddedItems
	//  - GetReplacedItems
	MultiPut(ctx context.Context, bigsetID TKey, setData *TItemSet, getAddedItems bool, getReplacedItems bool) (r *TMultiPutItemResult_, err error)
	// Parameters:
	//  - BigsetID
	GetTotalCount(ctx context.Context, bigsetID TKey) (r int64, err error)
	// Parameters:
	//  - BigsetID
	RemoveAll(ctx context.Context, bigsetID TKey) (r int64, err error)
}

type TIBSDataServiceBulkLoadArgs

type TIBSDataServiceBulkLoadArgs struct {
	BigsetID TKey      `thrift:"bigsetID,1" db:"bigsetID" json:"bigsetID"`
	SetData  *TItemSet `thrift:"setData,2" db:"setData" json:"setData"`
}

Attributes:

  • BigsetID
  • SetData

func NewTIBSDataServiceBulkLoadArgs

func NewTIBSDataServiceBulkLoadArgs() *TIBSDataServiceBulkLoadArgs

func (*TIBSDataServiceBulkLoadArgs) GetBigsetID

func (p *TIBSDataServiceBulkLoadArgs) GetBigsetID() TKey

func (*TIBSDataServiceBulkLoadArgs) GetSetData

func (p *TIBSDataServiceBulkLoadArgs) GetSetData() *TItemSet

func (*TIBSDataServiceBulkLoadArgs) IsSetSetData

func (p *TIBSDataServiceBulkLoadArgs) IsSetSetData() bool

func (*TIBSDataServiceBulkLoadArgs) Read

func (*TIBSDataServiceBulkLoadArgs) ReadField1

func (p *TIBSDataServiceBulkLoadArgs) ReadField1(iprot thrift.TProtocol) error

func (*TIBSDataServiceBulkLoadArgs) ReadField2

func (p *TIBSDataServiceBulkLoadArgs) ReadField2(iprot thrift.TProtocol) error

func (*TIBSDataServiceBulkLoadArgs) String

func (p *TIBSDataServiceBulkLoadArgs) String() string

func (*TIBSDataServiceBulkLoadArgs) Write

type TIBSDataServiceBulkLoadResult

type TIBSDataServiceBulkLoadResult struct {
	Success *bool `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTIBSDataServiceBulkLoadResult

func NewTIBSDataServiceBulkLoadResult() *TIBSDataServiceBulkLoadResult

func (*TIBSDataServiceBulkLoadResult) GetSuccess

func (p *TIBSDataServiceBulkLoadResult) GetSuccess() bool

func (*TIBSDataServiceBulkLoadResult) IsSetSuccess

func (p *TIBSDataServiceBulkLoadResult) IsSetSuccess() bool

func (*TIBSDataServiceBulkLoadResult) Read

func (*TIBSDataServiceBulkLoadResult) ReadField0

func (p *TIBSDataServiceBulkLoadResult) ReadField0(iprot thrift.TProtocol) error

func (*TIBSDataServiceBulkLoadResult) String

func (*TIBSDataServiceBulkLoadResult) Write

type TIBSDataServiceClient

type TIBSDataServiceClient struct {
	// contains filtered or unexported fields
}

func NewTIBSDataServiceClient

func NewTIBSDataServiceClient(c thrift.TClient) *TIBSDataServiceClient

func NewTIBSDataServiceClientProtocol

func NewTIBSDataServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *TIBSDataServiceClient

func (*TIBSDataServiceClient) BulkLoad

func (p *TIBSDataServiceClient) BulkLoad(ctx context.Context, bigsetID TKey, setData *TItemSet) (r bool, err error)

Parameters:

  • BigsetID
  • SetData

func (*TIBSDataServiceClient) Client_

func (p *TIBSDataServiceClient) Client_() thrift.TClient

func (*TIBSDataServiceClient) Existed

func (p *TIBSDataServiceClient) Existed(ctx context.Context, bigsetID TKey, itemKey TItemKey) (r *TExistedResult_, err error)

Parameters:

  • BigsetID
  • ItemKey

func (*TIBSDataServiceClient) GetItem

func (p *TIBSDataServiceClient) GetItem(ctx context.Context, bigsetID TKey, itemKey TItemKey) (r *TItemResult_, err error)

Parameters:

  • BigsetID
  • ItemKey

func (*TIBSDataServiceClient) GetSlice

func (p *TIBSDataServiceClient) GetSlice(ctx context.Context, bigsetID TKey, fromPos int32, count int32) (r *TItemSetResult_, err error)

Parameters:

  • BigsetID
  • FromPos
  • Count

func (*TIBSDataServiceClient) GetSliceFromItem

func (p *TIBSDataServiceClient) GetSliceFromItem(ctx context.Context, bigsetID TKey, fromKey TItemKey, count int32) (r *TItemSetResult_, err error)

Parameters:

  • BigsetID
  • FromKey
  • Count

func (*TIBSDataServiceClient) GetSliceFromItemR

func (p *TIBSDataServiceClient) GetSliceFromItemR(ctx context.Context, bigsetID TKey, fromKey TItemKey, count int32) (r *TItemSetResult_, err error)

Parameters:

  • BigsetID
  • FromKey
  • Count

func (*TIBSDataServiceClient) GetSliceR

func (p *TIBSDataServiceClient) GetSliceR(ctx context.Context, bigsetID TKey, fromPos int32, count int32) (r *TItemSetResult_, err error)

Parameters:

  • BigsetID
  • FromPos
  • Count

func (*TIBSDataServiceClient) GetTotalCount

func (p *TIBSDataServiceClient) GetTotalCount(ctx context.Context, bigsetID TKey) (r int64, err error)

Parameters:

  • BigsetID

func (*TIBSDataServiceClient) MultiPut

func (p *TIBSDataServiceClient) MultiPut(ctx context.Context, bigsetID TKey, setData *TItemSet, getAddedItems bool, getReplacedItems bool) (r *TMultiPutItemResult_, err error)

Parameters:

  • BigsetID
  • SetData
  • GetAddedItems
  • GetReplacedItems

func (*TIBSDataServiceClient) PutItem

func (p *TIBSDataServiceClient) PutItem(ctx context.Context, bigsetID TKey, item *TItem) (r *TPutItemResult_, err error)

Parameters:

  • BigsetID
  • Item

func (*TIBSDataServiceClient) RangeQuery

func (p *TIBSDataServiceClient) RangeQuery(ctx context.Context, bigsetID TKey, startKey TItemKey, endKey TItemKey) (r *TItemSetResult_, err error)

Parameters:

  • BigsetID
  • StartKey
  • EndKey

func (*TIBSDataServiceClient) RemoveAll

func (p *TIBSDataServiceClient) RemoveAll(ctx context.Context, bigsetID TKey) (r int64, err error)

Parameters:

  • BigsetID

func (*TIBSDataServiceClient) RemoveItem

func (p *TIBSDataServiceClient) RemoveItem(ctx context.Context, bigsetID TKey, itemKey TItemKey) (r bool, err error)

Parameters:

  • BigsetID
  • ItemKey

type TIBSDataServiceExistedArgs

type TIBSDataServiceExistedArgs struct {
	BigsetID TKey     `thrift:"bigsetID,1" db:"bigsetID" json:"bigsetID"`
	ItemKey  TItemKey `thrift:"itemKey,2" db:"itemKey" json:"itemKey"`
}

Attributes:

  • BigsetID
  • ItemKey

func NewTIBSDataServiceExistedArgs

func NewTIBSDataServiceExistedArgs() *TIBSDataServiceExistedArgs

func (*TIBSDataServiceExistedArgs) GetBigsetID

func (p *TIBSDataServiceExistedArgs) GetBigsetID() TKey

func (*TIBSDataServiceExistedArgs) GetItemKey

func (p *TIBSDataServiceExistedArgs) GetItemKey() TItemKey

func (*TIBSDataServiceExistedArgs) Read

func (*TIBSDataServiceExistedArgs) ReadField1

func (p *TIBSDataServiceExistedArgs) ReadField1(iprot thrift.TProtocol) error

func (*TIBSDataServiceExistedArgs) ReadField2

func (p *TIBSDataServiceExistedArgs) ReadField2(iprot thrift.TProtocol) error

func (*TIBSDataServiceExistedArgs) String

func (p *TIBSDataServiceExistedArgs) String() string

func (*TIBSDataServiceExistedArgs) Write

type TIBSDataServiceExistedResult

type TIBSDataServiceExistedResult struct {
	Success *TExistedResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTIBSDataServiceExistedResult

func NewTIBSDataServiceExistedResult() *TIBSDataServiceExistedResult

func (*TIBSDataServiceExistedResult) GetSuccess

func (*TIBSDataServiceExistedResult) IsSetSuccess

func (p *TIBSDataServiceExistedResult) IsSetSuccess() bool

func (*TIBSDataServiceExistedResult) Read

func (*TIBSDataServiceExistedResult) ReadField0

func (p *TIBSDataServiceExistedResult) ReadField0(iprot thrift.TProtocol) error

func (*TIBSDataServiceExistedResult) String

func (*TIBSDataServiceExistedResult) Write

type TIBSDataServiceGetItemArgs

type TIBSDataServiceGetItemArgs struct {
	BigsetID TKey     `thrift:"bigsetID,1" db:"bigsetID" json:"bigsetID"`
	ItemKey  TItemKey `thrift:"itemKey,2" db:"itemKey" json:"itemKey"`
}

Attributes:

  • BigsetID
  • ItemKey

func NewTIBSDataServiceGetItemArgs

func NewTIBSDataServiceGetItemArgs() *TIBSDataServiceGetItemArgs

func (*TIBSDataServiceGetItemArgs) GetBigsetID

func (p *TIBSDataServiceGetItemArgs) GetBigsetID() TKey

func (*TIBSDataServiceGetItemArgs) GetItemKey

func (p *TIBSDataServiceGetItemArgs) GetItemKey() TItemKey

func (*TIBSDataServiceGetItemArgs) Read

func (*TIBSDataServiceGetItemArgs) ReadField1

func (p *TIBSDataServiceGetItemArgs) ReadField1(iprot thrift.TProtocol) error

func (*TIBSDataServiceGetItemArgs) ReadField2

func (p *TIBSDataServiceGetItemArgs) ReadField2(iprot thrift.TProtocol) error

func (*TIBSDataServiceGetItemArgs) String

func (p *TIBSDataServiceGetItemArgs) String() string

func (*TIBSDataServiceGetItemArgs) Write

type TIBSDataServiceGetItemResult

type TIBSDataServiceGetItemResult struct {
	Success *TItemResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTIBSDataServiceGetItemResult

func NewTIBSDataServiceGetItemResult() *TIBSDataServiceGetItemResult

func (*TIBSDataServiceGetItemResult) GetSuccess

func (p *TIBSDataServiceGetItemResult) GetSuccess() *TItemResult_

func (*TIBSDataServiceGetItemResult) IsSetSuccess

func (p *TIBSDataServiceGetItemResult) IsSetSuccess() bool

func (*TIBSDataServiceGetItemResult) Read

func (*TIBSDataServiceGetItemResult) ReadField0

func (p *TIBSDataServiceGetItemResult) ReadField0(iprot thrift.TProtocol) error

func (*TIBSDataServiceGetItemResult) String

func (*TIBSDataServiceGetItemResult) Write

type TIBSDataServiceGetSliceArgs

type TIBSDataServiceGetSliceArgs struct {
	BigsetID TKey  `thrift:"bigsetID,1" db:"bigsetID" json:"bigsetID"`
	FromPos  int32 `thrift:"fromPos,2" db:"fromPos" json:"fromPos"`
	Count    int32 `thrift:"count,3" db:"count" json:"count"`
}

Attributes:

  • BigsetID
  • FromPos
  • Count

func NewTIBSDataServiceGetSliceArgs

func NewTIBSDataServiceGetSliceArgs() *TIBSDataServiceGetSliceArgs

func (*TIBSDataServiceGetSliceArgs) GetBigsetID

func (p *TIBSDataServiceGetSliceArgs) GetBigsetID() TKey

func (*TIBSDataServiceGetSliceArgs) GetCount

func (p *TIBSDataServiceGetSliceArgs) GetCount() int32

func (*TIBSDataServiceGetSliceArgs) GetFromPos

func (p *TIBSDataServiceGetSliceArgs) GetFromPos() int32

func (*TIBSDataServiceGetSliceArgs) Read

func (*TIBSDataServiceGetSliceArgs) ReadField1

func (p *TIBSDataServiceGetSliceArgs) ReadField1(iprot thrift.TProtocol) error

func (*TIBSDataServiceGetSliceArgs) ReadField2

func (p *TIBSDataServiceGetSliceArgs) ReadField2(iprot thrift.TProtocol) error

func (*TIBSDataServiceGetSliceArgs) ReadField3

func (p *TIBSDataServiceGetSliceArgs) ReadField3(iprot thrift.TProtocol) error

func (*TIBSDataServiceGetSliceArgs) String

func (p *TIBSDataServiceGetSliceArgs) String() string

func (*TIBSDataServiceGetSliceArgs) Write

type TIBSDataServiceGetSliceFromItemArgs

type TIBSDataServiceGetSliceFromItemArgs struct {
	BigsetID TKey     `thrift:"bigsetID,1" db:"bigsetID" json:"bigsetID"`
	FromKey  TItemKey `thrift:"fromKey,2" db:"fromKey" json:"fromKey"`
	Count    int32    `thrift:"count,3" db:"count" json:"count"`
}

Attributes:

  • BigsetID
  • FromKey
  • Count

func NewTIBSDataServiceGetSliceFromItemArgs

func NewTIBSDataServiceGetSliceFromItemArgs() *TIBSDataServiceGetSliceFromItemArgs

func (*TIBSDataServiceGetSliceFromItemArgs) GetBigsetID

func (p *TIBSDataServiceGetSliceFromItemArgs) GetBigsetID() TKey

func (*TIBSDataServiceGetSliceFromItemArgs) GetCount

func (*TIBSDataServiceGetSliceFromItemArgs) GetFromKey

func (*TIBSDataServiceGetSliceFromItemArgs) Read

func (*TIBSDataServiceGetSliceFromItemArgs) ReadField1

func (*TIBSDataServiceGetSliceFromItemArgs) ReadField2

func (*TIBSDataServiceGetSliceFromItemArgs) ReadField3

func (*TIBSDataServiceGetSliceFromItemArgs) String

func (*TIBSDataServiceGetSliceFromItemArgs) Write

type TIBSDataServiceGetSliceFromItemRArgs

type TIBSDataServiceGetSliceFromItemRArgs struct {
	BigsetID TKey     `thrift:"bigsetID,1" db:"bigsetID" json:"bigsetID"`
	FromKey  TItemKey `thrift:"fromKey,2" db:"fromKey" json:"fromKey"`
	Count    int32    `thrift:"count,3" db:"count" json:"count"`
}

Attributes:

  • BigsetID
  • FromKey
  • Count

func NewTIBSDataServiceGetSliceFromItemRArgs

func NewTIBSDataServiceGetSliceFromItemRArgs() *TIBSDataServiceGetSliceFromItemRArgs

func (*TIBSDataServiceGetSliceFromItemRArgs) GetBigsetID

func (p *TIBSDataServiceGetSliceFromItemRArgs) GetBigsetID() TKey

func (*TIBSDataServiceGetSliceFromItemRArgs) GetCount

func (*TIBSDataServiceGetSliceFromItemRArgs) GetFromKey

func (*TIBSDataServiceGetSliceFromItemRArgs) Read

func (*TIBSDataServiceGetSliceFromItemRArgs) ReadField1

func (*TIBSDataServiceGetSliceFromItemRArgs) ReadField2

func (*TIBSDataServiceGetSliceFromItemRArgs) ReadField3

func (*TIBSDataServiceGetSliceFromItemRArgs) String

func (*TIBSDataServiceGetSliceFromItemRArgs) Write

type TIBSDataServiceGetSliceFromItemRResult

type TIBSDataServiceGetSliceFromItemRResult struct {
	Success *TItemSetResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTIBSDataServiceGetSliceFromItemRResult

func NewTIBSDataServiceGetSliceFromItemRResult() *TIBSDataServiceGetSliceFromItemRResult

func (*TIBSDataServiceGetSliceFromItemRResult) GetSuccess

func (*TIBSDataServiceGetSliceFromItemRResult) IsSetSuccess

func (p *TIBSDataServiceGetSliceFromItemRResult) IsSetSuccess() bool

func (*TIBSDataServiceGetSliceFromItemRResult) Read

func (*TIBSDataServiceGetSliceFromItemRResult) ReadField0

func (*TIBSDataServiceGetSliceFromItemRResult) String

func (*TIBSDataServiceGetSliceFromItemRResult) Write

type TIBSDataServiceGetSliceFromItemResult

type TIBSDataServiceGetSliceFromItemResult struct {
	Success *TItemSetResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTIBSDataServiceGetSliceFromItemResult

func NewTIBSDataServiceGetSliceFromItemResult() *TIBSDataServiceGetSliceFromItemResult

func (*TIBSDataServiceGetSliceFromItemResult) GetSuccess

func (*TIBSDataServiceGetSliceFromItemResult) IsSetSuccess

func (p *TIBSDataServiceGetSliceFromItemResult) IsSetSuccess() bool

func (*TIBSDataServiceGetSliceFromItemResult) Read

func (*TIBSDataServiceGetSliceFromItemResult) ReadField0

func (*TIBSDataServiceGetSliceFromItemResult) String

func (*TIBSDataServiceGetSliceFromItemResult) Write

type TIBSDataServiceGetSliceRArgs

type TIBSDataServiceGetSliceRArgs struct {
	BigsetID TKey  `thrift:"bigsetID,1" db:"bigsetID" json:"bigsetID"`
	FromPos  int32 `thrift:"fromPos,2" db:"fromPos" json:"fromPos"`
	Count    int32 `thrift:"count,3" db:"count" json:"count"`
}

Attributes:

  • BigsetID
  • FromPos
  • Count

func NewTIBSDataServiceGetSliceRArgs

func NewTIBSDataServiceGetSliceRArgs() *TIBSDataServiceGetSliceRArgs

func (*TIBSDataServiceGetSliceRArgs) GetBigsetID

func (p *TIBSDataServiceGetSliceRArgs) GetBigsetID() TKey

func (*TIBSDataServiceGetSliceRArgs) GetCount

func (p *TIBSDataServiceGetSliceRArgs) GetCount() int32

func (*TIBSDataServiceGetSliceRArgs) GetFromPos

func (p *TIBSDataServiceGetSliceRArgs) GetFromPos() int32

func (*TIBSDataServiceGetSliceRArgs) Read

func (*TIBSDataServiceGetSliceRArgs) ReadField1

func (p *TIBSDataServiceGetSliceRArgs) ReadField1(iprot thrift.TProtocol) error

func (*TIBSDataServiceGetSliceRArgs) ReadField2

func (p *TIBSDataServiceGetSliceRArgs) ReadField2(iprot thrift.TProtocol) error

func (*TIBSDataServiceGetSliceRArgs) ReadField3

func (p *TIBSDataServiceGetSliceRArgs) ReadField3(iprot thrift.TProtocol) error

func (*TIBSDataServiceGetSliceRArgs) String

func (*TIBSDataServiceGetSliceRArgs) Write

type TIBSDataServiceGetSliceRResult

type TIBSDataServiceGetSliceRResult struct {
	Success *TItemSetResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTIBSDataServiceGetSliceRResult

func NewTIBSDataServiceGetSliceRResult() *TIBSDataServiceGetSliceRResult

func (*TIBSDataServiceGetSliceRResult) GetSuccess

func (*TIBSDataServiceGetSliceRResult) IsSetSuccess

func (p *TIBSDataServiceGetSliceRResult) IsSetSuccess() bool

func (*TIBSDataServiceGetSliceRResult) Read

func (*TIBSDataServiceGetSliceRResult) ReadField0

func (*TIBSDataServiceGetSliceRResult) String

func (*TIBSDataServiceGetSliceRResult) Write

type TIBSDataServiceGetSliceResult

type TIBSDataServiceGetSliceResult struct {
	Success *TItemSetResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTIBSDataServiceGetSliceResult

func NewTIBSDataServiceGetSliceResult() *TIBSDataServiceGetSliceResult

func (*TIBSDataServiceGetSliceResult) GetSuccess

func (*TIBSDataServiceGetSliceResult) IsSetSuccess

func (p *TIBSDataServiceGetSliceResult) IsSetSuccess() bool

func (*TIBSDataServiceGetSliceResult) Read

func (*TIBSDataServiceGetSliceResult) ReadField0

func (p *TIBSDataServiceGetSliceResult) ReadField0(iprot thrift.TProtocol) error

func (*TIBSDataServiceGetSliceResult) String

func (*TIBSDataServiceGetSliceResult) Write

type TIBSDataServiceGetTotalCountArgs

type TIBSDataServiceGetTotalCountArgs struct {
	BigsetID TKey `thrift:"bigsetID,1" db:"bigsetID" json:"bigsetID"`
}

Attributes:

  • BigsetID

func NewTIBSDataServiceGetTotalCountArgs

func NewTIBSDataServiceGetTotalCountArgs() *TIBSDataServiceGetTotalCountArgs

func (*TIBSDataServiceGetTotalCountArgs) GetBigsetID

func (p *TIBSDataServiceGetTotalCountArgs) GetBigsetID() TKey

func (*TIBSDataServiceGetTotalCountArgs) Read

func (*TIBSDataServiceGetTotalCountArgs) ReadField1

func (*TIBSDataServiceGetTotalCountArgs) String

func (*TIBSDataServiceGetTotalCountArgs) Write

type TIBSDataServiceGetTotalCountResult

type TIBSDataServiceGetTotalCountResult struct {
	Success *int64 `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTIBSDataServiceGetTotalCountResult

func NewTIBSDataServiceGetTotalCountResult() *TIBSDataServiceGetTotalCountResult

func (*TIBSDataServiceGetTotalCountResult) GetSuccess

func (p *TIBSDataServiceGetTotalCountResult) GetSuccess() int64

func (*TIBSDataServiceGetTotalCountResult) IsSetSuccess

func (p *TIBSDataServiceGetTotalCountResult) IsSetSuccess() bool

func (*TIBSDataServiceGetTotalCountResult) Read

func (*TIBSDataServiceGetTotalCountResult) ReadField0

func (*TIBSDataServiceGetTotalCountResult) String

func (*TIBSDataServiceGetTotalCountResult) Write

type TIBSDataServiceMultiPutArgs

type TIBSDataServiceMultiPutArgs struct {
	BigsetID         TKey      `thrift:"bigsetID,1" db:"bigsetID" json:"bigsetID"`
	SetData          *TItemSet `thrift:"setData,2" db:"setData" json:"setData"`
	GetAddedItems    bool      `thrift:"getAddedItems,3" db:"getAddedItems" json:"getAddedItems"`
	GetReplacedItems bool      `thrift:"getReplacedItems,4" db:"getReplacedItems" json:"getReplacedItems"`
}

Attributes:

  • BigsetID
  • SetData
  • GetAddedItems
  • GetReplacedItems

func NewTIBSDataServiceMultiPutArgs

func NewTIBSDataServiceMultiPutArgs() *TIBSDataServiceMultiPutArgs

func (*TIBSDataServiceMultiPutArgs) GetBigsetID

func (p *TIBSDataServiceMultiPutArgs) GetBigsetID() TKey

func (*TIBSDataServiceMultiPutArgs) GetGetAddedItems

func (p *TIBSDataServiceMultiPutArgs) GetGetAddedItems() bool

func (*TIBSDataServiceMultiPutArgs) GetGetReplacedItems

func (p *TIBSDataServiceMultiPutArgs) GetGetReplacedItems() bool

func (*TIBSDataServiceMultiPutArgs) GetSetData

func (p *TIBSDataServiceMultiPutArgs) GetSetData() *TItemSet

func (*TIBSDataServiceMultiPutArgs) IsSetSetData

func (p *TIBSDataServiceMultiPutArgs) IsSetSetData() bool

func (*TIBSDataServiceMultiPutArgs) Read

func (*TIBSDataServiceMultiPutArgs) ReadField1

func (p *TIBSDataServiceMultiPutArgs) ReadField1(iprot thrift.TProtocol) error

func (*TIBSDataServiceMultiPutArgs) ReadField2

func (p *TIBSDataServiceMultiPutArgs) ReadField2(iprot thrift.TProtocol) error

func (*TIBSDataServiceMultiPutArgs) ReadField3

func (p *TIBSDataServiceMultiPutArgs) ReadField3(iprot thrift.TProtocol) error

func (*TIBSDataServiceMultiPutArgs) ReadField4

func (p *TIBSDataServiceMultiPutArgs) ReadField4(iprot thrift.TProtocol) error

func (*TIBSDataServiceMultiPutArgs) String

func (p *TIBSDataServiceMultiPutArgs) String() string

func (*TIBSDataServiceMultiPutArgs) Write

type TIBSDataServiceMultiPutResult

type TIBSDataServiceMultiPutResult struct {
	Success *TMultiPutItemResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTIBSDataServiceMultiPutResult

func NewTIBSDataServiceMultiPutResult() *TIBSDataServiceMultiPutResult

func (*TIBSDataServiceMultiPutResult) GetSuccess

func (*TIBSDataServiceMultiPutResult) IsSetSuccess

func (p *TIBSDataServiceMultiPutResult) IsSetSuccess() bool

func (*TIBSDataServiceMultiPutResult) Read

func (*TIBSDataServiceMultiPutResult) ReadField0

func (p *TIBSDataServiceMultiPutResult) ReadField0(iprot thrift.TProtocol) error

func (*TIBSDataServiceMultiPutResult) String

func (*TIBSDataServiceMultiPutResult) Write

type TIBSDataServiceProcessor

type TIBSDataServiceProcessor struct {
	// contains filtered or unexported fields
}

func NewTIBSDataServiceProcessor

func NewTIBSDataServiceProcessor(handler TIBSDataService) *TIBSDataServiceProcessor

func (*TIBSDataServiceProcessor) AddToProcessorMap

func (p *TIBSDataServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)

func (*TIBSDataServiceProcessor) GetProcessorFunction

func (p *TIBSDataServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)

func (*TIBSDataServiceProcessor) Process

func (p *TIBSDataServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*TIBSDataServiceProcessor) ProcessorMap

type TIBSDataServicePutItemArgs

type TIBSDataServicePutItemArgs struct {
	BigsetID TKey   `thrift:"bigsetID,1" db:"bigsetID" json:"bigsetID"`
	Item     *TItem `thrift:"item,2" db:"item" json:"item"`
}

Attributes:

  • BigsetID
  • Item

func NewTIBSDataServicePutItemArgs

func NewTIBSDataServicePutItemArgs() *TIBSDataServicePutItemArgs

func (*TIBSDataServicePutItemArgs) GetBigsetID

func (p *TIBSDataServicePutItemArgs) GetBigsetID() TKey

func (*TIBSDataServicePutItemArgs) GetItem

func (p *TIBSDataServicePutItemArgs) GetItem() *TItem

func (*TIBSDataServicePutItemArgs) IsSetItem

func (p *TIBSDataServicePutItemArgs) IsSetItem() bool

func (*TIBSDataServicePutItemArgs) Read

func (*TIBSDataServicePutItemArgs) ReadField1

func (p *TIBSDataServicePutItemArgs) ReadField1(iprot thrift.TProtocol) error

func (*TIBSDataServicePutItemArgs) ReadField2

func (p *TIBSDataServicePutItemArgs) ReadField2(iprot thrift.TProtocol) error

func (*TIBSDataServicePutItemArgs) String

func (p *TIBSDataServicePutItemArgs) String() string

func (*TIBSDataServicePutItemArgs) Write

type TIBSDataServicePutItemResult

type TIBSDataServicePutItemResult struct {
	Success *TPutItemResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTIBSDataServicePutItemResult

func NewTIBSDataServicePutItemResult() *TIBSDataServicePutItemResult

func (*TIBSDataServicePutItemResult) GetSuccess

func (*TIBSDataServicePutItemResult) IsSetSuccess

func (p *TIBSDataServicePutItemResult) IsSetSuccess() bool

func (*TIBSDataServicePutItemResult) Read

func (*TIBSDataServicePutItemResult) ReadField0

func (p *TIBSDataServicePutItemResult) ReadField0(iprot thrift.TProtocol) error

func (*TIBSDataServicePutItemResult) String

func (*TIBSDataServicePutItemResult) Write

type TIBSDataServiceRangeQueryArgs

type TIBSDataServiceRangeQueryArgs struct {
	BigsetID TKey     `thrift:"bigsetID,1" db:"bigsetID" json:"bigsetID"`
	StartKey TItemKey `thrift:"startKey,2" db:"startKey" json:"startKey"`
	EndKey   TItemKey `thrift:"endKey,3" db:"endKey" json:"endKey"`
}

Attributes:

  • BigsetID
  • StartKey
  • EndKey

func NewTIBSDataServiceRangeQueryArgs

func NewTIBSDataServiceRangeQueryArgs() *TIBSDataServiceRangeQueryArgs

func (*TIBSDataServiceRangeQueryArgs) GetBigsetID

func (p *TIBSDataServiceRangeQueryArgs) GetBigsetID() TKey

func (*TIBSDataServiceRangeQueryArgs) GetEndKey

func (p *TIBSDataServiceRangeQueryArgs) GetEndKey() TItemKey

func (*TIBSDataServiceRangeQueryArgs) GetStartKey

func (p *TIBSDataServiceRangeQueryArgs) GetStartKey() TItemKey

func (*TIBSDataServiceRangeQueryArgs) Read

func (*TIBSDataServiceRangeQueryArgs) ReadField1

func (p *TIBSDataServiceRangeQueryArgs) ReadField1(iprot thrift.TProtocol) error

func (*TIBSDataServiceRangeQueryArgs) ReadField2

func (p *TIBSDataServiceRangeQueryArgs) ReadField2(iprot thrift.TProtocol) error

func (*TIBSDataServiceRangeQueryArgs) ReadField3

func (p *TIBSDataServiceRangeQueryArgs) ReadField3(iprot thrift.TProtocol) error

func (*TIBSDataServiceRangeQueryArgs) String

func (*TIBSDataServiceRangeQueryArgs) Write

type TIBSDataServiceRangeQueryResult

type TIBSDataServiceRangeQueryResult struct {
	Success *TItemSetResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTIBSDataServiceRangeQueryResult

func NewTIBSDataServiceRangeQueryResult() *TIBSDataServiceRangeQueryResult

func (*TIBSDataServiceRangeQueryResult) GetSuccess

func (*TIBSDataServiceRangeQueryResult) IsSetSuccess

func (p *TIBSDataServiceRangeQueryResult) IsSetSuccess() bool

func (*TIBSDataServiceRangeQueryResult) Read

func (*TIBSDataServiceRangeQueryResult) ReadField0

func (*TIBSDataServiceRangeQueryResult) String

func (*TIBSDataServiceRangeQueryResult) Write

type TIBSDataServiceRemoveAllArgs

type TIBSDataServiceRemoveAllArgs struct {
	BigsetID TKey `thrift:"bigsetID,1" db:"bigsetID" json:"bigsetID"`
}

Attributes:

  • BigsetID

func NewTIBSDataServiceRemoveAllArgs

func NewTIBSDataServiceRemoveAllArgs() *TIBSDataServiceRemoveAllArgs

func (*TIBSDataServiceRemoveAllArgs) GetBigsetID

func (p *TIBSDataServiceRemoveAllArgs) GetBigsetID() TKey

func (*TIBSDataServiceRemoveAllArgs) Read

func (*TIBSDataServiceRemoveAllArgs) ReadField1

func (p *TIBSDataServiceRemoveAllArgs) ReadField1(iprot thrift.TProtocol) error

func (*TIBSDataServiceRemoveAllArgs) String

func (*TIBSDataServiceRemoveAllArgs) Write

type TIBSDataServiceRemoveAllResult

type TIBSDataServiceRemoveAllResult struct {
	Success *int64 `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTIBSDataServiceRemoveAllResult

func NewTIBSDataServiceRemoveAllResult() *TIBSDataServiceRemoveAllResult

func (*TIBSDataServiceRemoveAllResult) GetSuccess

func (p *TIBSDataServiceRemoveAllResult) GetSuccess() int64

func (*TIBSDataServiceRemoveAllResult) IsSetSuccess

func (p *TIBSDataServiceRemoveAllResult) IsSetSuccess() bool

func (*TIBSDataServiceRemoveAllResult) Read

func (*TIBSDataServiceRemoveAllResult) ReadField0

func (*TIBSDataServiceRemoveAllResult) String

func (*TIBSDataServiceRemoveAllResult) Write

type TIBSDataServiceRemoveItemArgs

type TIBSDataServiceRemoveItemArgs struct {
	BigsetID TKey     `thrift:"bigsetID,1" db:"bigsetID" json:"bigsetID"`
	ItemKey  TItemKey `thrift:"itemKey,2" db:"itemKey" json:"itemKey"`
}

Attributes:

  • BigsetID
  • ItemKey

func NewTIBSDataServiceRemoveItemArgs

func NewTIBSDataServiceRemoveItemArgs() *TIBSDataServiceRemoveItemArgs

func (*TIBSDataServiceRemoveItemArgs) GetBigsetID

func (p *TIBSDataServiceRemoveItemArgs) GetBigsetID() TKey

func (*TIBSDataServiceRemoveItemArgs) GetItemKey

func (p *TIBSDataServiceRemoveItemArgs) GetItemKey() TItemKey

func (*TIBSDataServiceRemoveItemArgs) Read

func (*TIBSDataServiceRemoveItemArgs) ReadField1

func (p *TIBSDataServiceRemoveItemArgs) ReadField1(iprot thrift.TProtocol) error

func (*TIBSDataServiceRemoveItemArgs) ReadField2

func (p *TIBSDataServiceRemoveItemArgs) ReadField2(iprot thrift.TProtocol) error

func (*TIBSDataServiceRemoveItemArgs) String

func (*TIBSDataServiceRemoveItemArgs) Write

type TIBSDataServiceRemoveItemResult

type TIBSDataServiceRemoveItemResult struct {
	Success *bool `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTIBSDataServiceRemoveItemResult

func NewTIBSDataServiceRemoveItemResult() *TIBSDataServiceRemoveItemResult

func (*TIBSDataServiceRemoveItemResult) GetSuccess

func (p *TIBSDataServiceRemoveItemResult) GetSuccess() bool

func (*TIBSDataServiceRemoveItemResult) IsSetSuccess

func (p *TIBSDataServiceRemoveItemResult) IsSetSuccess() bool

func (*TIBSDataServiceRemoveItemResult) Read

func (*TIBSDataServiceRemoveItemResult) ReadField0

func (*TIBSDataServiceRemoveItemResult) String

func (*TIBSDataServiceRemoveItemResult) Write

type TItem

type TItem struct {
	Key   []byte `thrift:"key,1,required" db:"key" json:"key"`
	Value []byte `thrift:"value,2,required" db:"value" json:"value"`
}

Attributes:

  • Key
  • Value
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

func NewTItem() *TItem

func (*TItem) GetKey

func (p *TItem) GetKey() []byte

func (*TItem) GetValue

func (p *TItem) GetValue() []byte

func (*TItem) Read

func (p *TItem) Read(iprot thrift.TProtocol) error

func (*TItem) ReadField1

func (p *TItem) ReadField1(iprot thrift.TProtocol) error

func (*TItem) ReadField2

func (p *TItem) ReadField2(iprot thrift.TProtocol) error

func (*TItem) String

func (p *TItem) String() string

func (*TItem) Write

func (p *TItem) Write(oprot thrift.TProtocol) error

type TItemKey

type TItemKey []byte

func TItemKeyPtr

func TItemKeyPtr(v TItemKey) *TItemKey

type TItemKeySet

type TItemKeySet []TItemKey

func TItemKeySetPtr

func TItemKeySetPtr(v TItemKeySet) *TItemKeySet

type TItemList

type TItemList []*TItem

func TItemListPtr

func TItemListPtr(v TItemList) *TItemList

type TItemResult_

type TItemResult_ struct {
	Error TErrorCode `thrift:"error,1" db:"error" json:"error"`
	Item  *TItem     `thrift:"item,2" db:"item" json:"item,omitempty"`
}

Attributes:

  • Error
  • Item
var TBSGenericDataServiceBsgGetItemResult_Success_DEFAULT *TItemResult_
var TIBSDataServiceGetItemResult_Success_DEFAULT *TItemResult_
var TStringBigSetKVServiceBsGetItemResult_Success_DEFAULT *TItemResult_

func NewTItemResult_

func NewTItemResult_() *TItemResult_

func (*TItemResult_) GetError

func (p *TItemResult_) GetError() TErrorCode

func (*TItemResult_) GetItem

func (p *TItemResult_) GetItem() *TItem

func (*TItemResult_) IsSetItem

func (p *TItemResult_) IsSetItem() bool

func (*TItemResult_) Read

func (p *TItemResult_) Read(iprot thrift.TProtocol) error

func (*TItemResult_) ReadField1

func (p *TItemResult_) ReadField1(iprot thrift.TProtocol) error

func (*TItemResult_) ReadField2

func (p *TItemResult_) ReadField2(iprot thrift.TProtocol) error

func (*TItemResult_) String

func (p *TItemResult_) String() string

func (*TItemResult_) Write

func (p *TItemResult_) Write(oprot thrift.TProtocol) error

type TItemSet

type TItemSet struct {
	Items []*TItem `thrift:"items,1" db:"items" json:"items"`
}

Attributes:

  • Items
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

func NewTItemSet() *TItemSet

func (*TItemSet) GetItems

func (p *TItemSet) GetItems() []*TItem

func (*TItemSet) Read

func (p *TItemSet) Read(iprot thrift.TProtocol) error

func (*TItemSet) ReadField1

func (p *TItemSet) ReadField1(iprot thrift.TProtocol) error

func (*TItemSet) String

func (p *TItemSet) String() string

func (*TItemSet) Write

func (p *TItemSet) Write(oprot thrift.TProtocol) error

type TItemSetResult_

type TItemSetResult_ struct {
	Error TErrorCode `thrift:"error,1" db:"error" json:"error"`
	Items *TItemSet  `thrift:"items,2" db:"items" json:"items,omitempty"`
}

Attributes:

  • Error
  • Items
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_

func NewTItemSetResult_() *TItemSetResult_

func (*TItemSetResult_) GetError

func (p *TItemSetResult_) GetError() TErrorCode

func (*TItemSetResult_) GetItems

func (p *TItemSetResult_) GetItems() *TItemSet

func (*TItemSetResult_) IsSetItems

func (p *TItemSetResult_) IsSetItems() bool

func (*TItemSetResult_) Read

func (p *TItemSetResult_) Read(iprot thrift.TProtocol) error

func (*TItemSetResult_) ReadField1

func (p *TItemSetResult_) ReadField1(iprot thrift.TProtocol) error

func (*TItemSetResult_) ReadField2

func (p *TItemSetResult_) ReadField2(iprot thrift.TProtocol) error

func (*TItemSetResult_) String

func (p *TItemSetResult_) String() string

func (*TItemSetResult_) Write

func (p *TItemSetResult_) Write(oprot thrift.TProtocol) error

type TItemValue

type TItemValue []byte

func TItemValuePtr

func TItemValuePtr(v TItemValue) *TItemValue

type TKey

type TKey int64

func TKeyPtr

func TKeyPtr(v TKey) *TKey

type TLevelType

type TLevelType int16

func TLevelTypePtr

func TLevelTypePtr(v TLevelType) *TLevelType

type TMetaItem

type TMetaItem struct {
	MinItem TItemKey `thrift:"minItem,1" db:"minItem" json:"minItem"`
	MetaID  int64    `thrift:"metaID,2" db:"metaID" json:"metaID"`
	Count   int32    `thrift:"count,3" db:"count" json:"count"`
}

Attributes:

  • MinItem
  • MetaID
  • Count

func NewTMetaItem

func NewTMetaItem() *TMetaItem

func (*TMetaItem) GetCount

func (p *TMetaItem) GetCount() int32

func (*TMetaItem) GetMetaID

func (p *TMetaItem) GetMetaID() int64

func (*TMetaItem) GetMinItem

func (p *TMetaItem) GetMinItem() TItemKey

func (*TMetaItem) Read

func (p *TMetaItem) Read(iprot thrift.TProtocol) error

func (*TMetaItem) ReadField1

func (p *TMetaItem) ReadField1(iprot thrift.TProtocol) error

func (*TMetaItem) ReadField2

func (p *TMetaItem) ReadField2(iprot thrift.TProtocol) error

func (*TMetaItem) ReadField3

func (p *TMetaItem) ReadField3(iprot thrift.TProtocol) error

func (*TMetaItem) String

func (p *TMetaItem) String() string

func (*TMetaItem) Write

func (p *TMetaItem) Write(oprot thrift.TProtocol) error

type TMetaKey

type TMetaKey TContainerKey
var MasterMetaServiceGetMetaIDResult_Success_DEFAULT TMetaKey

func TMetaKeyPtr

func TMetaKeyPtr(v TMetaKey) *TMetaKey

type TMultiPutItemResult_

type TMultiPutItemResult_ struct {
	Error    TErrorCode `thrift:"error,1" db:"error" json:"error"`
	Added    []TItemKey `thrift:"added,2" db:"added" json:"added,omitempty"`
	Replaced []*TItem   `thrift:"replaced,3" db:"replaced" json:"replaced,omitempty"`
}

Attributes:

  • Error
  • Added
  • Replaced
var TBSGenericDataServiceBsgMultiPutResult_Success_DEFAULT *TMultiPutItemResult_
var TIBSDataServiceMultiPutResult_Success_DEFAULT *TMultiPutItemResult_
var TStringBigSetKVServiceBsMultiPutResult_Success_DEFAULT *TMultiPutItemResult_

func NewTMultiPutItemResult_

func NewTMultiPutItemResult_() *TMultiPutItemResult_

func (*TMultiPutItemResult_) GetAdded

func (p *TMultiPutItemResult_) GetAdded() []TItemKey

func (*TMultiPutItemResult_) GetError

func (p *TMultiPutItemResult_) GetError() TErrorCode

func (*TMultiPutItemResult_) GetReplaced

func (p *TMultiPutItemResult_) GetReplaced() []*TItem

func (*TMultiPutItemResult_) IsSetAdded

func (p *TMultiPutItemResult_) IsSetAdded() bool

func (*TMultiPutItemResult_) IsSetReplaced

func (p *TMultiPutItemResult_) IsSetReplaced() bool

func (*TMultiPutItemResult_) Read

func (p *TMultiPutItemResult_) Read(iprot thrift.TProtocol) error

func (*TMultiPutItemResult_) ReadField1

func (p *TMultiPutItemResult_) ReadField1(iprot thrift.TProtocol) error

func (*TMultiPutItemResult_) ReadField2

func (p *TMultiPutItemResult_) ReadField2(iprot thrift.TProtocol) error

func (*TMultiPutItemResult_) ReadField3

func (p *TMultiPutItemResult_) ReadField3(iprot thrift.TProtocol) error

func (*TMultiPutItemResult_) String

func (p *TMultiPutItemResult_) String() string

func (*TMultiPutItemResult_) Write

func (p *TMultiPutItemResult_) Write(oprot thrift.TProtocol) error

type TNeedSplitInfo

type TNeedSplitInfo struct {
	MetaID     TMetaKey `thrift:"metaID,1" db:"metaID" json:"metaID"`
	ParentID   TMetaKey `thrift:"parentID,2" db:"parentID" json:"parentID"`
	ChildCount int32    `thrift:"childCount,3" db:"childCount" json:"childCount"`
	IsSmallSet bool     `thrift:"isSmallSet,4" db:"isSmallSet" json:"isSmallSet"`
}

Attributes:

  • MetaID
  • ParentID
  • ChildCount
  • IsSmallSet
var BSNotificationPoolNeedSplitArgs_SplitInfo_DEFAULT *TNeedSplitInfo
var SplitJob_SplitInfo_DEFAULT *TNeedSplitInfo
var TBigSetGenericData_Splitinfo_DEFAULT *TNeedSplitInfo
var TSetMetaPath_SplitInfo_DEFAULT *TNeedSplitInfo

func NewTNeedSplitInfo

func NewTNeedSplitInfo() *TNeedSplitInfo

func (*TNeedSplitInfo) GetChildCount

func (p *TNeedSplitInfo) GetChildCount() int32

func (*TNeedSplitInfo) GetIsSmallSet

func (p *TNeedSplitInfo) GetIsSmallSet() bool

func (*TNeedSplitInfo) GetMetaID

func (p *TNeedSplitInfo) GetMetaID() TMetaKey

func (*TNeedSplitInfo) GetParentID

func (p *TNeedSplitInfo) GetParentID() TMetaKey

func (*TNeedSplitInfo) Read

func (p *TNeedSplitInfo) Read(iprot thrift.TProtocol) error

func (*TNeedSplitInfo) ReadField1

func (p *TNeedSplitInfo) ReadField1(iprot thrift.TProtocol) error

func (*TNeedSplitInfo) ReadField2

func (p *TNeedSplitInfo) ReadField2(iprot thrift.TProtocol) error

func (*TNeedSplitInfo) ReadField3

func (p *TNeedSplitInfo) ReadField3(iprot thrift.TProtocol) error

func (*TNeedSplitInfo) ReadField4

func (p *TNeedSplitInfo) ReadField4(iprot thrift.TProtocol) error

func (*TNeedSplitInfo) String

func (p *TNeedSplitInfo) String() string

func (*TNeedSplitInfo) Write

func (p *TNeedSplitInfo) Write(oprot thrift.TProtocol) error

type TPutItemResult_

type TPutItemResult_ struct {
	Error   TErrorCode `thrift:"error,1" db:"error" json:"error"`
	Ok      bool       `thrift:"ok,2" db:"ok" json:"ok"`
	OldItem *TItem     `thrift:"oldItem,3" db:"oldItem" json:"oldItem,omitempty"`
}

Attributes:

  • Error
  • Ok
  • OldItem
var TBSGenericDataServiceBsgPutItemResult_Success_DEFAULT *TPutItemResult_
var TIBSDataServicePutItemResult_Success_DEFAULT *TPutItemResult_
var TStringBigSetKVServiceBsPutItemResult_Success_DEFAULT *TPutItemResult_

func NewTPutItemResult_

func NewTPutItemResult_() *TPutItemResult_

func (*TPutItemResult_) GetError

func (p *TPutItemResult_) GetError() TErrorCode

func (*TPutItemResult_) GetOk

func (p *TPutItemResult_) GetOk() bool

func (*TPutItemResult_) GetOldItem

func (p *TPutItemResult_) GetOldItem() *TItem

func (*TPutItemResult_) IsSetOldItem

func (p *TPutItemResult_) IsSetOldItem() bool

func (*TPutItemResult_) Read

func (p *TPutItemResult_) Read(iprot thrift.TProtocol) error

func (*TPutItemResult_) ReadField1

func (p *TPutItemResult_) ReadField1(iprot thrift.TProtocol) error

func (*TPutItemResult_) ReadField2

func (p *TPutItemResult_) ReadField2(iprot thrift.TProtocol) error

func (*TPutItemResult_) ReadField3

func (p *TPutItemResult_) ReadField3(iprot thrift.TProtocol) error

func (*TPutItemResult_) String

func (p *TPutItemResult_) String() string

func (*TPutItemResult_) Write

func (p *TPutItemResult_) Write(oprot thrift.TProtocol) error

type TSetMetaPath

type TSetMetaPath struct {
	MetaPath     []*TSetMetaPathItem `thrift:"metaPath,1" db:"metaPath" json:"metaPath"`
	SmallSetInfo *TSetMetaPathItem   `thrift:"smallSetInfo,2" db:"smallSetInfo" json:"smallSetInfo,omitempty"`
	SplitInfo    *TNeedSplitInfo     `thrift:"splitInfo,3" db:"splitInfo" json:"splitInfo,omitempty"`
}

Attributes:

  • MetaPath
  • SmallSetInfo
  • SplitInfo

func NewTSetMetaPath

func NewTSetMetaPath() *TSetMetaPath

func (*TSetMetaPath) GetMetaPath

func (p *TSetMetaPath) GetMetaPath() []*TSetMetaPathItem

func (*TSetMetaPath) GetSmallSetInfo

func (p *TSetMetaPath) GetSmallSetInfo() *TSetMetaPathItem

func (*TSetMetaPath) GetSplitInfo

func (p *TSetMetaPath) GetSplitInfo() *TNeedSplitInfo

func (*TSetMetaPath) IsSetSmallSetInfo

func (p *TSetMetaPath) IsSetSmallSetInfo() bool

func (*TSetMetaPath) IsSetSplitInfo

func (p *TSetMetaPath) IsSetSplitInfo() bool

func (*TSetMetaPath) Read

func (p *TSetMetaPath) Read(iprot thrift.TProtocol) error

func (*TSetMetaPath) ReadField1

func (p *TSetMetaPath) ReadField1(iprot thrift.TProtocol) error

func (*TSetMetaPath) ReadField2

func (p *TSetMetaPath) ReadField2(iprot thrift.TProtocol) error

func (*TSetMetaPath) ReadField3

func (p *TSetMetaPath) ReadField3(iprot thrift.TProtocol) error

func (*TSetMetaPath) String

func (p *TSetMetaPath) String() string

func (*TSetMetaPath) Write

func (p *TSetMetaPath) Write(oprot thrift.TProtocol) error

type TSetMetaPathItem

type TSetMetaPathItem struct {
	MinItem TItemKey `thrift:"minItem,1" db:"minItem" json:"minItem"`
	MetaID  int64    `thrift:"metaID,2" db:"metaID" json:"metaID"`
	Level   int8     `thrift:"level,3" db:"level" json:"level"`
}

Attributes:

  • MinItem
  • MetaID
  • Level
var TSetMetaPath_SmallSetInfo_DEFAULT *TSetMetaPathItem

func NewTSetMetaPathItem

func NewTSetMetaPathItem() *TSetMetaPathItem

func (*TSetMetaPathItem) GetLevel

func (p *TSetMetaPathItem) GetLevel() int8

func (*TSetMetaPathItem) GetMetaID

func (p *TSetMetaPathItem) GetMetaID() int64

func (*TSetMetaPathItem) GetMinItem

func (p *TSetMetaPathItem) GetMinItem() TItemKey

func (*TSetMetaPathItem) Read

func (p *TSetMetaPathItem) Read(iprot thrift.TProtocol) error

func (*TSetMetaPathItem) ReadField1

func (p *TSetMetaPathItem) ReadField1(iprot thrift.TProtocol) error

func (*TSetMetaPathItem) ReadField2

func (p *TSetMetaPathItem) ReadField2(iprot thrift.TProtocol) error

func (*TSetMetaPathItem) ReadField3

func (p *TSetMetaPathItem) ReadField3(iprot thrift.TProtocol) error

func (*TSetMetaPathItem) String

func (p *TSetMetaPathItem) String() string

func (*TSetMetaPathItem) Write

func (p *TSetMetaPathItem) Write(oprot thrift.TProtocol) error

type TSmallSet

type TSmallSet struct {
	Entries TItemList       `thrift:"entries,1" db:"entries" json:"entries"`
	Prev    *TSmallSetIDKey `thrift:"prev,2" db:"prev" json:"prev,omitempty"`
	Nxt     *TSmallSetIDKey `thrift:"nxt,3" db:"nxt" json:"nxt,omitempty"`
}

Attributes:

  • Entries
  • Prev
  • Nxt
var TBigSetGenericData_Smallset_DEFAULT *TSmallSet

func NewTSmallSet

func NewTSmallSet() *TSmallSet

func (*TSmallSet) GetEntries

func (p *TSmallSet) GetEntries() TItemList

func (*TSmallSet) GetNxt

func (p *TSmallSet) GetNxt() TSmallSetIDKey

func (*TSmallSet) GetPrev

func (p *TSmallSet) GetPrev() TSmallSetIDKey

func (*TSmallSet) IsSetNxt

func (p *TSmallSet) IsSetNxt() bool

func (*TSmallSet) IsSetPrev

func (p *TSmallSet) IsSetPrev() bool

func (*TSmallSet) Read

func (p *TSmallSet) Read(iprot thrift.TProtocol) error

func (*TSmallSet) ReadField1

func (p *TSmallSet) ReadField1(iprot thrift.TProtocol) error

func (*TSmallSet) ReadField2

func (p *TSmallSet) ReadField2(iprot thrift.TProtocol) error

func (*TSmallSet) ReadField3

func (p *TSmallSet) ReadField3(iprot thrift.TProtocol) error

func (*TSmallSet) String

func (p *TSmallSet) String() string

func (*TSmallSet) Write

func (p *TSmallSet) Write(oprot thrift.TProtocol) error

type TSmallSetIDKey

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

func TSmallSetIDKeyPtr(v TSmallSetIDKey) *TSmallSetIDKey

type TSmallSetInfo

type TSmallSetInfo struct {
	Count        int32          `thrift:"count,1" db:"count" json:"count"`
	MidItem      TItemKey       `thrift:"midItem,2" db:"midItem" json:"midItem"`
	CountFromMid int32          `thrift:"countFromMid,3" db:"countFromMid" json:"countFromMid"`
	Prev         TSmallSetIDKey `thrift:"prev,4" db:"prev" json:"prev"`
	Nxt          TSmallSetIDKey `thrift:"nxt,5" db:"nxt" json:"nxt"`
}

Attributes:

  • Count
  • MidItem
  • CountFromMid
  • Prev
  • Nxt

func NewTSmallSetInfo

func NewTSmallSetInfo() *TSmallSetInfo

func (*TSmallSetInfo) GetCount

func (p *TSmallSetInfo) GetCount() int32

func (*TSmallSetInfo) GetCountFromMid

func (p *TSmallSetInfo) GetCountFromMid() int32

func (*TSmallSetInfo) GetMidItem

func (p *TSmallSetInfo) GetMidItem() TItemKey

func (*TSmallSetInfo) GetNxt

func (p *TSmallSetInfo) GetNxt() TSmallSetIDKey

func (*TSmallSetInfo) GetPrev

func (p *TSmallSetInfo) GetPrev() TSmallSetIDKey

func (*TSmallSetInfo) IsSetNxt

func (p *TSmallSetInfo) IsSetNxt() bool

func (*TSmallSetInfo) IsSetPrev

func (p *TSmallSetInfo) IsSetPrev() bool

func (*TSmallSetInfo) Read

func (p *TSmallSetInfo) Read(iprot thrift.TProtocol) error

func (*TSmallSetInfo) ReadField1

func (p *TSmallSetInfo) ReadField1(iprot thrift.TProtocol) error

func (*TSmallSetInfo) ReadField2

func (p *TSmallSetInfo) ReadField2(iprot thrift.TProtocol) error

func (*TSmallSetInfo) ReadField3

func (p *TSmallSetInfo) ReadField3(iprot thrift.TProtocol) error

func (*TSmallSetInfo) ReadField4

func (p *TSmallSetInfo) ReadField4(iprot thrift.TProtocol) error

func (*TSmallSetInfo) ReadField5

func (p *TSmallSetInfo) ReadField5(iprot thrift.TProtocol) error

func (*TSmallSetInfo) String

func (p *TSmallSetInfo) String() string

func (*TSmallSetInfo) Write

func (p *TSmallSetInfo) Write(oprot thrift.TProtocol) error

type TSplitBigSetResult_

type TSplitBigSetResult_ struct {
	Error      TErrorCode    `thrift:"error,1" db:"error" json:"error"`
	Splited    bool          `thrift:"splited,2" db:"splited" json:"splited"`
	NewRootID_ TContainerKey `thrift:"newRootID,3" db:"newRootID" json:"newRootID"`
	MinItem    TItemKey      `thrift:"minItem,4" db:"minItem" json:"minItem"`
	Count      int64         `thrift:"count,5" db:"count" json:"count"`
}

Attributes:

  • Error
  • Splited
  • NewRootID_
  • MinItem
  • Count
var TBSGenericDataServiceSplitBigSetResult_Success_DEFAULT *TSplitBigSetResult_

func NewTSplitBigSetResult_

func NewTSplitBigSetResult_() *TSplitBigSetResult_

func (*TSplitBigSetResult_) GetCount

func (p *TSplitBigSetResult_) GetCount() int64

func (*TSplitBigSetResult_) GetError

func (p *TSplitBigSetResult_) GetError() TErrorCode

func (*TSplitBigSetResult_) GetMinItem

func (p *TSplitBigSetResult_) GetMinItem() TItemKey

func (*TSplitBigSetResult_) GetNewRootID_

func (p *TSplitBigSetResult_) GetNewRootID_() TContainerKey

func (*TSplitBigSetResult_) GetSplited

func (p *TSplitBigSetResult_) GetSplited() bool

func (*TSplitBigSetResult_) Read

func (p *TSplitBigSetResult_) Read(iprot thrift.TProtocol) error

func (*TSplitBigSetResult_) ReadField1

func (p *TSplitBigSetResult_) ReadField1(iprot thrift.TProtocol) error

func (*TSplitBigSetResult_) ReadField2

func (p *TSplitBigSetResult_) ReadField2(iprot thrift.TProtocol) error

func (*TSplitBigSetResult_) ReadField3

func (p *TSplitBigSetResult_) ReadField3(iprot thrift.TProtocol) error

func (*TSplitBigSetResult_) ReadField4

func (p *TSplitBigSetResult_) ReadField4(iprot thrift.TProtocol) error

func (*TSplitBigSetResult_) ReadField5

func (p *TSplitBigSetResult_) ReadField5(iprot thrift.TProtocol) error

func (*TSplitBigSetResult_) String

func (p *TSplitBigSetResult_) String() string

func (*TSplitBigSetResult_) Write

func (p *TSplitBigSetResult_) Write(oprot thrift.TProtocol) error

type TStringBigSetInfo

type TStringBigSetInfo struct {
	BigsetName TStringKey    `thrift:"bigsetName,1,required" db:"bigsetName" json:"bigsetName"`
	BigsetID   TContainerKey `thrift:"bigsetID,2,required" db:"bigsetID" json:"bigsetID"`
	Count      *int64        `thrift:"count,3" db:"count" json:"count,omitempty"`
}

Attributes:

  • BigsetName
  • BigsetID
  • Count
var TBigSetInfoResult__Info_DEFAULT *TStringBigSetInfo

func NewTStringBigSetInfo

func NewTStringBigSetInfo() *TStringBigSetInfo

func (*TStringBigSetInfo) GetBigsetID

func (p *TStringBigSetInfo) GetBigsetID() TContainerKey

func (*TStringBigSetInfo) GetBigsetName

func (p *TStringBigSetInfo) GetBigsetName() TStringKey

func (*TStringBigSetInfo) GetCount

func (p *TStringBigSetInfo) GetCount() int64

func (*TStringBigSetInfo) IsSetCount

func (p *TStringBigSetInfo) IsSetCount() bool

func (*TStringBigSetInfo) Read

func (p *TStringBigSetInfo) Read(iprot thrift.TProtocol) error

func (*TStringBigSetInfo) ReadField1

func (p *TStringBigSetInfo) ReadField1(iprot thrift.TProtocol) error

func (*TStringBigSetInfo) ReadField2

func (p *TStringBigSetInfo) ReadField2(iprot thrift.TProtocol) error

func (*TStringBigSetInfo) ReadField3

func (p *TStringBigSetInfo) ReadField3(iprot thrift.TProtocol) error

func (*TStringBigSetInfo) String

func (p *TStringBigSetInfo) String() string

func (*TStringBigSetInfo) Write

func (p *TStringBigSetInfo) Write(oprot thrift.TProtocol) error

type TStringBigSetKVService

type TStringBigSetKVService interface {
	// Parameters:
	//  - BsName
	CreateStringBigSet(ctx context.Context, bsName TStringKey) (r *TBigSetInfoResult_, err error)
	// Parameters:
	//  - BsName
	GetBigSetInfoByName(ctx context.Context, bsName TStringKey) (r *TBigSetInfoResult_, err error)
	// Parameters:
	//  - BsName
	//  - BigsetID
	AssignBigSetName(ctx context.Context, bsName TStringKey, bigsetID TContainerKey) (r *TBigSetInfoResult_, err error)
	// Parameters:
	//  - BsName
	//  - Item
	BsPutItem(ctx context.Context, bsName TStringKey, item *TItem) (r *TPutItemResult_, err error)
	// Parameters:
	//  - BsName
	//  - ItemKey
	BsRemoveItem(ctx context.Context, bsName TStringKey, itemKey TItemKey) (r bool, err error)
	// Parameters:
	//  - BsName
	//  - ItemKey
	BsExisted(ctx context.Context, bsName TStringKey, itemKey TItemKey) (r *TExistedResult_, err error)
	// Parameters:
	//  - BsName
	//  - ItemKey
	BsGetItem(ctx context.Context, bsName TStringKey, itemKey TItemKey) (r *TItemResult_, err error)
	// Parameters:
	//  - BsName
	//  - FromPos
	//  - Count
	BsGetSlice(ctx context.Context, bsName TStringKey, fromPos int32, count int32) (r *TItemSetResult_, err error)
	// Parameters:
	//  - BsName
	//  - FromKey
	//  - Count
	BsGetSliceFromItem(ctx context.Context, bsName TStringKey, fromKey TItemKey, count int32) (r *TItemSetResult_, err error)
	// Parameters:
	//  - BsName
	//  - FromPos
	//  - Count
	BsGetSliceR(ctx context.Context, bsName TStringKey, fromPos int32, count int32) (r *TItemSetResult_, err error)
	// Parameters:
	//  - BsName
	//  - FromKey
	//  - Count
	BsGetSliceFromItemR(ctx context.Context, bsName TStringKey, fromKey TItemKey, count int32) (r *TItemSetResult_, err error)
	// Parameters:
	//  - BsName
	//  - StartKey
	//  - EndKey
	BsRangeQuery(ctx context.Context, bsName TStringKey, startKey TItemKey, endKey TItemKey) (r *TItemSetResult_, err error)
	// Parameters:
	//  - BsName
	//  - SetData
	BsBulkLoad(ctx context.Context, bsName TStringKey, setData *TItemSet) (r bool, err error)
	// Parameters:
	//  - BsName
	//  - SetData
	//  - GetAddedItems
	//  - GetReplacedItems
	BsMultiPut(ctx context.Context, bsName TStringKey, setData *TItemSet, getAddedItems bool, getReplacedItems bool) (r *TMultiPutItemResult_, err error)
	// Parameters:
	//  - BsName
	GetTotalCount(ctx context.Context, bsName TStringKey) (r int64, err error)
	// Parameters:
	//  - BsName
	RemoveAll(ctx context.Context, bsName TStringKey) (r int64, err error)
	TotalStringKeyCount(ctx context.Context) (r int64, err error)
	// Parameters:
	//  - FromIndex
	//  - Count
	GetListKey(ctx context.Context, fromIndex int64, count int32) (r []TStringKey, err error)
	// Parameters:
	//  - KeyFrom
	//  - Count
	GetListKeyFrom(ctx context.Context, keyFrom TStringKey, count int32) (r []TStringKey, err error)
}

type TStringBigSetKVServiceAssignBigSetNameArgs

type TStringBigSetKVServiceAssignBigSetNameArgs struct {
	BsName   TStringKey    `thrift:"bsName,1" db:"bsName" json:"bsName"`
	BigsetID TContainerKey `thrift:"bigsetID,2" db:"bigsetID" json:"bigsetID"`
}

Attributes:

  • BsName
  • BigsetID

func NewTStringBigSetKVServiceAssignBigSetNameArgs

func NewTStringBigSetKVServiceAssignBigSetNameArgs() *TStringBigSetKVServiceAssignBigSetNameArgs

func (*TStringBigSetKVServiceAssignBigSetNameArgs) GetBigsetID

func (*TStringBigSetKVServiceAssignBigSetNameArgs) GetBsName

func (*TStringBigSetKVServiceAssignBigSetNameArgs) Read

func (*TStringBigSetKVServiceAssignBigSetNameArgs) ReadField1

func (*TStringBigSetKVServiceAssignBigSetNameArgs) ReadField2

func (*TStringBigSetKVServiceAssignBigSetNameArgs) String

func (*TStringBigSetKVServiceAssignBigSetNameArgs) Write

type TStringBigSetKVServiceAssignBigSetNameResult

type TStringBigSetKVServiceAssignBigSetNameResult struct {
	Success *TBigSetInfoResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTStringBigSetKVServiceAssignBigSetNameResult

func NewTStringBigSetKVServiceAssignBigSetNameResult() *TStringBigSetKVServiceAssignBigSetNameResult

func (*TStringBigSetKVServiceAssignBigSetNameResult) GetSuccess

func (*TStringBigSetKVServiceAssignBigSetNameResult) IsSetSuccess

func (*TStringBigSetKVServiceAssignBigSetNameResult) Read

func (*TStringBigSetKVServiceAssignBigSetNameResult) ReadField0

func (*TStringBigSetKVServiceAssignBigSetNameResult) String

func (*TStringBigSetKVServiceAssignBigSetNameResult) Write

type TStringBigSetKVServiceBsBulkLoadArgs

type TStringBigSetKVServiceBsBulkLoadArgs struct {
	BsName  TStringKey `thrift:"bsName,1" db:"bsName" json:"bsName"`
	SetData *TItemSet  `thrift:"setData,2" db:"setData" json:"setData"`
}

Attributes:

  • BsName
  • SetData

func NewTStringBigSetKVServiceBsBulkLoadArgs

func NewTStringBigSetKVServiceBsBulkLoadArgs() *TStringBigSetKVServiceBsBulkLoadArgs

func (*TStringBigSetKVServiceBsBulkLoadArgs) GetBsName

func (*TStringBigSetKVServiceBsBulkLoadArgs) GetSetData

func (*TStringBigSetKVServiceBsBulkLoadArgs) IsSetSetData

func (p *TStringBigSetKVServiceBsBulkLoadArgs) IsSetSetData() bool

func (*TStringBigSetKVServiceBsBulkLoadArgs) Read

func (*TStringBigSetKVServiceBsBulkLoadArgs) ReadField1

func (*TStringBigSetKVServiceBsBulkLoadArgs) ReadField2

func (*TStringBigSetKVServiceBsBulkLoadArgs) String

func (*TStringBigSetKVServiceBsBulkLoadArgs) Write

type TStringBigSetKVServiceBsBulkLoadResult

type TStringBigSetKVServiceBsBulkLoadResult struct {
	Success *bool `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTStringBigSetKVServiceBsBulkLoadResult

func NewTStringBigSetKVServiceBsBulkLoadResult() *TStringBigSetKVServiceBsBulkLoadResult

func (*TStringBigSetKVServiceBsBulkLoadResult) GetSuccess

func (*TStringBigSetKVServiceBsBulkLoadResult) IsSetSuccess

func (p *TStringBigSetKVServiceBsBulkLoadResult) IsSetSuccess() bool

func (*TStringBigSetKVServiceBsBulkLoadResult) Read

func (*TStringBigSetKVServiceBsBulkLoadResult) ReadField0

func (*TStringBigSetKVServiceBsBulkLoadResult) String

func (*TStringBigSetKVServiceBsBulkLoadResult) Write

type TStringBigSetKVServiceBsExistedArgs

type TStringBigSetKVServiceBsExistedArgs struct {
	BsName  TStringKey `thrift:"bsName,1" db:"bsName" json:"bsName"`
	ItemKey TItemKey   `thrift:"itemKey,2" db:"itemKey" json:"itemKey"`
}

Attributes:

  • BsName
  • ItemKey

func NewTStringBigSetKVServiceBsExistedArgs

func NewTStringBigSetKVServiceBsExistedArgs() *TStringBigSetKVServiceBsExistedArgs

func (*TStringBigSetKVServiceBsExistedArgs) GetBsName

func (*TStringBigSetKVServiceBsExistedArgs) GetItemKey

func (*TStringBigSetKVServiceBsExistedArgs) Read

func (*TStringBigSetKVServiceBsExistedArgs) ReadField1

func (*TStringBigSetKVServiceBsExistedArgs) ReadField2

func (*TStringBigSetKVServiceBsExistedArgs) String

func (*TStringBigSetKVServiceBsExistedArgs) Write

type TStringBigSetKVServiceBsExistedResult

type TStringBigSetKVServiceBsExistedResult struct {
	Success *TExistedResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTStringBigSetKVServiceBsExistedResult

func NewTStringBigSetKVServiceBsExistedResult() *TStringBigSetKVServiceBsExistedResult

func (*TStringBigSetKVServiceBsExistedResult) GetSuccess

func (*TStringBigSetKVServiceBsExistedResult) IsSetSuccess

func (p *TStringBigSetKVServiceBsExistedResult) IsSetSuccess() bool

func (*TStringBigSetKVServiceBsExistedResult) Read

func (*TStringBigSetKVServiceBsExistedResult) ReadField0

func (*TStringBigSetKVServiceBsExistedResult) String

func (*TStringBigSetKVServiceBsExistedResult) Write

type TStringBigSetKVServiceBsGetItemArgs

type TStringBigSetKVServiceBsGetItemArgs struct {
	BsName  TStringKey `thrift:"bsName,1" db:"bsName" json:"bsName"`
	ItemKey TItemKey   `thrift:"itemKey,2" db:"itemKey" json:"itemKey"`
}

Attributes:

  • BsName
  • ItemKey

func NewTStringBigSetKVServiceBsGetItemArgs

func NewTStringBigSetKVServiceBsGetItemArgs() *TStringBigSetKVServiceBsGetItemArgs

func (*TStringBigSetKVServiceBsGetItemArgs) GetBsName

func (*TStringBigSetKVServiceBsGetItemArgs) GetItemKey

func (*TStringBigSetKVServiceBsGetItemArgs) Read

func (*TStringBigSetKVServiceBsGetItemArgs) ReadField1

func (*TStringBigSetKVServiceBsGetItemArgs) ReadField2

func (*TStringBigSetKVServiceBsGetItemArgs) String

func (*TStringBigSetKVServiceBsGetItemArgs) Write

type TStringBigSetKVServiceBsGetItemResult

type TStringBigSetKVServiceBsGetItemResult struct {
	Success *TItemResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTStringBigSetKVServiceBsGetItemResult

func NewTStringBigSetKVServiceBsGetItemResult() *TStringBigSetKVServiceBsGetItemResult

func (*TStringBigSetKVServiceBsGetItemResult) GetSuccess

func (*TStringBigSetKVServiceBsGetItemResult) IsSetSuccess

func (p *TStringBigSetKVServiceBsGetItemResult) IsSetSuccess() bool

func (*TStringBigSetKVServiceBsGetItemResult) Read

func (*TStringBigSetKVServiceBsGetItemResult) ReadField0

func (*TStringBigSetKVServiceBsGetItemResult) String

func (*TStringBigSetKVServiceBsGetItemResult) Write

type TStringBigSetKVServiceBsGetSliceArgs

type TStringBigSetKVServiceBsGetSliceArgs struct {
	BsName  TStringKey `thrift:"bsName,1" db:"bsName" json:"bsName"`
	FromPos int32      `thrift:"fromPos,2" db:"fromPos" json:"fromPos"`
	Count   int32      `thrift:"count,3" db:"count" json:"count"`
}

Attributes:

  • BsName
  • FromPos
  • Count

func NewTStringBigSetKVServiceBsGetSliceArgs

func NewTStringBigSetKVServiceBsGetSliceArgs() *TStringBigSetKVServiceBsGetSliceArgs

func (*TStringBigSetKVServiceBsGetSliceArgs) GetBsName

func (*TStringBigSetKVServiceBsGetSliceArgs) GetCount

func (*TStringBigSetKVServiceBsGetSliceArgs) GetFromPos

func (*TStringBigSetKVServiceBsGetSliceArgs) Read

func (*TStringBigSetKVServiceBsGetSliceArgs) ReadField1

func (*TStringBigSetKVServiceBsGetSliceArgs) ReadField2

func (*TStringBigSetKVServiceBsGetSliceArgs) ReadField3

func (*TStringBigSetKVServiceBsGetSliceArgs) String

func (*TStringBigSetKVServiceBsGetSliceArgs) Write

type TStringBigSetKVServiceBsGetSliceFromItemArgs

type TStringBigSetKVServiceBsGetSliceFromItemArgs struct {
	BsName  TStringKey `thrift:"bsName,1" db:"bsName" json:"bsName"`
	FromKey TItemKey   `thrift:"fromKey,2" db:"fromKey" json:"fromKey"`
	Count   int32      `thrift:"count,3" db:"count" json:"count"`
}

Attributes:

  • BsName
  • FromKey
  • Count

func NewTStringBigSetKVServiceBsGetSliceFromItemArgs

func NewTStringBigSetKVServiceBsGetSliceFromItemArgs() *TStringBigSetKVServiceBsGetSliceFromItemArgs

func (*TStringBigSetKVServiceBsGetSliceFromItemArgs) GetBsName

func (*TStringBigSetKVServiceBsGetSliceFromItemArgs) GetCount

func (*TStringBigSetKVServiceBsGetSliceFromItemArgs) GetFromKey

func (*TStringBigSetKVServiceBsGetSliceFromItemArgs) Read

func (*TStringBigSetKVServiceBsGetSliceFromItemArgs) ReadField1

func (*TStringBigSetKVServiceBsGetSliceFromItemArgs) ReadField2

func (*TStringBigSetKVServiceBsGetSliceFromItemArgs) ReadField3

func (*TStringBigSetKVServiceBsGetSliceFromItemArgs) String

func (*TStringBigSetKVServiceBsGetSliceFromItemArgs) Write

type TStringBigSetKVServiceBsGetSliceFromItemRArgs

type TStringBigSetKVServiceBsGetSliceFromItemRArgs struct {
	BsName  TStringKey `thrift:"bsName,1" db:"bsName" json:"bsName"`
	FromKey TItemKey   `thrift:"fromKey,2" db:"fromKey" json:"fromKey"`
	Count   int32      `thrift:"count,3" db:"count" json:"count"`
}

Attributes:

  • BsName
  • FromKey
  • Count

func NewTStringBigSetKVServiceBsGetSliceFromItemRArgs

func NewTStringBigSetKVServiceBsGetSliceFromItemRArgs() *TStringBigSetKVServiceBsGetSliceFromItemRArgs

func (*TStringBigSetKVServiceBsGetSliceFromItemRArgs) GetBsName

func (*TStringBigSetKVServiceBsGetSliceFromItemRArgs) GetCount

func (*TStringBigSetKVServiceBsGetSliceFromItemRArgs) GetFromKey

func (*TStringBigSetKVServiceBsGetSliceFromItemRArgs) Read

func (*TStringBigSetKVServiceBsGetSliceFromItemRArgs) ReadField1

func (*TStringBigSetKVServiceBsGetSliceFromItemRArgs) ReadField2

func (*TStringBigSetKVServiceBsGetSliceFromItemRArgs) ReadField3

func (*TStringBigSetKVServiceBsGetSliceFromItemRArgs) String

func (*TStringBigSetKVServiceBsGetSliceFromItemRArgs) Write

type TStringBigSetKVServiceBsGetSliceFromItemRResult

type TStringBigSetKVServiceBsGetSliceFromItemRResult struct {
	Success *TItemSetResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTStringBigSetKVServiceBsGetSliceFromItemRResult

func NewTStringBigSetKVServiceBsGetSliceFromItemRResult() *TStringBigSetKVServiceBsGetSliceFromItemRResult

func (*TStringBigSetKVServiceBsGetSliceFromItemRResult) GetSuccess

func (*TStringBigSetKVServiceBsGetSliceFromItemRResult) IsSetSuccess

func (*TStringBigSetKVServiceBsGetSliceFromItemRResult) Read

func (*TStringBigSetKVServiceBsGetSliceFromItemRResult) ReadField0

func (*TStringBigSetKVServiceBsGetSliceFromItemRResult) String

func (*TStringBigSetKVServiceBsGetSliceFromItemRResult) Write

type TStringBigSetKVServiceBsGetSliceFromItemResult

type TStringBigSetKVServiceBsGetSliceFromItemResult struct {
	Success *TItemSetResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTStringBigSetKVServiceBsGetSliceFromItemResult

func NewTStringBigSetKVServiceBsGetSliceFromItemResult() *TStringBigSetKVServiceBsGetSliceFromItemResult

func (*TStringBigSetKVServiceBsGetSliceFromItemResult) GetSuccess

func (*TStringBigSetKVServiceBsGetSliceFromItemResult) IsSetSuccess

func (*TStringBigSetKVServiceBsGetSliceFromItemResult) Read

func (*TStringBigSetKVServiceBsGetSliceFromItemResult) ReadField0

func (*TStringBigSetKVServiceBsGetSliceFromItemResult) String

func (*TStringBigSetKVServiceBsGetSliceFromItemResult) Write

type TStringBigSetKVServiceBsGetSliceRArgs

type TStringBigSetKVServiceBsGetSliceRArgs struct {
	BsName  TStringKey `thrift:"bsName,1" db:"bsName" json:"bsName"`
	FromPos int32      `thrift:"fromPos,2" db:"fromPos" json:"fromPos"`
	Count   int32      `thrift:"count,3" db:"count" json:"count"`
}

Attributes:

  • BsName
  • FromPos
  • Count

func NewTStringBigSetKVServiceBsGetSliceRArgs

func NewTStringBigSetKVServiceBsGetSliceRArgs() *TStringBigSetKVServiceBsGetSliceRArgs

func (*TStringBigSetKVServiceBsGetSliceRArgs) GetBsName

func (*TStringBigSetKVServiceBsGetSliceRArgs) GetCount

func (*TStringBigSetKVServiceBsGetSliceRArgs) GetFromPos

func (*TStringBigSetKVServiceBsGetSliceRArgs) Read

func (*TStringBigSetKVServiceBsGetSliceRArgs) ReadField1

func (*TStringBigSetKVServiceBsGetSliceRArgs) ReadField2

func (*TStringBigSetKVServiceBsGetSliceRArgs) ReadField3

func (*TStringBigSetKVServiceBsGetSliceRArgs) String

func (*TStringBigSetKVServiceBsGetSliceRArgs) Write

type TStringBigSetKVServiceBsGetSliceRResult

type TStringBigSetKVServiceBsGetSliceRResult struct {
	Success *TItemSetResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTStringBigSetKVServiceBsGetSliceRResult

func NewTStringBigSetKVServiceBsGetSliceRResult() *TStringBigSetKVServiceBsGetSliceRResult

func (*TStringBigSetKVServiceBsGetSliceRResult) GetSuccess

func (*TStringBigSetKVServiceBsGetSliceRResult) IsSetSuccess

func (*TStringBigSetKVServiceBsGetSliceRResult) Read

func (*TStringBigSetKVServiceBsGetSliceRResult) ReadField0

func (*TStringBigSetKVServiceBsGetSliceRResult) String

func (*TStringBigSetKVServiceBsGetSliceRResult) Write

type TStringBigSetKVServiceBsGetSliceResult

type TStringBigSetKVServiceBsGetSliceResult struct {
	Success *TItemSetResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTStringBigSetKVServiceBsGetSliceResult

func NewTStringBigSetKVServiceBsGetSliceResult() *TStringBigSetKVServiceBsGetSliceResult

func (*TStringBigSetKVServiceBsGetSliceResult) GetSuccess

func (*TStringBigSetKVServiceBsGetSliceResult) IsSetSuccess

func (p *TStringBigSetKVServiceBsGetSliceResult) IsSetSuccess() bool

func (*TStringBigSetKVServiceBsGetSliceResult) Read

func (*TStringBigSetKVServiceBsGetSliceResult) ReadField0

func (*TStringBigSetKVServiceBsGetSliceResult) String

func (*TStringBigSetKVServiceBsGetSliceResult) Write

type TStringBigSetKVServiceBsMultiPutArgs

type TStringBigSetKVServiceBsMultiPutArgs struct {
	BsName           TStringKey `thrift:"bsName,1" db:"bsName" json:"bsName"`
	SetData          *TItemSet  `thrift:"setData,2" db:"setData" json:"setData"`
	GetAddedItems    bool       `thrift:"getAddedItems,3" db:"getAddedItems" json:"getAddedItems"`
	GetReplacedItems bool       `thrift:"getReplacedItems,4" db:"getReplacedItems" json:"getReplacedItems"`
}

Attributes:

  • BsName
  • SetData
  • GetAddedItems
  • GetReplacedItems

func NewTStringBigSetKVServiceBsMultiPutArgs

func NewTStringBigSetKVServiceBsMultiPutArgs() *TStringBigSetKVServiceBsMultiPutArgs

func (*TStringBigSetKVServiceBsMultiPutArgs) GetBsName

func (*TStringBigSetKVServiceBsMultiPutArgs) GetGetAddedItems

func (p *TStringBigSetKVServiceBsMultiPutArgs) GetGetAddedItems() bool

func (*TStringBigSetKVServiceBsMultiPutArgs) GetGetReplacedItems

func (p *TStringBigSetKVServiceBsMultiPutArgs) GetGetReplacedItems() bool

func (*TStringBigSetKVServiceBsMultiPutArgs) GetSetData

func (*TStringBigSetKVServiceBsMultiPutArgs) IsSetSetData

func (p *TStringBigSetKVServiceBsMultiPutArgs) IsSetSetData() bool

func (*TStringBigSetKVServiceBsMultiPutArgs) Read

func (*TStringBigSetKVServiceBsMultiPutArgs) ReadField1

func (*TStringBigSetKVServiceBsMultiPutArgs) ReadField2

func (*TStringBigSetKVServiceBsMultiPutArgs) ReadField3

func (*TStringBigSetKVServiceBsMultiPutArgs) ReadField4

func (*TStringBigSetKVServiceBsMultiPutArgs) String

func (*TStringBigSetKVServiceBsMultiPutArgs) Write

type TStringBigSetKVServiceBsMultiPutResult

type TStringBigSetKVServiceBsMultiPutResult struct {
	Success *TMultiPutItemResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTStringBigSetKVServiceBsMultiPutResult

func NewTStringBigSetKVServiceBsMultiPutResult() *TStringBigSetKVServiceBsMultiPutResult

func (*TStringBigSetKVServiceBsMultiPutResult) GetSuccess

func (*TStringBigSetKVServiceBsMultiPutResult) IsSetSuccess

func (p *TStringBigSetKVServiceBsMultiPutResult) IsSetSuccess() bool

func (*TStringBigSetKVServiceBsMultiPutResult) Read

func (*TStringBigSetKVServiceBsMultiPutResult) ReadField0

func (*TStringBigSetKVServiceBsMultiPutResult) String

func (*TStringBigSetKVServiceBsMultiPutResult) Write

type TStringBigSetKVServiceBsPutItemArgs

type TStringBigSetKVServiceBsPutItemArgs struct {
	BsName TStringKey `thrift:"bsName,1" db:"bsName" json:"bsName"`
	Item   *TItem     `thrift:"item,2" db:"item" json:"item"`
}

Attributes:

  • BsName
  • Item

func NewTStringBigSetKVServiceBsPutItemArgs

func NewTStringBigSetKVServiceBsPutItemArgs() *TStringBigSetKVServiceBsPutItemArgs

func (*TStringBigSetKVServiceBsPutItemArgs) GetBsName

func (*TStringBigSetKVServiceBsPutItemArgs) GetItem

func (*TStringBigSetKVServiceBsPutItemArgs) IsSetItem

func (*TStringBigSetKVServiceBsPutItemArgs) Read

func (*TStringBigSetKVServiceBsPutItemArgs) ReadField1

func (*TStringBigSetKVServiceBsPutItemArgs) ReadField2

func (*TStringBigSetKVServiceBsPutItemArgs) String

func (*TStringBigSetKVServiceBsPutItemArgs) Write

type TStringBigSetKVServiceBsPutItemResult

type TStringBigSetKVServiceBsPutItemResult struct {
	Success *TPutItemResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTStringBigSetKVServiceBsPutItemResult

func NewTStringBigSetKVServiceBsPutItemResult() *TStringBigSetKVServiceBsPutItemResult

func (*TStringBigSetKVServiceBsPutItemResult) GetSuccess

func (*TStringBigSetKVServiceBsPutItemResult) IsSetSuccess

func (p *TStringBigSetKVServiceBsPutItemResult) IsSetSuccess() bool

func (*TStringBigSetKVServiceBsPutItemResult) Read

func (*TStringBigSetKVServiceBsPutItemResult) ReadField0

func (*TStringBigSetKVServiceBsPutItemResult) String

func (*TStringBigSetKVServiceBsPutItemResult) Write

type TStringBigSetKVServiceBsRangeQueryArgs

type TStringBigSetKVServiceBsRangeQueryArgs struct {
	BsName   TStringKey `thrift:"bsName,1" db:"bsName" json:"bsName"`
	StartKey TItemKey   `thrift:"startKey,2" db:"startKey" json:"startKey"`
	EndKey   TItemKey   `thrift:"endKey,3" db:"endKey" json:"endKey"`
}

Attributes:

  • BsName
  • StartKey
  • EndKey

func NewTStringBigSetKVServiceBsRangeQueryArgs

func NewTStringBigSetKVServiceBsRangeQueryArgs() *TStringBigSetKVServiceBsRangeQueryArgs

func (*TStringBigSetKVServiceBsRangeQueryArgs) GetBsName

func (*TStringBigSetKVServiceBsRangeQueryArgs) GetEndKey

func (*TStringBigSetKVServiceBsRangeQueryArgs) GetStartKey

func (*TStringBigSetKVServiceBsRangeQueryArgs) Read

func (*TStringBigSetKVServiceBsRangeQueryArgs) ReadField1

func (*TStringBigSetKVServiceBsRangeQueryArgs) ReadField2

func (*TStringBigSetKVServiceBsRangeQueryArgs) ReadField3

func (*TStringBigSetKVServiceBsRangeQueryArgs) String

func (*TStringBigSetKVServiceBsRangeQueryArgs) Write

type TStringBigSetKVServiceBsRangeQueryResult

type TStringBigSetKVServiceBsRangeQueryResult struct {
	Success *TItemSetResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTStringBigSetKVServiceBsRangeQueryResult

func NewTStringBigSetKVServiceBsRangeQueryResult() *TStringBigSetKVServiceBsRangeQueryResult

func (*TStringBigSetKVServiceBsRangeQueryResult) GetSuccess

func (*TStringBigSetKVServiceBsRangeQueryResult) IsSetSuccess

func (*TStringBigSetKVServiceBsRangeQueryResult) Read

func (*TStringBigSetKVServiceBsRangeQueryResult) ReadField0

func (*TStringBigSetKVServiceBsRangeQueryResult) String

func (*TStringBigSetKVServiceBsRangeQueryResult) Write

type TStringBigSetKVServiceBsRemoveItemArgs

type TStringBigSetKVServiceBsRemoveItemArgs struct {
	BsName  TStringKey `thrift:"bsName,1" db:"bsName" json:"bsName"`
	ItemKey TItemKey   `thrift:"itemKey,2" db:"itemKey" json:"itemKey"`
}

Attributes:

  • BsName
  • ItemKey

func NewTStringBigSetKVServiceBsRemoveItemArgs

func NewTStringBigSetKVServiceBsRemoveItemArgs() *TStringBigSetKVServiceBsRemoveItemArgs

func (*TStringBigSetKVServiceBsRemoveItemArgs) GetBsName

func (*TStringBigSetKVServiceBsRemoveItemArgs) GetItemKey

func (*TStringBigSetKVServiceBsRemoveItemArgs) Read

func (*TStringBigSetKVServiceBsRemoveItemArgs) ReadField1

func (*TStringBigSetKVServiceBsRemoveItemArgs) ReadField2

func (*TStringBigSetKVServiceBsRemoveItemArgs) String

func (*TStringBigSetKVServiceBsRemoveItemArgs) Write

type TStringBigSetKVServiceBsRemoveItemResult

type TStringBigSetKVServiceBsRemoveItemResult struct {
	Success *bool `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTStringBigSetKVServiceBsRemoveItemResult

func NewTStringBigSetKVServiceBsRemoveItemResult() *TStringBigSetKVServiceBsRemoveItemResult

func (*TStringBigSetKVServiceBsRemoveItemResult) GetSuccess

func (*TStringBigSetKVServiceBsRemoveItemResult) IsSetSuccess

func (*TStringBigSetKVServiceBsRemoveItemResult) Read

func (*TStringBigSetKVServiceBsRemoveItemResult) ReadField0

func (*TStringBigSetKVServiceBsRemoveItemResult) String

func (*TStringBigSetKVServiceBsRemoveItemResult) Write

type TStringBigSetKVServiceClient

type TStringBigSetKVServiceClient struct {
	// contains filtered or unexported fields
}

func NewTStringBigSetKVServiceClient

func NewTStringBigSetKVServiceClient(c thrift.TClient) *TStringBigSetKVServiceClient

func NewTStringBigSetKVServiceClientProtocol

func NewTStringBigSetKVServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *TStringBigSetKVServiceClient

func (*TStringBigSetKVServiceClient) AssignBigSetName

func (p *TStringBigSetKVServiceClient) AssignBigSetName(ctx context.Context, bsName TStringKey, bigsetID TContainerKey) (r *TBigSetInfoResult_, err error)

Parameters:

  • BsName
  • BigsetID

func (*TStringBigSetKVServiceClient) BsBulkLoad

func (p *TStringBigSetKVServiceClient) BsBulkLoad(ctx context.Context, bsName TStringKey, setData *TItemSet) (r bool, err error)

Parameters:

  • BsName
  • SetData

func (*TStringBigSetKVServiceClient) BsExisted

func (p *TStringBigSetKVServiceClient) BsExisted(ctx context.Context, bsName TStringKey, itemKey TItemKey) (r *TExistedResult_, err error)

Parameters:

  • BsName
  • ItemKey

func (*TStringBigSetKVServiceClient) BsGetItem

func (p *TStringBigSetKVServiceClient) BsGetItem(ctx context.Context, bsName TStringKey, itemKey TItemKey) (r *TItemResult_, err error)

Parameters:

  • BsName
  • ItemKey

func (*TStringBigSetKVServiceClient) BsGetSlice

func (p *TStringBigSetKVServiceClient) BsGetSlice(ctx context.Context, bsName TStringKey, fromPos int32, count int32) (r *TItemSetResult_, err error)

Parameters:

  • BsName
  • FromPos
  • Count

func (*TStringBigSetKVServiceClient) BsGetSliceFromItem

func (p *TStringBigSetKVServiceClient) BsGetSliceFromItem(ctx context.Context, bsName TStringKey, fromKey TItemKey, count int32) (r *TItemSetResult_, err error)

Parameters:

  • BsName
  • FromKey
  • Count

func (*TStringBigSetKVServiceClient) BsGetSliceFromItemR

func (p *TStringBigSetKVServiceClient) BsGetSliceFromItemR(ctx context.Context, bsName TStringKey, fromKey TItemKey, count int32) (r *TItemSetResult_, err error)

Parameters:

  • BsName
  • FromKey
  • Count

func (*TStringBigSetKVServiceClient) BsGetSliceR

func (p *TStringBigSetKVServiceClient) BsGetSliceR(ctx context.Context, bsName TStringKey, fromPos int32, count int32) (r *TItemSetResult_, err error)

Parameters:

  • BsName
  • FromPos
  • Count

func (*TStringBigSetKVServiceClient) BsMultiPut

func (p *TStringBigSetKVServiceClient) BsMultiPut(ctx context.Context, bsName TStringKey, setData *TItemSet, getAddedItems bool, getReplacedItems bool) (r *TMultiPutItemResult_, err error)

Parameters:

  • BsName
  • SetData
  • GetAddedItems
  • GetReplacedItems

func (*TStringBigSetKVServiceClient) BsPutItem

func (p *TStringBigSetKVServiceClient) BsPutItem(ctx context.Context, bsName TStringKey, item *TItem) (r *TPutItemResult_, err error)

Parameters:

  • BsName
  • Item

func (*TStringBigSetKVServiceClient) BsRangeQuery

func (p *TStringBigSetKVServiceClient) BsRangeQuery(ctx context.Context, bsName TStringKey, startKey TItemKey, endKey TItemKey) (r *TItemSetResult_, err error)

Parameters:

  • BsName
  • StartKey
  • EndKey

func (*TStringBigSetKVServiceClient) BsRemoveItem

func (p *TStringBigSetKVServiceClient) BsRemoveItem(ctx context.Context, bsName TStringKey, itemKey TItemKey) (r bool, err error)

Parameters:

  • BsName
  • ItemKey

func (*TStringBigSetKVServiceClient) Client_

func (*TStringBigSetKVServiceClient) CreateStringBigSet

func (p *TStringBigSetKVServiceClient) CreateStringBigSet(ctx context.Context, bsName TStringKey) (r *TBigSetInfoResult_, err error)

Parameters:

  • BsName

func (*TStringBigSetKVServiceClient) GetBigSetInfoByName

func (p *TStringBigSetKVServiceClient) GetBigSetInfoByName(ctx context.Context, bsName TStringKey) (r *TBigSetInfoResult_, err error)

Parameters:

  • BsName

func (*TStringBigSetKVServiceClient) GetListKey

func (p *TStringBigSetKVServiceClient) GetListKey(ctx context.Context, fromIndex int64, count int32) (r []TStringKey, err error)

Parameters:

  • FromIndex
  • Count

func (*TStringBigSetKVServiceClient) GetListKeyFrom

func (p *TStringBigSetKVServiceClient) GetListKeyFrom(ctx context.Context, keyFrom TStringKey, count int32) (r []TStringKey, err error)

Parameters:

  • KeyFrom
  • Count

func (*TStringBigSetKVServiceClient) GetTotalCount

func (p *TStringBigSetKVServiceClient) GetTotalCount(ctx context.Context, bsName TStringKey) (r int64, err error)

Parameters:

  • BsName

func (*TStringBigSetKVServiceClient) RemoveAll

func (p *TStringBigSetKVServiceClient) RemoveAll(ctx context.Context, bsName TStringKey) (r int64, err error)

Parameters:

  • BsName

func (*TStringBigSetKVServiceClient) TotalStringKeyCount

func (p *TStringBigSetKVServiceClient) TotalStringKeyCount(ctx context.Context) (r int64, err error)

type TStringBigSetKVServiceCreateStringBigSetArgs

type TStringBigSetKVServiceCreateStringBigSetArgs struct {
	BsName TStringKey `thrift:"bsName,1" db:"bsName" json:"bsName"`
}

Attributes:

  • BsName

func NewTStringBigSetKVServiceCreateStringBigSetArgs

func NewTStringBigSetKVServiceCreateStringBigSetArgs() *TStringBigSetKVServiceCreateStringBigSetArgs

func (*TStringBigSetKVServiceCreateStringBigSetArgs) GetBsName

func (*TStringBigSetKVServiceCreateStringBigSetArgs) Read

func (*TStringBigSetKVServiceCreateStringBigSetArgs) ReadField1

func (*TStringBigSetKVServiceCreateStringBigSetArgs) String

func (*TStringBigSetKVServiceCreateStringBigSetArgs) Write

type TStringBigSetKVServiceCreateStringBigSetResult

type TStringBigSetKVServiceCreateStringBigSetResult struct {
	Success *TBigSetInfoResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTStringBigSetKVServiceCreateStringBigSetResult

func NewTStringBigSetKVServiceCreateStringBigSetResult() *TStringBigSetKVServiceCreateStringBigSetResult

func (*TStringBigSetKVServiceCreateStringBigSetResult) GetSuccess

func (*TStringBigSetKVServiceCreateStringBigSetResult) IsSetSuccess

func (*TStringBigSetKVServiceCreateStringBigSetResult) Read

func (*TStringBigSetKVServiceCreateStringBigSetResult) ReadField0

func (*TStringBigSetKVServiceCreateStringBigSetResult) String

func (*TStringBigSetKVServiceCreateStringBigSetResult) Write

type TStringBigSetKVServiceGetBigSetInfoByNameArgs

type TStringBigSetKVServiceGetBigSetInfoByNameArgs struct {
	BsName TStringKey `thrift:"bsName,1" db:"bsName" json:"bsName"`
}

Attributes:

  • BsName

func NewTStringBigSetKVServiceGetBigSetInfoByNameArgs

func NewTStringBigSetKVServiceGetBigSetInfoByNameArgs() *TStringBigSetKVServiceGetBigSetInfoByNameArgs

func (*TStringBigSetKVServiceGetBigSetInfoByNameArgs) GetBsName

func (*TStringBigSetKVServiceGetBigSetInfoByNameArgs) Read

func (*TStringBigSetKVServiceGetBigSetInfoByNameArgs) ReadField1

func (*TStringBigSetKVServiceGetBigSetInfoByNameArgs) String

func (*TStringBigSetKVServiceGetBigSetInfoByNameArgs) Write

type TStringBigSetKVServiceGetBigSetInfoByNameResult

type TStringBigSetKVServiceGetBigSetInfoByNameResult struct {
	Success *TBigSetInfoResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTStringBigSetKVServiceGetBigSetInfoByNameResult

func NewTStringBigSetKVServiceGetBigSetInfoByNameResult() *TStringBigSetKVServiceGetBigSetInfoByNameResult

func (*TStringBigSetKVServiceGetBigSetInfoByNameResult) GetSuccess

func (*TStringBigSetKVServiceGetBigSetInfoByNameResult) IsSetSuccess

func (*TStringBigSetKVServiceGetBigSetInfoByNameResult) Read

func (*TStringBigSetKVServiceGetBigSetInfoByNameResult) ReadField0

func (*TStringBigSetKVServiceGetBigSetInfoByNameResult) String

func (*TStringBigSetKVServiceGetBigSetInfoByNameResult) Write

type TStringBigSetKVServiceGetListKeyArgs

type TStringBigSetKVServiceGetListKeyArgs struct {
	FromIndex int64 `thrift:"fromIndex,1" db:"fromIndex" json:"fromIndex"`
	Count     int32 `thrift:"count,2" db:"count" json:"count"`
}

Attributes:

  • FromIndex
  • Count

func NewTStringBigSetKVServiceGetListKeyArgs

func NewTStringBigSetKVServiceGetListKeyArgs() *TStringBigSetKVServiceGetListKeyArgs

func (*TStringBigSetKVServiceGetListKeyArgs) GetCount

func (*TStringBigSetKVServiceGetListKeyArgs) GetFromIndex

func (p *TStringBigSetKVServiceGetListKeyArgs) GetFromIndex() int64

func (*TStringBigSetKVServiceGetListKeyArgs) Read

func (*TStringBigSetKVServiceGetListKeyArgs) ReadField1

func (*TStringBigSetKVServiceGetListKeyArgs) ReadField2

func (*TStringBigSetKVServiceGetListKeyArgs) String

func (*TStringBigSetKVServiceGetListKeyArgs) Write

type TStringBigSetKVServiceGetListKeyFromArgs

type TStringBigSetKVServiceGetListKeyFromArgs struct {
	KeyFrom TStringKey `thrift:"keyFrom,1" db:"keyFrom" json:"keyFrom"`
	Count   int32      `thrift:"count,2" db:"count" json:"count"`
}

Attributes:

  • KeyFrom
  • Count

func NewTStringBigSetKVServiceGetListKeyFromArgs

func NewTStringBigSetKVServiceGetListKeyFromArgs() *TStringBigSetKVServiceGetListKeyFromArgs

func (*TStringBigSetKVServiceGetListKeyFromArgs) GetCount

func (*TStringBigSetKVServiceGetListKeyFromArgs) GetKeyFrom

func (*TStringBigSetKVServiceGetListKeyFromArgs) Read

func (*TStringBigSetKVServiceGetListKeyFromArgs) ReadField1

func (*TStringBigSetKVServiceGetListKeyFromArgs) ReadField2

func (*TStringBigSetKVServiceGetListKeyFromArgs) String

func (*TStringBigSetKVServiceGetListKeyFromArgs) Write

type TStringBigSetKVServiceGetListKeyFromResult

type TStringBigSetKVServiceGetListKeyFromResult struct {
	Success []TStringKey `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTStringBigSetKVServiceGetListKeyFromResult

func NewTStringBigSetKVServiceGetListKeyFromResult() *TStringBigSetKVServiceGetListKeyFromResult

func (*TStringBigSetKVServiceGetListKeyFromResult) GetSuccess

func (*TStringBigSetKVServiceGetListKeyFromResult) IsSetSuccess

func (*TStringBigSetKVServiceGetListKeyFromResult) Read

func (*TStringBigSetKVServiceGetListKeyFromResult) ReadField0

func (*TStringBigSetKVServiceGetListKeyFromResult) String

func (*TStringBigSetKVServiceGetListKeyFromResult) Write

type TStringBigSetKVServiceGetListKeyResult

type TStringBigSetKVServiceGetListKeyResult struct {
	Success []TStringKey `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTStringBigSetKVServiceGetListKeyResult

func NewTStringBigSetKVServiceGetListKeyResult() *TStringBigSetKVServiceGetListKeyResult

func (*TStringBigSetKVServiceGetListKeyResult) GetSuccess

func (*TStringBigSetKVServiceGetListKeyResult) IsSetSuccess

func (p *TStringBigSetKVServiceGetListKeyResult) IsSetSuccess() bool

func (*TStringBigSetKVServiceGetListKeyResult) Read

func (*TStringBigSetKVServiceGetListKeyResult) ReadField0

func (*TStringBigSetKVServiceGetListKeyResult) String

func (*TStringBigSetKVServiceGetListKeyResult) Write

type TStringBigSetKVServiceGetTotalCountArgs

type TStringBigSetKVServiceGetTotalCountArgs struct {
	BsName TStringKey `thrift:"bsName,1" db:"bsName" json:"bsName"`
}

Attributes:

  • BsName

func NewTStringBigSetKVServiceGetTotalCountArgs

func NewTStringBigSetKVServiceGetTotalCountArgs() *TStringBigSetKVServiceGetTotalCountArgs

func (*TStringBigSetKVServiceGetTotalCountArgs) GetBsName

func (*TStringBigSetKVServiceGetTotalCountArgs) Read

func (*TStringBigSetKVServiceGetTotalCountArgs) ReadField1

func (*TStringBigSetKVServiceGetTotalCountArgs) String

func (*TStringBigSetKVServiceGetTotalCountArgs) Write

type TStringBigSetKVServiceGetTotalCountResult

type TStringBigSetKVServiceGetTotalCountResult struct {
	Success *int64 `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTStringBigSetKVServiceGetTotalCountResult

func NewTStringBigSetKVServiceGetTotalCountResult() *TStringBigSetKVServiceGetTotalCountResult

func (*TStringBigSetKVServiceGetTotalCountResult) GetSuccess

func (*TStringBigSetKVServiceGetTotalCountResult) IsSetSuccess

func (*TStringBigSetKVServiceGetTotalCountResult) Read

func (*TStringBigSetKVServiceGetTotalCountResult) ReadField0

func (*TStringBigSetKVServiceGetTotalCountResult) String

func (*TStringBigSetKVServiceGetTotalCountResult) Write

type TStringBigSetKVServiceProcessor

type TStringBigSetKVServiceProcessor struct {
	// contains filtered or unexported fields
}

func NewTStringBigSetKVServiceProcessor

func NewTStringBigSetKVServiceProcessor(handler TStringBigSetKVService) *TStringBigSetKVServiceProcessor

func (*TStringBigSetKVServiceProcessor) AddToProcessorMap

func (p *TStringBigSetKVServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)

func (*TStringBigSetKVServiceProcessor) GetProcessorFunction

func (p *TStringBigSetKVServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)

func (*TStringBigSetKVServiceProcessor) Process

func (p *TStringBigSetKVServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*TStringBigSetKVServiceProcessor) ProcessorMap

type TStringBigSetKVServiceRemoveAllArgs

type TStringBigSetKVServiceRemoveAllArgs struct {
	BsName TStringKey `thrift:"bsName,1" db:"bsName" json:"bsName"`
}

Attributes:

  • BsName

func NewTStringBigSetKVServiceRemoveAllArgs

func NewTStringBigSetKVServiceRemoveAllArgs() *TStringBigSetKVServiceRemoveAllArgs

func (*TStringBigSetKVServiceRemoveAllArgs) GetBsName

func (*TStringBigSetKVServiceRemoveAllArgs) Read

func (*TStringBigSetKVServiceRemoveAllArgs) ReadField1

func (*TStringBigSetKVServiceRemoveAllArgs) String

func (*TStringBigSetKVServiceRemoveAllArgs) Write

type TStringBigSetKVServiceRemoveAllResult

type TStringBigSetKVServiceRemoveAllResult struct {
	Success *int64 `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTStringBigSetKVServiceRemoveAllResult

func NewTStringBigSetKVServiceRemoveAllResult() *TStringBigSetKVServiceRemoveAllResult

func (*TStringBigSetKVServiceRemoveAllResult) GetSuccess

func (*TStringBigSetKVServiceRemoveAllResult) IsSetSuccess

func (p *TStringBigSetKVServiceRemoveAllResult) IsSetSuccess() bool

func (*TStringBigSetKVServiceRemoveAllResult) Read

func (*TStringBigSetKVServiceRemoveAllResult) ReadField0

func (*TStringBigSetKVServiceRemoveAllResult) String

func (*TStringBigSetKVServiceRemoveAllResult) Write

type TStringBigSetKVServiceTotalStringKeyCountArgs

type TStringBigSetKVServiceTotalStringKeyCountArgs struct {
}

func NewTStringBigSetKVServiceTotalStringKeyCountArgs

func NewTStringBigSetKVServiceTotalStringKeyCountArgs() *TStringBigSetKVServiceTotalStringKeyCountArgs

func (*TStringBigSetKVServiceTotalStringKeyCountArgs) Read

func (*TStringBigSetKVServiceTotalStringKeyCountArgs) String

func (*TStringBigSetKVServiceTotalStringKeyCountArgs) Write

type TStringBigSetKVServiceTotalStringKeyCountResult

type TStringBigSetKVServiceTotalStringKeyCountResult struct {
	Success *int64 `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTStringBigSetKVServiceTotalStringKeyCountResult

func NewTStringBigSetKVServiceTotalStringKeyCountResult() *TStringBigSetKVServiceTotalStringKeyCountResult

func (*TStringBigSetKVServiceTotalStringKeyCountResult) GetSuccess

func (*TStringBigSetKVServiceTotalStringKeyCountResult) IsSetSuccess

func (*TStringBigSetKVServiceTotalStringKeyCountResult) Read

func (*TStringBigSetKVServiceTotalStringKeyCountResult) ReadField0

func (*TStringBigSetKVServiceTotalStringKeyCountResult) String

func (*TStringBigSetKVServiceTotalStringKeyCountResult) Write

type TStringKey

type TStringKey string

func TStringKeyPtr

func TStringKeyPtr(v TStringKey) *TStringKey

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL