rrdb

package
v0.0.0-...-ba0e684 Latest Latest
Warning

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

 Go to latest Published: May 19, 2022 License: Apache-2.0 Imports: 9 Imported by: 8

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var CheckAndMutateRequest_CheckOperand_DEFAULT *base.Blob
View Source 
var CheckAndMutateRequest_CheckSortKey_DEFAULT *base.Blob
View Source 
var CheckAndMutateRequest_HashKey_DEFAULT *base.Blob
View Source 
var CheckAndMutateResponse_CheckValue_DEFAULT *base.Blob
View Source 
var CheckAndSetRequest_CheckOperand_DEFAULT *base.Blob
View Source 
var CheckAndSetRequest_CheckSortKey_DEFAULT *base.Blob
View Source 
var CheckAndSetRequest_HashKey_DEFAULT *base.Blob
View Source 
var CheckAndSetRequest_SetSortKey_DEFAULT *base.Blob
View Source 
var CheckAndSetRequest_SetValue_DEFAULT *base.Blob
View Source 
var CheckAndSetResponse_CheckValue_DEFAULT *base.Blob
View Source 
var GetScannerRequest_HashKeyFilterPattern_DEFAULT *base.Blob
View Source 
var GetScannerRequest_NeedCheckHash_DEFAULT bool
View Source 
var GetScannerRequest_SortKeyFilterPattern_DEFAULT *base.Blob
View Source 
var GetScannerRequest_StartKey_DEFAULT *base.Blob
View Source 
var GetScannerRequest_StopKey_DEFAULT *base.Blob
View Source 
var GoUnusedProtection__ int
View Source 
var IncrRequest_Key_DEFAULT *base.Blob
View Source 
var KeyValue_Key_DEFAULT *base.Blob
View Source 
var KeyValue_Value_DEFAULT *base.Blob
View Source 
var MetaQueryCfgArgs_Query_DEFAULT *replication.QueryCfgRequest
View Source 
var MetaQueryCfgResult_Success_DEFAULT *replication.QueryCfgResponse
View Source 
var MultiGetRequest_HashKey_DEFAULT *base.Blob
View Source 
var MultiGetRequest_SortKeyFilterPattern_DEFAULT *base.Blob
View Source 
var MultiGetRequest_StartSortkey_DEFAULT *base.Blob
View Source 
var MultiGetRequest_StopSortkey_DEFAULT *base.Blob
View Source 
var MultiPutRequest_HashKey_DEFAULT *base.Blob
View Source 
var MultiRemoveRequest_HashKey_DEFAULT *base.Blob
View Source 
var Mutate_SortKey_DEFAULT *base.Blob
View Source 
var Mutate_Value_DEFAULT *base.Blob
View Source 
var ReadResponse_Value_DEFAULT *base.Blob
View Source 
var RrdbGetArgs_Key_DEFAULT *base.Blob
View Source 
var RrdbRemoveArgs_Key_DEFAULT *base.Blob
View Source 
var RrdbSortkeyCountArgs_HashKey_DEFAULT *base.Blob
View Source 
var RrdbTTLArgs_Key_DEFAULT *base.Blob
View Source 
var UpdateRequest_Key_DEFAULT *base.Blob
View Source 
var UpdateRequest_Value_DEFAULT *base.Blob

Functions

This section is empty.

Types

type CasCheckType 

type CasCheckType int64
const (
	CasCheckType_CT_NO_CHECK                     CasCheckType = 0
	CasCheckType_CT_VALUE_NOT_EXIST              CasCheckType = 1
	CasCheckType_CT_VALUE_NOT_EXIST_OR_EMPTY     CasCheckType = 2
	CasCheckType_CT_VALUE_EXIST                  CasCheckType = 3
	CasCheckType_CT_VALUE_NOT_EMPTY              CasCheckType = 4
	CasCheckType_CT_VALUE_MATCH_ANYWHERE         CasCheckType = 5
	CasCheckType_CT_VALUE_MATCH_PREFIX           CasCheckType = 6
	CasCheckType_CT_VALUE_MATCH_POSTFIX          CasCheckType = 7
	CasCheckType_CT_VALUE_BYTES_LESS             CasCheckType = 8
	CasCheckType_CT_VALUE_BYTES_LESS_OR_EQUAL    CasCheckType = 9
	CasCheckType_CT_VALUE_BYTES_EQUAL            CasCheckType = 10
	CasCheckType_CT_VALUE_BYTES_GREATER_OR_EQUAL CasCheckType = 11
	CasCheckType_CT_VALUE_BYTES_GREATER          CasCheckType = 12
	CasCheckType_CT_VALUE_INT_LESS               CasCheckType = 13
	CasCheckType_CT_VALUE_INT_LESS_OR_EQUAL      CasCheckType = 14
	CasCheckType_CT_VALUE_INT_EQUAL              CasCheckType = 15
	CasCheckType_CT_VALUE_INT_GREATER_OR_EQUAL   CasCheckType = 16
	CasCheckType_CT_VALUE_INT_GREATER            CasCheckType = 17
)

func CasCheckTypeFromString 

func CasCheckTypeFromString(s string) (CasCheckType, error)

func CasCheckTypePtr 

func CasCheckTypePtr(v CasCheckType) *CasCheckType

func (CasCheckType) MarshalText 

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

func (*CasCheckType) Scan 

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

func (CasCheckType) String 

func (p CasCheckType) String() string

func (*CasCheckType) UnmarshalText 

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

func (*CasCheckType) Value 

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

type CheckAndMutateRequest 

type CheckAndMutateRequest struct {
	HashKey          *base.Blob   `thrift:"hash_key,1" db:"hash_key" json:"hash_key"`
	CheckSortKey     *base.Blob   `thrift:"check_sort_key,2" db:"check_sort_key" json:"check_sort_key"`
	CheckType        CasCheckType `thrift:"check_type,3" db:"check_type" json:"check_type"`
	CheckOperand     *base.Blob   `thrift:"check_operand,4" db:"check_operand" json:"check_operand"`
	MutateList       []*Mutate    `thrift:"mutate_list,5" db:"mutate_list" json:"mutate_list"`
	ReturnCheckValue bool         `thrift:"return_check_value,6" db:"return_check_value" json:"return_check_value"`
}

Attributes:

  • HashKey
  • CheckSortKey
  • CheckType
  • CheckOperand
  • MutateList
  • ReturnCheckValue
var RrdbCheckAndMutateArgs_Request_DEFAULT *CheckAndMutateRequest

func NewCheckAndMutateRequest 

func NewCheckAndMutateRequest() *CheckAndMutateRequest

func (*CheckAndMutateRequest) GetCheckOperand 

func (p *CheckAndMutateRequest) GetCheckOperand() *base.Blob

func (*CheckAndMutateRequest) GetCheckSortKey 

func (p *CheckAndMutateRequest) GetCheckSortKey() *base.Blob

func (*CheckAndMutateRequest) GetCheckType 

func (p *CheckAndMutateRequest) GetCheckType() CasCheckType

func (*CheckAndMutateRequest) GetHashKey 

func (p *CheckAndMutateRequest) GetHashKey() *base.Blob

func (*CheckAndMutateRequest) GetMutateList 

func (p *CheckAndMutateRequest) GetMutateList() []*Mutate

func (*CheckAndMutateRequest) GetReturnCheckValue 

func (p *CheckAndMutateRequest) GetReturnCheckValue() bool

func (*CheckAndMutateRequest) IsSetCheckOperand 

func (p *CheckAndMutateRequest) IsSetCheckOperand() bool

func (*CheckAndMutateRequest) IsSetCheckSortKey 

func (p *CheckAndMutateRequest) IsSetCheckSortKey() bool

func (*CheckAndMutateRequest) IsSetHashKey 

func (p *CheckAndMutateRequest) IsSetHashKey() bool

func (*CheckAndMutateRequest) Read 

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

func (*CheckAndMutateRequest) ReadField1 

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

func (*CheckAndMutateRequest) ReadField2 

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

func (*CheckAndMutateRequest) ReadField3 

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

func (*CheckAndMutateRequest) ReadField4 

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

func (*CheckAndMutateRequest) ReadField5 

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

func (*CheckAndMutateRequest) ReadField6 

func (p *CheckAndMutateRequest) ReadField6(iprot thrift.TProtocol) error

func (*CheckAndMutateRequest) String 

func (p *CheckAndMutateRequest) String() string

func (*CheckAndMutateRequest) Write 

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

type CheckAndMutateResponse 

type CheckAndMutateResponse struct {
	Error              int32      `thrift:"error,1" db:"error" json:"error"`
	CheckValueReturned bool       `thrift:"check_value_returned,2" db:"check_value_returned" json:"check_value_returned"`
	CheckValueExist    bool       `thrift:"check_value_exist,3" db:"check_value_exist" json:"check_value_exist"`
	CheckValue         *base.Blob `thrift:"check_value,4" db:"check_value" json:"check_value"`
	AppID              int32      `thrift:"app_id,5" db:"app_id" json:"app_id"`
	PartitionIndex     int32      `thrift:"partition_index,6" db:"partition_index" json:"partition_index"`
	Decree             int64      `thrift:"decree,7" db:"decree" json:"decree"`
	Server             string     `thrift:"server,8" db:"server" json:"server"`
}

Attributes:

  • Error
  • CheckValueReturned
  • CheckValueExist
  • CheckValue
  • AppID
  • PartitionIndex
  • Decree
  • Server
var RrdbCheckAndMutateResult_Success_DEFAULT *CheckAndMutateResponse

func NewCheckAndMutateResponse 

func NewCheckAndMutateResponse() *CheckAndMutateResponse

func (*CheckAndMutateResponse) GetAppID 

func (p *CheckAndMutateResponse) GetAppID() int32

func (*CheckAndMutateResponse) GetCheckValue 

func (p *CheckAndMutateResponse) GetCheckValue() *base.Blob

func (*CheckAndMutateResponse) GetCheckValueExist 

func (p *CheckAndMutateResponse) GetCheckValueExist() bool

func (*CheckAndMutateResponse) GetCheckValueReturned 

func (p *CheckAndMutateResponse) GetCheckValueReturned() bool

func (*CheckAndMutateResponse) GetDecree 

func (p *CheckAndMutateResponse) GetDecree() int64

func (*CheckAndMutateResponse) GetError 

func (p *CheckAndMutateResponse) GetError() int32

