gen

package
v0.0.0-...-7aea3de Latest Latest
Warning

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

 Go to latest Published: Apr 26, 2019 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var GetInfoResult_Success_DEFAULT []*HFileInfo
View Source 
var GoUnusedProtection__ int
View Source 
var HFileInfo_FirstKey_DEFAULT []byte
View Source 
var HFileInfo_LastKey_DEFAULT []byte
View Source 
var HFileInfo_Name_DEFAULT string
View Source 
var HFileInfo_NumElements_DEFAULT int64
View Source 
var HFileInfo_Path_DEFAULT string
View Source 
var HFileInfo_RandomKeys_DEFAULT [][]byte
View Source 
var HFileServiceException_Message_DEFAULT string
View Source 
var InfoRequest_HfileName_DEFAULT string
View Source 
var InfoRequest_NumRandomKeys_DEFAULT int64
View Source 
var IteratorRequest_EndKey_DEFAULT []byte
View Source 
var IteratorRequest_HfileName_DEFAULT string
View Source 
var IteratorRequest_IncludeValues_DEFAULT bool
View Source 
var IteratorRequest_LastKey_DEFAULT []byte
View Source 
var IteratorRequest_ResponseLimit_DEFAULT int32
View Source 
var IteratorRequest_SkipKeys_DEFAULT int32
View Source 
var IteratorResponse_LastKey_DEFAULT []byte
View Source 
var IteratorResponse_SkipKeys_DEFAULT int32
View Source 
var IteratorResponse_Values_DEFAULT []*KeyValueItem
View Source 
var KeyToValuesResponse_Values_DEFAULT map[string][][]byte
View Source 
var KeyValueItem_Key_DEFAULT []byte
View Source 
var KeyValueItem_Value_DEFAULT []byte
View Source 
var MultiHFileKeyResponse_KeyCount_DEFAULT int32
View Source 
var MultiHFileKeyResponse_Values_DEFAULT map[int32][][]byte
View Source 
var MultiHFileSplitKeyRequest_HfileName_DEFAULT string
View Source 
var MultiHFileSplitKeyRequest_RetiredSortedPrefixes_DEFAULT [][]byte
View Source 
var MultiHFileSplitKeyRequest_RetiredSortedSuffixes_DEFAULT [][]byte
View Source 
var MultiHFileSplitKeyRequest_SplitKey_DEFAULT [][][]byte
View Source 
var PrefixRequest_HfileName_DEFAULT string
View Source 
var PrefixRequest_LastKey_DEFAULT []byte
View Source 
var PrefixRequest_SortedKeys_DEFAULT [][]byte
View Source 
var PrefixRequest_ValueLimit_DEFAULT int32
View Source 
var PrefixResponse_LastKey_DEFAULT []byte
View Source 
var PrefixResponse_Values_DEFAULT map[string][][]byte
View Source 
var ScanCollectionAndSampleKeysResult_Success_DEFAULT []*HFileInfo
View Source 
var SingleHFileKeyRequest_CountOnly_DEFAULT bool
View Source 
var SingleHFileKeyRequest_HfileName_DEFAULT string
View Source 
var SingleHFileKeyRequest_PerKeyValueLimit_DEFAULT int32
View Source 
var SingleHFileKeyRequest_SortedKeys_DEFAULT [][]byte
View Source 
var SingleHFileKeyResponse_KeyCount_DEFAULT int32
View Source 
var SingleHFileKeyResponse_Values_DEFAULT map[int32][]byte
View Source 
var TestTimeoutResult_Success_DEFAULT int32

Functions

This section is empty.

Types

type GetInfoArgs 

type GetInfoArgs struct {
	Req *InfoRequest `thrift:"req,1" json:"req"`
}

func NewGetInfoArgs 

func NewGetInfoArgs() *GetInfoArgs

func (*GetInfoArgs) GetReq 

func (p *GetInfoArgs) GetReq() *InfoRequest

func (*GetInfoArgs) IsSetReq 

func (p *GetInfoArgs) IsSetReq() bool

func (*GetInfoArgs) Read 

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

func (*GetInfoArgs) ReadField1 

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

func (*GetInfoArgs) String 

func (p *GetInfoArgs) String() string

func (*GetInfoArgs) Write 

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

type GetInfoResult 

type GetInfoResult struct {
	Success []*HFileInfo           `thrift:"success,0" json:"success"`
	Ex      *HFileServiceException `thrift:"ex,1" json:"ex"`
}

func NewGetInfoResult 

func NewGetInfoResult() *GetInfoResult

func (*GetInfoResult) GetEx 

func (p *GetInfoResult) GetEx() *HFileServiceException

func (*GetInfoResult) GetSuccess 

func (p *GetInfoResult) GetSuccess() []*HFileInfo

func (*GetInfoResult) IsSetEx 

func (p *GetInfoResult) IsSetEx() bool

func (*GetInfoResult) IsSetSuccess 

func (p *GetInfoResult) IsSetSuccess() bool

func (*GetInfoResult) Read 

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

func (*GetInfoResult) ReadField0 

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

func (*GetInfoResult) ReadField1 

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

func (*GetInfoResult) String 

func (p *GetInfoResult) String() string

func (*GetInfoResult) Write 

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

type GetIteratorArgs 

type GetIteratorArgs struct {
	Req *IteratorRequest `thrift:"req,1" json:"req"`
}

func NewGetIteratorArgs 

func NewGetIteratorArgs() *GetIteratorArgs

func (*GetIteratorArgs) GetReq 

func (p *GetIteratorArgs) GetReq() *IteratorRequest

