region

Documentation

Overview

Package region contains data structures to represent HBase regions.

Index

• Constants
• Variables
• func Compare(a, b []byte) int
• func CompareGeneric(a, b interface{}) int
• func NewClient(host string, port uint16, ctype ClientType, queueSize int, ...) (hrpc.RegionClient, error)
• func NewInfo(table, name, startKey, stopKey []byte) hrpc.RegionInfo
• func ParseRegionInfo(metaRow *pb.GetResponse) (hrpc.RegionInfo, string, uint16, error)
• type ClientType
• type RetryableError
  • func (e RetryableError) Error() string
• type UnrecoverableError
  • func (e UnrecoverableError) Error() string

Constants

const (
	// RegionClient is a ClientType that means this will be a normal client
	RegionClient = ClientType("ClientService")

	// MasterClient is a ClientType that means this client will talk to the
	// master server
	MasterClient = ClientType("MasterService")
)

Variables

var (
	// ErrShortWrite is used when the writer thread only succeeds in writing
	// part of its buffer to the socket, and not all of the buffer was sent
	ErrShortWrite = errors.New("short write occurred while writing to socket")

	// ErrMissingCallID is used when HBase sends us a response message for a
	// request that we didn't send
	ErrMissingCallID = errors.New("HBase responded to a nonsensical call ID")
)

Functions

func Compare

func Compare(a, b []byte) int

Compare compares two region names. We can't just use bytes.Compare() because it doesn't play nicely with the way META keys are built as the first region has an empty start key. Let's assume we know about those 2 regions in our cache:

.META.,,1
tableA,,1273018455182

We're given an RPC to execute on "tableA", row "\x00" (1 byte row key containing a 0). If we use Compare() to sort the entries in the cache, when we search for the entry right before "tableA,\000,:" we'll erroneously find ".META.,,1" instead of the entry for first region of "tableA".

Since this scheme breaks natural ordering, we need this comparator to implement a special version of comparison to handle this scenario.

func CompareGeneric

func CompareGeneric(a, b interface{}) int

CompareGeneric is the same thing as Compare but for interface{}.

func NewClient

func NewClient(host string, port uint16, ctype ClientType,
	queueSize int, flushInterval time.Duration) (hrpc.RegionClient, error)

NewClient creates a new RegionClient.

func NewInfo

func NewInfo(table, name, startKey, stopKey []byte) hrpc.RegionInfo

NewInfo creates a new region info

func ParseRegionInfo

func ParseRegionInfo(metaRow *pb.GetResponse) (hrpc.RegionInfo, string, uint16, error)

ParseRegionInfo parses the contents of a row from the meta table. It's guaranteed to return a region info and a host/port OR return an error.

Types

type ClientType

type ClientType string

ClientType is a type alias to represent the type of this region client

type RetryableError

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

RetryableError is an error that indicates the RPC should be retried because the error is transient (e.g. a region being momentarily unavailable).

func (RetryableError) Error

func (e RetryableError) Error() string

type UnrecoverableError

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

UnrecoverableError is an error that this region.Client can't recover from. The connection to the RegionServer has to be closed and all queued and outstanding RPCs will be failed / retried.

func (UnrecoverableError) Error

func (e UnrecoverableError) Error() string