func (*CheckAndMutateResponse) GetPartitionIndex 

func (p *CheckAndMutateResponse) GetPartitionIndex() int32

func (*CheckAndMutateResponse) GetServer 

func (p *CheckAndMutateResponse) GetServer() string

func (*CheckAndMutateResponse) IsSetCheckValue 

func (p *CheckAndMutateResponse) IsSetCheckValue() bool

func (*CheckAndMutateResponse) Read 

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

func (*CheckAndMutateResponse) ReadField1 

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

func (*CheckAndMutateResponse) ReadField2 

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

func (*CheckAndMutateResponse) ReadField3 

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

func (*CheckAndMutateResponse) ReadField4 

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

func (*CheckAndMutateResponse) ReadField5 

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

func (*CheckAndMutateResponse) ReadField6 

func (p *CheckAndMutateResponse) ReadField6(iprot thrift.TProtocol) error

func (*CheckAndMutateResponse) ReadField7 

func (p *CheckAndMutateResponse) ReadField7(iprot thrift.TProtocol) error

func (*CheckAndMutateResponse) ReadField8 

func (p *CheckAndMutateResponse) ReadField8(iprot thrift.TProtocol) error

func (*CheckAndMutateResponse) String 

func (p *CheckAndMutateResponse) String() string

func (*CheckAndMutateResponse) Write 

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

type CheckAndSetRequest 

type CheckAndSetRequest struct {
	HashKey            *base.Blob   `thrift:"hash_key,1" db:"hash_key" json:"hash_key"`
	CheckSortKey       *base.Blob   `thrift:"check_sort_key,2" db:"check_sort_key" json:"check_sort_key"`
	CheckType          CasCheckType `thrift:"check_type,3" db:"check_type" json:"check_type"`
	CheckOperand       *base.Blob   `thrift:"check_operand,4" db:"check_operand" json:"check_operand"`
	SetDiffSortKey     bool         `thrift:"set_diff_sort_key,5" db:"set_diff_sort_key" json:"set_diff_sort_key"`
	SetSortKey         *base.Blob   `thrift:"set_sort_key,6" db:"set_sort_key" json:"set_sort_key"`
	SetValue           *base.Blob   `thrift:"set_value,7" db:"set_value" json:"set_value"`
	SetExpireTsSeconds int32        `thrift:"set_expire_ts_seconds,8" db:"set_expire_ts_seconds" json:"set_expire_ts_seconds"`
	ReturnCheckValue   bool         `thrift:"return_check_value,9" db:"return_check_value" json:"return_check_value"`
}

Attributes:

  • HashKey
  • CheckSortKey
  • CheckType
  • CheckOperand
  • SetDiffSortKey
  • SetSortKey
  • SetValue
  • SetExpireTsSeconds
  • ReturnCheckValue
var RrdbCheckAndSetArgs_Request_DEFAULT *CheckAndSetRequest

func NewCheckAndSetRequest 

func NewCheckAndSetRequest() *CheckAndSetRequest

func (*CheckAndSetRequest) GetCheckOperand 

func (p *CheckAndSetRequest) GetCheckOperand() *base.Blob

func (*CheckAndSetRequest) GetCheckSortKey 

func (p *CheckAndSetRequest) GetCheckSortKey() *base.Blob

func (*CheckAndSetRequest) GetCheckType 

func (p *CheckAndSetRequest) GetCheckType() CasCheckType

func (*CheckAndSetRequest) GetHashKey 

func (p *CheckAndSetRequest) GetHashKey() *base.Blob

func (*CheckAndSetRequest) GetReturnCheckValue 

func (p *CheckAndSetRequest) GetReturnCheckValue() bool

func (*CheckAndSetRequest) GetSetDiffSortKey 

func (p *CheckAndSetRequest) GetSetDiffSortKey() bool

func (*CheckAndSetRequest) GetSetExpireTsSeconds 

func (p *CheckAndSetRequest) GetSetExpireTsSeconds() int32

func (*CheckAndSetRequest) GetSetSortKey 

func (p *CheckAndSetRequest) GetSetSortKey() *base.Blob

func (*CheckAndSetRequest) GetSetValue 

func (p *CheckAndSetRequest) GetSetValue() *base.Blob

func (*CheckAndSetRequest) IsSetCheckOperand 

func (p *CheckAndSetRequest) IsSetCheckOperand() bool

func (*CheckAndSetRequest) IsSetCheckSortKey 

func (p *CheckAndSetRequest) IsSetCheckSortKey() bool

func (*CheckAndSetRequest) IsSetHashKey 

func (p *CheckAndSetRequest) IsSetHashKey() bool

func (*CheckAndSetRequest) IsSetSetSortKey 

func (p *CheckAndSetRequest) IsSetSetSortKey() bool

func (*CheckAndSetRequest) IsSetSetValue 

func (p *CheckAndSetRequest) IsSetSetValue() bool

func (*CheckAndSetRequest) Read 

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

func (*CheckAndSetRequest) ReadField1 

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

func (*CheckAndSetRequest) ReadField2 

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

func (*CheckAndSetRequest) ReadField3 

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

func (*CheckAndSetRequest) ReadField4 

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

func (*CheckAndSetRequest) ReadField5 

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

func (*CheckAndSetRequest) ReadField6 

func (p *CheckAndSetRequest) ReadField6(iprot thrift.TProtocol) error

func (*CheckAndSetRequest) ReadField7 

func (p *CheckAndSetRequest) ReadField7(iprot thrift.TProtocol) error

func (*CheckAndSetRequest) ReadField8 

func (p *CheckAndSetRequest) ReadField8(iprot thrift.TProtocol) error

func (*CheckAndSetRequest) ReadField9 

func (p *CheckAndSetRequest) ReadField9(iprot thrift.TProtocol) error

func (*CheckAndSetRequest) String 

func (p *CheckAndSetRequest) String() string

func (*CheckAndSetRequest) Write 

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

type CheckAndSetResponse 

type CheckAndSetResponse struct {
	Error              int32      `thrift:"error,1" db:"error" json:"error"`
	CheckValueReturned bool       `thrift:"check_value_returned,2" db:"check_value_returned" json:"check_value_returned"`
	CheckValueExist    bool       `thrift:"check_value_exist,3" db:"check_value_exist" json:"check_value_exist"`
	CheckValue         *base.Blob `thrift:"check_value,4" db:"check_value" json:"check_value"`
	AppID              int32      `thrift:"app_id,5" db:"app_id" json:"app_id"`
	PartitionIndex     int32      `thrift:"partition_index,6" db:"partition_index" json:"partition_index"`
	Decree             int64      `thrift:"decree,7" db:"decree" json:"decree"`
	Server             string     `thrift:"server,8" db:"server" json:"server"`
}

Attributes:

  • Error
  • CheckValueReturned
  • CheckValueExist
  • CheckValue
  • AppID
  • PartitionIndex
  • Decree
  • Server
var RrdbCheckAndSetResult_Success_DEFAULT *CheckAndSetResponse

func NewCheckAndSetResponse 

func NewCheckAndSetResponse() *CheckAndSetResponse

func (*CheckAndSetResponse) GetAppID 

func (p *CheckAndSetResponse) GetAppID() int32

func (*CheckAndSetResponse) GetCheckValue 

func (p *CheckAndSetResponse) GetCheckValue() *base.Blob

func (*CheckAndSetResponse) GetCheckValueExist 

func (p *CheckAndSetResponse) GetCheckValueExist() bool

func (*CheckAndSetResponse) GetCheckValueReturned 

func (p *CheckAndSetResponse) GetCheckValueReturned() bool

func (*CheckAndSetResponse) GetDecree 

func (p *CheckAndSetResponse) GetDecree() int64

func (*CheckAndSetResponse) GetError 

func (p *CheckAndSetResponse) GetError() int32

func (*CheckAndSetResponse) GetPartitionIndex 

func (p *CheckAndSetResponse) GetPartitionIndex() int32

func (*CheckAndSetResponse) GetServer 

func (p *CheckAndSetResponse) GetServer() string

func (*CheckAndSetResponse) IsSetCheckValue 

func (p *CheckAndSetResponse) IsSetCheckValue() bool

func (*CheckAndSetResponse) Read 

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

func (*CheckAndSetResponse) ReadField1 

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

func (*CheckAndSetResponse) ReadField2 

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

func (*CheckAndSetResponse) ReadField3 

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

func (*CheckAndSetResponse) ReadField4 

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

func (*CheckAndSetResponse) ReadField5 

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

func (*CheckAndSetResponse) ReadField6 

func (p *CheckAndSetResponse) ReadField6(iprot thrift.TProtocol) error

func (*CheckAndSetResponse) ReadField7 

func (p *CheckAndSetResponse) ReadField7(iprot thrift.TProtocol) error

func (*CheckAndSetResponse) ReadField8 

func (p *CheckAndSetResponse) ReadField8(iprot thrift.TProtocol) error

func (*CheckAndSetResponse) String 

func (p *CheckAndSetResponse) String() string

func (*CheckAndSetResponse) Write 

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

type CountResponse 

type CountResponse struct {
	Error          int32 `thrift:"error,1" db:"error" json:"error"`
	Count          int64 `thrift:"count,2" db:"count" json:"count"`
	AppID          int32 `thrift:"app_id,3" db:"app_id" json:"app_id"`
	PartitionIndex int32 `thrift:"partition_index,4" db:"partition_index" json:"partition_index"`
	// unused field # 5
	Server string `thrift:"server,6" db:"server" json:"server"`
}

Attributes:

  • Error
  • Count
  • AppID
  • PartitionIndex
  • Server
var RrdbSortkeyCountResult_Success_DEFAULT *CountResponse

func NewCountResponse 

func NewCountResponse() *CountResponse

func (*CountResponse) GetAppID 

func (p *CountResponse) GetAppID() int32

func (*CountResponse) GetCount 

func (p *CountResponse) GetCount() int64

func (*CountResponse) GetError 

func (p *CountResponse) GetError() int32

func (*CountResponse) GetPartitionIndex 

func (p *CountResponse) GetPartitionIndex() int32

func (*CountResponse) GetServer 

func (p *CountResponse) GetServer() string

func (*CountResponse) Read 

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

func (*CountResponse) ReadField1 

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

func (*CountResponse) ReadField2 

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

func (*CountResponse) ReadField3 

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

func (*CountResponse) ReadField4 

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

func (*CountResponse) ReadField6 

