Documentation
¶
Index ¶
- Variables
- type 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
- 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 (s *StorageAdapter) Id() uint64
- 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
Constants ¶
This section is empty.
Variables ¶
View Source
var ( MigrationTimeout = 30 * time.Second ErrClosedPrematurely = errors.New("client closed before ready") ErrClosed = errors.New("client closed") )
View Source
var (
ErrSkip = errors.New("Skiped")
)
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func (*Client) GetStoreAdapter ¶
func (cli *Client) GetStoreAdapter(store types.Storage) *StorageAdapter
func (*Client) Migrate ¶
func (cli *Client) Migrate(reader resp.ResponseReader, store types.Storage)
func (*Client) Send ¶
func (cli *Client) Send(cmd string, stream resp.AllReadCloser, args ...string) (resp.ResponseReader, error)
func (*Client) TriggerDestination ¶
func (*Client) WaitForMigration ¶
type StorageAdapter ¶
type StorageAdapter struct {
// contains filtered or unexported fields
}
func (*StorageAdapter) GetStream ¶
func (a *StorageAdapter) GetStream(key string) (string, resp.AllReadCloser, *types.OpRet)
func (*StorageAdapter) Id ¶
func (s *StorageAdapter) Id() uint64
func (*StorageAdapter) Keys ¶
func (a *StorageAdapter) Keys() <-chan string
func (*StorageAdapter) Len ¶
func (a *StorageAdapter) Len() int
func (*StorageAdapter) LocalDel ¶
func (a *StorageAdapter) LocalDel(key string)
func (*StorageAdapter) Meta ¶
func (a *StorageAdapter) Meta() types.StorageMeta
func (*StorageAdapter) Migrate ¶
func (a *StorageAdapter) Migrate(key string) (string, *types.OpRet)
func (*StorageAdapter) Restore ¶
func (a *StorageAdapter) Restore() types.Storage
func (*StorageAdapter) SetStream ¶
func (a *StorageAdapter) SetStream(key string, chunk string, valReader resp.AllReadCloser) *types.OpRet
Source Files
Click to show internal directories.
Click to hide internal directories.