proto

package
v0.0.0-...-07b630c Latest Latest
Warning

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

Go to latest
Published: Apr 2, 2020 License: BSD-3-Clause Imports: 2 Imported by: 0

Documentation

Overview

Package proto is a generated protocol buffer package.

It is generated from these files:

AccessControl.proto
Admin.proto
Aggregate.proto
Authentication.proto
Cell.proto
Client.proto
ClusterId.proto
ClusterStatus.proto
Comparator.proto
Encryption.proto
ErrorHandling.proto
FS.proto
Filter.proto
HBase.proto
HFile.proto
LoadBalancer.proto
MapReduce.proto
Master.proto
MultiRowMutation.proto
Quota.proto
RPC.proto
RegionServerStatus.proto
RowProcessor.proto
SecureBulkLoad.proto
Snapshot.proto
Tracing.proto
VisibilityLabels.proto
WAL.proto
ZooKeeper.proto

It has these top-level messages:

Permission
TablePermission
NamespacePermission
GlobalPermission
UserPermission
UsersAndPermissions
GrantRequest
GrantResponse
RevokeRequest
RevokeResponse
GetUserPermissionsRequest
GetUserPermissionsResponse
CheckPermissionsRequest
CheckPermissionsResponse

Index

Constants

View Source
const Default_CloseRegionRequest_TransitionIn_ZK bool = true
View Source
const Default_DispatchMergingRegionsRequest_Forcible bool = false
View Source
const Default_GetTableDescriptorsRequest_IncludeSysTables bool = false
View Source
const Default_GetTableNamesRequest_IncludeSysTables bool = false
View Source
const Default_Get_CacheBlocks bool = true
View Source
const Default_Get_ClosestRowBefore bool = false
View Source
const Default_Get_ExistenceOnly bool = false
View Source
const Default_Get_MaxVersions uint32 = 1
View Source
const Default_IsProcedureDoneResponse_Done bool = false
View Source
const Default_IsRestoreSnapshotDoneResponse_Done bool = false
View Source
const Default_IsSnapshotDoneResponse_Done bool = false
View Source
const Default_MergeRegionsRequest_Forcible bool = false
View Source
const Default_ProcedureDescription_CreationTime int64 = 0
View Source
const Default_Quotas_BypassGlobals bool = false
View Source
const Default_RegionInfo_ReplicaId int32 = 0
View Source
const Default_RegionLoadStats_HeapOccupancy int32 = 0
View Source
const Default_RegionLoadStats_MemstoreLoad int32 = 0
View Source
const Default_Result_Stale bool = false
View Source
const Default_Scan_CacheBlocks bool = true
View Source
const Default_Scan_MaxVersions uint32 = 1
View Source
const Default_Scan_Reversed bool = false
View Source
const Default_SnapshotDescription_CreationTime int64 = 0
View Source
const Default_TruncateTableRequest_PreserveSplits bool = false
View Source
const Default_UnassignRegionRequest_Force bool = false

Variables

View Source
var BitComparator_BitwiseOp_name = map[int32]string{
	1: "AND",
	2: "OR",
	3: "XOR",
}
View Source
var BitComparator_BitwiseOp_value = map[string]int32{
	"AND": 1,
	"OR":  2,
	"XOR": 3,
}
View Source
var CellType_name = map[int32]string{
	0:   "MINIMUM",
	4:   "PUT",
	8:   "DELETE",
	12:  "DELETE_COLUMN",
	14:  "DELETE_FAMILY",
	255: "MAXIMUM",
}
View Source
var CellType_value = map[string]int32{
	"MINIMUM":       0,
	"PUT":           4,
	"DELETE":        8,
	"DELETE_COLUMN": 12,
	"DELETE_FAMILY": 14,
	"MAXIMUM":       255,
}
View Source
var CompareType_name = map[int32]string{
	0: "LESS",
	1: "LESS_OR_EQUAL",
	2: "EQUAL",
	3: "NOT_EQUAL",
	4: "GREATER_OR_EQUAL",
	5: "GREATER",
	6: "NO_OP",
}
View Source
var CompareType_value = map[string]int32{
	"LESS":             0,
	"LESS_OR_EQUAL":    1,
	"EQUAL":            2,
	"NOT_EQUAL":        3,
	"GREATER_OR_EQUAL": 4,
	"GREATER":          5,
	"NO_OP":            6,
}
View Source
var Consistency_name = map[int32]string{
	0: "STRONG",
	1: "TIMELINE",
}
View Source
var Consistency_value = map[string]int32{
	"STRONG":   0,
	"TIMELINE": 1,
}
View Source
var FilterList_Operator_name = map[int32]string{
	1: "MUST_PASS_ALL",
	2: "MUST_PASS_ONE",
}
View Source
var FilterList_Operator_value = map[string]int32{
	"MUST_PASS_ALL": 1,
	"MUST_PASS_ONE": 2,
}
View Source
var FlushDescriptor_FlushAction_name = map[int32]string{
	0: "START_FLUSH",
	1: "COMMIT_FLUSH",
	2: "ABORT_FLUSH",
}
View Source
var FlushDescriptor_FlushAction_value = map[string]int32{
	"START_FLUSH":  0,
	"COMMIT_FLUSH": 1,
	"ABORT_FLUSH":  2,
}
View Source
var GetRegionInfoResponse_CompactionState_name = map[int32]string{
	0: "NONE",
	1: "MINOR",
	2: "MAJOR",
	3: "MAJOR_AND_MINOR",
}
View Source
var GetRegionInfoResponse_CompactionState_value = map[string]int32{
	"NONE":            0,
	"MINOR":           1,
	"MAJOR":           2,
	"MAJOR_AND_MINOR": 3,
}
View Source
var MutationProto_DeleteType_name = map[int32]string{
	0: "DELETE_ONE_VERSION",
	1: "DELETE_MULTIPLE_VERSIONS",
	2: "DELETE_FAMILY",
	3: "DELETE_FAMILY_VERSION",
}
View Source
var MutationProto_DeleteType_value = map[string]int32{
	"DELETE_ONE_VERSION":       0,
	"DELETE_MULTIPLE_VERSIONS": 1,
	"DELETE_FAMILY":            2,
	"DELETE_FAMILY_VERSION":    3,
}
View Source
var MutationProto_Durability_name = map[int32]string{
	0: "USE_DEFAULT",
	1: "SKIP_WAL",
	2: "ASYNC_WAL",
	3: "SYNC_WAL",
	4: "FSYNC_WAL",
}
View Source
var MutationProto_Durability_value = map[string]int32{
	"USE_DEFAULT": 0,
	"SKIP_WAL":    1,
	"ASYNC_WAL":   2,
	"SYNC_WAL":    3,
	"FSYNC_WAL":   4,
}
View Source
var MutationProto_MutationType_name = map[int32]string{
	0: "APPEND",
	1: "INCREMENT",
	2: "PUT",
	3: "DELETE",
}
View Source
var MutationProto_MutationType_value = map[string]int32{
	"APPEND":    0,
	"INCREMENT": 1,
	"PUT":       2,
	"DELETE":    3,
}
View Source
var OpenRegionResponse_RegionOpeningState_name = map[int32]string{
	0: "OPENED",
	1: "ALREADY_OPENED",
	2: "FAILED_OPENING",
}
View Source
var OpenRegionResponse_RegionOpeningState_value = map[string]int32{
	"OPENED":         0,
	"ALREADY_OPENED": 1,
	"FAILED_OPENING": 2,
}
View Source
var Permission_Action_name = map[int32]string{
	0: "READ",
	1: "WRITE",
	2: "EXEC",
	3: "CREATE",
	4: "ADMIN",
}
View Source
var Permission_Action_value = map[string]int32{
	"READ":   0,
	"WRITE":  1,
	"EXEC":   2,
	"CREATE": 3,
	"ADMIN":  4,
}
View Source
var Permission_Type_name = map[int32]string{
	1: "Global",
	2: "Namespace",
	3: "Table",
}
View Source
var Permission_Type_value = map[string]int32{
	"Global":    1,
	"Namespace": 2,
	"Table":     3,
}
View Source
var QuotaScope_name = map[int32]string{
	1: "CLUSTER",
	2: "MACHINE",
}
View Source
var QuotaScope_value = map[string]int32{
	"CLUSTER": 1,
	"MACHINE": 2,
}
View Source
var QuotaType_name = map[int32]string{
	1: "THROTTLE",
}
View Source
var QuotaType_value = map[string]int32{
	"THROTTLE": 1,
}
View Source
var Reference_Range_name = map[int32]string{
	0: "TOP",
	1: "BOTTOM",
}
View Source
var Reference_Range_value = map[string]int32{
	"TOP":    0,
	"BOTTOM": 1,
}
View Source
var RegionEventDescriptor_EventType_name = map[int32]string{
	0: "REGION_OPEN",
	1: "REGION_CLOSE",
}
View Source
var RegionEventDescriptor_EventType_value = map[string]int32{
	"REGION_OPEN":  0,
	"REGION_CLOSE": 1,
}
View Source
var RegionSpecifier_RegionSpecifierType_name = map[int32]string{
	1: "REGION_NAME",
	2: "ENCODED_REGION_NAME",
}
View Source
var RegionSpecifier_RegionSpecifierType_value = map[string]int32{
	"REGION_NAME":         1,
	"ENCODED_REGION_NAME": 2,
}
View Source
var RegionStateTransition_TransitionCode_name = map[int32]string{
	0:  "OPENED",
	1:  "FAILED_OPEN",
	2:  "CLOSED",
	3:  "READY_TO_SPLIT",
	4:  "READY_TO_MERGE",
	5:  "SPLIT_PONR",
	6:  "MERGE_PONR",
	7:  "SPLIT",
	8:  "MERGED",
	9:  "SPLIT_REVERTED",
	10: "MERGE_REVERTED",
}
View Source
var RegionStateTransition_TransitionCode_value = map[string]int32{
	"OPENED":         0,
	"FAILED_OPEN":    1,
	"CLOSED":         2,
	"READY_TO_SPLIT": 3,
	"READY_TO_MERGE": 4,
	"SPLIT_PONR":     5,
	"MERGE_PONR":     6,
	"SPLIT":          7,
	"MERGED":         8,
	"SPLIT_REVERTED": 9,
	"MERGE_REVERTED": 10,
}
View Source
var RegionState_State_name = map[int32]string{
	0:  "OFFLINE",
	1:  "PENDING_OPEN",
	2:  "OPENING",
	3:  "OPEN",
	4:  "PENDING_CLOSE",
	5:  "CLOSING",
	6:  "CLOSED",
	7:  "SPLITTING",
	8:  "SPLIT",
	9:  "FAILED_OPEN",
	10: "FAILED_CLOSE",
	11: "MERGING",
	12: "MERGED",
	13: "SPLITTING_NEW",
	14: "MERGING_NEW",
}
View Source
var RegionState_State_value = map[string]int32{
	"OFFLINE":       0,
	"PENDING_OPEN":  1,
	"OPENING":       2,
	"OPEN":          3,
	"PENDING_CLOSE": 4,
	"CLOSING":       5,
	"CLOSED":        6,
	"SPLITTING":     7,
	"SPLIT":         8,
	"FAILED_OPEN":   9,
	"FAILED_CLOSE":  10,
	"MERGING":       11,
	"MERGED":        12,
	"SPLITTING_NEW": 13,
	"MERGING_NEW":   14,
}
View Source
var ReplicationState_State_name = map[int32]string{
	0: "ENABLED",
	1: "DISABLED",
}
View Source
var ReplicationState_State_value = map[string]int32{
	"ENABLED":  0,
	"DISABLED": 1,
}
View Source
var ScopeType_name = map[int32]string{
	0: "REPLICATION_SCOPE_LOCAL",
	1: "REPLICATION_SCOPE_GLOBAL",
}
View Source
var ScopeType_value = map[string]int32{
	"REPLICATION_SCOPE_LOCAL":  0,
	"REPLICATION_SCOPE_GLOBAL": 1,
}
View Source
var SnapshotDescription_Type_name = map[int32]string{
	0: "DISABLED",
	1: "FLUSH",
	2: "SKIPFLUSH",
}
View Source
var SnapshotDescription_Type_value = map[string]int32{
	"DISABLED":  0,
	"FLUSH":     1,
	"SKIPFLUSH": 2,
}
View Source
var SnapshotFileInfo_Type_name = map[int32]string{
	1: "HFILE",
	2: "WAL",
}
View Source
var SnapshotFileInfo_Type_value = map[string]int32{
	"HFILE": 1,
	"WAL":   2,
}
View Source
var SplitLogTask_RecoveryMode_name = map[int32]string{
	0: "UNKNOWN",
	1: "LOG_SPLITTING",
	2: "LOG_REPLAY",
}
View Source
var SplitLogTask_RecoveryMode_value = map[string]int32{
	"UNKNOWN":       0,
	"LOG_SPLITTING": 1,
	"LOG_REPLAY":    2,
}
View Source
var SplitLogTask_State_name = map[int32]string{
	0: "UNASSIGNED",
	1: "OWNED",
	2: "RESIGNED",
	3: "DONE",
	4: "ERR",
}
View Source
var SplitLogTask_State_value = map[string]int32{
	"UNASSIGNED": 0,
	"OWNED":      1,
	"RESIGNED":   2,
	"DONE":       3,
	"ERR":        4,
}
View Source
var Table_State_name = map[int32]string{
	0: "ENABLED",
	1: "DISABLED",
	2: "DISABLING",
	3: "ENABLING",
}
View Source
var Table_State_value = map[string]int32{
	"ENABLED":   0,
	"DISABLED":  1,
	"DISABLING": 2,
	"ENABLING":  3,
}
View Source
var ThrottleType_name = map[int32]string{
	1: "REQUEST_NUMBER",
	2: "REQUEST_SIZE",
	3: "WRITE_NUMBER",
	4: "WRITE_SIZE",
	5: "READ_NUMBER",
	6: "READ_SIZE",
}
View Source
var ThrottleType_value = map[string]int32{
	"REQUEST_NUMBER": 1,
	"REQUEST_SIZE":   2,
	"WRITE_NUMBER":   3,
	"WRITE_SIZE":     4,
	"READ_NUMBER":    5,
	"READ_SIZE":      6,
}
View Source
var TimeUnit_name = map[int32]string{
	1: "NANOSECONDS",
	2: "MICROSECONDS",
	3: "MILLISECONDS",
	4: "SECONDS",
	5: "MINUTES",
	6: "HOURS",
	7: "DAYS",
}
View Source
var TimeUnit_value = map[string]int32{
	"NANOSECONDS":  1,
	"MICROSECONDS": 2,
	"MILLISECONDS": 3,
	"SECONDS":      4,
	"MINUTES":      5,
	"HOURS":        6,
	"DAYS":         7,
}
View Source
var TokenIdentifier_Kind_name = map[int32]string{
	0: "HBASE_AUTH_TOKEN",
}
View Source
var TokenIdentifier_Kind_value = map[string]int32{
	"HBASE_AUTH_TOKEN": 0,
}

Functions

This section is empty.

Types

type Action

type Action struct {
	// If part of a multi action, useful aligning
	// result with what was originally submitted.
	Index            *uint32                 `protobuf:"varint,1,opt,name=index" json:"index,omitempty"`
	Mutation         *MutationProto          `protobuf:"bytes,2,opt,name=mutation" json:"mutation,omitempty"`
	Get              *Get                    `protobuf:"bytes,3,opt,name=get" json:"get,omitempty"`
	ServiceCall      *CoprocessorServiceCall `protobuf:"bytes,4,opt,name=service_call" json:"service_call,omitempty"`
	XXX_unrecognized []byte                  `json:"-"`
}

Either a Get or a Mutation

func (*Action) GetGet

func (m *Action) GetGet() *Get

func (*Action) GetIndex

func (m *Action) GetIndex() uint32

func (*Action) GetMutation

func (m *Action) GetMutation() *MutationProto

func (*Action) GetServiceCall

func (m *Action) GetServiceCall() *CoprocessorServiceCall

func (*Action) ProtoMessage

func (*Action) ProtoMessage()

func (*Action) Reset

func (m *Action) Reset()

func (*Action) String

func (m *Action) String() string

type AddColumnRequest