func (*GetIteratorArgs) IsSetReq 

func (p *GetIteratorArgs) IsSetReq() bool

func (*GetIteratorArgs) Read 

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

func (*GetIteratorArgs) ReadField1 

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

func (*GetIteratorArgs) String 

func (p *GetIteratorArgs) String() string

func (*GetIteratorArgs) Write 

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

type GetIteratorResult 

type GetIteratorResult struct {
	Success *IteratorResponse      `thrift:"success,0" json:"success"`
	Ex      *HFileServiceException `thrift:"ex,1" json:"ex"`
}

func NewGetIteratorResult 

func NewGetIteratorResult() *GetIteratorResult

func (*GetIteratorResult) GetEx 

func (p *GetIteratorResult) GetEx() *HFileServiceException

func (*GetIteratorResult) GetSuccess 

func (p *GetIteratorResult) GetSuccess() *IteratorResponse

func (*GetIteratorResult) IsSetEx 

func (p *GetIteratorResult) IsSetEx() bool

func (*GetIteratorResult) IsSetSuccess 

func (p *GetIteratorResult) IsSetSuccess() bool

func (*GetIteratorResult) Read 

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

func (*GetIteratorResult) ReadField0 

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

func (*GetIteratorResult) ReadField1 

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

func (*GetIteratorResult) String 

func (p *GetIteratorResult) String() string

func (*GetIteratorResult) Write 

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

type GetValuesForPrefixesArgs 

type GetValuesForPrefixesArgs struct {
	Req *PrefixRequest `thrift:"req,1" json:"req"`
}

func NewGetValuesForPrefixesArgs 

func NewGetValuesForPrefixesArgs() *GetValuesForPrefixesArgs

func (*GetValuesForPrefixesArgs) GetReq 

func (p *GetValuesForPrefixesArgs) GetReq() *PrefixRequest

func (*GetValuesForPrefixesArgs) IsSetReq 

func (p *GetValuesForPrefixesArgs) IsSetReq() bool

func (*GetValuesForPrefixesArgs) Read 

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

func (*GetValuesForPrefixesArgs) ReadField1 

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

func (*GetValuesForPrefixesArgs) String 

func (p *GetValuesForPrefixesArgs) String() string

func (*GetValuesForPrefixesArgs) Write 

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

type GetValuesForPrefixesResult 

type GetValuesForPrefixesResult struct {
	Success *PrefixResponse        `thrift:"success,0" json:"success"`
	Ex      *HFileServiceException `thrift:"ex,1" json:"ex"`
}

func NewGetValuesForPrefixesResult 

func NewGetValuesForPrefixesResult() *GetValuesForPrefixesResult

func (*GetValuesForPrefixesResult) GetEx 

func (p *GetValuesForPrefixesResult) GetEx() *HFileServiceException

func (*GetValuesForPrefixesResult) GetSuccess 

func (p *GetValuesForPrefixesResult) GetSuccess() *PrefixResponse

func (*GetValuesForPrefixesResult) IsSetEx 

func (p *GetValuesForPrefixesResult) IsSetEx() bool

func (*GetValuesForPrefixesResult) IsSetSuccess 

func (p *GetValuesForPrefixesResult) IsSetSuccess() bool

func (*GetValuesForPrefixesResult) Read 

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

func (*GetValuesForPrefixesResult) ReadField0 

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

func (*GetValuesForPrefixesResult) ReadField1 

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

func (*GetValuesForPrefixesResult) String 

func (p *GetValuesForPrefixesResult) String() string

func (*GetValuesForPrefixesResult) Write 

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

type GetValuesMultiArgs 

type GetValuesMultiArgs struct {
	Req *SingleHFileKeyRequest `thrift:"req,1" json:"req"`
}

func NewGetValuesMultiArgs 

func NewGetValuesMultiArgs() *GetValuesMultiArgs

func (*GetValuesMultiArgs) GetReq 

func (p *GetValuesMultiArgs) GetReq() *SingleHFileKeyRequest

func (*GetValuesMultiArgs) IsSetReq 

func (p *GetValuesMultiArgs) IsSetReq() bool

func (*GetValuesMultiArgs) Read 

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

func (*GetValuesMultiArgs) ReadField1 

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

func (*GetValuesMultiArgs) String 

func (p *GetValuesMultiArgs) String() string

func (*GetValuesMultiArgs) Write 

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

type GetValuesMultiResult 

type GetValuesMultiResult struct {
	Success *MultiHFileKeyResponse `thrift:"success,0" json:"success"`
	Ex      *HFileServiceException `thrift:"ex,1" json:"ex"`
}

func NewGetValuesMultiResult 

func NewGetValuesMultiResult() *GetValuesMultiResult

func (*GetValuesMultiResult) GetEx 

func (p *GetValuesMultiResult) GetEx() *HFileServiceException

func (*GetValuesMultiResult) GetSuccess 

func (p *GetValuesMultiResult) GetSuccess() *MultiHFileKeyResponse

func (*GetValuesMultiResult) IsSetEx 

func (p *GetValuesMultiResult) IsSetEx() bool

func (*GetValuesMultiResult) IsSetSuccess 

func (p *GetValuesMultiResult) IsSetSuccess() bool

func (*GetValuesMultiResult) Read 

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

func (*GetValuesMultiResult) ReadField0 

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

func (*GetValuesMultiResult) ReadField1 

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

func (*GetValuesMultiResult) String 

func (p *GetValuesMultiResult) String() string

func (*GetValuesMultiResult) Write 

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

type GetValuesMultiSplitKeysArgs 

