hbase: github.com/He11oLx/hbase Index | Files

package hbase

import "github.com/He11oLx/hbase"

Index

Package Files

client.go errors.go functions.go interface.go processor.go types.go

Variables

var AppendResult_Success_DEFAULT []*TCell
var AtomicIncrementResult_Success_DEFAULT int64
var CheckAndPutResult_Success_DEFAULT bool
var GetColumnDescriptorsResult_Success_DEFAULT map[string]*ColumnDescriptor
var GetResult_Success_DEFAULT []*TCell
var GetRowResult_Success_DEFAULT []*TRowResult_
var GetRowTsResult_Success_DEFAULT []*TRowResult_
var GetRowWithColumnsResult_Success_DEFAULT []*TRowResult_
var GetRowWithColumnsTsResult_Success_DEFAULT []*TRowResult_
var GetRowsResult_Success_DEFAULT []*TRowResult_
var GetRowsTsResult_Success_DEFAULT []*TRowResult_
var GetRowsWithColumnsResult_Success_DEFAULT []*TRowResult_
var GetRowsWithColumnsTsResult_Success_DEFAULT []*TRowResult_
var GetTableNamesResult_Success_DEFAULT [][]byte
var GetTableRegionsResult_Success_DEFAULT []*TRegionInfo
var GetVerResult_Success_DEFAULT []*TCell
var GetVerTsResult_Success_DEFAULT []*TCell
var IsTableEnabledResult_Success_DEFAULT bool
var ScannerGetListResult_Success_DEFAULT []*TRowResult_
var ScannerGetResult_Success_DEFAULT []*TRowResult_

type AlreadyExists Uses

type AlreadyExists struct {
    Message string `thrift:"message,1" db:"message" json:"message"`
}

An AlreadyExists exceptions signals that a table with the specified name already exists

Attributes:

- Message
var CreateTableResult_Exist_DEFAULT *AlreadyExists

func NewAlreadyExists Uses

func NewAlreadyExists() *AlreadyExists

func (*AlreadyExists) Error Uses

func (p *AlreadyExists) Error() string

func (*AlreadyExists) Read Uses

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

func (*AlreadyExists) ReadField1 Uses

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

func (*AlreadyExists) String Uses

func (p *AlreadyExists) String() string

func (*AlreadyExists) Write Uses

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

type AppendArgs Uses

type AppendArgs struct {
    Append *TAppend `thrift:"append,1" db:"append" json:"append"`
}

Attributes:

- Append: The single append operation to apply

func NewAppendArgs Uses

func NewAppendArgs() *AppendArgs

func (*AppendArgs) GetAppend Uses

func (p *AppendArgs) GetAppend() *TAppend

func (*AppendArgs) IsSetAppend Uses

func (p *AppendArgs) IsSetAppend() bool

func (*AppendArgs) Read Uses

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

func (*AppendArgs) ReadField1 Uses

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

func (*AppendArgs) String Uses

func (p *AppendArgs) String() string

func (*AppendArgs) Write Uses

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

type AppendResult Uses

