hbase

Sep 19, 2019

Changes in this version

+ var GoUnusedProtection__ int

+ var HbasePool *pool.ObjectPool

+ var TAppend_Attributes_DEFAULT map[string][]byte

+ var TAuthorization_Labels_DEFAULT []string

+ var TCellVisibility_Expression_DEFAULT string

+ var TColumnIncrement_Amount_DEFAULT int64 = 1

+ var TColumnValue_Tags_DEFAULT []byte

+ var TColumnValue_Timestamp_DEFAULT int64

+ var TColumn_Qualifier_DEFAULT []byte

+ var TColumn_Timestamp_DEFAULT int64

+ var TDelete_Attributes_DEFAULT map[string][]byte

+ var TDelete_Columns_DEFAULT []*TColumn

+ var TDelete_Timestamp_DEFAULT int64

+ var TGet_Attributes_DEFAULT map[string][]byte

+ var TGet_Columns_DEFAULT []*TColumn

+ var TGet_FilterString_DEFAULT []byte

+ var TGet_MaxVersions_DEFAULT int32

+ var TGet_Timestamp_DEFAULT int64

+ var THBaseServiceCheckAndDeleteResult_Success_DEFAULT bool

+ var THBaseServiceCheckAndMutateResult_Success_DEFAULT bool

+ var THBaseServiceCheckAndPutResult_Success_DEFAULT bool

+ var THBaseServiceDeleteMultipleResult_Success_DEFAULT []*TDelete

+ var THBaseServiceExistsAllResult_Success_DEFAULT []bool

+ var THBaseServiceExistsResult_Success_DEFAULT bool

+ var THBaseServiceGetAllRegionLocationsResult_Success_DEFAULT []*THRegionLocation

+ var THBaseServiceGetMultipleResult_Success_DEFAULT []*TResult_

+ var THBaseServiceGetScannerResultsResult_Success_DEFAULT []*TResult_

+ var THBaseServiceGetScannerRowsResult_Success_DEFAULT []*TResult_

+ var THBaseServiceOpenScannerResult_Success_DEFAULT int32

+ var THRegionInfo_EndKey_DEFAULT []byte

+ var THRegionInfo_Offline_DEFAULT bool

+ var THRegionInfo_ReplicaId_DEFAULT int32

+ var THRegionInfo_Split_DEFAULT bool

+ var THRegionInfo_StartKey_DEFAULT []byte

+ var TIOError_Message_DEFAULT string

+ var TIllegalArgument_Message_DEFAULT string

+ var TIncrement_Attributes_DEFAULT map[string][]byte

+ var TPut_Attributes_DEFAULT map[string][]byte

+ var TPut_Timestamp_DEFAULT int64

+ var TResult__Row_DEFAULT []byte

+ var TScan_Attributes_DEFAULT map[string][]byte

+ var TScan_BatchSize_DEFAULT int32

+ var TScan_CacheBlocks_DEFAULT bool

+ var TScan_Caching_DEFAULT int32

+ var TScan_ColFamTimeRangeMap_DEFAULT map[string]*TTimeRange

+ var TScan_Columns_DEFAULT []*TColumn

+ var TScan_FilterString_DEFAULT []byte

+ var TScan_Limit_DEFAULT int32

+ var TScan_MaxVersions_DEFAULT int32 = 1

+ var TScan_Reversed_DEFAULT bool

+ var TScan_StartRow_DEFAULT []byte

+ var TScan_StopRow_DEFAULT []byte

+ var TServerName_Port_DEFAULT int32

+ var TServerName_StartCode_DEFAULT int64

+ func NewHbase() error

+ type RpcHbaseClient struct

+ var HbaseClinet *RpcHbaseClient

+ func (h RpcHbaseClient) Delete(table string, tdelete *TDelete) (err error)

+ func (h RpcHbaseClient) Exists(table string, tget *TGet) (r bool, err error)

+ func (h RpcHbaseClient) Get(table string, tget *TGet) (r *TResult_, err error)

+ func (h RpcHbaseClient) Put(table string, tput *TPut) (err error)

+ type TAppend struct

+ Attributes map[string][]byte

+ CellVisibility *TCellVisibility

+ Columns []*TColumnValue

+ Durability *TDurability

+ Row []byte

+ var THBaseServiceAppendArgs_Tappend_DEFAULT *TAppend

+ func NewTAppend() *TAppend

+ func (p *TAppend) GetAttributes() map[string][]byte

+ func (p *TAppend) GetCellVisibility() *TCellVisibility

+ func (p *TAppend) GetColumns() []*TColumnValue

+ func (p *TAppend) GetDurability() TDurability

+ func (p *TAppend) GetRow() []byte

+ func (p *TAppend) IsSetAttributes() bool

+ func (p *TAppend) IsSetCellVisibility() bool

+ func (p *TAppend) IsSetDurability() bool

+ func (p *TAppend) Read(iprot thrift.TProtocol) error

+ func (p *TAppend) String() string

+ func (p *TAppend) Write(oprot thrift.TProtocol) error

+ type TAuthorization struct

+ Labels []string

+ var TGet_Authorizations_DEFAULT *TAuthorization

+ var TScan_Authorizations_DEFAULT *TAuthorization

+ func NewTAuthorization() *TAuthorization

+ func (p *TAuthorization) GetLabels() []string

+ func (p *TAuthorization) IsSetLabels() bool

+ func (p *TAuthorization) Read(iprot thrift.TProtocol) error

+ func (p *TAuthorization) String() string

+ func (p *TAuthorization) Write(oprot thrift.TProtocol) error

+ type TCellVisibility struct

+ Expression *string

+ var TAppend_CellVisibility_DEFAULT *TCellVisibility

+ var TIncrement_CellVisibility_DEFAULT *TCellVisibility

+ var TPut_CellVisibility_DEFAULT *TCellVisibility

+ func NewTCellVisibility() *TCellVisibility

+ func (p *TCellVisibility) GetExpression() string

+ func (p *TCellVisibility) IsSetExpression() bool

+ func (p *TCellVisibility) Read(iprot thrift.TProtocol) error

+ func (p *TCellVisibility) String() string

+ func (p *TCellVisibility) Write(oprot thrift.TProtocol) error

+ type TColumn struct

+ Family []byte

+ Qualifier []byte

+ Timestamp *int64

+ func NewTColumn() *TColumn

+ func (p *TColumn) GetFamily() []byte

+ func (p *TColumn) GetQualifier() []byte

+ func (p *TColumn) GetTimestamp() int64

+ func (p *TColumn) IsSetQualifier() bool

+ func (p *TColumn) IsSetTimestamp() bool

+ func (p *TColumn) Read(iprot thrift.TProtocol) error

+ func (p *TColumn) String() string

+ func (p *TColumn) Write(oprot thrift.TProtocol) error

+ type TColumnIncrement struct

+ Amount int64

+ Family []byte

+ Qualifier []byte

+ func NewTColumnIncrement() *TColumnIncrement

+ func (p *TColumnIncrement) GetAmount() int64

+ func (p *TColumnIncrement) GetFamily() []byte

+ func (p *TColumnIncrement) GetQualifier() []byte

+ func (p *TColumnIncrement) IsSetAmount() bool

+ func (p *TColumnIncrement) Read(iprot thrift.TProtocol) error

+ func (p *TColumnIncrement) String() string

+ func (p *TColumnIncrement) Write(oprot thrift.TProtocol) error

+ type TColumnValue struct