type GetValuesMultiSplitKeysArgs struct {
	Req *MultiHFileSplitKeyRequest `thrift:"req,1" json:"req"`
}

func NewGetValuesMultiSplitKeysArgs 

func NewGetValuesMultiSplitKeysArgs() *GetValuesMultiSplitKeysArgs

func (*GetValuesMultiSplitKeysArgs) GetReq 

func (p *GetValuesMultiSplitKeysArgs) GetReq() *MultiHFileSplitKeyRequest

func (*GetValuesMultiSplitKeysArgs) IsSetReq 

func (p *GetValuesMultiSplitKeysArgs) IsSetReq() bool

func (*GetValuesMultiSplitKeysArgs) Read 

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

func (*GetValuesMultiSplitKeysArgs) ReadField1 

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

func (*GetValuesMultiSplitKeysArgs) String 

func (p *GetValuesMultiSplitKeysArgs) String() string

func (*GetValuesMultiSplitKeysArgs) Write 

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

type GetValuesMultiSplitKeysResult 

type GetValuesMultiSplitKeysResult struct {
	Success *KeyToValuesResponse   `thrift:"success,0" json:"success"`
	Ex      *HFileServiceException `thrift:"ex,1" json:"ex"`
}

func NewGetValuesMultiSplitKeysResult 

func NewGetValuesMultiSplitKeysResult() *GetValuesMultiSplitKeysResult

func (*GetValuesMultiSplitKeysResult) GetEx 

func (p *GetValuesMultiSplitKeysResult) GetEx() *HFileServiceException

func (*GetValuesMultiSplitKeysResult) GetSuccess 

func (p *GetValuesMultiSplitKeysResult) GetSuccess() *KeyToValuesResponse

func (*GetValuesMultiSplitKeysResult) IsSetEx 

func (p *GetValuesMultiSplitKeysResult) IsSetEx() bool

func (*GetValuesMultiSplitKeysResult) IsSetSuccess 

func (p *GetValuesMultiSplitKeysResult) IsSetSuccess() bool

func (*GetValuesMultiSplitKeysResult) Read 

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

func (*GetValuesMultiSplitKeysResult) ReadField0 

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

func (*GetValuesMultiSplitKeysResult) ReadField1 

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

func (*GetValuesMultiSplitKeysResult) String 

func (p *GetValuesMultiSplitKeysResult) String() string

func (*GetValuesMultiSplitKeysResult) Write 

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

type GetValuesSingleArgs 

type GetValuesSingleArgs struct {
	Req *SingleHFileKeyRequest `thrift:"req,1" json:"req"`
}

func NewGetValuesSingleArgs 

func NewGetValuesSingleArgs() *GetValuesSingleArgs

func (*GetValuesSingleArgs) GetReq 

func (p *GetValuesSingleArgs) GetReq() *SingleHFileKeyRequest

func (*GetValuesSingleArgs) IsSetReq 

func (p *GetValuesSingleArgs) IsSetReq() bool

func (*GetValuesSingleArgs) Read 

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

func (*GetValuesSingleArgs) ReadField1 

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

func (*GetValuesSingleArgs) String 

func (p *GetValuesSingleArgs) String() string

func (*GetValuesSingleArgs) Write 

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

type GetValuesSingleResult 

type GetValuesSingleResult struct {
	Success *SingleHFileKeyResponse `thrift:"success,0" json:"success"`
	Ex      *HFileServiceException  `thrift:"ex,1" json:"ex"`
}

func NewGetValuesSingleResult 

func NewGetValuesSingleResult() *GetValuesSingleResult

func (*GetValuesSingleResult) GetEx 

func (p *GetValuesSingleResult) GetEx() *HFileServiceException

func (*GetValuesSingleResult) GetSuccess 

func (p *GetValuesSingleResult) GetSuccess() *SingleHFileKeyResponse

func (*GetValuesSingleResult) IsSetEx 

func (p *GetValuesSingleResult) IsSetEx() bool

func (*GetValuesSingleResult) IsSetSuccess 

func (p *GetValuesSingleResult) IsSetSuccess() bool

func (*GetValuesSingleResult) Read 

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

func (*GetValuesSingleResult) ReadField0 

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

func (*GetValuesSingleResult) ReadField1 

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

func (*GetValuesSingleResult) String 

func (p *GetValuesSingleResult) String() string

func (*GetValuesSingleResult) Write 

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

type HFileInfo 

type HFileInfo struct {
	Name        *string  `thrift:"name,1" json:"name"`
	Path        *string  `thrift:"path,2" json:"path"`
	NumElements *int64   `thrift:"numElements,3" json:"numElements"`
	FirstKey    []byte   `thrift:"firstKey,4" json:"firstKey"`
	LastKey     []byte   `thrift:"lastKey,5" json:"lastKey"`
	RandomKeys  [][]byte `thrift:"randomKeys,6" json:"randomKeys"`
}

func NewHFileInfo 

func NewHFileInfo() *HFileInfo

func (*HFileInfo) GetFirstKey 

func (p *HFileInfo) GetFirstKey() []byte

func (*HFileInfo) GetLastKey 

func (p *HFileInfo) GetLastKey() []byte

func (*HFileInfo) GetName 

func (p *HFileInfo) GetName() string

func (*HFileInfo) GetNumElements 

func (p *HFileInfo) GetNumElements() int64

func (*HFileInfo) GetPath 

func (p *HFileInfo) GetPath() string

func (*HFileInfo) GetRandomKeys 

func (p *HFileInfo) GetRandomKeys() [][]byte

func (*HFileInfo) IsSetFirstKey 

