region

Documentation

Index

• Constants
• Variables
• type Client
  • func NewClient(host string, port uint16, ctype ClientType, queueSize int, ...) (*Client, error)
  • func (c *Client) Close()
  • func (c *Client) Host() string
  • func (c *Client) Port() uint16
  • func (c *Client) QueueRPC(rpc hrpc.Call) 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")
)

Types

type Client

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

Client manages a connection to a RegionServer.

func NewClient

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

NewClient creates a new RegionClient.

func (*Client) Close

func (c *Client) Close()

Close asks this region.Client to close its connection to the RegionServer. All queued and outstanding RPCs, if any, will be failed as if a connection error had happened.

func (*Client) Host

func (c *Client) Host() string

Host returns the host that this client talks to

func (*Client) Port

func (c *Client) Port() uint16

Port returns the port that this client talks over

func (*Client) QueueRPC

func (c *Client) QueueRPC(rpc hrpc.Call) error

QueueRPC will add an rpc call to the queue for processing by the writer goroutine

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