hbase

type BytesSlice [][]byte

type Column struct {
	Family []byte
	Qual   []byte
}

type ColumnCoordinate struct {
	Table []byte
	Row   []byte
	Column
}

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

type CoprocessorServiceCall struct {
	Row          []byte
	ServiceName  string
	MethodName   string
	RequestParam []byte
}

type Delete struct {
	Row         []byte
	Families    set
	FamilyQuals map[string]set
	Ts          map[string]uint64
}

type Get struct {
	Row         []byte
	Families    set
	FamilyQuals map[string]set
	Versions    int32
	TsRangeFrom uint64
	TsRangeTo   uint64
}

type HBaseClient interface {
	Get(tbl string, g *Get) (*ResultRow, error)
	Put(tbl string, p *Put) (bool, error)
	Delete(tbl string, d *Delete) (bool, error)
	TableExists(tbl string) bool
	DropTable(t TableName) error
	DisableTable(t TableName) error
	CreateTable(t *TableDescriptor, splits [][]byte) error
	ServiceCall(table string, call *CoprocessorServiceCall) (*proto.CoprocessorServiceResponse, error)
	LocateRegion(table, row []byte, useCache bool) *RegionInfo
	Close() error
}

type Kv struct {
	Row   []byte
	Ts    uint64
	Value []byte
	// history results
	Values map[uint64][]byte
	Column
}

type Put struct {
	Row        []byte
	Families   [][]byte
	Qualifiers [][][]byte
	Values     [][][]byte
}

type RegionInfo struct {
	Server         string
	StartKey       []byte
	EndKey         []byte
	Name           string
	Ts             string
	TableNamespace string
	TableName      string
	Offline        bool
	Split          bool
}

type ResultRow struct {
	Row           []byte
	Columns       map[string]*Kv
	SortedColumns []*Kv
}

type Scan struct {
	StartRow []byte
	StopRow  []byte

	MaxVersions uint32
	TsRangeFrom uint64
	TsRangeTo   uint64
	// contains filtered or unexported fields
}

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

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

type Type byte