+ Family []byte

+ Qualifier []byte

+ Tags []byte

+ Timestamp *int64

+ Value []byte

+ func NewTColumnValue() *TColumnValue

+ func (p *TColumnValue) GetFamily() []byte

+ func (p *TColumnValue) GetQualifier() []byte

+ func (p *TColumnValue) GetTags() []byte

+ func (p *TColumnValue) GetTimestamp() int64

+ func (p *TColumnValue) GetValue() []byte

+ func (p *TColumnValue) IsSetTags() bool

+ func (p *TColumnValue) IsSetTimestamp() bool

+ func (p *TColumnValue) Read(iprot thrift.TProtocol) error

+ func (p *TColumnValue) String() string

+ func (p *TColumnValue) Write(oprot thrift.TProtocol) error

+ type TCompareOp int64

+ const TCompareOp_EQUAL

+ const TCompareOp_GREATER

+ const TCompareOp_GREATER_OR_EQUAL

+ const TCompareOp_LESS

+ const TCompareOp_LESS_OR_EQUAL

+ const TCompareOp_NOT_EQUAL

+ const TCompareOp_NO_OP

+ func TCompareOpFromString(s string) (TCompareOp, error)

+ func TCompareOpPtr(v TCompareOp) *TCompareOp

+ func (p *TCompareOp) UnmarshalText(text []byte) error

+ func (p TCompareOp) MarshalText() ([]byte, error)

+ func (p TCompareOp) String() string

+ type TDelete struct

+ Attributes map[string][]byte

+ Columns []*TColumn

+ DeleteType TDeleteType

+ Durability *TDurability

+ Row []byte

+ Timestamp *int64

+ var THBaseServiceCheckAndDeleteArgs_Tdelete_DEFAULT *TDelete

+ var THBaseServiceDeleteSingleArgs_Tdelete_DEFAULT *TDelete

+ var TMutation_DeleteSingle_DEFAULT *TDelete

+ func NewTDelete() *TDelete

+ func (p *TDelete) GetAttributes() map[string][]byte

+ func (p *TDelete) GetColumns() []*TColumn

+ func (p *TDelete) GetDeleteType() TDeleteType

+ func (p *TDelete) GetDurability() TDurability

+ func (p *TDelete) GetRow() []byte

+ func (p *TDelete) GetTimestamp() int64

+ func (p *TDelete) IsSetAttributes() bool

+ func (p *TDelete) IsSetColumns() bool

+ func (p *TDelete) IsSetDeleteType() bool

+ func (p *TDelete) IsSetDurability() bool

+ func (p *TDelete) IsSetTimestamp() bool

+ func (p *TDelete) Read(iprot thrift.TProtocol) error

+ func (p *TDelete) String() string

+ func (p *TDelete) Write(oprot thrift.TProtocol) error

+ type TDeleteType int64

+ const TDeleteType_DELETE_COLUMN

+ const TDeleteType_DELETE_COLUMNS

+ const TDeleteType_DELETE_FAMILY

+ const TDeleteType_DELETE_FAMILY_VERSION

+ var TDelete_DeleteType_DEFAULT TDeleteType = 1

+ func TDeleteTypeFromString(s string) (TDeleteType, error)

+ func TDeleteTypePtr(v TDeleteType) *TDeleteType

+ func (p *TDeleteType) UnmarshalText(text []byte) error

+ func (p TDeleteType) MarshalText() ([]byte, error)

+ func (p TDeleteType) String() string

+ type TDurability int64

+ const TDurability_ASYNC_WAL

+ const TDurability_FSYNC_WAL

+ const TDurability_SKIP_WAL

+ const TDurability_SYNC_WAL

+ var TAppend_Durability_DEFAULT TDurability

+ var TDelete_Durability_DEFAULT TDurability

+ var TIncrement_Durability_DEFAULT TDurability

+ var TPut_Durability_DEFAULT TDurability

+ func TDurabilityFromString(s string) (TDurability, error)

+ func TDurabilityPtr(v TDurability) *TDurability

+ func (p *TDurability) UnmarshalText(text []byte) error

+ func (p TDurability) MarshalText() ([]byte, error)

+ func (p TDurability) String() string

+ type TGet struct

+ Attributes map[string][]byte

+ Authorizations *TAuthorization

+ Columns []*TColumn

+ FilterString []byte

+ MaxVersions *int32

+ Row []byte

+ TimeRange *TTimeRange

+ Timestamp *int64

+ var THBaseServiceExistsArgs_Tget_DEFAULT *TGet

+ var THBaseServiceGetArgs_Tget_DEFAULT *TGet

+ func NewTGet() *TGet

+ func (p *TGet) GetAttributes() map[string][]byte

+ func (p *TGet) GetAuthorizations() *TAuthorization

+ func (p *TGet) GetColumns() []*TColumn

+ func (p *TGet) GetFilterString() []byte

+ func (p *TGet) GetMaxVersions() int32

+ func (p *TGet) GetRow() []byte

+ func (p *TGet) GetTimeRange() *TTimeRange

+ func (p *TGet) GetTimestamp() int64

+ func (p *TGet) IsSetAttributes() bool

+ func (p *TGet) IsSetAuthorizations() bool

+ func (p *TGet) IsSetColumns() bool

+ func (p *TGet) IsSetFilterString() bool

+ func (p *TGet) IsSetMaxVersions() bool

+ func (p *TGet) IsSetTimeRange() bool

+ func (p *TGet) IsSetTimestamp() bool

+ func (p *TGet) Read(iprot thrift.TProtocol) error

+ func (p *TGet) String() string

+ func (p *TGet) Write(oprot thrift.TProtocol) error

+ type THBaseService interface

+ Append func(table []byte, tappend *TAppend) (r *TResult_, err error)

+ CheckAndDelete func(table []byte, row []byte, family []byte, qualifier []byte, value []byte, ...) (r bool, err error)

+ CheckAndMutate func(table []byte, row []byte, family []byte, qualifier []byte, ...) (r bool, err error)

+ CheckAndPut func(table []byte, row []byte, family []byte, qualifier []byte, value []byte, ...) (r bool, err error)

+ CloseScanner func(scannerId int32) (err error)

+ DeleteMultiple func(table []byte, tdeletes []*TDelete) (r []*TDelete, err error)

+ DeleteSingle func(table []byte, tdelete *TDelete) (err error)

+ Exists func(table []byte, tget *TGet) (r bool, err error)

+ ExistsAll func(table []byte, tgets []*TGet) (r []bool, err error)

+ Get func(table []byte, tget *TGet) (r *TResult_, err error)

+ GetAllRegionLocations func(table []byte) (r []*THRegionLocation, err error)

+ GetMultiple func(table []byte, tgets []*TGet) (r []*TResult_, err error)

+ GetRegionLocation func(table []byte, row []byte, reload bool) (r *THRegionLocation, err error)

+ GetScannerResults func(table []byte, tscan *TScan, numRows int32) (r []*TResult_, err error)

+ GetScannerRows func(scannerId int32, numRows int32) (r []*TResult_, err error)

+ Increment func(table []byte, tincrement *TIncrement) (r *TResult_, err error)

+ MutateRow func(table []byte, trowMutations *TRowMutations) (err error)

+ OpenScanner func(table []byte, tscan *TScan) (r int32, err error)

+ Put func(table []byte, tput *TPut) (err error)

+ PutMultiple func(table []byte, tputs []*TPut) (err error)

