Versions in this module Expand all Collapse all v1 v1.4.1 Feb 27, 2023 Changes in this version + var ErrClosed = errors.New("client closed") + var ErrClosedPrematurely = errors.New("client closed before ready") + var ErrSkip = errors.New("Skiped") + var MigrationTimeout = 30 * time.Second + type Client struct + func NewClient() *Client + func (cli *Client) Close() + func (cli *Client) Connect(addr string) (err error) + func (cli *Client) GetStoreAdapter(store types.Storage) *StorageAdapter + func (cli *Client) Initiate(initiator func() error) error + func (cli *Client) IsReady() bool + func (cli *Client) Migrate(reader resp.ResponseReader, store types.Storage) + func (cli *Client) Ready() <-chan error + func (cli *Client) Send(cmd string, stream resp.AllReadCloser, args ...string) (resp.ResponseReader, error) + func (cli *Client) SetError(err error) + func (cli *Client) SetReady() + func (cli *Client) TriggerDestination(dest string, args interface{}) (err error) + func (cli *Client) WaitForMigration(srv *redeo.Server) + type StorageAdapter struct + func (a *StorageAdapter) Del(key string, reason string) *types.OpRet + func (a *StorageAdapter) Get(key string) (string, []byte, *types.OpRet) + func (a *StorageAdapter) GetStream(key string) (string, resp.AllReadCloser, *types.OpRet) + func (a *StorageAdapter) Keys() <-chan string + func (a *StorageAdapter) Len() int + func (a *StorageAdapter) LocalDel(key string) + func (a *StorageAdapter) Meta() types.StorageMeta + func (a *StorageAdapter) Migrate(key string) (string, *types.OpRet) + func (a *StorageAdapter) Restore() types.Storage + func (a *StorageAdapter) Set(key string, chunk string, val []byte) *types.OpRet + func (a *StorageAdapter) SetStream(key string, chunk string, valReader resp.AllReadCloser) *types.OpRet + func (s *StorageAdapter) Id() uint64
Go to main page