Versions in this module Expand all Collapse all v0 v0.9.4 Apr 3, 2020 v0.9.3 Apr 1, 2020 v0.9.2 Feb 14, 2020 v0.9.0 Dec 19, 2018 Changes in this version + var CollectTrace = false + var EKAddress = errorx.RegisterPrintableProperty("address") + var EKArgPos = errorx.RegisterPrintableProperty("argpos") + var EKLine = errorx.RegisterProperty("line") + var EKMovedTo = errorx.RegisterProperty("movedto") + var EKRequest = errorx.RegisterPrintableProperty("request") + var EKRequests = errorx.RegisterPrintableProperty("requests") + var EKResponse = errorx.RegisterProperty("response") + var EKSlot = errorx.RegisterPrintableProperty("slot") + var EKVal = errorx.RegisterPrintableProperty("val") + var ErrArgumentType = ErrRequest.NewType("argument_type") + var ErrAsk = ErrResult.NewSubtype("ask", ErrTraitClusterMove) + var ErrBatchFormat = ErrRequest.NewType("batch_format") + var ErrCommandForbidden = ErrRequest.NewType("command_forbidden") + var ErrContextClosed = Errors.NewType("connection_context_closed", ErrTraitNotSent) + var ErrContextIsNil = ErrOpts.NewType("context_is_nil") + var ErrExecAbort = ErrResult.NewSubtype("exec_abort") + var ErrExecEmpty = ErrResult.NewSubtype("exec_empty") + var ErrHeaderlineEmpty = ErrResponse.NewType("headerline_empty") + var ErrHeaderlineTooLarge = ErrResponse.NewType("headerline_too_large") + var ErrIO = Errors.NewType("io error", ErrTraitConnectivity) + var ErrIntegerParsing = ErrResponse.NewType("integer_parsiing") + var ErrLoading = ErrResult.NewSubtype("loading", ErrTraitNotSent) + var ErrMoved = ErrResult.NewSubtype("moved", ErrTraitClusterMove) + var ErrNoAddressProvided = ErrOpts.NewType("no_address") + var ErrNoFinalRN = ErrResponse.NewType("no_final_rn") + var ErrNoSlotKey = ErrRequest.NewType("no_slot_key") + var ErrOpts = Errors.NewSubNamespace("opts") + var ErrPing = ErrResponse.NewType("ping") + var ErrRequest = Errors.NewSubNamespace("request") + var ErrRequestCancelled = ErrRequest.NewType("request_cancelled") + var ErrResponse = Errors.NewSubNamespace("response") + var ErrResponseFormat = ErrResponse.NewType("format") + var ErrResponseUnexpected = ErrResponse.NewType("unexpected") + var ErrResult = Errors.NewType("result") + var ErrTraitClusterMove = errorx.RegisterTrait("cluster_move") + var ErrTraitConnectivity = errorx.RegisterTrait("network") + var ErrTraitNotSent = errorx.RegisterTrait("request_not_sent") + var ErrTryAgain = ErrResult.NewSubtype("exec_try_again") + var ErrUnknownHeaderType = ErrResponse.NewType("unknown_headerline_type") + var Errors = errorx.NewNamespace("redispipe").ApplyModifiers(errorx.TypeModifierOmitStackTrace) + var ScanEOF = errors.New("Iteration finished") + func AppendRequest(buf []byte, req Request) ([]byte, error) + func ArgToString(arg interface{}) (string, bool) + func AsError(v interface{}) error + func AsErrorx(v interface{}) *errorx.Error + func Blocking(name string) bool + func CheckRequest(req Request, singleThreaded bool) error + func Dangerous(name string) bool + func ForbiddenCommand(name string, singleThreaded bool) error + func ReadResponse(b *bufio.Reader) interface + func ReplicaSafe(name string) bool + func ScanResponse(res interface{}) ([]byte, []string, error) + func TransactionResponse(res interface{}) ([]interface{}, error) + type ChanFuture struct + func (f *ChanFuture) Cancelled() error + func (f *ChanFuture) Done() <-chan struct{} + func (f *ChanFuture) Resolve(res interface{}, _ uint64) + func (f *ChanFuture) Value() interface{} + type ChanFutured struct + S Sender + func (s ChanFutured) Send(r Request) *ChanFuture + func (s ChanFutured) SendMany(reqs []Request) ChanFutures + func (s ChanFutured) SendTransaction(r []Request) *ChanTransaction + type ChanFutures []*ChanFuture + func (f ChanFutures) Cancelled() error + func (f ChanFutures) Resolve(res interface{}, i uint64) + type ChanTransaction struct + func (f *ChanTransaction) Results() ([]interface{}, error) + type FuncFuture func(res interface{}, n uint64) + func (f FuncFuture) Cancelled() error + func (f FuncFuture) Resolve(res interface{}, n uint64) + type Future interface + Cancelled func() error + Resolve func(res interface{}, n uint64) + type Request struct + Args []interface{} + Cmd string + func Req(cmd string, args ...interface{}) Request + func (r Request) Key() (string, bool) + func (r Request) String() string + type ScanOpts struct + Cmd string + Count int + Key string + Match string + func (s ScanOpts) Request(it []byte) Request + type Scanner interface + Next func(cb Future) + type ScannerBase struct + Err error + Iter []byte + func (s *ScannerBase) Cancelled() error + func (s *ScannerBase) DoNext(cb Future, snd Sender) + func (s *ScannerBase) IterLast() bool + func (s *ScannerBase) Resolve(res interface{}, _ uint64) + type Sender interface + Close func() + EachShard func(func(Sender, error) bool) + Scanner func(opts ScanOpts) Scanner + Send func(r Request, cb Future, n uint64) + SendMany func(r []Request, cb Future, n uint64) + SendTransaction func(r []Request, cb Future, n uint64) + type Sync struct + S Sender + func (s Sync) Do(cmd string, args ...interface{}) interface{} + func (s Sync) Scanner(opts ScanOpts) SyncIterator + func (s Sync) Send(r Request) interface{} + func (s Sync) SendMany(reqs []Request) []interface{} + func (s Sync) SendTransaction(reqs []Request) ([]interface{}, error) + type SyncCtx struct + S Sender + func (s SyncCtx) Do(ctx context.Context, cmd string, args ...interface{}) interface{} + func (s SyncCtx) Scanner(ctx context.Context, opts ScanOpts) SyncCtxIterator + func (s SyncCtx) Send(ctx context.Context, r Request) interface{} + func (s SyncCtx) SendMany(ctx context.Context, reqs []Request) []interface{} + func (s SyncCtx) SendTransaction(ctx context.Context, reqs []Request) ([]interface{}, error) + type SyncCtxIterator struct + func (s SyncCtxIterator) Next() ([]string, error) + type SyncIterator struct + func (s SyncIterator) Next() ([]string, error)