func (p *HFileInfo) IsSetFirstKey() bool

func (*HFileInfo) IsSetLastKey 

func (p *HFileInfo) IsSetLastKey() bool

func (*HFileInfo) IsSetName 

func (p *HFileInfo) IsSetName() bool

func (*HFileInfo) IsSetNumElements 

func (p *HFileInfo) IsSetNumElements() bool

func (*HFileInfo) IsSetPath 

func (p *HFileInfo) IsSetPath() bool

func (*HFileInfo) IsSetRandomKeys 

func (p *HFileInfo) IsSetRandomKeys() bool

func (*HFileInfo) Read 

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

func (*HFileInfo) ReadField1 

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

func (*HFileInfo) ReadField2 

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

func (*HFileInfo) ReadField3 

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

func (*HFileInfo) ReadField4 

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

func (*HFileInfo) ReadField5 

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

func (*HFileInfo) ReadField6 

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

func (*HFileInfo) String 

func (p *HFileInfo) String() string

func (*HFileInfo) Write 

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

type HFileService 

type HFileService interface {
	// Parameters:
	//  - Req
	GetValuesSingle(req *SingleHFileKeyRequest) (r *SingleHFileKeyResponse, err error)
	// Parameters:
	//  - Req
	GetValuesMulti(req *SingleHFileKeyRequest) (r *MultiHFileKeyResponse, err error)
	// Parameters:
	//  - Req
	GetValuesForPrefixes(req *PrefixRequest) (r *PrefixResponse, err error)
	// Parameters:
	//  - Req
	GetValuesMultiSplitKeys(req *MultiHFileSplitKeyRequest) (r *KeyToValuesResponse, err error)
	// Parameters:
	//  - Req
	GetIterator(req *IteratorRequest) (r *IteratorResponse, err error)
	// Parameters:
	//  - Req
	GetInfo(req *InfoRequest) (r []*HFileInfo, err error)
	// Parameters:
	//  - Req
	ScanCollectionAndSampleKeys(req *InfoRequest) (r []*HFileInfo, err error)
	// Parameters:
	//  - WaitInMillis
	TestTimeout(waitInMillis int32) (r int32, err error)
}

type HFileServiceAction 

type HFileServiceAction int64
const (
	HFileServiceAction_fetchValuesSingle       HFileServiceAction = 0
	HFileServiceAction_fetchValuesMulti        HFileServiceAction = 1
	HFileServiceAction_getIterator             HFileServiceAction = 2
	HFileServiceAction_fetchValuesForPrefixes  HFileServiceAction = 3
	HFileServiceAction_fetchValuesForSplitKeys HFileServiceAction = 4
)

func HFileServiceActionFromString 

func HFileServiceActionFromString(s string) (HFileServiceAction, error)

func HFileServiceActionPtr 

func HFileServiceActionPtr(v HFileServiceAction) *HFileServiceAction

func (HFileServiceAction) String 

func (p HFileServiceAction) String() string

type HFileServiceClient 

type HFileServiceClient struct {
	Transport       thrift.TTransport
	ProtocolFactory thrift.TProtocolFactory
	InputProtocol   thrift.TProtocol
	OutputProtocol  thrift.TProtocol
	SeqId           int32
}

func NewHFileServiceClientFactory 

func NewHFileServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *HFileServiceClient

func NewHFileServiceClientProtocol 

func NewHFileServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *HFileServiceClient

func (*HFileServiceClient) GetInfo 

func (p *HFileServiceClient) GetInfo(req *InfoRequest) (r []*HFileInfo, err error)

Parameters:

  • Req

func (*HFileServiceClient) GetIterator 

func (p *HFileServiceClient) GetIterator(req *IteratorRequest) (r *IteratorResponse, err error)

Parameters:

  • Req

func (*HFileServiceClient) GetValuesForPrefixes 

func (p *HFileServiceClient) GetValuesForPrefixes(req *PrefixRequest) (r *PrefixResponse, err error)

Parameters:

  • Req

func (*HFileServiceClient) GetValuesMulti 

func (p *HFileServiceClient) GetValuesMulti(req *SingleHFileKeyRequest) (r *MultiHFileKeyResponse, err error)

Parameters:

  • Req

func (*HFileServiceClient) GetValuesMultiSplitKeys 

func (p *HFileServiceClient) GetValuesMultiSplitKeys(req *MultiHFileSplitKeyRequest) (r *KeyToValuesResponse, err error)

Parameters:

  • Req

func (*HFileServiceClient) GetValuesSingle 

func (p *HFileServiceClient) GetValuesSingle(req *SingleHFileKeyRequest) (r *SingleHFileKeyResponse, err error)

Parameters:

  • Req

func (*HFileServiceClient) ScanCollectionAndSampleKeys 

func (p *HFileServiceClient) ScanCollectionAndSampleKeys(req *InfoRequest) (r []*HFileInfo, err error)

Parameters:

  • Req

func (*HFileServiceClient) TestTimeout 

func (p *HFileServiceClient) TestTimeout(waitInMillis int32) (r int32, err error)

Parameters:

  • WaitInMillis

type HFileServiceException 

type HFileServiceException struct {
	Message *string `thrift:"message,1" json:"message"`
}
var GetInfoResult_Ex_DEFAULT *HFileServiceException
var GetIteratorResult_Ex_DEFAULT *HFileServiceException
var GetValuesForPrefixesResult_Ex_DEFAULT *HFileServiceException
var GetValuesMultiResult_Ex_DEFAULT *HFileServiceException
var GetValuesMultiSplitKeysResult_Ex_DEFAULT *HFileServiceException
var GetValuesSingleResult_Ex_DEFAULT *HFileServiceException
var ScanCollectionAndSampleKeysResult_Ex_DEFAULT *HFileServiceException