func (p *CountResponse) ReadField6(iprot thrift.TProtocol) error

func (*CountResponse) String 

func (p *CountResponse) String() string

func (*CountResponse) Write 

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

type FilterType 

type FilterType int64
const (
	FilterType_FT_NO_FILTER      FilterType = 0
	FilterType_FT_MATCH_ANYWHERE FilterType = 1
	FilterType_FT_MATCH_PREFIX   FilterType = 2
	FilterType_FT_MATCH_POSTFIX  FilterType = 3
)

func FilterTypeFromString 

func FilterTypeFromString(s string) (FilterType, error)

func FilterTypePtr 

func FilterTypePtr(v FilterType) *FilterType

func (FilterType) MarshalText 

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

func (*FilterType) Scan 

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

func (FilterType) String 

func (p FilterType) String() string

func (*FilterType) UnmarshalText 

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

func (*FilterType) Value 

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

type GetScannerRequest 

type GetScannerRequest struct {
	StartKey             *base.Blob `thrift:"start_key,1" db:"start_key" json:"start_key"`
	StopKey              *base.Blob `thrift:"stop_key,2" db:"stop_key" json:"stop_key"`
	StartInclusive       bool       `thrift:"start_inclusive,3" db:"start_inclusive" json:"start_inclusive"`
	StopInclusive        bool       `thrift:"stop_inclusive,4" db:"stop_inclusive" json:"stop_inclusive"`
	BatchSize            int32      `thrift:"batch_size,5" db:"batch_size" json:"batch_size"`
	NoValue              bool       `thrift:"no_value,6" db:"no_value" json:"no_value"`
	HashKeyFilterType    FilterType `thrift:"hash_key_filter_type,7" db:"hash_key_filter_type" json:"hash_key_filter_type"`
	HashKeyFilterPattern *base.Blob `thrift:"hash_key_filter_pattern,8" db:"hash_key_filter_pattern" json:"hash_key_filter_pattern"`
	SortKeyFilterType    FilterType `thrift:"sort_key_filter_type,9" db:"sort_key_filter_type" json:"sort_key_filter_type"`
	SortKeyFilterPattern *base.Blob `thrift:"sort_key_filter_pattern,10" db:"sort_key_filter_pattern" json:"sort_key_filter_pattern"`
	NeedCheckHash        *bool      `thrift:"need_check_hash,11" db:"need_check_hash" json:"need_check_hash,omitempty"`
}

Attributes:

  • StartKey
  • StopKey
  • StartInclusive
  • StopInclusive
  • BatchSize
  • NoValue
  • HashKeyFilterType
  • HashKeyFilterPattern
  • SortKeyFilterType
  • SortKeyFilterPattern
  • NeedCheckHash
var RrdbGetScannerArgs_Request_DEFAULT *GetScannerRequest

func NewGetScannerRequest 

func NewGetScannerRequest() *GetScannerRequest

func (*GetScannerRequest) GetBatchSize 

func (p *GetScannerRequest) GetBatchSize() int32

func (*GetScannerRequest) GetHashKeyFilterPattern 

func (p *GetScannerRequest) GetHashKeyFilterPattern() *base.Blob

func (*GetScannerRequest) GetHashKeyFilterType 

func (p *GetScannerRequest) GetHashKeyFilterType() FilterType

func (*GetScannerRequest) GetNeedCheckHash 

func (p *GetScannerRequest) GetNeedCheckHash() bool

func (*GetScannerRequest) GetNoValue 

func (p *GetScannerRequest) GetNoValue() bool

func (*GetScannerRequest) GetSortKeyFilterPattern 

func (p *GetScannerRequest) GetSortKeyFilterPattern() *base.Blob

func (*GetScannerRequest) GetSortKeyFilterType 

func (p *GetScannerRequest) GetSortKeyFilterType() FilterType

func (*GetScannerRequest) GetStartInclusive 

func (p *GetScannerRequest) GetStartInclusive() bool

func (*GetScannerRequest) GetStartKey 

func (p *GetScannerRequest) GetStartKey() *base.Blob

func (*GetScannerRequest) GetStopInclusive 

func (p *GetScannerRequest) GetStopInclusive() bool

func (*GetScannerRequest) GetStopKey 

func (p *GetScannerRequest) GetStopKey() *base.Blob

func (*GetScannerRequest) IsSetHashKeyFilterPattern 

func (p *GetScannerRequest) IsSetHashKeyFilterPattern() bool

func (*GetScannerRequest) IsSetNeedCheckHash 

func (p *GetScannerRequest) IsSetNeedCheckHash() bool

func (*GetScannerRequest) IsSetSortKeyFilterPattern 

func (p *GetScannerRequest) IsSetSortKeyFilterPattern() bool

func (*GetScannerRequest) IsSetStartKey 

func (p *GetScannerRequest) IsSetStartKey() bool

func (*GetScannerRequest) IsSetStopKey 

func (p *GetScannerRequest) IsSetStopKey() bool

func (*GetScannerRequest) Read 

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

func (*GetScannerRequest) ReadField1 

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

func (*GetScannerRequest) ReadField10 

func (p *GetScannerRequest) ReadField10(iprot thrift.TProtocol) error

func (*GetScannerRequest) ReadField11 

func (p *GetScannerRequest) ReadField11(iprot thrift.TProtocol) error

func (*GetScannerRequest) ReadField2 

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

func (*GetScannerRequest) ReadField3 

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

func (*GetScannerRequest) ReadField4 

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

func (*GetScannerRequest) ReadField5 

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

func (*GetScannerRequest) ReadField6 

func (p *GetScannerRequest) ReadField6(iprot thrift.TProtocol) error

func (*GetScannerRequest) ReadField7 

func (p *GetScannerRequest) ReadField7(iprot thrift.TProtocol) error

func (*GetScannerRequest) ReadField8 

func (p *GetScannerRequest) ReadField8(iprot thrift.TProtocol) error

func (*GetScannerRequest) ReadField9 

func (p *GetScannerRequest) ReadField9(iprot thrift.TProtocol) error

func (*GetScannerRequest) String 

func (p *GetScannerRequest) String() string

func (*GetScannerRequest) Write 

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

type IncrRequest 

type IncrRequest struct {
	Key             *base.Blob `thrift:"key,1" db:"key" json:"key"`
	Increment       int64      `thrift:"increment,2" db:"increment" json:"increment"`
	ExpireTsSeconds int32      `thrift:"expire_ts_seconds,3" db:"expire_ts_seconds" json:"expire_ts_seconds"`
}

Attributes:

  • Key
  • Increment
  • ExpireTsSeconds
var RrdbIncrArgs_Request_DEFAULT *IncrRequest

func NewIncrRequest 

func NewIncrRequest() *IncrRequest

func (*IncrRequest) GetExpireTsSeconds 

func (p *IncrRequest) GetExpireTsSeconds() int32

func (*IncrRequest) GetIncrement 

func (p *IncrRequest) GetIncrement() int64

func (*IncrRequest) GetKey 

func (p *IncrRequest) GetKey() *base.Blob

func (*IncrRequest) IsSetKey 

func (p *IncrRequest) IsSetKey() bool

func (*IncrRequest) Read 

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

func (*IncrRequest) ReadField1 

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

func (*IncrRequest) ReadField2 

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

func (*IncrRequest) ReadField3 

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

func (*IncrRequest) String 

func (p *IncrRequest) String() string

func (*IncrRequest) Write 

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

type IncrResponse 

type IncrResponse struct {
	Error          int32  `thrift:"error,1" db:"error" json:"error"`
	NewValue_      int64  `thrift:"new_value,2" db:"new_value" json:"new_value"`
	AppID          int32  `thrift:"app_id,3" db:"app_id" json:"app_id"`
	PartitionIndex int32  `thrift:"partition_index,4" db:"partition_index" json:"partition_index"`
	Decree         int64  `thrift:"decree,5" db:"decree" json:"decree"`
	Server         string `thrift:"server,6" db:"server" json:"server"`
}

Attributes:

  • Error
  • NewValue_
  • AppID
  • PartitionIndex
  • Decree
  • Server
var RrdbIncrResult_Success_DEFAULT *IncrResponse

func NewIncrResponse 

func NewIncrResponse() *IncrResponse

func (*IncrResponse) GetAppID 

func (p *IncrResponse) GetAppID() int32

func (*IncrResponse) GetDecree 

func (p *IncrResponse) GetDecree() int64

func (*IncrResponse) GetError 

func (p *IncrResponse) GetError() int32

func (*IncrResponse) GetNewValue_ 

func (p *IncrResponse) GetNewValue_() int64

func (*IncrResponse) GetPartitionIndex 

func (p *IncrResponse) GetPartitionIndex() int32

func (*IncrResponse) GetServer 

func (p *IncrResponse) GetServer() string

func (*IncrResponse) Read 

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

func (*IncrResponse) ReadField1 

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

func (*IncrResponse) ReadField2 

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

func (*IncrResponse) ReadField3 

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

func (*IncrResponse) ReadField4 

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

func (*IncrResponse) ReadField5 

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

func (*IncrResponse) ReadField6 

func (p *IncrResponse) ReadField6(iprot thrift.TProtocol) error

func (*IncrResponse) String 

func (p *IncrResponse) String() string

func (*IncrResponse) Write 

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

type KeyValue 

type KeyValue struct {
	Key   *base.Blob `thrift:"key,1" db:"key" json:"key"`
	Value *base.Blob `thrift:"value,2" db:"value" json:"value"`
}

Attributes:

  • Key
  • Value

func NewKeyValue 

func NewKeyValue() *KeyValue

func (*KeyValue) GetKey 

func (p *KeyValue) GetKey() *base.Blob

func (*KeyValue) GetValue 

func (p *KeyValue) GetValue() *base.Blob

func (*KeyValue) IsSetKey 

func (p *KeyValue) IsSetKey() bool

func (*KeyValue) IsSetValue 

func (p *KeyValue) IsSetValue() bool

func (*KeyValue) Read 

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

func (*KeyValue) ReadField1 

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

func (*KeyValue) ReadField2 

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

func (*KeyValue) String 

func (p *KeyValue) String() string

func (*KeyValue) Write 

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

type Meta 

type Meta interface {
	// Parameters:
	//  - Query
	QueryCfg(ctx context.Context, query *replication.QueryCfgRequest) (r *replication.QueryCfgResponse, err error)
}

type MetaClient 

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

func NewMetaClient 