+ type THBaseServiceAppendArgs struct

+ Table []byte

+ Tappend *TAppend

+ func NewTHBaseServiceAppendArgs() *THBaseServiceAppendArgs

+ func (p *THBaseServiceAppendArgs) GetTable() []byte

+ func (p *THBaseServiceAppendArgs) GetTappend() *TAppend

+ func (p *THBaseServiceAppendArgs) IsSetTappend() bool

+ func (p *THBaseServiceAppendArgs) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServiceAppendArgs) String() string

+ func (p *THBaseServiceAppendArgs) Write(oprot thrift.TProtocol) error

+ type THBaseServiceAppendResult struct

+ Io *TIOError

+ Success *TResult_

+ func NewTHBaseServiceAppendResult() *THBaseServiceAppendResult

+ func (p *THBaseServiceAppendResult) GetIo() *TIOError

+ func (p *THBaseServiceAppendResult) GetSuccess() *TResult_

+ func (p *THBaseServiceAppendResult) IsSetIo() bool

+ func (p *THBaseServiceAppendResult) IsSetSuccess() bool

+ func (p *THBaseServiceAppendResult) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServiceAppendResult) String() string

+ func (p *THBaseServiceAppendResult) Write(oprot thrift.TProtocol) error

+ type THBaseServiceCheckAndDeleteArgs struct

+ Family []byte

+ Qualifier []byte

+ Row []byte

+ Table []byte

+ Tdelete *TDelete

+ Value []byte

+ func NewTHBaseServiceCheckAndDeleteArgs() *THBaseServiceCheckAndDeleteArgs

+ func (p *THBaseServiceCheckAndDeleteArgs) GetFamily() []byte

+ func (p *THBaseServiceCheckAndDeleteArgs) GetQualifier() []byte

+ func (p *THBaseServiceCheckAndDeleteArgs) GetRow() []byte

+ func (p *THBaseServiceCheckAndDeleteArgs) GetTable() []byte

+ func (p *THBaseServiceCheckAndDeleteArgs) GetTdelete() *TDelete

+ func (p *THBaseServiceCheckAndDeleteArgs) GetValue() []byte

+ func (p *THBaseServiceCheckAndDeleteArgs) IsSetTdelete() bool

+ func (p *THBaseServiceCheckAndDeleteArgs) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServiceCheckAndDeleteArgs) String() string

+ func (p *THBaseServiceCheckAndDeleteArgs) Write(oprot thrift.TProtocol) error

+ type THBaseServiceCheckAndDeleteResult struct

+ Io *TIOError

+ Success *bool

+ func NewTHBaseServiceCheckAndDeleteResult() *THBaseServiceCheckAndDeleteResult

+ func (p *THBaseServiceCheckAndDeleteResult) GetIo() *TIOError

+ func (p *THBaseServiceCheckAndDeleteResult) GetSuccess() bool

+ func (p *THBaseServiceCheckAndDeleteResult) IsSetIo() bool

+ func (p *THBaseServiceCheckAndDeleteResult) IsSetSuccess() bool

+ func (p *THBaseServiceCheckAndDeleteResult) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServiceCheckAndDeleteResult) String() string

+ func (p *THBaseServiceCheckAndDeleteResult) Write(oprot thrift.TProtocol) error

+ type THBaseServiceCheckAndMutateArgs struct

+ CompareOp TCompareOp

+ Family []byte

+ Qualifier []byte

+ Row []byte

+ RowMutations *TRowMutations

+ Table []byte

+ Value []byte

+ func NewTHBaseServiceCheckAndMutateArgs() *THBaseServiceCheckAndMutateArgs

+ func (p *THBaseServiceCheckAndMutateArgs) GetCompareOp() TCompareOp

+ func (p *THBaseServiceCheckAndMutateArgs) GetFamily() []byte

+ func (p *THBaseServiceCheckAndMutateArgs) GetQualifier() []byte

+ func (p *THBaseServiceCheckAndMutateArgs) GetRow() []byte

+ func (p *THBaseServiceCheckAndMutateArgs) GetRowMutations() *TRowMutations

+ func (p *THBaseServiceCheckAndMutateArgs) GetTable() []byte

+ func (p *THBaseServiceCheckAndMutateArgs) GetValue() []byte

+ func (p *THBaseServiceCheckAndMutateArgs) IsSetRowMutations() bool

+ func (p *THBaseServiceCheckAndMutateArgs) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServiceCheckAndMutateArgs) String() string

+ func (p *THBaseServiceCheckAndMutateArgs) Write(oprot thrift.TProtocol) error

+ type THBaseServiceCheckAndMutateResult struct

+ Io *TIOError

+ Success *bool

+ func NewTHBaseServiceCheckAndMutateResult() *THBaseServiceCheckAndMutateResult

+ func (p *THBaseServiceCheckAndMutateResult) GetIo() *TIOError

+ func (p *THBaseServiceCheckAndMutateResult) GetSuccess() bool

+ func (p *THBaseServiceCheckAndMutateResult) IsSetIo() bool

+ func (p *THBaseServiceCheckAndMutateResult) IsSetSuccess() bool

+ func (p *THBaseServiceCheckAndMutateResult) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServiceCheckAndMutateResult) String() string

+ func (p *THBaseServiceCheckAndMutateResult) Write(oprot thrift.TProtocol) error

+ type THBaseServiceCheckAndPutArgs struct

+ Family []byte

+ Qualifier []byte

+ Row []byte

+ Table []byte

+ Tput *TPut

+ Value []byte

+ func NewTHBaseServiceCheckAndPutArgs() *THBaseServiceCheckAndPutArgs

+ func (p *THBaseServiceCheckAndPutArgs) GetFamily() []byte

+ func (p *THBaseServiceCheckAndPutArgs) GetQualifier() []byte

+ func (p *THBaseServiceCheckAndPutArgs) GetRow() []byte

+ func (p *THBaseServiceCheckAndPutArgs) GetTable() []byte

+ func (p *THBaseServiceCheckAndPutArgs) GetTput() *TPut

+ func (p *THBaseServiceCheckAndPutArgs) GetValue() []byte

+ func (p *THBaseServiceCheckAndPutArgs) IsSetTput() bool

+ func (p *THBaseServiceCheckAndPutArgs) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServiceCheckAndPutArgs) String() string

+ func (p *THBaseServiceCheckAndPutArgs) Write(oprot thrift.TProtocol) error

+ type THBaseServiceCheckAndPutResult struct

+ Io *TIOError

+ Success *bool

+ func NewTHBaseServiceCheckAndPutResult() *THBaseServiceCheckAndPutResult

+ func (p *THBaseServiceCheckAndPutResult) GetIo() *TIOError

+ func (p *THBaseServiceCheckAndPutResult) GetSuccess() bool

+ func (p *THBaseServiceCheckAndPutResult) IsSetIo() bool

+ func (p *THBaseServiceCheckAndPutResult) IsSetSuccess() bool

+ func (p *THBaseServiceCheckAndPutResult) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServiceCheckAndPutResult) String() string

+ func (p *THBaseServiceCheckAndPutResult) Write(oprot thrift.TProtocol) error

+ type THBaseServiceClient struct

+ InputProtocol thrift.TProtocol

+ OutputProtocol thrift.TProtocol

+ ProtocolFactory thrift.TProtocolFactory

+ SeqId int32

+ Transport thrift.TTransport

+ func LinkHbase() (*THBaseServiceClient, error)