func NewHFileServiceException 

func NewHFileServiceException() *HFileServiceException

func (*HFileServiceException) Error 

func (p *HFileServiceException) Error() string

func (*HFileServiceException) GetMessage 

func (p *HFileServiceException) GetMessage() string

func (*HFileServiceException) IsSetMessage 

func (p *HFileServiceException) IsSetMessage() bool

func (*HFileServiceException) Read 

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

func (*HFileServiceException) ReadField1 

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

func (*HFileServiceException) String 

func (p *HFileServiceException) String() string

func (*HFileServiceException) Write 

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

type HFileServiceProcessor 

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

func NewHFileServiceProcessor 

func NewHFileServiceProcessor(handler HFileService) *HFileServiceProcessor

func (*HFileServiceProcessor) AddToProcessorMap 

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

func (*HFileServiceProcessor) GetProcessorFunction 

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

func (*HFileServiceProcessor) Process 

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

func (*HFileServiceProcessor) ProcessorMap 

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

type InfoRequest 

type InfoRequest struct {
	HfileName     *string `thrift:"hfileName,1" json:"hfileName"`
	NumRandomKeys *int64  `thrift:"numRandomKeys,2" json:"numRandomKeys"`
}
var GetInfoArgs_Req_DEFAULT *InfoRequest
var ScanCollectionAndSampleKeysArgs_Req_DEFAULT *InfoRequest

func NewInfoRequest 

func NewInfoRequest() *InfoRequest

func (*InfoRequest) GetHfileName 

func (p *InfoRequest) GetHfileName() string

func (*InfoRequest) GetNumRandomKeys 

func (p *InfoRequest) GetNumRandomKeys() int64

func (*InfoRequest) IsSetHfileName 

func (p *InfoRequest) IsSetHfileName() bool

func (*InfoRequest) IsSetNumRandomKeys 

func (p *InfoRequest) IsSetNumRandomKeys() bool

func (*InfoRequest) Read 

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

func (*InfoRequest) ReadField1 

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

func (*InfoRequest) ReadField2 

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

func (*InfoRequest) String 

func (p *InfoRequest) String() string

func (*InfoRequest) Write 

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

type IteratorRequest 

type IteratorRequest struct {
	HfileName     *string `thrift:"hfileName,1" json:"hfileName"`
	IncludeValues *bool   `thrift:"includeValues,2" json:"includeValues"`
	LastKey       []byte  `thrift:"lastKey,3" json:"lastKey"`
	SkipKeys      *int32  `thrift:"skipKeys,4" json:"skipKeys"`
	ResponseLimit *int32  `thrift:"responseLimit,5" json:"responseLimit"`
	EndKey        []byte  `thrift:"endKey,6" json:"endKey"`
}
var GetIteratorArgs_Req_DEFAULT *IteratorRequest

func NewIteratorRequest 

func NewIteratorRequest() *IteratorRequest

func (*IteratorRequest) GetEndKey 

func (p *IteratorRequest) GetEndKey() []byte

func (*IteratorRequest) GetHfileName 

func (p *IteratorRequest) GetHfileName() string

func (*IteratorRequest) GetIncludeValues 

func (p *IteratorRequest) GetIncludeValues() bool

func (*IteratorRequest) GetLastKey 

func (p *IteratorRequest) GetLastKey() []byte

func (*IteratorRequest) GetResponseLimit 

func (p *IteratorRequest) GetResponseLimit() int32

func (*IteratorRequest) GetSkipKeys 

func (p *IteratorRequest) GetSkipKeys() int32

func (*IteratorRequest) IsSetEndKey 

func (p *IteratorRequest) IsSetEndKey() bool

func (*IteratorRequest) IsSetHfileName 

func (p *IteratorRequest) IsSetHfileName() bool

func (*IteratorRequest) IsSetIncludeValues 

func (p *IteratorRequest) IsSetIncludeValues() bool

func (*IteratorRequest) IsSetLastKey 

func (p *IteratorRequest) IsSetLastKey() bool

func (*IteratorRequest) IsSetResponseLimit 

func (p *IteratorRequest) IsSetResponseLimit() bool

func (*IteratorRequest) IsSetSkipKeys 

func (p *IteratorRequest) IsSetSkipKeys() bool

func (*IteratorRequest) Read 

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

func (*IteratorRequest) ReadField1 

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

func (*IteratorRequest) ReadField2 

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

func (*IteratorRequest) ReadField3 

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

func (*IteratorRequest) ReadField4 

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

func (*IteratorRequest) ReadField5 

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

func (*IteratorRequest) ReadField6 

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

func (*IteratorRequest) String 

func (p *IteratorRequest) String() string

func (*IteratorRequest) Write 

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

type IteratorResponse 

type IteratorResponse struct {
	Values   []*KeyValueItem `thrift:"values,1" json:"values"`
	LastKey  []byte          `thrift:"lastKey,2" json:"lastKey"`
	SkipKeys *int32          `thrift:"skipKeys,3" json:"skipKeys"`
}
var GetIteratorResult_Success_DEFAULT *IteratorResponse

func NewIteratorResponse 

func NewIteratorResponse() *IteratorResponse

func (*IteratorResponse) GetLastKey 

func (p *IteratorResponse) GetLastKey() []byte

func (*IteratorResponse) GetSkipKeys 

func (p *IteratorResponse) GetSkipKeys() int32

func (*IteratorResponse) GetValues 