func NewMetaClient(c thrift.TClient) *MetaClient

func NewMetaClientFactory 

func NewMetaClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *MetaClient

func NewMetaClientProtocol 

func NewMetaClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *MetaClient

func (*MetaClient) Client_ 

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

func (*MetaClient) QueryCfg 

func (p *MetaClient) QueryCfg(ctx context.Context, query *replication.QueryCfgRequest) (r *replication.QueryCfgResponse, err error)

Parameters:

  • Query

type MetaProcessor 

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

func NewMetaProcessor 

func NewMetaProcessor(handler Meta) *MetaProcessor

func (*MetaProcessor) AddToProcessorMap 

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

func (*MetaProcessor) GetProcessorFunction 

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

func (*MetaProcessor) Process 

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

func (*MetaProcessor) ProcessorMap 

func (p *MetaProcessor) ProcessorMap() map[string]thrift.TProcessorFunction

type MetaQueryCfgArgs 

type MetaQueryCfgArgs struct {
	Query *replication.QueryCfgRequest `thrift:"query,1" db:"query" json:"query"`
}

Attributes:

  • Query

func NewMetaQueryCfgArgs 

func NewMetaQueryCfgArgs() *MetaQueryCfgArgs

func (*MetaQueryCfgArgs) GetQuery 

func (p *MetaQueryCfgArgs) GetQuery() *replication.QueryCfgRequest

func (*MetaQueryCfgArgs) IsSetQuery 

func (p *MetaQueryCfgArgs) IsSetQuery() bool

func (*MetaQueryCfgArgs) Read 

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

func (*MetaQueryCfgArgs) ReadField1 

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

func (*MetaQueryCfgArgs) String 

func (p *MetaQueryCfgArgs) String() string

func (*MetaQueryCfgArgs) Write 

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

type MetaQueryCfgResult 