+ func NewTHBaseServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *THBaseServiceClient

+ func NewTHBaseServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *THBaseServiceClient

+ func (p *THBaseServiceClient) Append(table []byte, tappend *TAppend) (r *TResult_, err error)

+ func (p *THBaseServiceClient) CheckAndDelete(table []byte, row []byte, family []byte, qualifier []byte, value []byte, ...) (r bool, err error)

+ func (p *THBaseServiceClient) CheckAndMutate(table []byte, row []byte, family []byte, qualifier []byte, ...) (r bool, err error)

+ func (p *THBaseServiceClient) CheckAndPut(table []byte, row []byte, family []byte, qualifier []byte, value []byte, ...) (r bool, err error)

+ func (p *THBaseServiceClient) CloseScanner(scannerId int32) (err error)

+ func (p *THBaseServiceClient) DeleteMultiple(table []byte, tdeletes []*TDelete) (r []*TDelete, err error)

+ func (p *THBaseServiceClient) DeleteSingle(table []byte, tdelete *TDelete) (err error)

+ func (p *THBaseServiceClient) Exists(table []byte, tget *TGet) (r bool, err error)

+ func (p *THBaseServiceClient) ExistsAll(table []byte, tgets []*TGet) (r []bool, err error)

+ func (p *THBaseServiceClient) Get(table []byte, tget *TGet) (r *TResult_, err error)

+ func (p *THBaseServiceClient) GetAllRegionLocations(table []byte) (r []*THRegionLocation, err error)

+ func (p *THBaseServiceClient) GetMultiple(table []byte, tgets []*TGet) (r []*TResult_, err error)

+ func (p *THBaseServiceClient) GetRegionLocation(table []byte, row []byte, reload bool) (r *THRegionLocation, err error)

+ func (p *THBaseServiceClient) GetScannerResults(table []byte, tscan *TScan, numRows int32) (r []*TResult_, err error)

+ func (p *THBaseServiceClient) GetScannerRows(scannerId int32, numRows int32) (r []*TResult_, err error)

+ func (p *THBaseServiceClient) Increment(table []byte, tincrement *TIncrement) (r *TResult_, err error)

+ func (p *THBaseServiceClient) MutateRow(table []byte, trowMutations *TRowMutations) (err error)

+ func (p *THBaseServiceClient) OpenScanner(table []byte, tscan *TScan) (r int32, err error)

+ func (p *THBaseServiceClient) Put(table []byte, tput *TPut) (err error)

+ func (p *THBaseServiceClient) PutMultiple(table []byte, tputs []*TPut) (err error)

+ type THBaseServiceCloseScannerArgs struct

+ ScannerId int32

+ func NewTHBaseServiceCloseScannerArgs() *THBaseServiceCloseScannerArgs

+ func (p *THBaseServiceCloseScannerArgs) GetScannerId() int32

+ func (p *THBaseServiceCloseScannerArgs) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServiceCloseScannerArgs) String() string

+ func (p *THBaseServiceCloseScannerArgs) Write(oprot thrift.TProtocol) error

+ type THBaseServiceCloseScannerResult struct

+ Ia *TIllegalArgument

+ Io *TIOError

+ func NewTHBaseServiceCloseScannerResult() *THBaseServiceCloseScannerResult

+ func (p *THBaseServiceCloseScannerResult) GetIa() *TIllegalArgument

+ func (p *THBaseServiceCloseScannerResult) GetIo() *TIOError

+ func (p *THBaseServiceCloseScannerResult) IsSetIa() bool

+ func (p *THBaseServiceCloseScannerResult) IsSetIo() bool

+ func (p *THBaseServiceCloseScannerResult) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServiceCloseScannerResult) String() string

+ func (p *THBaseServiceCloseScannerResult) Write(oprot thrift.TProtocol) error

+ type THBaseServiceDeleteMultipleArgs struct

+ Table []byte

+ Tdeletes []*TDelete

+ func NewTHBaseServiceDeleteMultipleArgs() *THBaseServiceDeleteMultipleArgs

+ func (p *THBaseServiceDeleteMultipleArgs) GetTable() []byte

+ func (p *THBaseServiceDeleteMultipleArgs) GetTdeletes() []*TDelete

+ func (p *THBaseServiceDeleteMultipleArgs) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServiceDeleteMultipleArgs) String() string

+ func (p *THBaseServiceDeleteMultipleArgs) Write(oprot thrift.TProtocol) error

+ type THBaseServiceDeleteMultipleResult struct

+ Io *TIOError

+ Success []*TDelete

+ func NewTHBaseServiceDeleteMultipleResult() *THBaseServiceDeleteMultipleResult

+ func (p *THBaseServiceDeleteMultipleResult) GetIo() *TIOError

+ func (p *THBaseServiceDeleteMultipleResult) GetSuccess() []*TDelete

+ func (p *THBaseServiceDeleteMultipleResult) IsSetIo() bool

+ func (p *THBaseServiceDeleteMultipleResult) IsSetSuccess() bool

+ func (p *THBaseServiceDeleteMultipleResult) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServiceDeleteMultipleResult) String() string

+ func (p *THBaseServiceDeleteMultipleResult) Write(oprot thrift.TProtocol) error

+ type THBaseServiceDeleteSingleArgs struct

+ Table []byte

+ Tdelete *TDelete

+ func NewTHBaseServiceDeleteSingleArgs() *THBaseServiceDeleteSingleArgs

+ func (p *THBaseServiceDeleteSingleArgs) GetTable() []byte

+ func (p *THBaseServiceDeleteSingleArgs) GetTdelete() *TDelete

+ func (p *THBaseServiceDeleteSingleArgs) IsSetTdelete() bool

+ func (p *THBaseServiceDeleteSingleArgs) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServiceDeleteSingleArgs) String() string

+ func (p *THBaseServiceDeleteSingleArgs) Write(oprot thrift.TProtocol) error

+ type THBaseServiceDeleteSingleResult struct

+ Io *TIOError

+ func NewTHBaseServiceDeleteSingleResult() *THBaseServiceDeleteSingleResult

+ func (p *THBaseServiceDeleteSingleResult) GetIo() *TIOError

+ func (p *THBaseServiceDeleteSingleResult) IsSetIo() bool

+ func (p *THBaseServiceDeleteSingleResult) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServiceDeleteSingleResult) String() string

+ func (p *THBaseServiceDeleteSingleResult) Write(oprot thrift.TProtocol) error

+ type THBaseServiceExistsAllArgs struct

+ Table []byte

+ Tgets []*TGet

+ func NewTHBaseServiceExistsAllArgs() *THBaseServiceExistsAllArgs

+ func (p *THBaseServiceExistsAllArgs) GetTable() []byte

+ func (p *THBaseServiceExistsAllArgs) GetTgets() []*TGet

+ func (p *THBaseServiceExistsAllArgs) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServiceExistsAllArgs) String() string

+ func (p *THBaseServiceExistsAllArgs) Write(oprot thrift.TProtocol) error

+ type THBaseServiceExistsAllResult struct

+ Io *TIOError

+ Success []bool

+ func NewTHBaseServiceExistsAllResult() *THBaseServiceExistsAllResult

+ func (p *THBaseServiceExistsAllResult) GetIo() *TIOError

+ func (p *THBaseServiceExistsAllResult) GetSuccess() []bool

+ func (p *THBaseServiceExistsAllResult) IsSetIo() bool