func (p *IteratorResponse) GetValues() []*KeyValueItem

func (*IteratorResponse) IsSetLastKey 

func (p *IteratorResponse) IsSetLastKey() bool

func (*IteratorResponse) IsSetSkipKeys 

func (p *IteratorResponse) IsSetSkipKeys() bool

func (*IteratorResponse) IsSetValues 

func (p *IteratorResponse) IsSetValues() bool

func (*IteratorResponse) Read 

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

func (*IteratorResponse) ReadField1 

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

func (*IteratorResponse) ReadField2 

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

func (*IteratorResponse) ReadField3 

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

func (*IteratorResponse) String 

func (p *IteratorResponse) String() string

func (*IteratorResponse) Write 

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

type KeyToValuesResponse 

type KeyToValuesResponse struct {
	Values map[string][][]byte `thrift:"values,1" json:"values"`
}
var GetValuesMultiSplitKeysResult_Success_DEFAULT *KeyToValuesResponse

func NewKeyToValuesResponse 

func NewKeyToValuesResponse() *KeyToValuesResponse

func (*KeyToValuesResponse) GetValues 

func (p *KeyToValuesResponse) GetValues() map[string][][]byte

func (*KeyToValuesResponse) IsSetValues 

func (p *KeyToValuesResponse) IsSetValues() bool

func (*KeyToValuesResponse) Read 

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

func (*KeyToValuesResponse) ReadField1 

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

func (*KeyToValuesResponse) String 

func (p *KeyToValuesResponse) String() string

func (*KeyToValuesResponse) Write 

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

type KeyValueItem 

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

func NewKeyValueItem 

func NewKeyValueItem() *KeyValueItem

func (*KeyValueItem) GetKey 

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

func (*KeyValueItem) GetValue 

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

func (*KeyValueItem) IsSetKey 

func (p *KeyValueItem) IsSetKey() bool

func (*KeyValueItem) IsSetValue 

func (p *KeyValueItem) IsSetValue() bool

func (*KeyValueItem) Read 

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

func (*KeyValueItem) ReadField1 

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

func (*KeyValueItem) ReadField2 

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

func (*KeyValueItem) String 

func (p *KeyValueItem) String() string

func (*KeyValueItem) Write 

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

type MultiHFileKeyResponse 

type MultiHFileKeyResponse struct {
	Values   map[int32][][]byte `thrift:"values,1" json:"values"`
	KeyCount *int32             `thrift:"keyCount,2" json:"keyCount"`
}
var GetValuesMultiResult_Success_DEFAULT *MultiHFileKeyResponse

func NewMultiHFileKeyResponse 

func NewMultiHFileKeyResponse() *MultiHFileKeyResponse

func (*MultiHFileKeyResponse) GetKeyCount 

func (p *MultiHFileKeyResponse) GetKeyCount() int32

func (*MultiHFileKeyResponse) GetValues 

func (p *MultiHFileKeyResponse) GetValues() map[int32][][]byte

func (*MultiHFileKeyResponse) IsSetKeyCount 

func (p *MultiHFileKeyResponse) IsSetKeyCount() bool

func (*MultiHFileKeyResponse) IsSetValues 

func (p *MultiHFileKeyResponse) IsSetValues() bool

func (*MultiHFileKeyResponse) Read 

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

func (*MultiHFileKeyResponse) ReadField1 

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

func (*MultiHFileKeyResponse) ReadField2 

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

func (*MultiHFileKeyResponse) String 

func (p *MultiHFileKeyResponse) String() string

func (*MultiHFileKeyResponse) Write 

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

type MultiHFileSplitKeyRequest 

type MultiHFileSplitKeyRequest struct {
	HfileName             *string    `thrift:"hfileName,1" json:"hfileName"`
	RetiredSortedPrefixes [][]byte   `thrift:"retired_sortedPrefixes,2" json:"retired_sortedPrefixes"`
	RetiredSortedSuffixes [][]byte   `thrift:"retired_sortedSuffixes,3" json:"retired_sortedSuffixes"`
	SplitKey              [][][]byte `thrift:"splitKey,4" json:"splitKey"`
}
var GetValuesMultiSplitKeysArgs_Req_DEFAULT *MultiHFileSplitKeyRequest

func NewMultiHFileSplitKeyRequest 

func NewMultiHFileSplitKeyRequest() *MultiHFileSplitKeyRequest

func (*MultiHFileSplitKeyRequest) GetHfileName 

func (p *MultiHFileSplitKeyRequest) GetHfileName() string

func (*MultiHFileSplitKeyRequest) GetRetiredSortedPrefixes 

func (p *MultiHFileSplitKeyRequest) GetRetiredSortedPrefixes() [][]byte

func (*MultiHFileSplitKeyRequest) GetRetiredSortedSuffixes 

func (p *MultiHFileSplitKeyRequest) GetRetiredSortedSuffixes() [][]byte

func (*MultiHFileSplitKeyRequest) GetSplitKey 

func (p *MultiHFileSplitKeyRequest) GetSplitKey() [][][]byte

func (*MultiHFileSplitKeyRequest) IsSetHfileName 

func (p *MultiHFileSplitKeyRequest) IsSetHfileName() bool

func (*MultiHFileSplitKeyRequest) IsSetRetiredSortedPrefixes 

func (p *MultiHFileSplitKeyRequest) IsSetRetiredSortedPrefixes() bool

func (*MultiHFileSplitKeyRequest) IsSetRetiredSortedSuffixes 

func (p *MultiHFileSplitKeyRequest) IsSetRetiredSortedSuffixes() bool