type AppendResult struct {
    Success []*TCell `thrift:"success,0" db:"success" json:"success,omitempty"`
    Io      *IOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

- Success
- Io

func NewAppendResult Uses

func NewAppendResult() *AppendResult

func (*AppendResult) GetIo Uses

func (p *AppendResult) GetIo() *IOError

func (*AppendResult) GetSuccess Uses

func (p *AppendResult) GetSuccess() []*TCell

func (*AppendResult) IsSetIo Uses

func (p *AppendResult) IsSetIo() bool

func (*AppendResult) IsSetSuccess Uses

func (p *AppendResult) IsSetSuccess() bool

func (*AppendResult) Read Uses

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

func (*AppendResult) ReadField0 Uses

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

func (*AppendResult) ReadField1 Uses

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

func (*AppendResult) String Uses

func (p *AppendResult) String() string

func (*AppendResult) Write Uses

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

type AtomicIncrementArgs Uses

type AtomicIncrementArgs struct {
    TableName []byte `thrift:"tableName,1" db:"tableName" json:"tableName"`
    Row       []byte `thrift:"row,2" db:"row" json:"row"`
    Column    []byte `thrift:"column,3" db:"column" json:"column"`
    Value     int64  `thrift:"value,4" db:"value" json:"value"`
}

Attributes:

- TableName: name of table
- Row: row to increment
- Column: name of column
- Value: amount to increment by

func NewAtomicIncrementArgs Uses

func NewAtomicIncrementArgs() *AtomicIncrementArgs

func (*AtomicIncrementArgs) Read Uses

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

func (*AtomicIncrementArgs) ReadField1 Uses

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

func (*AtomicIncrementArgs) ReadField2 Uses

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

func (*AtomicIncrementArgs) ReadField3 Uses

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

func (*AtomicIncrementArgs) ReadField4 Uses

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

func (*AtomicIncrementArgs) String Uses

func (p *AtomicIncrementArgs) String() string

func (*AtomicIncrementArgs) Write Uses

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

type AtomicIncrementResult Uses

type AtomicIncrementResult struct {
    Success *int64           `thrift:"success,0" db:"success" json:"success,omitempty"`
    Io      *IOError         `thrift:"io,1" db:"io" json:"io,omitempty"`
    Ia      *IllegalArgument `thrift:"ia,2" db:"ia" json:"ia,omitempty"`
}

Attributes:

- Success
- Io
- Ia

func NewAtomicIncrementResult Uses

func NewAtomicIncrementResult() *AtomicIncrementResult

func (*AtomicIncrementResult) GetIa Uses

func (p *AtomicIncrementResult) GetIa() *IllegalArgument

func (*AtomicIncrementResult) GetIo Uses

func (p *AtomicIncrementResult) GetIo() *IOError

func (*AtomicIncrementResult) GetSuccess Uses

func (p *AtomicIncrementResult) GetSuccess() int64

func (*AtomicIncrementResult) IsSetIa Uses

func (p *AtomicIncrementResult) IsSetIa() bool

func (*AtomicIncrementResult) IsSetIo Uses

func (p *AtomicIncrementResult) IsSetIo() bool

func (*AtomicIncrementResult) IsSetSuccess Uses

func (p *AtomicIncrementResult) IsSetSuccess() bool

func (*AtomicIncrementResult) Read Uses

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

func (*AtomicIncrementResult) ReadField0 Uses

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

func (*AtomicIncrementResult) ReadField1 Uses

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

func (*AtomicIncrementResult) ReadField2 Uses

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

func (*AtomicIncrementResult) String Uses

func (p *AtomicIncrementResult) String() string

func (*AtomicIncrementResult) Write Uses

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

type BatchMutation Uses

type BatchMutation struct {
    Row       []byte      `thrift:"row,1" db:"row" json:"row"`
    Mutations []*Mutation `thrift:"mutations,2" db:"mutations" json:"mutations"`
}

A BatchMutation object is used to apply a number of Mutations to a single row.

Attributes:

- Row
- Mutations

func NewBatchMutation Uses

func NewBatchMutation() *BatchMutation

func (*BatchMutation) Read Uses

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

func (*BatchMutation) ReadField1 Uses

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

func (*BatchMutation) ReadField2 Uses

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

func (*BatchMutation) String Uses

func (p *BatchMutation) String() string

func (*BatchMutation) Write Uses

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

type CheckAndPutArgs Uses

type CheckAndPutArgs struct {
    TableName []byte `thrift:"tableName,1" db:"tableName" json:"tableName"`
    Row       []byte `thrift:"row,2" db:"row" json:"row"`
    Column    []byte `thrift:"column,3" db:"column" json:"column"`
    // unused field # 4
    Value      []byte            `thrift:"value,5" db:"value" json:"value"`
    Mput       *Mutation         `thrift:"mput,6" db:"mput" json:"mput"`
    Attributes map[string][]byte `thrift:"attributes,7" db:"attributes" json:"attributes"`
}

Attributes:

- TableName: name of table
- Row: row key
- Column: column name
- Value: the expected value for the column parameter, if not

provided the check is for the non-existence of the column in question

- Mput: mutation for the put
- Attributes: Mutation attributes

func NewCheckAndPutArgs Uses

func NewCheckAndPutArgs() *CheckAndPutArgs

func (*CheckAndPutArgs) GetMput Uses

func (p *CheckAndPutArgs) GetMput() *Mutation

func (*CheckAndPutArgs) IsSetMput Uses

func (p *CheckAndPutArgs) IsSetMput() bool

func (*CheckAndPutArgs) Read Uses

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

func (*CheckAndPutArgs) ReadField1 Uses

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

func (*CheckAndPutArgs) ReadField2 Uses

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

func (*CheckAndPutArgs) ReadField3 Uses

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

func (*CheckAndPutArgs) ReadField5 Uses

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

func (*CheckAndPutArgs) ReadField6 Uses

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

func (*CheckAndPutArgs) ReadField7 Uses

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

func (*CheckAndPutArgs) String Uses

func (p *CheckAndPutArgs) String() string

func (*CheckAndPutArgs) Write Uses

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

type CheckAndPutResult Uses

type CheckAndPutResult struct {
    Success *bool            `thrift:"success,0" db:"success" json:"success,omitempty"`
    Io      *IOError         `thrift:"io,1" db:"io" json:"io,omitempty"`
    Ia      *IllegalArgument `thrift:"ia,2" db:"ia" json:"ia,omitempty"`
}

Attributes:

- Success
- Io
- Ia

func NewCheckAndPutResult Uses

func NewCheckAndPutResult() *CheckAndPutResult

func (*CheckAndPutResult) GetIa Uses

func (p *CheckAndPutResult) GetIa() *IllegalArgument

func (*CheckAndPutResult) GetIo Uses

func (p *CheckAndPutResult) GetIo() *IOError

func (*CheckAndPutResult) GetSuccess Uses

func (p *CheckAndPutResult) GetSuccess() bool

func (*CheckAndPutResult) IsSetIa Uses

func (p *CheckAndPutResult) IsSetIa() bool

func (*CheckAndPutResult) IsSetIo Uses

func (p *CheckAndPutResult) IsSetIo() bool

func (*CheckAndPutResult) IsSetSuccess Uses

func (p *CheckAndPutResult) IsSetSuccess() bool

func (*CheckAndPutResult) Read Uses

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

func (*CheckAndPutResult) ReadField0 Uses

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

func (*CheckAndPutResult) ReadField1 Uses

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

func (*CheckAndPutResult) ReadField2 Uses

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

func (*CheckAndPutResult) String Uses

func (p *CheckAndPutResult) String() string

func (*CheckAndPutResult) Write Uses

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

type Client Uses

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

func NewClient Uses

func NewClient(c thrift.TClient) *Client

func NewClientFactory Uses

func NewClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *Client

Deprecated: Use NewHbase instead

func NewClientProtocol Uses

func NewClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *Client

Deprecated: Use NewHbase instead

func (*Client) Append Uses

func (p *Client) Append(ctx context.Context, append *TAppend) (r []*TCell, err error)

Appends values to one or more columns within a single row.

@return values of columns after the append operation.

Parameters:

- Append: The single append operation to apply

func (*Client) AtomicIncrement Uses

func (p *Client) AtomicIncrement(ctx context.Context, tableName []byte, row []byte, column []byte, value int64) (r int64, err error)

Atomically increment the column value specified. Returns the next value post increment.

Parameters:

- TableName: name of table
- Row: row to increment
- Column: name of column
- Value: amount to increment by

func (*Client) CheckAndPut Uses

func (p *Client) CheckAndPut(ctx context.Context, tableName []byte, row []byte, column []byte, value []byte, mput *Mutation, attributes map[string][]byte) (r bool, err error)

Atomically checks if a row/family/qualifier value matches the expected value. If it does, it adds the corresponding mutation operation for put.

@return true if the new put was executed, false otherwise

Parameters:

- TableName: name of table
- Row: row key
- Column: column name
- Value: the expected value for the column parameter, if not

provided the check is for the non-existence of the column in question

- Mput: mutation for the put
- Attributes: Mutation attributes

func (*Client) Compact Uses

func (p *Client) Compact(ctx context.Context, tableNameOrRegionName []byte) (err error)

Parameters:

- TableNameOrRegionName

func (*Client) CreateTable Uses

func (p *Client) CreateTable(ctx context.Context, tableName []byte, columnFamilies []*ColumnDescriptor) (err error)

Create a table with the specified column families. The name field for each ColumnDescriptor must be set and must end in a colon (:). All other fields are optional and will get default values if not explicitly specified.

@throws IllegalArgument if an input parameter is invalid

@throws AlreadyExists if the table name already exists

Parameters:

- TableName: name of table to create
- ColumnFamilies: list of column family descriptors

func (*Client) DeleteAll Uses

func (p *Client) DeleteAll(ctx context.Context, tableName []byte, row []byte, column []byte, attributes map[string][]byte) (err error)

Delete all cells that match the passed row and column.

Parameters:

- TableName: name of table
- Row: Row to update
- Column: name of column whose value is to be deleted
- Attributes: Delete attributes

func (*Client) DeleteAllRow Uses

func (p *Client) DeleteAllRow(ctx context.Context, tableName []byte, row []byte, attributes map[string][]byte) (err error)

Completely delete the row's cells.

Parameters:

- TableName: name of table
- Row: key of the row to be completely deleted.
- Attributes: Delete attributes

func (*Client) DeleteAllRowTs Uses

func (p *Client) DeleteAllRowTs(ctx context.Context, tableName []byte, row []byte, timestamp int64, attributes map[string][]byte) (err error)

Completely delete the row's cells marked with a timestamp equal-to or older than the passed timestamp.

Parameters:

- TableName: name of table
- Row: key of the row to be completely deleted.
- Timestamp: timestamp
- Attributes: Delete attributes

func (*Client) DeleteAllTs Uses

func (p *Client) DeleteAllTs(ctx context.Context, tableName []byte, row []byte, column []byte, timestamp int64, attributes map[string][]byte) (err error)

Delete all cells that match the passed row and column and whose timestamp is equal-to or older than the passed timestamp.

Parameters:

- TableName: name of table
- Row: Row to update
- Column: name of column whose value is to be deleted
- Timestamp: timestamp
- Attributes: Delete attributes

func (*Client) DeleteTable Uses

func (p *Client) DeleteTable(ctx context.Context, tableName []byte) (err error)

Deletes a table

@throws IOError if table doesn't exist on server or there was some other problem

Parameters:

- TableName: name of table to delete

func (*Client) DisableTable Uses

func (p *Client) DisableTable(ctx context.Context, tableName []byte) (err error)

Disables a table (takes it off-line) If it is being served, the master will tell the servers to stop serving it.

Parameters:

- TableName: name of the table

func (*Client) EnableTable Uses

func (p *Client) EnableTable(ctx context.Context, tableName []byte) (err error)

Brings a table on-line (enables it)

Parameters:

- TableName: name of the table

func (*Client) Get Uses

func (p *Client) Get(ctx context.Context, tableName []byte, row []byte, column []byte, attributes map[string][]byte) (r []*TCell, err error)

Get a single TCell for the specified table, row, and column at the latest timestamp. Returns an empty list if no such value exists.

@return value for specified row/column

Parameters:

- TableName: name of table
- Row: row key
- Column: column name
- Attributes: Get attributes

func (*Client) GetColumnDescriptors Uses

func (p *Client) GetColumnDescriptors(ctx context.Context, tableName []byte) (r map[string]*ColumnDescriptor, err error)

List all the column families assoicated with a table.

@return list of column family descriptors

Parameters:

- TableName: table name

func (*Client) GetRegionInfo Uses

func (p *Client) GetRegionInfo(ctx context.Context, row []byte) (r *TRegionInfo, err error)

Get the regininfo for the specified row. It scans the metatable to find region's start and end keys.

@return value for specified row/column

Parameters:

- Row: row key

func (*Client) GetRow Uses

func (p *Client) GetRow(ctx context.Context, tableName []byte, row []byte, attributes map[string][]byte) (r []*TRowResult_, err error)

Get all the data for the specified table and row at the latest timestamp. Returns an empty list if the row does not exist.

@return TRowResult containing the row and map of columns to TCells

Parameters:

- TableName: name of table
- Row: row key
- Attributes: Get attributes

func (*Client) GetRowTs Uses

func (p *Client) GetRowTs(ctx context.Context, tableName []byte, row []byte, timestamp int64, attributes map[string][]byte) (r []*TRowResult_, err error)

Get all the data for the specified table and row at the specified timestamp. Returns an empty list if the row does not exist.

@return TRowResult containing the row and map of columns to TCells

Parameters:

- TableName: name of the table
- Row: row key
- Timestamp: timestamp
- Attributes: Get attributes

func (*Client) GetRowWithColumns Uses

func (p *Client) GetRowWithColumns(ctx context.Context, tableName []byte, row []byte, columns [][]byte, attributes map[string][]byte) (r []*TRowResult_, err error)

Get the specified columns for the specified table and row at the latest timestamp. Returns an empty list if the row does not exist.

@return TRowResult containing the row and map of columns to TCells

Parameters:

- TableName: name of table
- Row: row key
- Columns: List of columns to return, null for all columns
- Attributes: Get attributes

func (*Client) GetRowWithColumnsTs Uses

func (p *Client) GetRowWithColumnsTs(ctx context.Context, tableName []byte, row []byte, columns [][]byte, timestamp int64, attributes map[string][]byte) (r []*TRowResult_, err error)

Get the specified columns for the specified table and row at the specified timestamp. Returns an empty list if the row does not exist.

@return TRowResult containing the row and map of columns to TCells

Parameters:

- TableName: name of table
- Row: row key
- Columns: List of columns to return, null for all columns
- Timestamp
- Attributes: Get attributes

func (*Client) GetRows Uses

func (p *Client) GetRows(ctx context.Context, tableName []byte, rows [][]byte, attributes map[string][]byte) (r []*TRowResult_, err error)

Get all the data for the specified table and rows at the latest timestamp. Returns an empty list if no rows exist.

@return TRowResult containing the rows and map of columns to TCells

Parameters:

- TableName: name of table
- Rows: row keys
- Attributes: Get attributes

func (*Client) GetRowsTs Uses

func (p *Client) GetRowsTs(ctx context.Context, tableName []byte, rows [][]byte, timestamp int64, attributes map[string][]byte) (r []*TRowResult_, err error)

Get all the data for the specified table and rows at the specified timestamp. Returns an empty list if no rows exist.

@return TRowResult containing the rows and map of columns to TCells

Parameters:

- TableName: name of the table
- Rows: row keys
- Timestamp: timestamp
- Attributes: Get attributes

func (*Client) GetRowsWithColumns Uses

func (p *Client) GetRowsWithColumns(ctx context.Context, tableName []byte, rows [][]byte, columns [][]byte, attributes map[string][]byte) (r []*TRowResult_, err error)

Get the specified columns for the specified table and rows at the latest timestamp. Returns an empty list if no rows exist.

@return TRowResult containing the rows and map of columns to TCells

Parameters:

- TableName: name of table
- Rows: row keys
- Columns: List of columns to return, null for all columns
- Attributes: Get attributes

func (*Client) GetRowsWithColumnsTs Uses

func (p *Client) GetRowsWithColumnsTs(ctx context.Context, tableName []byte, rows [][]byte, columns [][]byte, timestamp int64, attributes map[string][]byte) (r []*TRowResult_, err error)

Get the specified columns for the specified table and rows at the specified timestamp. Returns an empty list if no rows exist.

@return TRowResult containing the rows and map of columns to TCells

Parameters:

- TableName: name of table
- Rows: row keys
- Columns: List of columns to return, null for all columns
- Timestamp
- Attributes: Get attributes

func (*Client) GetTableNames Uses

func (p *Client) GetTableNames(ctx context.Context) (r [][]byte, err error)

List all the userspace tables.

@return returns a list of names

func (*Client) GetTableRegions Uses

func (p *Client) GetTableRegions(ctx context.Context, tableName []byte) (r []*TRegionInfo, err error)

List the regions associated with a table.

@return list of region descriptors

Parameters:

- TableName: table name

func (*Client) GetVer Uses

func (p *Client) GetVer(ctx context.Context, tableName []byte, row []byte, column []byte, numVersions int32, attributes map[string][]byte) (r []*TCell, err error)

Get the specified number of versions for the specified table, row, and column.

@return list of cells for specified row/column

Parameters:

- TableName: name of table
- Row: row key
- Column: column name
- NumVersions: number of versions to retrieve
- Attributes: Get attributes

func (*Client) GetVerTs Uses

func (p *Client) GetVerTs(ctx context.Context, tableName []byte, row []byte, column []byte, timestamp int64, numVersions int32, attributes map[string][]byte) (r []*TCell, err error)

Get the specified number of versions for the specified table, row, and column. Only versions less than or equal to the specified timestamp will be returned.

@return list of cells for specified row/column

Parameters:

- TableName: name of table
- Row: row key
- Column: column name
- Timestamp: timestamp
- NumVersions: number of versions to retrieve
- Attributes: Get attributes

func (*Client) Increment Uses

func (p *Client) Increment(ctx context.Context, increment *TIncrement) (err error)

Increment a cell by the ammount. Increments can be applied async if hbase.regionserver.thrift.coalesceIncrement is set to true. False is the default. Turn to true if you need the extra performance and can accept some data loss if a thrift server dies with increments still in the queue.

Parameters:

- Increment: The single increment to apply

func (*Client) IncrementRows Uses

func (p *Client) IncrementRows(ctx context.Context, increments []*TIncrement) (err error)

Parameters:

- Increments: The list of increments

func (*Client) IsTableEnabled Uses

func (p *Client) IsTableEnabled(ctx context.Context, tableName []byte) (r bool, err error)

@return true if table is on-line

Parameters:

- TableName: name of the table to check

func (*Client) MajorCompact Uses

func (p *Client) MajorCompact(ctx context.Context, tableNameOrRegionName []byte) (err error)

Parameters:

- TableNameOrRegionName

func (*Client) MutateRow Uses

func (p *Client) MutateRow(ctx context.Context, tableName []byte, row []byte, mutations []*Mutation, attributes map[string][]byte) (err error)

Apply a series of mutations (updates/deletes) to a row in a single transaction. If an exception is thrown, then the transaction is aborted. Default current timestamp is used, and all entries will have an identical timestamp.

Parameters:

- TableName: name of table
- Row: row key
- Mutations: list of mutation commands
- Attributes: Mutation attributes

func (*Client) MutateRowTs Uses

func (p *Client) MutateRowTs(ctx context.Context, tableName []byte, row []byte, mutations []*Mutation, timestamp int64, attributes map[string][]byte) (err error)

Apply a series of mutations (updates/deletes) to a row in a single transaction. If an exception is thrown, then the transaction is aborted. The specified timestamp is used, and all entries will have an identical timestamp.

Parameters:

- TableName: name of table
- Row: row key
- Mutations: list of mutation commands
- Timestamp: timestamp
- Attributes: Mutation attributes

func (*Client) MutateRows Uses

func (p *Client) MutateRows(ctx context.Context, tableName []byte, rowBatches []*BatchMutation, attributes map[string][]byte) (err error)

Apply a series of batches (each a series of mutations on a single row) in a single transaction. If an exception is thrown, then the transaction is aborted. Default current timestamp is used, and all entries will have an identical timestamp.

Parameters:

- TableName: name of table
- RowBatches: list of row batches
- Attributes: Mutation attributes

func (*Client) MutateRowsTs Uses

func (p *Client) MutateRowsTs(ctx context.Context, tableName []byte, rowBatches []*BatchMutation, timestamp int64, attributes map[string][]byte) (err error)

Apply a series of batches (each a series of mutations on a single row) in a single transaction. If an exception is thrown, then the transaction is aborted. The specified timestamp is used, and all entries will have an identical timestamp.

Parameters:

- TableName: name of table
- RowBatches: list of row batches
- Timestamp: timestamp
- Attributes: Mutation attributes

func (*Client) ScannerClose Uses

func (p *Client) ScannerClose(ctx context.Context, id ScannerID) (err error)

Closes the server-state associated with an open scanner.

@throws IllegalArgument if ScannerID is invalid

Parameters:

- ID: id of a scanner returned by scannerOpen

func (*Client) ScannerGet Uses

func (p *Client) ScannerGet(ctx context.Context, id ScannerID) (r []*TRowResult_, err error)

Returns the scanner's current row value and advances to the next row in the table. When there are no more rows in the table, or a key greater-than-or-equal-to the scanner's specified stopRow is reached, an empty list is returned.

@return a TRowResult containing the current row and a map of the columns to TCells.

@throws IllegalArgument if ScannerID is invalid

@throws NotFound when the scanner reaches the end

Parameters:

- ID: id of a scanner returned by scannerOpen

func (*Client) ScannerGetList Uses

func (p *Client) ScannerGetList(ctx context.Context, id ScannerID, nbRows int32) (r []*TRowResult_, err error)

Returns, starting at the scanner's current row value nbRows worth of rows and advances to the next row in the table. When there are no more rows in the table, or a key greater-than-or-equal-to the scanner's specified stopRow is reached, an empty list is returned.

@return a TRowResult containing the current row and a map of the columns to TCells.

@throws IllegalArgument if ScannerID is invalid

@throws NotFound when the scanner reaches the end

Parameters:

- ID: id of a scanner returned by scannerOpen
- NbRows: number of results to return

func (*Client) ScannerOpen Uses

func (p *Client) ScannerOpen(ctx context.Context, tableName []byte, startRow []byte, columns [][]byte, attributes map[string][]byte) (r ScannerID, err error)

Get a scanner on the current table starting at the specified row and ending at the last row in the table. Return the specified columns.

@return scanner id to be used with other scanner procedures

Parameters:

- TableName: name of table
- StartRow: Starting row in table to scan.

Send "" (empty string) to start at the first row.

- Columns: columns to scan. If column name is a column family, all

columns of the specified column family are returned. It's also possible to pass a regex in the column qualifier.

- Attributes: Scan attributes

func (*Client) ScannerOpenTs Uses

func (p *Client) ScannerOpenTs(ctx context.Context, tableName []byte, startRow []byte, columns [][]byte, timestamp int64, attributes map[string][]byte) (r ScannerID, err error)

Get a scanner on the current table starting at the specified row and ending at the last row in the table. Return the specified columns. Only values with the specified timestamp are returned.

@return scanner id to be used with other scanner procedures

Parameters:

- TableName: name of table
- StartRow: Starting row in table to scan.

Send "" (empty string) to start at the first row.

- Columns: columns to scan. If column name is a column family, all

columns of the specified column family are returned. It's also possible to pass a regex in the column qualifier.

- Timestamp: timestamp
- Attributes: Scan attributes

func (*Client) ScannerOpenWithPrefix Uses

func (p *Client) ScannerOpenWithPrefix(ctx context.Context, tableName []byte, startAndPrefix []byte, columns [][]byte, attributes map[string][]byte) (r ScannerID, err error)

Open a scanner for a given prefix. That is all rows will have the specified prefix. No other rows will be returned.

@return scanner id to use with other scanner calls

Parameters:

- TableName: name of table
- StartAndPrefix: the prefix (and thus start row) of the keys you want
- Columns: the columns you want returned
- Attributes: Scan attributes

func (*Client) ScannerOpenWithScan Uses

func (p *Client) ScannerOpenWithScan(ctx context.Context, tableName []byte, scan *TScan, attributes map[string][]byte) (r ScannerID, err error)

Get a scanner on the current table, using the Scan instance for the scan parameters.

Parameters:

- TableName: name of table
- Scan: Scan instance
- Attributes: Scan attributes

func (*Client) ScannerOpenWithStop Uses

func (p *Client) ScannerOpenWithStop(ctx context.Context, tableName []byte, startRow []byte, stopRow []byte, columns [][]byte, attributes map[string][]byte) (r ScannerID, err error)

Get a scanner on the current table starting and stopping at the specified rows. ending at the last row in the table. Return the specified columns.

@return scanner id to be used with other scanner procedures

Parameters:

- TableName: name of table
- StartRow: Starting row in table to scan.

Send "" (empty string) to start at the first row.

- StopRow: row to stop scanning on. This row is *not* included in the

scanner's results

- Columns: columns to scan. If column name is a column family, all

columns of the specified column family are returned. It's also possible to pass a regex in the column qualifier.

- Attributes: Scan attributes

func (*Client) ScannerOpenWithStopTs Uses

func (p *Client) ScannerOpenWithStopTs(ctx context.Context, tableName []byte, startRow []byte, stopRow []byte, columns [][]byte, timestamp int64, attributes map[string][]byte) (r ScannerID, err error)

Get a scanner on the current table starting and stopping at the specified rows. ending at the last row in the table. Return the specified columns. Only values with the specified timestamp are returned.

@return scanner id to be used with other scanner procedures

Parameters:

- TableName: name of table
- StartRow: Starting row in table to scan.

Send "" (empty string) to start at the first row.

- StopRow: row to stop scanning on. This row is *not* included in the

scanner's results

- Columns: columns to scan. If column name is a column family, all

columns of the specified column family are returned. It's also possible to pass a regex in the column qualifier.

- Timestamp: timestamp
- Attributes: Scan attributes

type ColumnDescriptor Uses

type ColumnDescriptor struct {
    Name                  []byte `thrift:"name,1" db:"name" json:"name"`
    MaxVersions           int32  `thrift:"maxVersions,2" db:"maxVersions" json:"maxVersions"`
    Compression           string `thrift:"compression,3" db:"compression" json:"compression"`
    InMemory              bool   `thrift:"inMemory,4" db:"inMemory" json:"inMemory"`
    BloomFilterType       string `thrift:"bloomFilterType,5" db:"bloomFilterType" json:"bloomFilterType"`
    BloomFilterVectorSize int32  `thrift:"bloomFilterVectorSize,6" db:"bloomFilterVectorSize" json:"bloomFilterVectorSize"`
    BloomFilterNbHashes   int32  `thrift:"bloomFilterNbHashes,7" db:"bloomFilterNbHashes" json:"bloomFilterNbHashes"`
    BlockCacheEnabled     bool   `thrift:"blockCacheEnabled,8" db:"blockCacheEnabled" json:"blockCacheEnabled"`
    TimeToLive            int32  `thrift:"timeToLive,9" db:"timeToLive" json:"timeToLive"`
}

An HColumnDescriptor contains information about a column family such as the number of versions, compression settings, etc. It is used as input when creating a table or adding a column.

Attributes:

- Name
- MaxVersions
- Compression
- InMemory
- BloomFilterType
- BloomFilterVectorSize
- BloomFilterNbHashes
- BlockCacheEnabled
- TimeToLive

func NewColumnDescriptor Uses

func NewColumnDescriptor() *ColumnDescriptor

func (*ColumnDescriptor) Read Uses

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

func (*ColumnDescriptor) ReadField1 Uses

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

func (*ColumnDescriptor) ReadField2 Uses

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

func (*ColumnDescriptor) ReadField3 Uses

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

func (*ColumnDescriptor) ReadField4 Uses

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

func (*ColumnDescriptor) ReadField5 Uses

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

func (*ColumnDescriptor) ReadField6 Uses

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

func (*ColumnDescriptor) ReadField7 Uses

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

func (*ColumnDescriptor) ReadField8 Uses

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

func (*ColumnDescriptor) ReadField9 Uses

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

func (*ColumnDescriptor) String Uses

func (p *ColumnDescriptor) String() string

func (*ColumnDescriptor) Write Uses

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

type CompactArgs Uses

type CompactArgs struct {
    TableNameOrRegionName []byte `thrift:"tableNameOrRegionName,1" db:"tableNameOrRegionName" json:"tableNameOrRegionName"`
}

Attributes:

- TableNameOrRegionName

func NewCompactArgs Uses

func NewCompactArgs() *CompactArgs

func (*CompactArgs) GetTableNameOrRegionName Uses

func (p *CompactArgs) GetTableNameOrRegionName() []byte

func (*CompactArgs) Read Uses

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

func (*CompactArgs) ReadField1 Uses

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

func (*CompactArgs) String Uses

func (p *CompactArgs) String() string

func (*CompactArgs) Write Uses

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

type CompactResult Uses

type CompactResult struct {
    Io *IOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

- Io

func NewCompactResult Uses

func NewCompactResult() *CompactResult

func (*CompactResult) GetIo Uses

func (p *CompactResult) GetIo() *IOError

func (*CompactResult) IsSetIo Uses

func (p *CompactResult) IsSetIo() bool

func (*CompactResult) Read Uses

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

func (*CompactResult) ReadField1 Uses

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

func (*CompactResult) String Uses

func (p *CompactResult) String() string

func (*CompactResult) Write Uses

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

type CreateTableArgs Uses

type CreateTableArgs struct {
    TableName      []byte              `thrift:"tableName,1" db:"tableName" json:"tableName"`
    ColumnFamilies []*ColumnDescriptor `thrift:"columnFamilies,2" db:"columnFamilies" json:"columnFamilies"`
}

Attributes:

- TableName: name of table to create
- ColumnFamilies: list of column family descriptors

func NewCreateTableArgs Uses

func NewCreateTableArgs() *CreateTableArgs

func (*CreateTableArgs) GetColumnFamilies Uses

func (p *CreateTableArgs) GetColumnFamilies() []*ColumnDescriptor

func (*CreateTableArgs) Read Uses

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

func (*CreateTableArgs) ReadField1 Uses

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

func (*CreateTableArgs) ReadField2 Uses

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

func (*CreateTableArgs) String Uses

func (p *CreateTableArgs) String() string

func (*CreateTableArgs) Write Uses

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

type CreateTableResult Uses

type CreateTableResult struct {
    Io    *IOError         `thrift:"io,1" db:"io" json:"io,omitempty"`
    Ia    *IllegalArgument `thrift:"ia,2" db:"ia" json:"ia,omitempty"`
    Exist *AlreadyExists   `thrift:"exist,3" db:"exist" json:"exist,omitempty"`
}

Attributes:

- Io
- Ia
- Exist

func NewCreateTableResult Uses

func NewCreateTableResult() *CreateTableResult

func (*CreateTableResult) GetExist Uses

func (p *CreateTableResult) GetExist() *AlreadyExists

func (*CreateTableResult) GetIa Uses

func (p *CreateTableResult) GetIa() *IllegalArgument

func (*CreateTableResult) GetIo Uses

func (p *CreateTableResult) GetIo() *IOError

func (*CreateTableResult) IsSetExist Uses

func (p *CreateTableResult) IsSetExist() bool

func (*CreateTableResult) IsSetIa Uses

func (p *CreateTableResult) IsSetIa() bool

func (*CreateTableResult) IsSetIo Uses

func (p *CreateTableResult) IsSetIo() bool

func (*CreateTableResult) Read Uses

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

func (*CreateTableResult) ReadField1 Uses

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

func (*CreateTableResult) ReadField2 Uses

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

func (*CreateTableResult) ReadField3 Uses

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

func (*CreateTableResult) String Uses

func (p *CreateTableResult) String() string

func (*CreateTableResult) Write Uses

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

type DeleteAllArgs Uses

type DeleteAllArgs struct {
    TableName  []byte            `thrift:"tableName,1" db:"tableName" json:"tableName"`
    Row        []byte            `thrift:"row,2" db:"row" json:"row"`
    Column     []byte            `thrift:"column,3" db:"column" json:"column"`
    Attributes map[string][]byte `thrift:"attributes,4" db:"attributes" json:"attributes"`
}

Attributes:

- TableName: name of table
- Row: Row to update
- Column: name of column whose value is to be deleted
- Attributes: Delete attributes

func NewDeleteAllArgs Uses

func NewDeleteAllArgs() *DeleteAllArgs

func (*DeleteAllArgs) Read Uses

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

func (*DeleteAllArgs) ReadField1 Uses

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

func (*DeleteAllArgs) ReadField2 Uses

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

func (*DeleteAllArgs) ReadField3 Uses

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

func (*DeleteAllArgs) ReadField4 Uses

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

func (*DeleteAllArgs) String Uses

func (p *DeleteAllArgs) String() string

func (*DeleteAllArgs) Write Uses

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

type DeleteAllResult Uses

type DeleteAllResult struct {
    Io *IOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

- Io

func NewDeleteAllResult Uses

func NewDeleteAllResult() *DeleteAllResult

func (*DeleteAllResult) GetIo Uses

func (p *DeleteAllResult) GetIo() *IOError

func (*DeleteAllResult) IsSetIo Uses

func (p *DeleteAllResult) IsSetIo() bool

func (*DeleteAllResult) Read Uses

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

func (*DeleteAllResult) ReadField1 Uses

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

func (*DeleteAllResult) String Uses

func (p *DeleteAllResult) String() string

func (*DeleteAllResult) Write Uses

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

type DeleteAllRowArgs Uses

type DeleteAllRowArgs struct {
    TableName  []byte            `thrift:"tableName,1" db:"tableName" json:"tableName"`
    Row        []byte            `thrift:"row,2" db:"row" json:"row"`
    Attributes map[string][]byte `thrift:"attributes,3" db:"attributes" json:"attributes"`
}

Attributes:

- TableName: name of table
- Row: key of the row to be completely deleted.
- Attributes: Delete attributes

func NewDeleteAllRowArgs Uses

func NewDeleteAllRowArgs() *DeleteAllRowArgs

func (*DeleteAllRowArgs) Read Uses

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

func (*DeleteAllRowArgs) ReadField1 Uses

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

func (*DeleteAllRowArgs) ReadField2 Uses

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

func (*DeleteAllRowArgs) ReadField3 Uses

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

func (*DeleteAllRowArgs) String Uses

func (p *DeleteAllRowArgs) String() string

func (*DeleteAllRowArgs) Write Uses

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

type DeleteAllRowResult Uses

type DeleteAllRowResult struct {
    Io *IOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

- Io

func NewDeleteAllRowResult Uses

func NewDeleteAllRowResult() *DeleteAllRowResult

func (*DeleteAllRowResult) GetIo Uses

func (p *DeleteAllRowResult) GetIo() *IOError

func (*DeleteAllRowResult) IsSetIo Uses

func (p *DeleteAllRowResult) IsSetIo() bool

func (*DeleteAllRowResult) Read Uses

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

func (*DeleteAllRowResult) ReadField1 Uses

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

func (*DeleteAllRowResult) String Uses

func (p *DeleteAllRowResult) String() string

func (*DeleteAllRowResult) Write Uses

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

type DeleteAllRowTsArgs Uses

type DeleteAllRowTsArgs struct {
    TableName  []byte            `thrift:"tableName,1" db:"tableName" json:"tableName"`
    Row        []byte            `thrift:"row,2" db:"row" json:"row"`
    Timestamp  int64             `thrift:"timestamp,3" db:"timestamp" json:"timestamp"`
    Attributes map[string][]byte `thrift:"attributes,4" db:"attributes" json:"attributes"`
}

Attributes:

- TableName: name of table
- Row: key of the row to be completely deleted.
- Timestamp: timestamp
- Attributes: Delete attributes

func NewDeleteAllRowTsArgs Uses

func NewDeleteAllRowTsArgs() *DeleteAllRowTsArgs

func (*DeleteAllRowTsArgs) Read Uses

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

func (*DeleteAllRowTsArgs) ReadField1 Uses

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

func (*DeleteAllRowTsArgs) ReadField2 Uses

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

func (*DeleteAllRowTsArgs) ReadField3 Uses

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

func (*DeleteAllRowTsArgs) ReadField4 Uses

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

func (*DeleteAllRowTsArgs) String Uses

func (p *DeleteAllRowTsArgs) String() string

func (*DeleteAllRowTsArgs) Write Uses

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

type DeleteAllRowTsResult Uses

type DeleteAllRowTsResult struct {
    Io *IOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

- Io

func NewDeleteAllRowTsResult Uses

func NewDeleteAllRowTsResult() *DeleteAllRowTsResult

func (*DeleteAllRowTsResult) GetIo Uses

func (p *DeleteAllRowTsResult) GetIo() *IOError

func (*DeleteAllRowTsResult) IsSetIo Uses

func (p *DeleteAllRowTsResult) IsSetIo() bool

func (*DeleteAllRowTsResult) Read Uses

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

func (*DeleteAllRowTsResult) ReadField1 Uses

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

func (*DeleteAllRowTsResult) String Uses

func (p *DeleteAllRowTsResult) String() string

func (*DeleteAllRowTsResult) Write Uses

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

type DeleteAllTsArgs Uses

type DeleteAllTsArgs struct {
    TableName  []byte            `thrift:"tableName,1" db:"tableName" json:"tableName"`
    Row        []byte            `thrift:"row,2" db:"row" json:"row"`
    Column     []byte            `thrift:"column,3" db:"column" json:"column"`
    Timestamp  int64             `thrift:"timestamp,4" db:"timestamp" json:"timestamp"`
    Attributes map[string][]byte `thrift:"attributes,5" db:"attributes" json:"attributes"`
}

Attributes:

- TableName: name of table
- Row: Row to update
- Column: name of column whose value is to be deleted
- Timestamp: timestamp
- Attributes: Delete attributes

func NewDeleteAllTsArgs Uses

func NewDeleteAllTsArgs() *DeleteAllTsArgs

func (*DeleteAllTsArgs) Read Uses

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

func (*DeleteAllTsArgs) ReadField1 Uses

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

func (*DeleteAllTsArgs) ReadField2 Uses

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

func (*DeleteAllTsArgs) ReadField3 Uses

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

func (*DeleteAllTsArgs) ReadField4 Uses

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

func (*DeleteAllTsArgs) ReadField5 Uses

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

func (*DeleteAllTsArgs) String Uses

func (p *DeleteAllTsArgs) String() string

func (*DeleteAllTsArgs) Write Uses

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

type DeleteAllTsResult Uses

type DeleteAllTsResult struct {
    Io *IOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

- Io

func NewDeleteAllTsResult Uses

func NewDeleteAllTsResult() *DeleteAllTsResult

func (*DeleteAllTsResult) GetIo Uses

func (p *DeleteAllTsResult) GetIo() *IOError

func (*DeleteAllTsResult) IsSetIo Uses

func (p *DeleteAllTsResult) IsSetIo() bool

func (*DeleteAllTsResult) Read Uses

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

func (*DeleteAllTsResult) ReadField1 Uses

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

func (*DeleteAllTsResult) String Uses

func (p *DeleteAllTsResult) String() string

func (*DeleteAllTsResult) Write Uses

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

type DeleteTableArgs Uses

type DeleteTableArgs struct {
    TableName []byte `thrift:"tableName,1" db:"tableName" json:"tableName"`
}

Attributes:

- TableName: name of table to delete

func NewDeleteTableArgs Uses

func NewDeleteTableArgs() *DeleteTableArgs

func (*DeleteTableArgs) Read Uses

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

func (*DeleteTableArgs) ReadField1 Uses

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

func (*DeleteTableArgs) String Uses

func (p *DeleteTableArgs) String() string

func (*DeleteTableArgs) Write Uses

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

type DeleteTableResult Uses

type DeleteTableResult struct {
    Io *IOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

- Io

func NewDeleteTableResult Uses

func NewDeleteTableResult() *DeleteTableResult

func (*DeleteTableResult) GetIo Uses

func (p *DeleteTableResult) GetIo() *IOError

func (*DeleteTableResult) IsSetIo Uses

func (p *DeleteTableResult) IsSetIo() bool

func (*DeleteTableResult) Read Uses

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

func (*DeleteTableResult) ReadField1 Uses

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

func (*DeleteTableResult) String Uses

func (p *DeleteTableResult) String() string

func (*DeleteTableResult) Write Uses

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

type DisableTableArgs Uses

type DisableTableArgs struct {
    TableName []byte `thrift:"tableName,1" db:"tableName" json:"tableName"`
}

Attributes:

- TableName: name of the table

func NewDisableTableArgs Uses

func NewDisableTableArgs() *DisableTableArgs

func (*DisableTableArgs) Read Uses

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

func (*DisableTableArgs) ReadField1 Uses

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

func (*DisableTableArgs) String Uses

func (p *DisableTableArgs) String() string

func (*DisableTableArgs) Write Uses

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

type DisableTableResult Uses

type DisableTableResult struct {
    Io *IOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

- Io

func NewDisableTableResult Uses

func NewDisableTableResult() *DisableTableResult

func (*DisableTableResult) GetIo Uses

func (p *DisableTableResult) GetIo() *IOError

func (*DisableTableResult) IsSetIo Uses

func (p *DisableTableResult) IsSetIo() bool

func (*DisableTableResult) Read Uses

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

func (*DisableTableResult) ReadField1 Uses

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

func (*DisableTableResult) String Uses

func (p *DisableTableResult) String() string

func (*DisableTableResult) Write Uses

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

type EnableTableArgs Uses

type EnableTableArgs struct {
    TableName []byte `thrift:"tableName,1" db:"tableName" json:"tableName"`
}

Attributes:

- TableName: name of the table

func NewEnableTableArgs Uses

func NewEnableTableArgs() *EnableTableArgs

func (*EnableTableArgs) Read Uses

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

func (*EnableTableArgs) ReadField1 Uses

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

func (*EnableTableArgs) String Uses

func (p *EnableTableArgs) String() string

func (*EnableTableArgs) Write Uses

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

type EnableTableResult Uses

type EnableTableResult struct {
    Io *IOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

- Io

func NewEnableTableResult Uses

func NewEnableTableResult() *EnableTableResult

func (*EnableTableResult) GetIo Uses

func (p *EnableTableResult) GetIo() *IOError

func (*EnableTableResult) IsSetIo Uses

func (p *EnableTableResult) IsSetIo() bool

func (*EnableTableResult) Read Uses

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

func (*EnableTableResult) ReadField1 Uses

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

func (*EnableTableResult) String Uses

func (p *EnableTableResult) String() string

func (*EnableTableResult) Write Uses

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

type GetArgs Uses

type GetArgs struct {
    TableName  []byte            `thrift:"tableName,1" db:"tableName" json:"tableName"`
    Row        []byte            `thrift:"row,2" db:"row" json:"row"`
    Column     []byte            `thrift:"column,3" db:"column" json:"column"`
    Attributes map[string][]byte `thrift:"attributes,4" db:"attributes" json:"attributes"`
}

Attributes:

- TableName: name of table
- Row: row key
- Column: column name
- Attributes: Get attributes

func NewGetArgs Uses

func NewGetArgs() *GetArgs

func (*GetArgs) Read Uses

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

func (*GetArgs) ReadField1 Uses

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

func (*GetArgs) ReadField2 Uses

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

func (*GetArgs) ReadField3 Uses

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

func (*GetArgs) ReadField4 Uses

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

func (*GetArgs) String Uses

func (p *GetArgs) String() string

func (*GetArgs) Write Uses

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

type GetColumnDescriptorsArgs Uses

type GetColumnDescriptorsArgs struct {
    TableName []byte `thrift:"tableName,1" db:"tableName" json:"tableName"`
}

Attributes:

- TableName: table name

func NewGetColumnDescriptorsArgs Uses

func NewGetColumnDescriptorsArgs() *GetColumnDescriptorsArgs

func (*GetColumnDescriptorsArgs) Read Uses

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

func (*GetColumnDescriptorsArgs) ReadField1 Uses

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

func (*GetColumnDescriptorsArgs) String Uses

func (p *GetColumnDescriptorsArgs) String() string

func (*GetColumnDescriptorsArgs) Write Uses

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

type GetColumnDescriptorsResult Uses

type GetColumnDescriptorsResult struct {
    Success map[string]*ColumnDescriptor `thrift:"success,0" db:"success" json:"success,omitempty"`
    Io      *IOError                     `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

- Success
- Io

func NewGetColumnDescriptorsResult Uses

func NewGetColumnDescriptorsResult() *GetColumnDescriptorsResult

func (*GetColumnDescriptorsResult) GetIo Uses

func (p *GetColumnDescriptorsResult) GetIo() *IOError

func (*GetColumnDescriptorsResult) GetSuccess Uses

func (p *GetColumnDescriptorsResult) GetSuccess() map[string]*ColumnDescriptor

func (*GetColumnDescriptorsResult) IsSetIo Uses

func (p *GetColumnDescriptorsResult) IsSetIo() bool

func (*GetColumnDescriptorsResult) IsSetSuccess Uses

func (p *GetColumnDescriptorsResult) IsSetSuccess() bool

func (*GetColumnDescriptorsResult) Read Uses

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

func (*GetColumnDescriptorsResult) ReadField0 Uses

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

func (*GetColumnDescriptorsResult) ReadField1 Uses

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

func (*GetColumnDescriptorsResult) String Uses

func (p *GetColumnDescriptorsResult) String() string

func (*GetColumnDescriptorsResult) Write Uses

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

type GetRegionInfoArgs Uses

type GetRegionInfoArgs struct {
    Row []byte `thrift:"row,1" db:"row" json:"row"`
}

Attributes:

- Row: row key

func NewGetRegionInfoArgs Uses

func NewGetRegionInfoArgs() *GetRegionInfoArgs

func (*GetRegionInfoArgs) Read Uses

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

func (*GetRegionInfoArgs) ReadField1 Uses

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

func (*GetRegionInfoArgs) String Uses

func (p *GetRegionInfoArgs) String() string

func (*GetRegionInfoArgs) Write Uses

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

type GetRegionInfoResult Uses

type GetRegionInfoResult struct {
    Success *TRegionInfo `thrift:"success,0" db:"success" json:"success,omitempty"`
    Io      *IOError     `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

- Success
- Io

func NewGetRegionInfoResult Uses

func NewGetRegionInfoResult() *GetRegionInfoResult

func (*GetRegionInfoResult) GetIo Uses

func (p *GetRegionInfoResult) GetIo() *IOError

func (*GetRegionInfoResult) GetSuccess Uses

func (p *GetRegionInfoResult) GetSuccess() *TRegionInfo

func (*GetRegionInfoResult) IsSetIo Uses

func (p *GetRegionInfoResult) IsSetIo() bool

func (*GetRegionInfoResult) IsSetSuccess Uses

func (p *GetRegionInfoResult) IsSetSuccess() bool

func (*GetRegionInfoResult) Read Uses

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

func (*GetRegionInfoResult) ReadField0 Uses

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

func (*GetRegionInfoResult) ReadField1 Uses

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

func (*GetRegionInfoResult) String Uses

func (p *GetRegionInfoResult) String() string

func (*GetRegionInfoResult) Write Uses

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

type GetResult Uses

type GetResult struct {
    Success []*TCell `thrift:"success,0" db:"success" json:"success,omitempty"`
    Io      *IOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

- Success
- Io

func NewGetResult Uses

func NewGetResult() *GetResult

func (*GetResult) GetIo Uses

func (p *GetResult) GetIo() *IOError

func (*GetResult) GetSuccess Uses

func (p *GetResult) GetSuccess() []*TCell

func (*GetResult) IsSetIo Uses

func (p *GetResult) IsSetIo() bool

func (*GetResult) IsSetSuccess Uses

func (p *GetResult) IsSetSuccess() bool

func (*GetResult) Read Uses

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

func (*GetResult) ReadField0 Uses

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

func (*GetResult) ReadField1 Uses

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

func (*GetResult) String Uses

func (p *GetResult) String() string

func (*GetResult) Write Uses

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

type GetRowArgs Uses

type GetRowArgs struct {
    TableName  []byte            `thrift:"tableName,1" db:"tableName" json:"tableName"`
    Row        []byte            `thrift:"row,2" db:"row" json:"row"`
    Attributes map[string][]byte `thrift:"attributes,3" db:"attributes" json:"attributes"`
}

Attributes:

- TableName: name of table
- Row: row key
- Attributes: Get attributes

func NewGetRowArgs Uses

func NewGetRowArgs() *GetRowArgs

func (*GetRowArgs) Read Uses

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

func (*GetRowArgs) ReadField1 Uses

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

func (*GetRowArgs) ReadField2 Uses

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

func (*GetRowArgs) ReadField3 Uses

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

func (*GetRowArgs) String Uses

func (p *GetRowArgs) String() string

func (*GetRowArgs) Write Uses

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

type GetRowResult Uses

type GetRowResult struct {
    Success []*TRowResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
    Io      *IOError       `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

- Success
- Io

func NewGetRowResult Uses

func NewGetRowResult() *GetRowResult

func (*GetRowResult) GetIo Uses

func (p *GetRowResult) GetIo() *IOError

func (*GetRowResult) GetSuccess Uses

func (p *GetRowResult) GetSuccess() []*TRowResult_

func (*GetRowResult) IsSetIo Uses

func (p *GetRowResult) IsSetIo() bool

func (*GetRowResult) IsSetSuccess Uses

func (p *GetRowResult) IsSetSuccess() bool

func (*GetRowResult) Read Uses

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

func (*GetRowResult) ReadField0 Uses

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

func (*GetRowResult) ReadField1 Uses

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

func (*GetRowResult) String Uses

func (p *GetRowResult) String() string

func (*GetRowResult) Write Uses

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

type GetRowTsArgs Uses

type GetRowTsArgs struct {
    TableName  []byte            `thrift:"tableName,1" db:"tableName" json:"tableName"`
    Row        []byte            `thrift:"row,2" db:"row" json:"row"`
    Timestamp  int64             `thrift:"timestamp,3" db:"timestamp" json:"timestamp"`
    Attributes map[string][]byte `thrift:"attributes,4" db:"attributes" json:"attributes"`
}

Attributes:

- TableName: name of the table
- Row: row key
- Timestamp: timestamp
- Attributes: Get attributes

func NewGetRowTsArgs Uses

func NewGetRowTsArgs() *GetRowTsArgs

func (*GetRowTsArgs) Read Uses

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

func (*GetRowTsArgs) ReadField1 Uses

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

func (*GetRowTsArgs) ReadField2 Uses

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

func (*GetRowTsArgs) ReadField3 Uses

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

func (*GetRowTsArgs) ReadField4 Uses

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

func (*GetRowTsArgs) String Uses

func (p *GetRowTsArgs) String() string

func (*GetRowTsArgs) Write Uses

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

type GetRowTsResult Uses

type GetRowTsResult struct {
    Success []*TRowResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
    Io      *IOError       `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

- Success
- Io

func NewGetRowTsResult Uses

func NewGetRowTsResult() *GetRowTsResult

func (*GetRowTsResult) GetIo Uses

func (p *GetRowTsResult) GetIo() *IOError

func (*GetRowTsResult) GetSuccess Uses

func (p *GetRowTsResult) GetSuccess() []*TRowResult_

func (*GetRowTsResult) IsSetIo Uses

func (p *GetRowTsResult) IsSetIo() bool

func (*GetRowTsResult) IsSetSuccess Uses

func (p *GetRowTsResult) IsSetSuccess() bool

func (*GetRowTsResult) Read Uses

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

func (*GetRowTsResult) ReadField0 Uses

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

func (*GetRowTsResult) ReadField1 Uses

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

func (*GetRowTsResult) String Uses

func (p *GetRowTsResult) String() string

func (*GetRowTsResult) Write Uses

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

type GetRowWithColumnsArgs Uses

type GetRowWithColumnsArgs struct {
    TableName  []byte            `thrift:"tableName,1" db:"tableName" json:"tableName"`
    Row        []byte            `thrift:"row,2" db:"row" json:"row"`
    Columns    [][]byte          `thrift:"columns,3" db:"columns" json:"columns"`
    Attributes map[string][]byte `thrift:"attributes,4" db:"attributes" json:"attributes"`
}

Attributes:

- TableName: name of table
- Row: row key
- Columns: List of columns to return, null for all columns
- Attributes: Get attributes

func NewGetRowWithColumnsArgs Uses

func NewGetRowWithColumnsArgs() *GetRowWithColumnsArgs

func (*GetRowWithColumnsArgs) Read Uses

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

func (*GetRowWithColumnsArgs) ReadField1 Uses

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

func (*GetRowWithColumnsArgs) ReadField2 Uses

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

func (*GetRowWithColumnsArgs) ReadField3 Uses

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

func (*GetRowWithColumnsArgs) ReadField4 Uses

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

func (*GetRowWithColumnsArgs) String Uses

func (p *GetRowWithColumnsArgs) String() string

func (*GetRowWithColumnsArgs) Write Uses

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

type GetRowWithColumnsResult Uses

type GetRowWithColumnsResult struct {
    Success []*TRowResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
    Io      *IOError       `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

- Success
- Io

func NewGetRowWithColumnsResult Uses

func NewGetRowWithColumnsResult() *GetRowWithColumnsResult

func (*GetRowWithColumnsResult) GetIo Uses

func (p *GetRowWithColumnsResult) GetIo() *IOError

func (*GetRowWithColumnsResult) GetSuccess Uses

func (p *GetRowWithColumnsResult) GetSuccess() []*TRowResult_

func (*GetRowWithColumnsResult) IsSetIo Uses

func (p *GetRowWithColumnsResult) IsSetIo() bool

func (*GetRowWithColumnsResult) IsSetSuccess Uses

func (p *GetRowWithColumnsResult) IsSetSuccess() bool

func (*GetRowWithColumnsResult) Read Uses

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

func (*GetRowWithColumnsResult) ReadField0 Uses

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

func (*GetRowWithColumnsResult) ReadField1 Uses

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

func (*GetRowWithColumnsResult) String Uses

func (p *GetRowWithColumnsResult) String() string

func (*GetRowWithColumnsResult) Write Uses

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

type GetRowWithColumnsTsArgs Uses

type GetRowWithColumnsTsArgs struct {
    TableName  []byte            `thrift:"tableName,1" db:"tableName" json:"tableName"`
    Row        []byte            `thrift:"row,2" db:"row" json:"row"`
    Columns    [][]byte          `thrift:"columns,3" db:"columns" json:"columns"`
    Timestamp  int64             `thrift:"timestamp,4" db:"timestamp" json:"timestamp"`
    Attributes map[string][]byte `thrift:"attributes,5" db:"attributes" json:"attributes"`
}

Attributes:

- TableName: name of table
- Row: row key
- Columns: List of columns to return, null for all columns
- Timestamp
- Attributes: Get attributes

func NewGetRowWithColumnsTsArgs Uses

func NewGetRowWithColumnsTsArgs() *GetRowWithColumnsTsArgs

func (*GetRowWithColumnsTsArgs) Read Uses

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

func (*GetRowWithColumnsTsArgs) ReadField1 Uses

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

func (*GetRowWithColumnsTsArgs) ReadField2 Uses

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

func (*GetRowWithColumnsTsArgs) ReadField3 Uses

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

func (*GetRowWithColumnsTsArgs) ReadField4 Uses

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

func (*GetRowWithColumnsTsArgs) ReadField5 Uses

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

func (*GetRowWithColumnsTsArgs) String Uses

func (p *GetRowWithColumnsTsArgs) String() string

func (*GetRowWithColumnsTsArgs) Write Uses

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

type GetRowWithColumnsTsResult Uses

type GetRowWithColumnsTsResult struct {
    Success []*TRowResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
    Io      *IOError       `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

- Success
- Io

func NewGetRowWithColumnsTsResult Uses

func NewGetRowWithColumnsTsResult() *GetRowWithColumnsTsResult

func (*GetRowWithColumnsTsResult) GetIo Uses

func (p *GetRowWithColumnsTsResult) GetIo() *IOError

func (*GetRowWithColumnsTsResult) GetSuccess Uses

func (p *GetRowWithColumnsTsResult) GetSuccess() []*TRowResult_

func (*GetRowWithColumnsTsResult) IsSetIo Uses

func (p *GetRowWithColumnsTsResult) IsSetIo() bool

func (*GetRowWithColumnsTsResult) IsSetSuccess Uses

func (p *GetRowWithColumnsTsResult) IsSetSuccess() bool

func (*GetRowWithColumnsTsResult) Read Uses

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

func (*GetRowWithColumnsTsResult) ReadField0 Uses

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

func (*GetRowWithColumnsTsResult) ReadField1 Uses

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

func (*GetRowWithColumnsTsResult) String Uses

func (p *GetRowWithColumnsTsResult) String() string

func (*GetRowWithColumnsTsResult) Write Uses

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

type GetRowsArgs Uses

type GetRowsArgs struct {
    TableName  []byte            `thrift:"tableName,1" db:"tableName" json:"tableName"`
    Rows       [][]byte          `thrift:"rows,2" db:"rows" json:"rows"`
    Attributes map[string][]byte `thrift:"attributes,3" db:"attributes" json:"attributes"`
}

Attributes:

- TableName: name of table
- Rows: row keys
- Attributes: Get attributes

func NewGetRowsArgs Uses

func NewGetRowsArgs() *GetRowsArgs

func (*GetRowsArgs) Read Uses

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

func (*GetRowsArgs) ReadField1 Uses

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

func (*GetRowsArgs) ReadField2 Uses

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

func (*GetRowsArgs) ReadField3 Uses

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

func (*GetRowsArgs) String Uses

func (p *GetRowsArgs) String() string

func (*GetRowsArgs) Write Uses

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

type GetRowsResult Uses

type GetRowsResult struct {
    Success []*TRowResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
    Io      *IOError       `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

- Success
- Io

func NewGetRowsResult Uses

func NewGetRowsResult() *GetRowsResult

func (*GetRowsResult) GetIo Uses

func (p *GetRowsResult) GetIo() *IOError

func (*GetRowsResult) GetSuccess Uses

func (p *GetRowsResult) GetSuccess() []*TRowResult_

func (*GetRowsResult) IsSetIo Uses

func (p *GetRowsResult) IsSetIo() bool

func (*GetRowsResult) IsSetSuccess Uses

func (p *GetRowsResult) IsSetSuccess() bool

func (*GetRowsResult) Read Uses

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

func (*GetRowsResult) ReadField0 Uses

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

func (*GetRowsResult) ReadField1 Uses

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

func (*GetRowsResult) String Uses

func (p *GetRowsResult) String() string

func (*GetRowsResult) Write Uses

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

type GetRowsTsArgs Uses

type GetRowsTsArgs struct {
    TableName  []byte            `thrift:"tableName,1" db:"tableName" json:"tableName"`
    Rows       [][]byte          `thrift:"rows,2" db:"rows" json:"rows"`
    Timestamp  int64             `thrift:"timestamp,3" db:"timestamp" json:"timestamp"`
    Attributes map[string][]byte `thrift:"attributes,4" db:"attributes" json:"attributes"`
}

Attributes:

- TableName: name of the table
- Rows: row keys
- Timestamp: timestamp
- Attributes: Get attributes

func NewGetRowsTsArgs Uses

func NewGetRowsTsArgs() *GetRowsTsArgs

func (*GetRowsTsArgs) Read Uses

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

func (*GetRowsTsArgs) ReadField1 Uses

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

func (*GetRowsTsArgs) ReadField2 Uses

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

func (*GetRowsTsArgs) ReadField3 Uses

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

func (*GetRowsTsArgs) ReadField4 Uses

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

func (*GetRowsTsArgs) String Uses

func (p *GetRowsTsArgs) String() string

func (*GetRowsTsArgs) Write Uses

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

type GetRowsTsResult Uses

type GetRowsTsResult struct {
    Success []*TRowResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
    Io      *IOError       `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

- Success
- Io

func NewGetRowsTsResult Uses

func NewGetRowsTsResult() *GetRowsTsResult

func (*GetRowsTsResult) GetIo Uses

func (p *GetRowsTsResult) GetIo() *IOError

func (*GetRowsTsResult) GetSuccess Uses

func (p *GetRowsTsResult) GetSuccess() []*TRowResult_

func (*GetRowsTsResult) IsSetIo Uses

func (p *GetRowsTsResult) IsSetIo() bool

func (*GetRowsTsResult) IsSetSuccess Uses

func (p *GetRowsTsResult) IsSetSuccess() bool

func (*GetRowsTsResult) Read Uses

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

func (*GetRowsTsResult) ReadField0 Uses

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

func (*GetRowsTsResult) ReadField1 Uses

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

func (*GetRowsTsResult) String Uses

func (p *GetRowsTsResult) String() string

func (*GetRowsTsResult) Write Uses

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

type GetRowsWithColumnsArgs Uses

type GetRowsWithColumnsArgs struct {
    TableName  []byte            `thrift:"tableName,1" db:"tableName" json:"tableName"`
    Rows       [][]byte          `thrift:"rows,2" db:"rows" json:"rows"`
    Columns    [][]byte          `thrift:"columns,3" db:"columns" json:"columns"`
    Attributes map[string][]byte `thrift:"attributes,4" db:"attributes" json:"attributes"`
}

Attributes:

- TableName: name of table
- Rows: row keys
- Columns: List of columns to return, null for all columns
- Attributes: Get attributes

func NewGetRowsWithColumnsArgs Uses

func NewGetRowsWithColumnsArgs() *GetRowsWithColumnsArgs

func (*GetRowsWithColumnsArgs) Read Uses

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

func (*GetRowsWithColumnsArgs) ReadField1 Uses

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

func (*GetRowsWithColumnsArgs) ReadField2 Uses

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

func (*GetRowsWithColumnsArgs) ReadField3 Uses

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

func (*GetRowsWithColumnsArgs) ReadField4 Uses

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

func (*GetRowsWithColumnsArgs) String Uses

func (p *GetRowsWithColumnsArgs) String() string

func (*GetRowsWithColumnsArgs) Write Uses

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

type GetRowsWithColumnsResult Uses

type GetRowsWithColumnsResult struct {
    Success []*TRowResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
    Io      *IOError       `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

- Success
- Io

func NewGetRowsWithColumnsResult Uses

func NewGetRowsWithColumnsResult() *GetRowsWithColumnsResult

func (*GetRowsWithColumnsResult) GetIo Uses

func (p *GetRowsWithColumnsResult) GetIo() *IOError

func (*GetRowsWithColumnsResult) GetSuccess Uses

func (p *GetRowsWithColumnsResult) GetSuccess() []*TRowResult_

func (*GetRowsWithColumnsResult) IsSetIo Uses

func (p *GetRowsWithColumnsResult) IsSetIo() bool

func (*GetRowsWithColumnsResult) IsSetSuccess Uses

func (p *GetRowsWithColumnsResult) IsSetSuccess() bool

func (*GetRowsWithColumnsResult) Read Uses

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

func (*GetRowsWithColumnsResult) ReadField0 Uses

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

func (*GetRowsWithColumnsResult) ReadField1 Uses

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

func (*GetRowsWithColumnsResult) String Uses

func (p *GetRowsWithColumnsResult) String() string

func (*GetRowsWithColumnsResult) Write Uses

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

type GetRowsWithColumnsTsArgs Uses

type GetRowsWithColumnsTsArgs struct {
    TableName  []byte            `thrift:"tableName,1" db:"tableName" json:"tableName"`
    Rows       [][]byte          `thrift:"rows,2" db:"rows" json:"rows"`
    Columns    [][]byte          `thrift:"columns,3" db:"columns" json:"columns"`
    Timestamp  int64             `thrift:"timestamp,4" db:"timestamp" json:"timestamp"`
    Attributes map[string][]byte `thrift:"attributes,5" db:"attributes" json:"attributes"`
}

Attributes:

- TableName: name of table
- Rows: row keys
- Columns: List of columns to return, null for all columns
- Timestamp
- Attributes: Get attributes

func NewGetRowsWithColumnsTsArgs Uses

func NewGetRowsWithColumnsTsArgs() *GetRowsWithColumnsTsArgs

func (*GetRowsWithColumnsTsArgs) Read Uses

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

func (*GetRowsWithColumnsTsArgs) ReadField1 Uses

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

func (*GetRowsWithColumnsTsArgs) ReadField2 Uses

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

func (*GetRowsWithColumnsTsArgs) ReadField3 Uses

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

func (*GetRowsWithColumnsTsArgs) ReadField4 Uses

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

func (*GetRowsWithColumnsTsArgs) ReadField5 Uses

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

func (*GetRowsWithColumnsTsArgs) String Uses

func (p *GetRowsWithColumnsTsArgs) String() string

func (*GetRowsWithColumnsTsArgs) Write Uses

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

type GetRowsWithColumnsTsResult Uses

type GetRowsWithColumnsTsResult struct {
    Success []*TRowResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
    Io      *IOError       `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

- Success
- Io

func NewGetRowsWithColumnsTsResult Uses

func NewGetRowsWithColumnsTsResult() *GetRowsWithColumnsTsResult

func (*GetRowsWithColumnsTsResult) GetIo Uses

func (p *GetRowsWithColumnsTsResult) GetIo() *IOError

func (*GetRowsWithColumnsTsResult) GetSuccess Uses

func (p *GetRowsWithColumnsTsResult) GetSuccess() []*TRowResult_

func (*GetRowsWithColumnsTsResult) IsSetIo Uses

func (p *GetRowsWithColumnsTsResult) IsSetIo() bool

func (*GetRowsWithColumnsTsResult) IsSetSuccess Uses

func (p *GetRowsWithColumnsTsResult) IsSetSuccess() bool

func (*GetRowsWithColumnsTsResult) Read Uses

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

func (*GetRowsWithColumnsTsResult) ReadField0 Uses

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

func (*GetRowsWithColumnsTsResult) ReadField1 Uses

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

func (*GetRowsWithColumnsTsResult) String Uses

func (p *GetRowsWithColumnsTsResult) String() string

func (*GetRowsWithColumnsTsResult) Write Uses

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

type GetTableNamesArgs Uses

type GetTableNamesArgs struct {
}

func NewGetTableNamesArgs Uses

func NewGetTableNamesArgs() *GetTableNamesArgs

func (*GetTableNamesArgs) Read Uses

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

func (*GetTableNamesArgs) String Uses

func (p *GetTableNamesArgs) String() string

func (*GetTableNamesArgs) Write Uses

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

type GetTableNamesResult Uses

type GetTableNamesResult struct {
    Success [][]byte `thrift:"success,0" db:"success" json:"success,omitempty"`
    Io      *IOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

- Success
- Io

func NewGetTableNamesResult Uses

func NewGetTableNamesResult() *GetTableNamesResult

func (*GetTableNamesResult) GetIo Uses

func (p *GetTableNamesResult) GetIo() *IOError

func (*GetTableNamesResult) GetSuccess Uses

func (p *GetTableNamesResult) GetSuccess() [][]byte

func (*GetTableNamesResult) IsSetIo Uses

func (p *GetTableNamesResult) IsSetIo() bool

func (*GetTableNamesResult) IsSetSuccess Uses

func (p *GetTableNamesResult) IsSetSuccess() bool

func (*GetTableNamesResult) Read Uses

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

func (*GetTableNamesResult) ReadField0 Uses

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

func (*GetTableNamesResult) ReadField1 Uses

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

func (*GetTableNamesResult) String Uses

func (p *GetTableNamesResult) String() string

func (*GetTableNamesResult) Write Uses

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

type GetTableRegionsArgs Uses

type GetTableRegionsArgs struct {
    TableName []byte `thrift:"tableName,1" db:"tableName" json:"tableName"`
}

Attributes:

- TableName: table name

func NewGetTableRegionsArgs Uses

func NewGetTableRegionsArgs() *GetTableRegionsArgs

func (*GetTableRegionsArgs) Read Uses

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

func (*GetTableRegionsArgs) ReadField1 Uses

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

func (*GetTableRegionsArgs) String Uses

func (p *GetTableRegionsArgs) String() string

func (*GetTableRegionsArgs) Write Uses

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

type GetTableRegionsResult Uses

type GetTableRegionsResult struct {
    Success []*TRegionInfo `thrift:"success,0" db:"success" json:"success,omitempty"`
    Io      *IOError       `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

- Success
- Io

func NewGetTableRegionsResult Uses

func NewGetTableRegionsResult() *GetTableRegionsResult

func (*GetTableRegionsResult) GetIo Uses

func (p *GetTableRegionsResult) GetIo() *IOError

func (*GetTableRegionsResult) GetSuccess Uses

func (p *GetTableRegionsResult) GetSuccess() []*TRegionInfo

func (*GetTableRegionsResult) IsSetIo Uses

func (p *GetTableRegionsResult) IsSetIo() bool

func (*GetTableRegionsResult) IsSetSuccess Uses

func (p *GetTableRegionsResult) IsSetSuccess() bool

func (*GetTableRegionsResult) Read Uses

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

func (*GetTableRegionsResult) ReadField0 Uses

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

func (*GetTableRegionsResult) ReadField1 Uses

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

func (*GetTableRegionsResult) String Uses

func (p *GetTableRegionsResult) String() string

func (*GetTableRegionsResult) Write Uses

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

type GetVerArgs Uses

type GetVerArgs struct {
    TableName   []byte            `thrift:"tableName,1" db:"tableName" json:"tableName"`
    Row         []byte            `thrift:"row,2" db:"row" json:"row"`
    Column      []byte            `thrift:"column,3" db:"column" json:"column"`
    NumVersions int32             `thrift:"numVersions,4" db:"numVersions" json:"numVersions"`
    Attributes  map[string][]byte `thrift:"attributes,5" db:"attributes" json:"attributes"`
}

Attributes:

- TableName: name of table
- Row: row key
- Column: column name
- NumVersions: number of versions to retrieve
- Attributes: Get attributes

func NewGetVerArgs Uses

func NewGetVerArgs() *GetVerArgs

func (*GetVerArgs) Read Uses

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

func (*GetVerArgs) ReadField1 Uses

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

func (*GetVerArgs) ReadField2 Uses

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

func (*GetVerArgs) ReadField3 Uses

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

func (*GetVerArgs) ReadField4 Uses

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

func (*GetVerArgs) ReadField5 Uses

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

func (*GetVerArgs) String Uses

func (p *GetVerArgs) String() string

func (*GetVerArgs) Write Uses

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

type GetVerResult Uses

type GetVerResult struct {
    Success []*TCell `thrift:"success,0" db:"success" json:"success,omitempty"`
    Io      *IOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

- Success
- Io

func NewGetVerResult Uses

func NewGetVerResult() *GetVerResult

func (*GetVerResult) GetIo Uses

func (p *GetVerResult) GetIo() *IOError

func (*GetVerResult) GetSuccess Uses

func (p *GetVerResult) GetSuccess() []*TCell

func (*GetVerResult) IsSetIo Uses

func (p *GetVerResult) IsSetIo() bool

func (*GetVerResult) IsSetSuccess Uses

func (p *GetVerResult) IsSetSuccess() bool

func (*GetVerResult) Read Uses

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

func (*GetVerResult) ReadField0 Uses

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

func (*GetVerResult) ReadField1 Uses

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

func (*GetVerResult) String Uses

func (p *GetVerResult) String() string

func (*GetVerResult) Write Uses

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

type GetVerTsArgs Uses

type GetVerTsArgs struct {
    TableName   []byte            `thrift:"tableName,1" db:"tableName" json:"tableName"`
    Row         []byte            `thrift:"row,2" db:"row" json:"row"`
    Column      []byte            `thrift:"column,3" db:"column" json:"column"`
    Timestamp   int64             `thrift:"timestamp,4" db:"timestamp" json:"timestamp"`
    NumVersions int32             `thrift:"numVersions,5" db:"numVersions" json:"numVersions"`
    Attributes  map[string][]byte `thrift:"attributes,6" db:"attributes" json:"attributes"`
}

Attributes:

- TableName: name of table
- Row: row key
- Column: column name
- Timestamp: timestamp
- NumVersions: number of versions to retrieve
- Attributes: Get attributes

func NewGetVerTsArgs Uses

func NewGetVerTsArgs() *GetVerTsArgs

func (*GetVerTsArgs) Read Uses

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

func (*GetVerTsArgs) ReadField1 Uses

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

func (*GetVerTsArgs) ReadField2 Uses

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

func (*GetVerTsArgs) ReadField3 Uses

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

func (*GetVerTsArgs) ReadField4 Uses

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

func (*GetVerTsArgs) ReadField5 Uses

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

func (*GetVerTsArgs) ReadField6 Uses

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

func (*GetVerTsArgs) String Uses

func (p *GetVerTsArgs) String() string

func (*GetVerTsArgs) Write Uses

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

type GetVerTsResult Uses

type GetVerTsResult struct {
    Success []*TCell `thrift:"success,0" db:"success" json:"success,omitempty"`
    Io      *IOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

- Success
- Io

func NewGetVerTsResult Uses

func NewGetVerTsResult() *GetVerTsResult

func (*GetVerTsResult) GetIo Uses

func (p *GetVerTsResult) GetIo() *IOError

func (*GetVerTsResult) GetSuccess Uses

func (p *GetVerTsResult) GetSuccess() []*TCell

func (*GetVerTsResult) IsSetIo Uses

func (p *GetVerTsResult) IsSetIo() bool

func (*GetVerTsResult) IsSetSuccess Uses

func (p *GetVerTsResult) IsSetSuccess() bool

func (*GetVerTsResult) Read Uses

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

func (*GetVerTsResult) ReadField0 Uses

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

func (*GetVerTsResult) ReadField1 Uses

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

func (*GetVerTsResult) String Uses

func (p *GetVerTsResult) String() string

func (*GetVerTsResult) Write Uses

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

type Hbase Uses

type Hbase interface {
    // Brings a table on-line (enables it)
    //
    // Parameters:
    //  - TableName: name of the table
    EnableTable(ctx context.Context, tableName []byte) (err error)
    // Disables a table (takes it off-line) If it is being served, the master
    // will tell the servers to stop serving it.
    //
    // Parameters:
    //  - TableName: name of the table
    DisableTable(ctx context.Context, tableName []byte) (err error)
    // @return true if table is on-line
    //
    // Parameters:
    //  - TableName: name of the table to check
    IsTableEnabled(ctx context.Context, tableName []byte) (r bool, err error)
    // Parameters:
    //  - TableNameOrRegionName
    Compact(ctx context.Context, tableNameOrRegionName []byte) (err error)
    // Parameters:
    //  - TableNameOrRegionName
    MajorCompact(ctx context.Context, tableNameOrRegionName []byte) (err error)
    // List all the userspace tables.
    //
    // @return returns a list of names
    GetTableNames(ctx context.Context) (r [][]byte, err error)
    // List all the column families assoicated with a table.
    //
    // @return list of column family descriptors
    //
    // Parameters:
    //  - TableName: table name
    GetColumnDescriptors(ctx context.Context, tableName []byte) (r map[string]*ColumnDescriptor, err error)
    // List the regions associated with a table.
    //
    // @return list of region descriptors
    //
    // Parameters:
    //  - TableName: table name
    GetTableRegions(ctx context.Context, tableName []byte) (r []*TRegionInfo, err error)
    // Create a table with the specified column families.  The name
    // field for each ColumnDescriptor must be set and must end in a
    // colon (:). All other fields are optional and will get default
    // values if not explicitly specified.
    //
    // @throws IllegalArgument if an input parameter is invalid
    //
    // @throws AlreadyExists if the table name already exists
    //
    // Parameters:
    //  - TableName: name of table to create
    //  - ColumnFamilies: list of column family descriptors
    CreateTable(ctx context.Context, tableName []byte, columnFamilies []*ColumnDescriptor) (err error)
    // Deletes a table
    //
    // @throws IOError if table doesn't exist on server or there was some other
    // problem
    //
    // Parameters:
    //  - TableName: name of table to delete
    DeleteTable(ctx context.Context, tableName []byte) (err error)
    // Get a single TCell for the specified table, row, and column at the
    // latest timestamp. Returns an empty list if no such value exists.
    //
    // @return value for specified row/column
    //
    // Parameters:
    //  - TableName: name of table
    //  - Row: row key
    //  - Column: column name
    //  - Attributes: Get attributes
    Get(ctx context.Context, tableName []byte, row []byte, column []byte, attributes map[string][]byte) (r []*TCell, err error)
    // Get the specified number of versions for the specified table,
    // row, and column.
    //
    // @return list of cells for specified row/column
    //
    // Parameters:
    //  - TableName: name of table
    //  - Row: row key
    //  - Column: column name
    //  - NumVersions: number of versions to retrieve
    //  - Attributes: Get attributes
    GetVer(ctx context.Context, tableName []byte, row []byte, column []byte, numVersions int32, attributes map[string][]byte) (r []*TCell, err error)
    // Get the specified number of versions for the specified table,
    // row, and column.  Only versions less than or equal to the specified
    // timestamp will be returned.
    //
    // @return list of cells for specified row/column
    //
    // Parameters:
    //  - TableName: name of table
    //  - Row: row key
    //  - Column: column name
    //  - Timestamp: timestamp
    //  - NumVersions: number of versions to retrieve
    //  - Attributes: Get attributes
    GetVerTs(ctx context.Context, tableName []byte, row []byte, column []byte, timestamp int64, numVersions int32, attributes map[string][]byte) (r []*TCell, err error)
    // Get all the data for the specified table and row at the latest
    // timestamp. Returns an empty list if the row does not exist.
    //
    // @return TRowResult containing the row and map of columns to TCells
    //
    // Parameters:
    //  - TableName: name of table
    //  - Row: row key
    //  - Attributes: Get attributes
    GetRow(ctx context.Context, tableName []byte, row []byte, attributes map[string][]byte) (r []*TRowResult_, err error)
    // Get the specified columns for the specified table and row at the latest
    // timestamp. Returns an empty list if the row does not exist.
    //
    // @return TRowResult containing the row and map of columns to TCells
    //
    // Parameters:
    //  - TableName: name of table
    //  - Row: row key
    //  - Columns: List of columns to return, null for all columns
    //  - Attributes: Get attributes
    GetRowWithColumns(ctx context.Context, tableName []byte, row []byte, columns [][]byte, attributes map[string][]byte) (r []*TRowResult_, err error)
    // Get all the data for the specified table and row at the specified
    // timestamp. Returns an empty list if the row does not exist.
    //
    // @return TRowResult containing the row and map of columns to TCells
    //
    // Parameters:
    //  - TableName: name of the table
    //  - Row: row key
    //  - Timestamp: timestamp
    //  - Attributes: Get attributes
    GetRowTs(ctx context.Context, tableName []byte, row []byte, timestamp int64, attributes map[string][]byte) (r []*TRowResult_, err error)
    // Get the specified columns for the specified table and row at the specified
    // timestamp. Returns an empty list if the row does not exist.
    //
    // @return TRowResult containing the row and map of columns to TCells
    //
    // Parameters:
    //  - TableName: name of table
    //  - Row: row key
    //  - Columns: List of columns to return, null for all columns
    //  - Timestamp
    //  - Attributes: Get attributes
    GetRowWithColumnsTs(ctx context.Context, tableName []byte, row []byte, columns [][]byte, timestamp int64, attributes map[string][]byte) (r []*TRowResult_, err error)
    // Get all the data for the specified table and rows at the latest
    // timestamp. Returns an empty list if no rows exist.
    //
    // @return TRowResult containing the rows and map of columns to TCells
    //
    // Parameters:
    //  - TableName: name of table
    //  - Rows: row keys
    //  - Attributes: Get attributes
    GetRows(ctx context.Context, tableName []byte, rows [][]byte, attributes map[string][]byte) (r []*TRowResult_, err error)
    // Get the specified columns for the specified table and rows at the latest
    // timestamp. Returns an empty list if no rows exist.
    //
    // @return TRowResult containing the rows and map of columns to TCells
    //
    // Parameters:
    //  - TableName: name of table
    //  - Rows: row keys
    //  - Columns: List of columns to return, null for all columns
    //  - Attributes: Get attributes
    GetRowsWithColumns(ctx context.Context, tableName []byte, rows [][]byte, columns [][]byte, attributes map[string][]byte) (r []*TRowResult_, err error)
    // Get all the data for the specified table and rows at the specified
    // timestamp. Returns an empty list if no rows exist.
    //
    // @return TRowResult containing the rows and map of columns to TCells
    //
    // Parameters:
    //  - TableName: name of the table
    //  - Rows: row keys
    //  - Timestamp: timestamp
    //  - Attributes: Get attributes
    GetRowsTs(ctx context.Context, tableName []byte, rows [][]byte, timestamp int64, attributes map[string][]byte) (r []*TRowResult_, err error)
    // Get the specified columns for the specified table and rows at the specified
    // timestamp. Returns an empty list if no rows exist.
    //
    // @return TRowResult containing the rows and map of columns to TCells
    //
    // Parameters:
    //  - TableName: name of table
    //  - Rows: row keys
    //  - Columns: List of columns to return, null for all columns
    //  - Timestamp
    //  - Attributes: Get attributes
    GetRowsWithColumnsTs(ctx context.Context, tableName []byte, rows [][]byte, columns [][]byte, timestamp int64, attributes map[string][]byte) (r []*TRowResult_, err error)
    // Apply a series of mutations (updates/deletes) to a row in a
    // single transaction.  If an exception is thrown, then the
    // transaction is aborted.  Default current timestamp is used, and
    // all entries will have an identical timestamp.
    //
    // Parameters:
    //  - TableName: name of table
    //  - Row: row key
    //  - Mutations: list of mutation commands
    //  - Attributes: Mutation attributes
    MutateRow(ctx context.Context, tableName []byte, row []byte, mutations []*Mutation, attributes map[string][]byte) (err error)
    // Apply a series of mutations (updates/deletes) to a row in a
    // single transaction.  If an exception is thrown, then the
    // transaction is aborted.  The specified timestamp is used, and
    // all entries will have an identical timestamp.
    //
    // Parameters:
    //  - TableName: name of table
    //  - Row: row key
    //  - Mutations: list of mutation commands
    //  - Timestamp: timestamp
    //  - Attributes: Mutation attributes
    MutateRowTs(ctx context.Context, tableName []byte, row []byte, mutations []*Mutation, timestamp int64, attributes map[string][]byte) (err error)
    // Apply a series of batches (each a series of mutations on a single row)
    // in a single transaction.  If an exception is thrown, then the
    // transaction is aborted.  Default current timestamp is used, and
    // all entries will have an identical timestamp.
    //
    // Parameters:
    //  - TableName: name of table
    //  - RowBatches: list of row batches
    //  - Attributes: Mutation attributes
    MutateRows(ctx context.Context, tableName []byte, rowBatches []*BatchMutation, attributes map[string][]byte) (err error)
    // Apply a series of batches (each a series of mutations on a single row)
    // in a single transaction.  If an exception is thrown, then the
    // transaction is aborted.  The specified timestamp is used, and
    // all entries will have an identical timestamp.
    //
    // Parameters:
    //  - TableName: name of table
    //  - RowBatches: list of row batches
    //  - Timestamp: timestamp
    //  - Attributes: Mutation attributes
    MutateRowsTs(ctx context.Context, tableName []byte, rowBatches []*BatchMutation, timestamp int64, attributes map[string][]byte) (err error)
    // Atomically increment the column value specified.  Returns the next value post increment.
    //
    // Parameters:
    //  - TableName: name of table
    //  - Row: row to increment
    //  - Column: name of column
    //  - Value: amount to increment by
    AtomicIncrement(ctx context.Context, tableName []byte, row []byte, column []byte, value int64) (r int64, err error)
    // Delete all cells that match the passed row and column.
    //
    // Parameters:
    //  - TableName: name of table
    //  - Row: Row to update
    //  - Column: name of column whose value is to be deleted
    //  - Attributes: Delete attributes
    DeleteAll(ctx context.Context, tableName []byte, row []byte, column []byte, attributes map[string][]byte) (err error)
    // Delete all cells that match the passed row and column and whose
    // timestamp is equal-to or older than the passed timestamp.
    //
    // Parameters:
    //  - TableName: name of table
    //  - Row: Row to update
    //  - Column: name of column whose value is to be deleted
    //  - Timestamp: timestamp
    //  - Attributes: Delete attributes
    DeleteAllTs(ctx context.Context, tableName []byte, row []byte, column []byte, timestamp int64, attributes map[string][]byte) (err error)
    // Completely delete the row's cells.
    //
    // Parameters:
    //  - TableName: name of table
    //  - Row: key of the row to be completely deleted.
    //  - Attributes: Delete attributes
    DeleteAllRow(ctx context.Context, tableName []byte, row []byte, attributes map[string][]byte) (err error)
    // Increment a cell by the ammount.
    // Increments can be applied async if hbase.regionserver.thrift.coalesceIncrement is set to true.
    // False is the default.  Turn to true if you need the extra performance and can accept some
    // data loss if a thrift server dies with increments still in the queue.
    //
    // Parameters:
    //  - Increment: The single increment to apply
    Increment(ctx context.Context, increment *TIncrement) (err error)
    // Parameters:
    //  - Increments: The list of increments
    IncrementRows(ctx context.Context, increments []*TIncrement) (err error)
    // Completely delete the row's cells marked with a timestamp
    // equal-to or older than the passed timestamp.
    //
    // Parameters:
    //  - TableName: name of table
    //  - Row: key of the row to be completely deleted.
    //  - Timestamp: timestamp
    //  - Attributes: Delete attributes
    DeleteAllRowTs(ctx context.Context, tableName []byte, row []byte, timestamp int64, attributes map[string][]byte) (err error)
    // Get a scanner on the current table, using the Scan instance
    // for the scan parameters.
    //
    // Parameters:
    //  - TableName: name of table
    //  - Scan: Scan instance
    //  - Attributes: Scan attributes
    ScannerOpenWithScan(ctx context.Context, tableName []byte, scan *TScan, attributes map[string][]byte) (r ScannerID, err error)
    // Get a scanner on the current table starting at the specified row and
    // ending at the last row in the table.  Return the specified columns.
    //
    // @return scanner id to be used with other scanner procedures
    //
    // Parameters:
    //  - TableName: name of table
    //  - StartRow: Starting row in table to scan.
    // Send "" (empty string) to start at the first row.
    //  - Columns: columns to scan. If column name is a column family, all
    // columns of the specified column family are returned. It's also possible
    // to pass a regex in the column qualifier.
    //  - Attributes: Scan attributes
    ScannerOpen(ctx context.Context, tableName []byte, startRow []byte, columns [][]byte, attributes map[string][]byte) (r ScannerID, err error)
    // Get a scanner on the current table starting and stopping at the
    // specified rows.  ending at the last row in the table.  Return the
    // specified columns.
    //
    // @return scanner id to be used with other scanner procedures
    //
    // Parameters:
    //  - TableName: name of table
    //  - StartRow: Starting row in table to scan.
    // Send "" (empty string) to start at the first row.
    //  - StopRow: row to stop scanning on. This row is *not* included in the
    // scanner's results
    //  - Columns: columns to scan. If column name is a column family, all
    // columns of the specified column family are returned. It's also possible
    // to pass a regex in the column qualifier.
    //  - Attributes: Scan attributes
    ScannerOpenWithStop(ctx context.Context, tableName []byte, startRow []byte, stopRow []byte, columns [][]byte, attributes map[string][]byte) (r ScannerID, err error)
    // Open a scanner for a given prefix.  That is all rows will have the specified
    // prefix. No other rows will be returned.
    //
    // @return scanner id to use with other scanner calls
    //
    // Parameters:
    //  - TableName: name of table
    //  - StartAndPrefix: the prefix (and thus start row) of the keys you want
    //  - Columns: the columns you want returned
    //  - Attributes: Scan attributes
    ScannerOpenWithPrefix(ctx context.Context, tableName []byte, startAndPrefix []byte, columns [][]byte, attributes map[string][]byte) (r ScannerID, err error)
    // Get a scanner on the current table starting at the specified row and
    // ending at the last row in the table.  Return the specified columns.
    // Only values with the specified timestamp are returned.
    //
    // @return scanner id to be used with other scanner procedures
    //
    // Parameters:
    //  - TableName: name of table
    //  - StartRow: Starting row in table to scan.
    // Send "" (empty string) to start at the first row.
    //  - Columns: columns to scan. If column name is a column family, all
    // columns of the specified column family are returned. It's also possible
    // to pass a regex in the column qualifier.
    //  - Timestamp: timestamp
    //  - Attributes: Scan attributes
    ScannerOpenTs(ctx context.Context, tableName []byte, startRow []byte, columns [][]byte, timestamp int64, attributes map[string][]byte) (r ScannerID, err error)
    // Get a scanner on the current table starting and stopping at the
    // specified rows.  ending at the last row in the table.  Return the
    // specified columns.  Only values with the specified timestamp are
    // returned.
    //
    // @return scanner id to be used with other scanner procedures
    //
    // Parameters:
    //  - TableName: name of table
    //  - StartRow: Starting row in table to scan.
    // Send "" (empty string) to start at the first row.
    //  - StopRow: row to stop scanning on. This row is *not* included in the
    // scanner's results
    //  - Columns: columns to scan. If column name is a column family, all
    // columns of the specified column family are returned. It's also possible
    // to pass a regex in the column qualifier.
    //  - Timestamp: timestamp
    //  - Attributes: Scan attributes
    ScannerOpenWithStopTs(ctx context.Context, tableName []byte, startRow []byte, stopRow []byte, columns [][]byte, timestamp int64, attributes map[string][]byte) (r ScannerID, err error)
    // Returns the scanner's current row value and advances to the next
    // row in the table.  When there are no more rows in the table, or a key
    // greater-than-or-equal-to the scanner's specified stopRow is reached,
    // an empty list is returned.
    //
    // @return a TRowResult containing the current row and a map of the columns to TCells.
    //
    // @throws IllegalArgument if ScannerID is invalid
    //
    // @throws NotFound when the scanner reaches the end
    //
    // Parameters:
    //  - ID: id of a scanner returned by scannerOpen
    ScannerGet(ctx context.Context, id ScannerID) (r []*TRowResult_, err error)
    // Returns, starting at the scanner's current row value nbRows worth of
    // rows and advances to the next row in the table.  When there are no more
    // rows in the table, or a key greater-than-or-equal-to the scanner's
    // specified stopRow is reached,  an empty list is returned.
    //
    // @return a TRowResult containing the current row and a map of the columns to TCells.
    //
    // @throws IllegalArgument if ScannerID is invalid
    //
    // @throws NotFound when the scanner reaches the end
    //
    // Parameters:
    //  - ID: id of a scanner returned by scannerOpen
    //  - NbRows: number of results to return
    ScannerGetList(ctx context.Context, id ScannerID, nbRows int32) (r []*TRowResult_, err error)
    // Closes the server-state associated with an open scanner.
    //
    // @throws IllegalArgument if ScannerID is invalid
    //
    // Parameters:
    //  - ID: id of a scanner returned by scannerOpen
    ScannerClose(ctx context.Context, id ScannerID) (err error)
    // Get the regininfo for the specified row. It scans
    // the metatable to find region's start and end keys.
    //
    // @return value for specified row/column
    //
    // Parameters:
    //  - Row: row key
    GetRegionInfo(ctx context.Context, row []byte) (r *TRegionInfo, err error)
    // Appends values to one or more columns within a single row.
    //
    // @return values of columns after the append operation.
    //
    // Parameters:
    //  - Append: The single append operation to apply
    Append(ctx context.Context, append *TAppend) (r []*TCell, err error)
    // Atomically checks if a row/family/qualifier value matches the expected
    // value. If it does, it adds the corresponding mutation operation for put.
    //
    // @return true if the new put was executed, false otherwise
    //
    // Parameters:
    //  - TableName: name of table
    //  - Row: row key
    //  - Column: column name
    //  - Value: the expected value for the column parameter, if not
    // provided the check is for the non-existence of the
    // column in question
    //  - Mput: mutation for the put
    //  - Attributes: Mutation attributes
    CheckAndPut(ctx context.Context, tableName []byte, row []byte, column []byte, value []byte, mput *Mutation, attributes map[string][]byte) (r bool, err error)
}

type IOError Uses

type IOError struct {
    Message string `thrift:"message,1" db:"message" json:"message"`
}

An IOError exception signals that an error occurred communicating to the Hbase master or an Hbase region server. Also used to return more general Hbase error conditions.

Attributes:

- Message
var AppendResult_Io_DEFAULT *IOError
var AtomicIncrementResult_Io_DEFAULT *IOError
var CheckAndPutResult_Io_DEFAULT *IOError
var CompactResult_Io_DEFAULT *IOError
var CreateTableResult_Io_DEFAULT *IOError
var DeleteAllResult_Io_DEFAULT *IOError
var DeleteAllRowResult_Io_DEFAULT *IOError
var DeleteAllRowTsResult_Io_DEFAULT *IOError
var DeleteAllTsResult_Io_DEFAULT *IOError
var DeleteTableResult_Io_DEFAULT *IOError
var DisableTableResult_Io_DEFAULT *IOError
var EnableTableResult_Io_DEFAULT *IOError
var GetColumnDescriptorsResult_Io_DEFAULT *IOError
var GetRegionInfoResult_Io_DEFAULT *IOError
var GetResult_Io_DEFAULT *IOError
var GetRowResult_Io_DEFAULT *IOError
var GetRowTsResult_Io_DEFAULT *IOError
var GetRowWithColumnsResult_Io_DEFAULT *IOError
var GetRowWithColumnsTsResult_Io_DEFAULT *IOError
var GetRowsResult_Io_DEFAULT *IOError
var GetRowsTsResult_Io_DEFAULT *IOError
var GetRowsWithColumnsResult_Io_DEFAULT *IOError
var GetRowsWithColumnsTsResult_Io_DEFAULT *IOError
var GetTableNamesResult_Io_DEFAULT *IOError
var GetTableRegionsResult_Io_DEFAULT *IOError
var GetVerResult_Io_DEFAULT *IOError
var GetVerTsResult_Io_DEFAULT *IOError
var IncrementResult_Io_DEFAULT *IOError
var IncrementRowsResult_Io_DEFAULT *IOError
var IsTableEnabledResult_Io_DEFAULT *IOError
var MajorCompactResult_Io_DEFAULT *IOError
var MutateRowResult_Io_DEFAULT *IOError
var MutateRowTsResult_Io_DEFAULT *IOError
var MutateRowsResult_Io_DEFAULT *IOError
var MutateRowsTsResult_Io_DEFAULT *IOError
var ScannerCloseResult_Io_DEFAULT *IOError
var ScannerGetListResult_Io_DEFAULT *IOError
var ScannerGetResult_Io_DEFAULT *IOError
var ScannerOpenResult_Io_DEFAULT *IOError
var ScannerOpenTsResult_Io_DEFAULT *IOError
var ScannerOpenWithPrefixResult_Io_DEFAULT *IOError
var ScannerOpenWithScanResult_Io_DEFAULT *IOError
var ScannerOpenWithStopResult_Io_DEFAULT *IOError
var ScannerOpenWithStopTsResult_Io_DEFAULT *IOError

func NewIOError Uses

func NewIOError() *IOError

func (*IOError) Error Uses

func (p *IOError) Error() string

func (*IOError) Read Uses

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

func (*IOError) ReadField1 Uses

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

func (*IOError) String Uses

func (p *IOError) String() string

func (*IOError) Write Uses

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

type IllegalArgument Uses

type IllegalArgument struct {
    Message string `thrift:"message,1" db:"message" json:"message"`
}

An IllegalArgument exception indicates an illegal or invalid argument was passed into a procedure.

Attributes:

- Message
var AtomicIncrementResult_Ia_DEFAULT *IllegalArgument
var CheckAndPutResult_Ia_DEFAULT *IllegalArgument
var CreateTableResult_Ia_DEFAULT *IllegalArgument
var MutateRowResult_Ia_DEFAULT *IllegalArgument
var MutateRowTsResult_Ia_DEFAULT *IllegalArgument
var MutateRowsResult_Ia_DEFAULT *IllegalArgument
var MutateRowsTsResult_Ia_DEFAULT *IllegalArgument
var ScannerCloseResult_Ia_DEFAULT *IllegalArgument
var ScannerGetListResult_Ia_DEFAULT *IllegalArgument
var ScannerGetResult_Ia_DEFAULT *IllegalArgument

func NewIllegalArgument Uses

func NewIllegalArgument() *IllegalArgument

func (*IllegalArgument) Error Uses

func (p *IllegalArgument) Error() string

func (*IllegalArgument) Read Uses

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

func (*IllegalArgument) ReadField1 Uses

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

func (*IllegalArgument) String Uses

func (p *IllegalArgument) String() string

func (*IllegalArgument) Write Uses

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

type IncrementArgs Uses

type IncrementArgs struct {
    Increment *TIncrement `thrift:"increment,1" db:"increment" json:"increment"`
}

Attributes:

- Increment: The single increment to apply

func NewIncrementArgs Uses

func NewIncrementArgs() *IncrementArgs

func (*IncrementArgs) GetIncrement Uses

func (p *IncrementArgs) GetIncrement() *TIncrement

func (*IncrementArgs) IsSetIncrement Uses

func (p *IncrementArgs) IsSetIncrement() bool

func (*IncrementArgs) Read Uses

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

func (*IncrementArgs) ReadField1 Uses

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

func (*IncrementArgs) String Uses

func (p *IncrementArgs) String() string

func (*IncrementArgs) Write Uses

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

type IncrementResult Uses

type IncrementResult struct {
    Io *IOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

- Io

func NewIncrementResult Uses

func NewIncrementResult() *IncrementResult

func (*IncrementResult) GetIo Uses

func (p *IncrementResult) GetIo() *IOError

func (*IncrementResult) IsSetIo Uses

func (p *IncrementResult) IsSetIo() bool

func (*IncrementResult) Read Uses

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

func (*IncrementResult) ReadField1 Uses

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

func (*IncrementResult) String Uses

func (p *IncrementResult) String() string

func (*IncrementResult) Write Uses

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

type IncrementRowsArgs Uses

type IncrementRowsArgs struct {
    Increments []*TIncrement `thrift:"increments,1" db:"increments" json:"increments"`
}

Attributes:

- Increments: The list of increments

func NewIncrementRowsArgs Uses

func NewIncrementRowsArgs() *IncrementRowsArgs

func (*IncrementRowsArgs) GetIncrements Uses

func (p *IncrementRowsArgs) GetIncrements() []*TIncrement

func (*IncrementRowsArgs) Read Uses

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

func (*IncrementRowsArgs) ReadField1 Uses

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

func (*IncrementRowsArgs) String Uses

func (p *IncrementRowsArgs) String() string

func (*IncrementRowsArgs) Write Uses

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

type IncrementRowsResult Uses

type IncrementRowsResult struct {
    Io *IOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

- Io

func NewIncrementRowsResult Uses

func NewIncrementRowsResult() *IncrementRowsResult

func (*IncrementRowsResult) GetIo Uses

func (p *IncrementRowsResult) GetIo() *IOError

func (*IncrementRowsResult) IsSetIo Uses

func (p *IncrementRowsResult) IsSetIo() bool

func (*IncrementRowsResult) Read Uses

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

func (*IncrementRowsResult) ReadField1 Uses

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

func (*IncrementRowsResult) String Uses

func (p *IncrementRowsResult) String() string

func (*IncrementRowsResult) Write Uses

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

type IsTableEnabledArgs Uses

type IsTableEnabledArgs struct {
    TableName []byte `thrift:"tableName,1" db:"tableName" json:"tableName"`
}

Attributes:

- TableName: name of the table to check

func NewIsTableEnabledArgs Uses

func NewIsTableEnabledArgs() *IsTableEnabledArgs

func (*IsTableEnabledArgs) Read Uses

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

func (*IsTableEnabledArgs) ReadField1 Uses

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

func (*IsTableEnabledArgs) String Uses

func (p *IsTableEnabledArgs) String() string

func (*IsTableEnabledArgs) Write Uses

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

type IsTableEnabledResult Uses

type IsTableEnabledResult struct {
    Success *bool    `thrift:"success,0" db:"success" json:"success,omitempty"`
    Io      *IOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

- Success
- Io

func NewIsTableEnabledResult Uses

func NewIsTableEnabledResult() *IsTableEnabledResult

func (*IsTableEnabledResult) GetIo Uses

func (p *IsTableEnabledResult) GetIo() *IOError

func (*IsTableEnabledResult) GetSuccess Uses

func (p *IsTableEnabledResult) GetSuccess() bool

func (*IsTableEnabledResult) IsSetIo Uses

func (p *IsTableEnabledResult) IsSetIo() bool

func (*IsTableEnabledResult) IsSetSuccess Uses

func (p *IsTableEnabledResult) IsSetSuccess() bool

func (*IsTableEnabledResult) Read Uses

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

func (*IsTableEnabledResult) ReadField0 Uses

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

func (*IsTableEnabledResult) ReadField1 Uses

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

func (*IsTableEnabledResult) String Uses

func (p *IsTableEnabledResult) String() string

func (*IsTableEnabledResult) Write Uses

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

type MajorCompactArgs Uses

type MajorCompactArgs struct {
    TableNameOrRegionName []byte `thrift:"tableNameOrRegionName,1" db:"tableNameOrRegionName" json:"tableNameOrRegionName"`
}

Attributes:

- TableNameOrRegionName

func NewMajorCompactArgs Uses

func NewMajorCompactArgs() *MajorCompactArgs

func (*MajorCompactArgs) GetTableNameOrRegionName Uses

func (p *MajorCompactArgs) GetTableNameOrRegionName() []byte

func (*MajorCompactArgs) Read Uses

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

func (*MajorCompactArgs) ReadField1 Uses

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

func (*MajorCompactArgs) String Uses

func (p *MajorCompactArgs) String() string

func (*MajorCompactArgs) Write Uses

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

type MajorCompactResult Uses

type MajorCompactResult struct {
    Io *IOError `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

- Io

func NewMajorCompactResult Uses

func NewMajorCompactResult() *MajorCompactResult

func (*MajorCompactResult) GetIo Uses

func (p *MajorCompactResult) GetIo() *IOError

func (*MajorCompactResult) IsSetIo Uses

func (p *MajorCompactResult) IsSetIo() bool

func (*MajorCompactResult) Read Uses

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

func (*MajorCompactResult) ReadField1 Uses

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

func (*MajorCompactResult) String Uses

func (p *MajorCompactResult) String() string

func (*MajorCompactResult) Write Uses

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

type MutateRowArgs Uses

type MutateRowArgs struct {
    TableName  []byte            `thrift:"tableName,1" db:"tableName" json:"tableName"`
    Row        []byte            `thrift:"row,2" db:"row" json:"row"`
    Mutations  []*Mutation       `thrift:"mutations,3" db:"mutations" json:"mutations"`
    Attributes map[string][]byte `thrift:"attributes,4" db:"attributes" json:"attributes"`
}

Attributes:

- TableName: name of table
- Row: row key
- Mutations: list of mutation commands
- Attributes: Mutation attributes

func NewMutateRowArgs Uses

func NewMutateRowArgs() *MutateRowArgs

func (*MutateRowArgs) Read Uses

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

func (*MutateRowArgs) ReadField1 Uses

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

func (*MutateRowArgs) ReadField2 Uses

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

func (*MutateRowArgs) ReadField3 Uses

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

func (*MutateRowArgs) ReadField4 Uses

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

func (*MutateRowArgs) String Uses

func (p *MutateRowArgs) String() string

func (*MutateRowArgs) Write Uses

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

type MutateRowResult Uses

type MutateRowResult struct {
    Io  *IOError         `thrift:"io,1" db:"io" json:"io,omitempty"`
    Ia  *IllegalArgument `thrift:"ia,2" db:"ia" json:"ia,omitempty"`
}

Attributes:

- Io
- Ia

func NewMutateRowResult Uses

func NewMutateRowResult() *MutateRowResult

func (*MutateRowResult) GetIa Uses

func (p *MutateRowResult) GetIa() *IllegalArgument

func (*MutateRowResult) GetIo Uses

func (p *MutateRowResult) GetIo() *IOError

func (*MutateRowResult) IsSetIa Uses

func (p *MutateRowResult) IsSetIa() bool

func (*MutateRowResult) IsSetIo Uses

func (p *MutateRowResult) IsSetIo() bool

func (*MutateRowResult) Read Uses

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

func (*MutateRowResult) ReadField1 Uses

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

func (*MutateRowResult) ReadField2 Uses

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

func (*MutateRowResult) String Uses

func (p *MutateRowResult) String() string

func (*MutateRowResult) Write Uses

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

type MutateRowTsArgs Uses

type MutateRowTsArgs struct {
    TableName  []byte            `thrift:"tableName,1" db:"tableName" json:"tableName"`
    Row        []byte            `thrift:"row,2" db:"row" json:"row"`
    Mutations  []*Mutation       `thrift:"mutations,3" db:"mutations" json:"mutations"`
    Timestamp  int64             `thrift:"timestamp,4" db:"timestamp" json:"timestamp"`
    Attributes map[string][]byte `thrift:"attributes,5" db:"attributes" json:"attributes"`
}

Attributes:

- TableName: name of table
- Row: row key
- Mutations: list of mutation commands
- Timestamp: timestamp
- Attributes: Mutation attributes

func NewMutateRowTsArgs Uses

func NewMutateRowTsArgs() *MutateRowTsArgs

func (*MutateRowTsArgs) Read Uses

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

func (*MutateRowTsArgs) ReadField1 Uses

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

func (*MutateRowTsArgs) ReadField2 Uses

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

func (*MutateRowTsArgs) ReadField3 Uses

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

func (*MutateRowTsArgs) ReadField4 Uses

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

func (*MutateRowTsArgs) ReadField5 Uses

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

func (*MutateRowTsArgs) String Uses

func (p *MutateRowTsArgs) String() string

func (*MutateRowTsArgs) Write Uses

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

type MutateRowTsResult Uses

type MutateRowTsResult struct {
    Io  *IOError         `thrift:"io,1" db:"io" json:"io,omitempty"`
    Ia  *IllegalArgument `thrift:"ia,2" db:"ia" json:"ia,omitempty"`
}

Attributes:

- Io
- Ia

func NewMutateRowTsResult Uses

func NewMutateRowTsResult() *MutateRowTsResult

func (*MutateRowTsResult) GetIa Uses

func (p *MutateRowTsResult) GetIa() *IllegalArgument

func (*MutateRowTsResult) GetIo Uses

func (p *MutateRowTsResult) GetIo() *IOError

func (*MutateRowTsResult) IsSetIa Uses

func (p *MutateRowTsResult) IsSetIa() bool

func (*MutateRowTsResult) IsSetIo Uses

func (p *MutateRowTsResult) IsSetIo() bool

func (*MutateRowTsResult) Read Uses

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

func (*MutateRowTsResult) ReadField1 Uses

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

func (*MutateRowTsResult) ReadField2 Uses

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

func (*MutateRowTsResult) String Uses

func (p *MutateRowTsResult) String() string

func (*MutateRowTsResult) Write Uses

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

type MutateRowsArgs Uses

type MutateRowsArgs struct {
    TableName  []byte            `thrift:"tableName,1" db:"tableName" json:"tableName"`
    RowBatches []*BatchMutation  `thrift:"rowBatches,2" db:"rowBatches" json:"rowBatches"`
    Attributes map[string][]byte `thrift:"attributes,3" db:"attributes" json:"attributes"`
}

Attributes:

- TableName: name of table
- RowBatches: list of row batches
- Attributes: Mutation attributes

func NewMutateRowsArgs Uses

func NewMutateRowsArgs() *MutateRowsArgs

func (*MutateRowsArgs) GetRowBatches Uses

func (p *MutateRowsArgs) GetRowBatches() []*BatchMutation

func (*MutateRowsArgs) Read Uses

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

func (*MutateRowsArgs) ReadField1 Uses

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

func (*MutateRowsArgs) ReadField2 Uses

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

func (*MutateRowsArgs) ReadField3 Uses

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

func (*MutateRowsArgs) String Uses

func (p *MutateRowsArgs) String() string

func (*MutateRowsArgs) Write Uses

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

type MutateRowsResult Uses

type MutateRowsResult struct {
    Io  *IOError         `thrift:"io,1" db:"io" json:"io,omitempty"`
    Ia  *IllegalArgument `thrift:"ia,2" db:"ia" json:"ia,omitempty"`
}

Attributes:

- Io
- Ia

func NewMutateRowsResult Uses

func NewMutateRowsResult() *MutateRowsResult

func (*MutateRowsResult) GetIa Uses

func (p *MutateRowsResult) GetIa() *IllegalArgument

func (*MutateRowsResult) GetIo Uses

func (p *MutateRowsResult) GetIo() *IOError

func (*MutateRowsResult) IsSetIa Uses

func (p *MutateRowsResult) IsSetIa() bool

func (*MutateRowsResult) IsSetIo Uses

func (p *MutateRowsResult) IsSetIo() bool

func (*MutateRowsResult) Read Uses

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

func (*MutateRowsResult) ReadField1 Uses

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

func (*MutateRowsResult) ReadField2 Uses

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

func (*MutateRowsResult) String Uses

func (p *MutateRowsResult) String() string

func (*MutateRowsResult) Write Uses

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

type MutateRowsTsArgs Uses

type MutateRowsTsArgs struct {
    TableName  []byte            `thrift:"tableName,1" db:"tableName" json:"tableName"`
    RowBatches []*BatchMutation  `thrift:"rowBatches,2" db:"rowBatches" json:"rowBatches"`
    Timestamp  int64             `thrift:"timestamp,3" db:"timestamp" json:"timestamp"`
    Attributes map[string][]byte `thrift:"attributes,4" db:"attributes" json:"attributes"`
}

Attributes:

- TableName: name of table
- RowBatches: list of row batches
- Timestamp: timestamp
- Attributes: Mutation attributes

func NewMutateRowsTsArgs Uses

func NewMutateRowsTsArgs() *MutateRowsTsArgs

func (*MutateRowsTsArgs) GetRowBatches Uses

func (p *MutateRowsTsArgs) GetRowBatches() []*BatchMutation

func (*MutateRowsTsArgs) Read Uses

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

func (*MutateRowsTsArgs) ReadField1 Uses

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

func (*MutateRowsTsArgs) ReadField2 Uses

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

func (*MutateRowsTsArgs) ReadField3 Uses

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

func (*MutateRowsTsArgs) ReadField4 Uses

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

func (*MutateRowsTsArgs) String Uses

func (p *MutateRowsTsArgs) String() string

func (*MutateRowsTsArgs) Write Uses

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

type MutateRowsTsResult Uses

type MutateRowsTsResult struct {
    Io  *IOError         `thrift:"io,1" db:"io" json:"io,omitempty"`
    Ia  *IllegalArgument `thrift:"ia,2" db:"ia" json:"ia,omitempty"`
}

Attributes:

- Io
- Ia

func NewMutateRowsTsResult Uses

func NewMutateRowsTsResult() *MutateRowsTsResult

func (*MutateRowsTsResult) GetIa Uses

func (p *MutateRowsTsResult) GetIa() *IllegalArgument

func (*MutateRowsTsResult) GetIo Uses

func (p *MutateRowsTsResult) GetIo() *IOError

func (*MutateRowsTsResult) IsSetIa Uses

func (p *MutateRowsTsResult) IsSetIa() bool

func (*MutateRowsTsResult) IsSetIo Uses

func (p *MutateRowsTsResult) IsSetIo() bool

func (*MutateRowsTsResult) Read Uses

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

func (*MutateRowsTsResult) ReadField1 Uses

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

func (*MutateRowsTsResult) ReadField2 Uses

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

func (*MutateRowsTsResult) String Uses

func (p *MutateRowsTsResult) String() string

func (*MutateRowsTsResult) Write Uses

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

type Mutation Uses

type Mutation struct {
    IsDelete   bool   `thrift:"isDelete,1" db:"isDelete" json:"isDelete"`
    Column     []byte `thrift:"column,2" db:"column" json:"column"`
    Value      []byte `thrift:"value,3" db:"value" json:"value"`
    WriteToWAL bool   `thrift:"writeToWAL,4" db:"writeToWAL" json:"writeToWAL"`
}

A Mutation object is used to either update or delete a column-value.

Attributes:

- IsDelete
- Column
- Value
- WriteToWAL
var CheckAndPutArgs_Mput_DEFAULT *Mutation

func NewMutation Uses

func NewMutation() *Mutation

func (*Mutation) Read Uses

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

func (*Mutation) ReadField1 Uses

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

func (*Mutation) ReadField2 Uses

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

func (*Mutation) ReadField3 Uses

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

func (*Mutation) ReadField4 Uses

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

func (*Mutation) String Uses

func (p *Mutation) String() string

func (*Mutation) Write Uses

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

type Processor Uses

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

func NewProcessor Uses

func NewProcessor(handler Hbase) *Processor

func (*Processor) AddToProcessorMap Uses

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

func (*Processor) GetProcessorFunction Uses

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

func (*Processor) Process Uses

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

func (*Processor) ProcessorMap Uses

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

type ProcessorAppend Uses

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

func (*ProcessorAppend) Process Uses

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

type ProcessorAtomicIncrement Uses

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

func (*ProcessorAtomicIncrement) Process Uses

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

type ProcessorCheckAndPut Uses

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

func (*ProcessorCheckAndPut) Process Uses

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

type ProcessorCompact Uses

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

func (*ProcessorCompact) Process Uses

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

type ProcessorCreateTable Uses

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

func (*ProcessorCreateTable) Process Uses

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

type ProcessorDeleteAll Uses

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

func (*ProcessorDeleteAll) Process Uses

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

type ProcessorDeleteAllRow Uses

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

func (*ProcessorDeleteAllRow) Process Uses

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

type ProcessorDeleteAllRowTs Uses

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

func (*ProcessorDeleteAllRowTs) Process Uses

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

type ProcessorDeleteAllTs Uses

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

func (*ProcessorDeleteAllTs) Process Uses

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

type ProcessorDeleteTable Uses

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

func (*ProcessorDeleteTable) Process Uses

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

type ProcessorDisableTable Uses

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

func (*ProcessorDisableTable) Process Uses

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

type ProcessorEnableTable Uses

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

func (*ProcessorEnableTable) Process Uses

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

type ProcessorGet Uses

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

func (*ProcessorGet) Process Uses

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

type ProcessorGetColumnDescriptors Uses

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

func (*ProcessorGetColumnDescriptors) Process Uses

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

type ProcessorGetRegionInfo Uses

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

func (*ProcessorGetRegionInfo) Process Uses

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

type ProcessorGetRow Uses

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

func (*ProcessorGetRow) Process Uses

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

type ProcessorGetRowTs Uses

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

func (*ProcessorGetRowTs) Process Uses

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

type ProcessorGetRowWithColumns Uses

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

func (*ProcessorGetRowWithColumns) Process Uses

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

type ProcessorGetRowWithColumnsTs Uses

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

func (*ProcessorGetRowWithColumnsTs) Process Uses

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

type ProcessorGetRows Uses

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

func (*ProcessorGetRows) Process Uses

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

type ProcessorGetRowsTs Uses

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

func (*ProcessorGetRowsTs) Process Uses

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

type ProcessorGetRowsWithColumns Uses

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

func (*ProcessorGetRowsWithColumns) Process Uses

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

type ProcessorGetRowsWithColumnsTs Uses

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

func (*ProcessorGetRowsWithColumnsTs) Process Uses

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

type ProcessorGetTableNames Uses

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

func (*ProcessorGetTableNames) Process Uses

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

type ProcessorGetTableRegions Uses

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

func (*ProcessorGetTableRegions) Process Uses

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

type ProcessorGetVer Uses

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

func (*ProcessorGetVer) Process Uses

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

type ProcessorGetVerTs Uses

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

func (*ProcessorGetVerTs) Process Uses

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

type ProcessorIncrement Uses

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

func (*ProcessorIncrement) Process Uses

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

type ProcessorIncrementRows Uses

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

func (*ProcessorIncrementRows) Process Uses

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

type ProcessorIsTableEnabled Uses

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

func (*ProcessorIsTableEnabled) Process Uses

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

type ProcessorMajorCompact Uses

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

func (*ProcessorMajorCompact) Process Uses

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

type ProcessorMutateRow Uses

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

func (*ProcessorMutateRow) Process Uses

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

type ProcessorMutateRowTs Uses

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

func (*ProcessorMutateRowTs) Process Uses

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

type ProcessorMutateRows Uses

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

func (*ProcessorMutateRows) Process Uses

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

type ProcessorMutateRowsTs Uses

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

func (*ProcessorMutateRowsTs) Process Uses

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

type ProcessorScannerClose Uses

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

func (*ProcessorScannerClose) Process Uses

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

type ProcessorScannerGet Uses

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

func (*ProcessorScannerGet) Process Uses

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

type ProcessorScannerGetList Uses

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

func (*ProcessorScannerGetList) Process Uses

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

type ProcessorScannerOpen Uses

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

func (*ProcessorScannerOpen) Process Uses

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

type ProcessorScannerOpenTs Uses

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

func (*ProcessorScannerOpenTs) Process Uses

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

type ProcessorScannerOpenWithPrefix Uses

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

func (*ProcessorScannerOpenWithPrefix) Process Uses

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

type ProcessorScannerOpenWithScan Uses

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

func (*ProcessorScannerOpenWithScan) Process Uses

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

type ProcessorScannerOpenWithStop Uses

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

func (*ProcessorScannerOpenWithStop) Process Uses

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

type ProcessorScannerOpenWithStopTs Uses

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

func (*ProcessorScannerOpenWithStopTs) Process Uses

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

type ScannerCloseArgs Uses

type ScannerCloseArgs struct {
    ID ScannerID `thrift:"id,1" db:"id" json:"id"`
}

Attributes:

- ID: id of a scanner returned by scannerOpen

func NewScannerCloseArgs Uses

func NewScannerCloseArgs() *ScannerCloseArgs

func (*ScannerCloseArgs) GetID Uses

func (p *ScannerCloseArgs) GetID() ScannerID

func (*ScannerCloseArgs) Read Uses

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

func (*ScannerCloseArgs) ReadField1 Uses

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

func (*ScannerCloseArgs) String Uses

func (p *ScannerCloseArgs) String() string

func (*ScannerCloseArgs) Write Uses

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

type ScannerCloseResult Uses

type ScannerCloseResult struct {
    Io  *IOError         `thrift:"io,1" db:"io" json:"io,omitempty"`
    Ia  *IllegalArgument `thrift:"ia,2" db:"ia" json:"ia,omitempty"`
}

Attributes:

- Io
- Ia

func NewScannerCloseResult Uses

func NewScannerCloseResult() *ScannerCloseResult

func (*ScannerCloseResult) GetIa Uses

func (p *ScannerCloseResult) GetIa() *IllegalArgument

func (*ScannerCloseResult) GetIo Uses

func (p *ScannerCloseResult) GetIo() *IOError

func (*ScannerCloseResult) IsSetIa Uses

func (p *ScannerCloseResult) IsSetIa() bool

func (*ScannerCloseResult) IsSetIo Uses

func (p *ScannerCloseResult) IsSetIo() bool

func (*ScannerCloseResult) Read Uses

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

func (*ScannerCloseResult) ReadField1 Uses

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

func (*ScannerCloseResult) ReadField2 Uses

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

func (*ScannerCloseResult) String Uses

func (p *ScannerCloseResult) String() string

func (*ScannerCloseResult) Write Uses

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

type ScannerGetArgs Uses

type ScannerGetArgs struct {
    ID ScannerID `thrift:"id,1" db:"id" json:"id"`
}

Attributes:

- ID: id of a scanner returned by scannerOpen

func NewScannerGetArgs Uses

func NewScannerGetArgs() *ScannerGetArgs

func (*ScannerGetArgs) GetID Uses

func (p *ScannerGetArgs) GetID() ScannerID

func (*ScannerGetArgs) Read Uses

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

func (*ScannerGetArgs) ReadField1 Uses

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

func (*ScannerGetArgs) String Uses

func (p *ScannerGetArgs) String() string

func (*ScannerGetArgs) Write Uses

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

type ScannerGetListArgs Uses

type ScannerGetListArgs struct {
    ID     ScannerID `thrift:"id,1" db:"id" json:"id"`
    NbRows int32     `thrift:"nbRows,2" db:"nbRows" json:"nbRows"`
}

Attributes:

- ID: id of a scanner returned by scannerOpen
- NbRows: number of results to return

func NewScannerGetListArgs Uses

func NewScannerGetListArgs() *ScannerGetListArgs

func (*ScannerGetListArgs) GetID Uses

func (p *ScannerGetListArgs) GetID() ScannerID

func (*ScannerGetListArgs) GetNbRows Uses

func (p *ScannerGetListArgs) GetNbRows() int32

func (*ScannerGetListArgs) Read Uses

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

func (*ScannerGetListArgs) ReadField1 Uses

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

func (*ScannerGetListArgs) ReadField2 Uses

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

func (*ScannerGetListArgs) String Uses

func (p *ScannerGetListArgs) String() string

func (*ScannerGetListArgs) Write Uses

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

type ScannerGetListResult Uses

type ScannerGetListResult struct {
    Success []*TRowResult_   `thrift:"success,0" db:"success" json:"success,omitempty"`
    Io      *IOError         `thrift:"io,1" db:"io" json:"io,omitempty"`
    Ia      *IllegalArgument `thrift:"ia,2" db:"ia" json:"ia,omitempty"`
}

Attributes:

- Success
- Io
- Ia

func NewScannerGetListResult Uses

func NewScannerGetListResult() *ScannerGetListResult

func (*ScannerGetListResult) GetIa Uses

func (p *ScannerGetListResult) GetIa() *IllegalArgument

func (*ScannerGetListResult) GetIo Uses

func (p *ScannerGetListResult) GetIo() *IOError

func (*ScannerGetListResult) GetSuccess Uses

func (p *ScannerGetListResult) GetSuccess() []*TRowResult_

func (*ScannerGetListResult) IsSetIa Uses

func (p *ScannerGetListResult) IsSetIa() bool

func (*ScannerGetListResult) IsSetIo Uses

func (p *ScannerGetListResult) IsSetIo() bool

func (*ScannerGetListResult) IsSetSuccess Uses

func (p *ScannerGetListResult) IsSetSuccess() bool

func (*ScannerGetListResult) Read Uses

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

func (*ScannerGetListResult) ReadField0 Uses

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

func (*ScannerGetListResult) ReadField1 Uses

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

func (*ScannerGetListResult) ReadField2 Uses

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

func (*ScannerGetListResult) String Uses

func (p *ScannerGetListResult) String() string

func (*ScannerGetListResult) Write Uses

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

type ScannerGetResult Uses

type ScannerGetResult struct {
    Success []*TRowResult_   `thrift:"success,0" db:"success" json:"success,omitempty"`
    Io      *IOError         `thrift:"io,1" db:"io" json:"io,omitempty"`
    Ia      *IllegalArgument `thrift:"ia,2" db:"ia" json:"ia,omitempty"`
}

Attributes:

- Success
- Io
- Ia

func NewScannerGetResult Uses

func NewScannerGetResult() *ScannerGetResult

func (*ScannerGetResult) GetIa Uses

func (p *ScannerGetResult) GetIa() *IllegalArgument

func (*ScannerGetResult) GetIo Uses

func (p *ScannerGetResult) GetIo() *IOError

func (*ScannerGetResult) GetSuccess Uses

func (p *ScannerGetResult) GetSuccess() []*TRowResult_

func (*ScannerGetResult) IsSetIa Uses

func (p *ScannerGetResult) IsSetIa() bool

func (*ScannerGetResult) IsSetIo Uses

func (p *ScannerGetResult) IsSetIo() bool

func (*ScannerGetResult) IsSetSuccess Uses

func (p *ScannerGetResult) IsSetSuccess() bool

func (*ScannerGetResult) Read Uses

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

func (*ScannerGetResult) ReadField0 Uses

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

func (*ScannerGetResult) ReadField1 Uses

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

func (*ScannerGetResult) ReadField2 Uses

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

func (*ScannerGetResult) String Uses

func (p *ScannerGetResult) String() string

func (*ScannerGetResult) Write Uses

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

type ScannerID Uses

type ScannerID int32
var ScannerOpenResult_Success_DEFAULT ScannerID
var ScannerOpenTsResult_Success_DEFAULT ScannerID
var ScannerOpenWithPrefixResult_Success_DEFAULT ScannerID
var ScannerOpenWithScanResult_Success_DEFAULT ScannerID
var ScannerOpenWithStopResult_Success_DEFAULT ScannerID
var ScannerOpenWithStopTsResult_Success_DEFAULT ScannerID

func ScannerIDPtr Uses

func ScannerIDPtr(v ScannerID) *ScannerID

type ScannerOpenArgs Uses

type ScannerOpenArgs struct {
    TableName  []byte            `thrift:"tableName,1" db:"tableName" json:"tableName"`
    StartRow   []byte            `thrift:"startRow,2" db:"startRow" json:"startRow"`
    Columns    [][]byte          `thrift:"columns,3" db:"columns" json:"columns"`
    Attributes map[string][]byte `thrift:"attributes,4" db:"attributes" json:"attributes"`
}

Attributes:

- TableName: name of table
- StartRow: Starting row in table to scan.

Send "" (empty string) to start at the first row.

- Columns: columns to scan. If column name is a column family, all

columns of the specified column family are returned. It's also possible to pass a regex in the column qualifier.

- Attributes: Scan attributes

func NewScannerOpenArgs Uses

func NewScannerOpenArgs() *ScannerOpenArgs

func (*ScannerOpenArgs) GetStartRow Uses

func (p *ScannerOpenArgs) GetStartRow() []byte

func (*ScannerOpenArgs) Read Uses

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

func (*ScannerOpenArgs) ReadField1 Uses

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

func (*ScannerOpenArgs) ReadField2 Uses

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

func (*ScannerOpenArgs) ReadField3 Uses

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

func (*ScannerOpenArgs) ReadField4 Uses

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

func (*ScannerOpenArgs) String Uses

func (p *ScannerOpenArgs) String() string

func (*ScannerOpenArgs) Write Uses

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

type ScannerOpenResult Uses

type ScannerOpenResult struct {
    Success *ScannerID `thrift:"success,0" db:"success" json:"success,omitempty"`
    Io      *IOError   `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

- Success
- Io

func NewScannerOpenResult Uses

func NewScannerOpenResult() *ScannerOpenResult

func (*ScannerOpenResult) GetIo Uses

func (p *ScannerOpenResult) GetIo() *IOError

func (*ScannerOpenResult) GetSuccess Uses

func (p *ScannerOpenResult) GetSuccess() ScannerID

func (*ScannerOpenResult) IsSetIo Uses

func (p *ScannerOpenResult) IsSetIo() bool

func (*ScannerOpenResult) IsSetSuccess Uses

func (p *ScannerOpenResult) IsSetSuccess() bool

func (*ScannerOpenResult) Read Uses

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

func (*ScannerOpenResult) ReadField0 Uses

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

func (*ScannerOpenResult) ReadField1 Uses

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

func (*ScannerOpenResult) String Uses

func (p *ScannerOpenResult) String() string

func (*ScannerOpenResult) Write Uses

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

type ScannerOpenTsArgs Uses

type ScannerOpenTsArgs struct {
    TableName  []byte            `thrift:"tableName,1" db:"tableName" json:"tableName"`
    StartRow   []byte            `thrift:"startRow,2" db:"startRow" json:"startRow"`
    Columns    [][]byte          `thrift:"columns,3" db:"columns" json:"columns"`
    Timestamp  int64             `thrift:"timestamp,4" db:"timestamp" json:"timestamp"`
    Attributes map[string][]byte `thrift:"attributes,5" db:"attributes" json:"attributes"`
}

Attributes:

- TableName: name of table
- StartRow: Starting row in table to scan.

Send "" (empty string) to start at the first row.

- Columns: columns to scan. If column name is a column family, all

columns of the specified column family are returned. It's also possible to pass a regex in the column qualifier.

- Timestamp: timestamp
- Attributes: Scan attributes

func NewScannerOpenTsArgs Uses

func NewScannerOpenTsArgs() *ScannerOpenTsArgs

func (*ScannerOpenTsArgs) GetStartRow Uses

func (p *ScannerOpenTsArgs) GetStartRow() []byte

func (*ScannerOpenTsArgs) Read Uses

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

func (*ScannerOpenTsArgs) ReadField1 Uses

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

func (*ScannerOpenTsArgs) ReadField2 Uses

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

func (*ScannerOpenTsArgs) ReadField3 Uses

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

func (*ScannerOpenTsArgs) ReadField4 Uses

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

func (*ScannerOpenTsArgs) ReadField5 Uses

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

func (*ScannerOpenTsArgs) String Uses

func (p *ScannerOpenTsArgs) String() string

func (*ScannerOpenTsArgs) Write Uses

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

type ScannerOpenTsResult Uses

type ScannerOpenTsResult struct {
    Success *ScannerID `thrift:"success,0" db:"success" json:"success,omitempty"`
    Io      *IOError   `thrift:"io,1" db:"io" json:"io,omitempty"`
}

Attributes:

- Success
- Io

func NewScannerOpenTsResult Uses

func NewScannerOpenTsResult() *ScannerOpenTsResult

func (*ScannerOpenTsResult) GetIo Uses

func (p *ScannerOpenTsResult) GetIo() *IOError

func (*ScannerOpenTsResult) GetSuccess Uses

func (p *ScannerOpenTsResult) GetSuccess() ScannerID

func (*ScannerOpenTsResult) IsSetIo Uses

func (p *ScannerOpenTsResult) IsSetIo() bool

func (*ScannerOpenTsResult) IsSetSuccess Uses

func (p *ScannerOpenTsResult) IsSetSuccess() bool

func (*ScannerOpenTsResult) Read Uses

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

func (*ScannerOpenTsResult) ReadField0 Uses

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

func (*ScannerOpenTsResult) ReadField1 Uses

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

func (*ScannerOpenTsResult) String Uses

func (p *ScannerOpenTsResult) String() string

func (*ScannerOpenTsResult) Write Uses

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

type ScannerOpenWithPrefixArgs Uses

type ScannerOpenWithPrefixArgs struct {
    TableName      []byte            `thrift:"tableName,1" db:"tableName" json:"tableName"`
    StartAndPrefix []byte            `thrift:"startAndPrefix,2" db:"startAndPrefix" json:"startAndPrefix"`
    Columns        [][]byte          `thrift:"columns,3" db:"columns" json:"columns"`
    Attributes     map[string][]byte `thrift:"attributes,4" db:"attributes" json:"attributes"`
}

Attributes:

- TableName: name of table
- StartAndPrefix: the prefix (and thus start row) of the keys you want
- Columns: the columns you want returned
- Attributes: Scan attributes

func NewScannerOpenWithPrefixArgs Uses

func NewScannerOpenWithPrefixArgs() *ScannerOpenWithPrefixArgs

func (*ScannerOpenWithPrefixArgs) GetStartAndPrefix