+ func (p *THBaseServiceExistsAllResult) IsSetSuccess() bool

+ func (p *THBaseServiceExistsAllResult) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServiceExistsAllResult) String() string

+ func (p *THBaseServiceExistsAllResult) Write(oprot thrift.TProtocol) error

+ type THBaseServiceExistsArgs struct

+ Table []byte

+ Tget *TGet

+ func NewTHBaseServiceExistsArgs() *THBaseServiceExistsArgs

+ func (p *THBaseServiceExistsArgs) GetTable() []byte

+ func (p *THBaseServiceExistsArgs) GetTget() *TGet

+ func (p *THBaseServiceExistsArgs) IsSetTget() bool

+ func (p *THBaseServiceExistsArgs) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServiceExistsArgs) String() string

+ func (p *THBaseServiceExistsArgs) Write(oprot thrift.TProtocol) error

+ type THBaseServiceExistsResult struct

+ Io *TIOError

+ Success *bool

+ func NewTHBaseServiceExistsResult() *THBaseServiceExistsResult

+ func (p *THBaseServiceExistsResult) GetIo() *TIOError

+ func (p *THBaseServiceExistsResult) GetSuccess() bool

+ func (p *THBaseServiceExistsResult) IsSetIo() bool

+ func (p *THBaseServiceExistsResult) IsSetSuccess() bool

+ func (p *THBaseServiceExistsResult) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServiceExistsResult) String() string

+ func (p *THBaseServiceExistsResult) Write(oprot thrift.TProtocol) error

+ type THBaseServiceGetAllRegionLocationsArgs struct

+ Table []byte

+ func NewTHBaseServiceGetAllRegionLocationsArgs() *THBaseServiceGetAllRegionLocationsArgs

+ func (p *THBaseServiceGetAllRegionLocationsArgs) GetTable() []byte

+ func (p *THBaseServiceGetAllRegionLocationsArgs) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServiceGetAllRegionLocationsArgs) String() string

+ func (p *THBaseServiceGetAllRegionLocationsArgs) Write(oprot thrift.TProtocol) error

+ type THBaseServiceGetAllRegionLocationsResult struct

+ Io *TIOError

+ Success []*THRegionLocation

+ func NewTHBaseServiceGetAllRegionLocationsResult() *THBaseServiceGetAllRegionLocationsResult

+ func (p *THBaseServiceGetAllRegionLocationsResult) GetIo() *TIOError

+ func (p *THBaseServiceGetAllRegionLocationsResult) GetSuccess() []*THRegionLocation

+ func (p *THBaseServiceGetAllRegionLocationsResult) IsSetIo() bool

+ func (p *THBaseServiceGetAllRegionLocationsResult) IsSetSuccess() bool

+ func (p *THBaseServiceGetAllRegionLocationsResult) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServiceGetAllRegionLocationsResult) String() string

+ func (p *THBaseServiceGetAllRegionLocationsResult) Write(oprot thrift.TProtocol) error

+ type THBaseServiceGetArgs struct

+ Table []byte

+ Tget *TGet

+ func NewTHBaseServiceGetArgs() *THBaseServiceGetArgs

+ func (p *THBaseServiceGetArgs) GetTable() []byte

+ func (p *THBaseServiceGetArgs) GetTget() *TGet

+ func (p *THBaseServiceGetArgs) IsSetTget() bool

+ func (p *THBaseServiceGetArgs) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServiceGetArgs) String() string

+ func (p *THBaseServiceGetArgs) Write(oprot thrift.TProtocol) error

+ type THBaseServiceGetMultipleArgs struct

+ Table []byte

+ Tgets []*TGet

+ func NewTHBaseServiceGetMultipleArgs() *THBaseServiceGetMultipleArgs

+ func (p *THBaseServiceGetMultipleArgs) GetTable() []byte

+ func (p *THBaseServiceGetMultipleArgs) GetTgets() []*TGet

+ func (p *THBaseServiceGetMultipleArgs) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServiceGetMultipleArgs) String() string

+ func (p *THBaseServiceGetMultipleArgs) Write(oprot thrift.TProtocol) error

+ type THBaseServiceGetMultipleResult struct

+ Io *TIOError

+ Success []*TResult_

+ func NewTHBaseServiceGetMultipleResult() *THBaseServiceGetMultipleResult

+ func (p *THBaseServiceGetMultipleResult) GetIo() *TIOError

+ func (p *THBaseServiceGetMultipleResult) GetSuccess() []*TResult_

+ func (p *THBaseServiceGetMultipleResult) IsSetIo() bool

+ func (p *THBaseServiceGetMultipleResult) IsSetSuccess() bool

+ func (p *THBaseServiceGetMultipleResult) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServiceGetMultipleResult) String() string

+ func (p *THBaseServiceGetMultipleResult) Write(oprot thrift.TProtocol) error

+ type THBaseServiceGetRegionLocationArgs struct

+ Reload bool

+ Row []byte

+ Table []byte

+ func NewTHBaseServiceGetRegionLocationArgs() *THBaseServiceGetRegionLocationArgs

+ func (p *THBaseServiceGetRegionLocationArgs) GetReload() bool

+ func (p *THBaseServiceGetRegionLocationArgs) GetRow() []byte

+ func (p *THBaseServiceGetRegionLocationArgs) GetTable() []byte

+ func (p *THBaseServiceGetRegionLocationArgs) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServiceGetRegionLocationArgs) String() string

+ func (p *THBaseServiceGetRegionLocationArgs) Write(oprot thrift.TProtocol) error

+ type THBaseServiceGetRegionLocationResult struct

+ Io *TIOError

+ Success *THRegionLocation

+ func NewTHBaseServiceGetRegionLocationResult() *THBaseServiceGetRegionLocationResult

+ func (p *THBaseServiceGetRegionLocationResult) GetIo() *TIOError

+ func (p *THBaseServiceGetRegionLocationResult) GetSuccess() *THRegionLocation

+ func (p *THBaseServiceGetRegionLocationResult) IsSetIo() bool

+ func (p *THBaseServiceGetRegionLocationResult) IsSetSuccess() bool

+ func (p *THBaseServiceGetRegionLocationResult) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServiceGetRegionLocationResult) String() string

+ func (p *THBaseServiceGetRegionLocationResult) Write(oprot thrift.TProtocol) error

+ type THBaseServiceGetResult struct

+ Io *TIOError

+ Success *TResult_

+ func NewTHBaseServiceGetResult() *THBaseServiceGetResult

+ func (p *THBaseServiceGetResult) GetIo() *TIOError

+ func (p *THBaseServiceGetResult) GetSuccess() *TResult_

+ func (p *THBaseServiceGetResult) IsSetIo() bool

+ func (p *THBaseServiceGetResult) IsSetSuccess() bool

+ func (p *THBaseServiceGetResult) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServiceGetResult) String() string

+ func (p *THBaseServiceGetResult) Write(oprot thrift.TProtocol) error

+ type THBaseServiceGetScannerResultsArgs struct

+ NumRows int32

+ Table []byte

+ Tscan *TScan

+ func NewTHBaseServiceGetScannerResultsArgs() *THBaseServiceGetScannerResultsArgs

+ func (p *THBaseServiceGetScannerResultsArgs) GetNumRows() int32

+ func (p *THBaseServiceGetScannerResultsArgs) GetTable() []byte

+ func (p *THBaseServiceGetScannerResultsArgs) GetTscan() *TScan