type AddColumnRequest struct {
	TableName        *TableName          `protobuf:"bytes,1,req,name=table_name" json:"table_name,omitempty"`
	ColumnFamilies   *ColumnFamilySchema `protobuf:"bytes,2,req,name=column_families" json:"column_families,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

func (*AddColumnRequest) GetColumnFamilies

func (m *AddColumnRequest) GetColumnFamilies() *ColumnFamilySchema

func (*AddColumnRequest) GetTableName

func (m *AddColumnRequest) GetTableName() *TableName

func (*AddColumnRequest) ProtoMessage

func (*AddColumnRequest) ProtoMessage()

func (*AddColumnRequest) Reset

func (m *AddColumnRequest) Reset()

func (*AddColumnRequest) String

func (m *AddColumnRequest) String() string

type AddColumnResponse

type AddColumnResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*AddColumnResponse) ProtoMessage

func (*AddColumnResponse) ProtoMessage()

func (*AddColumnResponse) Reset

func (m *AddColumnResponse) Reset()

func (*AddColumnResponse) String

func (m *AddColumnResponse) String() string

type AggregateRequest

type AggregateRequest struct {
	// * The request passed to the AggregateService consists of three parts
	//  (1) the (canonical) classname of the ColumnInterpreter implementation
	//  (2) the Scan query
	//  (3) any bytes required to construct the ColumnInterpreter object
	//      properly
	InterpreterClassName     *string `protobuf:"bytes,1,req,name=interpreter_class_name" json:"interpreter_class_name,omitempty"`
	Scan                     *Scan   `protobuf:"bytes,2,req,name=scan" json:"scan,omitempty"`
	InterpreterSpecificBytes []byte  `protobuf:"bytes,3,opt,name=interpreter_specific_bytes" json:"interpreter_specific_bytes,omitempty"`
	XXX_unrecognized         []byte  `json:"-"`
}

func (*AggregateRequest) GetInterpreterClassName

func (m *AggregateRequest) GetInterpreterClassName() string

func (*AggregateRequest) GetInterpreterSpecificBytes

func (m *AggregateRequest) GetInterpreterSpecificBytes() []byte

func (*AggregateRequest) GetScan

func (m *AggregateRequest) GetScan() *Scan

func (*AggregateRequest) ProtoMessage

func (*AggregateRequest) ProtoMessage()

func (*AggregateRequest) Reset

func (m *AggregateRequest) Reset()

func (*AggregateRequest) String

func (m *AggregateRequest) String() string

type AggregateResponse

type AggregateResponse struct {
	// *
	// The AggregateService methods all have a response that either is a Pair
	// or a simple object. When it is a Pair both first_part and second_part
	// have defined values (and the second_part is not present in the response
	// when the response is not a pair). Refer to the AggregateImplementation
	// class for an overview of the AggregateResponse object constructions.
	FirstPart        [][]byte `protobuf:"bytes,1,rep,name=first_part" json:"first_part,omitempty"`
	SecondPart       []byte   `protobuf:"bytes,2,opt,name=second_part" json:"second_part,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*AggregateResponse) GetFirstPart

func (m *AggregateResponse) GetFirstPart() [][]byte

func (*AggregateResponse) GetSecondPart

func (m *AggregateResponse) GetSecondPart() []byte

func (*AggregateResponse) ProtoMessage

func (*AggregateResponse) ProtoMessage()

func (*AggregateResponse) Reset

func (m *AggregateResponse) Reset()

func (*AggregateResponse) String

func (m *AggregateResponse) String() string

type AssignRegionRequest

type AssignRegionRequest struct {
	Region           *RegionSpecifier `protobuf:"bytes,1,req,name=region" json:"region,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*AssignRegionRequest) GetRegion

func (m *AssignRegionRequest) GetRegion() *RegionSpecifier

func (*AssignRegionRequest) ProtoMessage

func (*AssignRegionRequest) ProtoMessage()

func (*AssignRegionRequest) Reset

func (m *AssignRegionRequest) Reset()

func (*AssignRegionRequest) String

func (m *AssignRegionRequest) String() string

type AssignRegionResponse

type AssignRegionResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*AssignRegionResponse) ProtoMessage

func (*AssignRegionResponse) ProtoMessage()

func (*AssignRegionResponse) Reset

func (m *AssignRegionResponse) Reset()

func (*AssignRegionResponse) String

func (m *AssignRegionResponse) String() string

type AuthenticationKey

type AuthenticationKey struct {
	Id               *int32 `protobuf:"varint,1,req,name=id" json:"id,omitempty"`
	ExpirationDate   *int64 `protobuf:"varint,2,req,name=expiration_date" json:"expiration_date,omitempty"`
	Key              []byte `protobuf:"bytes,3,req,name=key" json:"key,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*AuthenticationKey) GetExpirationDate

func (m *AuthenticationKey) GetExpirationDate() int64

func (*AuthenticationKey) GetId

func (m *AuthenticationKey) GetId() int32

func (*AuthenticationKey) GetKey

func (m *AuthenticationKey) GetKey() []byte

func (*AuthenticationKey) ProtoMessage

func (*AuthenticationKey) ProtoMessage()

func (*AuthenticationKey) Reset

func (m *AuthenticationKey) Reset()

func (*AuthenticationKey) String

func (m *AuthenticationKey) String() string

type Authorizations

type Authorizations struct {
	Label            []string `protobuf:"bytes,1,rep,name=label" json:"label,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

* The protocol buffer version of Authorizations.

func (*Authorizations) GetLabel

func (m *Authorizations) GetLabel() []string

func (*Authorizations) ProtoMessage

func (*Authorizations) ProtoMessage()

func (*Authorizations) Reset

func (m *Authorizations) Reset()

func (*Authorizations) String

func (m *Authorizations) String() string

type BalanceRequest

type BalanceRequest struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*BalanceRequest) ProtoMessage

func (*BalanceRequest) ProtoMessage()

func (*BalanceRequest) Reset

func (m *BalanceRequest) Reset()

func (*BalanceRequest) String

func (m *BalanceRequest) String() string

type BalanceResponse

type BalanceResponse struct {
	BalancerRan      *bool  `protobuf:"varint,1,req,name=balancer_ran" json:"balancer_ran,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*BalanceResponse) GetBalancerRan

func (m *BalanceResponse) GetBalancerRan() bool

func (*BalanceResponse) ProtoMessage

func (*BalanceResponse) ProtoMessage()

func (*BalanceResponse) Reset

func (m *BalanceResponse) Reset()

func (*BalanceResponse) String

func (m *BalanceResponse) String() string

type BigDecimalMsg

type BigDecimalMsg struct {
	BigdecimalMsg    []byte `protobuf:"bytes,1,req,name=bigdecimal_msg" json:"bigdecimal_msg,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*BigDecimalMsg) GetBigdecimalMsg

func (m *BigDecimalMsg) GetBigdecimalMsg() []byte

func (*BigDecimalMsg) ProtoMessage

func (*BigDecimalMsg) ProtoMessage()

func (*BigDecimalMsg) Reset

func (m *BigDecimalMsg) Reset()

func (*BigDecimalMsg) String

func (m *BigDecimalMsg) String() string

type BinaryComparator

type BinaryComparator struct {
	Comparable       *ByteArrayComparable `protobuf:"bytes,1,req,name=comparable" json:"comparable,omitempty"`
	XXX_unrecognized []byte               `json:"-"`
}

func (*BinaryComparator) GetComparable

func (m *BinaryComparator) GetComparable() *ByteArrayComparable

func (*BinaryComparator) ProtoMessage

func (*BinaryComparator) ProtoMessage()

func (*BinaryComparator) Reset

func (m *BinaryComparator) Reset()

func (*BinaryComparator) String

func (m *BinaryComparator) String() string

type BinaryPrefixComparator

type BinaryPrefixComparator struct {
	Comparable       *ByteArrayComparable `protobuf:"bytes,1,req,name=comparable" json:"comparable,omitempty"`
	XXX_unrecognized []byte               `json:"-"`
}

func (*BinaryPrefixComparator) GetComparable

func (m *BinaryPrefixComparator) GetComparable() *ByteArrayComparable

func (*BinaryPrefixComparator) ProtoMessage

func (*BinaryPrefixComparator) ProtoMessage()

func (*BinaryPrefixComparator) Reset

func (m *BinaryPrefixComparator) Reset()

func (*BinaryPrefixComparator) String

func (m *BinaryPrefixComparator) String() string

type BitComparator

type BitComparator struct {
	Comparable       *ByteArrayComparable     `protobuf:"bytes,1,req,name=comparable" json:"comparable,omitempty"`
	BitwiseOp        *BitComparator_BitwiseOp `protobuf:"varint,2,req,name=bitwise_op,enum=proto.BitComparator_BitwiseOp" json:"bitwise_op,omitempty"`
	XXX_unrecognized []byte                   `json:"-"`
}

func (*BitComparator) GetBitwiseOp

func (m *BitComparator) GetBitwiseOp() BitComparator_BitwiseOp

func (*BitComparator) GetComparable

func (m *BitComparator) GetComparable() *ByteArrayComparable

func (*BitComparator) ProtoMessage

func (*BitComparator) ProtoMessage()

func (*BitComparator) Reset

func (m *BitComparator) Reset()

func (*BitComparator) String

func (m *BitComparator) String() string

type BitComparator_BitwiseOp

type BitComparator_BitwiseOp int32
const (
	BitComparator_AND BitComparator_BitwiseOp = 1
	BitComparator_OR  BitComparator_BitwiseOp = 2
	BitComparator_XOR BitComparator_BitwiseOp = 3
)

func (BitComparator_BitwiseOp) Enum

func (BitComparator_BitwiseOp) String

func (x BitComparator_BitwiseOp) String() string

func (*BitComparator_BitwiseOp) UnmarshalJSON

func (x *BitComparator_BitwiseOp) UnmarshalJSON(data []byte) error

type BulkLoadDescriptor

type BulkLoadDescriptor struct {
	TableName         *TableName         `protobuf:"bytes,1,req,name=table_name" json:"table_name,omitempty"`
	EncodedRegionName []byte             `protobuf:"bytes,2,req,name=encoded_region_name" json:"encoded_region_name,omitempty"`
	Stores            []*StoreDescriptor `protobuf:"bytes,3,rep,name=stores" json:"stores,omitempty"`
	BulkloadSeqNum    *int64             `protobuf:"varint,4,req,name=bulkload_seq_num" json:"bulkload_seq_num,omitempty"`
	XXX_unrecognized  []byte             `json:"-"`
}

* Special WAL entry used for writing bulk load events to WAL

func (*BulkLoadDescriptor) GetBulkloadSeqNum

func (m *BulkLoadDescriptor) GetBulkloadSeqNum() int64

func (*BulkLoadDescriptor) GetEncodedRegionName

func (m *BulkLoadDescriptor) GetEncodedRegionName() []byte

func (*BulkLoadDescriptor) GetStores

func (m *BulkLoadDescriptor) GetStores() []*StoreDescriptor

func (*BulkLoadDescriptor) GetTableName

func (m *BulkLoadDescriptor) GetTableName() *TableName

func (*BulkLoadDescriptor) ProtoMessage

func (*BulkLoadDescriptor) ProtoMessage()

func (*BulkLoadDescriptor) Reset

func (m *BulkLoadDescriptor) Reset()

func (*BulkLoadDescriptor) String

func (m *BulkLoadDescriptor) String() string

type BulkLoadHFileRequest

type BulkLoadHFileRequest struct {
	Region           *RegionSpecifier                   `protobuf:"bytes,1,req,name=region" json:"region,omitempty"`
	FamilyPath       []*BulkLoadHFileRequest_FamilyPath `protobuf:"bytes,2,rep,name=family_path" json:"family_path,omitempty"`
	AssignSeqNum     *bool                              `protobuf:"varint,3,opt,name=assign_seq_num" json:"assign_seq_num,omitempty"`
	XXX_unrecognized []byte                             `json:"-"`
}

* Atomically bulk load multiple HFiles (say from different column families) into an open region.

func (*BulkLoadHFileRequest) GetAssignSeqNum

func (m *BulkLoadHFileRequest) GetAssignSeqNum() bool

func (*BulkLoadHFileRequest) GetFamilyPath

func (*BulkLoadHFileRequest) GetRegion

func (m *BulkLoadHFileRequest) GetRegion() *RegionSpecifier

func (*BulkLoadHFileRequest) ProtoMessage

func (*BulkLoadHFileRequest) ProtoMessage()

func (*BulkLoadHFileRequest) Reset

func (m *BulkLoadHFileRequest) Reset()

func (*BulkLoadHFileRequest) String

func (m *BulkLoadHFileRequest) String() string

type BulkLoadHFileRequest_FamilyPath

type BulkLoadHFileRequest_FamilyPath struct {
	Family           []byte  `protobuf:"bytes,1,req,name=family" json:"family,omitempty"`
	Path             *string `protobuf:"bytes,2,req,name=path" json:"path,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*BulkLoadHFileRequest_FamilyPath) GetFamily

func (m *BulkLoadHFileRequest_FamilyPath) GetFamily() []byte

func (*BulkLoadHFileRequest_FamilyPath) GetPath

func (*BulkLoadHFileRequest_FamilyPath) ProtoMessage

func (*BulkLoadHFileRequest_FamilyPath) ProtoMessage()

func (*BulkLoadHFileRequest_FamilyPath) Reset

func (*BulkLoadHFileRequest_FamilyPath) String

type BulkLoadHFileResponse

type BulkLoadHFileResponse struct {
	Loaded           *bool  `protobuf:"varint,1,req,name=loaded" json:"loaded,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*BulkLoadHFileResponse) GetLoaded

func (m *BulkLoadHFileResponse) GetLoaded() bool

func (*BulkLoadHFileResponse) ProtoMessage

func (*BulkLoadHFileResponse) ProtoMessage()

func (*BulkLoadHFileResponse) Reset

func (m *BulkLoadHFileResponse) Reset()

func (*BulkLoadHFileResponse) String

func (m *BulkLoadHFileResponse) String() string

type ByteArrayComparable

type ByteArrayComparable struct {
	Value            []byte `protobuf:"bytes,1,opt,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*ByteArrayComparable) GetValue

func (m *ByteArrayComparable) GetValue() []byte

func (*ByteArrayComparable) ProtoMessage

func (*ByteArrayComparable) ProtoMessage()

func (*ByteArrayComparable) Reset

func (m *ByteArrayComparable) Reset()

func (*ByteArrayComparable) String

func (m *ByteArrayComparable) String() string

type BytesBytesPair

type BytesBytesPair struct {
	First            []byte `protobuf:"bytes,1,req,name=first" json:"first,omitempty"`
	Second           []byte `protobuf:"bytes,2,req,name=second" json:"second,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*BytesBytesPair) GetFirst

func (m *BytesBytesPair) GetFirst() []byte

func (*BytesBytesPair) GetSecond

func (m *BytesBytesPair) GetSecond() []byte

func (*BytesBytesPair) ProtoMessage

func (*BytesBytesPair) ProtoMessage()

func (*BytesBytesPair) Reset

func (m *BytesBytesPair) Reset()

func (*BytesBytesPair) String

func (m *BytesBytesPair) String() string

type Cell

type Cell struct {
	Row              []byte    `protobuf:"bytes,1,opt,name=row" json:"row,omitempty"`
	Family           []byte    `protobuf:"bytes,2,opt,name=family" json:"family,omitempty"`
	Qualifier        []byte    `protobuf:"bytes,3,opt,name=qualifier" json:"qualifier,omitempty"`
	Timestamp        *uint64   `protobuf:"varint,4,opt,name=timestamp" json:"timestamp,omitempty"`
	CellType         *CellType `protobuf:"varint,5,opt,name=cell_type,enum=proto.CellType" json:"cell_type,omitempty"`
	Value            []byte    `protobuf:"bytes,6,opt,name=value" json:"value,omitempty"`
	Tags             []byte    `protobuf:"bytes,7,opt,name=tags" json:"tags,omitempty"`
	XXX_unrecognized []byte    `json:"-"`
}

* Protocol buffer version of Cell.

func (*Cell) GetCellType

func (m *Cell) GetCellType() CellType

func (*Cell) GetFamily

func (m *Cell) GetFamily() []byte

func (*Cell) GetQualifier

func (m *Cell) GetQualifier() []byte

func (*Cell) GetRow

func (m *Cell) GetRow() []byte

func (*Cell) GetTags

func (m *Cell) GetTags() []byte

func (*Cell) GetTimestamp

func (m *Cell) GetTimestamp() uint64

func (*Cell) GetValue

func (m *Cell) GetValue() []byte

func (*Cell) ProtoMessage

func (*Cell) ProtoMessage()

func (*Cell) Reset

func (m *Cell) Reset()

func (*Cell) String

func (m *Cell) String() string

type CellBlockMeta

type CellBlockMeta struct {
	// Length of the following cell block.  Could calculate it but convenient having it too hand.
	Length           *uint32 `protobuf:"varint,1,opt,name=length" json:"length,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

Optional Cell block Message. Included in client RequestHeader

func (*CellBlockMeta) GetLength

func (m *CellBlockMeta) GetLength() uint32

func (*CellBlockMeta) ProtoMessage

func (*CellBlockMeta) ProtoMessage()

func (*CellBlockMeta) Reset

func (m *CellBlockMeta) Reset()

func (*CellBlockMeta) String

func (m *CellBlockMeta) String() string

type CellType

type CellType int32

* The type of the key in a Cell

const (
	CellType_MINIMUM       CellType = 0
	CellType_PUT           CellType = 4
	CellType_DELETE        CellType = 8
	CellType_DELETE_COLUMN CellType = 12
	CellType_DELETE_FAMILY CellType = 14
	// MAXIMUM is used when searching; you look from maximum on down.
	CellType_MAXIMUM CellType = 255
)

func (CellType) Enum

func (x CellType) Enum() *CellType

func (CellType) String

func (x CellType) String() string

func (*CellType) UnmarshalJSON

func (x *CellType) UnmarshalJSON(data []byte) error

type CellVisibility

type CellVisibility struct {
	Expression       *string `protobuf:"bytes,1,req,name=expression" json:"expression,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* The protocol buffer version of CellVisibility.

func (*CellVisibility) GetExpression

func (m *CellVisibility) GetExpression() string

func (*CellVisibility) ProtoMessage

func (*CellVisibility) ProtoMessage()

func (*CellVisibility) Reset

func (m *CellVisibility) Reset()

func (*CellVisibility) String

func (m *CellVisibility) String() string

type CheckPermissionsRequest

type CheckPermissionsRequest struct {
	Permission       []*Permission `protobuf:"bytes,1,rep,name=permission" json:"permission,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*CheckPermissionsRequest) GetPermission

func (m *CheckPermissionsRequest) GetPermission() []*Permission

func (*CheckPermissionsRequest) ProtoMessage

func (*CheckPermissionsRequest) ProtoMessage()

func (*CheckPermissionsRequest) Reset

func (m *CheckPermissionsRequest) Reset()

func (*CheckPermissionsRequest) String

func (m *CheckPermissionsRequest) String() string

type CheckPermissionsResponse

type CheckPermissionsResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*CheckPermissionsResponse) ProtoMessage

func (*CheckPermissionsResponse) ProtoMessage()

func (*CheckPermissionsResponse) Reset

func (m *CheckPermissionsResponse) Reset()

func (*CheckPermissionsResponse) String

func (m *CheckPermissionsResponse) String() string

type CleanupBulkLoadRequest

type CleanupBulkLoadRequest struct {
	BulkToken        *string `protobuf:"bytes,1,req,name=bulk_token" json:"bulk_token,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*CleanupBulkLoadRequest) GetBulkToken

func (m *CleanupBulkLoadRequest) GetBulkToken() string

func (*CleanupBulkLoadRequest) ProtoMessage

func (*CleanupBulkLoadRequest) ProtoMessage()

func (*CleanupBulkLoadRequest) Reset

func (m *CleanupBulkLoadRequest) Reset()

func (*CleanupBulkLoadRequest) String

func (m *CleanupBulkLoadRequest) String() string

type CleanupBulkLoadResponse

type CleanupBulkLoadResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*CleanupBulkLoadResponse) ProtoMessage

func (*CleanupBulkLoadResponse) ProtoMessage()

func (*CleanupBulkLoadResponse) Reset

func (m *CleanupBulkLoadResponse) Reset()

func (*CleanupBulkLoadResponse) String

func (m *CleanupBulkLoadResponse) String() string

type CloseRegionRequest

type CloseRegionRequest struct {
	Region               *RegionSpecifier `protobuf:"bytes,1,req,name=region" json:"region,omitempty"`
	VersionOfClosingNode *uint32          `protobuf:"varint,2,opt,name=version_of_closing_node" json:"version_of_closing_node,omitempty"`
	TransitionIn_ZK      *bool            `protobuf:"varint,3,opt,name=transition_in_ZK,def=1" json:"transition_in_ZK,omitempty"`
	DestinationServer    *ServerName      `protobuf:"bytes,4,opt,name=destination_server" json:"destination_server,omitempty"`
	// the intended server for this RPC.
	ServerStartCode  *uint64 `protobuf:"varint,5,opt,name=serverStartCode" json:"serverStartCode,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Closes the specified region and will use or not use ZK during the close according to the specified flag.

func (*CloseRegionRequest) GetDestinationServer

func (m *CloseRegionRequest) GetDestinationServer() *ServerName

func (*CloseRegionRequest) GetRegion

func (m *CloseRegionRequest) GetRegion() *RegionSpecifier

func (*CloseRegionRequest) GetServerStartCode

func (m *CloseRegionRequest) GetServerStartCode() uint64

func (*CloseRegionRequest) GetTransitionIn_ZK

func (m *CloseRegionRequest) GetTransitionIn_ZK() bool

func (*CloseRegionRequest) GetVersionOfClosingNode

func (m *CloseRegionRequest) GetVersionOfClosingNode() uint32

func (*CloseRegionRequest) ProtoMessage

func (*CloseRegionRequest) ProtoMessage()

func (*CloseRegionRequest) Reset

func (m *CloseRegionRequest) Reset()

func (*CloseRegionRequest) String

func (m *CloseRegionRequest) String() string

type CloseRegionResponse

type CloseRegionResponse struct {
	Closed           *bool  `protobuf:"varint,1,req,name=closed" json:"closed,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*CloseRegionResponse) GetClosed

func (m *CloseRegionResponse) GetClosed() bool

func (*CloseRegionResponse) ProtoMessage

func (*CloseRegionResponse) ProtoMessage()

func (*CloseRegionResponse) Reset

func (m *CloseRegionResponse) Reset()

func (*CloseRegionResponse) String

func (m *CloseRegionResponse) String() string

type ClusterId

type ClusterId struct {
	// This is the cluster id, a uuid as a String
	ClusterId        *string `protobuf:"bytes,1,req,name=cluster_id" json:"cluster_id,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Content of the '/hbase/hbaseid', cluster id, znode. Also cluster of the ${HBASE_ROOTDIR}/hbase.id file.

func (*ClusterId) GetClusterId

func (m *ClusterId) GetClusterId() string

func (*ClusterId) ProtoMessage

func (*ClusterId) ProtoMessage()

func (*ClusterId) Reset

func (m *ClusterId) Reset()

func (*ClusterId) String

func (m *ClusterId) String() string

type ClusterStatus

type ClusterStatus struct {
	HbaseVersion        *HBaseVersionFileContent `protobuf:"bytes,1,opt,name=hbase_version" json:"hbase_version,omitempty"`
	LiveServers         []*LiveServerInfo        `protobuf:"bytes,2,rep,name=live_servers" json:"live_servers,omitempty"`
	DeadServers         []*ServerName            `protobuf:"bytes,3,rep,name=dead_servers" json:"dead_servers,omitempty"`
	RegionsInTransition []*RegionInTransition    `protobuf:"bytes,4,rep,name=regions_in_transition" json:"regions_in_transition,omitempty"`
	ClusterId           *ClusterId               `protobuf:"bytes,5,opt,name=cluster_id" json:"cluster_id,omitempty"`
	MasterCoprocessors  []*Coprocessor           `protobuf:"bytes,6,rep,name=master_coprocessors" json:"master_coprocessors,omitempty"`
	Master              *ServerName              `protobuf:"bytes,7,opt,name=master" json:"master,omitempty"`
	BackupMasters       []*ServerName            `protobuf:"bytes,8,rep,name=backup_masters" json:"backup_masters,omitempty"`
	BalancerOn          *bool                    `protobuf:"varint,9,opt,name=balancer_on" json:"balancer_on,omitempty"`
	XXX_unrecognized    []byte                   `json:"-"`
}

func (*ClusterStatus) GetBackupMasters

func (m *ClusterStatus) GetBackupMasters() []*ServerName

func (*ClusterStatus) GetBalancerOn

func (m *ClusterStatus) GetBalancerOn() bool

func (*ClusterStatus) GetClusterId

func (m *ClusterStatus) GetClusterId() *ClusterId

func (*ClusterStatus) GetDeadServers

func (m *ClusterStatus) GetDeadServers() []*ServerName

func (*ClusterStatus) GetHbaseVersion

func (m *ClusterStatus) GetHbaseVersion() *HBaseVersionFileContent

func (*ClusterStatus) GetLiveServers

func (m *ClusterStatus) GetLiveServers() []*LiveServerInfo

func (*ClusterStatus) GetMaster

func (m *ClusterStatus) GetMaster() *ServerName

func (*ClusterStatus) GetMasterCoprocessors

func (m *ClusterStatus) GetMasterCoprocessors() []*Coprocessor

func (*ClusterStatus) GetRegionsInTransition

func (m *ClusterStatus) GetRegionsInTransition() []*RegionInTransition

func (*ClusterStatus) ProtoMessage

func (*ClusterStatus) ProtoMessage()

func (*ClusterStatus) Reset

func (m *ClusterStatus) Reset()

func (*ClusterStatus) String

func (m *ClusterStatus) String() string

type ClusterUp

type ClusterUp struct {
	// If this znode is present, cluster is up.  Currently
	// the data is cluster start_date.
	StartDate        *string `protobuf:"bytes,1,req,name=start_date" json:"start_date,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Content of the '/hbase/running', cluster state, znode.

func (*ClusterUp) GetStartDate

func (m *ClusterUp) GetStartDate() string

func (*ClusterUp) ProtoMessage

func (*ClusterUp) ProtoMessage()

func (*ClusterUp) Reset

func (m *ClusterUp) Reset()

func (*ClusterUp) String

func (m *ClusterUp) String() string

type Column

type Column struct {
	Family           []byte   `protobuf:"bytes,1,req,name=family" json:"family,omitempty"`
	Qualifier        [][]byte `protobuf:"bytes,2,rep,name=qualifier" json:"qualifier,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

* Container for a list of column qualifier names of a family.

func (*Column) GetFamily

func (m *Column) GetFamily() []byte

func (*Column) GetQualifier

func (m *Column) GetQualifier() [][]byte

func (*Column) ProtoMessage

func (*Column) ProtoMessage()

func (*Column) Reset

func (m *Column) Reset()

func (*Column) String

func (m *Column) String() string

type ColumnCountGetFilter

type ColumnCountGetFilter struct {
	Limit            *int32 `protobuf:"varint,1,req,name=limit" json:"limit,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*ColumnCountGetFilter) GetLimit

func (m *ColumnCountGetFilter) GetLimit() int32

func (*ColumnCountGetFilter) ProtoMessage

func (*ColumnCountGetFilter) ProtoMessage()

func (*ColumnCountGetFilter) Reset

func (m *ColumnCountGetFilter) Reset()

func (*ColumnCountGetFilter) String

func (m *ColumnCountGetFilter) String() string

type ColumnFamilySchema

type ColumnFamilySchema struct {
	Name             []byte            `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	Attributes       []*BytesBytesPair `protobuf:"bytes,2,rep,name=attributes" json:"attributes,omitempty"`
	Configuration    []*NameStringPair `protobuf:"bytes,3,rep,name=configuration" json:"configuration,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

* Column Family Schema Inspired by the rest ColumSchemaMessage

func (*ColumnFamilySchema) GetAttributes

func (m *ColumnFamilySchema) GetAttributes() []*BytesBytesPair

func (*ColumnFamilySchema) GetConfiguration

func (m *ColumnFamilySchema) GetConfiguration() []*NameStringPair

func (*ColumnFamilySchema) GetName

func (m *ColumnFamilySchema) GetName() []byte

func (*ColumnFamilySchema) ProtoMessage

func (*ColumnFamilySchema) ProtoMessage()

func (*ColumnFamilySchema) Reset

func (m *ColumnFamilySchema) Reset()

func (*ColumnFamilySchema) String

func (m *ColumnFamilySchema) String() string

type ColumnPaginationFilter

type ColumnPaginationFilter struct {
	Limit            *int32 `protobuf:"varint,1,req,name=limit" json:"limit,omitempty"`
	Offset           *int32 `protobuf:"varint,2,opt,name=offset" json:"offset,omitempty"`
	ColumnOffset     []byte `protobuf:"bytes,3,opt,name=column_offset" json:"column_offset,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*ColumnPaginationFilter) GetColumnOffset

func (m *ColumnPaginationFilter) GetColumnOffset() []byte

func (*ColumnPaginationFilter) GetLimit

func (m *ColumnPaginationFilter) GetLimit() int32

func (*ColumnPaginationFilter) GetOffset

func (m *ColumnPaginationFilter) GetOffset() int32

func (*ColumnPaginationFilter) ProtoMessage

func (*ColumnPaginationFilter) ProtoMessage()

func (*ColumnPaginationFilter) Reset

func (m *ColumnPaginationFilter) Reset()

func (*ColumnPaginationFilter) String

func (m *ColumnPaginationFilter) String() string

type ColumnPrefixFilter

type ColumnPrefixFilter struct {
	Prefix           []byte `protobuf:"bytes,1,req,name=prefix" json:"prefix,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*ColumnPrefixFilter) GetPrefix

func (m *ColumnPrefixFilter) GetPrefix() []byte

func (*ColumnPrefixFilter) ProtoMessage

func (*ColumnPrefixFilter) ProtoMessage()

func (*ColumnPrefixFilter) Reset

func (m *ColumnPrefixFilter) Reset()

func (*ColumnPrefixFilter) String

func (m *ColumnPrefixFilter) String() string

type ColumnRangeFilter

type ColumnRangeFilter struct {
	MinColumn          []byte `protobuf:"bytes,1,opt,name=min_column" json:"min_column,omitempty"`
	MinColumnInclusive *bool  `protobuf:"varint,2,opt,name=min_column_inclusive" json:"min_column_inclusive,omitempty"`
	MaxColumn          []byte `protobuf:"bytes,3,opt,name=max_column" json:"max_column,omitempty"`
	MaxColumnInclusive *bool  `protobuf:"varint,4,opt,name=max_column_inclusive" json:"max_column_inclusive,omitempty"`
	XXX_unrecognized   []byte `json:"-"`
}

func (*ColumnRangeFilter) GetMaxColumn

func (m *ColumnRangeFilter) GetMaxColumn() []byte

func (*ColumnRangeFilter) GetMaxColumnInclusive

func (m *ColumnRangeFilter) GetMaxColumnInclusive() bool

func (*ColumnRangeFilter) GetMinColumn

func (m *ColumnRangeFilter) GetMinColumn() []byte

func (*ColumnRangeFilter) GetMinColumnInclusive

func (m *ColumnRangeFilter) GetMinColumnInclusive() bool

func (*ColumnRangeFilter) ProtoMessage

func (*ColumnRangeFilter) ProtoMessage()

func (*ColumnRangeFilter) Reset

func (m *ColumnRangeFilter) Reset()

func (*ColumnRangeFilter) String

func (m *ColumnRangeFilter) String() string

type CompactRegionRequest

type CompactRegionRequest struct {
	Region           *RegionSpecifier `protobuf:"bytes,1,req,name=region" json:"region,omitempty"`
	Major            *bool            `protobuf:"varint,2,opt,name=major" json:"major,omitempty"`
	Family           []byte           `protobuf:"bytes,3,opt,name=family" json:"family,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

* Compacts the specified region. Performs a major compaction if specified. <p> This method is asynchronous.

func (*CompactRegionRequest) GetFamily

func (m *CompactRegionRequest) GetFamily() []byte

func (*CompactRegionRequest) GetMajor

func (m *CompactRegionRequest) GetMajor() bool

func (*CompactRegionRequest) GetRegion

func (m *CompactRegionRequest) GetRegion() *RegionSpecifier

func (*CompactRegionRequest) ProtoMessage

func (*CompactRegionRequest) ProtoMessage()

func (*CompactRegionRequest) Reset

func (m *CompactRegionRequest) Reset()

func (*CompactRegionRequest) String

func (m *CompactRegionRequest) String() string

type CompactRegionResponse

type CompactRegionResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*CompactRegionResponse) ProtoMessage

func (*CompactRegionResponse) ProtoMessage()

func (*CompactRegionResponse) Reset

func (m *CompactRegionResponse) Reset()

func (*CompactRegionResponse) String

func (m *CompactRegionResponse) String() string

type CompactionDescriptor

type CompactionDescriptor struct {
	TableName         []byte   `protobuf:"bytes,1,req,name=table_name" json:"table_name,omitempty"`
	EncodedRegionName []byte   `protobuf:"bytes,2,req,name=encoded_region_name" json:"encoded_region_name,omitempty"`
	FamilyName        []byte   `protobuf:"bytes,3,req,name=family_name" json:"family_name,omitempty"`
	CompactionInput   []string `protobuf:"bytes,4,rep,name=compaction_input" json:"compaction_input,omitempty"`
	CompactionOutput  []string `protobuf:"bytes,5,rep,name=compaction_output" json:"compaction_output,omitempty"`
	StoreHomeDir      *string  `protobuf:"bytes,6,req,name=store_home_dir" json:"store_home_dir,omitempty"`
	RegionName        []byte   `protobuf:"bytes,7,opt,name=region_name" json:"region_name,omitempty"`
	XXX_unrecognized  []byte   `json:"-"`
}

* Special WAL entry to hold all related to a compaction. Written to WAL before completing compaction. There is sufficient info in the below message to complete later the * compaction should we fail the WAL write.

func (*CompactionDescriptor) GetCompactionInput

func (m *CompactionDescriptor) GetCompactionInput() []string

func (*CompactionDescriptor) GetCompactionOutput

func (m *CompactionDescriptor) GetCompactionOutput() []string

func (*CompactionDescriptor) GetEncodedRegionName

func (m *CompactionDescriptor) GetEncodedRegionName() []byte

func (*CompactionDescriptor) GetFamilyName

func (m *CompactionDescriptor) GetFamilyName() []byte

func (*CompactionDescriptor) GetRegionName

func (m *CompactionDescriptor) GetRegionName() []byte

func (*CompactionDescriptor) GetStoreHomeDir

func (m *CompactionDescriptor) GetStoreHomeDir() string

func (*CompactionDescriptor) GetTableName

func (m *CompactionDescriptor) GetTableName() []byte

func (*CompactionDescriptor) ProtoMessage

func (*CompactionDescriptor) ProtoMessage()

func (*CompactionDescriptor) Reset

func (m *CompactionDescriptor) Reset()

func (*CompactionDescriptor) String

func (m *CompactionDescriptor) String() string

type Comparator

type Comparator struct {
	Name                 *string `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	SerializedComparator []byte  `protobuf:"bytes,2,opt,name=serialized_comparator" json:"serialized_comparator,omitempty"`
	XXX_unrecognized     []byte  `json:"-"`
}

func (*Comparator) GetName

func (m *Comparator) GetName() string

func (*Comparator) GetSerializedComparator

func (m *Comparator) GetSerializedComparator() []byte

func (*Comparator) ProtoMessage

func (*Comparator) ProtoMessage()

func (*Comparator) Reset

func (m *Comparator) Reset()

func (*Comparator) String

func (m *Comparator) String() string

type CompareFilter

type CompareFilter struct {
	CompareOp        *CompareType `protobuf:"varint,1,req,name=compare_op,enum=proto.CompareType" json:"compare_op,omitempty"`
	Comparator       *Comparator  `protobuf:"bytes,2,opt,name=comparator" json:"comparator,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*CompareFilter) GetComparator

func (m *CompareFilter) GetComparator() *Comparator

func (*CompareFilter) GetCompareOp

func (m *CompareFilter) GetCompareOp() CompareType

func (*CompareFilter) ProtoMessage

func (*CompareFilter) ProtoMessage()

func (*CompareFilter) Reset

func (m *CompareFilter) Reset()

func (*CompareFilter) String

func (m *CompareFilter) String() string

type CompareType

type CompareType int32

Comparison operators

const (
	CompareType_LESS             CompareType = 0
	CompareType_LESS_OR_EQUAL    CompareType = 1
	CompareType_EQUAL            CompareType = 2
	CompareType_NOT_EQUAL        CompareType = 3
	CompareType_GREATER_OR_EQUAL CompareType = 4
	CompareType_GREATER          CompareType = 5
	CompareType_NO_OP            CompareType = 6
)

func (CompareType) Enum

func (x CompareType) Enum() *CompareType

func (CompareType) String

func (x CompareType) String() string

func (*CompareType) UnmarshalJSON

func (x *CompareType) UnmarshalJSON(data []byte) error

type Condition

type Condition struct {
	Row              []byte       `protobuf:"bytes,1,req,name=row" json:"row,omitempty"`
	Family           []byte       `protobuf:"bytes,2,req,name=family" json:"family,omitempty"`
	Qualifier        []byte       `protobuf:"bytes,3,req,name=qualifier" json:"qualifier,omitempty"`
	CompareType      *CompareType `protobuf:"varint,4,req,name=compare_type,enum=proto.CompareType" json:"compare_type,omitempty"`
	Comparator       *Comparator  `protobuf:"bytes,5,req,name=comparator" json:"comparator,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

* Condition to check if the value of a given cell (row, family, qualifier) matches a value via a given comparator.

Condition is used in check and mutate operations.

func (*Condition) GetComparator

func (m *Condition) GetComparator() *Comparator

func (*Condition) GetCompareType

func (m *Condition) GetCompareType() CompareType

func (*Condition) GetFamily

func (m *Condition) GetFamily() []byte

func (*Condition) GetQualifier

func (m *Condition) GetQualifier() []byte

func (*Condition) GetRow

func (m *Condition) GetRow() []byte

func (*Condition) ProtoMessage

func (*Condition) ProtoMessage()

func (*Condition) Reset

func (m *Condition) Reset()

func (*Condition) String

func (m *Condition) String() string

type ConnectionHeader

type ConnectionHeader struct {
	UserInfo    *UserInformation `protobuf:"bytes,1,opt,name=user_info" json:"user_info,omitempty"`
	ServiceName *string          `protobuf:"bytes,2,opt,name=service_name" json:"service_name,omitempty"`
	// Cell block codec we will use sending over optional cell blocks.  Server throws exception
	// if cannot deal.  Null means no codec'ing going on so we are pb all the time (SLOW!!!)
	CellBlockCodecClass *string `protobuf:"bytes,3,opt,name=cell_block_codec_class" json:"cell_block_codec_class,omitempty"`
	// Compressor we will use if cell block is compressed.  Server will throw exception if not supported.
	// Class must implement hadoop's CompressionCodec Interface.  Can't compress if no codec.
	CellBlockCompressorClass *string `protobuf:"bytes,4,opt,name=cell_block_compressor_class" json:"cell_block_compressor_class,omitempty"`
	XXX_unrecognized         []byte  `json:"-"`
}

This is sent on connection setup after the connection preamble is sent.

func (*ConnectionHeader) GetCellBlockCodecClass

func (m *ConnectionHeader) GetCellBlockCodecClass() string

func (*ConnectionHeader) GetCellBlockCompressorClass

func (m *ConnectionHeader) GetCellBlockCompressorClass() string

func (*ConnectionHeader) GetServiceName

func (m *ConnectionHeader) GetServiceName() string

func (*ConnectionHeader) GetUserInfo

func (m *ConnectionHeader) GetUserInfo() *UserInformation

func (*ConnectionHeader) ProtoMessage

func (*ConnectionHeader) ProtoMessage()

func (*ConnectionHeader) Reset

func (m *ConnectionHeader) Reset()

func (*ConnectionHeader) String

func (m *ConnectionHeader) String() string

type Consistency

type Consistency int32

* Consistency defines the expected consistency level for an operation.

const (
	Consistency_STRONG   Consistency = 0
	Consistency_TIMELINE Consistency = 1
)
const Default_Get_Consistency Consistency = Consistency_STRONG
const Default_Scan_Consistency Consistency = Consistency_STRONG

func (Consistency) Enum

func (x Consistency) Enum() *Consistency

func (Consistency) String

func (x Consistency) String() string

func (*Consistency) UnmarshalJSON

func (x *Consistency) UnmarshalJSON(data []byte) error

type Coprocessor

type Coprocessor struct {
	Name             *string `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*Coprocessor) GetName

func (m *Coprocessor) GetName() string

func (*Coprocessor) ProtoMessage

func (*Coprocessor) ProtoMessage()

func (*Coprocessor) Reset

func (m *Coprocessor) Reset()

func (*Coprocessor) String

func (m *Coprocessor) String() string

type CoprocessorServiceCall

type CoprocessorServiceCall struct {
	Row              []byte  `protobuf:"bytes,1,req,name=row" json:"row,omitempty"`
	ServiceName      *string `protobuf:"bytes,2,req,name=service_name" json:"service_name,omitempty"`
	MethodName       *string `protobuf:"bytes,3,req,name=method_name" json:"method_name,omitempty"`
	Request          []byte  `protobuf:"bytes,4,req,name=request" json:"request,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*CoprocessorServiceCall) GetMethodName

func (m *CoprocessorServiceCall) GetMethodName() string

func (*CoprocessorServiceCall) GetRequest

func (m *CoprocessorServiceCall) GetRequest() []byte

func (*CoprocessorServiceCall) GetRow

func (m *CoprocessorServiceCall) GetRow() []byte

func (*CoprocessorServiceCall) GetServiceName

func (m *CoprocessorServiceCall) GetServiceName() string

func (*CoprocessorServiceCall) ProtoMessage

func (*CoprocessorServiceCall) ProtoMessage()

func (*CoprocessorServiceCall) Reset

func (m *CoprocessorServiceCall) Reset()

func (*CoprocessorServiceCall) String

func (m *CoprocessorServiceCall) String() string

type CoprocessorServiceRequest

type CoprocessorServiceRequest struct {
	Region           *RegionSpecifier        `protobuf:"bytes,1,req,name=region" json:"region,omitempty"`
	Call             *CoprocessorServiceCall `protobuf:"bytes,2,req,name=call" json:"call,omitempty"`
	XXX_unrecognized []byte                  `json:"-"`
}

func (*CoprocessorServiceRequest) GetCall

func (*CoprocessorServiceRequest) GetRegion

func (*CoprocessorServiceRequest) ProtoMessage

func (*CoprocessorServiceRequest) ProtoMessage()

func (*CoprocessorServiceRequest) Reset

func (m *CoprocessorServiceRequest) Reset()

func (*CoprocessorServiceRequest) String

func (m *CoprocessorServiceRequest) String() string

type CoprocessorServiceResponse

type CoprocessorServiceResponse struct {
	Region           *RegionSpecifier `protobuf:"bytes,1,req,name=region" json:"region,omitempty"`
	Value            *NameBytesPair   `protobuf:"bytes,2,req,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*CoprocessorServiceResponse) GetRegion

func (*CoprocessorServiceResponse) GetValue

func (*CoprocessorServiceResponse) ProtoMessage

func (*CoprocessorServiceResponse) ProtoMessage()

func (*CoprocessorServiceResponse) Reset

func (m *CoprocessorServiceResponse) Reset()

func (*CoprocessorServiceResponse) String

func (m *CoprocessorServiceResponse) String() string

type CoprocessorServiceResult

type CoprocessorServiceResult struct {
	Value            *NameBytesPair `protobuf:"bytes,1,opt,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*CoprocessorServiceResult) GetValue

func (m *CoprocessorServiceResult) GetValue() *NameBytesPair

func (*CoprocessorServiceResult) ProtoMessage

func (*CoprocessorServiceResult) ProtoMessage()

func (*CoprocessorServiceResult) Reset

func (m *CoprocessorServiceResult) Reset()

func (*CoprocessorServiceResult) String

func (m *CoprocessorServiceResult) String() string

type CreateNamespaceRequest

type CreateNamespaceRequest struct {
	NamespaceDescriptor *NamespaceDescriptor `protobuf:"bytes,1,req,name=namespaceDescriptor" json:"namespaceDescriptor,omitempty"`
	XXX_unrecognized    []byte               `json:"-"`
}

func (*CreateNamespaceRequest) GetNamespaceDescriptor

func (m *CreateNamespaceRequest) GetNamespaceDescriptor() *NamespaceDescriptor

func (*CreateNamespaceRequest) ProtoMessage

func (*CreateNamespaceRequest) ProtoMessage()

func (*CreateNamespaceRequest) Reset

func (m *CreateNamespaceRequest) Reset()

func (*CreateNamespaceRequest) String

func (m *CreateNamespaceRequest) String() string

type CreateNamespaceResponse

type CreateNamespaceResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*CreateNamespaceResponse) ProtoMessage

func (*CreateNamespaceResponse) ProtoMessage()

func (*CreateNamespaceResponse) Reset

func (m *CreateNamespaceResponse) Reset()

func (*CreateNamespaceResponse) String

func (m *CreateNamespaceResponse) String() string

type CreateTableRequest

type CreateTableRequest struct {
	TableSchema      *TableSchema `protobuf:"bytes,1,req,name=table_schema" json:"table_schema,omitempty"`
	SplitKeys        [][]byte     `protobuf:"bytes,2,rep,name=split_keys" json:"split_keys,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*CreateTableRequest) GetSplitKeys

func (m *CreateTableRequest) GetSplitKeys() [][]byte

func (*CreateTableRequest) GetTableSchema

func (m *CreateTableRequest) GetTableSchema() *TableSchema

func (*CreateTableRequest) ProtoMessage

func (*CreateTableRequest) ProtoMessage()

func (*CreateTableRequest) Reset

func (m *CreateTableRequest) Reset()

func (*CreateTableRequest) String

func (m *CreateTableRequest) String() string

type CreateTableResponse

type CreateTableResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*CreateTableResponse) ProtoMessage

func (*CreateTableResponse) ProtoMessage()

func (*CreateTableResponse) Reset

func (m *CreateTableResponse) Reset()

func (*CreateTableResponse) String

func (m *CreateTableResponse) String() string

type DelegationToken

type DelegationToken struct {
	Identifier       []byte  `protobuf:"bytes,1,opt,name=identifier" json:"identifier,omitempty"`
	Password         []byte  `protobuf:"bytes,2,opt,name=password" json:"password,omitempty"`
	Kind             *string `protobuf:"bytes,3,opt,name=kind" json:"kind,omitempty"`
	Service          *string `protobuf:"bytes,4,opt,name=service" json:"service,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*DelegationToken) GetIdentifier

func (m *DelegationToken) GetIdentifier() []byte

func (*DelegationToken) GetKind

func (m *DelegationToken) GetKind() string

func (*DelegationToken) GetPassword

func (m *DelegationToken) GetPassword() []byte

func (*DelegationToken) GetService

func (m *DelegationToken) GetService() string

func (*DelegationToken) ProtoMessage

func (*DelegationToken) ProtoMessage()

func (*DelegationToken) Reset

func (m *DelegationToken) Reset()

func (*DelegationToken) String

func (m *DelegationToken) String() string

type DeleteColumnRequest

type DeleteColumnRequest struct {
	TableName        *TableName `protobuf:"bytes,1,req,name=table_name" json:"table_name,omitempty"`
	ColumnName       []byte     `protobuf:"bytes,2,req,name=column_name" json:"column_name,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

func (*DeleteColumnRequest) GetColumnName

func (m *DeleteColumnRequest) GetColumnName() []byte

func (*DeleteColumnRequest) GetTableName

func (m *DeleteColumnRequest) GetTableName() *TableName

func (*DeleteColumnRequest) ProtoMessage

func (*DeleteColumnRequest) ProtoMessage()

func (*DeleteColumnRequest) Reset

func (m *DeleteColumnRequest) Reset()

func (*DeleteColumnRequest) String

func (m *DeleteColumnRequest) String() string

type DeleteColumnResponse

type DeleteColumnResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*DeleteColumnResponse) ProtoMessage

func (*DeleteColumnResponse) ProtoMessage()

func (*DeleteColumnResponse) Reset

func (m *DeleteColumnResponse) Reset()

func (*DeleteColumnResponse) String

func (m *DeleteColumnResponse) String() string

type DeleteNamespaceRequest

type DeleteNamespaceRequest struct {
	NamespaceName    *string `protobuf:"bytes,1,req,name=namespaceName" json:"namespaceName,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*DeleteNamespaceRequest) GetNamespaceName

func (m *DeleteNamespaceRequest) GetNamespaceName() string

func (*DeleteNamespaceRequest) ProtoMessage

func (*DeleteNamespaceRequest) ProtoMessage()

func (*DeleteNamespaceRequest) Reset

func (m *DeleteNamespaceRequest) Reset()

func (*DeleteNamespaceRequest) String

func (m *DeleteNamespaceRequest) String() string

type DeleteNamespaceResponse

type DeleteNamespaceResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*DeleteNamespaceResponse) ProtoMessage

func (*DeleteNamespaceResponse) ProtoMessage()

func (*DeleteNamespaceResponse) Reset

func (m *DeleteNamespaceResponse) Reset()

func (*DeleteNamespaceResponse) String

func (m *DeleteNamespaceResponse) String() string

type DeleteSnapshotRequest

type DeleteSnapshotRequest struct {
	Snapshot         *SnapshotDescription `protobuf:"bytes,1,req,name=snapshot" json:"snapshot,omitempty"`
	XXX_unrecognized []byte               `json:"-"`
}

func (*DeleteSnapshotRequest) GetSnapshot

func (m *DeleteSnapshotRequest) GetSnapshot() *SnapshotDescription

func (*DeleteSnapshotRequest) ProtoMessage

func (*DeleteSnapshotRequest) ProtoMessage()

func (*DeleteSnapshotRequest) Reset

func (m *DeleteSnapshotRequest) Reset()

func (*DeleteSnapshotRequest) String

func (m *DeleteSnapshotRequest) String() string

type DeleteSnapshotResponse

type DeleteSnapshotResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*DeleteSnapshotResponse) ProtoMessage

func (*DeleteSnapshotResponse) ProtoMessage()

func (*DeleteSnapshotResponse) Reset

func (m *DeleteSnapshotResponse) Reset()

func (*DeleteSnapshotResponse) String

func (m *DeleteSnapshotResponse) String() string

type DeleteTableRequest

type DeleteTableRequest struct {
	TableName        *TableName `protobuf:"bytes,1,req,name=table_name" json:"table_name,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

func (*DeleteTableRequest) GetTableName

func (m *DeleteTableRequest) GetTableName() *TableName

func (*DeleteTableRequest) ProtoMessage

func (*DeleteTableRequest) ProtoMessage()

func (*DeleteTableRequest) Reset

func (m *DeleteTableRequest) Reset()

func (*DeleteTableRequest) String

func (m *DeleteTableRequest) String() string

type DeleteTableResponse

type DeleteTableResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*DeleteTableResponse) ProtoMessage

func (*DeleteTableResponse) ProtoMessage()

func (*DeleteTableResponse) Reset

func (m *DeleteTableResponse) Reset()

func (*DeleteTableResponse) String

func (m *DeleteTableResponse) String() string

type DependentColumnFilter

type DependentColumnFilter struct {
	CompareFilter       *CompareFilter `protobuf:"bytes,1,req,name=compare_filter" json:"compare_filter,omitempty"`
	ColumnFamily        []byte         `protobuf:"bytes,2,opt,name=column_family" json:"column_family,omitempty"`
	ColumnQualifier     []byte         `protobuf:"bytes,3,opt,name=column_qualifier" json:"column_qualifier,omitempty"`
	DropDependentColumn *bool          `protobuf:"varint,4,opt,name=drop_dependent_column" json:"drop_dependent_column,omitempty"`
	XXX_unrecognized    []byte         `json:"-"`
}

func (*DependentColumnFilter) GetColumnFamily

func (m *DependentColumnFilter) GetColumnFamily() []byte

func (*DependentColumnFilter) GetColumnQualifier

func (m *DependentColumnFilter) GetColumnQualifier() []byte

func (*DependentColumnFilter) GetCompareFilter

func (m *DependentColumnFilter) GetCompareFilter() *CompareFilter

func (*DependentColumnFilter) GetDropDependentColumn

func (m *DependentColumnFilter) GetDropDependentColumn() bool

func (*DependentColumnFilter) ProtoMessage

func (*DependentColumnFilter) ProtoMessage()

func (*DependentColumnFilter) Reset

func (m *DependentColumnFilter) Reset()

func (*DependentColumnFilter) String

func (m *DependentColumnFilter) String() string

type DisableTableRequest

type DisableTableRequest struct {
	TableName        *TableName `protobuf:"bytes,1,req,name=table_name" json:"table_name,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

func (*DisableTableRequest) GetTableName

func (m *DisableTableRequest) GetTableName() *TableName

func (*DisableTableRequest) ProtoMessage

func (*DisableTableRequest) ProtoMessage()

func (*DisableTableRequest) Reset

func (m *DisableTableRequest) Reset()

func (*DisableTableRequest) String

func (m *DisableTableRequest) String() string

type DisableTableResponse

type DisableTableResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*DisableTableResponse) ProtoMessage

func (*DisableTableResponse) ProtoMessage()

func (*DisableTableResponse) Reset

func (m *DisableTableResponse) Reset()

func (*DisableTableResponse) String

func (m *DisableTableResponse) String() string

type DispatchMergingRegionsRequest

type DispatchMergingRegionsRequest struct {
	RegionA          *RegionSpecifier `protobuf:"bytes,1,req,name=region_a" json:"region_a,omitempty"`
	RegionB          *RegionSpecifier `protobuf:"bytes,2,req,name=region_b" json:"region_b,omitempty"`
	Forcible         *bool            `protobuf:"varint,3,opt,name=forcible,def=0" json:"forcible,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

* Dispatch merging the specified regions.

func (*DispatchMergingRegionsRequest) GetForcible

func (m *DispatchMergingRegionsRequest) GetForcible() bool

func (*DispatchMergingRegionsRequest) GetRegionA

func (*DispatchMergingRegionsRequest) GetRegionB

func (*DispatchMergingRegionsRequest) ProtoMessage

func (*DispatchMergingRegionsRequest) ProtoMessage()

func (*DispatchMergingRegionsRequest) Reset

func (m *DispatchMergingRegionsRequest) Reset()

func (*DispatchMergingRegionsRequest) String

type DispatchMergingRegionsResponse

type DispatchMergingRegionsResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*DispatchMergingRegionsResponse) ProtoMessage

func (*DispatchMergingRegionsResponse) ProtoMessage()

func (*DispatchMergingRegionsResponse) Reset

func (m *DispatchMergingRegionsResponse) Reset()

func (*DispatchMergingRegionsResponse) String

type DoubleMsg

type DoubleMsg struct {
	DoubleMsg        *float64 `protobuf:"fixed64,1,req,name=double_msg" json:"double_msg,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*DoubleMsg) GetDoubleMsg

func (m *DoubleMsg) GetDoubleMsg() float64

func (*DoubleMsg) ProtoMessage

func (*DoubleMsg) ProtoMessage()

func (*DoubleMsg) Reset

func (m *DoubleMsg) Reset()

func (*DoubleMsg) String

func (m *DoubleMsg) String() string

type EmptyMsg

type EmptyMsg struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*EmptyMsg) ProtoMessage

func (*EmptyMsg) ProtoMessage()

func (*EmptyMsg) Reset

func (m *EmptyMsg) Reset()

func (*EmptyMsg) String

func (m *EmptyMsg) String() string

type EnableCatalogJanitorRequest

type EnableCatalogJanitorRequest struct {
	Enable           *bool  `protobuf:"varint,1,req,name=enable" json:"enable,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*EnableCatalogJanitorRequest) GetEnable

func (m *EnableCatalogJanitorRequest) GetEnable() bool

func (*EnableCatalogJanitorRequest) ProtoMessage

func (*EnableCatalogJanitorRequest) ProtoMessage()

func (*EnableCatalogJanitorRequest) Reset

func (m *EnableCatalogJanitorRequest) Reset()

func (*EnableCatalogJanitorRequest) String

func (m *EnableCatalogJanitorRequest) String() string

type EnableCatalogJanitorResponse

type EnableCatalogJanitorResponse struct {
	PrevValue        *bool  `protobuf:"varint,1,opt,name=prev_value" json:"prev_value,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*EnableCatalogJanitorResponse) GetPrevValue

func (m *EnableCatalogJanitorResponse) GetPrevValue() bool

func (*EnableCatalogJanitorResponse) ProtoMessage

func (*EnableCatalogJanitorResponse) ProtoMessage()

func (*EnableCatalogJanitorResponse) Reset

func (m *EnableCatalogJanitorResponse) Reset()

func (*EnableCatalogJanitorResponse) String

type EnableTableRequest

type EnableTableRequest struct {
	TableName        *TableName `protobuf:"bytes,1,req,name=table_name" json:"table_name,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

func (*EnableTableRequest) GetTableName

func (m *EnableTableRequest) GetTableName() *TableName

func (*EnableTableRequest) ProtoMessage

func (*EnableTableRequest) ProtoMessage()

func (*EnableTableRequest) Reset

func (m *EnableTableRequest) Reset()

func (*EnableTableRequest) String

func (m *EnableTableRequest) String() string

type EnableTableResponse

type EnableTableResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*EnableTableResponse) ProtoMessage

func (*EnableTableResponse) ProtoMessage()

func (*EnableTableResponse) Reset

func (m *EnableTableResponse) Reset()

func (*EnableTableResponse) String

func (m *EnableTableResponse) String() string

type ExceptionResponse

type ExceptionResponse struct {
	// Class name of the exception thrown from the server
	ExceptionClassName *string `protobuf:"bytes,1,opt,name=exception_class_name" json:"exception_class_name,omitempty"`
	// Exception stack trace from the server side
	StackTrace *string `protobuf:"bytes,2,opt,name=stack_trace" json:"stack_trace,omitempty"`
	// Optional hostname.  Filled in for some exceptions such as region moved
	// where exception gives clue on where the region may have moved.
	Hostname *string `protobuf:"bytes,3,opt,name=hostname" json:"hostname,omitempty"`
	Port     *int32  `protobuf:"varint,4,opt,name=port" json:"port,omitempty"`
	// Set if we are NOT to retry on receipt of this exception
	DoNotRetry       *bool  `protobuf:"varint,5,opt,name=do_not_retry" json:"do_not_retry,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

At the RPC layer, this message is used to carry the server side exception to the RPC client.

func (*ExceptionResponse) GetDoNotRetry

func (m *ExceptionResponse) GetDoNotRetry() bool

func (*ExceptionResponse) GetExceptionClassName

func (m *ExceptionResponse) GetExceptionClassName() string

func (*ExceptionResponse) GetHostname

func (m *ExceptionResponse) GetHostname() string

func (*ExceptionResponse) GetPort

func (m *ExceptionResponse) GetPort() int32

func (*ExceptionResponse) GetStackTrace

func (m *ExceptionResponse) GetStackTrace() string

func (*ExceptionResponse) ProtoMessage

func (*ExceptionResponse) ProtoMessage()

func (*ExceptionResponse) Reset

func (m *ExceptionResponse) Reset()

func (*ExceptionResponse) String

func (m *ExceptionResponse) String() string

type ExecProcedureRequest

type ExecProcedureRequest struct {
	Procedure        *ProcedureDescription `protobuf:"bytes,1,req,name=procedure" json:"procedure,omitempty"`
	XXX_unrecognized []byte                `json:"-"`
}

func (*ExecProcedureRequest) GetProcedure

func (m *ExecProcedureRequest) GetProcedure() *ProcedureDescription

func (*ExecProcedureRequest) ProtoMessage

func (*ExecProcedureRequest) ProtoMessage()

func (*ExecProcedureRequest) Reset

func (m *ExecProcedureRequest) Reset()

func (*ExecProcedureRequest) String

func (m *ExecProcedureRequest) String() string

type ExecProcedureResponse

type ExecProcedureResponse struct {
	ExpectedTimeout  *int64 `protobuf:"varint,1,opt,name=expected_timeout" json:"expected_timeout,omitempty"`
	ReturnData       []byte `protobuf:"bytes,2,opt,name=return_data" json:"return_data,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*ExecProcedureResponse) GetExpectedTimeout

func (m *ExecProcedureResponse) GetExpectedTimeout() int64

func (*ExecProcedureResponse) GetReturnData

func (m *ExecProcedureResponse) GetReturnData() []byte

func (*ExecProcedureResponse) ProtoMessage

func (*ExecProcedureResponse) ProtoMessage()

func (*ExecProcedureResponse) Reset

func (m *ExecProcedureResponse) Reset()

func (*ExecProcedureResponse) String

func (m *ExecProcedureResponse) String() string

type FamilyFilter

type FamilyFilter struct {
	CompareFilter    *CompareFilter `protobuf:"bytes,1,req,name=compare_filter" json:"compare_filter,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*FamilyFilter) GetCompareFilter

func (m *FamilyFilter) GetCompareFilter() *CompareFilter

func (*FamilyFilter) ProtoMessage

func (*FamilyFilter) ProtoMessage()

func (*FamilyFilter) Reset

func (m *FamilyFilter) Reset()

func (*FamilyFilter) String

func (m *FamilyFilter) String() string

type FamilyScope

type FamilyScope struct {
	Family           []byte     `protobuf:"bytes,1,req,name=family" json:"family,omitempty"`
	ScopeType        *ScopeType `protobuf:"varint,2,req,name=scope_type,enum=proto.ScopeType" json:"scope_type,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

func (*FamilyScope) GetFamily

func (m *FamilyScope) GetFamily() []byte

func (*FamilyScope) GetScopeType

func (m *FamilyScope) GetScopeType() ScopeType

func (*FamilyScope) ProtoMessage

func (*FamilyScope) ProtoMessage()

func (*FamilyScope) Reset

func (m *FamilyScope) Reset()

func (*FamilyScope) String

func (m *FamilyScope) String() string

type FavoredNodes

type FavoredNodes struct {
	FavoredNode      []*ServerName `protobuf:"bytes,1,rep,name=favored_node" json:"favored_node,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

* Protocol buffer for favored nodes

func (*FavoredNodes) GetFavoredNode

func (m *FavoredNodes) GetFavoredNode() []*ServerName

func (*FavoredNodes) ProtoMessage

func (*FavoredNodes) ProtoMessage()

func (*FavoredNodes) Reset

func (m *FavoredNodes) Reset()

func (*FavoredNodes) String

func (m *FavoredNodes) String() string

type FileInfoProto

type FileInfoProto struct {
	MapEntry         []*BytesBytesPair `protobuf:"bytes,1,rep,name=map_entry" json:"map_entry,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

Map of name/values

func (*FileInfoProto) GetMapEntry

func (m *FileInfoProto) GetMapEntry() []*BytesBytesPair

func (*FileInfoProto) ProtoMessage

func (*FileInfoProto) ProtoMessage()

func (*FileInfoProto) Reset

func (m *FileInfoProto) Reset()

func (*FileInfoProto) String

func (m *FileInfoProto) String() string

type FileTrailerProto

type FileTrailerProto struct {
	FileInfoOffset            *uint64 `protobuf:"varint,1,opt,name=file_info_offset" json:"file_info_offset,omitempty"`
	LoadOnOpenDataOffset      *uint64 `protobuf:"varint,2,opt,name=load_on_open_data_offset" json:"load_on_open_data_offset,omitempty"`
	UncompressedDataIndexSize *uint64 `protobuf:"varint,3,opt,name=uncompressed_data_index_size" json:"uncompressed_data_index_size,omitempty"`
	TotalUncompressedBytes    *uint64 `protobuf:"varint,4,opt,name=total_uncompressed_bytes" json:"total_uncompressed_bytes,omitempty"`
	DataIndexCount            *uint32 `protobuf:"varint,5,opt,name=data_index_count" json:"data_index_count,omitempty"`
	MetaIndexCount            *uint32 `protobuf:"varint,6,opt,name=meta_index_count" json:"meta_index_count,omitempty"`
	EntryCount                *uint64 `protobuf:"varint,7,opt,name=entry_count" json:"entry_count,omitempty"`
	NumDataIndexLevels        *uint32 `protobuf:"varint,8,opt,name=num_data_index_levels" json:"num_data_index_levels,omitempty"`
	FirstDataBlockOffset      *uint64 `protobuf:"varint,9,opt,name=first_data_block_offset" json:"first_data_block_offset,omitempty"`
	LastDataBlockOffset       *uint64 `protobuf:"varint,10,opt,name=last_data_block_offset" json:"last_data_block_offset,omitempty"`
	ComparatorClassName       *string `protobuf:"bytes,11,opt,name=comparator_class_name" json:"comparator_class_name,omitempty"`
	CompressionCodec          *uint32 `protobuf:"varint,12,opt,name=compression_codec" json:"compression_codec,omitempty"`
	EncryptionKey             []byte  `protobuf:"bytes,13,opt,name=encryption_key" json:"encryption_key,omitempty"`
	XXX_unrecognized          []byte  `json:"-"`
}

HFile file trailer

func (*FileTrailerProto) GetComparatorClassName

func (m *FileTrailerProto) GetComparatorClassName() string

func (*FileTrailerProto) GetCompressionCodec

func (m *FileTrailerProto) GetCompressionCodec() uint32

func (*FileTrailerProto) GetDataIndexCount

func (m *FileTrailerProto) GetDataIndexCount() uint32

func (*FileTrailerProto) GetEncryptionKey

func (m *FileTrailerProto) GetEncryptionKey() []byte

func (*FileTrailerProto) GetEntryCount

func (m *FileTrailerProto) GetEntryCount() uint64

func (*FileTrailerProto) GetFileInfoOffset

func (m *FileTrailerProto) GetFileInfoOffset() uint64

func (*FileTrailerProto) GetFirstDataBlockOffset

func (m *FileTrailerProto) GetFirstDataBlockOffset() uint64

func (*FileTrailerProto) GetLastDataBlockOffset

func (m *FileTrailerProto) GetLastDataBlockOffset() uint64

func (*FileTrailerProto) GetLoadOnOpenDataOffset

func (m *FileTrailerProto) GetLoadOnOpenDataOffset() uint64

func (*FileTrailerProto) GetMetaIndexCount

func (m *FileTrailerProto) GetMetaIndexCount() uint32

func (*FileTrailerProto) GetNumDataIndexLevels

func (m *FileTrailerProto) GetNumDataIndexLevels() uint32

func (*FileTrailerProto) GetTotalUncompressedBytes

func (m *FileTrailerProto) GetTotalUncompressedBytes() uint64

func (*FileTrailerProto) GetUncompressedDataIndexSize

func (m *FileTrailerProto) GetUncompressedDataIndexSize() uint64

func (*FileTrailerProto) ProtoMessage

func (*FileTrailerProto) ProtoMessage()

func (*FileTrailerProto) Reset

func (m *FileTrailerProto) Reset()

func (*FileTrailerProto) String

func (m *FileTrailerProto) String() string

type Filter

type Filter struct {
	Name             *string `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	SerializedFilter []byte  `protobuf:"bytes,2,opt,name=serialized_filter" json:"serialized_filter,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*Filter) GetName

func (m *Filter) GetName() string

func (*Filter) GetSerializedFilter

func (m *Filter) GetSerializedFilter() []byte

func (*Filter) ProtoMessage

func (*Filter) ProtoMessage()

func (*Filter) Reset

func (m *Filter) Reset()

func (*Filter) String

func (m *Filter) String() string

type FilterAllFilter

type FilterAllFilter struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*FilterAllFilter) ProtoMessage

func (*FilterAllFilter) ProtoMessage()

func (*FilterAllFilter) Reset

func (m *FilterAllFilter) Reset()

func (*FilterAllFilter) String

func (m *FilterAllFilter) String() string

type FilterList

type FilterList struct {
	Operator         *FilterList_Operator `protobuf:"varint,1,req,name=operator,enum=proto.FilterList_Operator" json:"operator,omitempty"`
	Filters          []*Filter            `protobuf:"bytes,2,rep,name=filters" json:"filters,omitempty"`
	XXX_unrecognized []byte               `json:"-"`
}

func (*FilterList) GetFilters

func (m *FilterList) GetFilters() []*Filter

func (*FilterList) GetOperator

func (m *FilterList) GetOperator() FilterList_Operator

func (*FilterList) ProtoMessage

func (*FilterList) ProtoMessage()

func (*FilterList) Reset

func (m *FilterList) Reset()

func (*FilterList) String

func (m *FilterList) String() string

type FilterList_Operator

type FilterList_Operator int32
const (
	FilterList_MUST_PASS_ALL FilterList_Operator = 1
	FilterList_MUST_PASS_ONE FilterList_Operator = 2
)

func (FilterList_Operator) Enum

func (FilterList_Operator) String

func (x FilterList_Operator) String() string

func (*FilterList_Operator) UnmarshalJSON

func (x *FilterList_Operator) UnmarshalJSON(data []byte) error

type FilterWrapper

type FilterWrapper struct {
	Filter           *Filter `protobuf:"bytes,1,req,name=filter" json:"filter,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*FilterWrapper) GetFilter

func (m *FilterWrapper) GetFilter() *Filter

func (*FilterWrapper) ProtoMessage

func (*FilterWrapper) ProtoMessage()

func (*FilterWrapper) Reset

func (m *FilterWrapper) Reset()

func (*FilterWrapper) String

func (m *FilterWrapper) String() string

type FirstKeyOnlyFilter

type FirstKeyOnlyFilter struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*FirstKeyOnlyFilter) ProtoMessage

func (*FirstKeyOnlyFilter) ProtoMessage()

func (*FirstKeyOnlyFilter) Reset

func (m *FirstKeyOnlyFilter) Reset()

func (*FirstKeyOnlyFilter) String

func (m *FirstKeyOnlyFilter) String() string

type FirstKeyValueMatchingQualifiersFilter

type FirstKeyValueMatchingQualifiersFilter struct {
	Qualifiers       [][]byte `protobuf:"bytes,1,rep,name=qualifiers" json:"qualifiers,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*FirstKeyValueMatchingQualifiersFilter) GetQualifiers

func (m *FirstKeyValueMatchingQualifiersFilter) GetQualifiers() [][]byte

func (*FirstKeyValueMatchingQualifiersFilter) ProtoMessage

func (*FirstKeyValueMatchingQualifiersFilter) ProtoMessage()

func (*FirstKeyValueMatchingQualifiersFilter) Reset

func (*FirstKeyValueMatchingQualifiersFilter) String

type FlushDescriptor

type FlushDescriptor struct {
	Action              *FlushDescriptor_FlushAction            `protobuf:"varint,1,req,name=action,enum=proto.FlushDescriptor_FlushAction" json:"action,omitempty"`
	TableName           []byte                                  `protobuf:"bytes,2,req,name=table_name" json:"table_name,omitempty"`
	EncodedRegionName   []byte                                  `protobuf:"bytes,3,req,name=encoded_region_name" json:"encoded_region_name,omitempty"`
	FlushSequenceNumber *uint64                                 `protobuf:"varint,4,opt,name=flush_sequence_number" json:"flush_sequence_number,omitempty"`
	StoreFlushes        []*FlushDescriptor_StoreFlushDescriptor `protobuf:"bytes,5,rep,name=store_flushes" json:"store_flushes,omitempty"`
	RegionName          []byte                                  `protobuf:"bytes,6,opt,name=region_name" json:"region_name,omitempty"`
	XXX_unrecognized    []byte                                  `json:"-"`
}

* Special WAL entry to hold all related to a flush.

func (*FlushDescriptor) GetAction

func (*FlushDescriptor) GetEncodedRegionName

func (m *FlushDescriptor) GetEncodedRegionName() []byte

func (*FlushDescriptor) GetFlushSequenceNumber

func (m *FlushDescriptor) GetFlushSequenceNumber() uint64

func (*FlushDescriptor) GetRegionName

func (m *FlushDescriptor) GetRegionName() []byte

func (*FlushDescriptor) GetStoreFlushes

func (m *FlushDescriptor) GetStoreFlushes() []*FlushDescriptor_StoreFlushDescriptor

func (*FlushDescriptor) GetTableName

func (m *FlushDescriptor) GetTableName() []byte

func (*FlushDescriptor) ProtoMessage

func (*FlushDescriptor) ProtoMessage()

func (*FlushDescriptor) Reset

func (m *FlushDescriptor) Reset()

func (*FlushDescriptor) String

func (m *FlushDescriptor) String() string

type FlushDescriptor_FlushAction

type FlushDescriptor_FlushAction int32
const (
	FlushDescriptor_START_FLUSH  FlushDescriptor_FlushAction = 0
	FlushDescriptor_COMMIT_FLUSH FlushDescriptor_FlushAction = 1
	FlushDescriptor_ABORT_FLUSH  FlushDescriptor_FlushAction = 2
)

func (FlushDescriptor_FlushAction) Enum

func (FlushDescriptor_FlushAction) String

func (*FlushDescriptor_FlushAction) UnmarshalJSON

func (x *FlushDescriptor_FlushAction) UnmarshalJSON(data []byte) error

type FlushDescriptor_StoreFlushDescriptor

type FlushDescriptor_StoreFlushDescriptor struct {
	FamilyName       []byte   `protobuf:"bytes,1,req,name=family_name" json:"family_name,omitempty"`
	StoreHomeDir     *string  `protobuf:"bytes,2,req,name=store_home_dir" json:"store_home_dir,omitempty"`
	FlushOutput      []string `protobuf:"bytes,3,rep,name=flush_output" json:"flush_output,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*FlushDescriptor_StoreFlushDescriptor) GetFamilyName

func (m *FlushDescriptor_StoreFlushDescriptor) GetFamilyName() []byte

func (*FlushDescriptor_StoreFlushDescriptor) GetFlushOutput

func (m *FlushDescriptor_StoreFlushDescriptor) GetFlushOutput() []string

func (*FlushDescriptor_StoreFlushDescriptor) GetStoreHomeDir

func (m *FlushDescriptor_StoreFlushDescriptor) GetStoreHomeDir() string

func (*FlushDescriptor_StoreFlushDescriptor) ProtoMessage

func (*FlushDescriptor_StoreFlushDescriptor) ProtoMessage()

func (*FlushDescriptor_StoreFlushDescriptor) Reset

func (*FlushDescriptor_StoreFlushDescriptor) String

type FlushRegionRequest

type FlushRegionRequest struct {
	Region           *RegionSpecifier `protobuf:"bytes,1,req,name=region" json:"region,omitempty"`
	IfOlderThanTs    *uint64          `protobuf:"varint,2,opt,name=if_older_than_ts" json:"if_older_than_ts,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

* Flushes the MemStore of the specified region. <p> This method is synchronous.

func (*FlushRegionRequest) GetIfOlderThanTs

func (m *FlushRegionRequest) GetIfOlderThanTs() uint64

func (*FlushRegionRequest) GetRegion

func (m *FlushRegionRequest) GetRegion() *RegionSpecifier

func (*FlushRegionRequest) ProtoMessage

func (*FlushRegionRequest) ProtoMessage()

func (*FlushRegionRequest) Reset

func (m *FlushRegionRequest) Reset()

func (*FlushRegionRequest) String

func (m *FlushRegionRequest) String() string

type FlushRegionResponse

type FlushRegionResponse struct {
	LastFlushTime    *uint64 `protobuf:"varint,1,req,name=last_flush_time" json:"last_flush_time,omitempty"`
	Flushed          *bool   `protobuf:"varint,2,opt,name=flushed" json:"flushed,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*FlushRegionResponse) GetFlushed

func (m *FlushRegionResponse) GetFlushed() bool

func (*FlushRegionResponse) GetLastFlushTime

func (m *FlushRegionResponse) GetLastFlushTime() uint64

func (*FlushRegionResponse) ProtoMessage

func (*FlushRegionResponse) ProtoMessage()

func (*FlushRegionResponse) Reset

func (m *FlushRegionResponse) Reset()

func (*FlushRegionResponse) String

func (m *FlushRegionResponse) String() string

type ForeignExceptionMessage

type ForeignExceptionMessage struct {
	Source           *string                  `protobuf:"bytes,1,opt,name=source" json:"source,omitempty"`
	GenericException *GenericExceptionMessage `protobuf:"bytes,2,opt,name=generic_exception" json:"generic_exception,omitempty"`
	XXX_unrecognized []byte                   `json:"-"`
}

* Exception sent across the wire when a remote task needs to notify other tasks that it failed and why

func (*ForeignExceptionMessage) GetGenericException

func (m *ForeignExceptionMessage) GetGenericException() *GenericExceptionMessage

func (*ForeignExceptionMessage) GetSource

func (m *ForeignExceptionMessage) GetSource() string

func (*ForeignExceptionMessage) ProtoMessage

func (*ForeignExceptionMessage) ProtoMessage()

func (*ForeignExceptionMessage) Reset

func (m *ForeignExceptionMessage) Reset()

func (*ForeignExceptionMessage) String

func (m *ForeignExceptionMessage) String() string

type FuzzyRowFilter

type FuzzyRowFilter struct {
	FuzzyKeysData    []*BytesBytesPair `protobuf:"bytes,1,rep,name=fuzzy_keys_data" json:"fuzzy_keys_data,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

func (*FuzzyRowFilter) GetFuzzyKeysData

func (m *FuzzyRowFilter) GetFuzzyKeysData() []*BytesBytesPair

func (*FuzzyRowFilter) ProtoMessage

func (*FuzzyRowFilter) ProtoMessage()

func (*FuzzyRowFilter) Reset

func (m *FuzzyRowFilter) Reset()

func (*FuzzyRowFilter) String

func (m *FuzzyRowFilter) String() string

type GenericExceptionMessage

type GenericExceptionMessage struct {
	ClassName        *string                     `protobuf:"bytes,1,opt,name=class_name" json:"class_name,omitempty"`
	Message          *string                     `protobuf:"bytes,2,opt,name=message" json:"message,omitempty"`
	ErrorInfo        []byte                      `protobuf:"bytes,3,opt,name=error_info" json:"error_info,omitempty"`
	Trace            []*StackTraceElementMessage `protobuf:"bytes,4,rep,name=trace" json:"trace,omitempty"`
	XXX_unrecognized []byte                      `json:"-"`
}

* Cause of a remote failure for a generic exception. Contains all the information for a generic exception as well as optional info about the error for generic info passing (which should be another protobuffed class).

func (*GenericExceptionMessage) GetClassName

func (m *GenericExceptionMessage) GetClassName() string

func (*GenericExceptionMessage) GetErrorInfo

func (m *GenericExceptionMessage) GetErrorInfo() []byte

func (*GenericExceptionMessage) GetMessage

func (m *GenericExceptionMessage) GetMessage() string

func (*GenericExceptionMessage) GetTrace

func (*GenericExceptionMessage) ProtoMessage

func (*GenericExceptionMessage) ProtoMessage()

func (*GenericExceptionMessage) Reset

func (m *GenericExceptionMessage) Reset()

func (*GenericExceptionMessage) String

func (m *GenericExceptionMessage) String() string

type Get

type Get struct {
	Row         []byte           `protobuf:"bytes,1,req,name=row" json:"row,omitempty"`
	Column      []*Column        `protobuf:"bytes,2,rep,name=column" json:"column,omitempty"`
	Attribute   []*NameBytesPair `protobuf:"bytes,3,rep,name=attribute" json:"attribute,omitempty"`
	Filter      *Filter          `protobuf:"bytes,4,opt,name=filter" json:"filter,omitempty"`
	TimeRange   *TimeRange       `protobuf:"bytes,5,opt,name=time_range" json:"time_range,omitempty"`
	MaxVersions *uint32          `protobuf:"varint,6,opt,name=max_versions,def=1" json:"max_versions,omitempty"`
	CacheBlocks *bool            `protobuf:"varint,7,opt,name=cache_blocks,def=1" json:"cache_blocks,omitempty"`
	StoreLimit  *uint32          `protobuf:"varint,8,opt,name=store_limit" json:"store_limit,omitempty"`
	StoreOffset *uint32          `protobuf:"varint,9,opt,name=store_offset" json:"store_offset,omitempty"`
	// The result isn't asked for, just check for
	// the existence.
	ExistenceOnly *bool `protobuf:"varint,10,opt,name=existence_only,def=0" json:"existence_only,omitempty"`
	// If the row to get doesn't exist, return the
	// closest row before.
	ClosestRowBefore *bool        `protobuf:"varint,11,opt,name=closest_row_before,def=0" json:"closest_row_before,omitempty"`
	Consistency      *Consistency `protobuf:"varint,12,opt,name=consistency,enum=proto.Consistency,def=0" json:"consistency,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

* The protocol buffer version of Get. Unless existence_only is specified, return all the requested data for the row that matches exactly, or the one that immediately precedes it if closest_row_before is specified.

func (*Get) GetAttribute

func (m *Get) GetAttribute() []*NameBytesPair

func (*Get) GetCacheBlocks

func (m *Get) GetCacheBlocks() bool

func (*Get) GetClosestRowBefore

func (m *Get) GetClosestRowBefore() bool

func (*Get) GetColumn

func (m *Get) GetColumn() []*Column

func (*Get) GetConsistency

func (m *Get) GetConsistency() Consistency

func (*Get) GetExistenceOnly

func (m *Get) GetExistenceOnly() bool

func (*Get) GetFilter

func (m *Get) GetFilter() *Filter

func (*Get) GetMaxVersions

func (m *Get) GetMaxVersions() uint32

func (*Get) GetRow

func (m *Get) GetRow() []byte

func (*Get) GetStoreLimit

func (m *Get) GetStoreLimit() uint32

func (*Get) GetStoreOffset

func (m *Get) GetStoreOffset() uint32

func (*Get) GetTimeRange

func (m *Get) GetTimeRange() *TimeRange

func (*Get) ProtoMessage

func (*Get) ProtoMessage()

func (*Get) Reset

func (m *Get) Reset()

func (*Get) String

func (m *Get) String() string

type GetAuthenticationTokenRequest

type GetAuthenticationTokenRequest struct {
	XXX_unrecognized []byte `json:"-"`
}

RPC request & response messages

func (*GetAuthenticationTokenRequest) ProtoMessage

func (*GetAuthenticationTokenRequest) ProtoMessage()

func (*GetAuthenticationTokenRequest) Reset

func (m *GetAuthenticationTokenRequest) Reset()

func (*GetAuthenticationTokenRequest) String

type GetAuthenticationTokenResponse

type GetAuthenticationTokenResponse struct {
	Token            *Token `protobuf:"bytes,1,opt,name=token" json:"token,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*GetAuthenticationTokenResponse) GetToken

func (m *GetAuthenticationTokenResponse) GetToken() *Token

func (*GetAuthenticationTokenResponse) ProtoMessage

func (*GetAuthenticationTokenResponse) ProtoMessage()

func (*GetAuthenticationTokenResponse) Reset

func (m *GetAuthenticationTokenResponse) Reset()

func (*GetAuthenticationTokenResponse) String

type GetAuthsRequest

type GetAuthsRequest struct {
	User             []byte `protobuf:"bytes,1,req,name=user" json:"user,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*GetAuthsRequest) GetUser

func (m *GetAuthsRequest) GetUser() []byte

func (*GetAuthsRequest) ProtoMessage

func (*GetAuthsRequest) ProtoMessage()

func (*GetAuthsRequest) Reset

func (m *GetAuthsRequest) Reset()

func (*GetAuthsRequest) String

func (m *GetAuthsRequest) String() string

type GetAuthsResponse

type GetAuthsResponse struct {
	User             []byte   `protobuf:"bytes,1,req,name=user" json:"user,omitempty"`
	Auth             [][]byte `protobuf:"bytes,2,rep,name=auth" json:"auth,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*GetAuthsResponse) GetAuth

func (m *GetAuthsResponse) GetAuth() [][]byte

func (*GetAuthsResponse) GetUser

func (m *GetAuthsResponse) GetUser() []byte

func (*GetAuthsResponse) ProtoMessage

func (*GetAuthsResponse) ProtoMessage()

func (*GetAuthsResponse) Reset

func (m *GetAuthsResponse) Reset()

func (*GetAuthsResponse) String

func (m *GetAuthsResponse) String() string

type GetClusterStatusRequest

type GetClusterStatusRequest struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*GetClusterStatusRequest) ProtoMessage

func (*GetClusterStatusRequest) ProtoMessage()

func (*GetClusterStatusRequest) Reset

func (m *GetClusterStatusRequest) Reset()

func (*GetClusterStatusRequest) String

func (m *GetClusterStatusRequest) String() string

type GetClusterStatusResponse

type GetClusterStatusResponse struct {
	ClusterStatus    *ClusterStatus `protobuf:"bytes,1,req,name=cluster_status" json:"cluster_status,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*GetClusterStatusResponse) GetClusterStatus

func (m *GetClusterStatusResponse) GetClusterStatus() *ClusterStatus

func (*GetClusterStatusResponse) ProtoMessage

func (*GetClusterStatusResponse) ProtoMessage()

func (*GetClusterStatusResponse) Reset

func (m *GetClusterStatusResponse) Reset()

func (*GetClusterStatusResponse) String

func (m *GetClusterStatusResponse) String() string

type GetCompletedSnapshotsRequest

type GetCompletedSnapshotsRequest struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*GetCompletedSnapshotsRequest) ProtoMessage

func (*GetCompletedSnapshotsRequest) ProtoMessage()

func (*GetCompletedSnapshotsRequest) Reset

func (m *GetCompletedSnapshotsRequest) Reset()

func (*GetCompletedSnapshotsRequest) String

type GetCompletedSnapshotsResponse

type GetCompletedSnapshotsResponse struct {
	Snapshots        []*SnapshotDescription `protobuf:"bytes,1,rep,name=snapshots" json:"snapshots,omitempty"`
	XXX_unrecognized []byte                 `json:"-"`
}

func (*GetCompletedSnapshotsResponse) GetSnapshots

func (*GetCompletedSnapshotsResponse) ProtoMessage

func (*GetCompletedSnapshotsResponse) ProtoMessage()

func (*GetCompletedSnapshotsResponse) Reset

func (m *GetCompletedSnapshotsResponse) Reset()

func (*GetCompletedSnapshotsResponse) String

type GetLastFlushedSequenceIdRequest

type GetLastFlushedSequenceIdRequest struct {
	// * region name
	RegionName       []byte `protobuf:"bytes,1,req,name=region_name" json:"region_name,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*GetLastFlushedSequenceIdRequest) GetRegionName

func (m *GetLastFlushedSequenceIdRequest) GetRegionName() []byte

func (*GetLastFlushedSequenceIdRequest) ProtoMessage

func (*GetLastFlushedSequenceIdRequest) ProtoMessage()

func (*GetLastFlushedSequenceIdRequest) Reset

func (*GetLastFlushedSequenceIdRequest) String

type GetLastFlushedSequenceIdResponse

type GetLastFlushedSequenceIdResponse struct {
	// the last WAL sequence id flushed from MemStore to HFile for the region
	LastFlushedSequenceId *uint64 `protobuf:"varint,1,req,name=last_flushed_sequence_id" json:"last_flushed_sequence_id,omitempty"`
	XXX_unrecognized      []byte  `json:"-"`
}

func (*GetLastFlushedSequenceIdResponse) GetLastFlushedSequenceId

func (m *GetLastFlushedSequenceIdResponse) GetLastFlushedSequenceId() uint64

func (*GetLastFlushedSequenceIdResponse) ProtoMessage

func (*GetLastFlushedSequenceIdResponse) ProtoMessage()

func (*GetLastFlushedSequenceIdResponse) Reset

func (*GetLastFlushedSequenceIdResponse) String

type GetNamespaceDescriptorRequest

type GetNamespaceDescriptorRequest struct {
	NamespaceName    *string `protobuf:"bytes,1,req,name=namespaceName" json:"namespaceName,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*GetNamespaceDescriptorRequest) GetNamespaceName

func (m *GetNamespaceDescriptorRequest) GetNamespaceName() string

func (*GetNamespaceDescriptorRequest) ProtoMessage

func (*GetNamespaceDescriptorRequest) ProtoMessage()

func (*GetNamespaceDescriptorRequest) Reset

func (m *GetNamespaceDescriptorRequest) Reset()

func (*GetNamespaceDescriptorRequest) String

type GetNamespaceDescriptorResponse

type GetNamespaceDescriptorResponse struct {
	NamespaceDescriptor *NamespaceDescriptor `protobuf:"bytes,1,req,name=namespaceDescriptor" json:"namespaceDescriptor,omitempty"`
	XXX_unrecognized    []byte               `json:"-"`
}

func (*GetNamespaceDescriptorResponse) GetNamespaceDescriptor

func (m *GetNamespaceDescriptorResponse) GetNamespaceDescriptor() *NamespaceDescriptor

func (*GetNamespaceDescriptorResponse) ProtoMessage

func (*GetNamespaceDescriptorResponse) ProtoMessage()

func (*GetNamespaceDescriptorResponse) Reset

func (m *GetNamespaceDescriptorResponse) Reset()

func (*GetNamespaceDescriptorResponse) String

type GetOnlineRegionRequest

type GetOnlineRegionRequest struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*GetOnlineRegionRequest) ProtoMessage

func (*GetOnlineRegionRequest) ProtoMessage()

func (*GetOnlineRegionRequest) Reset

func (m *GetOnlineRegionRequest) Reset()

func (*GetOnlineRegionRequest) String

func (m *GetOnlineRegionRequest) String() string

type GetOnlineRegionResponse

type GetOnlineRegionResponse struct {
	RegionInfo       []*RegionInfo `protobuf:"bytes,1,rep,name=region_info" json:"region_info,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*GetOnlineRegionResponse) GetRegionInfo

func (m *GetOnlineRegionResponse) GetRegionInfo() []*RegionInfo

func (*GetOnlineRegionResponse) ProtoMessage

func (*GetOnlineRegionResponse) ProtoMessage()

func (*GetOnlineRegionResponse) Reset

func (m *GetOnlineRegionResponse) Reset()

func (*GetOnlineRegionResponse) String

func (m *GetOnlineRegionResponse) String() string

type GetRegionInfoRequest

type GetRegionInfoRequest struct {
	Region           *RegionSpecifier `protobuf:"bytes,1,req,name=region" json:"region,omitempty"`
	CompactionState  *bool            `protobuf:"varint,2,opt,name=compaction_state" json:"compaction_state,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*GetRegionInfoRequest) GetCompactionState

func (m *GetRegionInfoRequest) GetCompactionState() bool

func (*GetRegionInfoRequest) GetRegion

func (m *GetRegionInfoRequest) GetRegion() *RegionSpecifier

func (*GetRegionInfoRequest) ProtoMessage

func (*GetRegionInfoRequest) ProtoMessage()

func (*GetRegionInfoRequest) Reset

func (m *GetRegionInfoRequest) Reset()

func (*GetRegionInfoRequest) String

func (m *GetRegionInfoRequest) String() string

type GetRegionInfoResponse

type GetRegionInfoResponse struct {
	RegionInfo       *RegionInfo                            `protobuf:"bytes,1,req,name=region_info" json:"region_info,omitempty"`
	CompactionState  *GetRegionInfoResponse_CompactionState `` /* 128-byte string literal not displayed */
	IsRecovering     *bool                                  `protobuf:"varint,3,opt,name=isRecovering" json:"isRecovering,omitempty"`
	XXX_unrecognized []byte                                 `json:"-"`
}

func (*GetRegionInfoResponse) GetCompactionState

func (*GetRegionInfoResponse) GetIsRecovering

func (m *GetRegionInfoResponse) GetIsRecovering() bool

func (*GetRegionInfoResponse) GetRegionInfo

func (m *GetRegionInfoResponse) GetRegionInfo() *RegionInfo

func (*GetRegionInfoResponse) ProtoMessage

func (*GetRegionInfoResponse) ProtoMessage()

func (*GetRegionInfoResponse) Reset

func (m *GetRegionInfoResponse) Reset()

func (*GetRegionInfoResponse) String

func (m *GetRegionInfoResponse) String() string

type GetRegionInfoResponse_CompactionState

type GetRegionInfoResponse_CompactionState int32
const (
	GetRegionInfoResponse_NONE            GetRegionInfoResponse_CompactionState = 0
	GetRegionInfoResponse_MINOR           GetRegionInfoResponse_CompactionState = 1
	GetRegionInfoResponse_MAJOR           GetRegionInfoResponse_CompactionState = 2
	GetRegionInfoResponse_MAJOR_AND_MINOR GetRegionInfoResponse_CompactionState = 3
)

func (GetRegionInfoResponse_CompactionState) Enum

func (GetRegionInfoResponse_CompactionState) String

func (*GetRegionInfoResponse_CompactionState) UnmarshalJSON

func (x *GetRegionInfoResponse_CompactionState) UnmarshalJSON(data []byte) error

type GetRequest

type GetRequest struct {
	Region           *RegionSpecifier `protobuf:"bytes,1,req,name=region" json:"region,omitempty"`
	Get              *Get             `protobuf:"bytes,2,req,name=get" json:"get,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

* The get request. Perform a single Get operation.

func (*GetRequest) GetGet

func (m *GetRequest) GetGet() *Get

func (*GetRequest) GetRegion

func (m *GetRequest) GetRegion() *RegionSpecifier

func (*GetRequest) ProtoMessage

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset

func (m *GetRequest) Reset()

func (*GetRequest) String

func (m *GetRequest) String() string

type GetResponse

type GetResponse struct {
	Result           *Result `protobuf:"bytes,1,opt,name=result" json:"result,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*GetResponse) GetResult

func (m *GetResponse) GetResult() *Result

func (*GetResponse) ProtoMessage

func (*GetResponse) ProtoMessage()

func (*GetResponse) Reset

func (m *GetResponse) Reset()

func (*GetResponse) String

func (m *GetResponse) String() string

type GetSchemaAlterStatusRequest

type GetSchemaAlterStatusRequest struct {
	TableName        *TableName `protobuf:"bytes,1,req,name=table_name" json:"table_name,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

func (*GetSchemaAlterStatusRequest) GetTableName

func (m *GetSchemaAlterStatusRequest) GetTableName() *TableName

func (*GetSchemaAlterStatusRequest) ProtoMessage

func (*GetSchemaAlterStatusRequest) ProtoMessage()

func (*GetSchemaAlterStatusRequest) Reset

func (m *GetSchemaAlterStatusRequest) Reset()

func (*GetSchemaAlterStatusRequest) String

func (m *GetSchemaAlterStatusRequest) String() string

type GetSchemaAlterStatusResponse

type GetSchemaAlterStatusResponse struct {
	YetToUpdateRegions *uint32 `protobuf:"varint,1,opt,name=yet_to_update_regions" json:"yet_to_update_regions,omitempty"`
	TotalRegions       *uint32 `protobuf:"varint,2,opt,name=total_regions" json:"total_regions,omitempty"`
	XXX_unrecognized   []byte  `json:"-"`
}

func (*GetSchemaAlterStatusResponse) GetTotalRegions

func (m *GetSchemaAlterStatusResponse) GetTotalRegions() uint32

func (*GetSchemaAlterStatusResponse) GetYetToUpdateRegions

func (m *GetSchemaAlterStatusResponse) GetYetToUpdateRegions() uint32

func (*GetSchemaAlterStatusResponse) ProtoMessage

func (*GetSchemaAlterStatusResponse) ProtoMessage()

func (*GetSchemaAlterStatusResponse) Reset

func (m *GetSchemaAlterStatusResponse) Reset()

func (*GetSchemaAlterStatusResponse) String

type GetServerInfoRequest

type GetServerInfoRequest struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*GetServerInfoRequest) ProtoMessage

func (*GetServerInfoRequest) ProtoMessage()

func (*GetServerInfoRequest) Reset

func (m *GetServerInfoRequest) Reset()

func (*GetServerInfoRequest) String

func (m *GetServerInfoRequest) String() string

type GetServerInfoResponse

type GetServerInfoResponse struct {
	ServerInfo       *ServerInfo `protobuf:"bytes,1,req,name=server_info" json:"server_info,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*GetServerInfoResponse) GetServerInfo

func (m *GetServerInfoResponse) GetServerInfo() *ServerInfo

func (*GetServerInfoResponse) ProtoMessage

func (*GetServerInfoResponse) ProtoMessage()

func (*GetServerInfoResponse) Reset

func (m *GetServerInfoResponse) Reset()

func (*GetServerInfoResponse) String

func (m *GetServerInfoResponse) String() string

type GetStoreFileRequest

type GetStoreFileRequest struct {
	Region           *RegionSpecifier `protobuf:"bytes,1,req,name=region" json:"region,omitempty"`
	Family           [][]byte         `protobuf:"bytes,2,rep,name=family" json:"family,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

* Get a list of store files for a set of column families in a particular region. If no column family is specified, get the store files for all column families.

func (*GetStoreFileRequest) GetFamily

func (m *GetStoreFileRequest) GetFamily() [][]byte

func (*GetStoreFileRequest) GetRegion

func (m *GetStoreFileRequest) GetRegion() *RegionSpecifier

func (*GetStoreFileRequest) ProtoMessage

func (*GetStoreFileRequest) ProtoMessage()

func (*GetStoreFileRequest) Reset

func (m *GetStoreFileRequest) Reset()

func (*GetStoreFileRequest) String

func (m *GetStoreFileRequest) String() string

type GetStoreFileResponse

type GetStoreFileResponse struct {
	StoreFile        []string `protobuf:"bytes,1,rep,name=store_file" json:"store_file,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*GetStoreFileResponse) GetStoreFile

func (m *GetStoreFileResponse) GetStoreFile() []string

func (*GetStoreFileResponse) ProtoMessage

func (*GetStoreFileResponse) ProtoMessage()

func (*GetStoreFileResponse) Reset

func (m *GetStoreFileResponse) Reset()

func (*GetStoreFileResponse) String

func (m *GetStoreFileResponse) String() string

type GetTableDescriptorsRequest

type GetTableDescriptorsRequest struct {
	TableNames       []*TableName `protobuf:"bytes,1,rep,name=table_names" json:"table_names,omitempty"`
	Regex            *string      `protobuf:"bytes,2,opt,name=regex" json:"regex,omitempty"`
	IncludeSysTables *bool        `protobuf:"varint,3,opt,name=include_sys_tables,def=0" json:"include_sys_tables,omitempty"`
	Namespace        *string      `protobuf:"bytes,4,opt,name=namespace" json:"namespace,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*GetTableDescriptorsRequest) GetIncludeSysTables

func (m *GetTableDescriptorsRequest) GetIncludeSysTables() bool

func (*GetTableDescriptorsRequest) GetNamespace

func (m *GetTableDescriptorsRequest) GetNamespace() string

func (*GetTableDescriptorsRequest) GetRegex

func (m *GetTableDescriptorsRequest) GetRegex() string

func (*GetTableDescriptorsRequest) GetTableNames

func (m *GetTableDescriptorsRequest) GetTableNames() []*TableName

func (*GetTableDescriptorsRequest) ProtoMessage

func (*GetTableDescriptorsRequest) ProtoMessage()

func (*GetTableDescriptorsRequest) Reset

func (m *GetTableDescriptorsRequest) Reset()

func (*GetTableDescriptorsRequest) String

func (m *GetTableDescriptorsRequest) String() string

type GetTableDescriptorsResponse

type GetTableDescriptorsResponse struct {
	TableSchema      []*TableSchema `protobuf:"bytes,1,rep,name=table_schema" json:"table_schema,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*GetTableDescriptorsResponse) GetTableSchema

func (m *GetTableDescriptorsResponse) GetTableSchema() []*TableSchema

func (*GetTableDescriptorsResponse) ProtoMessage

func (*GetTableDescriptorsResponse) ProtoMessage()

func (*GetTableDescriptorsResponse) Reset

func (m *GetTableDescriptorsResponse) Reset()

func (*GetTableDescriptorsResponse) String

func (m *GetTableDescriptorsResponse) String() string

type GetTableNamesRequest

type GetTableNamesRequest struct {
	Regex            *string `protobuf:"bytes,1,opt,name=regex" json:"regex,omitempty"`
	IncludeSysTables *bool   `protobuf:"varint,2,opt,name=include_sys_tables,def=0" json:"include_sys_tables,omitempty"`
	Namespace        *string `protobuf:"bytes,3,opt,name=namespace" json:"namespace,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*GetTableNamesRequest) GetIncludeSysTables

func (m *GetTableNamesRequest) GetIncludeSysTables() bool

func (*GetTableNamesRequest) GetNamespace

func (m *GetTableNamesRequest) GetNamespace() string

func (*GetTableNamesRequest) GetRegex

func (m *GetTableNamesRequest) GetRegex() string

func (*GetTableNamesRequest) ProtoMessage

func (*GetTableNamesRequest) ProtoMessage()

func (*GetTableNamesRequest) Reset

func (m *GetTableNamesRequest) Reset()

func (*GetTableNamesRequest) String

func (m *GetTableNamesRequest) String() string

type GetTableNamesResponse

type GetTableNamesResponse struct {
	TableNames       []*TableName `protobuf:"bytes,1,rep,name=table_names" json:"table_names,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*GetTableNamesResponse) GetTableNames

func (m *GetTableNamesResponse) GetTableNames() []*TableName

func (*GetTableNamesResponse) ProtoMessage

func (*GetTableNamesResponse) ProtoMessage()

func (*GetTableNamesResponse) Reset

func (m *GetTableNamesResponse) Reset()

func (*GetTableNamesResponse) String

func (m *GetTableNamesResponse) String() string

type GetUserPermissionsRequest

type GetUserPermissionsRequest struct {
	Type             *Permission_Type `protobuf:"varint,1,opt,name=type,enum=proto.Permission_Type" json:"type,omitempty"`
	TableName        *TableName       `protobuf:"bytes,2,opt,name=table_name" json:"table_name,omitempty"`
	NamespaceName    []byte           `protobuf:"bytes,3,opt,name=namespace_name" json:"namespace_name,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*GetUserPermissionsRequest) GetNamespaceName

func (m *GetUserPermissionsRequest) GetNamespaceName() []byte

func (*GetUserPermissionsRequest) GetTableName

func (m *GetUserPermissionsRequest) GetTableName() *TableName

func (*GetUserPermissionsRequest) GetType

func (*GetUserPermissionsRequest) ProtoMessage

func (*GetUserPermissionsRequest) ProtoMessage()

func (*GetUserPermissionsRequest) Reset

func (m *GetUserPermissionsRequest) Reset()

func (*GetUserPermissionsRequest) String

func (m *GetUserPermissionsRequest) String() string

type GetUserPermissionsResponse

type GetUserPermissionsResponse struct {
	UserPermission   []*UserPermission `protobuf:"bytes,1,rep,name=user_permission" json:"user_permission,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

func (*GetUserPermissionsResponse) GetUserPermission

func (m *GetUserPermissionsResponse) GetUserPermission() []*UserPermission

func (*GetUserPermissionsResponse) ProtoMessage

func (*GetUserPermissionsResponse) ProtoMessage()

func (*GetUserPermissionsResponse) Reset

func (m *GetUserPermissionsResponse) Reset()

func (*GetUserPermissionsResponse) String

func (m *GetUserPermissionsResponse) String() string

type GlobalPermission

type GlobalPermission struct {
	Action           []Permission_Action `protobuf:"varint,1,rep,name=action,enum=proto.Permission_Action" json:"action,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

func (*GlobalPermission) GetAction

func (m *GlobalPermission) GetAction() []Permission_Action

func (*GlobalPermission) ProtoMessage

func (*GlobalPermission) ProtoMessage()

func (*GlobalPermission) Reset

func (m *GlobalPermission) Reset()

func (*GlobalPermission) String

func (m *GlobalPermission) String() string

type GrantRequest

type GrantRequest struct {
	UserPermission   *UserPermission `protobuf:"bytes,1,req,name=user_permission" json:"user_permission,omitempty"`
	XXX_unrecognized []byte          `json:"-"`
}

func (*GrantRequest) GetUserPermission

func (m *GrantRequest) GetUserPermission() *UserPermission

func (*GrantRequest) ProtoMessage

func (*GrantRequest) ProtoMessage()

func (*GrantRequest) Reset

func (m *GrantRequest) Reset()

func (*GrantRequest) String

func (m *GrantRequest) String() string

type GrantResponse

type GrantResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*GrantResponse) ProtoMessage

func (*GrantResponse) ProtoMessage()

func (*GrantResponse) Reset

func (m *GrantResponse) Reset()

func (*GrantResponse) String

func (m *GrantResponse) String() string

type HBaseVersionFileContent

type HBaseVersionFileContent struct {
	Version          *string `protobuf:"bytes,1,req,name=version" json:"version,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* The ${HBASE_ROOTDIR}/hbase.version file content

func (*HBaseVersionFileContent) GetVersion

func (m *HBaseVersionFileContent) GetVersion() string

func (*HBaseVersionFileContent) ProtoMessage

func (*HBaseVersionFileContent) ProtoMessage()

func (*HBaseVersionFileContent) Reset

func (m *HBaseVersionFileContent) Reset()

func (*HBaseVersionFileContent) String

func (m *HBaseVersionFileContent) String() string

type InclusiveStopFilter

type InclusiveStopFilter struct {
	StopRowKey       []byte `protobuf:"bytes,1,opt,name=stop_row_key" json:"stop_row_key,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*InclusiveStopFilter) GetStopRowKey

func (m *InclusiveStopFilter) GetStopRowKey() []byte

func (*InclusiveStopFilter) ProtoMessage

func (*InclusiveStopFilter) ProtoMessage()

func (*InclusiveStopFilter) Reset

func (m *InclusiveStopFilter) Reset()

func (*InclusiveStopFilter) String

func (m *InclusiveStopFilter) String() string

type IsCatalogJanitorEnabledRequest

type IsCatalogJanitorEnabledRequest struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*IsCatalogJanitorEnabledRequest) ProtoMessage

func (*IsCatalogJanitorEnabledRequest) ProtoMessage()

func (*IsCatalogJanitorEnabledRequest) Reset

func (m *IsCatalogJanitorEnabledRequest) Reset()

func (*IsCatalogJanitorEnabledRequest) String

type IsCatalogJanitorEnabledResponse

type IsCatalogJanitorEnabledResponse struct {
	Value            *bool  `protobuf:"varint,1,req,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*IsCatalogJanitorEnabledResponse) GetValue

func (m *IsCatalogJanitorEnabledResponse) GetValue() bool

func (*IsCatalogJanitorEnabledResponse) ProtoMessage

func (*IsCatalogJanitorEnabledResponse) ProtoMessage()

func (*IsCatalogJanitorEnabledResponse) Reset

func (*IsCatalogJanitorEnabledResponse) String

type IsMasterRunningRequest

type IsMasterRunningRequest struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*IsMasterRunningRequest) ProtoMessage

func (*IsMasterRunningRequest) ProtoMessage()

func (*IsMasterRunningRequest) Reset

func (m *IsMasterRunningRequest) Reset()

func (*IsMasterRunningRequest) String

func (m *IsMasterRunningRequest) String() string

type IsMasterRunningResponse

type IsMasterRunningResponse struct {
	IsMasterRunning  *bool  `protobuf:"varint,1,req,name=is_master_running" json:"is_master_running,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*IsMasterRunningResponse) GetIsMasterRunning

func (m *IsMasterRunningResponse) GetIsMasterRunning() bool

func (*IsMasterRunningResponse) ProtoMessage

func (*IsMasterRunningResponse) ProtoMessage()

func (*IsMasterRunningResponse) Reset

func (m *IsMasterRunningResponse) Reset()

func (*IsMasterRunningResponse) String

func (m *IsMasterRunningResponse) String() string

type IsProcedureDoneRequest

type IsProcedureDoneRequest struct {
	Procedure        *ProcedureDescription `protobuf:"bytes,1,opt,name=procedure" json:"procedure,omitempty"`
	XXX_unrecognized []byte                `json:"-"`
}

func (*IsProcedureDoneRequest) GetProcedure

func (m *IsProcedureDoneRequest) GetProcedure() *ProcedureDescription

func (*IsProcedureDoneRequest) ProtoMessage

func (*IsProcedureDoneRequest) ProtoMessage()

func (*IsProcedureDoneRequest) Reset

func (m *IsProcedureDoneRequest) Reset()

func (*IsProcedureDoneRequest) String

func (m *IsProcedureDoneRequest) String() string

type IsProcedureDoneResponse

type IsProcedureDoneResponse struct {
	Done             *bool                 `protobuf:"varint,1,opt,name=done,def=0" json:"done,omitempty"`
	Snapshot         *ProcedureDescription `protobuf:"bytes,2,opt,name=snapshot" json:"snapshot,omitempty"`
	XXX_unrecognized []byte                `json:"-"`
}

func (*IsProcedureDoneResponse) GetDone

func (m *IsProcedureDoneResponse) GetDone() bool

func (*IsProcedureDoneResponse) GetSnapshot

func (*IsProcedureDoneResponse) ProtoMessage

func (*IsProcedureDoneResponse) ProtoMessage()

func (*IsProcedureDoneResponse) Reset

func (m *IsProcedureDoneResponse) Reset()

func (*IsProcedureDoneResponse) String

func (m *IsProcedureDoneResponse) String() string

type IsRestoreSnapshotDoneRequest

type IsRestoreSnapshotDoneRequest struct {
	Snapshot         *SnapshotDescription `protobuf:"bytes,1,opt,name=snapshot" json:"snapshot,omitempty"`
	XXX_unrecognized []byte               `json:"-"`
}

func (*IsRestoreSnapshotDoneRequest) GetSnapshot

func (*IsRestoreSnapshotDoneRequest) ProtoMessage

func (*IsRestoreSnapshotDoneRequest) ProtoMessage()

func (*IsRestoreSnapshotDoneRequest) Reset

func (m *IsRestoreSnapshotDoneRequest) Reset()

func (*IsRestoreSnapshotDoneRequest) String

type IsRestoreSnapshotDoneResponse

type IsRestoreSnapshotDoneResponse struct {
	Done             *bool  `protobuf:"varint,1,opt,name=done,def=0" json:"done,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*IsRestoreSnapshotDoneResponse) GetDone

func (m *IsRestoreSnapshotDoneResponse) GetDone() bool

func (*IsRestoreSnapshotDoneResponse) ProtoMessage

func (*IsRestoreSnapshotDoneResponse) ProtoMessage()

func (*IsRestoreSnapshotDoneResponse) Reset

func (m *IsRestoreSnapshotDoneResponse) Reset()

func (*IsRestoreSnapshotDoneResponse) String

type IsSnapshotDoneRequest

type IsSnapshotDoneRequest struct {
	Snapshot         *SnapshotDescription `protobuf:"bytes,1,opt,name=snapshot" json:"snapshot,omitempty"`
	XXX_unrecognized []byte               `json:"-"`
}

if you don't send the snapshot, then you will get it back in the response (if the snapshot is done) so you can check the snapshot

func (*IsSnapshotDoneRequest) GetSnapshot

func (m *IsSnapshotDoneRequest) GetSnapshot() *SnapshotDescription

func (*IsSnapshotDoneRequest) ProtoMessage

func (*IsSnapshotDoneRequest) ProtoMessage()

func (*IsSnapshotDoneRequest) Reset

func (m *IsSnapshotDoneRequest) Reset()

func (*IsSnapshotDoneRequest) String

func (m *IsSnapshotDoneRequest) String() string

type IsSnapshotDoneResponse

type IsSnapshotDoneResponse struct {
	Done             *bool                `protobuf:"varint,1,opt,name=done,def=0" json:"done,omitempty"`
	Snapshot         *SnapshotDescription `protobuf:"bytes,2,opt,name=snapshot" json:"snapshot,omitempty"`
	XXX_unrecognized []byte               `json:"-"`
}

func (*IsSnapshotDoneResponse) GetDone

func (m *IsSnapshotDoneResponse) GetDone() bool

func (*IsSnapshotDoneResponse) GetSnapshot

func (m *IsSnapshotDoneResponse) GetSnapshot() *SnapshotDescription

func (*IsSnapshotDoneResponse) ProtoMessage

func (*IsSnapshotDoneResponse) ProtoMessage()

func (*IsSnapshotDoneResponse) Reset

func (m *IsSnapshotDoneResponse) Reset()

func (*IsSnapshotDoneResponse) String

func (m *IsSnapshotDoneResponse) String() string

type KeyOnlyFilter

type KeyOnlyFilter struct {
	LenAsVal         *bool  `protobuf:"varint,1,req,name=len_as_val" json:"len_as_val,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*KeyOnlyFilter) GetLenAsVal

func (m *KeyOnlyFilter) GetLenAsVal() bool

func (*KeyOnlyFilter) ProtoMessage

func (*KeyOnlyFilter) ProtoMessage()

func (*KeyOnlyFilter) Reset

func (m *KeyOnlyFilter) Reset()

func (*KeyOnlyFilter) String

func (m *KeyOnlyFilter) String() string

type KeyValue

type KeyValue struct {
	Row              []byte    `protobuf:"bytes,1,req,name=row" json:"row,omitempty"`
	Family           []byte    `protobuf:"bytes,2,req,name=family" json:"family,omitempty"`
	Qualifier        []byte    `protobuf:"bytes,3,req,name=qualifier" json:"qualifier,omitempty"`
	Timestamp        *uint64   `protobuf:"varint,4,opt,name=timestamp" json:"timestamp,omitempty"`
	KeyType          *CellType `protobuf:"varint,5,opt,name=key_type,enum=proto.CellType" json:"key_type,omitempty"`
	Value            []byte    `protobuf:"bytes,6,opt,name=value" json:"value,omitempty"`
	Tags             []byte    `protobuf:"bytes,7,opt,name=tags" json:"tags,omitempty"`
	XXX_unrecognized []byte    `json:"-"`
}

* Protocol buffer version of KeyValue. It doesn't have those transient parameters

func (*KeyValue) GetFamily

func (m *KeyValue) GetFamily() []byte

func (*KeyValue) GetKeyType

func (m *KeyValue) GetKeyType() CellType

func (*KeyValue) GetQualifier

func (m *KeyValue) GetQualifier() []byte

func (*KeyValue) GetRow

func (m *KeyValue) GetRow() []byte

func (*KeyValue) GetTags

func (m *KeyValue) GetTags() []byte

func (*KeyValue) GetTimestamp

func (m *KeyValue) GetTimestamp() uint64

func (*KeyValue) GetValue

func (m *KeyValue) GetValue() []byte

func (*KeyValue) ProtoMessage

func (*KeyValue) ProtoMessage()

func (*KeyValue) Reset

func (m *KeyValue) Reset()

func (*KeyValue) String

func (m *KeyValue) String() string

type ListLabelsRequest

type ListLabelsRequest struct {
	Regex            *string `protobuf:"bytes,1,opt,name=regex" json:"regex,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ListLabelsRequest) GetRegex

func (m *ListLabelsRequest) GetRegex() string

func (*ListLabelsRequest) ProtoMessage

func (*ListLabelsRequest) ProtoMessage()

func (*ListLabelsRequest) Reset

func (m *ListLabelsRequest) Reset()

func (*ListLabelsRequest) String

func (m *ListLabelsRequest) String() string

type ListLabelsResponse

type ListLabelsResponse struct {
	Label            [][]byte `protobuf:"bytes,1,rep,name=label" json:"label,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*ListLabelsResponse) GetLabel

func (m *ListLabelsResponse) GetLabel() [][]byte

func (*ListLabelsResponse) ProtoMessage

func (*ListLabelsResponse) ProtoMessage()

func (*ListLabelsResponse) Reset

func (m *ListLabelsResponse) Reset()

func (*ListLabelsResponse) String

func (m *ListLabelsResponse) String() string

type ListNamespaceDescriptorsRequest

type ListNamespaceDescriptorsRequest struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*ListNamespaceDescriptorsRequest) ProtoMessage

func (*ListNamespaceDescriptorsRequest) ProtoMessage()

func (*ListNamespaceDescriptorsRequest) Reset

func (*ListNamespaceDescriptorsRequest) String

type ListNamespaceDescriptorsResponse

type ListNamespaceDescriptorsResponse struct {
	NamespaceDescriptor []*NamespaceDescriptor `protobuf:"bytes,1,rep,name=namespaceDescriptor" json:"namespaceDescriptor,omitempty"`
	XXX_unrecognized    []byte                 `json:"-"`
}

func (*ListNamespaceDescriptorsResponse) GetNamespaceDescriptor

func (m *ListNamespaceDescriptorsResponse) GetNamespaceDescriptor() []*NamespaceDescriptor

func (*ListNamespaceDescriptorsResponse) ProtoMessage

func (*ListNamespaceDescriptorsResponse) ProtoMessage()

func (*ListNamespaceDescriptorsResponse) Reset

func (*ListNamespaceDescriptorsResponse) String

type ListTableDescriptorsByNamespaceRequest

type ListTableDescriptorsByNamespaceRequest struct {
	NamespaceName    *string `protobuf:"bytes,1,req,name=namespaceName" json:"namespaceName,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ListTableDescriptorsByNamespaceRequest) GetNamespaceName

func (m *ListTableDescriptorsByNamespaceRequest) GetNamespaceName() string

func (*ListTableDescriptorsByNamespaceRequest) ProtoMessage

func (*ListTableDescriptorsByNamespaceRequest) Reset

func (*ListTableDescriptorsByNamespaceRequest) String

type ListTableDescriptorsByNamespaceResponse

type ListTableDescriptorsByNamespaceResponse struct {
	TableSchema      []*TableSchema `protobuf:"bytes,1,rep,name=tableSchema" json:"tableSchema,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*ListTableDescriptorsByNamespaceResponse) GetTableSchema

func (*ListTableDescriptorsByNamespaceResponse) ProtoMessage

func (*ListTableDescriptorsByNamespaceResponse) Reset

func (*ListTableDescriptorsByNamespaceResponse) String

type ListTableNamesByNamespaceRequest

type ListTableNamesByNamespaceRequest struct {
	NamespaceName    *string `protobuf:"bytes,1,req,name=namespaceName" json:"namespaceName,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ListTableNamesByNamespaceRequest) GetNamespaceName

func (m *ListTableNamesByNamespaceRequest) GetNamespaceName() string

func (*ListTableNamesByNamespaceRequest) ProtoMessage

func (*ListTableNamesByNamespaceRequest) ProtoMessage()

func (*ListTableNamesByNamespaceRequest) Reset

func (*ListTableNamesByNamespaceRequest) String

type ListTableNamesByNamespaceResponse

type ListTableNamesByNamespaceResponse struct {
	TableName        []*TableName `protobuf:"bytes,1,rep,name=tableName" json:"tableName,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*ListTableNamesByNamespaceResponse) GetTableName

func (m *ListTableNamesByNamespaceResponse) GetTableName() []*TableName

func (*ListTableNamesByNamespaceResponse) ProtoMessage

func (*ListTableNamesByNamespaceResponse) ProtoMessage()

func (*ListTableNamesByNamespaceResponse) Reset

func (*ListTableNamesByNamespaceResponse) String

type LiveServerInfo

type LiveServerInfo struct {
	Server           *ServerName `protobuf:"bytes,1,req,name=server" json:"server,omitempty"`
	ServerLoad       *ServerLoad `protobuf:"bytes,2,req,name=server_load" json:"server_load,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*LiveServerInfo) GetServer

func (m *LiveServerInfo) GetServer() *ServerName

func (*LiveServerInfo) GetServerLoad

func (m *LiveServerInfo) GetServerLoad() *ServerLoad

func (*LiveServerInfo) ProtoMessage

func (*LiveServerInfo) ProtoMessage()

func (*LiveServerInfo) Reset

func (m *LiveServerInfo) Reset()

func (*LiveServerInfo) String

func (m *LiveServerInfo) String() string

type LoadBalancerState

type LoadBalancerState struct {
	BalancerOn       *bool  `protobuf:"varint,1,opt,name=balancer_on" json:"balancer_on,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*LoadBalancerState) GetBalancerOn

func (m *LoadBalancerState) GetBalancerOn() bool

func (*LoadBalancerState) ProtoMessage

func (*LoadBalancerState) ProtoMessage()

func (*LoadBalancerState) Reset

func (m *LoadBalancerState) Reset()

func (*LoadBalancerState) String

func (m *LoadBalancerState) String() string

type LongComparator

type LongComparator struct {
	Comparable       *ByteArrayComparable `protobuf:"bytes,1,req,name=comparable" json:"comparable,omitempty"`
	XXX_unrecognized []byte               `json:"-"`
}

func (*LongComparator) GetComparable

func (m *LongComparator) GetComparable() *ByteArrayComparable

func (*LongComparator) ProtoMessage

func (*LongComparator) ProtoMessage()

func (*LongComparator) Reset

func (m *LongComparator) Reset()

func (*LongComparator) String

func (m *LongComparator) String() string

type LongMsg

type LongMsg struct {
	LongMsg          *int64 `protobuf:"varint,1,req,name=long_msg" json:"long_msg,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*LongMsg) GetLongMsg

func (m *LongMsg) GetLongMsg() int64

func (*LongMsg) ProtoMessage

func (*LongMsg) ProtoMessage()

func (*LongMsg) Reset

func (m *LongMsg) Reset()

func (*LongMsg) String

func (m *LongMsg) String() string

type Master

type Master struct {
	// The ServerName of the current Master
	Master *ServerName `protobuf:"bytes,1,req,name=master" json:"master,omitempty"`
	// Major RPC version so that clients can know what version the master can accept.
	RpcVersion       *uint32 `protobuf:"varint,2,opt,name=rpc_version" json:"rpc_version,omitempty"`
	InfoPort         *uint32 `protobuf:"varint,3,opt,name=info_port" json:"info_port,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Content of the master znode.

func (*Master) GetInfoPort

func (m *Master) GetInfoPort() uint32

func (*Master) GetMaster

func (m *Master) GetMaster() *ServerName

func (*Master) GetRpcVersion

func (m *Master) GetRpcVersion() uint32

func (*Master) ProtoMessage

func (*Master) ProtoMessage()

func (*Master) Reset

func (m *Master) Reset()

func (*Master) String

func (m *Master) String() string

type MergeRegionsRequest

type MergeRegionsRequest struct {
	RegionA          *RegionSpecifier `protobuf:"bytes,1,req,name=region_a" json:"region_a,omitempty"`
	RegionB          *RegionSpecifier `protobuf:"bytes,2,req,name=region_b" json:"region_b,omitempty"`
	Forcible         *bool            `protobuf:"varint,3,opt,name=forcible,def=0" json:"forcible,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

* Merges the specified regions. <p> This method currently closes the regions and then merges them

func (*MergeRegionsRequest) GetForcible

func (m *MergeRegionsRequest) GetForcible() bool

func (*MergeRegionsRequest) GetRegionA

func (m *MergeRegionsRequest) GetRegionA() *RegionSpecifier

func (*MergeRegionsRequest) GetRegionB

func (m *MergeRegionsRequest) GetRegionB() *RegionSpecifier

func (*MergeRegionsRequest) ProtoMessage

func (*MergeRegionsRequest) ProtoMessage()

func (*MergeRegionsRequest) Reset

func (m *MergeRegionsRequest) Reset()

func (*MergeRegionsRequest) String

func (m *MergeRegionsRequest) String() string

type MergeRegionsResponse

type MergeRegionsResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*MergeRegionsResponse) ProtoMessage

func (*MergeRegionsResponse) ProtoMessage()

func (*MergeRegionsResponse) Reset

func (m *MergeRegionsResponse) Reset()

func (*MergeRegionsResponse) String

func (m *MergeRegionsResponse) String() string

type MetaRegionServer

type MetaRegionServer struct {
	// The ServerName hosting the meta region currently, or destination server,
	// if meta region is in transition.
	Server *ServerName `protobuf:"bytes,1,req,name=server" json:"server,omitempty"`
	// The major version of the rpc the server speaks.  This is used so that
	// clients connecting to the cluster can have prior knowledge of what version
	// to send to a RegionServer.  AsyncHBase will use this to detect versions.
	RpcVersion *uint32 `protobuf:"varint,2,opt,name=rpc_version" json:"rpc_version,omitempty"`
	// State of the region transition. OPEN means fully operational 'hbase:meta'
	State            *RegionState_State `protobuf:"varint,3,opt,name=state,enum=proto.RegionState_State" json:"state,omitempty"`
	XXX_unrecognized []byte             `json:"-"`
}

* Content of the meta-region-server znode.

func (*MetaRegionServer) GetRpcVersion

func (m *MetaRegionServer) GetRpcVersion() uint32

func (*MetaRegionServer) GetServer

func (m *MetaRegionServer) GetServer() *ServerName

func (*MetaRegionServer) GetState

func (m *MetaRegionServer) GetState() RegionState_State

func (*MetaRegionServer) ProtoMessage

func (*MetaRegionServer) ProtoMessage()

func (*MetaRegionServer) Reset

func (m *MetaRegionServer) Reset()

func (*MetaRegionServer) String

func (m *MetaRegionServer) String() string

type ModifyColumnRequest

type ModifyColumnRequest struct {
	TableName        *TableName          `protobuf:"bytes,1,req,name=table_name" json:"table_name,omitempty"`
	ColumnFamilies   *ColumnFamilySchema `protobuf:"bytes,2,req,name=column_families" json:"column_families,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

func (*ModifyColumnRequest) GetColumnFamilies

func (m *ModifyColumnRequest) GetColumnFamilies() *ColumnFamilySchema

func (*ModifyColumnRequest) GetTableName

func (m *ModifyColumnRequest) GetTableName() *TableName

func (*ModifyColumnRequest) ProtoMessage

func (*ModifyColumnRequest) ProtoMessage()

func (*ModifyColumnRequest) Reset

func (m *ModifyColumnRequest) Reset()

func (*ModifyColumnRequest) String

func (m *ModifyColumnRequest) String() string

type ModifyColumnResponse

type ModifyColumnResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*ModifyColumnResponse) ProtoMessage

func (*ModifyColumnResponse) ProtoMessage()

func (*ModifyColumnResponse) Reset

func (m *ModifyColumnResponse) Reset()

func (*ModifyColumnResponse) String

func (m *ModifyColumnResponse) String() string

type ModifyNamespaceRequest

type ModifyNamespaceRequest struct {
	NamespaceDescriptor *NamespaceDescriptor `protobuf:"bytes,1,req,name=namespaceDescriptor" json:"namespaceDescriptor,omitempty"`
	XXX_unrecognized    []byte               `json:"-"`
}

func (*ModifyNamespaceRequest) GetNamespaceDescriptor

func (m *ModifyNamespaceRequest) GetNamespaceDescriptor() *NamespaceDescriptor

func (*ModifyNamespaceRequest) ProtoMessage

func (*ModifyNamespaceRequest) ProtoMessage()

func (*ModifyNamespaceRequest) Reset

func (m *ModifyNamespaceRequest) Reset()

func (*ModifyNamespaceRequest) String

func (m *ModifyNamespaceRequest) String() string

type ModifyNamespaceResponse

type ModifyNamespaceResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*ModifyNamespaceResponse) ProtoMessage

func (*ModifyNamespaceResponse) ProtoMessage()

func (*ModifyNamespaceResponse) Reset

func (m *ModifyNamespaceResponse) Reset()

func (*ModifyNamespaceResponse) String

func (m *ModifyNamespaceResponse) String() string

type ModifyTableRequest

type ModifyTableRequest struct {
	TableName        *TableName   `protobuf:"bytes,1,req,name=table_name" json:"table_name,omitempty"`
	TableSchema      *TableSchema `protobuf:"bytes,2,req,name=table_schema" json:"table_schema,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*ModifyTableRequest) GetTableName

func (m *ModifyTableRequest) GetTableName() *TableName

func (*ModifyTableRequest) GetTableSchema

func (m *ModifyTableRequest) GetTableSchema() *TableSchema

func (*ModifyTableRequest) ProtoMessage

func (*ModifyTableRequest) ProtoMessage()

func (*ModifyTableRequest) Reset

func (m *ModifyTableRequest) Reset()

func (*ModifyTableRequest) String

func (m *ModifyTableRequest) String() string

type ModifyTableResponse

type ModifyTableResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*ModifyTableResponse) ProtoMessage

func (*ModifyTableResponse) ProtoMessage()

func (*ModifyTableResponse) Reset

func (m *ModifyTableResponse) Reset()

func (*ModifyTableResponse) String

func (m *ModifyTableResponse) String() string

type MoveRegionRequest

type MoveRegionRequest struct {
	Region           *RegionSpecifier `protobuf:"bytes,1,req,name=region" json:"region,omitempty"`
	DestServerName   *ServerName      `protobuf:"bytes,2,opt,name=dest_server_name" json:"dest_server_name,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*MoveRegionRequest) GetDestServerName

func (m *MoveRegionRequest) GetDestServerName() *ServerName

func (*MoveRegionRequest) GetRegion

func (m *MoveRegionRequest) GetRegion() *RegionSpecifier

func (*MoveRegionRequest) ProtoMessage

func (*MoveRegionRequest) ProtoMessage()

func (*MoveRegionRequest) Reset

func (m *MoveRegionRequest) Reset()

func (*MoveRegionRequest) String

func (m *MoveRegionRequest) String() string

type MoveRegionResponse

type MoveRegionResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*MoveRegionResponse) ProtoMessage

func (*MoveRegionResponse) ProtoMessage()

func (*MoveRegionResponse) Reset

func (m *MoveRegionResponse) Reset()

func (*MoveRegionResponse) String

func (m *MoveRegionResponse) String() string

type MultiRequest

type MultiRequest struct {
	RegionAction     []*RegionAction `protobuf:"bytes,1,rep,name=regionAction" json:"regionAction,omitempty"`
	NonceGroup       *uint64         `protobuf:"varint,2,opt,name=nonceGroup" json:"nonceGroup,omitempty"`
	Condition        *Condition      `protobuf:"bytes,3,opt,name=condition" json:"condition,omitempty"`
	XXX_unrecognized []byte          `json:"-"`
}

* Execute a list of actions on a given region in order. Nothing prevents a request to contains a set of RegionAction on the same region. For this reason, the matching between the MultiRequest and the MultiResponse is not

done by the region specifier but by keeping the order of the RegionActionResult vs.
the order of the RegionAction.

func (*MultiRequest) GetCondition

func (m *MultiRequest) GetCondition() *Condition

func (*MultiRequest) GetNonceGroup

func (m *MultiRequest) GetNonceGroup() uint64

func (*MultiRequest) GetRegionAction

func (m *MultiRequest) GetRegionAction() []*RegionAction

func (*MultiRequest) ProtoMessage

func (*MultiRequest) ProtoMessage()

func (*MultiRequest) Reset

func (m *MultiRequest) Reset()

func (*MultiRequest) String

func (m *MultiRequest) String() string

type MultiResponse

type MultiResponse struct {
	RegionActionResult []*RegionActionResult `protobuf:"bytes,1,rep,name=regionActionResult" json:"regionActionResult,omitempty"`
	// used for mutate to indicate processed only
	Processed        *bool  `protobuf:"varint,2,opt,name=processed" json:"processed,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*MultiResponse) GetProcessed

func (m *MultiResponse) GetProcessed() bool

func (*MultiResponse) GetRegionActionResult

func (m *MultiResponse) GetRegionActionResult() []*RegionActionResult

func (*MultiResponse) ProtoMessage

func (*MultiResponse) ProtoMessage()

func (*MultiResponse) Reset

func (m *MultiResponse) Reset()

func (*MultiResponse) String

func (m *MultiResponse) String() string

type MultiRowMutationProcessorRequest

type MultiRowMutationProcessorRequest struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*MultiRowMutationProcessorRequest) ProtoMessage

func (*MultiRowMutationProcessorRequest) ProtoMessage()

func (*MultiRowMutationProcessorRequest) Reset

func (*MultiRowMutationProcessorRequest) String

type MultiRowMutationProcessorResponse

type MultiRowMutationProcessorResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*MultiRowMutationProcessorResponse) ProtoMessage

func (*MultiRowMutationProcessorResponse) ProtoMessage()

func (*MultiRowMutationProcessorResponse) Reset

func (*MultiRowMutationProcessorResponse) String

type MultiUserAuthorizations

type MultiUserAuthorizations struct {
	UserAuths        []*UserAuthorizations `protobuf:"bytes,1,rep,name=userAuths" json:"userAuths,omitempty"`
	XXX_unrecognized []byte                `json:"-"`
}

func (*MultiUserAuthorizations) GetUserAuths

func (m *MultiUserAuthorizations) GetUserAuths() []*UserAuthorizations

func (*MultiUserAuthorizations) ProtoMessage

func (*MultiUserAuthorizations) ProtoMessage()

func (*MultiUserAuthorizations) Reset

func (m *MultiUserAuthorizations) Reset()

func (*MultiUserAuthorizations) String

func (m *MultiUserAuthorizations) String() string

type MultipleColumnPrefixFilter

type MultipleColumnPrefixFilter struct {
	SortedPrefixes   [][]byte `protobuf:"bytes,1,rep,name=sorted_prefixes" json:"sorted_prefixes,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*MultipleColumnPrefixFilter) GetSortedPrefixes

func (m *MultipleColumnPrefixFilter) GetSortedPrefixes() [][]byte

func (*MultipleColumnPrefixFilter) ProtoMessage

func (*MultipleColumnPrefixFilter) ProtoMessage()

func (*MultipleColumnPrefixFilter) Reset

func (m *MultipleColumnPrefixFilter) Reset()

func (*MultipleColumnPrefixFilter) String

func (m *MultipleColumnPrefixFilter) String() string

type MutateRequest

type MutateRequest struct {
	Region           *RegionSpecifier `protobuf:"bytes,1,req,name=region" json:"region,omitempty"`
	Mutation         *MutationProto   `protobuf:"bytes,2,req,name=mutation" json:"mutation,omitempty"`
	Condition        *Condition       `protobuf:"bytes,3,opt,name=condition" json:"condition,omitempty"`
	NonceGroup       *uint64          `protobuf:"varint,4,opt,name=nonce_group" json:"nonce_group,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

* The mutate request. Perform a single Mutate operation.

Optionally, you can specify a condition. The mutate will take place only if the condition is met. Otherwise, the mutate will be ignored. In the response result, parameter processed is used to indicate if the mutate actually happened.

func (*MutateRequest) GetCondition

func (m *MutateRequest) GetCondition() *Condition

func (*MutateRequest) GetMutation

func (m *MutateRequest) GetMutation() *MutationProto

func (*MutateRequest) GetNonceGroup

func (m *MutateRequest) GetNonceGroup() uint64

func (*MutateRequest) GetRegion

func (m *MutateRequest) GetRegion() *RegionSpecifier

func (*MutateRequest) ProtoMessage

func (*MutateRequest) ProtoMessage()

func (*MutateRequest) Reset

func (m *MutateRequest) Reset()

func (*MutateRequest) String

func (m *MutateRequest) String() string

type MutateResponse

type MutateResponse struct {
	Result *Result `protobuf:"bytes,1,opt,name=result" json:"result,omitempty"`
	// used for mutate to indicate processed only
	Processed        *bool  `protobuf:"varint,2,opt,name=processed" json:"processed,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*MutateResponse) GetProcessed

func (m *MutateResponse) GetProcessed() bool

func (*MutateResponse) GetResult

func (m *MutateResponse) GetResult() *Result

func (*MutateResponse) ProtoMessage

func (*MutateResponse) ProtoMessage()

func (*MutateResponse) Reset

func (m *MutateResponse) Reset()

func (*MutateResponse) String

func (m *MutateResponse) String() string

type MutateRowsRequest

type MutateRowsRequest struct {
	MutationRequest  []*MutationProto `protobuf:"bytes,1,rep,name=mutation_request" json:"mutation_request,omitempty"`
	NonceGroup       *uint64          `protobuf:"varint,2,opt,name=nonce_group" json:"nonce_group,omitempty"`
	Nonce            *uint64          `protobuf:"varint,3,opt,name=nonce" json:"nonce,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*MutateRowsRequest) GetMutationRequest

func (m *MutateRowsRequest) GetMutationRequest() []*MutationProto

func (*MutateRowsRequest) GetNonce

func (m *MutateRowsRequest) GetNonce() uint64

func (*MutateRowsRequest) GetNonceGroup

func (m *MutateRowsRequest) GetNonceGroup() uint64

func (*MutateRowsRequest) ProtoMessage

func (*MutateRowsRequest) ProtoMessage()

func (*MutateRowsRequest) Reset

func (m *MutateRowsRequest) Reset()

func (*MutateRowsRequest) String

func (m *MutateRowsRequest) String() string

type MutateRowsResponse

type MutateRowsResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*MutateRowsResponse) ProtoMessage

func (*MutateRowsResponse) ProtoMessage()

func (*MutateRowsResponse) Reset

func (m *MutateRowsResponse) Reset()

func (*MutateRowsResponse) String

func (m *MutateRowsResponse) String() string

type MutationProto

type MutationProto struct {
	Row         []byte                       `protobuf:"bytes,1,opt,name=row" json:"row,omitempty"`
	MutateType  *MutationProto_MutationType  `protobuf:"varint,2,opt,name=mutate_type,enum=proto.MutationProto_MutationType" json:"mutate_type,omitempty"`
	ColumnValue []*MutationProto_ColumnValue `protobuf:"bytes,3,rep,name=column_value" json:"column_value,omitempty"`
	Timestamp   *uint64                      `protobuf:"varint,4,opt,name=timestamp" json:"timestamp,omitempty"`
	Attribute   []*NameBytesPair             `protobuf:"bytes,5,rep,name=attribute" json:"attribute,omitempty"`
	Durability  *MutationProto_Durability    `protobuf:"varint,6,opt,name=durability,enum=proto.MutationProto_Durability,def=0" json:"durability,omitempty"`
	// For some mutations, a result may be returned, in which case,
	// time range can be specified for potential performance gain
	TimeRange *TimeRange `protobuf:"bytes,7,opt,name=time_range" json:"time_range,omitempty"`
	// The below count is set when the associated cells are NOT
	// part of this protobuf message; they are passed alongside
	// and then this Message is a placeholder with metadata.  The
	// count is needed to know how many to peel off the block of Cells as
	// ours.  NOTE: This is different from the pb managed cell_count of the
	// 'cell' field above which is non-null when the cells are pb'd.
	AssociatedCellCount *int32  `protobuf:"varint,8,opt,name=associated_cell_count" json:"associated_cell_count,omitempty"`
	Nonce               *uint64 `protobuf:"varint,9,opt,name=nonce" json:"nonce,omitempty"`
	XXX_unrecognized    []byte  `json:"-"`
}

* A specific mutation inside a mutate request. It can be an append, increment, put or delete based on the mutation type. It can be fully filled in or only metadata present because data is being carried elsewhere outside of pb.

func (*MutationProto) GetAssociatedCellCount

func (m *MutationProto) GetAssociatedCellCount() int32

func (*MutationProto) GetAttribute

func (m *MutationProto) GetAttribute() []*NameBytesPair

func (*MutationProto) GetColumnValue

func (m *MutationProto) GetColumnValue() []*MutationProto_ColumnValue

func (*MutationProto) GetDurability

func (m *MutationProto) GetDurability() MutationProto_Durability

func (*MutationProto) GetMutateType

func (m *MutationProto) GetMutateType() MutationProto_MutationType

func (*MutationProto) GetNonce

func (m *MutationProto) GetNonce() uint64

func (*MutationProto) GetRow

func (m *MutationProto) GetRow() []byte

func (*MutationProto) GetTimeRange

func (m *MutationProto) GetTimeRange() *TimeRange

func (*MutationProto) GetTimestamp

func (m *MutationProto) GetTimestamp() uint64

func (*MutationProto) ProtoMessage

func (*MutationProto) ProtoMessage()

func (*MutationProto) Reset

func (m *MutationProto) Reset()

func (*MutationProto) String

func (m *MutationProto) String() string

type MutationProto_ColumnValue

type MutationProto_ColumnValue struct {
	Family           []byte                                      `protobuf:"bytes,1,req,name=family" json:"family,omitempty"`
	QualifierValue   []*MutationProto_ColumnValue_QualifierValue `protobuf:"bytes,2,rep,name=qualifier_value" json:"qualifier_value,omitempty"`
	XXX_unrecognized []byte                                      `json:"-"`
}

func (*MutationProto_ColumnValue) GetFamily

func (m *MutationProto_ColumnValue) GetFamily() []byte

func (*MutationProto_ColumnValue) GetQualifierValue

func (*MutationProto_ColumnValue) ProtoMessage

func (*MutationProto_ColumnValue) ProtoMessage()

func (*MutationProto_ColumnValue) Reset

func (m *MutationProto_ColumnValue) Reset()

func (*MutationProto_ColumnValue) String

func (m *MutationProto_ColumnValue) String() string

type MutationProto_ColumnValue_QualifierValue

type MutationProto_ColumnValue_QualifierValue struct {
	Qualifier        []byte                    `protobuf:"bytes,1,opt,name=qualifier" json:"qualifier,omitempty"`
	Value            []byte                    `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
	Timestamp        *uint64                   `protobuf:"varint,3,opt,name=timestamp" json:"timestamp,omitempty"`
	DeleteType       *MutationProto_DeleteType `protobuf:"varint,4,opt,name=delete_type,enum=proto.MutationProto_DeleteType" json:"delete_type,omitempty"`
	Tags             []byte                    `protobuf:"bytes,5,opt,name=tags" json:"tags,omitempty"`
	XXX_unrecognized []byte                    `json:"-"`
}

func (*MutationProto_ColumnValue_QualifierValue) GetDeleteType

func (*MutationProto_ColumnValue_QualifierValue) GetQualifier

func (m *MutationProto_ColumnValue_QualifierValue) GetQualifier() []byte

func (*MutationProto_ColumnValue_QualifierValue) GetTags

func (*MutationProto_ColumnValue_QualifierValue) GetTimestamp

func (*MutationProto_ColumnValue_QualifierValue) GetValue

func (*MutationProto_ColumnValue_QualifierValue) ProtoMessage

func (*MutationProto_ColumnValue_QualifierValue) Reset

func (*MutationProto_ColumnValue_QualifierValue) String

type MutationProto_DeleteType

type MutationProto_DeleteType int32
const (
	MutationProto_DELETE_ONE_VERSION       MutationProto_DeleteType = 0
	MutationProto_DELETE_MULTIPLE_VERSIONS MutationProto_DeleteType = 1
	MutationProto_DELETE_FAMILY            MutationProto_DeleteType = 2
	MutationProto_DELETE_FAMILY_VERSION    MutationProto_DeleteType = 3
)

func (MutationProto_DeleteType) Enum

func (MutationProto_DeleteType) String

func (x MutationProto_DeleteType) String() string

func (*MutationProto_DeleteType) UnmarshalJSON

func (x *MutationProto_DeleteType) UnmarshalJSON(data []byte) error

type MutationProto_Durability

type MutationProto_Durability int32
const (
	MutationProto_USE_DEFAULT MutationProto_Durability = 0
	MutationProto_SKIP_WAL    MutationProto_Durability = 1
	MutationProto_ASYNC_WAL   MutationProto_Durability = 2
	MutationProto_SYNC_WAL    MutationProto_Durability = 3
	MutationProto_FSYNC_WAL   MutationProto_Durability = 4
)
const Default_MutationProto_Durability MutationProto_Durability = MutationProto_USE_DEFAULT

func (MutationProto_Durability) Enum

func (MutationProto_Durability) String

func (x MutationProto_Durability) String() string

func (*MutationProto_Durability) UnmarshalJSON

func (x *MutationProto_Durability) UnmarshalJSON(data []byte) error

type MutationProto_MutationType

type MutationProto_MutationType int32
const (
	MutationProto_APPEND    MutationProto_MutationType = 0
	MutationProto_INCREMENT MutationProto_MutationType = 1
	MutationProto_PUT       MutationProto_MutationType = 2
	MutationProto_DELETE    MutationProto_MutationType = 3
)

func (MutationProto_MutationType) Enum

func (MutationProto_MutationType) String

func (*MutationProto_MutationType) UnmarshalJSON

func (x *MutationProto_MutationType) UnmarshalJSON(data []byte) error

type NameBytesPair

type NameBytesPair struct {
	Name             *string `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	Value            []byte  `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*NameBytesPair) GetName

func (m *NameBytesPair) GetName() string

func (*NameBytesPair) GetValue

func (m *NameBytesPair) GetValue() []byte

func (*NameBytesPair) ProtoMessage

func (*NameBytesPair) ProtoMessage()

func (*NameBytesPair) Reset

func (m *NameBytesPair) Reset()

func (*NameBytesPair) String

func (m *NameBytesPair) String() string

type NameInt64Pair

type NameInt64Pair struct {
	Name             *string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Value            *int64  `protobuf:"varint,2,opt,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*NameInt64Pair) GetName

func (m *NameInt64Pair) GetName() string

func (*NameInt64Pair) GetValue

func (m *NameInt64Pair) GetValue() int64

func (*NameInt64Pair) ProtoMessage

func (*NameInt64Pair) ProtoMessage()

func (*NameInt64Pair) Reset

func (m *NameInt64Pair) Reset()

func (*NameInt64Pair) String

func (m *NameInt64Pair) String() string

type NameStringPair

type NameStringPair struct {
	Name             *string `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	Value            *string `protobuf:"bytes,2,req,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*NameStringPair) GetName

func (m *NameStringPair) GetName() string

func (*NameStringPair) GetValue

func (m *NameStringPair) GetValue() string

func (*NameStringPair) ProtoMessage

func (*NameStringPair) ProtoMessage()

func (*NameStringPair) Reset

func (m *NameStringPair) Reset()

func (*NameStringPair) String

func (m *NameStringPair) String() string

type NamespaceDescriptor

type NamespaceDescriptor struct {
	Name             []byte            `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	Configuration    []*NameStringPair `protobuf:"bytes,2,rep,name=configuration" json:"configuration,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

func (*NamespaceDescriptor) GetConfiguration

func (m *NamespaceDescriptor) GetConfiguration() []*NameStringPair

func (*NamespaceDescriptor) GetName

func (m *NamespaceDescriptor) GetName() []byte

func (*NamespaceDescriptor) ProtoMessage

func (*NamespaceDescriptor) ProtoMessage()

func (*NamespaceDescriptor) Reset

func (m *NamespaceDescriptor) Reset()

func (*NamespaceDescriptor) String

func (m *NamespaceDescriptor) String() string

type NamespacePermission

type NamespacePermission struct {
	NamespaceName    []byte              `protobuf:"bytes,1,opt,name=namespace_name" json:"namespace_name,omitempty"`
	Action           []Permission_Action `protobuf:"varint,2,rep,name=action,enum=proto.Permission_Action" json:"action,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

func (*NamespacePermission) GetAction

func (m *NamespacePermission) GetAction() []Permission_Action

func (*NamespacePermission) GetNamespaceName

func (m *NamespacePermission) GetNamespaceName() []byte

func (*NamespacePermission) ProtoMessage

func (*NamespacePermission) ProtoMessage()

func (*NamespacePermission) Reset

func (m *NamespacePermission) Reset()

func (*NamespacePermission) String

func (m *NamespacePermission) String() string

type NullComparator

type NullComparator struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*NullComparator) ProtoMessage

func (*NullComparator) ProtoMessage()

func (*NullComparator) Reset

func (m *NullComparator) Reset()

func (*NullComparator) String

func (m *NullComparator) String() string

type OfflineRegionRequest

type OfflineRegionRequest struct {
	Region           *RegionSpecifier `protobuf:"bytes,1,req,name=region" json:"region,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*OfflineRegionRequest) GetRegion

func (m *OfflineRegionRequest) GetRegion() *RegionSpecifier

func (*OfflineRegionRequest) ProtoMessage

func (*OfflineRegionRequest) ProtoMessage()

func (*OfflineRegionRequest) Reset

func (m *OfflineRegionRequest) Reset()

func (*OfflineRegionRequest) String

func (m *OfflineRegionRequest) String() string

type OfflineRegionResponse

type OfflineRegionResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*OfflineRegionResponse) ProtoMessage

func (*OfflineRegionResponse) ProtoMessage()

func (*OfflineRegionResponse) Reset

func (m *OfflineRegionResponse) Reset()

func (*OfflineRegionResponse) String

func (m *OfflineRegionResponse) String() string

type OpenRegionRequest

type OpenRegionRequest struct {
	OpenInfo []*OpenRegionRequest_RegionOpenInfo `protobuf:"bytes,1,rep,name=open_info" json:"open_info,omitempty"`
	// the intended server for this RPC.
	ServerStartCode  *uint64 `protobuf:"varint,2,opt,name=serverStartCode" json:"serverStartCode,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*OpenRegionRequest) GetOpenInfo

func (*OpenRegionRequest) GetServerStartCode

func (m *OpenRegionRequest) GetServerStartCode() uint64

func (*OpenRegionRequest) ProtoMessage

func (*OpenRegionRequest) ProtoMessage()

func (*OpenRegionRequest) Reset

func (m *OpenRegionRequest) Reset()

func (*OpenRegionRequest) String

func (m *OpenRegionRequest) String() string

type OpenRegionRequest_RegionOpenInfo

type OpenRegionRequest_RegionOpenInfo struct {
	Region               *RegionInfo   `protobuf:"bytes,1,req,name=region" json:"region,omitempty"`
	VersionOfOfflineNode *uint32       `protobuf:"varint,2,opt,name=version_of_offline_node" json:"version_of_offline_node,omitempty"`
	FavoredNodes         []*ServerName `protobuf:"bytes,3,rep,name=favored_nodes" json:"favored_nodes,omitempty"`
	// open region for distributedLogReplay
	OpenForDistributedLogReplay *bool  `protobuf:"varint,4,opt,name=openForDistributedLogReplay" json:"openForDistributedLogReplay,omitempty"`
	XXX_unrecognized            []byte `json:"-"`
}

func (*OpenRegionRequest_RegionOpenInfo) GetFavoredNodes

func (m *OpenRegionRequest_RegionOpenInfo) GetFavoredNodes() []*ServerName

func (*OpenRegionRequest_RegionOpenInfo) GetOpenForDistributedLogReplay

func (m *OpenRegionRequest_RegionOpenInfo) GetOpenForDistributedLogReplay() bool

func (*OpenRegionRequest_RegionOpenInfo) GetRegion

func (*OpenRegionRequest_RegionOpenInfo) GetVersionOfOfflineNode

func (m *OpenRegionRequest_RegionOpenInfo) GetVersionOfOfflineNode() uint32

func (*OpenRegionRequest_RegionOpenInfo) ProtoMessage

func (*OpenRegionRequest_RegionOpenInfo) ProtoMessage()

func (*OpenRegionRequest_RegionOpenInfo) Reset

func (*OpenRegionRequest_RegionOpenInfo) String

type OpenRegionResponse

type OpenRegionResponse struct {
	OpeningState     []OpenRegionResponse_RegionOpeningState `protobuf:"varint,1,rep,name=opening_state,enum=proto.OpenRegionResponse_RegionOpeningState" json:"opening_state,omitempty"`
	XXX_unrecognized []byte                                  `json:"-"`
}

func (*OpenRegionResponse) GetOpeningState

func (*OpenRegionResponse) ProtoMessage

func (*OpenRegionResponse) ProtoMessage()

func (*OpenRegionResponse) Reset

func (m *OpenRegionResponse) Reset()

func (*OpenRegionResponse) String

func (m *OpenRegionResponse) String() string

type OpenRegionResponse_RegionOpeningState

type OpenRegionResponse_RegionOpeningState int32
const (
	OpenRegionResponse_OPENED         OpenRegionResponse_RegionOpeningState = 0
	OpenRegionResponse_ALREADY_OPENED OpenRegionResponse_RegionOpeningState = 1
	OpenRegionResponse_FAILED_OPENING OpenRegionResponse_RegionOpeningState = 2
)

func (OpenRegionResponse_RegionOpeningState) Enum

func (OpenRegionResponse_RegionOpeningState) String

func (*OpenRegionResponse_RegionOpeningState) UnmarshalJSON

func (x *OpenRegionResponse_RegionOpeningState) UnmarshalJSON(data []byte) error

type PageFilter

type PageFilter struct {
	PageSize         *int64 `protobuf:"varint,1,req,name=page_size" json:"page_size,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*PageFilter) GetPageSize

func (m *PageFilter) GetPageSize() int64

func (*PageFilter) ProtoMessage

func (*PageFilter) ProtoMessage()

func (*PageFilter) Reset

func (m *PageFilter) Reset()

func (*PageFilter) String

func (m *PageFilter) String() string

type Permission

type Permission struct {
	Type                *Permission_Type     `protobuf:"varint,1,req,name=type,enum=proto.Permission_Type" json:"type,omitempty"`
	GlobalPermission    *GlobalPermission    `protobuf:"bytes,2,opt,name=global_permission" json:"global_permission,omitempty"`
	NamespacePermission *NamespacePermission `protobuf:"bytes,3,opt,name=namespace_permission" json:"namespace_permission,omitempty"`
	TablePermission     *TablePermission     `protobuf:"bytes,4,opt,name=table_permission" json:"table_permission,omitempty"`
	XXX_unrecognized    []byte               `json:"-"`
}

func (*Permission) GetGlobalPermission

func (m *Permission) GetGlobalPermission() *GlobalPermission

func (*Permission) GetNamespacePermission

func (m *Permission) GetNamespacePermission() *NamespacePermission

func (*Permission) GetTablePermission

func (m *Permission) GetTablePermission() *TablePermission

func (*Permission) GetType

func (m *Permission) GetType() Permission_Type

func (*Permission) ProtoMessage

func (*Permission) ProtoMessage()

func (*Permission) Reset

func (m *Permission) Reset()

func (*Permission) String

func (m *Permission) String() string

type Permission_Action

type Permission_Action int32
const (
	Permission_READ   Permission_Action = 0
	Permission_WRITE  Permission_Action = 1
	Permission_EXEC   Permission_Action = 2
	Permission_CREATE Permission_Action = 3
	Permission_ADMIN  Permission_Action = 4
)

func (Permission_Action) Enum

func (Permission_Action) String

func (x Permission_Action) String() string

func (*Permission_Action) UnmarshalJSON

func (x *Permission_Action) UnmarshalJSON(data []byte) error

type Permission_Type

type Permission_Type int32
const (
	Permission_Global    Permission_Type = 1
	Permission_Namespace Permission_Type = 2
	Permission_Table     Permission_Type = 3
)

func (Permission_Type) Enum

func (x Permission_Type) Enum() *Permission_Type

func (Permission_Type) String

func (x Permission_Type) String() string

func (*Permission_Type) UnmarshalJSON

func (x *Permission_Type) UnmarshalJSON(data []byte) error

type PrefixFilter

type PrefixFilter struct {
	Prefix           []byte `protobuf:"bytes,1,opt,name=prefix" json:"prefix,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*PrefixFilter) GetPrefix

func (m *PrefixFilter) GetPrefix() []byte

func (*PrefixFilter) ProtoMessage

func (*PrefixFilter) ProtoMessage()

func (*PrefixFilter) Reset

func (m *PrefixFilter) Reset()

func (*PrefixFilter) String

func (m *PrefixFilter) String() string

type PrepareBulkLoadRequest

type PrepareBulkLoadRequest struct {
	TableName        *TableName `protobuf:"bytes,1,req,name=table_name" json:"table_name,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

func (*PrepareBulkLoadRequest) GetTableName

func (m *PrepareBulkLoadRequest) GetTableName() *TableName

func (*PrepareBulkLoadRequest) ProtoMessage

func (*PrepareBulkLoadRequest) ProtoMessage()

func (*PrepareBulkLoadRequest) Reset

func (m *PrepareBulkLoadRequest) Reset()

func (*PrepareBulkLoadRequest) String

func (m *PrepareBulkLoadRequest) String() string

type PrepareBulkLoadResponse

type PrepareBulkLoadResponse struct {
	BulkToken        *string `protobuf:"bytes,1,req,name=bulk_token" json:"bulk_token,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*PrepareBulkLoadResponse) GetBulkToken

func (m *PrepareBulkLoadResponse) GetBulkToken() string

func (*PrepareBulkLoadResponse) ProtoMessage

func (*PrepareBulkLoadResponse) ProtoMessage()

func (*PrepareBulkLoadResponse) Reset

func (m *PrepareBulkLoadResponse) Reset()

func (*PrepareBulkLoadResponse) String

func (m *PrepareBulkLoadResponse) String() string

type ProcedureDescription

type ProcedureDescription struct {
	Signature        *string           `protobuf:"bytes,1,req,name=signature" json:"signature,omitempty"`
	Instance         *string           `protobuf:"bytes,2,opt,name=instance" json:"instance,omitempty"`
	CreationTime     *int64            `protobuf:"varint,3,opt,name=creation_time,def=0" json:"creation_time,omitempty"`
	Configuration    []*NameStringPair `protobuf:"bytes,4,rep,name=configuration" json:"configuration,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

* Description of the distributed procedure to take

func (*ProcedureDescription) GetConfiguration

func (m *ProcedureDescription) GetConfiguration() []*NameStringPair

func (*ProcedureDescription) GetCreationTime

func (m *ProcedureDescription) GetCreationTime() int64

func (*ProcedureDescription) GetInstance

func (m *ProcedureDescription) GetInstance() string

func (*ProcedureDescription) GetSignature

func (m *ProcedureDescription) GetSignature() string

func (*ProcedureDescription) ProtoMessage

func (*ProcedureDescription) ProtoMessage()

func (*ProcedureDescription) Reset

func (m *ProcedureDescription) Reset()

func (*ProcedureDescription) String

func (m *ProcedureDescription) String() string

type ProcessRequest

type ProcessRequest struct {
	RowProcessorClassName              *string `protobuf:"bytes,1,req,name=row_processor_class_name" json:"row_processor_class_name,omitempty"`
	RowProcessorInitializerMessageName *string `protobuf:"bytes,2,opt,name=row_processor_initializer_message_name" json:"row_processor_initializer_message_name,omitempty"`
	RowProcessorInitializerMessage     []byte  `protobuf:"bytes,3,opt,name=row_processor_initializer_message" json:"row_processor_initializer_message,omitempty"`
	NonceGroup                         *uint64 `protobuf:"varint,4,opt,name=nonce_group" json:"nonce_group,omitempty"`
	Nonce                              *uint64 `protobuf:"varint,5,opt,name=nonce" json:"nonce,omitempty"`
	XXX_unrecognized                   []byte  `json:"-"`
}

func (*ProcessRequest) GetNonce

func (m *ProcessRequest) GetNonce() uint64

func (*ProcessRequest) GetNonceGroup

func (m *ProcessRequest) GetNonceGroup() uint64

func (*ProcessRequest) GetRowProcessorClassName

func (m *ProcessRequest) GetRowProcessorClassName() string

func (*ProcessRequest) GetRowProcessorInitializerMessage

func (m *ProcessRequest) GetRowProcessorInitializerMessage() []byte

func (*ProcessRequest) GetRowProcessorInitializerMessageName

func (m *ProcessRequest) GetRowProcessorInitializerMessageName() string

func (*ProcessRequest) ProtoMessage

func (*ProcessRequest) ProtoMessage()

func (*ProcessRequest) Reset

func (m *ProcessRequest) Reset()

func (*ProcessRequest) String

func (m *ProcessRequest) String() string

type ProcessResponse

type ProcessResponse struct {
	RowProcessorResult []byte `protobuf:"bytes,1,req,name=row_processor_result" json:"row_processor_result,omitempty"`
	XXX_unrecognized   []byte `json:"-"`
}

func (*ProcessResponse) GetRowProcessorResult

func (m *ProcessResponse) GetRowProcessorResult() []byte

func (*ProcessResponse) ProtoMessage

func (*ProcessResponse) ProtoMessage()

func (*ProcessResponse) Reset

func (m *ProcessResponse) Reset()

func (*ProcessResponse) String

func (m *ProcessResponse) String() string

type QualifierFilter

type QualifierFilter struct {
	CompareFilter    *CompareFilter `protobuf:"bytes,1,req,name=compare_filter" json:"compare_filter,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*QualifierFilter) GetCompareFilter

func (m *QualifierFilter) GetCompareFilter() *CompareFilter

func (*QualifierFilter) ProtoMessage

func (*QualifierFilter) ProtoMessage()

func (*QualifierFilter) Reset

func (m *QualifierFilter) Reset()

func (*QualifierFilter) String

func (m *QualifierFilter) String() string

type QuotaScope

type QuotaScope int32
const (
	QuotaScope_CLUSTER QuotaScope = 1
	QuotaScope_MACHINE QuotaScope = 2
)
const Default_TimedQuota_Scope QuotaScope = QuotaScope_MACHINE

func (QuotaScope) Enum

func (x QuotaScope) Enum() *QuotaScope

func (QuotaScope) String

func (x QuotaScope) String() string

func (*QuotaScope) UnmarshalJSON

func (x *QuotaScope) UnmarshalJSON(data []byte) error

type QuotaType

type QuotaType int32
const (
	QuotaType_THROTTLE QuotaType = 1
)

func (QuotaType) Enum

func (x QuotaType) Enum() *QuotaType

func (QuotaType) String

func (x QuotaType) String() string

func (*QuotaType) UnmarshalJSON

func (x *QuotaType) UnmarshalJSON(data []byte) error

type QuotaUsage

type QuotaUsage struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*QuotaUsage) ProtoMessage

func (*QuotaUsage) ProtoMessage()

func (*QuotaUsage) Reset

func (m *QuotaUsage) Reset()

func (*QuotaUsage) String

func (m *QuotaUsage) String() string

type Quotas

type Quotas struct {
	BypassGlobals    *bool     `protobuf:"varint,1,opt,name=bypass_globals,def=0" json:"bypass_globals,omitempty"`
	Throttle         *Throttle `protobuf:"bytes,2,opt,name=throttle" json:"throttle,omitempty"`
	XXX_unrecognized []byte    `json:"-"`
}

func (*Quotas) GetBypassGlobals

func (m *Quotas) GetBypassGlobals() bool

func (*Quotas) GetThrottle

func (m *Quotas) GetThrottle() *Throttle

func (*Quotas) ProtoMessage

func (*Quotas) ProtoMessage()

func (*Quotas) Reset

func (m *Quotas) Reset()

func (*Quotas) String

func (m *Quotas) String() string

type RPCTInfo

type RPCTInfo struct {
	TraceId          *int64 `protobuf:"varint,1,opt,name=trace_id" json:"trace_id,omitempty"`
	ParentId         *int64 `protobuf:"varint,2,opt,name=parent_id" json:"parent_id,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

Used to pass through the information necessary to continue a trace after an RPC is made. All we need is the traceid (so we know the overarching trace this message is a part of), and the id of the current span when this message was sent, so we know what span caused the new span we will create when this message is received.

func (*RPCTInfo) GetParentId

func (m *RPCTInfo) GetParentId() int64

func (*RPCTInfo) GetTraceId

func (m *RPCTInfo) GetTraceId() int64

func (*RPCTInfo) ProtoMessage

func (*RPCTInfo) ProtoMessage()

func (*RPCTInfo) Reset

func (m *RPCTInfo) Reset()

func (*RPCTInfo) String

func (m *RPCTInfo) String() string

type RandomRowFilter

type RandomRowFilter struct {
	Chance           *float32 `protobuf:"fixed32,1,req,name=chance" json:"chance,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*RandomRowFilter) GetChance

func (m *RandomRowFilter) GetChance() float32

func (*RandomRowFilter) ProtoMessage

func (*RandomRowFilter) ProtoMessage()

func (*RandomRowFilter) Reset

func (m *RandomRowFilter) Reset()

func (*RandomRowFilter) String

func (m *RandomRowFilter) String() string

type Reference

type Reference struct {
	Splitkey         []byte           `protobuf:"bytes,1,req,name=splitkey" json:"splitkey,omitempty"`
	Range            *Reference_Range `protobuf:"varint,2,req,name=range,enum=proto.Reference_Range" json:"range,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

* Reference file content used when we split an hfile under a region.

func (*Reference) GetRange

func (m *Reference) GetRange() Reference_Range

func (*Reference) GetSplitkey

func (m *Reference) GetSplitkey() []byte

func (*Reference) ProtoMessage

func (*Reference) ProtoMessage()

func (*Reference) Reset

func (m *Reference) Reset()

func (*Reference) String

func (m *Reference) String() string

type Reference_Range

type Reference_Range int32
const (
	Reference_TOP    Reference_Range = 0
	Reference_BOTTOM Reference_Range = 1
)

func (Reference_Range) Enum

func (x Reference_Range) Enum() *Reference_Range

func (Reference_Range) String

func (x Reference_Range) String() string

func (*Reference_Range) UnmarshalJSON

func (x *Reference_Range) UnmarshalJSON(data []byte) error

type RegexStringComparator

type RegexStringComparator struct {
	Pattern          *string `protobuf:"bytes,1,req,name=pattern" json:"pattern,omitempty"`
	PatternFlags     *int32  `protobuf:"varint,2,req,name=pattern_flags" json:"pattern_flags,omitempty"`
	Charset          *string `protobuf:"bytes,3,req,name=charset" json:"charset,omitempty"`
	Engine           *string `protobuf:"bytes,4,opt,name=engine" json:"engine,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*RegexStringComparator) GetCharset

func (m *RegexStringComparator) GetCharset() string

func (*RegexStringComparator) GetEngine

func (m *RegexStringComparator) GetEngine() string

func (*RegexStringComparator) GetPattern

func (m *RegexStringComparator) GetPattern() string

func (*RegexStringComparator) GetPatternFlags

func (m *RegexStringComparator) GetPatternFlags() int32

func (*RegexStringComparator) ProtoMessage

func (*RegexStringComparator) ProtoMessage()

func (*RegexStringComparator) Reset

func (m *RegexStringComparator) Reset()

func (*RegexStringComparator) String

func (m *RegexStringComparator) String() string

type RegionAction

type RegionAction struct {
	Region *RegionSpecifier `protobuf:"bytes,1,req,name=region" json:"region,omitempty"`
	// When set, run mutations as atomic unit.
	Atomic           *bool     `protobuf:"varint,2,opt,name=atomic" json:"atomic,omitempty"`
	Action           []*Action `protobuf:"bytes,3,rep,name=action" json:"action,omitempty"`
	XXX_unrecognized []byte    `json:"-"`
}

* Actions to run against a Region.

func (*RegionAction) GetAction

func (m *RegionAction) GetAction() []*Action

func (*RegionAction) GetAtomic

func (m *RegionAction) GetAtomic() bool

func (*RegionAction) GetRegion

func (m *RegionAction) GetRegion() *RegionSpecifier

func (*RegionAction) ProtoMessage

func (*RegionAction) ProtoMessage()

func (*RegionAction) Reset

func (m *RegionAction) Reset()

func (*RegionAction) String

func (m *RegionAction) String() string

type RegionActionResult

type RegionActionResult struct {
	ResultOrException []*ResultOrException `protobuf:"bytes,1,rep,name=resultOrException" json:"resultOrException,omitempty"`
	// If the operation failed globally for this region, this exception is set
	Exception        *NameBytesPair `protobuf:"bytes,2,opt,name=exception" json:"exception,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

* The result of a RegionAction.

func (*RegionActionResult) GetException

func (m *RegionActionResult) GetException() *NameBytesPair

func (*RegionActionResult) GetResultOrException

func (m *RegionActionResult) GetResultOrException() []*ResultOrException

func (*RegionActionResult) ProtoMessage

func (*RegionActionResult) ProtoMessage()

func (*RegionActionResult) Reset

func (m *RegionActionResult) Reset()

func (*RegionActionResult) String

func (m *RegionActionResult) String() string

type RegionEventDescriptor

type RegionEventDescriptor struct {
	EventType         *RegionEventDescriptor_EventType `protobuf:"varint,1,req,name=event_type,enum=proto.RegionEventDescriptor_EventType" json:"event_type,omitempty"`
	TableName         []byte                           `protobuf:"bytes,2,req,name=table_name" json:"table_name,omitempty"`
	EncodedRegionName []byte                           `protobuf:"bytes,3,req,name=encoded_region_name" json:"encoded_region_name,omitempty"`
	LogSequenceNumber *uint64                          `protobuf:"varint,4,opt,name=log_sequence_number" json:"log_sequence_number,omitempty"`
	Stores            []*StoreDescriptor               `protobuf:"bytes,5,rep,name=stores" json:"stores,omitempty"`
	Server            *ServerName                      `protobuf:"bytes,6,opt,name=server" json:"server,omitempty"`
	RegionName        []byte                           `protobuf:"bytes,7,opt,name=region_name" json:"region_name,omitempty"`
	XXX_unrecognized  []byte                           `json:"-"`
}

* Special WAL entry to hold all related to a region event (open/close).

func (*RegionEventDescriptor) GetEncodedRegionName

func (m *RegionEventDescriptor) GetEncodedRegionName() []byte

func (*RegionEventDescriptor) GetEventType

func (*RegionEventDescriptor) GetLogSequenceNumber

func (m *RegionEventDescriptor) GetLogSequenceNumber() uint64

func (*RegionEventDescriptor) GetRegionName

func (m *RegionEventDescriptor) GetRegionName() []byte

func (*RegionEventDescriptor) GetServer

func (m *RegionEventDescriptor) GetServer() *ServerName

func (*RegionEventDescriptor) GetStores

func (m *RegionEventDescriptor) GetStores() []*StoreDescriptor

func (*RegionEventDescriptor) GetTableName

func (m *RegionEventDescriptor) GetTableName() []byte

func (*RegionEventDescriptor) ProtoMessage

func (*RegionEventDescriptor) ProtoMessage()

func (*RegionEventDescriptor) Reset

func (m *RegionEventDescriptor) Reset()

func (*RegionEventDescriptor) String

func (m *RegionEventDescriptor) String() string

type RegionEventDescriptor_EventType

type RegionEventDescriptor_EventType int32
const (
	RegionEventDescriptor_REGION_OPEN  RegionEventDescriptor_EventType = 0
	RegionEventDescriptor_REGION_CLOSE RegionEventDescriptor_EventType = 1
)

func (RegionEventDescriptor_EventType) Enum

func (RegionEventDescriptor_EventType) String

func (*RegionEventDescriptor_EventType) UnmarshalJSON

func (x *RegionEventDescriptor_EventType) UnmarshalJSON(data []byte) error

type RegionInTransition

type RegionInTransition struct {
	Spec             *RegionSpecifier `protobuf:"bytes,1,req,name=spec" json:"spec,omitempty"`
	RegionState      *RegionState     `protobuf:"bytes,2,req,name=region_state" json:"region_state,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*RegionInTransition) GetRegionState

func (m *RegionInTransition) GetRegionState() *RegionState

func (*RegionInTransition) GetSpec

func (m *RegionInTransition) GetSpec() *RegionSpecifier

func (*RegionInTransition) ProtoMessage

func (*RegionInTransition) ProtoMessage()

func (*RegionInTransition) Reset

func (m *RegionInTransition) Reset()

func (*RegionInTransition) String

func (m *RegionInTransition) String() string

type RegionInfo

type RegionInfo struct {
	RegionId         *uint64    `protobuf:"varint,1,req,name=region_id" json:"region_id,omitempty"`
	TableName        *TableName `protobuf:"bytes,2,req,name=table_name" json:"table_name,omitempty"`
	StartKey         []byte     `protobuf:"bytes,3,opt,name=start_key" json:"start_key,omitempty"`
	EndKey           []byte     `protobuf:"bytes,4,opt,name=end_key" json:"end_key,omitempty"`
	Offline          *bool      `protobuf:"varint,5,opt,name=offline" json:"offline,omitempty"`
	Split            *bool      `protobuf:"varint,6,opt,name=split" json:"split,omitempty"`
	ReplicaId        *int32     `protobuf:"varint,7,opt,name=replica_id,def=0" json:"replica_id,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

* Protocol buffer version of HRegionInfo.

func (*RegionInfo) GetEndKey

func (m *RegionInfo) GetEndKey() []byte

func (*RegionInfo) GetOffline

func (m *RegionInfo) GetOffline() bool

func (*RegionInfo) GetRegionId

func (m *RegionInfo) GetRegionId() uint64

func (*RegionInfo) GetReplicaId

func (m *RegionInfo) GetReplicaId() int32

func (*RegionInfo) GetSplit

func (m *RegionInfo) GetSplit() bool

func (*RegionInfo) GetStartKey

func (m *RegionInfo) GetStartKey() []byte

func (*RegionInfo) GetTableName

func (m *RegionInfo) GetTableName() *TableName

func (*RegionInfo) ProtoMessage

func (*RegionInfo) ProtoMessage()

func (*RegionInfo) Reset

func (m *RegionInfo) Reset()

func (*RegionInfo) String

func (m *RegionInfo) String() string

type RegionLoad

type RegionLoad struct {
	// * the region specifier
	RegionSpecifier *RegionSpecifier `protobuf:"bytes,1,req,name=region_specifier" json:"region_specifier,omitempty"`
	// * the number of stores for the region
	Stores *uint32 `protobuf:"varint,2,opt,name=stores" json:"stores,omitempty"`
	// * the number of storefiles for the region
	Storefiles *uint32 `protobuf:"varint,3,opt,name=storefiles" json:"storefiles,omitempty"`
	// * the total size of the store files for the region, uncompressed, in MB
	StoreUncompressedSize_MB *uint32 `protobuf:"varint,4,opt,name=store_uncompressed_size_MB" json:"store_uncompressed_size_MB,omitempty"`
	// * the current total size of the store files for the region, in MB
	StorefileSize_MB *uint32 `protobuf:"varint,5,opt,name=storefile_size_MB" json:"storefile_size_MB,omitempty"`
	// * the current size of the memstore for the region, in MB
	MemstoreSize_MB *uint32 `protobuf:"varint,6,opt,name=memstore_size_MB" json:"memstore_size_MB,omitempty"`
	// *
	// The current total size of root-level store file indexes for the region,
	// in MB. The same as {@link #rootIndexSizeKB} but in MB.
	StorefileIndexSize_MB *uint32 `protobuf:"varint,7,opt,name=storefile_index_size_MB" json:"storefile_index_size_MB,omitempty"`
	// * the current total read requests made to region
	ReadRequestsCount *uint64 `protobuf:"varint,8,opt,name=read_requests_count" json:"read_requests_count,omitempty"`
	// * the current total write requests made to region
	WriteRequestsCount *uint64 `protobuf:"varint,9,opt,name=write_requests_count" json:"write_requests_count,omitempty"`
	// * the total compacting key values in currently running compaction
	TotalCompacting_KVs *uint64 `protobuf:"varint,10,opt,name=total_compacting_KVs" json:"total_compacting_KVs,omitempty"`
	// * the completed count of key values in currently running compaction
	CurrentCompacted_KVs *uint64 `protobuf:"varint,11,opt,name=current_compacted_KVs" json:"current_compacted_KVs,omitempty"`
	// * The current total size of root-level indexes for the region, in KB.
	RootIndexSize_KB *uint32 `protobuf:"varint,12,opt,name=root_index_size_KB" json:"root_index_size_KB,omitempty"`
	// * The total size of all index blocks, not just the root level, in KB.
	TotalStaticIndexSize_KB *uint32 `protobuf:"varint,13,opt,name=total_static_index_size_KB" json:"total_static_index_size_KB,omitempty"`
	// *
	// The total size of all Bloom filter blocks, not just loaded into the
	// block cache, in KB.
	TotalStaticBloomSize_KB *uint32 `protobuf:"varint,14,opt,name=total_static_bloom_size_KB" json:"total_static_bloom_size_KB,omitempty"`
	// * the most recent sequence Id from cache flush
	CompleteSequenceId *uint64 `protobuf:"varint,15,opt,name=complete_sequence_id" json:"complete_sequence_id,omitempty"`
	// * The current data locality for region in the regionserver
	DataLocality     *float32 `protobuf:"fixed32,16,opt,name=data_locality" json:"data_locality,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*RegionLoad) GetCompleteSequenceId

func (m *RegionLoad) GetCompleteSequenceId() uint64

func (*RegionLoad) GetCurrentCompacted_KVs

func (m *RegionLoad) GetCurrentCompacted_KVs() uint64

func (*RegionLoad) GetDataLocality

func (m *RegionLoad) GetDataLocality() float32

func (*RegionLoad) GetMemstoreSize_MB

func (m *RegionLoad) GetMemstoreSize_MB() uint32

func (*RegionLoad) GetReadRequestsCount

func (m *RegionLoad) GetReadRequestsCount() uint64

func (*RegionLoad) GetRegionSpecifier

func (m *RegionLoad) GetRegionSpecifier() *RegionSpecifier

func (*RegionLoad) GetRootIndexSize_KB

func (m *RegionLoad) GetRootIndexSize_KB() uint32

func (*RegionLoad) GetStoreUncompressedSize_MB

func (m *RegionLoad) GetStoreUncompressedSize_MB() uint32

func (*RegionLoad) GetStorefileIndexSize_MB

func (m *RegionLoad) GetStorefileIndexSize_MB() uint32

func (*RegionLoad) GetStorefileSize_MB

func (m *RegionLoad) GetStorefileSize_MB() uint32

func (*RegionLoad) GetStorefiles

func (m *RegionLoad) GetStorefiles() uint32

func (*RegionLoad) GetStores

func (m *RegionLoad) GetStores() uint32

func (*RegionLoad) GetTotalCompacting_KVs

func (m *RegionLoad) GetTotalCompacting_KVs() uint64

func (*RegionLoad) GetTotalStaticBloomSize_KB

func (m *RegionLoad) GetTotalStaticBloomSize_KB() uint32

func (*RegionLoad) GetTotalStaticIndexSize_KB

func (m *RegionLoad) GetTotalStaticIndexSize_KB() uint32

func (*RegionLoad) GetWriteRequestsCount

func (m *RegionLoad) GetWriteRequestsCount() uint64

func (*RegionLoad) ProtoMessage

func (*RegionLoad) ProtoMessage()

func (*RegionLoad) Reset

func (m *RegionLoad) Reset()

func (*RegionLoad) String

func (m *RegionLoad) String() string

type RegionLoadStats

type RegionLoadStats struct {
	// Percent load on the memstore. Guaranteed to be positive, between 0 and 100.
	MemstoreLoad *int32 `protobuf:"varint,1,opt,name=memstoreLoad,def=0" json:"memstoreLoad,omitempty"`
	// Percent JVM heap occupancy. Guaranteed to be positive, between 0 and 100.
	// We can move this to "ServerLoadStats" should we develop them.
	HeapOccupancy    *int32 `protobuf:"varint,2,opt,name=heapOccupancy,def=0" json:"heapOccupancy,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

Statistics about the current load on the region

func (*RegionLoadStats) GetHeapOccupancy

func (m *RegionLoadStats) GetHeapOccupancy() int32

func (*RegionLoadStats) GetMemstoreLoad

func (m *RegionLoadStats) GetMemstoreLoad() int32

func (*RegionLoadStats) ProtoMessage

func (*RegionLoadStats) ProtoMessage()

func (*RegionLoadStats) Reset

func (m *RegionLoadStats) Reset()

func (*RegionLoadStats) String

func (m *RegionLoadStats) String() string

type RegionServerInfo

type RegionServerInfo struct {
	InfoPort         *int32 `protobuf:"varint,1,opt,name=infoPort" json:"infoPort,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

* Description of the region server info

func (*RegionServerInfo) GetInfoPort

func (m *RegionServerInfo) GetInfoPort() int32

func (*RegionServerInfo) ProtoMessage

func (*RegionServerInfo) ProtoMessage()

func (*RegionServerInfo) Reset

func (m *RegionServerInfo) Reset()

func (*RegionServerInfo) String

func (m *RegionServerInfo) String() string

type RegionServerReportRequest

type RegionServerReportRequest struct {
	Server *ServerName `protobuf:"bytes,1,req,name=server" json:"server,omitempty"`
	// * load the server is under
	Load             *ServerLoad `protobuf:"bytes,2,opt,name=load" json:"load,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*RegionServerReportRequest) GetLoad

func (m *RegionServerReportRequest) GetLoad() *ServerLoad

func (*RegionServerReportRequest) GetServer

func (m *RegionServerReportRequest) GetServer() *ServerName

func (*RegionServerReportRequest) ProtoMessage

func (*RegionServerReportRequest) ProtoMessage()

func (*RegionServerReportRequest) Reset

func (m *RegionServerReportRequest) Reset()

func (*RegionServerReportRequest) String

func (m *RegionServerReportRequest) String() string

type RegionServerReportResponse

type RegionServerReportResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*RegionServerReportResponse) ProtoMessage

func (*RegionServerReportResponse) ProtoMessage()

func (*RegionServerReportResponse) Reset

func (m *RegionServerReportResponse) Reset()

func (*RegionServerReportResponse) String

func (m *RegionServerReportResponse) String() string

type RegionServerStartupRequest

type RegionServerStartupRequest struct {
	// * Port number this regionserver is up on
	Port *uint32 `protobuf:"varint,1,req,name=port" json:"port,omitempty"`
	// * This servers' startcode
	ServerStartCode *uint64 `protobuf:"varint,2,req,name=server_start_code" json:"server_start_code,omitempty"`
	// * Current time of the region server in ms
	ServerCurrentTime *uint64 `protobuf:"varint,3,req,name=server_current_time" json:"server_current_time,omitempty"`
	XXX_unrecognized  []byte  `json:"-"`
}

func (*RegionServerStartupRequest) GetPort

func (m *RegionServerStartupRequest) GetPort() uint32

func (*RegionServerStartupRequest) GetServerCurrentTime

func (m *RegionServerStartupRequest) GetServerCurrentTime() uint64

func (*RegionServerStartupRequest) GetServerStartCode

func (m *RegionServerStartupRequest) GetServerStartCode() uint64

func (*RegionServerStartupRequest) ProtoMessage

func (*RegionServerStartupRequest) ProtoMessage()

func (*RegionServerStartupRequest) Reset

func (m *RegionServerStartupRequest) Reset()

func (*RegionServerStartupRequest) String

func (m *RegionServerStartupRequest) String() string

type RegionServerStartupResponse

type RegionServerStartupResponse struct {
	// *
	// Configuration for the regionserver to use: e.g. filesystem,
	// hbase rootdir, the hostname to use creating the RegionServer ServerName,
	// etc
	MapEntries       []*NameStringPair `protobuf:"bytes,1,rep,name=map_entries" json:"map_entries,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

func (*RegionServerStartupResponse) GetMapEntries

func (m *RegionServerStartupResponse) GetMapEntries() []*NameStringPair

func (*RegionServerStartupResponse) ProtoMessage

func (*RegionServerStartupResponse) ProtoMessage()

func (*RegionServerStartupResponse) Reset

func (m *RegionServerStartupResponse) Reset()

func (*RegionServerStartupResponse) String

func (m *RegionServerStartupResponse) String() string

type RegionSpecifier

type RegionSpecifier struct {
	Type             *RegionSpecifier_RegionSpecifierType `protobuf:"varint,1,req,name=type,enum=proto.RegionSpecifier_RegionSpecifierType" json:"type,omitempty"`
	Value            []byte                               `protobuf:"bytes,2,req,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte                               `json:"-"`
}

* Container protocol buffer to specify a region. You can specify region by region name, or the hash of the region name, which is known as encoded region name.

func (*RegionSpecifier) GetType

func (*RegionSpecifier) GetValue

func (m *RegionSpecifier) GetValue() []byte

func (*RegionSpecifier) ProtoMessage

func (*RegionSpecifier) ProtoMessage()

func (*RegionSpecifier) Reset

func (m *RegionSpecifier) Reset()

func (*RegionSpecifier) String

func (m *RegionSpecifier) String() string

type RegionSpecifier_RegionSpecifierType

type RegionSpecifier_RegionSpecifierType int32
const (
	// <tablename>,<startkey>,<regionId>.<encodedName>
	RegionSpecifier_REGION_NAME RegionSpecifier_RegionSpecifierType = 1
	// hash of <tablename>,<startkey>,<regionId>
	RegionSpecifier_ENCODED_REGION_NAME RegionSpecifier_RegionSpecifierType = 2
)

func (RegionSpecifier_RegionSpecifierType) Enum

func (RegionSpecifier_RegionSpecifierType) String

func (*RegionSpecifier_RegionSpecifierType) UnmarshalJSON

func (x *RegionSpecifier_RegionSpecifierType) UnmarshalJSON(data []byte) error

type RegionState

type RegionState struct {
	RegionInfo       *RegionInfo        `protobuf:"bytes,1,req,name=region_info" json:"region_info,omitempty"`
	State            *RegionState_State `protobuf:"varint,2,req,name=state,enum=proto.RegionState_State" json:"state,omitempty"`
	Stamp            *uint64            `protobuf:"varint,3,opt,name=stamp" json:"stamp,omitempty"`
	XXX_unrecognized []byte             `json:"-"`
}

func (*RegionState) GetRegionInfo

func (m *RegionState) GetRegionInfo() *RegionInfo

func (*RegionState) GetStamp

func (m *RegionState) GetStamp() uint64

func (*RegionState) GetState

func (m *RegionState) GetState() RegionState_State

func (*RegionState) ProtoMessage

func (*RegionState) ProtoMessage()

func (*RegionState) Reset

func (m *RegionState) Reset()

func (*RegionState) String

func (m *RegionState) String() string

type RegionStateTransition

type RegionStateTransition struct {
	TransitionCode *RegionStateTransition_TransitionCode `protobuf:"varint,1,req,name=transition_code,enum=proto.RegionStateTransition_TransitionCode" json:"transition_code,omitempty"`
	// * Mutliple regions are involved during merging/splitting
	RegionInfo []*RegionInfo `protobuf:"bytes,2,rep,name=region_info" json:"region_info,omitempty"`
	// * For newly opened region, the open seq num is needed
	OpenSeqNum       *uint64 `protobuf:"varint,3,opt,name=open_seq_num" json:"open_seq_num,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*RegionStateTransition) GetOpenSeqNum

func (m *RegionStateTransition) GetOpenSeqNum() uint64

func (*RegionStateTransition) GetRegionInfo

func (m *RegionStateTransition) GetRegionInfo() []*RegionInfo

func (*RegionStateTransition) GetTransitionCode

func (*RegionStateTransition) ProtoMessage

func (*RegionStateTransition) ProtoMessage()

func (*RegionStateTransition) Reset

func (m *RegionStateTransition) Reset()

func (*RegionStateTransition) String

func (m *RegionStateTransition) String() string

type RegionStateTransition_TransitionCode

type RegionStateTransition_TransitionCode int32
const (
	RegionStateTransition_OPENED      RegionStateTransition_TransitionCode = 0
	RegionStateTransition_FAILED_OPEN RegionStateTransition_TransitionCode = 1
	// * No failed_close, in which case region server will abort
	RegionStateTransition_CLOSED RegionStateTransition_TransitionCode = 2
	// * Ask master for ok to split/merge region(s)
	RegionStateTransition_READY_TO_SPLIT RegionStateTransition_TransitionCode = 3
	RegionStateTransition_READY_TO_MERGE RegionStateTransition_TransitionCode = 4
	RegionStateTransition_SPLIT_PONR     RegionStateTransition_TransitionCode = 5
	RegionStateTransition_MERGE_PONR     RegionStateTransition_TransitionCode = 6
	RegionStateTransition_SPLIT          RegionStateTransition_TransitionCode = 7
	RegionStateTransition_MERGED         RegionStateTransition_TransitionCode = 8
	RegionStateTransition_SPLIT_REVERTED RegionStateTransition_TransitionCode = 9
	RegionStateTransition_MERGE_REVERTED RegionStateTransition_TransitionCode = 10
)

func (RegionStateTransition_TransitionCode) Enum

func (RegionStateTransition_TransitionCode) String

func (*RegionStateTransition_TransitionCode) UnmarshalJSON

func (x *RegionStateTransition_TransitionCode) UnmarshalJSON(data []byte) error

type RegionState_State

type RegionState_State int32
const (
	RegionState_OFFLINE       RegionState_State = 0
	RegionState_PENDING_OPEN  RegionState_State = 1
	RegionState_OPENING       RegionState_State = 2
	RegionState_OPEN          RegionState_State = 3
	RegionState_PENDING_CLOSE RegionState_State = 4
	RegionState_CLOSING       RegionState_State = 5
	RegionState_CLOSED        RegionState_State = 6
	RegionState_SPLITTING     RegionState_State = 7
	RegionState_SPLIT         RegionState_State = 8
	RegionState_FAILED_OPEN   RegionState_State = 9
	RegionState_FAILED_CLOSE  RegionState_State = 10
	RegionState_MERGING       RegionState_State = 11
	RegionState_MERGED        RegionState_State = 12
	RegionState_SPLITTING_NEW RegionState_State = 13
	// region but hasn't be created yet, or master doesn't
	// know it's already created
	RegionState_MERGING_NEW RegionState_State = 14
)

func (RegionState_State) Enum

func (RegionState_State) String

func (x RegionState_State) String() string

func (*RegionState_State) UnmarshalJSON

func (x *RegionState_State) UnmarshalJSON(data []byte) error

type RegionStoreSequenceIds

type RegionStoreSequenceIds struct {
	LastFlushedSequenceId *uint64            `protobuf:"varint,1,req,name=last_flushed_sequence_id" json:"last_flushed_sequence_id,omitempty"`
	StoreSequenceId       []*StoreSequenceId `protobuf:"bytes,2,rep,name=store_sequence_id" json:"store_sequence_id,omitempty"`
	XXX_unrecognized      []byte             `json:"-"`
}

* contains a sequence id of a region which should be the minimum of its store sequence ids and list sequence ids of the region's stores

func (*RegionStoreSequenceIds) GetLastFlushedSequenceId

func (m *RegionStoreSequenceIds) GetLastFlushedSequenceId() uint64

func (*RegionStoreSequenceIds) GetStoreSequenceId

func (m *RegionStoreSequenceIds) GetStoreSequenceId() []*StoreSequenceId

func (*RegionStoreSequenceIds) ProtoMessage

func (*RegionStoreSequenceIds) ProtoMessage()

func (*RegionStoreSequenceIds) Reset

func (m *RegionStoreSequenceIds) Reset()

func (*RegionStoreSequenceIds) String

func (m *RegionStoreSequenceIds) String() string

type RegionTransition

type RegionTransition struct {
	// Code for EventType gotten by doing o.a.h.h.EventHandler.EventType.getCode()
	EventTypeCode *uint32 `protobuf:"varint,1,req,name=event_type_code" json:"event_type_code,omitempty"`
	// Full regionname in bytes
	RegionName []byte  `protobuf:"bytes,2,req,name=region_name" json:"region_name,omitempty"`
	CreateTime *uint64 `protobuf:"varint,3,req,name=create_time" json:"create_time,omitempty"`
	// The region server where the transition will happen or is happening
	ServerName       *ServerName `protobuf:"bytes,4,req,name=server_name" json:"server_name,omitempty"`
	Payload          []byte      `protobuf:"bytes,5,opt,name=payload" json:"payload,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

* What we write under unassigned up in zookeeper as a region moves through open/close, etc., regions. Details a region in transition.

func (*RegionTransition) GetCreateTime

func (m *RegionTransition) GetCreateTime() uint64

func (*RegionTransition) GetEventTypeCode

func (m *RegionTransition) GetEventTypeCode() uint32

func (*RegionTransition) GetPayload

func (m *RegionTransition) GetPayload() []byte

func (*RegionTransition) GetRegionName

func (m *RegionTransition) GetRegionName() []byte

func (*RegionTransition) GetServerName

func (m *RegionTransition) GetServerName() *ServerName

func (*RegionTransition) ProtoMessage

func (*RegionTransition) ProtoMessage()

func (*RegionTransition) Reset

func (m *RegionTransition) Reset()

func (*RegionTransition) String

func (m *RegionTransition) String() string

type ReplicateWALEntryRequest

type ReplicateWALEntryRequest struct {
	Entry            []*WALEntry `protobuf:"bytes,1,rep,name=entry" json:"entry,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

* Replicates the given entries. The guarantee is that the given entries will be durable on the slave cluster if this method returns without any exception. hbase.replication has to be set to true for this to work.

func (*ReplicateWALEntryRequest) GetEntry

func (m *ReplicateWALEntryRequest) GetEntry() []*WALEntry

func (*ReplicateWALEntryRequest) ProtoMessage

func (*ReplicateWALEntryRequest) ProtoMessage()

func (*ReplicateWALEntryRequest) Reset

func (m *ReplicateWALEntryRequest) Reset()

func (*ReplicateWALEntryRequest) String

func (m *ReplicateWALEntryRequest) String() string

type ReplicateWALEntryResponse

type ReplicateWALEntryResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*ReplicateWALEntryResponse) ProtoMessage

func (*ReplicateWALEntryResponse) ProtoMessage()

func (*ReplicateWALEntryResponse) Reset

func (m *ReplicateWALEntryResponse) Reset()

func (*ReplicateWALEntryResponse) String

func (m *ReplicateWALEntryResponse) String() string

type ReplicationHLogPosition

type ReplicationHLogPosition struct {
	Position         *int64 `protobuf:"varint,1,req,name=position" json:"position,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

* Used by replication. Holds the current position in an WAL file.

func (*ReplicationHLogPosition) GetPosition

func (m *ReplicationHLogPosition) GetPosition() int64

func (*ReplicationHLogPosition) ProtoMessage

func (*ReplicationHLogPosition) ProtoMessage()

func (*ReplicationHLogPosition) Reset

func (m *ReplicationHLogPosition) Reset()

func (*ReplicationHLogPosition) String

func (m *ReplicationHLogPosition) String() string

type ReplicationLoadSink

type ReplicationLoadSink struct {
	AgeOfLastAppliedOp        *uint64 `protobuf:"varint,1,req,name=ageOfLastAppliedOp" json:"ageOfLastAppliedOp,omitempty"`
	TimeStampsOfLastAppliedOp *uint64 `protobuf:"varint,2,req,name=timeStampsOfLastAppliedOp" json:"timeStampsOfLastAppliedOp,omitempty"`
	XXX_unrecognized          []byte  `json:"-"`
}

func (*ReplicationLoadSink) GetAgeOfLastAppliedOp

func (m *ReplicationLoadSink) GetAgeOfLastAppliedOp() uint64

func (*ReplicationLoadSink) GetTimeStampsOfLastAppliedOp

func (m *ReplicationLoadSink) GetTimeStampsOfLastAppliedOp() uint64

func (*ReplicationLoadSink) ProtoMessage

func (*ReplicationLoadSink) ProtoMessage()

func (*ReplicationLoadSink) Reset

func (m *ReplicationLoadSink) Reset()

func (*ReplicationLoadSink) String

func (m *ReplicationLoadSink) String() string

type ReplicationLoadSource

type ReplicationLoadSource struct {
	PeerID                   *string `protobuf:"bytes,1,req,name=peerID" json:"peerID,omitempty"`
	AgeOfLastShippedOp       *uint64 `protobuf:"varint,2,req,name=ageOfLastShippedOp" json:"ageOfLastShippedOp,omitempty"`
	SizeOfLogQueue           *uint32 `protobuf:"varint,3,req,name=sizeOfLogQueue" json:"sizeOfLogQueue,omitempty"`
	TimeStampOfLastShippedOp *uint64 `protobuf:"varint,4,req,name=timeStampOfLastShippedOp" json:"timeStampOfLastShippedOp,omitempty"`
	ReplicationLag           *uint64 `protobuf:"varint,5,req,name=replicationLag" json:"replicationLag,omitempty"`
	XXX_unrecognized         []byte  `json:"-"`
}

func (*ReplicationLoadSource) GetAgeOfLastShippedOp

func (m *ReplicationLoadSource) GetAgeOfLastShippedOp() uint64

func (*ReplicationLoadSource) GetPeerID

func (m *ReplicationLoadSource) GetPeerID() string

func (*ReplicationLoadSource) GetReplicationLag

func (m *ReplicationLoadSource) GetReplicationLag() uint64

func (*ReplicationLoadSource) GetSizeOfLogQueue

func (m *ReplicationLoadSource) GetSizeOfLogQueue() uint32

func (*ReplicationLoadSource) GetTimeStampOfLastShippedOp

func (m *ReplicationLoadSource) GetTimeStampOfLastShippedOp() uint64

func (*ReplicationLoadSource) ProtoMessage

func (*ReplicationLoadSource) ProtoMessage()

func (*ReplicationLoadSource) Reset

func (m *ReplicationLoadSource) Reset()

func (*ReplicationLoadSource) String

func (m *ReplicationLoadSource) String() string

type ReplicationLock

type ReplicationLock struct {
	LockOwner        *string `protobuf:"bytes,1,req,name=lock_owner" json:"lock_owner,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Used by replication. Used to lock a region server during failover.

func (*ReplicationLock) GetLockOwner

func (m *ReplicationLock) GetLockOwner() string

func (*ReplicationLock) ProtoMessage

func (*ReplicationLock) ProtoMessage()

func (*ReplicationLock) Reset

func (m *ReplicationLock) Reset()

func (*ReplicationLock) String

func (m *ReplicationLock) String() string

type ReplicationPeer

type ReplicationPeer struct {
	// clusterkey is the concatenation of the slave cluster's
	// hbase.zookeeper.quorum:hbase.zookeeper.property.clientPort:zookeeper.znode.parent
	Clusterkey              *string           `protobuf:"bytes,1,req,name=clusterkey" json:"clusterkey,omitempty"`
	ReplicationEndpointImpl *string           `protobuf:"bytes,2,opt,name=replicationEndpointImpl" json:"replicationEndpointImpl,omitempty"`
	Data                    []*BytesBytesPair `protobuf:"bytes,3,rep,name=data" json:"data,omitempty"`
	Configuration           []*NameStringPair `protobuf:"bytes,4,rep,name=configuration" json:"configuration,omitempty"`
	XXX_unrecognized        []byte            `json:"-"`
}

* Used by replication. Holds a replication peer key.

func (*ReplicationPeer) GetClusterkey

func (m *ReplicationPeer) GetClusterkey() string

func (*ReplicationPeer) GetConfiguration

func (m *ReplicationPeer) GetConfiguration() []*NameStringPair

func (*ReplicationPeer) GetData

func (m *ReplicationPeer) GetData() []*BytesBytesPair

func (*ReplicationPeer) GetReplicationEndpointImpl

func (m *ReplicationPeer) GetReplicationEndpointImpl() string

func (*ReplicationPeer) ProtoMessage

func (*ReplicationPeer) ProtoMessage()

func (*ReplicationPeer) Reset

func (m *ReplicationPeer) Reset()

func (*ReplicationPeer) String

func (m *ReplicationPeer) String() string

type ReplicationState

type ReplicationState struct {
	State            *ReplicationState_State `protobuf:"varint,1,req,name=state,enum=proto.ReplicationState_State" json:"state,omitempty"`
	XXX_unrecognized []byte                  `json:"-"`
}

* Used by replication. Holds whether enabled or disabled

func (*ReplicationState) GetState

func (*ReplicationState) ProtoMessage

func (*ReplicationState) ProtoMessage()

func (*ReplicationState) Reset

func (m *ReplicationState) Reset()

func (*ReplicationState) String

func (m *ReplicationState) String() string

type ReplicationState_State

type ReplicationState_State int32
const (
	ReplicationState_ENABLED  ReplicationState_State = 0
	ReplicationState_DISABLED ReplicationState_State = 1
)

func (ReplicationState_State) Enum

func (ReplicationState_State) String

func (x ReplicationState_State) String() string

func (*ReplicationState_State) UnmarshalJSON

func (x *ReplicationState_State) UnmarshalJSON(data []byte) error

type ReportRSFatalErrorRequest

type ReportRSFatalErrorRequest struct {
	// * name of the server experiencing the error
	Server *ServerName `protobuf:"bytes,1,req,name=server" json:"server,omitempty"`
	// * informative text to expose in the master logs and UI
	ErrorMessage     *string `protobuf:"bytes,2,req,name=error_message" json:"error_message,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ReportRSFatalErrorRequest) GetErrorMessage

func (m *ReportRSFatalErrorRequest) GetErrorMessage() string

func (*ReportRSFatalErrorRequest) GetServer

func (m *ReportRSFatalErrorRequest) GetServer() *ServerName

func (*ReportRSFatalErrorRequest) ProtoMessage

func (*ReportRSFatalErrorRequest) ProtoMessage()

func (*ReportRSFatalErrorRequest) Reset

func (m *ReportRSFatalErrorRequest) Reset()

func (*ReportRSFatalErrorRequest) String

func (m *ReportRSFatalErrorRequest) String() string

type ReportRSFatalErrorResponse

type ReportRSFatalErrorResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*ReportRSFatalErrorResponse) ProtoMessage

func (*ReportRSFatalErrorResponse) ProtoMessage()

func (*ReportRSFatalErrorResponse) Reset

func (m *ReportRSFatalErrorResponse) Reset()

func (*ReportRSFatalErrorResponse) String

func (m *ReportRSFatalErrorResponse) String() string

type ReportRegionStateTransitionRequest

type ReportRegionStateTransitionRequest struct {
	// * This region server's server name
	Server           *ServerName              `protobuf:"bytes,1,req,name=server" json:"server,omitempty"`
	Transition       []*RegionStateTransition `protobuf:"bytes,2,rep,name=transition" json:"transition,omitempty"`
	XXX_unrecognized []byte                   `json:"-"`
}

func (*ReportRegionStateTransitionRequest) GetServer

func (*ReportRegionStateTransitionRequest) GetTransition

func (*ReportRegionStateTransitionRequest) ProtoMessage

func (*ReportRegionStateTransitionRequest) ProtoMessage()

func (*ReportRegionStateTransitionRequest) Reset

func (*ReportRegionStateTransitionRequest) String

type ReportRegionStateTransitionResponse

type ReportRegionStateTransitionResponse struct {
	// * Error message if failed to update the region state
	ErrorMessage     *string `protobuf:"bytes,1,opt,name=error_message" json:"error_message,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ReportRegionStateTransitionResponse) GetErrorMessage

func (m *ReportRegionStateTransitionResponse) GetErrorMessage() string

func (*ReportRegionStateTransitionResponse) ProtoMessage

func (*ReportRegionStateTransitionResponse) ProtoMessage()

func (*ReportRegionStateTransitionResponse) Reset

func (*ReportRegionStateTransitionResponse) String

type RequestHeader

type RequestHeader struct {
	// Monotonically increasing call_id to keep track of RPC requests and their response
	CallId     *uint32   `protobuf:"varint,1,opt,name=call_id" json:"call_id,omitempty"`
	TraceInfo  *RPCTInfo `protobuf:"bytes,2,opt,name=trace_info" json:"trace_info,omitempty"`
	MethodName *string   `protobuf:"bytes,3,opt,name=method_name" json:"method_name,omitempty"`
	// If true, then a pb Message param follows.
	RequestParam *bool `protobuf:"varint,4,opt,name=request_param" json:"request_param,omitempty"`
	// If present, then an encoded data block follows.
	CellBlockMeta *CellBlockMeta `protobuf:"bytes,5,opt,name=cell_block_meta" json:"cell_block_meta,omitempty"`
	// 0 is NORMAL priority.  200 is HIGH.  If no priority, treat it as NORMAL.
	// See HConstants.
	Priority         *uint32 `protobuf:"varint,6,opt,name=priority" json:"priority,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

Header sent making a request.

func (*RequestHeader) GetCallId

func (m *RequestHeader) GetCallId() uint32

func (*RequestHeader) GetCellBlockMeta

func (m *RequestHeader) GetCellBlockMeta() *CellBlockMeta

func (*RequestHeader) GetMethodName

func (m *RequestHeader) GetMethodName() string

func (*RequestHeader) GetPriority

func (m *RequestHeader) GetPriority() uint32

func (*RequestHeader) GetRequestParam

func (m *RequestHeader) GetRequestParam() bool

func (*RequestHeader) GetTraceInfo

func (m *RequestHeader) GetTraceInfo() *RPCTInfo

func (*RequestHeader) ProtoMessage

func (*RequestHeader) ProtoMessage()

func (*RequestHeader) Reset

func (m *RequestHeader) Reset()

func (*RequestHeader) String

func (m *RequestHeader) String() string

type ResponseHeader

type ResponseHeader struct {
	CallId *uint32 `protobuf:"varint,1,opt,name=call_id" json:"call_id,omitempty"`
	// If present, then request threw an exception and no response message (else we presume one)
	Exception *ExceptionResponse `protobuf:"bytes,2,opt,name=exception" json:"exception,omitempty"`
	// If present, then an encoded data block follows.
	CellBlockMeta    *CellBlockMeta `protobuf:"bytes,3,opt,name=cell_block_meta" json:"cell_block_meta,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*ResponseHeader) GetCallId

func (m *ResponseHeader) GetCallId() uint32

func (*ResponseHeader) GetCellBlockMeta

func (m *ResponseHeader) GetCellBlockMeta() *CellBlockMeta

func (*ResponseHeader) GetException

func (m *ResponseHeader) GetException() *ExceptionResponse

func (*ResponseHeader) ProtoMessage

func (*ResponseHeader) ProtoMessage()

func (*ResponseHeader) Reset

func (m *ResponseHeader) Reset()

func (*ResponseHeader) String

func (m *ResponseHeader) String() string

type RestoreSnapshotRequest

type RestoreSnapshotRequest struct {
	Snapshot         *SnapshotDescription `protobuf:"bytes,1,req,name=snapshot" json:"snapshot,omitempty"`
	XXX_unrecognized []byte               `json:"-"`
}

func (*RestoreSnapshotRequest) GetSnapshot

func (m *RestoreSnapshotRequest) GetSnapshot() *SnapshotDescription

func (*RestoreSnapshotRequest) ProtoMessage

func (*RestoreSnapshotRequest) ProtoMessage()

func (*RestoreSnapshotRequest) Reset

func (m *RestoreSnapshotRequest) Reset()

func (*RestoreSnapshotRequest) String

func (m *RestoreSnapshotRequest) String() string

type RestoreSnapshotResponse

type RestoreSnapshotResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*RestoreSnapshotResponse) ProtoMessage

func (*RestoreSnapshotResponse) ProtoMessage()

func (*RestoreSnapshotResponse) Reset

func (m *RestoreSnapshotResponse) Reset()

func (*RestoreSnapshotResponse) String

func (m *RestoreSnapshotResponse) String() string

type Result

type Result struct {
	// Result includes the Cells or else it just has a count of Cells
	// that are carried otherwise.
	Cell []*Cell `protobuf:"bytes,1,rep,name=cell" json:"cell,omitempty"`
	// The below count is set when the associated cells are
	// not part of this protobuf message; they are passed alongside
	// and then this Message is just a placeholder with metadata.
	// The count is needed to know how many to peel off the block of Cells as
	// ours.  NOTE: This is different from the pb managed cell_count of the
	// 'cell' field above which is non-null when the cells are pb'd.
	AssociatedCellCount *int32 `protobuf:"varint,2,opt,name=associated_cell_count" json:"associated_cell_count,omitempty"`
	// used for Get to check existence only. Not set if existence_only was not set to true
	//  in the query.
	Exists *bool `protobuf:"varint,3,opt,name=exists" json:"exists,omitempty"`
	// Whether or not the results are coming from possibly stale data
	Stale            *bool  `protobuf:"varint,4,opt,name=stale,def=0" json:"stale,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*Result) GetAssociatedCellCount

func (m *Result) GetAssociatedCellCount() int32

func (*Result) GetCell

func (m *Result) GetCell() []*Cell

func (*Result) GetExists

func (m *Result) GetExists() bool

func (*Result) GetStale

func (m *Result) GetStale() bool

func (*Result) ProtoMessage

func (*Result) ProtoMessage()

func (*Result) Reset

func (m *Result) Reset()

func (*Result) String

func (m *Result) String() string

type ResultOrException

type ResultOrException struct {
	// If part of a multi call, save original index of the list of all
	// passed so can align this response w/ original request.
	Index     *uint32        `protobuf:"varint,1,opt,name=index" json:"index,omitempty"`
	Result    *Result        `protobuf:"bytes,2,opt,name=result" json:"result,omitempty"`
	Exception *NameBytesPair `protobuf:"bytes,3,opt,name=exception" json:"exception,omitempty"`
	// result if this was a coprocessor service call
	ServiceResult *CoprocessorServiceResult `protobuf:"bytes,4,opt,name=service_result" json:"service_result,omitempty"`
	// current load on the region
	LoadStats        *RegionLoadStats `protobuf:"bytes,5,opt,name=loadStats" json:"loadStats,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

* Either a Result or an Exception NameBytesPair (keyed by exception name whose value is the exception stringified) or maybe empty if no result and no exception.

func (*ResultOrException) GetException

func (m *ResultOrException) GetException() *NameBytesPair

func (*ResultOrException) GetIndex

func (m *ResultOrException) GetIndex() uint32

func (*ResultOrException) GetLoadStats

func (m *ResultOrException) GetLoadStats() *RegionLoadStats

func (*ResultOrException) GetResult

func (m *ResultOrException) GetResult() *Result

func (*ResultOrException) GetServiceResult

func (m *ResultOrException) GetServiceResult() *CoprocessorServiceResult

func (*ResultOrException) ProtoMessage

func (*ResultOrException) ProtoMessage()

func (*ResultOrException) Reset

func (m *ResultOrException) Reset()

func (*ResultOrException) String

func (m *ResultOrException) String() string

type RevokeRequest

type RevokeRequest struct {
	UserPermission   *UserPermission `protobuf:"bytes,1,req,name=user_permission" json:"user_permission,omitempty"`
	XXX_unrecognized []byte          `json:"-"`
}

func (*RevokeRequest) GetUserPermission

func (m *RevokeRequest) GetUserPermission() *UserPermission

func (*RevokeRequest) ProtoMessage

func (*RevokeRequest) ProtoMessage()

func (*RevokeRequest) Reset

func (m *RevokeRequest) Reset()

func (*RevokeRequest) String

func (m *RevokeRequest) String() string

type RevokeResponse

type RevokeResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*RevokeResponse) ProtoMessage

func (*RevokeResponse) ProtoMessage()

func (*RevokeResponse) Reset

func (m *RevokeResponse) Reset()

func (*RevokeResponse) String

func (m *RevokeResponse) String() string

type RollWALWriterRequest

type RollWALWriterRequest struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*RollWALWriterRequest) ProtoMessage

func (*RollWALWriterRequest) ProtoMessage()

func (*RollWALWriterRequest) Reset

func (m *RollWALWriterRequest) Reset()

func (*RollWALWriterRequest) String

func (m *RollWALWriterRequest) String() string

type RollWALWriterResponse

type RollWALWriterResponse struct {
	// A list of encoded name of regions to flush
	RegionToFlush    [][]byte `protobuf:"bytes,1,rep,name=region_to_flush" json:"region_to_flush,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

Roll request responses no longer include regions to flush this list will always be empty when talking to a 1.0 server

func (*RollWALWriterResponse) GetRegionToFlush

func (m *RollWALWriterResponse) GetRegionToFlush() [][]byte

func (*RollWALWriterResponse) ProtoMessage

func (*RollWALWriterResponse) ProtoMessage()

func (*RollWALWriterResponse) Reset

func (m *RollWALWriterResponse) Reset()

func (*RollWALWriterResponse) String

func (m *RollWALWriterResponse) String() string

type RowFilter

type RowFilter struct {
	CompareFilter    *CompareFilter `protobuf:"bytes,1,req,name=compare_filter" json:"compare_filter,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*RowFilter) GetCompareFilter

func (m *RowFilter) GetCompareFilter() *CompareFilter

func (*RowFilter) ProtoMessage

func (*RowFilter) ProtoMessage()

func (*RowFilter) Reset

func (m *RowFilter) Reset()

func (*RowFilter) String

func (m *RowFilter) String() string

type RunCatalogScanRequest

type RunCatalogScanRequest struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*RunCatalogScanRequest) ProtoMessage

func (*RunCatalogScanRequest) ProtoMessage()

func (*RunCatalogScanRequest) Reset

func (m *RunCatalogScanRequest) Reset()

func (*RunCatalogScanRequest) String

func (m *RunCatalogScanRequest) String() string

type RunCatalogScanResponse

type RunCatalogScanResponse struct {
	ScanResult       *int32 `protobuf:"varint,1,opt,name=scan_result" json:"scan_result,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*RunCatalogScanResponse) GetScanResult

func (m *RunCatalogScanResponse) GetScanResult() int32

func (*RunCatalogScanResponse) ProtoMessage

func (*RunCatalogScanResponse) ProtoMessage()

func (*RunCatalogScanResponse) Reset

func (m *RunCatalogScanResponse) Reset()

func (*RunCatalogScanResponse) String

func (m *RunCatalogScanResponse) String() string

type Scan

type Scan struct {
	Column                     []*Column        `protobuf:"bytes,1,rep,name=column" json:"column,omitempty"`
	Attribute                  []*NameBytesPair `protobuf:"bytes,2,rep,name=attribute" json:"attribute,omitempty"`
	StartRow                   []byte           `protobuf:"bytes,3,opt,name=start_row" json:"start_row,omitempty"`
	StopRow                    []byte           `protobuf:"bytes,4,opt,name=stop_row" json:"stop_row,omitempty"`
	Filter                     *Filter          `protobuf:"bytes,5,opt,name=filter" json:"filter,omitempty"`
	TimeRange                  *TimeRange       `protobuf:"bytes,6,opt,name=time_range" json:"time_range,omitempty"`
	MaxVersions                *uint32          `protobuf:"varint,7,opt,name=max_versions,def=1" json:"max_versions,omitempty"`
	CacheBlocks                *bool            `protobuf:"varint,8,opt,name=cache_blocks,def=1" json:"cache_blocks,omitempty"`
	BatchSize                  *uint32          `protobuf:"varint,9,opt,name=batch_size" json:"batch_size,omitempty"`
	MaxResultSize              *uint64          `protobuf:"varint,10,opt,name=max_result_size" json:"max_result_size,omitempty"`
	StoreLimit                 *uint32          `protobuf:"varint,11,opt,name=store_limit" json:"store_limit,omitempty"`
	StoreOffset                *uint32          `protobuf:"varint,12,opt,name=store_offset" json:"store_offset,omitempty"`
	LoadColumnFamiliesOnDemand *bool            `protobuf:"varint,13,opt,name=load_column_families_on_demand" json:"load_column_families_on_demand,omitempty"`
	Small                      *bool            `protobuf:"varint,14,opt,name=small" json:"small,omitempty"`
	Reversed                   *bool            `protobuf:"varint,15,opt,name=reversed,def=0" json:"reversed,omitempty"`
	Consistency                *Consistency     `protobuf:"varint,16,opt,name=consistency,enum=proto.Consistency,def=0" json:"consistency,omitempty"`
	Caching                    *uint32          `protobuf:"varint,17,opt,name=caching" json:"caching,omitempty"`
	XXX_unrecognized           []byte           `json:"-"`
}

* Instead of get from a table, you can scan it with optional filters. You can specify the row key range, time range, the columns/families to scan and so on.

This scan is used the first time in a scan request. The response of the initial scan will return a scanner id, which should be used to fetch result batches later on before it is closed.

func (*Scan) GetAttribute

func (m *Scan) GetAttribute() []*NameBytesPair

func (*Scan) GetBatchSize

func (m *Scan) GetBatchSize() uint32

func (*Scan) GetCacheBlocks

func (m *Scan) GetCacheBlocks() bool

func (*Scan) GetCaching

func (m *Scan) GetCaching() uint32

func (*Scan) GetColumn

func (m *Scan) GetColumn() []*Column

func (*Scan) GetConsistency

func (m *Scan) GetConsistency() Consistency

func (*Scan) GetFilter

func (m *Scan) GetFilter() *Filter

func (*Scan) GetLoadColumnFamiliesOnDemand

func (m *Scan) GetLoadColumnFamiliesOnDemand() bool

func (*Scan) GetMaxResultSize

func (m *Scan) GetMaxResultSize() uint64

func (*Scan) GetMaxVersions

func (m *Scan) GetMaxVersions() uint32

func (*Scan) GetReversed

func (m *Scan) GetReversed() bool

func (*Scan) GetSmall

func (m *Scan) GetSmall() bool

func (*Scan) GetStartRow

func (m *Scan) GetStartRow() []byte

func (*Scan) GetStopRow

func (m *Scan) GetStopRow() []byte

func (*Scan) GetStoreLimit

func (m *Scan) GetStoreLimit() uint32

func (*Scan) GetStoreOffset

func (m *Scan) GetStoreOffset() uint32

func (*Scan) GetTimeRange

func (m *Scan) GetTimeRange() *TimeRange

func (*Scan) ProtoMessage

func (*Scan) ProtoMessage()

func (*Scan) Reset

func (m *Scan) Reset()

func (*Scan) String

func (m *Scan) String() string

type ScanMetrics

type ScanMetrics struct {
	Metrics          []*NameInt64Pair `protobuf:"bytes,1,rep,name=metrics" json:"metrics,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*ScanMetrics) GetMetrics

func (m *ScanMetrics) GetMetrics() []*NameInt64Pair

func (*ScanMetrics) ProtoMessage

func (*ScanMetrics) ProtoMessage()

func (*ScanMetrics) Reset

func (m *ScanMetrics) Reset()

func (*ScanMetrics) String

func (m *ScanMetrics) String() string

type ScanRequest

type ScanRequest struct {
	Region           *RegionSpecifier `protobuf:"bytes,1,opt,name=region" json:"region,omitempty"`
	Scan             *Scan            `protobuf:"bytes,2,opt,name=scan" json:"scan,omitempty"`
	ScannerId        *uint64          `protobuf:"varint,3,opt,name=scanner_id" json:"scanner_id,omitempty"`
	NumberOfRows     *uint32          `protobuf:"varint,4,opt,name=number_of_rows" json:"number_of_rows,omitempty"`
	CloseScanner     *bool            `protobuf:"varint,5,opt,name=close_scanner" json:"close_scanner,omitempty"`
	NextCallSeq      *uint64          `protobuf:"varint,6,opt,name=next_call_seq" json:"next_call_seq,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

* A scan request. Initially, it should specify a scan. Later on, you can use the scanner id returned to fetch result batches with a different scan request.

The scanner will remain open if there are more results, and it's not asked to be closed explicitly.

You can fetch the results and ask the scanner to be closed to save a trip if you are not interested in remaining results.

func (*ScanRequest) GetCloseScanner

func (m *ScanRequest) GetCloseScanner() bool

func (*ScanRequest) GetNextCallSeq

func (m *ScanRequest) GetNextCallSeq() uint64

func (*ScanRequest) GetNumberOfRows

func (m *ScanRequest) GetNumberOfRows() uint32

func (*ScanRequest) GetRegion

func (m *ScanRequest) GetRegion() *RegionSpecifier

func (*ScanRequest) GetScan

func (m *ScanRequest) GetScan() *Scan

func (*ScanRequest) GetScannerId

func (m *ScanRequest) GetScannerId() uint64

func (*ScanRequest) ProtoMessage

func (*ScanRequest) ProtoMessage()

func (*ScanRequest) Reset

func (m *ScanRequest) Reset()

func (*ScanRequest) String

func (m *ScanRequest) String() string

type ScanResponse

type ScanResponse struct {
	// This field is filled in if we are doing cellblocks.  A cellblock is made up
	// of all Cells serialized out as one cellblock BUT responses from a server
	// have their Cells grouped by Result.  So we can reconstitute the
	// Results on the client-side, this field is a list of counts of Cells
	// in each Result that makes up the response.  For example, if this field
	// has 3, 3, 3 in it, then we know that on the client, we are to make
	// three Results each of three Cells each.
	CellsPerResult []uint32 `protobuf:"varint,1,rep,name=cells_per_result" json:"cells_per_result,omitempty"`
	ScannerId      *uint64  `protobuf:"varint,2,opt,name=scanner_id" json:"scanner_id,omitempty"`
	MoreResults    *bool    `protobuf:"varint,3,opt,name=more_results" json:"more_results,omitempty"`
	Ttl            *uint32  `protobuf:"varint,4,opt,name=ttl" json:"ttl,omitempty"`
	// If cells are not carried in an accompanying cellblock, then they are pb'd here.
	// This field is mutually exclusive with cells_per_result (since the Cells will
	// be inside the pb'd Result)
	Results          []*Result `protobuf:"bytes,5,rep,name=results" json:"results,omitempty"`
	Stale            *bool     `protobuf:"varint,6,opt,name=stale" json:"stale,omitempty"`
	XXX_unrecognized []byte    `json:"-"`
}

* The scan response. If there are no more results, more_results will be false. If it is not specified, it means there are more.

func (*ScanResponse) GetCellsPerResult

func (m *ScanResponse) GetCellsPerResult() []uint32

func (*ScanResponse) GetMoreResults

func (m *ScanResponse) GetMoreResults() bool

func (*ScanResponse) GetResults

func (m *ScanResponse) GetResults() []*Result

func (*ScanResponse) GetScannerId

func (m *ScanResponse) GetScannerId() uint64

func (*ScanResponse) GetStale

func (m *ScanResponse) GetStale() bool

func (*ScanResponse) GetTtl

func (m *ScanResponse) GetTtl() uint32

func (*ScanResponse) ProtoMessage

func (*ScanResponse) ProtoMessage()

func (*ScanResponse) Reset

func (m *ScanResponse) Reset()

func (*ScanResponse) String

func (m *ScanResponse) String() string

type ScopeType

type ScopeType int32
const (
	ScopeType_REPLICATION_SCOPE_LOCAL  ScopeType = 0
	ScopeType_REPLICATION_SCOPE_GLOBAL ScopeType = 1
)

func (ScopeType) Enum

func (x ScopeType) Enum() *ScopeType

func (ScopeType) String

func (x ScopeType) String() string

func (*ScopeType) UnmarshalJSON

func (x *ScopeType) UnmarshalJSON(data []byte) error

type SecureBulkLoadHFilesRequest

type SecureBulkLoadHFilesRequest struct {
	FamilyPath       []*BulkLoadHFileRequest_FamilyPath `protobuf:"bytes,1,rep,name=family_path" json:"family_path,omitempty"`
	AssignSeqNum     *bool                              `protobuf:"varint,2,opt,name=assign_seq_num" json:"assign_seq_num,omitempty"`
	FsToken          *DelegationToken                   `protobuf:"bytes,3,req,name=fs_token" json:"fs_token,omitempty"`
	BulkToken        *string                            `protobuf:"bytes,4,req,name=bulk_token" json:"bulk_token,omitempty"`
	XXX_unrecognized []byte                             `json:"-"`
}

func (*SecureBulkLoadHFilesRequest) GetAssignSeqNum

func (m *SecureBulkLoadHFilesRequest) GetAssignSeqNum() bool

func (*SecureBulkLoadHFilesRequest) GetBulkToken

func (m *SecureBulkLoadHFilesRequest) GetBulkToken() string

func (*SecureBulkLoadHFilesRequest) GetFamilyPath

func (*SecureBulkLoadHFilesRequest) GetFsToken

func (*SecureBulkLoadHFilesRequest) ProtoMessage

func (*SecureBulkLoadHFilesRequest) ProtoMessage()

func (*SecureBulkLoadHFilesRequest) Reset

func (m *SecureBulkLoadHFilesRequest) Reset()

func (*SecureBulkLoadHFilesRequest) String

func (m *SecureBulkLoadHFilesRequest) String() string

type SecureBulkLoadHFilesResponse

type SecureBulkLoadHFilesResponse struct {
	Loaded           *bool  `protobuf:"varint,1,req,name=loaded" json:"loaded,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*SecureBulkLoadHFilesResponse) GetLoaded

func (m *SecureBulkLoadHFilesResponse) GetLoaded() bool

func (*SecureBulkLoadHFilesResponse) ProtoMessage

func (*SecureBulkLoadHFilesResponse) ProtoMessage()

func (*SecureBulkLoadHFilesResponse) Reset

func (m *SecureBulkLoadHFilesResponse) Reset()

func (*SecureBulkLoadHFilesResponse) String

type ServerInfo

type ServerInfo struct {
	ServerName       *ServerName `protobuf:"bytes,1,req,name=server_name" json:"server_name,omitempty"`
	WebuiPort        *uint32     `protobuf:"varint,2,opt,name=webui_port" json:"webui_port,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*ServerInfo) GetServerName

func (m *ServerInfo) GetServerName() *ServerName

func (*ServerInfo) GetWebuiPort

func (m *ServerInfo) GetWebuiPort() uint32

func (*ServerInfo) ProtoMessage

func (*ServerInfo) ProtoMessage()

func (*ServerInfo) Reset

func (m *ServerInfo) Reset()

func (*ServerInfo) String

func (m *ServerInfo) String() string

type ServerLoad

type ServerLoad struct {
	// * Number of requests since last report.
	NumberOfRequests *uint32 `protobuf:"varint,1,opt,name=number_of_requests" json:"number_of_requests,omitempty"`
	// * Total Number of requests from the start of the region server.
	TotalNumberOfRequests *uint32 `protobuf:"varint,2,opt,name=total_number_of_requests" json:"total_number_of_requests,omitempty"`
	// * the amount of used heap, in MB.
	UsedHeap_MB *uint32 `protobuf:"varint,3,opt,name=used_heap_MB" json:"used_heap_MB,omitempty"`
	// * the maximum allowable size of the heap, in MB.
	MaxHeap_MB *uint32 `protobuf:"varint,4,opt,name=max_heap_MB" json:"max_heap_MB,omitempty"`
	// * Information on the load of individual regions.
	RegionLoads []*RegionLoad `protobuf:"bytes,5,rep,name=region_loads" json:"region_loads,omitempty"`
	// *
	// Regionserver-level coprocessors, e.g., WALObserver implementations.
	// Region-level coprocessors, on the other hand, are stored inside RegionLoad
	// objects.
	Coprocessors []*Coprocessor `protobuf:"bytes,6,rep,name=coprocessors" json:"coprocessors,omitempty"`
	// *
	// Time when incremental (non-total) counts began being calculated (e.g. number_of_requests)
	// time is measured as the difference, measured in milliseconds, between the current time
	// and midnight, January 1, 1970 UTC.
	ReportStartTime *uint64 `protobuf:"varint,7,opt,name=report_start_time" json:"report_start_time,omitempty"`
	// *
	// Time when report was generated.
	// time is measured as the difference, measured in milliseconds, between the current time
	// and midnight, January 1, 1970 UTC.
	ReportEndTime *uint64 `protobuf:"varint,8,opt,name=report_end_time" json:"report_end_time,omitempty"`
	// *
	// The port number that this region server is hosing an info server on.
	InfoServerPort *uint32 `protobuf:"varint,9,opt,name=info_server_port" json:"info_server_port,omitempty"`
	// *
	// The replicationLoadSource for the replication Source status of this region server.
	ReplLoadSource []*ReplicationLoadSource `protobuf:"bytes,10,rep,name=replLoadSource" json:"replLoadSource,omitempty"`
	// *
	// The replicationLoadSink for the replication Sink status of this region server.
	ReplLoadSink     *ReplicationLoadSink `protobuf:"bytes,11,opt,name=replLoadSink" json:"replLoadSink,omitempty"`
	XXX_unrecognized []byte               `json:"-"`
}

func (*ServerLoad) GetCoprocessors

func (m *ServerLoad) GetCoprocessors() []*Coprocessor

func (*ServerLoad) GetInfoServerPort

func (m *ServerLoad) GetInfoServerPort() uint32

func (*ServerLoad) GetMaxHeap_MB

func (m *ServerLoad) GetMaxHeap_MB() uint32

func (*ServerLoad) GetNumberOfRequests

func (m *ServerLoad) GetNumberOfRequests() uint32

func (*ServerLoad) GetRegionLoads

func (m *ServerLoad) GetRegionLoads() []*RegionLoad

func (*ServerLoad) GetReplLoadSink

func (m *ServerLoad) GetReplLoadSink() *ReplicationLoadSink

func (*ServerLoad) GetReplLoadSource

func (m *ServerLoad) GetReplLoadSource() []*ReplicationLoadSource

func (*ServerLoad) GetReportEndTime

func (m *ServerLoad) GetReportEndTime() uint64

func (*ServerLoad) GetReportStartTime

func (m *ServerLoad) GetReportStartTime() uint64

func (*ServerLoad) GetTotalNumberOfRequests

func (m *ServerLoad) GetTotalNumberOfRequests() uint32

func (*ServerLoad) GetUsedHeap_MB

func (m *ServerLoad) GetUsedHeap_MB() uint32

func (*ServerLoad) ProtoMessage

func (*ServerLoad) ProtoMessage()

func (*ServerLoad) Reset

func (m *ServerLoad) Reset()

func (*ServerLoad) String

func (m *ServerLoad) String() string

type ServerName

type ServerName struct {
	HostName         *string `protobuf:"bytes,1,req,name=host_name" json:"host_name,omitempty"`
	Port             *uint32 `protobuf:"varint,2,opt,name=port" json:"port,omitempty"`
	StartCode        *uint64 `protobuf:"varint,3,opt,name=start_code" json:"start_code,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Protocol buffer version of ServerName

func (*ServerName) GetHostName

func (m *ServerName) GetHostName() string

func (*ServerName) GetPort

func (m *ServerName) GetPort() uint32

func (*ServerName) GetStartCode

func (m *ServerName) GetStartCode() uint64

func (*ServerName) ProtoMessage

func (*ServerName) ProtoMessage()

func (*ServerName) Reset

func (m *ServerName) Reset()

func (*ServerName) String

func (m *ServerName) String() string

type SetAuthsRequest

type SetAuthsRequest struct {
	User             []byte   `protobuf:"bytes,1,req,name=user" json:"user,omitempty"`
	Auth             [][]byte `protobuf:"bytes,2,rep,name=auth" json:"auth,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*SetAuthsRequest) GetAuth

func (m *SetAuthsRequest) GetAuth() [][]byte

func (*SetAuthsRequest) GetUser

func (m *SetAuthsRequest) GetUser() []byte

func (*SetAuthsRequest) ProtoMessage

func (*SetAuthsRequest) ProtoMessage()

func (*SetAuthsRequest) Reset

func (m *SetAuthsRequest) Reset()

func (*SetAuthsRequest) String

func (m *SetAuthsRequest) String() string

type SetBalancerRunningRequest

type SetBalancerRunningRequest struct {
	On               *bool  `protobuf:"varint,1,req,name=on" json:"on,omitempty"`
	Synchronous      *bool  `protobuf:"varint,2,opt,name=synchronous" json:"synchronous,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*SetBalancerRunningRequest) GetOn

func (m *SetBalancerRunningRequest) GetOn() bool

func (*SetBalancerRunningRequest) GetSynchronous

func (m *SetBalancerRunningRequest) GetSynchronous() bool

func (*SetBalancerRunningRequest) ProtoMessage

func (*SetBalancerRunningRequest) ProtoMessage()

func (*SetBalancerRunningRequest) Reset

func (m *SetBalancerRunningRequest) Reset()

func (*SetBalancerRunningRequest) String

func (m *SetBalancerRunningRequest) String() string

type SetBalancerRunningResponse

type SetBalancerRunningResponse struct {
	PrevBalanceValue *bool  `protobuf:"varint,1,opt,name=prev_balance_value" json:"prev_balance_value,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*SetBalancerRunningResponse) GetPrevBalanceValue

func (m *SetBalancerRunningResponse) GetPrevBalanceValue() bool

func (*SetBalancerRunningResponse) ProtoMessage

func (*SetBalancerRunningResponse) ProtoMessage()

func (*SetBalancerRunningResponse) Reset

func (m *SetBalancerRunningResponse) Reset()

func (*SetBalancerRunningResponse) String

func (m *SetBalancerRunningResponse) String() string

type SetQuotaRequest

type SetQuotaRequest struct {
	UserName         *string          `protobuf:"bytes,1,opt,name=user_name" json:"user_name,omitempty"`
	UserGroup        *string          `protobuf:"bytes,2,opt,name=user_group" json:"user_group,omitempty"`
	Namespace        *string          `protobuf:"bytes,3,opt,name=namespace" json:"namespace,omitempty"`
	TableName        *TableName       `protobuf:"bytes,4,opt,name=table_name" json:"table_name,omitempty"`
	RemoveAll        *bool            `protobuf:"varint,5,opt,name=remove_all" json:"remove_all,omitempty"`
	BypassGlobals    *bool            `protobuf:"varint,6,opt,name=bypass_globals" json:"bypass_globals,omitempty"`
	Throttle         *ThrottleRequest `protobuf:"bytes,7,opt,name=throttle" json:"throttle,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*SetQuotaRequest) GetBypassGlobals

func (m *SetQuotaRequest) GetBypassGlobals() bool

func (*SetQuotaRequest) GetNamespace

func (m *SetQuotaRequest) GetNamespace() string

func (*SetQuotaRequest) GetRemoveAll

func (m *SetQuotaRequest) GetRemoveAll() bool

func (*SetQuotaRequest) GetTableName

func (m *SetQuotaRequest) GetTableName() *TableName

func (*SetQuotaRequest) GetThrottle

func (m *SetQuotaRequest) GetThrottle() *ThrottleRequest

func (*SetQuotaRequest) GetUserGroup

func (m *SetQuotaRequest) GetUserGroup() string

func (*SetQuotaRequest) GetUserName

func (m *SetQuotaRequest) GetUserName() string

func (*SetQuotaRequest) ProtoMessage

func (*SetQuotaRequest) ProtoMessage()

func (*SetQuotaRequest) Reset

func (m *SetQuotaRequest) Reset()

func (*SetQuotaRequest) String

func (m *SetQuotaRequest) String() string

type SetQuotaResponse

type SetQuotaResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*SetQuotaResponse) ProtoMessage

func (*SetQuotaResponse) ProtoMessage()

func (*SetQuotaResponse) Reset

func (m *SetQuotaResponse) Reset()

func (*SetQuotaResponse) String

func (m *SetQuotaResponse) String() string

type ShutdownRequest

type ShutdownRequest struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*ShutdownRequest) ProtoMessage

func (*ShutdownRequest) ProtoMessage()

func (*ShutdownRequest) Reset

func (m *ShutdownRequest) Reset()

func (*ShutdownRequest) String

func (m *ShutdownRequest) String() string

type ShutdownResponse

type ShutdownResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*ShutdownResponse) ProtoMessage

func (*ShutdownResponse) ProtoMessage()

func (*ShutdownResponse) Reset

func (m *ShutdownResponse) Reset()

func (*ShutdownResponse) String

func (m *ShutdownResponse) String() string

type SingleColumnValueExcludeFilter

type SingleColumnValueExcludeFilter struct {
	SingleColumnValueFilter *SingleColumnValueFilter `protobuf:"bytes,1,req,name=single_column_value_filter" json:"single_column_value_filter,omitempty"`
	XXX_unrecognized        []byte                   `json:"-"`
}

func (*SingleColumnValueExcludeFilter) GetSingleColumnValueFilter

func (m *SingleColumnValueExcludeFilter) GetSingleColumnValueFilter() *SingleColumnValueFilter

func (*SingleColumnValueExcludeFilter) ProtoMessage

func (*SingleColumnValueExcludeFilter) ProtoMessage()

func (*SingleColumnValueExcludeFilter) Reset

func (m *SingleColumnValueExcludeFilter) Reset()

func (*SingleColumnValueExcludeFilter) String

type SingleColumnValueFilter

type SingleColumnValueFilter struct {
	ColumnFamily      []byte       `protobuf:"bytes,1,opt,name=column_family" json:"column_family,omitempty"`
	ColumnQualifier   []byte       `protobuf:"bytes,2,opt,name=column_qualifier" json:"column_qualifier,omitempty"`
	CompareOp         *CompareType `protobuf:"varint,3,req,name=compare_op,enum=proto.CompareType" json:"compare_op,omitempty"`
	Comparator        *Comparator  `protobuf:"bytes,4,req,name=comparator" json:"comparator,omitempty"`
	FilterIfMissing   *bool        `protobuf:"varint,5,opt,name=filter_if_missing" json:"filter_if_missing,omitempty"`
	LatestVersionOnly *bool        `protobuf:"varint,6,opt,name=latest_version_only" json:"latest_version_only,omitempty"`
	XXX_unrecognized  []byte       `json:"-"`
}

func (*SingleColumnValueFilter) GetColumnFamily

func (m *SingleColumnValueFilter) GetColumnFamily() []byte

func (*SingleColumnValueFilter) GetColumnQualifier

func (m *SingleColumnValueFilter) GetColumnQualifier() []byte

func (*SingleColumnValueFilter) GetComparator

func (m *SingleColumnValueFilter) GetComparator() *Comparator

func (*SingleColumnValueFilter) GetCompareOp

func (m *SingleColumnValueFilter) GetCompareOp() CompareType

func (*SingleColumnValueFilter) GetFilterIfMissing

func (m *SingleColumnValueFilter) GetFilterIfMissing() bool

func (*SingleColumnValueFilter) GetLatestVersionOnly

func (m *SingleColumnValueFilter) GetLatestVersionOnly() bool

func (*SingleColumnValueFilter) ProtoMessage

func (*SingleColumnValueFilter) ProtoMessage()

func (*SingleColumnValueFilter) Reset

func (m *SingleColumnValueFilter) Reset()

func (*SingleColumnValueFilter) String

func (m *SingleColumnValueFilter) String() string

type SkipFilter

type SkipFilter struct {
	Filter           *Filter `protobuf:"bytes,1,req,name=filter" json:"filter,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*SkipFilter) GetFilter

func (m *SkipFilter) GetFilter() *Filter

func (*SkipFilter) ProtoMessage

func (*SkipFilter) ProtoMessage()

func (*SkipFilter) Reset

func (m *SkipFilter) Reset()

func (*SkipFilter) String

func (m *SkipFilter) String() string

type SnapshotDataManifest

type SnapshotDataManifest struct {
	TableSchema      *TableSchema              `protobuf:"bytes,1,req,name=table_schema" json:"table_schema,omitempty"`
	RegionManifests  []*SnapshotRegionManifest `protobuf:"bytes,2,rep,name=region_manifests" json:"region_manifests,omitempty"`
	XXX_unrecognized []byte                    `json:"-"`
}

func (*SnapshotDataManifest) GetRegionManifests

func (m *SnapshotDataManifest) GetRegionManifests() []*SnapshotRegionManifest

func (*SnapshotDataManifest) GetTableSchema

func (m *SnapshotDataManifest) GetTableSchema() *TableSchema

func (*SnapshotDataManifest) ProtoMessage

func (*SnapshotDataManifest) ProtoMessage()

func (*SnapshotDataManifest) Reset

func (m *SnapshotDataManifest) Reset()

func (*SnapshotDataManifest) String

func (m *SnapshotDataManifest) String() string

type SnapshotDescription

type SnapshotDescription struct {
	Name             *string                   `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	Table            *string                   `protobuf:"bytes,2,opt,name=table" json:"table,omitempty"`
	CreationTime     *int64                    `protobuf:"varint,3,opt,name=creation_time,def=0" json:"creation_time,omitempty"`
	Type             *SnapshotDescription_Type `protobuf:"varint,4,opt,name=type,enum=proto.SnapshotDescription_Type,def=1" json:"type,omitempty"`
	Version          *int32                    `protobuf:"varint,5,opt,name=version" json:"version,omitempty"`
	XXX_unrecognized []byte                    `json:"-"`
}

* Description of the snapshot to take

func (*SnapshotDescription) GetCreationTime

func (m *SnapshotDescription) GetCreationTime() int64

func (*SnapshotDescription) GetName

func (m *SnapshotDescription) GetName() string

func (*SnapshotDescription) GetTable

func (m *SnapshotDescription) GetTable() string

func (*SnapshotDescription) GetType

func (*SnapshotDescription) GetVersion

func (m *SnapshotDescription) GetVersion() int32

func (*SnapshotDescription) ProtoMessage

func (*SnapshotDescription) ProtoMessage()

func (*SnapshotDescription) Reset

func (m *SnapshotDescription) Reset()

func (*SnapshotDescription) String

func (m *SnapshotDescription) String() string

type SnapshotDescription_Type

type SnapshotDescription_Type int32
const (
	SnapshotDescription_DISABLED  SnapshotDescription_Type = 0
	SnapshotDescription_FLUSH     SnapshotDescription_Type = 1
	SnapshotDescription_SKIPFLUSH SnapshotDescription_Type = 2
)
const Default_SnapshotDescription_Type SnapshotDescription_Type = SnapshotDescription_FLUSH

func (SnapshotDescription_Type) Enum

func (SnapshotDescription_Type) String

func (x SnapshotDescription_Type) String() string

func (*SnapshotDescription_Type) UnmarshalJSON

func (x *SnapshotDescription_Type) UnmarshalJSON(data []byte) error

type SnapshotFileInfo

type SnapshotFileInfo struct {
	Type             *SnapshotFileInfo_Type `protobuf:"varint,1,req,name=type,enum=proto.SnapshotFileInfo_Type" json:"type,omitempty"`
	Hfile            *string                `protobuf:"bytes,3,opt,name=hfile" json:"hfile,omitempty"`
	WalServer        *string                `protobuf:"bytes,4,opt,name=wal_server" json:"wal_server,omitempty"`
	WalName          *string                `protobuf:"bytes,5,opt,name=wal_name" json:"wal_name,omitempty"`
	XXX_unrecognized []byte                 `json:"-"`
}

func (*SnapshotFileInfo) GetHfile

func (m *SnapshotFileInfo) GetHfile() string

func (*SnapshotFileInfo) GetType

func (*SnapshotFileInfo) GetWalName

func (m *SnapshotFileInfo) GetWalName() string

func (*SnapshotFileInfo) GetWalServer

func (m *SnapshotFileInfo) GetWalServer() string

func (*SnapshotFileInfo) ProtoMessage

func (*SnapshotFileInfo) ProtoMessage()

func (*SnapshotFileInfo) Reset

func (m *SnapshotFileInfo) Reset()

func (*SnapshotFileInfo) String

func (m *SnapshotFileInfo) String() string

type SnapshotFileInfo_Type

type SnapshotFileInfo_Type int32
const (
	SnapshotFileInfo_HFILE SnapshotFileInfo_Type = 1
	SnapshotFileInfo_WAL   SnapshotFileInfo_Type = 2
)

func (SnapshotFileInfo_Type) Enum

func (SnapshotFileInfo_Type) String

func (x SnapshotFileInfo_Type) String() string

func (*SnapshotFileInfo_Type) UnmarshalJSON

func (x *SnapshotFileInfo_Type) UnmarshalJSON(data []byte) error

type SnapshotRegionManifest

type SnapshotRegionManifest struct {
	Version          *int32                                `protobuf:"varint,1,opt,name=version" json:"version,omitempty"`
	RegionInfo       *RegionInfo                           `protobuf:"bytes,2,req,name=region_info" json:"region_info,omitempty"`
	FamilyFiles      []*SnapshotRegionManifest_FamilyFiles `protobuf:"bytes,3,rep,name=family_files" json:"family_files,omitempty"`
	XXX_unrecognized []byte                                `json:"-"`
}

func (*SnapshotRegionManifest) GetFamilyFiles

func (*SnapshotRegionManifest) GetRegionInfo

func (m *SnapshotRegionManifest) GetRegionInfo() *RegionInfo

func (*SnapshotRegionManifest) GetVersion

func (m *SnapshotRegionManifest) GetVersion() int32

func (*SnapshotRegionManifest) ProtoMessage

func (*SnapshotRegionManifest) ProtoMessage()

func (*SnapshotRegionManifest) Reset

func (m *SnapshotRegionManifest) Reset()

func (*SnapshotRegionManifest) String

func (m *SnapshotRegionManifest) String() string

type SnapshotRegionManifest_FamilyFiles

type SnapshotRegionManifest_FamilyFiles struct {
	FamilyName       []byte                              `protobuf:"bytes,1,req,name=family_name" json:"family_name,omitempty"`
	StoreFiles       []*SnapshotRegionManifest_StoreFile `protobuf:"bytes,2,rep,name=store_files" json:"store_files,omitempty"`
	XXX_unrecognized []byte                              `json:"-"`
}

func (*SnapshotRegionManifest_FamilyFiles) GetFamilyName

func (m *SnapshotRegionManifest_FamilyFiles) GetFamilyName() []byte

func (*SnapshotRegionManifest_FamilyFiles) GetStoreFiles

func (*SnapshotRegionManifest_FamilyFiles) ProtoMessage

func (*SnapshotRegionManifest_FamilyFiles) ProtoMessage()

func (*SnapshotRegionManifest_FamilyFiles) Reset

func (*SnapshotRegionManifest_FamilyFiles) String

type SnapshotRegionManifest_StoreFile

type SnapshotRegionManifest_StoreFile struct {
	Name      *string    `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	Reference *Reference `protobuf:"bytes,2,opt,name=reference" json:"reference,omitempty"`
	// TODO: Add checksums or other fields to verify the file
	FileSize         *uint64 `protobuf:"varint,3,opt,name=file_size" json:"file_size,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*SnapshotRegionManifest_StoreFile) GetFileSize

func (m *SnapshotRegionManifest_StoreFile) GetFileSize() uint64

func (*SnapshotRegionManifest_StoreFile) GetName

func (*SnapshotRegionManifest_StoreFile) GetReference

func (m *SnapshotRegionManifest_StoreFile) GetReference() *Reference

func (*SnapshotRegionManifest_StoreFile) ProtoMessage

func (*SnapshotRegionManifest_StoreFile) ProtoMessage()

func (*SnapshotRegionManifest_StoreFile) Reset

func (*SnapshotRegionManifest_StoreFile) String

type SnapshotRequest

type SnapshotRequest struct {
	Snapshot         *SnapshotDescription `protobuf:"bytes,1,req,name=snapshot" json:"snapshot,omitempty"`
	XXX_unrecognized []byte               `json:"-"`
}

func (*SnapshotRequest) GetSnapshot

func (m *SnapshotRequest) GetSnapshot() *SnapshotDescription

func (*SnapshotRequest) ProtoMessage

func (*SnapshotRequest) ProtoMessage()

func (*SnapshotRequest) Reset

func (m *SnapshotRequest) Reset()

func (*SnapshotRequest) String

func (m *SnapshotRequest) String() string

type SnapshotResponse

type SnapshotResponse struct {
	ExpectedTimeout  *int64 `protobuf:"varint,1,req,name=expected_timeout" json:"expected_timeout,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*SnapshotResponse) GetExpectedTimeout

func (m *SnapshotResponse) GetExpectedTimeout() int64

func (*SnapshotResponse) ProtoMessage

func (*SnapshotResponse) ProtoMessage()

func (*SnapshotResponse) Reset

func (m *SnapshotResponse) Reset()

func (*SnapshotResponse) String

func (m *SnapshotResponse) String() string

type SplitLogTask

type SplitLogTask struct {
	State            *SplitLogTask_State        `protobuf:"varint,1,req,name=state,enum=proto.SplitLogTask_State" json:"state,omitempty"`
	ServerName       *ServerName                `protobuf:"bytes,2,req,name=server_name" json:"server_name,omitempty"`
	Mode             *SplitLogTask_RecoveryMode `protobuf:"varint,3,opt,name=mode,enum=proto.SplitLogTask_RecoveryMode,def=0" json:"mode,omitempty"`
	XXX_unrecognized []byte                     `json:"-"`
}

* WAL SplitLog directory znodes have this for content. Used doing distributed WAL splitting. Holds current state and name of server that originated split.

func (*SplitLogTask) GetMode

func (*SplitLogTask) GetServerName

func (m *SplitLogTask) GetServerName() *ServerName

func (*SplitLogTask) GetState

func (m *SplitLogTask) GetState() SplitLogTask_State

func (*SplitLogTask) ProtoMessage

func (*SplitLogTask) ProtoMessage()

func (*SplitLogTask) Reset

func (m *SplitLogTask) Reset()

func (*SplitLogTask) String

func (m *SplitLogTask) String() string

type SplitLogTask_RecoveryMode

type SplitLogTask_RecoveryMode int32
const (
	SplitLogTask_UNKNOWN       SplitLogTask_RecoveryMode = 0
	SplitLogTask_LOG_SPLITTING SplitLogTask_RecoveryMode = 1
	SplitLogTask_LOG_REPLAY    SplitLogTask_RecoveryMode = 2
)
const Default_SplitLogTask_Mode SplitLogTask_RecoveryMode = SplitLogTask_UNKNOWN

func (SplitLogTask_RecoveryMode) Enum

func (SplitLogTask_RecoveryMode) String

func (x SplitLogTask_RecoveryMode) String() string

func (*SplitLogTask_RecoveryMode) UnmarshalJSON

func (x *SplitLogTask_RecoveryMode) UnmarshalJSON(data []byte) error

type SplitLogTask_State

type SplitLogTask_State int32
const (
	SplitLogTask_UNASSIGNED SplitLogTask_State = 0
	SplitLogTask_OWNED      SplitLogTask_State = 1
	SplitLogTask_RESIGNED   SplitLogTask_State = 2
	SplitLogTask_DONE       SplitLogTask_State = 3
	SplitLogTask_ERR        SplitLogTask_State = 4
)

func (SplitLogTask_State) Enum

func (SplitLogTask_State) String

func (x SplitLogTask_State) String() string

func (*SplitLogTask_State) UnmarshalJSON

func (x *SplitLogTask_State) UnmarshalJSON(data []byte) error

type SplitRegionRequest

type SplitRegionRequest struct {
	Region           *RegionSpecifier `protobuf:"bytes,1,req,name=region" json:"region,omitempty"`
	SplitPoint       []byte           `protobuf:"bytes,2,opt,name=split_point" json:"split_point,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

* Splits the specified region. <p> This method currently flushes the region and then forces a compaction which will then trigger a split. The flush is done synchronously but the compaction is asynchronous.

func (*SplitRegionRequest) GetRegion

func (m *SplitRegionRequest) GetRegion() *RegionSpecifier

func (*SplitRegionRequest) GetSplitPoint

func (m *SplitRegionRequest) GetSplitPoint() []byte

func (*SplitRegionRequest) ProtoMessage

func (*SplitRegionRequest) ProtoMessage()

func (*SplitRegionRequest) Reset

func (m *SplitRegionRequest) Reset()

func (*SplitRegionRequest) String

func (m *SplitRegionRequest) String() string

type SplitRegionResponse

type SplitRegionResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*SplitRegionResponse) ProtoMessage

func (*SplitRegionResponse) ProtoMessage()

func (*SplitRegionResponse) Reset

func (m *SplitRegionResponse) Reset()

func (*SplitRegionResponse) String

func (m *SplitRegionResponse) String() string

type StackTraceElementMessage

type StackTraceElementMessage struct {
	DeclaringClass   *string `protobuf:"bytes,1,opt,name=declaring_class" json:"declaring_class,omitempty"`
	MethodName       *string `protobuf:"bytes,2,opt,name=method_name" json:"method_name,omitempty"`
	FileName         *string `protobuf:"bytes,3,opt,name=file_name" json:"file_name,omitempty"`
	LineNumber       *int32  `protobuf:"varint,4,opt,name=line_number" json:"line_number,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Protobuf version of a java.lang.StackTraceElement so we can serialize exceptions.

func (*StackTraceElementMessage) GetDeclaringClass

func (m *StackTraceElementMessage) GetDeclaringClass() string

func (*StackTraceElementMessage) GetFileName

func (m *StackTraceElementMessage) GetFileName() string

func (*StackTraceElementMessage) GetLineNumber

func (m *StackTraceElementMessage) GetLineNumber() int32

func (*StackTraceElementMessage) GetMethodName

func (m *StackTraceElementMessage) GetMethodName() string

func (*StackTraceElementMessage) ProtoMessage

func (*StackTraceElementMessage) ProtoMessage()

func (*StackTraceElementMessage) Reset

func (m *StackTraceElementMessage) Reset()

func (*StackTraceElementMessage) String

func (m *StackTraceElementMessage) String() string

type StopMasterRequest

type StopMasterRequest struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*StopMasterRequest) ProtoMessage

func (*StopMasterRequest) ProtoMessage()

func (*StopMasterRequest) Reset

func (m *StopMasterRequest) Reset()

func (*StopMasterRequest) String

func (m *StopMasterRequest) String() string

type StopMasterResponse

type StopMasterResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*StopMasterResponse) ProtoMessage

func (*StopMasterResponse) ProtoMessage()

func (*StopMasterResponse) Reset

func (m *StopMasterResponse) Reset()

func (*StopMasterResponse) String

func (m *StopMasterResponse) String() string

type StopServerRequest

type StopServerRequest struct {
	Reason           *string `protobuf:"bytes,1,req,name=reason" json:"reason,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*StopServerRequest) GetReason

func (m *StopServerRequest) GetReason() string

func (*StopServerRequest) ProtoMessage

func (*StopServerRequest) ProtoMessage()

func (*StopServerRequest) Reset

func (m *StopServerRequest) Reset()

func (*StopServerRequest) String

func (m *StopServerRequest) String() string

type StopServerResponse

type StopServerResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*StopServerResponse) ProtoMessage

func (*StopServerResponse) ProtoMessage()

func (*StopServerResponse) Reset

func (m *StopServerResponse) Reset()

func (*StopServerResponse) String

func (m *StopServerResponse) String() string

type StoreDescriptor

type StoreDescriptor struct {
	FamilyName       []byte   `protobuf:"bytes,1,req,name=family_name" json:"family_name,omitempty"`
	StoreHomeDir     *string  `protobuf:"bytes,2,req,name=store_home_dir" json:"store_home_dir,omitempty"`
	StoreFile        []string `protobuf:"bytes,3,rep,name=store_file" json:"store_file,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*StoreDescriptor) GetFamilyName

func (m *StoreDescriptor) GetFamilyName() []byte

func (*StoreDescriptor) GetStoreFile

func (m *StoreDescriptor) GetStoreFile() []string

func (*StoreDescriptor) GetStoreHomeDir

func (m *StoreDescriptor) GetStoreHomeDir() string

func (*StoreDescriptor) ProtoMessage

func (*StoreDescriptor) ProtoMessage()

func (*StoreDescriptor) Reset

func (m *StoreDescriptor) Reset()

func (*StoreDescriptor) String

func (m *StoreDescriptor) String() string

type StoreSequenceId

type StoreSequenceId struct {
	FamilyName       []byte  `protobuf:"bytes,1,req,name=family_name" json:"family_name,omitempty"`
	SequenceId       *uint64 `protobuf:"varint,2,req,name=sequence_id" json:"sequence_id,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* sequence Id of a store

func (*StoreSequenceId) GetFamilyName

func (m *StoreSequenceId) GetFamilyName() []byte

func (*StoreSequenceId) GetSequenceId

func (m *StoreSequenceId) GetSequenceId() uint64

func (*StoreSequenceId) ProtoMessage

func (*StoreSequenceId) ProtoMessage()

func (*StoreSequenceId) Reset

func (m *StoreSequenceId) Reset()

func (*StoreSequenceId) String

func (m *StoreSequenceId) String() string

type SubstringComparator

type SubstringComparator struct {
	Substr           *string `protobuf:"bytes,1,req,name=substr" json:"substr,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*SubstringComparator) GetSubstr

func (m *SubstringComparator) GetSubstr() string

func (*SubstringComparator) ProtoMessage

func (*SubstringComparator) ProtoMessage()

func (*SubstringComparator) Reset

func (m *SubstringComparator) Reset()

func (*SubstringComparator) String

func (m *SubstringComparator) String() string

type Table

type Table struct {
	// This is the table's state.  If no znode for a table,
	// its state is presumed enabled.  See o.a.h.h.zookeeper.ZKTable class
	// for more.
	State            *Table_State `protobuf:"varint,1,req,name=state,enum=proto.Table_State,def=0" json:"state,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

* The znode that holds state of table.

func (*Table) GetState

func (m *Table) GetState() Table_State

func (*Table) ProtoMessage

func (*Table) ProtoMessage()

func (*Table) Reset

func (m *Table) Reset()

func (*Table) String

func (m *Table) String() string

type TableLock

type TableLock struct {
	TableName        *TableName  `protobuf:"bytes,1,opt,name=table_name" json:"table_name,omitempty"`
	LockOwner        *ServerName `protobuf:"bytes,2,opt,name=lock_owner" json:"lock_owner,omitempty"`
	ThreadId         *int64      `protobuf:"varint,3,opt,name=thread_id" json:"thread_id,omitempty"`
	IsShared         *bool       `protobuf:"varint,4,opt,name=is_shared" json:"is_shared,omitempty"`
	Purpose          *string     `protobuf:"bytes,5,opt,name=purpose" json:"purpose,omitempty"`
	CreateTime       *int64      `protobuf:"varint,6,opt,name=create_time" json:"create_time,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

* Metadata associated with a table lock in zookeeper

func (*TableLock) GetCreateTime

func (m *TableLock) GetCreateTime() int64

func (*TableLock) GetIsShared

func (m *TableLock) GetIsShared() bool

func (*TableLock) GetLockOwner

func (m *TableLock) GetLockOwner() *ServerName

func (*TableLock) GetPurpose

func (m *TableLock) GetPurpose() string

func (*TableLock) GetTableName

func (m *TableLock) GetTableName() *TableName

func (*TableLock) GetThreadId

func (m *TableLock) GetThreadId() int64

func (*TableLock) ProtoMessage

func (*TableLock) ProtoMessage()

func (*TableLock) Reset

func (m *TableLock) Reset()

func (*TableLock) String

func (m *TableLock) String() string

type TableName

type TableName struct {
	Namespace        []byte `protobuf:"bytes,1,req,name=namespace" json:"namespace,omitempty"`
	Qualifier        []byte `protobuf:"bytes,2,req,name=qualifier" json:"qualifier,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

* Table Name

func (*TableName) GetNamespace

func (m *TableName) GetNamespace() []byte

func (*TableName) GetQualifier

func (m *TableName) GetQualifier() []byte

func (*TableName) ProtoMessage

func (*TableName) ProtoMessage()

func (*TableName) Reset

func (m *TableName) Reset()

func (*TableName) String

func (m *TableName) String() string

type TablePermission

type TablePermission struct {
	TableName        *TableName          `protobuf:"bytes,1,opt,name=table_name" json:"table_name,omitempty"`
	Family           []byte              `protobuf:"bytes,2,opt,name=family" json:"family,omitempty"`
	Qualifier        []byte              `protobuf:"bytes,3,opt,name=qualifier" json:"qualifier,omitempty"`
	Action           []Permission_Action `protobuf:"varint,4,rep,name=action,enum=proto.Permission_Action" json:"action,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

func (*TablePermission) GetAction

func (m *TablePermission) GetAction() []Permission_Action

func (*TablePermission) GetFamily

func (m *TablePermission) GetFamily() []byte

func (*TablePermission) GetQualifier

func (m *TablePermission) GetQualifier() []byte

func (*TablePermission) GetTableName

func (m *TablePermission) GetTableName() *TableName

func (*TablePermission) ProtoMessage

func (*TablePermission) ProtoMessage()

func (*TablePermission) Reset

func (m *TablePermission) Reset()

func (*TablePermission) String

func (m *TablePermission) String() string

type TableSchema

type TableSchema struct {
	TableName        *TableName            `protobuf:"bytes,1,opt,name=table_name" json:"table_name,omitempty"`
	Attributes       []*BytesBytesPair     `protobuf:"bytes,2,rep,name=attributes" json:"attributes,omitempty"`
	ColumnFamilies   []*ColumnFamilySchema `protobuf:"bytes,3,rep,name=column_families" json:"column_families,omitempty"`
	Configuration    []*NameStringPair     `protobuf:"bytes,4,rep,name=configuration" json:"configuration,omitempty"`
	XXX_unrecognized []byte                `json:"-"`
}

* Table Schema Inspired by the rest TableSchema

func (*TableSchema) GetAttributes

func (m *TableSchema) GetAttributes() []*BytesBytesPair

func (*TableSchema) GetColumnFamilies

func (m *TableSchema) GetColumnFamilies() []*ColumnFamilySchema

func (*TableSchema) GetConfiguration

func (m *TableSchema) GetConfiguration() []*NameStringPair

func (*TableSchema) GetTableName

func (m *TableSchema) GetTableName() *TableName

func (*TableSchema) ProtoMessage

func (*TableSchema) ProtoMessage()

func (*TableSchema) Reset

func (m *TableSchema) Reset()

func (*TableSchema) String

func (m *TableSchema) String() string

type TableSnapshotRegionSplit

type TableSnapshotRegionSplit struct {
	Locations        []string     `protobuf:"bytes,2,rep,name=locations" json:"locations,omitempty"`
	Table            *TableSchema `protobuf:"bytes,3,opt,name=table" json:"table,omitempty"`
	Region           *RegionInfo  `protobuf:"bytes,4,opt,name=region" json:"region,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*TableSnapshotRegionSplit) GetLocations

func (m *TableSnapshotRegionSplit) GetLocations() []string

func (*TableSnapshotRegionSplit) GetRegion

func (m *TableSnapshotRegionSplit) GetRegion() *RegionInfo

func (*TableSnapshotRegionSplit) GetTable

func (m *TableSnapshotRegionSplit) GetTable() *TableSchema

func (*TableSnapshotRegionSplit) ProtoMessage

func (*TableSnapshotRegionSplit) ProtoMessage()

func (*TableSnapshotRegionSplit) Reset

func (m *TableSnapshotRegionSplit) Reset()

func (*TableSnapshotRegionSplit) String

func (m *TableSnapshotRegionSplit) String() string

type Table_State

type Table_State int32

Table's current state

const (
	Table_ENABLED   Table_State = 0
	Table_DISABLED  Table_State = 1
	Table_DISABLING Table_State = 2
	Table_ENABLING  Table_State = 3
)
const Default_Table_State Table_State = Table_ENABLED

func (Table_State) Enum

func (x Table_State) Enum() *Table_State

func (Table_State) String

func (x Table_State) String() string

func (*Table_State) UnmarshalJSON

func (x *Table_State) UnmarshalJSON(data []byte) error

type Throttle

type Throttle struct {
	ReqNum           *TimedQuota `protobuf:"bytes,1,opt,name=req_num" json:"req_num,omitempty"`
	ReqSize          *TimedQuota `protobuf:"bytes,2,opt,name=req_size" json:"req_size,omitempty"`
	WriteNum         *TimedQuota `protobuf:"bytes,3,opt,name=write_num" json:"write_num,omitempty"`
	WriteSize        *TimedQuota `protobuf:"bytes,4,opt,name=write_size" json:"write_size,omitempty"`
	ReadNum          *TimedQuota `protobuf:"bytes,5,opt,name=read_num" json:"read_num,omitempty"`
	ReadSize         *TimedQuota `protobuf:"bytes,6,opt,name=read_size" json:"read_size,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*Throttle) GetReadNum

func (m *Throttle) GetReadNum() *TimedQuota

func (*Throttle) GetReadSize

func (m *Throttle) GetReadSize() *TimedQuota

func (*Throttle) GetReqNum

func (m *Throttle) GetReqNum() *TimedQuota

func (*Throttle) GetReqSize

func (m *Throttle) GetReqSize() *TimedQuota

func (*Throttle) GetWriteNum

func (m *Throttle) GetWriteNum() *TimedQuota

func (*Throttle) GetWriteSize

func (m *Throttle) GetWriteSize() *TimedQuota

func (*Throttle) ProtoMessage

func (*Throttle) ProtoMessage()

func (*Throttle) Reset

func (m *Throttle) Reset()

func (*Throttle) String

func (m *Throttle) String() string

type ThrottleRequest

type ThrottleRequest struct {
	Type             *ThrottleType `protobuf:"varint,1,opt,name=type,enum=proto.ThrottleType" json:"type,omitempty"`
	TimedQuota       *TimedQuota   `protobuf:"bytes,2,opt,name=timed_quota" json:"timed_quota,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*ThrottleRequest) GetTimedQuota

func (m *ThrottleRequest) GetTimedQuota() *TimedQuota

func (*ThrottleRequest) GetType

func (m *ThrottleRequest) GetType() ThrottleType

func (*ThrottleRequest) ProtoMessage

func (*ThrottleRequest) ProtoMessage()

func (*ThrottleRequest) Reset

func (m *ThrottleRequest) Reset()

func (*ThrottleRequest) String

func (m *ThrottleRequest) String() string

type ThrottleType

type ThrottleType int32
const (
	ThrottleType_REQUEST_NUMBER ThrottleType = 1
	ThrottleType_REQUEST_SIZE   ThrottleType = 2
	ThrottleType_WRITE_NUMBER   ThrottleType = 3
	ThrottleType_WRITE_SIZE     ThrottleType = 4
	ThrottleType_READ_NUMBER    ThrottleType = 5
	ThrottleType_READ_SIZE      ThrottleType = 6
)

func (ThrottleType) Enum

func (x ThrottleType) Enum() *ThrottleType

func (ThrottleType) String

func (x ThrottleType) String() string

func (*ThrottleType) UnmarshalJSON

func (x *ThrottleType) UnmarshalJSON(data []byte) error

type TimeRange

type TimeRange struct {
	From             *uint64 `protobuf:"varint,1,opt,name=from" json:"from,omitempty"`
	To               *uint64 `protobuf:"varint,2,opt,name=to" json:"to,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* A range of time. Both from and to are Java time stamp in milliseconds. If you don't specify a time range, it means all time. By default, if not specified, from = 0, and to = Long.MAX_VALUE

func (*TimeRange) GetFrom

func (m *TimeRange) GetFrom() uint64

func (*TimeRange) GetTo

func (m *TimeRange) GetTo() uint64

func (*TimeRange) ProtoMessage

func (*TimeRange) ProtoMessage()

func (*TimeRange) Reset

func (m *TimeRange) Reset()

func (*TimeRange) String

func (m *TimeRange) String() string

type TimeUnit

type TimeUnit int32
const (
	TimeUnit_NANOSECONDS  TimeUnit = 1
	TimeUnit_MICROSECONDS TimeUnit = 2
	TimeUnit_MILLISECONDS TimeUnit = 3
	TimeUnit_SECONDS      TimeUnit = 4
	TimeUnit_MINUTES      TimeUnit = 5
	TimeUnit_HOURS        TimeUnit = 6
	TimeUnit_DAYS         TimeUnit = 7
)

func (TimeUnit) Enum

func (x TimeUnit) Enum() *TimeUnit

func (TimeUnit) String

func (x TimeUnit) String() string

func (*TimeUnit) UnmarshalJSON

func (x *TimeUnit) UnmarshalJSON(data []byte) error

type TimedQuota

type TimedQuota struct {
	TimeUnit         *TimeUnit   `protobuf:"varint,1,req,name=time_unit,enum=proto.TimeUnit" json:"time_unit,omitempty"`
	SoftLimit        *uint64     `protobuf:"varint,2,opt,name=soft_limit" json:"soft_limit,omitempty"`
	Share            *float32    `protobuf:"fixed32,3,opt,name=share" json:"share,omitempty"`
	Scope            *QuotaScope `protobuf:"varint,4,opt,name=scope,enum=proto.QuotaScope,def=2" json:"scope,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*TimedQuota) GetScope

func (m *TimedQuota) GetScope() QuotaScope

func (*TimedQuota) GetShare

func (m *TimedQuota) GetShare() float32

func (*TimedQuota) GetSoftLimit

func (m *TimedQuota) GetSoftLimit() uint64

func (*TimedQuota) GetTimeUnit

func (m *TimedQuota) GetTimeUnit() TimeUnit

func (*TimedQuota) ProtoMessage

func (*TimedQuota) ProtoMessage()

func (*TimedQuota) Reset

func (m *TimedQuota) Reset()

func (*TimedQuota) String

func (m *TimedQuota) String() string

type TimestampsFilter

type TimestampsFilter struct {
	Timestamps       []int64 `protobuf:"varint,1,rep,packed,name=timestamps" json:"timestamps,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*TimestampsFilter) GetTimestamps

func (m *TimestampsFilter) GetTimestamps() []int64

func (*TimestampsFilter) ProtoMessage

func (*TimestampsFilter) ProtoMessage()

func (*TimestampsFilter) Reset

func (m *TimestampsFilter) Reset()

func (*TimestampsFilter) String

func (m *TimestampsFilter) String() string

type Token

type Token struct {
	// the TokenIdentifier in serialized form
	// Note: we can't use the protobuf directly because the Hadoop Token class
	// only stores the serialized bytes
	Identifier       []byte `protobuf:"bytes,1,opt,name=identifier" json:"identifier,omitempty"`
	Password         []byte `protobuf:"bytes,2,opt,name=password" json:"password,omitempty"`
	Service          []byte `protobuf:"bytes,3,opt,name=service" json:"service,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

Serialization of the org.apache.hadoop.security.token.Token class Note that this is a Hadoop class, so fields may change!

func (*Token) GetIdentifier

func (m *Token) GetIdentifier() []byte

func (*Token) GetPassword

func (m *Token) GetPassword() []byte

func (*Token) GetService

func (m *Token) GetService() []byte

func (*Token) ProtoMessage

func (*Token) ProtoMessage()

func (*Token) Reset

func (m *Token) Reset()

func (*Token) String

func (m *Token) String() string

type TokenIdentifier

type TokenIdentifier struct {
	Kind             *TokenIdentifier_Kind `protobuf:"varint,1,req,name=kind,enum=proto.TokenIdentifier_Kind" json:"kind,omitempty"`
	Username         []byte                `protobuf:"bytes,2,req,name=username" json:"username,omitempty"`
	KeyId            *int32                `protobuf:"varint,3,req,name=key_id" json:"key_id,omitempty"`
	IssueDate        *int64                `protobuf:"varint,4,opt,name=issue_date" json:"issue_date,omitempty"`
	ExpirationDate   *int64                `protobuf:"varint,5,opt,name=expiration_date" json:"expiration_date,omitempty"`
	SequenceNumber   *int64                `protobuf:"varint,6,opt,name=sequence_number" json:"sequence_number,omitempty"`
	XXX_unrecognized []byte                `json:"-"`
}

func (*TokenIdentifier) GetExpirationDate

func (m *TokenIdentifier) GetExpirationDate() int64

func (*TokenIdentifier) GetIssueDate

func (m *TokenIdentifier) GetIssueDate() int64

func (*TokenIdentifier) GetKeyId

func (m *TokenIdentifier) GetKeyId() int32

func (*TokenIdentifier) GetKind

func (*TokenIdentifier) GetSequenceNumber

func (m *TokenIdentifier) GetSequenceNumber() int64

func (*TokenIdentifier) GetUsername

func (m *TokenIdentifier) GetUsername() []byte

func (*TokenIdentifier) ProtoMessage

func (*TokenIdentifier) ProtoMessage()

func (*TokenIdentifier) Reset

func (m *TokenIdentifier) Reset()

func (*TokenIdentifier) String

func (m *TokenIdentifier) String() string

type TokenIdentifier_Kind

type TokenIdentifier_Kind int32
const (
	TokenIdentifier_HBASE_AUTH_TOKEN TokenIdentifier_Kind = 0
)

func (TokenIdentifier_Kind) Enum

func (TokenIdentifier_Kind) String

func (x TokenIdentifier_Kind) String() string

func (*TokenIdentifier_Kind) UnmarshalJSON

func (x *TokenIdentifier_Kind) UnmarshalJSON(data []byte) error

type TruncateTableRequest

type TruncateTableRequest struct {
	TableName        *TableName `protobuf:"bytes,1,req,name=tableName" json:"tableName,omitempty"`
	PreserveSplits   *bool      `protobuf:"varint,2,opt,name=preserveSplits,def=0" json:"preserveSplits,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

func (*TruncateTableRequest) GetPreserveSplits

func (m *TruncateTableRequest) GetPreserveSplits() bool

func (*TruncateTableRequest) GetTableName

func (m *TruncateTableRequest) GetTableName() *TableName

func (*TruncateTableRequest) ProtoMessage

func (*TruncateTableRequest) ProtoMessage()

func (*TruncateTableRequest) Reset

func (m *TruncateTableRequest) Reset()

func (*TruncateTableRequest) String

func (m *TruncateTableRequest) String() string

type TruncateTableResponse

type TruncateTableResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*TruncateTableResponse) ProtoMessage

func (*TruncateTableResponse) ProtoMessage()

func (*TruncateTableResponse) Reset

func (m *TruncateTableResponse) Reset()

func (*TruncateTableResponse) String

func (m *TruncateTableResponse) String() string

type UUID

type UUID struct {
	LeastSigBits     *uint64 `protobuf:"varint,1,req,name=least_sig_bits" json:"least_sig_bits,omitempty"`
	MostSigBits      *uint64 `protobuf:"varint,2,req,name=most_sig_bits" json:"most_sig_bits,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*UUID) GetLeastSigBits

func (m *UUID) GetLeastSigBits() uint64

func (*UUID) GetMostSigBits

func (m *UUID) GetMostSigBits() uint64

func (*UUID) ProtoMessage

func (*UUID) ProtoMessage()

func (*UUID) Reset

func (m *UUID) Reset()

func (*UUID) String

func (m *UUID) String() string

type UnassignRegionRequest

type UnassignRegionRequest struct {
	Region           *RegionSpecifier `protobuf:"bytes,1,req,name=region" json:"region,omitempty"`
	Force            *bool            `protobuf:"varint,2,opt,name=force,def=0" json:"force,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*UnassignRegionRequest) GetForce

func (m *UnassignRegionRequest) GetForce() bool

func (*UnassignRegionRequest) GetRegion

func (m *UnassignRegionRequest) GetRegion() *RegionSpecifier

func (*UnassignRegionRequest) ProtoMessage

func (*UnassignRegionRequest) ProtoMessage()

func (*UnassignRegionRequest) Reset

func (m *UnassignRegionRequest) Reset()

func (*UnassignRegionRequest) String

func (m *UnassignRegionRequest) String() string

type UnassignRegionResponse

type UnassignRegionResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*UnassignRegionResponse) ProtoMessage

func (*UnassignRegionResponse) ProtoMessage()

func (*UnassignRegionResponse) Reset

func (m *UnassignRegionResponse) Reset()

func (*UnassignRegionResponse) String

func (m *UnassignRegionResponse) String() string

type UpdateConfigurationRequest

type UpdateConfigurationRequest struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*UpdateConfigurationRequest) ProtoMessage

func (*UpdateConfigurationRequest) ProtoMessage()

func (*UpdateConfigurationRequest) Reset

func (m *UpdateConfigurationRequest) Reset()

func (*UpdateConfigurationRequest) String

func (m *UpdateConfigurationRequest) String() string

type UpdateConfigurationResponse

type UpdateConfigurationResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*UpdateConfigurationResponse) ProtoMessage

func (*UpdateConfigurationResponse) ProtoMessage()

func (*UpdateConfigurationResponse) Reset

func (m *UpdateConfigurationResponse) Reset()

func (*UpdateConfigurationResponse) String

func (m *UpdateConfigurationResponse) String() string

type UpdateFavoredNodesRequest

type UpdateFavoredNodesRequest struct {
	UpdateInfo       []*UpdateFavoredNodesRequest_RegionUpdateInfo `protobuf:"bytes,1,rep,name=update_info" json:"update_info,omitempty"`
	XXX_unrecognized []byte                                        `json:"-"`
}

func (*UpdateFavoredNodesRequest) GetUpdateInfo

func (*UpdateFavoredNodesRequest) ProtoMessage

func (*UpdateFavoredNodesRequest) ProtoMessage()

func (*UpdateFavoredNodesRequest) Reset

func (m *UpdateFavoredNodesRequest) Reset()

func (*UpdateFavoredNodesRequest) String

func (m *UpdateFavoredNodesRequest) String() string

type UpdateFavoredNodesRequest_RegionUpdateInfo

type UpdateFavoredNodesRequest_RegionUpdateInfo struct {
	Region           *RegionInfo   `protobuf:"bytes,1,req,name=region" json:"region,omitempty"`
	FavoredNodes     []*ServerName `protobuf:"bytes,2,rep,name=favored_nodes" json:"favored_nodes,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*UpdateFavoredNodesRequest_RegionUpdateInfo) GetFavoredNodes

func (*UpdateFavoredNodesRequest_RegionUpdateInfo) GetRegion

func (*UpdateFavoredNodesRequest_RegionUpdateInfo) ProtoMessage

func (*UpdateFavoredNodesRequest_RegionUpdateInfo) Reset

func (*UpdateFavoredNodesRequest_RegionUpdateInfo) String

type UpdateFavoredNodesResponse

type UpdateFavoredNodesResponse struct {
	Response         *uint32 `protobuf:"varint,1,opt,name=response" json:"response,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*UpdateFavoredNodesResponse) GetResponse

func (m *UpdateFavoredNodesResponse) GetResponse() uint32

func (*UpdateFavoredNodesResponse) ProtoMessage

func (*UpdateFavoredNodesResponse) ProtoMessage()

func (*UpdateFavoredNodesResponse) Reset

func (m *UpdateFavoredNodesResponse) Reset()

func (*UpdateFavoredNodesResponse) String

func (m *UpdateFavoredNodesResponse) String() string

type UserAuthorizations

type UserAuthorizations struct {
	User             []byte   `protobuf:"bytes,1,req,name=user" json:"user,omitempty"`
	Auth             []uint32 `protobuf:"varint,2,rep,name=auth" json:"auth,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*UserAuthorizations) GetAuth

func (m *UserAuthorizations) GetAuth() []uint32

func (*UserAuthorizations) GetUser

func (m *UserAuthorizations) GetUser() []byte

func (*UserAuthorizations) ProtoMessage

func (*UserAuthorizations) ProtoMessage()

func (*UserAuthorizations) Reset

func (m *UserAuthorizations) Reset()

func (*UserAuthorizations) String

func (m *UserAuthorizations) String() string

type UserInformation

type UserInformation struct {
	EffectiveUser    *string `protobuf:"bytes,1,req,name=effective_user" json:"effective_user,omitempty"`
	RealUser         *string `protobuf:"bytes,2,opt,name=real_user" json:"real_user,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

User Information proto. Included in ConnectionHeader on connection setup

func (*UserInformation) GetEffectiveUser

func (m *UserInformation) GetEffectiveUser() string

func (*UserInformation) GetRealUser

func (m *UserInformation) GetRealUser() string

func (*UserInformation) ProtoMessage

func (*UserInformation) ProtoMessage()

func (*UserInformation) Reset

func (m *UserInformation) Reset()

func (*UserInformation) String

func (m *UserInformation) String() string

type UserPermission

type UserPermission struct {
	User             []byte      `protobuf:"bytes,1,req,name=user" json:"user,omitempty"`
	Permission       *Permission `protobuf:"bytes,3,req,name=permission" json:"permission,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*UserPermission) GetPermission

func (m *UserPermission) GetPermission() *Permission

func (*UserPermission) GetUser

func (m *UserPermission) GetUser() []byte

func (*UserPermission) ProtoMessage

func (*UserPermission) ProtoMessage()

func (*UserPermission) Reset

func (m *UserPermission) Reset()

func (*UserPermission) String

func (m *UserPermission) String() string

type UsersAndPermissions

type UsersAndPermissions struct {
	UserPermissions  []*UsersAndPermissions_UserPermissions `protobuf:"bytes,1,rep,name=user_permissions" json:"user_permissions,omitempty"`
	XXX_unrecognized []byte                                 `json:"-"`
}

* Content of the /hbase/acl/<table or namespace> znode.

func (*UsersAndPermissions) GetUserPermissions

func (m *UsersAndPermissions) GetUserPermissions() []*UsersAndPermissions_UserPermissions

func (*UsersAndPermissions) ProtoMessage

func (*UsersAndPermissions) ProtoMessage()

func (*UsersAndPermissions) Reset

func (m *UsersAndPermissions) Reset()

func (*UsersAndPermissions) String

func (m *UsersAndPermissions) String() string

type UsersAndPermissions_UserPermissions

type UsersAndPermissions_UserPermissions struct {
	User             []byte        `protobuf:"bytes,1,req,name=user" json:"user,omitempty"`
	Permissions      []*Permission `protobuf:"bytes,2,rep,name=permissions" json:"permissions,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*UsersAndPermissions_UserPermissions) GetPermissions

func (m *UsersAndPermissions_UserPermissions) GetPermissions() []*Permission

func (*UsersAndPermissions_UserPermissions) GetUser

func (*UsersAndPermissions_UserPermissions) ProtoMessage

func (*UsersAndPermissions_UserPermissions) ProtoMessage()

func (*UsersAndPermissions_UserPermissions) Reset

func (*UsersAndPermissions_UserPermissions) String

type ValueFilter

type ValueFilter struct {
	CompareFilter    *CompareFilter `protobuf:"bytes,1,req,name=compare_filter" json:"compare_filter,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*ValueFilter) GetCompareFilter

func (m *ValueFilter) GetCompareFilter() *CompareFilter

func (*ValueFilter) ProtoMessage

func (*ValueFilter) ProtoMessage()

func (*ValueFilter) Reset

func (m *ValueFilter) Reset()

func (*ValueFilter) String

func (m *ValueFilter) String() string

type VisibilityLabel

type VisibilityLabel struct {
	Label            []byte  `protobuf:"bytes,1,req,name=label" json:"label,omitempty"`
	Ordinal          *uint32 `protobuf:"varint,2,opt,name=ordinal" json:"ordinal,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*VisibilityLabel) GetLabel

func (m *VisibilityLabel) GetLabel() []byte

func (*VisibilityLabel) GetOrdinal

func (m *VisibilityLabel) GetOrdinal() uint32

func (*VisibilityLabel) ProtoMessage

func (*VisibilityLabel) ProtoMessage()

func (*VisibilityLabel) Reset

func (m *VisibilityLabel) Reset()

func (*VisibilityLabel) String

func (m *VisibilityLabel) String() string

type VisibilityLabelsRequest

type VisibilityLabelsRequest struct {
	VisLabel         []*VisibilityLabel `protobuf:"bytes,1,rep,name=visLabel" json:"visLabel,omitempty"`
	XXX_unrecognized []byte             `json:"-"`
}

func (*VisibilityLabelsRequest) GetVisLabel

func (m *VisibilityLabelsRequest) GetVisLabel() []*VisibilityLabel

func (*VisibilityLabelsRequest) ProtoMessage

func (*VisibilityLabelsRequest) ProtoMessage()

func (*VisibilityLabelsRequest) Reset

func (m *VisibilityLabelsRequest) Reset()

func (*VisibilityLabelsRequest) String

func (m *VisibilityLabelsRequest) String() string

type VisibilityLabelsResponse

type VisibilityLabelsResponse struct {
	Result           []*RegionActionResult `protobuf:"bytes,1,rep,name=result" json:"result,omitempty"`
	XXX_unrecognized []byte                `json:"-"`
}

func (*VisibilityLabelsResponse) GetResult

func (m *VisibilityLabelsResponse) GetResult() []*RegionActionResult

func (*VisibilityLabelsResponse) ProtoMessage

func (*VisibilityLabelsResponse) ProtoMessage()

func (*VisibilityLabelsResponse) Reset

func (m *VisibilityLabelsResponse) Reset()

func (*VisibilityLabelsResponse) String

func (m *VisibilityLabelsResponse) String() string

type WALEntry

type WALEntry struct {
	Key *WALKey `protobuf:"bytes,1,req,name=key" json:"key,omitempty"`
	// Following may be null if the KVs/Cells are carried along the side in a cellblock (See
	// RPC for more on cellblocks). If Cells/KVs are in a cellblock, this next field is null
	// and associated_cell_count has count of Cells associated w/ this WALEntry
	KeyValueBytes [][]byte `protobuf:"bytes,2,rep,name=key_value_bytes" json:"key_value_bytes,omitempty"`
	// If Cell data is carried alongside in a cellblock, this is count of Cells in the cellblock.
	AssociatedCellCount *int32 `protobuf:"varint,3,opt,name=associated_cell_count" json:"associated_cell_count,omitempty"`
	XXX_unrecognized    []byte `json:"-"`
}

Protocol buffer version of WAL for replication

func (*WALEntry) GetAssociatedCellCount

func (m *WALEntry) GetAssociatedCellCount() int32

func (*WALEntry) GetKey

func (m *WALEntry) GetKey() *WALKey

func (*WALEntry) GetKeyValueBytes

func (m *WALEntry) GetKeyValueBytes() [][]byte

func (*WALEntry) ProtoMessage

func (*WALEntry) ProtoMessage()

func (*WALEntry) Reset

func (m *WALEntry) Reset()

func (*WALEntry) String

func (m *WALEntry) String() string

type WALHeader

type WALHeader struct {
	HasCompression    *bool   `protobuf:"varint,1,opt,name=has_compression" json:"has_compression,omitempty"`
	EncryptionKey     []byte  `protobuf:"bytes,2,opt,name=encryption_key" json:"encryption_key,omitempty"`
	HasTagCompression *bool   `protobuf:"varint,3,opt,name=has_tag_compression" json:"has_tag_compression,omitempty"`
	WriterClsName     *string `protobuf:"bytes,4,opt,name=writer_cls_name" json:"writer_cls_name,omitempty"`
	CellCodecClsName  *string `protobuf:"bytes,5,opt,name=cell_codec_cls_name" json:"cell_codec_cls_name,omitempty"`
	XXX_unrecognized  []byte  `json:"-"`
}

func (*WALHeader) GetCellCodecClsName

func (m *WALHeader) GetCellCodecClsName() string

func (*WALHeader) GetEncryptionKey

func (m *WALHeader) GetEncryptionKey() []byte

func (*WALHeader) GetHasCompression

func (m *WALHeader) GetHasCompression() bool

func (*WALHeader) GetHasTagCompression

func (m *WALHeader) GetHasTagCompression() bool

func (*WALHeader) GetWriterClsName

func (m *WALHeader) GetWriterClsName() string

func (*WALHeader) ProtoMessage

func (*WALHeader) ProtoMessage()

func (*WALHeader) Reset

func (m *WALHeader) Reset()

func (*WALHeader) String

func (m *WALHeader) String() string

type WALKey

type WALKey struct {
	EncodedRegionName []byte  `protobuf:"bytes,1,req,name=encoded_region_name" json:"encoded_region_name,omitempty"`
	TableName         []byte  `protobuf:"bytes,2,req,name=table_name" json:"table_name,omitempty"`
	LogSequenceNumber *uint64 `protobuf:"varint,3,req,name=log_sequence_number" json:"log_sequence_number,omitempty"`
	WriteTime         *uint64 `protobuf:"varint,4,req,name=write_time" json:"write_time,omitempty"`
	//
	// This parameter is deprecated in favor of clusters which
	// contains the list of clusters that have consumed the change.
	// It is retained so that the log created by earlier releases (0.94)
	// can be read by the newer releases.
	ClusterId        *UUID          `protobuf:"bytes,5,opt,name=cluster_id" json:"cluster_id,omitempty"`
	Scopes           []*FamilyScope `protobuf:"bytes,6,rep,name=scopes" json:"scopes,omitempty"`
	FollowingKvCount *uint32        `protobuf:"varint,7,opt,name=following_kv_count" json:"following_kv_count,omitempty"`
	//
	// This field contains the list of clusters that have
	// consumed the change
	ClusterIds         []*UUID `protobuf:"bytes,8,rep,name=cluster_ids" json:"cluster_ids,omitempty"`
	NonceGroup         *uint64 `protobuf:"varint,9,opt,name=nonceGroup" json:"nonceGroup,omitempty"`
	Nonce              *uint64 `protobuf:"varint,10,opt,name=nonce" json:"nonce,omitempty"`
	OrigSequenceNumber *uint64 `protobuf:"varint,11,opt,name=orig_sequence_number" json:"orig_sequence_number,omitempty"`
	XXX_unrecognized   []byte  `json:"-"`
}

Protocol buffer version of WALKey; see WALKey comment, not really a key but WALEdit header for some KVs

func (*WALKey) GetClusterId

func (m *WALKey) GetClusterId() *UUID

func (*WALKey) GetClusterIds

func (m *WALKey) GetClusterIds() []*UUID

func (*WALKey) GetEncodedRegionName

func (m *WALKey) GetEncodedRegionName() []byte

func (*WALKey) GetFollowingKvCount

func (m *WALKey) GetFollowingKvCount() uint32

func (*WALKey) GetLogSequenceNumber

func (m *WALKey) GetLogSequenceNumber() uint64

func (*WALKey) GetNonce

func (m *WALKey) GetNonce() uint64

func (*WALKey) GetNonceGroup

func (m *WALKey) GetNonceGroup() uint64

func (*WALKey) GetOrigSequenceNumber

func (m *WALKey) GetOrigSequenceNumber() uint64

func (*WALKey) GetScopes

func (m *WALKey) GetScopes() []*FamilyScope

func (*WALKey) GetTableName

func (m *WALKey) GetTableName() []byte

func (*WALKey) GetWriteTime

func (m *WALKey) GetWriteTime() uint64

func (*WALKey) ProtoMessage

func (*WALKey) ProtoMessage()

func (*WALKey) Reset

func (m *WALKey) Reset()

func (*WALKey) String

func (m *WALKey) String() string

type WALTrailer

type WALTrailer struct {
	XXX_unrecognized []byte `json:"-"`
}

* A trailer that is appended to the end of a properly closed WAL file. If missing, this is either a legacy or a corrupted WAL file. N.B. This trailer currently doesn't contain any information and we purposefully don't expose it in the WAL APIs. It's for future growth.

func (*WALTrailer) ProtoMessage

func (*WALTrailer) ProtoMessage()

func (*WALTrailer) Reset

func (m *WALTrailer) Reset()

func (*WALTrailer) String

func (m *WALTrailer) String() string

type WhileMatchFilter

type WhileMatchFilter struct {
	Filter           *Filter `protobuf:"bytes,1,req,name=filter" json:"filter,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*WhileMatchFilter) GetFilter

func (m *WhileMatchFilter) GetFilter() *Filter

func (*WhileMatchFilter) ProtoMessage

func (*WhileMatchFilter) ProtoMessage()

func (*WhileMatchFilter) Reset

func (m *WhileMatchFilter) Reset()

func (*WhileMatchFilter) String

func (m *WhileMatchFilter) String() string

type WhoAmIRequest

type WhoAmIRequest struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*WhoAmIRequest) ProtoMessage

func (*WhoAmIRequest) ProtoMessage()

func (*WhoAmIRequest) Reset

func (m *WhoAmIRequest) Reset()

func (*WhoAmIRequest) String

func (m *WhoAmIRequest) String() string

type WhoAmIResponse

type WhoAmIResponse struct {
	Username         *string `protobuf:"bytes,1,opt,name=username" json:"username,omitempty"`
	AuthMethod       *string `protobuf:"bytes,2,opt,name=auth_method" json:"auth_method,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*WhoAmIResponse) GetAuthMethod

func (m *WhoAmIResponse) GetAuthMethod() string

func (*WhoAmIResponse) GetUsername

func (m *WhoAmIResponse) GetUsername() string

func (*WhoAmIResponse) ProtoMessage

func (*WhoAmIResponse) ProtoMessage()

func (*WhoAmIResponse) Reset

func (m *WhoAmIResponse) Reset()

func (*WhoAmIResponse) String

func (m *WhoAmIResponse) String() string

type WrappedKey

type WrappedKey struct {
	Algorithm        *string `protobuf:"bytes,1,req,name=algorithm" json:"algorithm,omitempty"`
	Length           *uint32 `protobuf:"varint,2,req,name=length" json:"length,omitempty"`
	Data             []byte  `protobuf:"bytes,3,req,name=data" json:"data,omitempty"`
	Iv               []byte  `protobuf:"bytes,4,opt,name=iv" json:"iv,omitempty"`
	Hash             []byte  `protobuf:"bytes,5,opt,name=hash" json:"hash,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*WrappedKey) GetAlgorithm

func (m *WrappedKey) GetAlgorithm() string

func (*WrappedKey) GetData

func (m *WrappedKey) GetData() []byte

func (*WrappedKey) GetHash

func (m *WrappedKey) GetHash() []byte

func (*WrappedKey) GetIv

func (m *WrappedKey) GetIv() []byte

func (*WrappedKey) GetLength

func (m *WrappedKey) GetLength() uint32

func (*WrappedKey) ProtoMessage

func (*WrappedKey) ProtoMessage()

func (*WrappedKey) Reset

func (m *WrappedKey) Reset()

func (*WrappedKey) String

func (m *WrappedKey) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL