Documentation ¶
Index ¶
- func NewQueueProxy(session types.QueueSessionUpdater) (types.QueueDriver, error)
- func NewQueueProxyWithDriverInstance(session types.QueueSessionUpdater, q types.QueueDriver) types.QueueDriver
- func NewStorageProxy(session types.StorageSessionUpdater) (types.StorageDriver, error)
- func NewStorageProxyWithDriverInstance(session types.StorageSessionUpdater, s types.StorageDriver) types.StorageDriver
- type LocalFileSystem
- type QueueProxy
- func (q *QueueProxy) ChangeMessageVisibility(msg types.ChangeVisibilityMessage, second int32) error
- func (q *QueueProxy) DeleteMessage(msg types.DeletableMessage) error
- func (q *QueueProxy) GetConfig() *types.QueueConfig
- func (q *QueueProxy) GetMessage(num int) ([]types.Message, error)
- func (q *QueueProxy) GetMessageLength() ([]string, error)
- func (q *QueueProxy) PutMessage(raw []byte, delay int32) error
- func (q *QueueProxy) Update()
- type StorageProxy
- func (d *StorageProxy) Download(bucket string, key string, dist string) error
- func (d *StorageProxy) Get(root string, path string) ([]byte, error)
- func (d *StorageProxy) GetByStream(bucket string, key string) (io.ReadCloser, error)
- func (d *StorageProxy) GetConfig() *types.StorageConfig
- func (d *StorageProxy) List(bucket string, prefix string) (list []string, err error, next func() ([]string, error))
- func (d *StorageProxy) Put(root string, path string, raw []byte) error
- func (d *StorageProxy) Update()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewQueueProxy ¶
func NewQueueProxy(session types.QueueSessionUpdater) (types.QueueDriver, error)
func NewQueueProxyWithDriverInstance ¶ added in v1.1.0
func NewQueueProxyWithDriverInstance(session types.QueueSessionUpdater, q types.QueueDriver) types.QueueDriver
func NewStorageProxy ¶
func NewStorageProxy(session types.StorageSessionUpdater) (types.StorageDriver, error)
func NewStorageProxyWithDriverInstance ¶ added in v1.1.0
func NewStorageProxyWithDriverInstance(session types.StorageSessionUpdater, s types.StorageDriver) types.StorageDriver
Types ¶
type LocalFileSystem ¶
type LocalFileSystem struct { }
type QueueProxy ¶
type QueueProxy struct {
// contains filtered or unexported fields
}
func (*QueueProxy) ChangeMessageVisibility ¶
func (q *QueueProxy) ChangeMessageVisibility(msg types.ChangeVisibilityMessage, second int32) error
func (*QueueProxy) DeleteMessage ¶
func (q *QueueProxy) DeleteMessage(msg types.DeletableMessage) error
func (*QueueProxy) GetConfig ¶ added in v1.1.0
func (q *QueueProxy) GetConfig() *types.QueueConfig
func (*QueueProxy) GetMessage ¶
func (q *QueueProxy) GetMessage(num int) ([]types.Message, error)
func (*QueueProxy) GetMessageLength ¶ added in v1.2.12
func (q *QueueProxy) GetMessageLength() ([]string, error)
func (*QueueProxy) PutMessage ¶
func (q *QueueProxy) PutMessage(raw []byte, delay int32) error
func (*QueueProxy) Update ¶
func (q *QueueProxy) Update()
type StorageProxy ¶
type StorageProxy struct {
// contains filtered or unexported fields
}
func (*StorageProxy) Download ¶ added in v1.5.1
func (d *StorageProxy) Download(bucket string, key string, dist string) error
func (*StorageProxy) GetByStream ¶ added in v1.5.3
func (d *StorageProxy) GetByStream(bucket string, key string) (io.ReadCloser, error)
func (*StorageProxy) GetConfig ¶ added in v1.1.0
func (d *StorageProxy) GetConfig() *types.StorageConfig
func (*StorageProxy) Update ¶
func (d *StorageProxy) Update()
Click to show internal directories.
Click to hide internal directories.