+ func (p *THBaseServiceGetScannerResultsArgs) IsSetTscan() bool

+ func (p *THBaseServiceGetScannerResultsArgs) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServiceGetScannerResultsArgs) String() string

+ func (p *THBaseServiceGetScannerResultsArgs) Write(oprot thrift.TProtocol) error

+ type THBaseServiceGetScannerResultsResult struct

+ Io *TIOError

+ Success []*TResult_

+ func NewTHBaseServiceGetScannerResultsResult() *THBaseServiceGetScannerResultsResult

+ func (p *THBaseServiceGetScannerResultsResult) GetIo() *TIOError

+ func (p *THBaseServiceGetScannerResultsResult) GetSuccess() []*TResult_

+ func (p *THBaseServiceGetScannerResultsResult) IsSetIo() bool

+ func (p *THBaseServiceGetScannerResultsResult) IsSetSuccess() bool

+ func (p *THBaseServiceGetScannerResultsResult) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServiceGetScannerResultsResult) String() string

+ func (p *THBaseServiceGetScannerResultsResult) Write(oprot thrift.TProtocol) error

+ type THBaseServiceGetScannerRowsArgs struct

+ NumRows int32

+ ScannerId int32

+ func NewTHBaseServiceGetScannerRowsArgs() *THBaseServiceGetScannerRowsArgs

+ func (p *THBaseServiceGetScannerRowsArgs) GetNumRows() int32

+ func (p *THBaseServiceGetScannerRowsArgs) GetScannerId() int32

+ func (p *THBaseServiceGetScannerRowsArgs) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServiceGetScannerRowsArgs) String() string

+ func (p *THBaseServiceGetScannerRowsArgs) Write(oprot thrift.TProtocol) error

+ type THBaseServiceGetScannerRowsResult struct

+ Ia *TIllegalArgument

+ Io *TIOError

+ Success []*TResult_

+ func NewTHBaseServiceGetScannerRowsResult() *THBaseServiceGetScannerRowsResult

+ func (p *THBaseServiceGetScannerRowsResult) GetIa() *TIllegalArgument

+ func (p *THBaseServiceGetScannerRowsResult) GetIo() *TIOError

+ func (p *THBaseServiceGetScannerRowsResult) GetSuccess() []*TResult_

+ func (p *THBaseServiceGetScannerRowsResult) IsSetIa() bool

+ func (p *THBaseServiceGetScannerRowsResult) IsSetIo() bool

+ func (p *THBaseServiceGetScannerRowsResult) IsSetSuccess() bool

+ func (p *THBaseServiceGetScannerRowsResult) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServiceGetScannerRowsResult) String() string

+ func (p *THBaseServiceGetScannerRowsResult) Write(oprot thrift.TProtocol) error

+ type THBaseServiceIncrementArgs struct

+ Table []byte

+ Tincrement *TIncrement

+ func NewTHBaseServiceIncrementArgs() *THBaseServiceIncrementArgs

+ func (p *THBaseServiceIncrementArgs) GetTable() []byte

+ func (p *THBaseServiceIncrementArgs) GetTincrement() *TIncrement

+ func (p *THBaseServiceIncrementArgs) IsSetTincrement() bool

+ func (p *THBaseServiceIncrementArgs) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServiceIncrementArgs) String() string

+ func (p *THBaseServiceIncrementArgs) Write(oprot thrift.TProtocol) error

+ type THBaseServiceIncrementResult struct

+ Io *TIOError

+ Success *TResult_

+ func NewTHBaseServiceIncrementResult() *THBaseServiceIncrementResult

+ func (p *THBaseServiceIncrementResult) GetIo() *TIOError

+ func (p *THBaseServiceIncrementResult) GetSuccess() *TResult_

+ func (p *THBaseServiceIncrementResult) IsSetIo() bool

+ func (p *THBaseServiceIncrementResult) IsSetSuccess() bool

+ func (p *THBaseServiceIncrementResult) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServiceIncrementResult) String() string

+ func (p *THBaseServiceIncrementResult) Write(oprot thrift.TProtocol) error

+ type THBaseServiceMutateRowArgs struct

+ Table []byte

+ TrowMutations *TRowMutations

+ func NewTHBaseServiceMutateRowArgs() *THBaseServiceMutateRowArgs

+ func (p *THBaseServiceMutateRowArgs) GetTable() []byte

+ func (p *THBaseServiceMutateRowArgs) GetTrowMutations() *TRowMutations

+ func (p *THBaseServiceMutateRowArgs) IsSetTrowMutations() bool

+ func (p *THBaseServiceMutateRowArgs) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServiceMutateRowArgs) String() string

+ func (p *THBaseServiceMutateRowArgs) Write(oprot thrift.TProtocol) error

+ type THBaseServiceMutateRowResult struct

+ Io *TIOError

+ func NewTHBaseServiceMutateRowResult() *THBaseServiceMutateRowResult

+ func (p *THBaseServiceMutateRowResult) GetIo() *TIOError

+ func (p *THBaseServiceMutateRowResult) IsSetIo() bool

+ func (p *THBaseServiceMutateRowResult) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServiceMutateRowResult) String() string

+ func (p *THBaseServiceMutateRowResult) Write(oprot thrift.TProtocol) error

+ type THBaseServiceOpenScannerArgs struct

+ Table []byte

+ Tscan *TScan

+ func NewTHBaseServiceOpenScannerArgs() *THBaseServiceOpenScannerArgs

+ func (p *THBaseServiceOpenScannerArgs) GetTable() []byte

+ func (p *THBaseServiceOpenScannerArgs) GetTscan() *TScan

+ func (p *THBaseServiceOpenScannerArgs) IsSetTscan() bool

+ func (p *THBaseServiceOpenScannerArgs) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServiceOpenScannerArgs) String() string

+ func (p *THBaseServiceOpenScannerArgs) Write(oprot thrift.TProtocol) error

+ type THBaseServiceOpenScannerResult struct

+ Io *TIOError

+ Success *int32

+ func NewTHBaseServiceOpenScannerResult() *THBaseServiceOpenScannerResult

+ func (p *THBaseServiceOpenScannerResult) GetIo() *TIOError

+ func (p *THBaseServiceOpenScannerResult) GetSuccess() int32

+ func (p *THBaseServiceOpenScannerResult) IsSetIo() bool

+ func (p *THBaseServiceOpenScannerResult) IsSetSuccess() bool

+ func (p *THBaseServiceOpenScannerResult) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServiceOpenScannerResult) String() string

+ func (p *THBaseServiceOpenScannerResult) Write(oprot thrift.TProtocol) error

+ type THBaseServiceProcessor struct

+ func NewTHBaseServiceProcessor(handler THBaseService) *THBaseServiceProcessor

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

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

+ func (p *THBaseServiceProcessor) Process(iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

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

+ type THBaseServicePutArgs struct

+ Table []byte

+ Tput *TPut

+ func NewTHBaseServicePutArgs() *THBaseServicePutArgs

+ func (p *THBaseServicePutArgs) GetTable() []byte

+ func (p *THBaseServicePutArgs) GetTput() *TPut

+ func (p *THBaseServicePutArgs) IsSetTput() bool

+ func (p *THBaseServicePutArgs) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServicePutArgs) String() string

+ func (p *THBaseServicePutArgs) Write(oprot thrift.TProtocol) error

+ type THBaseServicePutMultipleArgs struct