type MetaQueryCfgResult struct {
	Success *replication.QueryCfgResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewMetaQueryCfgResult 

func NewMetaQueryCfgResult() *MetaQueryCfgResult

func (*MetaQueryCfgResult) GetSuccess 

func (p *MetaQueryCfgResult) GetSuccess() *replication.QueryCfgResponse

func (*MetaQueryCfgResult) IsSetSuccess 

func (p *MetaQueryCfgResult) IsSetSuccess() bool

func (*MetaQueryCfgResult) Read 

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

func (*MetaQueryCfgResult) ReadField0 

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

func (*MetaQueryCfgResult) String 

func (p *MetaQueryCfgResult) String() string

func (*MetaQueryCfgResult) Write 

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

type MultiGetRequest 

type MultiGetRequest struct {
	HashKey              *base.Blob   `thrift:"hash_key,1" db:"hash_key" json:"hash_key"`
	SorkKeys             []*base.Blob `thrift:"sork_keys,2" db:"sork_keys" json:"sork_keys"`
	MaxKvCount           int32        `thrift:"max_kv_count,3" db:"max_kv_count" json:"max_kv_count"`
	MaxKvSize            int32        `thrift:"max_kv_size,4" db:"max_kv_size" json:"max_kv_size"`
	NoValue              bool         `thrift:"no_value,5" db:"no_value" json:"no_value"`
	StartSortkey         *base.Blob   `thrift:"start_sortkey,6" db:"start_sortkey" json:"start_sortkey"`
	StopSortkey          *base.Blob   `thrift:"stop_sortkey,7" db:"stop_sortkey" json:"stop_sortkey"`
	StartInclusive       bool         `thrift:"start_inclusive,8" db:"start_inclusive" json:"start_inclusive"`
	StopInclusive        bool         `thrift:"stop_inclusive,9" db:"stop_inclusive" json:"stop_inclusive"`
	SortKeyFilterType    FilterType   `thrift:"sort_key_filter_type,10" db:"sort_key_filter_type" json:"sort_key_filter_type"`
	SortKeyFilterPattern *base.Blob   `thrift:"sort_key_filter_pattern,11" db:"sort_key_filter_pattern" json:"sort_key_filter_pattern"`
	Reverse              bool         `thrift:"reverse,12" db:"reverse" json:"reverse"`
}

Attributes:

  • HashKey
  • SorkKeys
  • MaxKvCount
  • MaxKvSize
  • NoValue
  • StartSortkey
  • StopSortkey
  • StartInclusive
  • StopInclusive
  • SortKeyFilterType
  • SortKeyFilterPattern
  • Reverse
var RrdbMultiGetArgs_Request_DEFAULT *MultiGetRequest

func NewMultiGetRequest 

func NewMultiGetRequest() *MultiGetRequest

func (*MultiGetRequest) GetHashKey 

func (p *MultiGetRequest) GetHashKey() *base.Blob

func (*MultiGetRequest) GetMaxKvCount 

func (p *MultiGetRequest) GetMaxKvCount() int32

func (*MultiGetRequest) GetMaxKvSize 

func (p *MultiGetRequest) GetMaxKvSize() int32

func (*MultiGetRequest) GetNoValue 

func (p *MultiGetRequest) GetNoValue() bool

func (*MultiGetRequest) GetReverse 

func (p *MultiGetRequest) GetReverse() bool

func (*MultiGetRequest) GetSorkKeys 

func (p *MultiGetRequest) GetSorkKeys() []*base.Blob

func (*MultiGetRequest) GetSortKeyFilterPattern 

func (p *MultiGetRequest) GetSortKeyFilterPattern() *base.Blob

func (*MultiGetRequest) GetSortKeyFilterType 

func (p *MultiGetRequest) GetSortKeyFilterType() FilterType

func (*MultiGetRequest) GetStartInclusive 

func (p *MultiGetRequest) GetStartInclusive() bool

func (*MultiGetRequest) GetStartSortkey 

func (p *MultiGetRequest) GetStartSortkey() *base.Blob

func (*MultiGetRequest) GetStopInclusive 

func (p *MultiGetRequest) GetStopInclusive() bool

func (*MultiGetRequest) GetStopSortkey 

func (p *MultiGetRequest) GetStopSortkey() *base.Blob

func (*MultiGetRequest) IsSetHashKey 

func (p *MultiGetRequest) IsSetHashKey() bool

func (*MultiGetRequest) IsSetSortKeyFilterPattern 

func (p *MultiGetRequest) IsSetSortKeyFilterPattern() bool

func (*MultiGetRequest) IsSetStartSortkey 

func (p *MultiGetRequest) IsSetStartSortkey() bool

func (*MultiGetRequest) IsSetStopSortkey 

func (p *MultiGetRequest) IsSetStopSortkey() bool

func (*MultiGetRequest) Read 

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

func (*MultiGetRequest) ReadField1 

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

func (*MultiGetRequest) ReadField10 

func (p *MultiGetRequest) ReadField10(iprot thrift.TProtocol) error

func (*MultiGetRequest) ReadField11 

func (p *MultiGetRequest) ReadField11(iprot thrift.TProtocol) error

func (*MultiGetRequest) ReadField12 

func (p *MultiGetRequest) ReadField12(iprot thrift.TProtocol) error

func (*MultiGetRequest) ReadField2 

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

func (*MultiGetRequest) ReadField3 

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

func (*MultiGetRequest) ReadField4 

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

func (*MultiGetRequest) ReadField5 

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

func (*MultiGetRequest) ReadField6 

func (p *MultiGetRequest) ReadField6(iprot thrift.TProtocol) error

func (*MultiGetRequest) ReadField7 

func (p *MultiGetRequest) ReadField7(iprot thrift.TProtocol) error

func (*MultiGetRequest) ReadField8 

func (p *MultiGetRequest) ReadField8(iprot thrift.TProtocol) error

func (*MultiGetRequest) ReadField9 

func (p *MultiGetRequest) ReadField9(iprot thrift.TProtocol) error

func (*MultiGetRequest) String 

func (p *MultiGetRequest) String() string

func (*MultiGetRequest) Write 

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

type MultiGetResponse 

type MultiGetResponse struct {
	Error          int32       `thrift:"error,1" db:"error" json:"error"`
	Kvs            []*KeyValue `thrift:"kvs,2" db:"kvs" json:"kvs"`
	AppID          int32       `thrift:"app_id,3" db:"app_id" json:"app_id"`
	PartitionIndex int32       `thrift:"partition_index,4" db:"partition_index" json:"partition_index"`
	// unused field # 5
	Server string `thrift:"server,6" db:"server" json:"server"`
}

Attributes:

  • Error
  • Kvs
  • AppID
  • PartitionIndex
  • Server
var RrdbMultiGetResult_Success_DEFAULT *MultiGetResponse

func NewMultiGetResponse 

func NewMultiGetResponse() *MultiGetResponse

func (*MultiGetResponse) GetAppID 

func (p *MultiGetResponse) GetAppID() int32

func (*MultiGetResponse) GetError 

func (p *MultiGetResponse) GetError() int32

func (*MultiGetResponse) GetKvs 

func (p *MultiGetResponse) GetKvs() []*KeyValue

func (*MultiGetResponse) GetPartitionIndex 

func (p *MultiGetResponse) GetPartitionIndex() int32

func (*MultiGetResponse) GetServer 

func (p *MultiGetResponse) GetServer() string

func (*MultiGetResponse) Read 

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

func (*MultiGetResponse) ReadField1 

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

func (*MultiGetResponse) ReadField2 

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

func (*MultiGetResponse) ReadField3 

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

func (*MultiGetResponse) ReadField4 

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

func (*MultiGetResponse) ReadField6 

func (p *MultiGetResponse) ReadField6(iprot thrift.TProtocol) error

func (*MultiGetResponse) String 

func (p *MultiGetResponse) String() string

func (*MultiGetResponse) Write 

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

type MultiPutRequest 

type MultiPutRequest struct {
	HashKey         *base.Blob  `thrift:"hash_key,1" db:"hash_key" json:"hash_key"`
	Kvs             []*KeyValue `thrift:"kvs,2" db:"kvs" json:"kvs"`
	ExpireTsSeconds int32       `thrift:"expire_ts_seconds,3" db:"expire_ts_seconds" json:"expire_ts_seconds"`
}

Attributes:

  • HashKey
  • Kvs
  • ExpireTsSeconds
var RrdbMultiPutArgs_Request_DEFAULT *MultiPutRequest

func NewMultiPutRequest 

func NewMultiPutRequest() *MultiPutRequest

func (*MultiPutRequest) GetExpireTsSeconds 

func (p *MultiPutRequest) GetExpireTsSeconds() int32

func (*MultiPutRequest) GetHashKey 

func (p *MultiPutRequest) GetHashKey() *base.Blob

func (*MultiPutRequest) GetKvs 

func (p *MultiPutRequest) GetKvs() []*KeyValue

func (*MultiPutRequest) IsSetHashKey 

func (p *MultiPutRequest) IsSetHashKey() bool

func (*MultiPutRequest) Read 

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

func (*MultiPutRequest) ReadField1 

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

func (*MultiPutRequest) ReadField2 

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

func (*MultiPutRequest) ReadField3 

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

func (*MultiPutRequest) String 

func (p *MultiPutRequest) String() string

func (*MultiPutRequest) Write 

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

type MultiRemoveRequest 

type MultiRemoveRequest struct {
	HashKey  *base.Blob   `thrift:"hash_key,1" db:"hash_key" json:"hash_key"`
	SorkKeys []*base.Blob `thrift:"sork_keys,2" db:"sork_keys" json:"sork_keys"`
	MaxCount int64        `thrift:"max_count,3" db:"max_count" json:"max_count"`
}

Attributes:

  • HashKey
  • SorkKeys
  • MaxCount
var RrdbMultiRemoveArgs_Request_DEFAULT *MultiRemoveRequest

func NewMultiRemoveRequest 

func NewMultiRemoveRequest() *MultiRemoveRequest

func (*MultiRemoveRequest) GetHashKey 

func (p *MultiRemoveRequest) GetHashKey() *base.Blob

func (*MultiRemoveRequest) GetMaxCount 

func (p *MultiRemoveRequest) GetMaxCount() int64

func (*MultiRemoveRequest) GetSorkKeys 

func (p *MultiRemoveRequest) GetSorkKeys() []*base.Blob

func (*MultiRemoveRequest) IsSetHashKey 

func (p *MultiRemoveRequest) IsSetHashKey() bool

func (*MultiRemoveRequest) Read 

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

func (*MultiRemoveRequest) ReadField1 

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

func (*MultiRemoveRequest) ReadField2 

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

func (*MultiRemoveRequest) ReadField3 

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

func (*MultiRemoveRequest) String 

func (p *MultiRemoveRequest) String() string

func (*MultiRemoveRequest) Write 

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

type MultiRemoveResponse 

type MultiRemoveResponse struct {
	Error          int32  `thrift:"error,1" db:"error" json:"error"`
	Count          int64  `thrift:"count,2" db:"count" json:"count"`
	AppID          int32  `thrift:"app_id,3" db:"app_id" json:"app_id"`
	PartitionIndex int32  `thrift:"partition_index,4" db:"partition_index" json:"partition_index"`
	Decree         int64  `thrift:"decree,5" db:"decree" json:"decree"`
	Server         string `thrift:"server,6" db:"server" json:"server"`
}

Attributes:

  • Error
  • Count
  • AppID
  • PartitionIndex
  • Decree
  • Server
var RrdbMultiRemoveResult_Success_DEFAULT *MultiRemoveResponse

func NewMultiRemoveResponse 

func NewMultiRemoveResponse() *MultiRemoveResponse

func (*MultiRemoveResponse) GetAppID 

func (p *MultiRemoveResponse) GetAppID() int32

func (*MultiRemoveResponse) GetCount 

func (p *MultiRemoveResponse) GetCount() int64

func (*MultiRemoveResponse) GetDecree 

func (p *MultiRemoveResponse) GetDecree() int64

func (*MultiRemoveResponse) GetError 

func (p *MultiRemoveResponse) GetError() int32

func (*MultiRemoveResponse) GetPartitionIndex 

func (p *MultiRemoveResponse) GetPartitionIndex() int32

func (*MultiRemoveResponse) GetServer 

func (p *MultiRemoveResponse) GetServer() string

func (*MultiRemoveResponse) Read 

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

func (*MultiRemoveResponse) ReadField1 

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

func (*MultiRemoveResponse) ReadField2 

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

func (*MultiRemoveResponse) ReadField3 

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

func (*MultiRemoveResponse) ReadField4 

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

func (*MultiRemoveResponse) ReadField5 

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

func (*MultiRemoveResponse) ReadField6 

func (p *MultiRemoveResponse) ReadField6(iprot thrift.TProtocol) error

func (*MultiRemoveResponse) String 

func (p *MultiRemoveResponse) String() string

func (*MultiRemoveResponse) Write 

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

type Mutate 

type Mutate struct {
	Operation          MutateOperation `thrift:"operation,1" db:"operation" json:"operation"`
	SortKey            *base.Blob      `thrift:"sort_key,2" db:"sort_key" json:"sort_key"`
	Value              *base.Blob      `thrift:"value,3" db:"value" json:"value"`
	SetExpireTsSeconds int32           `thrift:"set_expire_ts_seconds,4" db:"set_expire_ts_seconds" json:"set_expire_ts_seconds"`
}

Attributes:

  • Operation
  • SortKey
  • Value
  • SetExpireTsSeconds

func NewMutate 

func NewMutate() *Mutate

func (*Mutate) GetOperation 

func (p *Mutate) GetOperation() MutateOperation

func (*Mutate) GetSetExpireTsSeconds 

func (p *Mutate) GetSetExpireTsSeconds() int32

func (*Mutate) GetSortKey 

func (p *Mutate) GetSortKey() *base.Blob

func (*Mutate) GetValue 

func (p *Mutate) GetValue() *base.Blob

func (*Mutate) IsSetSortKey 

func (p *Mutate) IsSetSortKey() bool

func (*Mutate) IsSetValue 

func (p *Mutate) IsSetValue() bool

func (*Mutate) Read 

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

func (*Mutate) ReadField1 

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

func (*Mutate) ReadField2 

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

func (*Mutate) ReadField3 

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

func (*Mutate) ReadField4 

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

func (*Mutate) String 

func (p *Mutate) String() string

func (*Mutate) Write 

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

type MutateOperation 

type MutateOperation int64
const (
	MutateOperation_MO_PUT    MutateOperation = 0
	MutateOperation_MO_DELETE MutateOperation = 1
)

func MutateOperationFromString 

func MutateOperationFromString(s string) (MutateOperation, error)

func MutateOperationPtr 

func MutateOperationPtr(v MutateOperation) *MutateOperation

func (MutateOperation) MarshalText 

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

func (*MutateOperation) Scan 

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

func (MutateOperation) String 

func (p MutateOperation) String() string

func (*MutateOperation) UnmarshalText 

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

func (*MutateOperation) Value 

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

type ReadResponse 

type ReadResponse struct {
	Error          int32      `thrift:"error,1" db:"error" json:"error"`
	Value          *base.Blob `thrift:"value,2" db:"value" json:"value"`
	AppID          int32      `thrift:"app_id,3" db:"app_id" json:"app_id"`
	PartitionIndex int32      `thrift:"partition_index,4" db:"partition_index" json:"partition_index"`
	// unused field # 5
	Server string `thrift:"server,6" db:"server" json:"server"`
}

Attributes:

  • Error
  • Value
  • AppID
  • PartitionIndex
  • Server
var RrdbGetResult_Success_DEFAULT *ReadResponse

func NewReadResponse 

func NewReadResponse() *ReadResponse

func (*ReadResponse) GetAppID 

func (p *ReadResponse) GetAppID() int32

func (*ReadResponse) GetError 

func (p *ReadResponse) GetError() int32

func (*ReadResponse) GetPartitionIndex 

func (p *ReadResponse) GetPartitionIndex() int32

func (*ReadResponse) GetServer 

func (p *ReadResponse) GetServer() string

func (*ReadResponse) GetValue 

func (p *ReadResponse) GetValue() *base.Blob

func (*ReadResponse) IsSetValue 

func (p *ReadResponse) IsSetValue() bool

func (*ReadResponse) Read 

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

func (*ReadResponse) ReadField1 

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

func (*ReadResponse) ReadField2 

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

func (*ReadResponse) ReadField3 

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

func (*ReadResponse) ReadField4 

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

func (*ReadResponse) ReadField6 

func (p *ReadResponse) ReadField6(iprot thrift.TProtocol) error

func (*ReadResponse) String 

func (p *ReadResponse) String() string

func (*ReadResponse) Write 

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

type Rrdb 

type Rrdb interface {
	// Parameters:
	//  - Update
	Put(ctx context.Context, update *UpdateRequest) (r *UpdateResponse, err error)
	// Parameters:
	//  - Request
	MultiPut(ctx context.Context, request *MultiPutRequest) (r *UpdateResponse, err error)
	// Parameters:
	//  - Key
	Remove(ctx context.Context, key *base.Blob) (r *UpdateResponse, err error)
	// Parameters:
	//  - Request
	MultiRemove(ctx context.Context, request *MultiRemoveRequest) (r *MultiRemoveResponse, err error)
	// Parameters:
	//  - Request
	Incr(ctx context.Context, request *IncrRequest) (r *IncrResponse, err error)
	// Parameters:
	//  - Request
	CheckAndSet(ctx context.Context, request *CheckAndSetRequest) (r *CheckAndSetResponse, err error)
	// Parameters:
	//  - Request
	CheckAndMutate(ctx context.Context, request *CheckAndMutateRequest) (r *CheckAndMutateResponse, err error)
	// Parameters:
	//  - Key
	Get(ctx context.Context, key *base.Blob) (r *ReadResponse, err error)
	// Parameters:
	//  - Request
	MultiGet(ctx context.Context, request *MultiGetRequest) (r *MultiGetResponse, err error)
	// Parameters:
	//  - HashKey
	SortkeyCount(ctx context.Context, hash_key *base.Blob) (r *CountResponse, err error)
	// Parameters:
	//  - Key
	TTL(ctx context.Context, key *base.Blob) (r *TTLResponse, err error)
	// Parameters:
	//  - Request
	GetScanner(ctx context.Context, request *GetScannerRequest) (r *ScanResponse, err error)
	// Parameters:
	//  - Request
	Scan(ctx context.Context, request *ScanRequest) (r *ScanResponse, err error)
	// Parameters:
	//  - ContextID
	ClearScanner(ctx context.Context, context_id int64) (err error)
}

type RrdbCheckAndMutateArgs 

type RrdbCheckAndMutateArgs struct {
	Request *CheckAndMutateRequest `thrift:"request,1" db:"request" json:"request"`
}

Attributes:

  • Request

func NewRrdbCheckAndMutateArgs 

func NewRrdbCheckAndMutateArgs() *RrdbCheckAndMutateArgs

func (*RrdbCheckAndMutateArgs) GetRequest 

func (p *RrdbCheckAndMutateArgs) GetRequest() *CheckAndMutateRequest

func (*RrdbCheckAndMutateArgs) IsSetRequest 

func (p *RrdbCheckAndMutateArgs) IsSetRequest() bool

func (*RrdbCheckAndMutateArgs) Read 

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

func (*RrdbCheckAndMutateArgs) ReadField1 

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

func (*RrdbCheckAndMutateArgs) String 

func (p *RrdbCheckAndMutateArgs) String() string

func (*RrdbCheckAndMutateArgs) Write 

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

type RrdbCheckAndMutateResult 

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

Attributes:

  • Success

func NewRrdbCheckAndMutateResult 

func NewRrdbCheckAndMutateResult() *RrdbCheckAndMutateResult

func (*RrdbCheckAndMutateResult) GetSuccess 

func (p *RrdbCheckAndMutateResult) GetSuccess() *CheckAndMutateResponse

func (*RrdbCheckAndMutateResult) IsSetSuccess 

func (p *RrdbCheckAndMutateResult) IsSetSuccess() bool

func (*RrdbCheckAndMutateResult) Read 

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

func (*RrdbCheckAndMutateResult) ReadField0 

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

func (*RrdbCheckAndMutateResult) String 

func (p *RrdbCheckAndMutateResult) String() string

func (*RrdbCheckAndMutateResult) Write 

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

type RrdbCheckAndSetArgs 

type RrdbCheckAndSetArgs struct {
	Request *CheckAndSetRequest `thrift:"request,1" db:"request" json:"request"`
}

Attributes:

  • Request

func NewRrdbCheckAndSetArgs 

func NewRrdbCheckAndSetArgs() *RrdbCheckAndSetArgs

func (*RrdbCheckAndSetArgs) GetRequest 

func (p *RrdbCheckAndSetArgs) GetRequest() *CheckAndSetRequest

func (*RrdbCheckAndSetArgs) IsSetRequest 

func (p *RrdbCheckAndSetArgs) IsSetRequest() bool

func (*RrdbCheckAndSetArgs) Read 

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

func (*RrdbCheckAndSetArgs) ReadField1 

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

func (*RrdbCheckAndSetArgs) String 

func (p *RrdbCheckAndSetArgs) String() string

func (*RrdbCheckAndSetArgs) Write 

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

type RrdbCheckAndSetResult 

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

Attributes:

  • Success

func NewRrdbCheckAndSetResult 

func NewRrdbCheckAndSetResult() *RrdbCheckAndSetResult

func (*RrdbCheckAndSetResult) GetSuccess 

func (p *RrdbCheckAndSetResult) GetSuccess() *CheckAndSetResponse

func (*RrdbCheckAndSetResult) IsSetSuccess 

func (p *RrdbCheckAndSetResult) IsSetSuccess() bool

func (*RrdbCheckAndSetResult) Read 

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

func (*RrdbCheckAndSetResult) ReadField0 

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

func (*RrdbCheckAndSetResult) String 

func (p *RrdbCheckAndSetResult) String() string

func (*RrdbCheckAndSetResult) Write 

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

type RrdbClearScannerArgs 

type RrdbClearScannerArgs struct {
	ContextID int64 `thrift:"context_id,1" db:"context_id" json:"context_id"`
}

Attributes:

  • ContextID

func NewRrdbClearScannerArgs 

func NewRrdbClearScannerArgs() *RrdbClearScannerArgs

func (*RrdbClearScannerArgs) GetContextID 

func (p *RrdbClearScannerArgs) GetContextID() int64

func (*RrdbClearScannerArgs) Read 

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

func (*RrdbClearScannerArgs) ReadField1 

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

func (*RrdbClearScannerArgs) String 

func (p *RrdbClearScannerArgs) String() string

func (*RrdbClearScannerArgs) Write 

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

type RrdbClient 

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

func NewRrdbClient 

func NewRrdbClient(c thrift.TClient) *RrdbClient

func NewRrdbClientFactory 

func NewRrdbClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *RrdbClient

func NewRrdbClientProtocol 

func NewRrdbClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *RrdbClient

func (*RrdbClient) CheckAndMutate 

func (p *RrdbClient) CheckAndMutate(ctx context.Context, request *CheckAndMutateRequest) (r *CheckAndMutateResponse, err error)

Parameters:

  • Request

func (*RrdbClient) CheckAndSet 

func (p *RrdbClient) CheckAndSet(ctx context.Context, request *CheckAndSetRequest) (r *CheckAndSetResponse, err error)

Parameters:

  • Request

func (*RrdbClient) ClearScanner 

func (p *RrdbClient) ClearScanner(ctx context.Context, context_id int64) (err error)

Parameters:

  • ContextID

func (*RrdbClient) Client_ 

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

func (*RrdbClient) Get 

func (p *RrdbClient) Get(ctx context.Context, key *base.Blob) (r *ReadResponse, err error)

Parameters:

  • Key

func (*RrdbClient) GetScanner 

func (p *RrdbClient) GetScanner(ctx context.Context, request *GetScannerRequest) (r *ScanResponse, err error)

Parameters:

  • Request

func (*RrdbClient) Incr 

func (p *RrdbClient) Incr(ctx context.Context, request *IncrRequest) (r *IncrResponse, err error)

Parameters:

  • Request

func (*RrdbClient) MultiGet 

func (p *RrdbClient) MultiGet(ctx context.Context, request *MultiGetRequest) (r *MultiGetResponse, err error)

Parameters:

  • Request

func (*RrdbClient) MultiPut 

func (p *RrdbClient) MultiPut(ctx context.Context, request *MultiPutRequest) (r *UpdateResponse, err error)

Parameters:

  • Request

func (*RrdbClient) MultiRemove 

func (p *RrdbClient) MultiRemove(ctx context.Context, request *MultiRemoveRequest) (r *MultiRemoveResponse, err error)

Parameters:

  • Request

func (*RrdbClient) Put 

func (p *RrdbClient) Put(ctx context.Context, update *UpdateRequest) (r *UpdateResponse, err error)

Parameters:

  • Update

func (*RrdbClient) Remove 

func (p *RrdbClient) Remove(ctx context.Context, key *base.Blob) (r *UpdateResponse, err error)

Parameters:

  • Key

func (*RrdbClient) Scan 

func (p *RrdbClient) Scan(ctx context.Context, request *ScanRequest) (r *ScanResponse, err error)

Parameters:

  • Request

func (*RrdbClient) SortkeyCount 

func (p *RrdbClient) SortkeyCount(ctx context.Context, hash_key *base.Blob) (r *CountResponse, err error)

Parameters:

  • HashKey

func (*RrdbClient) TTL 

func (p *RrdbClient) TTL(ctx context.Context, key *base.Blob) (r *TTLResponse, err error)

Parameters:

  • Key

type RrdbGetArgs 

type RrdbGetArgs struct {
	Key *base.Blob `thrift:"key,1" db:"key" json:"key"`
}

Attributes:

  • Key

func NewRrdbGetArgs 

func NewRrdbGetArgs() *RrdbGetArgs

func (*RrdbGetArgs) GetKey 

func (p *RrdbGetArgs) GetKey() *base.Blob

func (*RrdbGetArgs) IsSetKey 

func (p *RrdbGetArgs) IsSetKey() bool

func (*RrdbGetArgs) Read 

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

func (*RrdbGetArgs) ReadField1 

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

func (*RrdbGetArgs) String 

func (p *RrdbGetArgs) String() string

func (*RrdbGetArgs) Write 

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

type RrdbGetResult 

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

Attributes:

  • Success

func NewRrdbGetResult 

func NewRrdbGetResult() *RrdbGetResult

func (*RrdbGetResult) GetSuccess 

func (p *RrdbGetResult) GetSuccess() *ReadResponse

func (*RrdbGetResult) IsSetSuccess 

func (p *RrdbGetResult) IsSetSuccess() bool

func (*RrdbGetResult) Read 

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

func (*RrdbGetResult) ReadField0 

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

func (*RrdbGetResult) String 

func (p *RrdbGetResult) String() string

func (*RrdbGetResult) Write 

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

type RrdbGetScannerArgs 

type RrdbGetScannerArgs struct {
	Request *GetScannerRequest `thrift:"request,1" db:"request" json:"request"`
}

Attributes:

  • Request

func NewRrdbGetScannerArgs 

func NewRrdbGetScannerArgs() *RrdbGetScannerArgs

func (*RrdbGetScannerArgs) GetRequest 

func (p *RrdbGetScannerArgs) GetRequest() *GetScannerRequest

func (*RrdbGetScannerArgs) IsSetRequest 

func (p *RrdbGetScannerArgs) IsSetRequest() bool

func (*RrdbGetScannerArgs) Read 

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

func (*RrdbGetScannerArgs) ReadField1 

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

func (*RrdbGetScannerArgs) String 

func (p *RrdbGetScannerArgs) String() string

func (*RrdbGetScannerArgs) Write 

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

type RrdbGetScannerResult 

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

Attributes:

  • Success

func NewRrdbGetScannerResult 

func NewRrdbGetScannerResult() *RrdbGetScannerResult

func (*RrdbGetScannerResult) GetSuccess 

func (p *RrdbGetScannerResult) GetSuccess() *ScanResponse

func (*RrdbGetScannerResult) IsSetSuccess 

func (p *RrdbGetScannerResult) IsSetSuccess() bool

func (*RrdbGetScannerResult) Read 

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

func (*RrdbGetScannerResult) ReadField0 

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

func (*RrdbGetScannerResult) String 

func (p *RrdbGetScannerResult) String() string

func (*RrdbGetScannerResult) Write 

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

type RrdbIncrArgs 

type RrdbIncrArgs struct {
	Request *IncrRequest `thrift:"request,1" db:"request" json:"request"`
}

Attributes:

  • Request

func NewRrdbIncrArgs 

func NewRrdbIncrArgs() *RrdbIncrArgs

func (*RrdbIncrArgs) GetRequest 

func (p *RrdbIncrArgs) GetRequest() *IncrRequest

func (*RrdbIncrArgs) IsSetRequest 

func (p *RrdbIncrArgs) IsSetRequest() bool

func (*RrdbIncrArgs) Read 

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

func (*RrdbIncrArgs) ReadField1 

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

func (*RrdbIncrArgs) String 

func (p *RrdbIncrArgs) String() string

func (*RrdbIncrArgs) Write 

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

type RrdbIncrResult 

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

Attributes:

  • Success

func NewRrdbIncrResult 

func NewRrdbIncrResult() *RrdbIncrResult

func (*RrdbIncrResult) GetSuccess 

func (p *RrdbIncrResult) GetSuccess() *IncrResponse

func (*RrdbIncrResult) IsSetSuccess 

func (p *RrdbIncrResult) IsSetSuccess() bool

func (*RrdbIncrResult) Read 

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

func (*RrdbIncrResult) ReadField0 

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

func (*RrdbIncrResult) String 

func (p *RrdbIncrResult) String() string

func (*RrdbIncrResult) Write 

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

type RrdbMultiGetArgs 

type RrdbMultiGetArgs struct {
	Request *MultiGetRequest `thrift:"request,1" db:"request" json:"request"`
}

Attributes:

  • Request

func NewRrdbMultiGetArgs 

func NewRrdbMultiGetArgs() *RrdbMultiGetArgs

func (*RrdbMultiGetArgs) GetRequest 

func (p *RrdbMultiGetArgs) GetRequest() *MultiGetRequest

func (*RrdbMultiGetArgs) IsSetRequest 

func (p *RrdbMultiGetArgs) IsSetRequest() bool

func (*RrdbMultiGetArgs) Read 

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

func (*RrdbMultiGetArgs) ReadField1 

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

func (*RrdbMultiGetArgs) String 

func (p *RrdbMultiGetArgs) String() string

func (*RrdbMultiGetArgs) Write 

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

type RrdbMultiGetResult 

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

Attributes:

  • Success

func NewRrdbMultiGetResult 

func NewRrdbMultiGetResult() *RrdbMultiGetResult

func (*RrdbMultiGetResult) GetSuccess 

func (p *RrdbMultiGetResult) GetSuccess() *MultiGetResponse

func (*RrdbMultiGetResult) IsSetSuccess 

func (p *RrdbMultiGetResult) IsSetSuccess() bool

func (*RrdbMultiGetResult) Read 

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

func (*RrdbMultiGetResult) ReadField0 

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

func (*RrdbMultiGetResult) String 

func (p *RrdbMultiGetResult) String() string

func (*RrdbMultiGetResult) Write 

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

type RrdbMultiPutArgs 

type RrdbMultiPutArgs struct {
	Request *MultiPutRequest `thrift:"request,1" db:"request" json:"request"`
}

Attributes:

  • Request

func NewRrdbMultiPutArgs 

func NewRrdbMultiPutArgs() *RrdbMultiPutArgs

func (*RrdbMultiPutArgs) GetRequest 

func (p *RrdbMultiPutArgs) GetRequest() *MultiPutRequest

func (*RrdbMultiPutArgs) IsSetRequest 

func (p *RrdbMultiPutArgs) IsSetRequest() bool

func (*RrdbMultiPutArgs) Read 

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

func (*RrdbMultiPutArgs) ReadField1 

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

func (*RrdbMultiPutArgs) String 

func (p *RrdbMultiPutArgs) String() string

func (*RrdbMultiPutArgs) Write 

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

type RrdbMultiPutResult 

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

Attributes:

  • Success

func NewRrdbMultiPutResult 

func NewRrdbMultiPutResult() *RrdbMultiPutResult

func (*RrdbMultiPutResult) GetSuccess 

func (p *RrdbMultiPutResult) GetSuccess() *UpdateResponse

func (*RrdbMultiPutResult) IsSetSuccess 

func (p *RrdbMultiPutResult) IsSetSuccess() bool

func (*RrdbMultiPutResult) Read 

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

func (*RrdbMultiPutResult) ReadField0 

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

func (*RrdbMultiPutResult) String 

func (p *RrdbMultiPutResult) String() string

func (*RrdbMultiPutResult) Write 

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

type RrdbMultiRemoveArgs 

type RrdbMultiRemoveArgs struct {
	Request *MultiRemoveRequest `thrift:"request,1" db:"request" json:"request"`
}

Attributes:

  • Request

func NewRrdbMultiRemoveArgs 

func NewRrdbMultiRemoveArgs() *RrdbMultiRemoveArgs

func (*RrdbMultiRemoveArgs) GetRequest 

func (p *RrdbMultiRemoveArgs) GetRequest() *MultiRemoveRequest

func (*RrdbMultiRemoveArgs) IsSetRequest 

func (p *RrdbMultiRemoveArgs) IsSetRequest() bool

func (*RrdbMultiRemoveArgs) Read 

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

func (*RrdbMultiRemoveArgs) ReadField1 

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

func (*RrdbMultiRemoveArgs) String 

func (p *RrdbMultiRemoveArgs) String() string

func (*RrdbMultiRemoveArgs) Write 

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

type RrdbMultiRemoveResult 

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

Attributes:

  • Success

func NewRrdbMultiRemoveResult 

func NewRrdbMultiRemoveResult() *RrdbMultiRemoveResult

func (*RrdbMultiRemoveResult) GetSuccess 

func (p *RrdbMultiRemoveResult) GetSuccess() *MultiRemoveResponse

func (*RrdbMultiRemoveResult) IsSetSuccess 

func (p *RrdbMultiRemoveResult) IsSetSuccess() bool

func (*RrdbMultiRemoveResult) Read 

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

func (*RrdbMultiRemoveResult) ReadField0 

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

func (*RrdbMultiRemoveResult) String 

func (p *RrdbMultiRemoveResult) String() string

func (*RrdbMultiRemoveResult) Write 

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

type RrdbProcessor 

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

func NewRrdbProcessor 

func NewRrdbProcessor(handler Rrdb) *RrdbProcessor

func (*RrdbProcessor) AddToProcessorMap 

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

func (*RrdbProcessor) GetProcessorFunction 

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

func (*RrdbProcessor) Process 

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

func (*RrdbProcessor) ProcessorMap 

func (p *RrdbProcessor) ProcessorMap() map[string]thrift.TProcessorFunction

type RrdbPutArgs 

type RrdbPutArgs struct {
	Update *UpdateRequest `thrift:"update,1" db:"update" json:"update"`
}

Attributes:

  • Update

func NewRrdbPutArgs 

func NewRrdbPutArgs() *RrdbPutArgs

func (*RrdbPutArgs) GetUpdate 

func (p *RrdbPutArgs) GetUpdate() *UpdateRequest

func (*RrdbPutArgs) IsSetUpdate 

func (p *RrdbPutArgs) IsSetUpdate() bool

func (*RrdbPutArgs) Read 

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

func (*RrdbPutArgs) ReadField1 

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

func (*RrdbPutArgs) String 

func (p *RrdbPutArgs) String() string

func (*RrdbPutArgs) Write 

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

type RrdbPutResult 

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

Attributes:

  • Success

func NewRrdbPutResult 

func NewRrdbPutResult() *RrdbPutResult

func (*RrdbPutResult) GetSuccess 

func (p *RrdbPutResult) GetSuccess() *UpdateResponse

func (*RrdbPutResult) IsSetSuccess 

func (p *RrdbPutResult) IsSetSuccess() bool

func (*RrdbPutResult) Read 

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

func (*RrdbPutResult) ReadField0 

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

func (*RrdbPutResult) String 

func (p *RrdbPutResult) String() string

func (*RrdbPutResult) Write 

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

type RrdbRemoveArgs 

type RrdbRemoveArgs struct {
	Key *base.Blob `thrift:"key,1" db:"key" json:"key"`
}

Attributes:

  • Key

func NewRrdbRemoveArgs 

func NewRrdbRemoveArgs() *RrdbRemoveArgs

func (*RrdbRemoveArgs) GetKey 

func (p *RrdbRemoveArgs) GetKey() *base.Blob

func (*RrdbRemoveArgs) IsSetKey 

func (p *RrdbRemoveArgs) IsSetKey() bool

func (*RrdbRemoveArgs) Read 

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

func (*RrdbRemoveArgs) ReadField1 

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

func (*RrdbRemoveArgs) String 

func (p *RrdbRemoveArgs) String() string

func (*RrdbRemoveArgs) Write 

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

type RrdbRemoveResult 

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

Attributes:

  • Success

func NewRrdbRemoveResult 

func NewRrdbRemoveResult() *RrdbRemoveResult

func (*RrdbRemoveResult) GetSuccess 

func (p *RrdbRemoveResult) GetSuccess() *UpdateResponse

func (*RrdbRemoveResult) IsSetSuccess 

func (p *RrdbRemoveResult) IsSetSuccess() bool

func (*RrdbRemoveResult) Read 

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

func (*RrdbRemoveResult) ReadField0 

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

func (*RrdbRemoveResult) String 

func (p *RrdbRemoveResult) String() string

func (*RrdbRemoveResult) Write 

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

type RrdbScanArgs 

type RrdbScanArgs struct {
	Request *ScanRequest `thrift:"request,1" db:"request" json:"request"`
}

Attributes:

  • Request

func NewRrdbScanArgs 

func NewRrdbScanArgs() *RrdbScanArgs

func (*RrdbScanArgs) GetRequest 

func (p *RrdbScanArgs) GetRequest() *ScanRequest

func (*RrdbScanArgs) IsSetRequest 

func (p *RrdbScanArgs) IsSetRequest() bool

func (*RrdbScanArgs) Read 

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

func (*RrdbScanArgs) ReadField1 

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

func (*RrdbScanArgs) String 

func (p *RrdbScanArgs) String() string

func (*RrdbScanArgs) Write 

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

type RrdbScanResult 

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

Attributes:

  • Success

func NewRrdbScanResult 

func NewRrdbScanResult() *RrdbScanResult

func (*RrdbScanResult) GetSuccess 

func (p *RrdbScanResult) GetSuccess() *ScanResponse

func (*RrdbScanResult) IsSetSuccess 

func (p *RrdbScanResult) IsSetSuccess() bool

func (*RrdbScanResult) Read 

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

func (*RrdbScanResult) ReadField0 

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

func (*RrdbScanResult) String 

func (p *RrdbScanResult) String() string

func (*RrdbScanResult) Write 

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

type RrdbSortkeyCountArgs 

type RrdbSortkeyCountArgs struct {
	HashKey *base.Blob `thrift:"hash_key,1" db:"hash_key" json:"hash_key"`
}

Attributes:

  • HashKey

func NewRrdbSortkeyCountArgs 

func NewRrdbSortkeyCountArgs() *RrdbSortkeyCountArgs

func (*RrdbSortkeyCountArgs) GetHashKey 

func (p *RrdbSortkeyCountArgs) GetHashKey() *base.Blob

func (*RrdbSortkeyCountArgs) IsSetHashKey 

func (p *RrdbSortkeyCountArgs) IsSetHashKey() bool

func (*RrdbSortkeyCountArgs) Read 

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

func (*RrdbSortkeyCountArgs) ReadField1 

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

func (*RrdbSortkeyCountArgs) String 

func (p *RrdbSortkeyCountArgs) String() string

func (*RrdbSortkeyCountArgs) Write 

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

type RrdbSortkeyCountResult 

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

Attributes:

  • Success

func NewRrdbSortkeyCountResult 

func NewRrdbSortkeyCountResult() *RrdbSortkeyCountResult

func (*RrdbSortkeyCountResult) GetSuccess 

func (p *RrdbSortkeyCountResult) GetSuccess() *CountResponse

func (*RrdbSortkeyCountResult) IsSetSuccess 

func (p *RrdbSortkeyCountResult) IsSetSuccess() bool

func (*RrdbSortkeyCountResult) Read 

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

func (*RrdbSortkeyCountResult) ReadField0 

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

func (*RrdbSortkeyCountResult) String 

func (p *RrdbSortkeyCountResult) String() string

func (*RrdbSortkeyCountResult) Write 

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

type RrdbTTLArgs 

type RrdbTTLArgs struct {
	Key *base.Blob `thrift:"key,1" db:"key" json:"key"`
}

Attributes:

  • Key

func NewRrdbTTLArgs 

func NewRrdbTTLArgs() *RrdbTTLArgs

func (*RrdbTTLArgs) GetKey 

func (p *RrdbTTLArgs) GetKey() *base.Blob

func (*RrdbTTLArgs) IsSetKey 

func (p *RrdbTTLArgs) IsSetKey() bool

func (*RrdbTTLArgs) Read 

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

func (*RrdbTTLArgs) ReadField1 

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

func (*RrdbTTLArgs) String 

func (p *RrdbTTLArgs) String() string

func (*RrdbTTLArgs) Write 

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

type RrdbTTLResult 

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

Attributes:

  • Success

func NewRrdbTTLResult 

func NewRrdbTTLResult() *RrdbTTLResult

func (*RrdbTTLResult) GetSuccess 

func (p *RrdbTTLResult) GetSuccess() *TTLResponse

func (*RrdbTTLResult) IsSetSuccess 

func (p *RrdbTTLResult) IsSetSuccess() bool

func (*RrdbTTLResult) Read 

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

func (*RrdbTTLResult) ReadField0 

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

func (*RrdbTTLResult) String 

func (p *RrdbTTLResult) String() string

func (*RrdbTTLResult) Write 

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

type ScanRequest 

type ScanRequest struct {
	ContextID int64 `thrift:"context_id,1" db:"context_id" json:"context_id"`
}

Attributes:

  • ContextID
var RrdbScanArgs_Request_DEFAULT *ScanRequest

func NewScanRequest 

func NewScanRequest() *ScanRequest

func (*ScanRequest) GetContextID 

func (p *ScanRequest) GetContextID() int64

func (*ScanRequest) Read 

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

func (*ScanRequest) ReadField1 

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

func (*ScanRequest) String 

func (p *ScanRequest) String() string

func (*ScanRequest) Write 

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

type ScanResponse 

type ScanResponse struct {
	Error          int32       `thrift:"error,1" db:"error" json:"error"`
	Kvs            []*KeyValue `thrift:"kvs,2" db:"kvs" json:"kvs"`
	ContextID      int64       `thrift:"context_id,3" db:"context_id" json:"context_id"`
	AppID          int32       `thrift:"app_id,4" db:"app_id" json:"app_id"`
	PartitionIndex int32       `thrift:"partition_index,5" db:"partition_index" json:"partition_index"`
	Server         string      `thrift:"server,6" db:"server" json:"server"`
}

Attributes:

  • Error
  • Kvs
  • ContextID
  • AppID
  • PartitionIndex
  • Server
var RrdbGetScannerResult_Success_DEFAULT *ScanResponse
var RrdbScanResult_Success_DEFAULT *ScanResponse

func NewScanResponse 

func NewScanResponse() *ScanResponse

func (*ScanResponse) GetAppID 

func (p *ScanResponse) GetAppID() int32

func (*ScanResponse) GetContextID 

func (p *ScanResponse) GetContextID() int64

func (*ScanResponse) GetError 

func (p *ScanResponse) GetError() int32

func (*ScanResponse) GetKvs 

func (p *ScanResponse) GetKvs() []*KeyValue

func (*ScanResponse) GetPartitionIndex 

func (p *ScanResponse) GetPartitionIndex() int32

func (*ScanResponse) GetServer 

func (p *ScanResponse) GetServer() string

func (*ScanResponse) Read 

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

func (*ScanResponse) ReadField1 

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

func (*ScanResponse) ReadField2 

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

func (*ScanResponse) ReadField3 

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

func (*ScanResponse) ReadField4 

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

func (*ScanResponse) ReadField5 

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

func (*ScanResponse) ReadField6 

func (p *ScanResponse) ReadField6(iprot thrift.TProtocol) error

func (*ScanResponse) String 

func (p *ScanResponse) String() string

func (*ScanResponse) Write 

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

type TTLResponse 

type TTLResponse struct {
	Error          int32 `thrift:"error,1" db:"error" json:"error"`
	TTLSeconds     int32 `thrift:"ttl_seconds,2" db:"ttl_seconds" json:"ttl_seconds"`
	AppID          int32 `thrift:"app_id,3" db:"app_id" json:"app_id"`
	PartitionIndex int32 `thrift:"partition_index,4" db:"partition_index" json:"partition_index"`
	// unused field # 5
	Server string `thrift:"server,6" db:"server" json:"server"`
}

Attributes:

  • Error
  • TTLSeconds
  • AppID
  • PartitionIndex
  • Server
var RrdbTTLResult_Success_DEFAULT *TTLResponse

func NewTTLResponse 

func NewTTLResponse() *TTLResponse

func (*TTLResponse) GetAppID 

func (p *TTLResponse) GetAppID() int32

func (*TTLResponse) GetError 

func (p *TTLResponse) GetError() int32

func (*TTLResponse) GetPartitionIndex 

func (p *TTLResponse) GetPartitionIndex() int32

func (*TTLResponse) GetServer 

func (p *TTLResponse) GetServer() string

func (*TTLResponse) GetTTLSeconds 

func (p *TTLResponse) GetTTLSeconds() int32

func (*TTLResponse) Read 

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

func (*TTLResponse) ReadField1 

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

func (*TTLResponse) ReadField2 

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

func (*TTLResponse) ReadField3 

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

func (*TTLResponse) ReadField4 

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

func (*TTLResponse) ReadField6 

func (p *TTLResponse) ReadField6(iprot thrift.TProtocol) error

func (*TTLResponse) String 

func (p *TTLResponse) String() string

func (*TTLResponse) Write 

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

type UpdateRequest 

type UpdateRequest struct {
	Key             *base.Blob `thrift:"key,1" db:"key" json:"key"`
	Value           *base.Blob `thrift:"value,2" db:"value" json:"value"`
	ExpireTsSeconds int32      `thrift:"expire_ts_seconds,3" db:"expire_ts_seconds" json:"expire_ts_seconds"`
}

Attributes:

  • Key
  • Value
  • ExpireTsSeconds
var RrdbPutArgs_Update_DEFAULT *UpdateRequest

func NewUpdateRequest 

func NewUpdateRequest() *UpdateRequest

func (*UpdateRequest) GetExpireTsSeconds 

func (p *UpdateRequest) GetExpireTsSeconds() int32

func (*UpdateRequest) GetKey 

func (p *UpdateRequest) GetKey() *base.Blob

func (*UpdateRequest) GetValue 

func (p *UpdateRequest) GetValue() *base.Blob

func (*UpdateRequest) IsSetKey 

func (p *UpdateRequest) IsSetKey() bool

func (*UpdateRequest) IsSetValue 

func (p *UpdateRequest) IsSetValue() bool

func (*UpdateRequest) Read 

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

func (*UpdateRequest) ReadField1 

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

func (*UpdateRequest) ReadField2 

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

func (*UpdateRequest) ReadField3 

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

func (*UpdateRequest) String 

func (p *UpdateRequest) String() string

func (*UpdateRequest) Write 

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

type UpdateResponse 

type UpdateResponse struct {
	Error          int32  `thrift:"error,1" db:"error" json:"error"`
	AppID          int32  `thrift:"app_id,2" db:"app_id" json:"app_id"`
	PartitionIndex int32  `thrift:"partition_index,3" db:"partition_index" json:"partition_index"`
	Decree         int64  `thrift:"decree,4" db:"decree" json:"decree"`
	Server         string `thrift:"server,5" db:"server" json:"server"`
}

Attributes:

  • Error
  • AppID
  • PartitionIndex
  • Decree
  • Server
var RrdbMultiPutResult_Success_DEFAULT *UpdateResponse
var RrdbPutResult_Success_DEFAULT *UpdateResponse
var RrdbRemoveResult_Success_DEFAULT *UpdateResponse

func NewUpdateResponse 

func NewUpdateResponse() *UpdateResponse

func (*UpdateResponse) GetAppID 

func (p *UpdateResponse) GetAppID() int32

func (*UpdateResponse) GetDecree 

func (p *UpdateResponse) GetDecree() int64

func (*UpdateResponse) GetError 

func (p *UpdateResponse) GetError() int32

func (*UpdateResponse) GetPartitionIndex 

func (p *UpdateResponse) GetPartitionIndex() int32

func (*UpdateResponse) GetServer 

func (p *UpdateResponse) GetServer() string

func (*UpdateResponse) Read 

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

func (*UpdateResponse) ReadField1 

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

func (*UpdateResponse) ReadField2 

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

func (*UpdateResponse) ReadField3 

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

func (*UpdateResponse) ReadField4 

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

func (*UpdateResponse) ReadField5 

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

func (*UpdateResponse) String 

func (p *UpdateResponse) String() string

func (*UpdateResponse) Write 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.