func (*MultiHFileSplitKeyRequest) IsSetSplitKey 

func (p *MultiHFileSplitKeyRequest) IsSetSplitKey() bool

func (*MultiHFileSplitKeyRequest) Read 

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

func (*MultiHFileSplitKeyRequest) ReadField1 

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

func (*MultiHFileSplitKeyRequest) ReadField2 

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

func (*MultiHFileSplitKeyRequest) ReadField3 

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

func (*MultiHFileSplitKeyRequest) ReadField4 

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

func (*MultiHFileSplitKeyRequest) String 

func (p *MultiHFileSplitKeyRequest) String() string

func (*MultiHFileSplitKeyRequest) Write 

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

type PrefixRequest 

type PrefixRequest struct {
	HfileName  *string  `thrift:"hfileName,1" json:"hfileName"`
	SortedKeys [][]byte `thrift:"sortedKeys,2" json:"sortedKeys"`
	LastKey    []byte   `thrift:"lastKey,3" json:"lastKey"`
	ValueLimit *int32   `thrift:"valueLimit,4" json:"valueLimit"`
}
var GetValuesForPrefixesArgs_Req_DEFAULT *PrefixRequest

func NewPrefixRequest 

func NewPrefixRequest() *PrefixRequest

func (*PrefixRequest) GetHfileName 

func (p *PrefixRequest) GetHfileName() string

func (*PrefixRequest) GetLastKey 

func (p *PrefixRequest) GetLastKey() []byte

func (*PrefixRequest) GetSortedKeys 

func (p *PrefixRequest) GetSortedKeys() [][]byte

func (*PrefixRequest) GetValueLimit 

func (p *PrefixRequest) GetValueLimit() int32

func (*PrefixRequest) IsSetHfileName 

func (p *PrefixRequest) IsSetHfileName() bool

func (*PrefixRequest) IsSetLastKey 

func (p *PrefixRequest) IsSetLastKey() bool

func (*PrefixRequest) IsSetSortedKeys 

func (p *PrefixRequest) IsSetSortedKeys() bool

func (*PrefixRequest) IsSetValueLimit 

func (p *PrefixRequest) IsSetValueLimit() bool

func (*PrefixRequest) Read 

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

func (*PrefixRequest) ReadField1 

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

func (*PrefixRequest) ReadField2 

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

func (*PrefixRequest) ReadField3 

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

func (*PrefixRequest) ReadField4 

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

func (*PrefixRequest) String 

func (p *PrefixRequest) String() string

func (*PrefixRequest) Write 

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

type PrefixResponse 

type PrefixResponse struct {
	Values  map[string][][]byte `thrift:"values,1" json:"values"`
	LastKey []byte              `thrift:"lastKey,2" json:"lastKey"`
}
var GetValuesForPrefixesResult_Success_DEFAULT *PrefixResponse

func NewPrefixResponse 

func NewPrefixResponse() *PrefixResponse

func (*PrefixResponse) GetLastKey 

func (p *PrefixResponse) GetLastKey() []byte

func (*PrefixResponse) GetValues 

func (p *PrefixResponse) GetValues() map[string][][]byte

func (*PrefixResponse) IsSetLastKey 

func (p *PrefixResponse) IsSetLastKey() bool

func (*PrefixResponse) IsSetValues 

func (p *PrefixResponse) IsSetValues() bool

func (*PrefixResponse) Read 

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

func (*PrefixResponse) ReadField1 

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

func (*PrefixResponse) ReadField2 

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

func (*PrefixResponse) String 

func (p *PrefixResponse) String() string

func (*PrefixResponse) Write 

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

type ScanCollectionAndSampleKeysArgs 

type ScanCollectionAndSampleKeysArgs struct {
	Req *InfoRequest `thrift:"req,1" json:"req"`
}

func NewScanCollectionAndSampleKeysArgs 

func NewScanCollectionAndSampleKeysArgs() *ScanCollectionAndSampleKeysArgs

func (*ScanCollectionAndSampleKeysArgs) GetReq 

func (p *ScanCollectionAndSampleKeysArgs) GetReq() *InfoRequest

func (*ScanCollectionAndSampleKeysArgs) IsSetReq 

func (p *ScanCollectionAndSampleKeysArgs) IsSetReq() bool

func (*ScanCollectionAndSampleKeysArgs) Read 

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

func (*ScanCollectionAndSampleKeysArgs) ReadField1 

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

func (*ScanCollectionAndSampleKeysArgs) String 

func (p *ScanCollectionAndSampleKeysArgs) String() string

func (*ScanCollectionAndSampleKeysArgs) Write 

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

type ScanCollectionAndSampleKeysResult 

type ScanCollectionAndSampleKeysResult struct {
	Success []*HFileInfo           `thrift:"success,0" json:"success"`
	Ex      *HFileServiceException `thrift:"ex,1" json:"ex"`
}

func NewScanCollectionAndSampleKeysResult 

func NewScanCollectionAndSampleKeysResult() *ScanCollectionAndSampleKeysResult

func (*ScanCollectionAndSampleKeysResult) GetEx 

func (p *ScanCollectionAndSampleKeysResult) GetEx() *HFileServiceException

func (*ScanCollectionAndSampleKeysResult) GetSuccess 

func (p *ScanCollectionAndSampleKeysResult) GetSuccess() []*HFileInfo

func (*ScanCollectionAndSampleKeysResult) IsSetEx 

func (p *ScanCollectionAndSampleKeysResult) IsSetEx() bool

func (*ScanCollectionAndSampleKeysResult) IsSetSuccess 