+ Table []byte

+ Tputs []*TPut

+ func NewTHBaseServicePutMultipleArgs() *THBaseServicePutMultipleArgs

+ func (p *THBaseServicePutMultipleArgs) GetTable() []byte

+ func (p *THBaseServicePutMultipleArgs) GetTputs() []*TPut

+ func (p *THBaseServicePutMultipleArgs) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServicePutMultipleArgs) String() string

+ func (p *THBaseServicePutMultipleArgs) Write(oprot thrift.TProtocol) error

+ type THBaseServicePutMultipleResult struct

+ Io *TIOError

+ func NewTHBaseServicePutMultipleResult() *THBaseServicePutMultipleResult

+ func (p *THBaseServicePutMultipleResult) GetIo() *TIOError

+ func (p *THBaseServicePutMultipleResult) IsSetIo() bool

+ func (p *THBaseServicePutMultipleResult) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServicePutMultipleResult) String() string

+ func (p *THBaseServicePutMultipleResult) Write(oprot thrift.TProtocol) error

+ type THBaseServicePutResult struct

+ Io *TIOError

+ func NewTHBaseServicePutResult() *THBaseServicePutResult

+ func (p *THBaseServicePutResult) GetIo() *TIOError

+ func (p *THBaseServicePutResult) IsSetIo() bool

+ func (p *THBaseServicePutResult) Read(iprot thrift.TProtocol) error

+ func (p *THBaseServicePutResult) String() string

+ func (p *THBaseServicePutResult) Write(oprot thrift.TProtocol) error

+ type THRegionInfo struct

+ EndKey []byte

+ Offline *bool

+ RegionId int64

+ ReplicaId *int32

+ Split *bool

+ StartKey []byte

+ TableName []byte

+ var THRegionLocation_RegionInfo_DEFAULT *THRegionInfo

+ func NewTHRegionInfo() *THRegionInfo

+ func (p *THRegionInfo) GetEndKey() []byte

+ func (p *THRegionInfo) GetOffline() bool

+ func (p *THRegionInfo) GetRegionId() int64

+ func (p *THRegionInfo) GetReplicaId() int32

+ func (p *THRegionInfo) GetSplit() bool

+ func (p *THRegionInfo) GetStartKey() []byte

+ func (p *THRegionInfo) GetTableName() []byte

+ func (p *THRegionInfo) IsSetEndKey() bool

+ func (p *THRegionInfo) IsSetOffline() bool

+ func (p *THRegionInfo) IsSetReplicaId() bool

+ func (p *THRegionInfo) IsSetSplit() bool

+ func (p *THRegionInfo) IsSetStartKey() bool

+ func (p *THRegionInfo) Read(iprot thrift.TProtocol) error

+ func (p *THRegionInfo) String() string

+ func (p *THRegionInfo) Write(oprot thrift.TProtocol) error

+ type THRegionLocation struct

+ RegionInfo *THRegionInfo

+ ServerName *TServerName

+ var THBaseServiceGetRegionLocationResult_Success_DEFAULT *THRegionLocation

+ func NewTHRegionLocation() *THRegionLocation

+ func (p *THRegionLocation) GetRegionInfo() *THRegionInfo

+ func (p *THRegionLocation) GetServerName() *TServerName

+ func (p *THRegionLocation) IsSetRegionInfo() bool

+ func (p *THRegionLocation) IsSetServerName() bool

+ func (p *THRegionLocation) Read(iprot thrift.TProtocol) error

+ func (p *THRegionLocation) String() string

+ func (p *THRegionLocation) Write(oprot thrift.TProtocol) error

+ type TIOError struct

+ Message *string

+ var THBaseServiceAppendResult_Io_DEFAULT *TIOError

+ var THBaseServiceCheckAndDeleteResult_Io_DEFAULT *TIOError

+ var THBaseServiceCheckAndMutateResult_Io_DEFAULT *TIOError

+ var THBaseServiceCheckAndPutResult_Io_DEFAULT *TIOError

+ var THBaseServiceCloseScannerResult_Io_DEFAULT *TIOError

+ var THBaseServiceDeleteMultipleResult_Io_DEFAULT *TIOError

+ var THBaseServiceDeleteSingleResult_Io_DEFAULT *TIOError

+ var THBaseServiceExistsAllResult_Io_DEFAULT *TIOError

+ var THBaseServiceExistsResult_Io_DEFAULT *TIOError

+ var THBaseServiceGetAllRegionLocationsResult_Io_DEFAULT *TIOError

+ var THBaseServiceGetMultipleResult_Io_DEFAULT *TIOError

+ var THBaseServiceGetRegionLocationResult_Io_DEFAULT *TIOError

+ var THBaseServiceGetResult_Io_DEFAULT *TIOError

+ var THBaseServiceGetScannerResultsResult_Io_DEFAULT *TIOError

+ var THBaseServiceGetScannerRowsResult_Io_DEFAULT *TIOError

+ var THBaseServiceIncrementResult_Io_DEFAULT *TIOError

+ var THBaseServiceMutateRowResult_Io_DEFAULT *TIOError

+ var THBaseServiceOpenScannerResult_Io_DEFAULT *TIOError

+ var THBaseServicePutMultipleResult_Io_DEFAULT *TIOError

+ var THBaseServicePutResult_Io_DEFAULT *TIOError

+ func NewTIOError() *TIOError

+ func (p *TIOError) Error() string

+ func (p *TIOError) GetMessage() string

+ func (p *TIOError) IsSetMessage() bool

+ func (p *TIOError) Read(iprot thrift.TProtocol) error

+ func (p *TIOError) String() string

+ func (p *TIOError) Write(oprot thrift.TProtocol) error

+ type TIllegalArgument struct

+ Message *string

+ var THBaseServiceCloseScannerResult_Ia_DEFAULT *TIllegalArgument

+ var THBaseServiceGetScannerRowsResult_Ia_DEFAULT *TIllegalArgument

+ func NewTIllegalArgument() *TIllegalArgument

+ func (p *TIllegalArgument) Error() string

+ func (p *TIllegalArgument) GetMessage() string

+ func (p *TIllegalArgument) IsSetMessage() bool

+ func (p *TIllegalArgument) Read(iprot thrift.TProtocol) error

+ func (p *TIllegalArgument) String() string

+ func (p *TIllegalArgument) Write(oprot thrift.TProtocol) error

+ type TIncrement struct

+ Attributes map[string][]byte

+ CellVisibility *TCellVisibility

+ Columns []*TColumnIncrement

+ Durability *TDurability

+ Row []byte

+ var THBaseServiceIncrementArgs_Tincrement_DEFAULT *TIncrement

+ func NewTIncrement() *TIncrement

+ func (p *TIncrement) GetAttributes() map[string][]byte

+ func (p *TIncrement) GetCellVisibility() *TCellVisibility

+ func (p *TIncrement) GetColumns() []*TColumnIncrement

+ func (p *TIncrement) GetDurability() TDurability

+ func (p *TIncrement) GetRow() []byte

+ func (p *TIncrement) IsSetAttributes() bool

+ func (p *TIncrement) IsSetCellVisibility() bool

+ func (p *TIncrement) IsSetDurability() bool

+ func (p *TIncrement) Read(iprot thrift.TProtocol) error

+ func (p *TIncrement) String() string

+ func (p *TIncrement) Write(oprot thrift.TProtocol) error

+ type TMutation struct

