Documentation ¶
Index ¶
- Constants
- type CoordConnectionError
- type CoordDecodeFailError
- type CoordEncodeFailError
- type CoordLockFailError
- type CoordNoNodeError
- type CoordNothingToRemoveError
- type CoordOperateError
- type CoordRequestError
- type CoordTargetAlreadyExistsError
- type InvalidStateError
- type PQError
- type QErrCode
- type TargetNotExistError
- type TopicNotExistError
- type ValidationError
Constants ¶
View Source
const ( // 00 - successful completion Success QErrCode = 0x0000 // 01 - msg or field error ErrInvalidMsgType = 0x0100 ErrInvalidStartOffset = 0x0101 ErrMarshalAnyFailed = 0x0102 ErrUnmarshalAnyFailed = 0x0103 ErrMarshalFailed = 0x0104 ErrUnmarshalFailed = 0x0105 ErrTopicNotSet = 0x0106 ErrValidation = 0x0107 ErrTopicFragmentOffsetNotSet = 0x0108 ErrInvalidState = 0x0109 // 02 - coordinating error ErrCoordConnection = 0x0200 ErrCoordTargetAlreadyExists = 0x0201 ErrCoordOperate = 0x0202 ErrCoordLockFail = 0x0203 ErrCoordEncodeFail = 0x0204 ErrCoordDecodeFail = 0x0205 ErrCoordNothingToRemove = 0x0206 ErrCoordRequest = 0x0207 ErrCoordNoNode = 0x0208 // 03 - rocksdb related error ErrDBOperate = 0x0300 // 04 - network related error ErrNotConnected = 0x0400 ErrAlreadyConnected = 0x0401 ErrDialFailed = 0x0402 // 05 - config related error ErrConfigValueNotSet = 0x0500 // 10 - bootstrapping error ErrTopicNotExists = 0x1000 ErrTargetNotExists = 0x1001 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CoordConnectionError ¶
type CoordConnectionError struct {
Addrs []string
}
coordinating
func (CoordConnectionError) Code ¶
func (e CoordConnectionError) Code() QErrCode
func (CoordConnectionError) Error ¶
func (e CoordConnectionError) Error() string
type CoordDecodeFailError ¶
type CoordDecodeFailError struct{}
func (CoordDecodeFailError) Code ¶
func (e CoordDecodeFailError) Code() QErrCode
func (CoordDecodeFailError) Error ¶
func (e CoordDecodeFailError) Error() string
type CoordEncodeFailError ¶
type CoordEncodeFailError struct{}
func (CoordEncodeFailError) Code ¶
func (e CoordEncodeFailError) Code() QErrCode
func (CoordEncodeFailError) Error ¶
func (e CoordEncodeFailError) Error() string
type CoordLockFailError ¶
func (CoordLockFailError) Code ¶
func (e CoordLockFailError) Code() QErrCode
func (CoordLockFailError) Error ¶
func (e CoordLockFailError) Error() string
type CoordNoNodeError ¶
type CoordNoNodeError struct {
Path string
}
func (CoordNoNodeError) Code ¶
func (e CoordNoNodeError) Code() QErrCode
func (CoordNoNodeError) Error ¶
func (e CoordNoNodeError) Error() string
type CoordNothingToRemoveError ¶
type CoordNothingToRemoveError struct{}
func (CoordNothingToRemoveError) Code ¶
func (e CoordNothingToRemoveError) Code() QErrCode
func (CoordNothingToRemoveError) Error ¶
func (e CoordNothingToRemoveError) Error() string
type CoordOperateError ¶
type CoordOperateError struct {
ErrStr string
}
func (CoordOperateError) Code ¶
func (e CoordOperateError) Code() QErrCode
func (CoordOperateError) Error ¶
func (e CoordOperateError) Error() string
type CoordRequestError ¶
type CoordRequestError struct {
ErrStr string
}
func (CoordRequestError) Code ¶
func (e CoordRequestError) Code() QErrCode
func (CoordRequestError) Error ¶
func (e CoordRequestError) Error() string
type CoordTargetAlreadyExistsError ¶
type CoordTargetAlreadyExistsError struct {
Target string
}
func (CoordTargetAlreadyExistsError) Code ¶
func (e CoordTargetAlreadyExistsError) Code() QErrCode
func (CoordTargetAlreadyExistsError) Error ¶
func (e CoordTargetAlreadyExistsError) Error() string
type InvalidStateError ¶
type InvalidStateError struct {
State string
}
func (InvalidStateError) Code ¶
func (e InvalidStateError) Code() QErrCode
func (InvalidStateError) Error ¶
func (e InvalidStateError) Error() string
type TargetNotExistError ¶
type TargetNotExistError struct {
Target string
}
func (TargetNotExistError) Code ¶
func (e TargetNotExistError) Code() QErrCode
func (TargetNotExistError) Error ¶
func (e TargetNotExistError) Error() string
type TopicNotExistError ¶
type TopicNotExistError struct {
Topic string
}
bootstrapping
func (TopicNotExistError) Code ¶
func (e TopicNotExistError) Code() QErrCode
func (TopicNotExistError) Error ¶
func (e TopicNotExistError) Error() string
type ValidationError ¶
func (ValidationError) Code ¶
func (e ValidationError) Code() QErrCode
func (ValidationError) Error ¶
func (e ValidationError) Error() string
Click to show internal directories.
Click to hide internal directories.