func (p *ScanCollectionAndSampleKeysResult) IsSetSuccess() bool

func (*ScanCollectionAndSampleKeysResult) Read 

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

func (*ScanCollectionAndSampleKeysResult) ReadField0 

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

func (*ScanCollectionAndSampleKeysResult) ReadField1 

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

func (*ScanCollectionAndSampleKeysResult) String 

func (p *ScanCollectionAndSampleKeysResult) String() string

func (*ScanCollectionAndSampleKeysResult) Write 

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

type SingleHFileKeyRequest 

type SingleHFileKeyRequest struct {
	HfileName        *string  `thrift:"hfileName,1" json:"hfileName"`
	SortedKeys       [][]byte `thrift:"sortedKeys,2" json:"sortedKeys"`
	PerKeyValueLimit *int32   `thrift:"perKeyValueLimit,3" json:"perKeyValueLimit"`
	CountOnly        *bool    `thrift:"countOnly,4" json:"countOnly"`
}
var GetValuesMultiArgs_Req_DEFAULT *SingleHFileKeyRequest
var GetValuesSingleArgs_Req_DEFAULT *SingleHFileKeyRequest

func NewSingleHFileKeyRequest 

func NewSingleHFileKeyRequest() *SingleHFileKeyRequest

func (*SingleHFileKeyRequest) GetCountOnly 

func (p *SingleHFileKeyRequest) GetCountOnly() bool

func (*SingleHFileKeyRequest) GetHfileName 

func (p *SingleHFileKeyRequest) GetHfileName() string

func (*SingleHFileKeyRequest) GetPerKeyValueLimit 

func (p *SingleHFileKeyRequest) GetPerKeyValueLimit() int32

func (*SingleHFileKeyRequest) GetSortedKeys 

func (p *SingleHFileKeyRequest) GetSortedKeys() [][]byte

func (*SingleHFileKeyRequest) IsSetCountOnly 

func (p *SingleHFileKeyRequest) IsSetCountOnly() bool

func (*SingleHFileKeyRequest) IsSetHfileName 

func (p *SingleHFileKeyRequest) IsSetHfileName() bool

func (*SingleHFileKeyRequest) IsSetPerKeyValueLimit 

func (p *SingleHFileKeyRequest) IsSetPerKeyValueLimit() bool

func (*SingleHFileKeyRequest) IsSetSortedKeys 

func (p *SingleHFileKeyRequest) IsSetSortedKeys() bool

func (*SingleHFileKeyRequest) Read 

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

func (*SingleHFileKeyRequest) ReadField1 

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

func (*SingleHFileKeyRequest) ReadField2 

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

func (*SingleHFileKeyRequest) ReadField3 

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

func (*SingleHFileKeyRequest) ReadField4 

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

func (*SingleHFileKeyRequest) String 

func (p *SingleHFileKeyRequest) String() string

func (*SingleHFileKeyRequest) Write 

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

type SingleHFileKeyResponse 

type SingleHFileKeyResponse struct {
	Values   map[int32][]byte `thrift:"values,1" json:"values"`
	KeyCount *int32           `thrift:"keyCount,2" json:"keyCount"`
}
var GetValuesSingleResult_Success_DEFAULT *SingleHFileKeyResponse

func NewSingleHFileKeyResponse 

func NewSingleHFileKeyResponse() *SingleHFileKeyResponse

func (*SingleHFileKeyResponse) GetKeyCount 

func (p *SingleHFileKeyResponse) GetKeyCount() int32

func (*SingleHFileKeyResponse) GetValues 

func (p *SingleHFileKeyResponse) GetValues() map[int32][]byte

func (*SingleHFileKeyResponse) IsSetKeyCount 

func (p *SingleHFileKeyResponse) IsSetKeyCount() bool

func (*SingleHFileKeyResponse) IsSetValues 

func (p *SingleHFileKeyResponse) IsSetValues() bool

func (*SingleHFileKeyResponse) Read 

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

func (*SingleHFileKeyResponse) ReadField1 

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

func (*SingleHFileKeyResponse) ReadField2 

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

func (*SingleHFileKeyResponse) String 

func (p *SingleHFileKeyResponse) String() string

func (*SingleHFileKeyResponse) Write 

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

type TestTimeoutArgs 

type TestTimeoutArgs struct {
	WaitInMillis int32 `thrift:"waitInMillis,1" json:"waitInMillis"`
}

func NewTestTimeoutArgs 

func NewTestTimeoutArgs() *TestTimeoutArgs

func (*TestTimeoutArgs) GetWaitInMillis 

func (p *TestTimeoutArgs) GetWaitInMillis() int32

func (*TestTimeoutArgs) Read 

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

func (*TestTimeoutArgs) ReadField1 

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

func (*TestTimeoutArgs) String 

func (p *TestTimeoutArgs) String() string

func (*TestTimeoutArgs) Write 

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

type TestTimeoutResult 

type TestTimeoutResult struct {
	Success *int32 `thrift:"success,0" json:"success"`
}

func NewTestTimeoutResult 

func NewTestTimeoutResult() *TestTimeoutResult

func (*TestTimeoutResult) GetSuccess 

func (p *TestTimeoutResult) GetSuccess() int32

func (*TestTimeoutResult) IsSetSuccess 

func (p *TestTimeoutResult) IsSetSuccess() bool

func (*TestTimeoutResult) Read 

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

func (*TestTimeoutResult) ReadField0 

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

func (*TestTimeoutResult) String 

func (p *TestTimeoutResult) String() string

func (*TestTimeoutResult) Write 

func (p *TestTimeoutResult) 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.