+ DeleteSingle *TDelete

+ Put *TPut

+ func NewTMutation() *TMutation

+ func (p *TMutation) CountSetFieldsTMutation() int

+ func (p *TMutation) GetDeleteSingle() *TDelete

+ func (p *TMutation) GetPut() *TPut

+ func (p *TMutation) IsSetDeleteSingle() bool

+ func (p *TMutation) IsSetPut() bool

+ func (p *TMutation) Read(iprot thrift.TProtocol) error

+ func (p *TMutation) String() string

+ func (p *TMutation) Write(oprot thrift.TProtocol) error

+ type TPut struct

+ Attributes map[string][]byte

+ CellVisibility *TCellVisibility

+ ColumnValues []*TColumnValue

+ Durability *TDurability

+ Row []byte

+ Timestamp *int64

+ var THBaseServiceCheckAndPutArgs_Tput_DEFAULT *TPut

+ var THBaseServicePutArgs_Tput_DEFAULT *TPut

+ var TMutation_Put_DEFAULT *TPut

+ func NewTPut() *TPut

+ func (p *TPut) GetAttributes() map[string][]byte

+ func (p *TPut) GetCellVisibility() *TCellVisibility

+ func (p *TPut) GetColumnValues() []*TColumnValue

+ func (p *TPut) GetDurability() TDurability

+ func (p *TPut) GetRow() []byte

+ func (p *TPut) GetTimestamp() int64

+ func (p *TPut) IsSetAttributes() bool

+ func (p *TPut) IsSetCellVisibility() bool

+ func (p *TPut) IsSetDurability() bool

+ func (p *TPut) IsSetTimestamp() bool

+ func (p *TPut) Read(iprot thrift.TProtocol) error

+ func (p *TPut) String() string

+ func (p *TPut) Write(oprot thrift.TProtocol) error

+ type TReadType int64

+ const TReadType_DEFAULT

+ const TReadType_PREAD

+ const TReadType_STREAM

+ var TScan_ReadType_DEFAULT TReadType

+ func TReadTypeFromString(s string) (TReadType, error)

+ func TReadTypePtr(v TReadType) *TReadType

+ func (p *TReadType) UnmarshalText(text []byte) error

+ func (p TReadType) MarshalText() ([]byte, error)

+ func (p TReadType) String() string

+ type TResult_ struct

+ ColumnValues []*TColumnValue

+ Row []byte

+ var THBaseServiceAppendResult_Success_DEFAULT *TResult_

+ var THBaseServiceGetResult_Success_DEFAULT *TResult_

+ var THBaseServiceIncrementResult_Success_DEFAULT *TResult_

+ func NewTResult_() *TResult_

+ func (p *TResult_) GetColumnValues() []*TColumnValue

+ func (p *TResult_) GetRow() []byte

+ func (p *TResult_) IsSetRow() bool

+ func (p *TResult_) Read(iprot thrift.TProtocol) error

+ func (p *TResult_) String() string

+ func (p *TResult_) Write(oprot thrift.TProtocol) error

+ type TRowMutations struct

+ Mutations []*TMutation

+ Row []byte

+ var THBaseServiceCheckAndMutateArgs_RowMutations_DEFAULT *TRowMutations

+ var THBaseServiceMutateRowArgs_TrowMutations_DEFAULT *TRowMutations

+ func NewTRowMutations() *TRowMutations

+ func (p *TRowMutations) GetMutations() []*TMutation

+ func (p *TRowMutations) GetRow() []byte

+ func (p *TRowMutations) Read(iprot thrift.TProtocol) error

+ func (p *TRowMutations) String() string

+ func (p *TRowMutations) Write(oprot thrift.TProtocol) error

+ type TScan struct

+ Attributes map[string][]byte

+ Authorizations *TAuthorization

+ BatchSize *int32

+ CacheBlocks *bool

+ Caching *int32

+ ColFamTimeRangeMap map[string]*TTimeRange

+ Columns []*TColumn

+ FilterString []byte

+ Limit *int32

+ MaxVersions int32

+ ReadType *TReadType

+ Reversed *bool

+ StartRow []byte

+ StopRow []byte

+ TimeRange *TTimeRange

+ var THBaseServiceGetScannerResultsArgs_Tscan_DEFAULT *TScan

+ var THBaseServiceOpenScannerArgs_Tscan_DEFAULT *TScan

+ func NewTScan() *TScan

+ func (p *TScan) GetAttributes() map[string][]byte

+ func (p *TScan) GetAuthorizations() *TAuthorization

+ func (p *TScan) GetBatchSize() int32

+ func (p *TScan) GetCacheBlocks() bool

+ func (p *TScan) GetCaching() int32

+ func (p *TScan) GetColFamTimeRangeMap() map[string]*TTimeRange

+ func (p *TScan) GetColumns() []*TColumn

+ func (p *TScan) GetFilterString() []byte

+ func (p *TScan) GetLimit() int32

+ func (p *TScan) GetMaxVersions() int32

+ func (p *TScan) GetReadType() TReadType

+ func (p *TScan) GetReversed() bool

+ func (p *TScan) GetStartRow() []byte

+ func (p *TScan) GetStopRow() []byte

+ func (p *TScan) GetTimeRange() *TTimeRange

+ func (p *TScan) IsSetAttributes() bool

+ func (p *TScan) IsSetAuthorizations() bool

+ func (p *TScan) IsSetBatchSize() bool

+ func (p *TScan) IsSetCacheBlocks() bool

+ func (p *TScan) IsSetCaching() bool

+ func (p *TScan) IsSetColFamTimeRangeMap() bool

+ func (p *TScan) IsSetColumns() bool

+ func (p *TScan) IsSetFilterString() bool

+ func (p *TScan) IsSetLimit() bool

+ func (p *TScan) IsSetMaxVersions() bool

+ func (p *TScan) IsSetReadType() bool

+ func (p *TScan) IsSetReversed() bool

+ func (p *TScan) IsSetStartRow() bool

+ func (p *TScan) IsSetStopRow() bool

+ func (p *TScan) IsSetTimeRange() bool

+ func (p *TScan) Read(iprot thrift.TProtocol) error

+ func (p *TScan) String() string

+ func (p *TScan) Write(oprot thrift.TProtocol) error

+ type TServerName struct

+ HostName string

+ Port *int32

+ StartCode *int64

+ var THRegionLocation_ServerName_DEFAULT *TServerName

+ func NewTServerName() *TServerName

+ func (p *TServerName) GetHostName() string

+ func (p *TServerName) GetPort() int32

+ func (p *TServerName) GetStartCode() int64

+ func (p *TServerName) IsSetPort() bool

+ func (p *TServerName) IsSetStartCode() bool

+ func (p *TServerName) Read(iprot thrift.TProtocol) error

+ func (p *TServerName) String() string

+ func (p *TServerName) Write(oprot thrift.TProtocol) error

+ type TTimeRange struct

+ MaxStamp int64

+ MinStamp int64

+ var TGet_TimeRange_DEFAULT *TTimeRange

+ var TScan_TimeRange_DEFAULT *TTimeRange

+ func NewTTimeRange() *TTimeRange

+ func (p *TTimeRange) GetMaxStamp() int64

+ func (p *TTimeRange) GetMinStamp() int64

+ func (p *TTimeRange) Read(iprot thrift.TProtocol) error

+ func (p *TTimeRange) String() string

+ func (p *TTimeRange) Write(oprot thrift.TProtocol) error