errors

Documentation

Index

• Variables
• func ErrMaxConcurrentQueriesLimitExceeded(n, limit int) error

Variables

var (
	// ErrInvalidQuery is returned when executing an unknown query type.
	ErrInvalidQuery = errors.New("invalid query")

	// ErrNotExecuted is returned when a statement is not executed in a query.
	// This can occur when a previous statement in the same query has errored.
	ErrNotExecuted = errors.New("not executed")

	// ErrQueryInterrupted is an error returned when the query is interrupted.
	ErrQueryInterrupted = errors.New("query interrupted")

	// ErrQueryAborted is an error returned when the query is aborted.
	ErrQueryAborted = errors.New("query aborted")

	// ErrQueryEngineShutdown is an error sent when the query cannot be
	// created because the query engine was shutdown.
	ErrQueryEngineShutdown = errors.New("query engine shutdown")

	// ErrQueryTimeoutLimitExceeded is an error when the query hits the max time allowed to run.
	ErrQueryTimeoutLimitExceeded = errors.New("query timeout limit exceeded")

	// ErrNoClientAddresses is an error when there are no addresses passed to the remote client
	ErrNoClientAddresses = errors.New("no client addresses given")
)

var (
	// ErrNilWriteQuery is returned when trying to write a nil query
	ErrNilWriteQuery = errors.New("nil write query")

	// ErrNotImplemented is returned when the storage endpoint is not implemented
	ErrNotImplemented = errors.New("not implemented")

	// ErrInvalidFetchResponse is returned when fetch fails from storage.
	ErrInvalidFetchResponse = errors.New("invalid response from fetch")

	// ErrFetchResponseOrder is returned fetch responses are not in order.
	ErrFetchResponseOrder = errors.New("responses out of order for fetch")

	// ErrFetchRequestType is an error returned when response from fetch has invalid type.
	ErrFetchRequestType = errors.New("invalid request type")

	// ErrInvalidFetchResult is an error returned when fetch result is invalid.
	ErrInvalidFetchResult = errors.New("invalid fetch result")
)

Functions

func ErrMaxConcurrentQueriesLimitExceeded

func ErrMaxConcurrentQueriesLimitExceeded(n, limit int) error

ErrMaxConcurrentQueriesLimitExceeded is an error when the query cannot be run because the maximum number of queries has been reached.