base

package

v0.0.0-...-23ace0b Latest Latest Go to latest Published: Aug 13, 2019 License: Apache-2.0 Imports: 3 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/harrylee2015/pegasus-go-client

Documentation ¶

Index ¶

Variables
func NewRocksDBErrFromInt(e int32) error
type Blob
- func NewBlob() *Blob
type DsnErrCode
- func DsnErrCodeString(s string) (DsnErrCode, error)
- func (e DsnErrCode) Error() string
- func (i DsnErrCode) String() string
type ErrorCode
type Gpid
type RPCAddress
type RocksDBErrCode
- func RocksDBErrCodeString(s string) (RocksDBErrCode, error)
- func (e RocksDBErrCode) Error() string
- func (i RocksDBErrCode) String() string

Constants ¶

This section is empty.

Variables ¶

View Source

var GoUnusedProtection__ int

Functions ¶

func NewRocksDBErrFromInt ¶

func NewRocksDBErrFromInt(e int32) error

Types ¶

type Blob ¶

type Blob struct {
	Data []byte
}

func NewBlob ¶

func NewBlob() *Blob

func (*Blob) Read ¶

func (b *Blob) Read(iprot thrift.TProtocol) error

func (*Blob) String ¶

func (b *Blob) String() string

func (*Blob) Write ¶

func (b *Blob) Write(oprot thrift.TProtocol) error

type DsnErrCode ¶

type DsnErrCode int32

const (
	ERR_OK DsnErrCode = iota
	ERR_UNKNOWN
	ERR_REPLICATION_FAILURE
	ERR_APP_EXIST
	ERR_APP_NOT_EXIST
	ERR_APP_DROPPED
	ERR_BUSY_CREATING
	ERR_BUSY_DROPPING
	ERR_EXPIRED
	ERR_LOCK_ALREADY_EXIST
	ERR_HOLD_BY_OTHERS
	ERR_RECURSIVE_LOCK
	ERR_NO_OWNER
	ERR_NODE_ALREADY_EXIST
	ERR_INCONSISTENT_STATE
	ERR_ARRAY_INDEX_OUT_OF_RANGE
	ERR_SERVICE_NOT_FOUND
	ERR_SERVICE_ALREADY_RUNNING
	ERR_IO_PENDING
	ERR_TIMEOUT
	ERR_SERVICE_NOT_ACTIVE
	ERR_BUSY
	ERR_NETWORK_INIT_FAILED
	ERR_FORWARD_TO_OTHERS
	ERR_OBJECT_NOT_FOUND
	ERR_HANDLER_NOT_FOUND
	ERR_LEARN_FILE_FAILED
	ERR_GET_LEARN_STATE_FAILED
	ERR_INVALID_VERSION
	ERR_INVALID_PARAMETERS
	ERR_CAPACITY_EXCEEDED
	ERR_INVALID_STATE
	ERR_INACTIVE_STATE
	ERR_NOT_ENOUGH_MEMBER
	ERR_FILE_OPERATION_FAILED
	ERR_HANDLE_EOF
	ERR_WRONG_CHECKSUM
	ERR_INVALID_DATA
	ERR_INVALID_HANDLE
	ERR_INCOMPLETE_DATA
	ERR_VERSION_OUTDATED
	ERR_PATH_NOT_FOUND
	ERR_PATH_ALREADY_EXIST
	ERR_ADDRESS_ALREADY_USED
	ERR_STATE_FREEZED
	ERR_LOCAL_APP_FAILURE
	ERR_BIND_IOCP_FAILED
	ERR_NETWORK_START_FAILED
	ERR_NOT_IMPLEMENTED
	ERR_CHECKPOINT_FAILED
	ERR_WRONG_TIMING
	ERR_NO_NEED_OPERATE
	ERR_CORRUPTION
	ERR_TRY_AGAIN
	ERR_CLUSTER_NOT_FOUND
	ERR_CLUSTER_ALREADY_EXIST
	ERR_ZOOKEEPER_OPERATION
	ERR_K8S_CLUSTER_NOT_FOUND
	ERR_K8S_KUBECTL_NOT_FOUND
	ERR_K8S_DEPLOY_FAILED
	ERR_K8S_UNDEPLOY_FAILED
	ERR_RESOURCE_NOT_ENOUGH
	ERR_WIN_DEPLOY_FAILED
	ERR_WIN_UNDEPLOY_FAILED
	ERR_DOCKER_DAEMON_NOT_FOUND
	ERR_DOCKER_BINARY_NOT_FOUND
	ERR_DOCKER_DEPLOY_FAILED
	ERR_DOCKER_UNDEPLOY_FAILED
	ERR_FS_INTERNAL
)

func DsnErrCodeString ¶

func DsnErrCodeString(s string) (DsnErrCode, error)

func (DsnErrCode) Error ¶

func (e DsnErrCode) Error() string

func (DsnErrCode) String ¶

func (i DsnErrCode) String() string

type ErrorCode ¶

type ErrorCode struct {
	Errno string
}

/ Primitive for Pegasus thrift framework.

func (*ErrorCode) Read ¶

func (ec *ErrorCode) Read(iprot thrift.TProtocol) (err error)

func (*ErrorCode) String ¶

func (ec *ErrorCode) String() string

func (*ErrorCode) Write ¶

func (ec *ErrorCode) Write(oprot thrift.TProtocol) error

type Gpid ¶

type Gpid struct {
	Appid, PartitionIndex int32
}

func (*Gpid) Read ¶

func (id *Gpid) Read(iprot thrift.TProtocol) error

func (*Gpid) String ¶

func (id *Gpid) String() string

func (*Gpid) Write ¶

func (id *Gpid) Write(oprot thrift.TProtocol) error

type RPCAddress ¶

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

func (*RPCAddress) GetAddress ¶

func (r *RPCAddress) GetAddress() string

func (*RPCAddress) GetRawAddress ¶

func (r *RPCAddress) GetRawAddress() int64

func (*RPCAddress) Read ¶

func (r *RPCAddress) Read(iprot thrift.TProtocol) error

func (*RPCAddress) String ¶

func (r *RPCAddress) String() string

func (*RPCAddress) Write ¶

func (r *RPCAddress) Write(oprot thrift.TProtocol) error

type RocksDBErrCode ¶

type RocksDBErrCode int32

const (
	Ok RocksDBErrCode = iota
	NotFound
	Corruption
	NotSupported
	InvalidArgument
	IOError
	MergeInProgress
	Incomplete
	ShutdownInProgress
	TimedOut
	Aborted
	Busy
	Expired
	TryAgain
)

func RocksDBErrCodeString ¶

func RocksDBErrCodeString(s string) (RocksDBErrCode, error)

func (RocksDBErrCode) Error ¶

func (e RocksDBErrCode) Error() string

func (RocksDBErrCode) String ¶

func (i RocksDBErrCode) String() string

Source Files ¶

View all Source files

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