remoteapp

package
v1.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 20, 2023 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrIllegalArguments        = errors.New("illegal arguments")
	ErrMissingRemoteChunk      = errors.New("missing data on the remote storage")
	ErrInvalidLocalStorage     = errors.New("invalid local storage")
	ErrInvalidRemoteStorage    = errors.New("invalid remote storage")
	ErrInvalidChunkState       = errors.New("invalid chunk state")
	ErrChunkUploaded           = errors.New("already uploaded chunk is not writable")
	ErrCompressionNotSupported = errors.New("compression is currently not supported")
	ErrCantDownload            = errors.New("can not download chunk")
	ErrCorruptedMetadata       = errors.New("corrupted metadata in a remote chunk")
)

Functions

This section is empty.

Types

type Options

type Options struct {
	multiapp.Options
	// contains filtered or unexported fields
}

func DefaultOptions

func DefaultOptions() *Options

func (*Options) Valid

func (opts *Options) Valid() bool

func (*Options) WithParallelUploads

func (opts *Options) WithParallelUploads(parallelUploads int) *Options

func (*Options) WithRetryDelayExp

func (opts *Options) WithRetryDelayExp(retryDelayExp float64) *Options

func (*Options) WithRetryDelayJitter

func (opts *Options) WithRetryDelayJitter(retryDelayJitter float64) *Options

func (*Options) WithRetryMaxDelay

func (opts *Options) WithRetryMaxDelay(retryMaxDelay time.Duration) *Options

func (*Options) WithRetryMinDelay

func (opts *Options) WithRetryMinDelay(retryMinDelay time.Duration) *Options

type RemoteStorageAppendable

type RemoteStorageAppendable struct {
	*multiapp.MultiFileAppendable
	// contains filtered or unexported fields
}

func Open

func Open(path string, remotePath string, storage remotestorage.Storage, opts *Options) (*RemoteStorageAppendable, error)

func (*RemoteStorageAppendable) Close

func (r *RemoteStorageAppendable) Close() error

func (*RemoteStorageAppendable) OpenAppendable

func (r *RemoteStorageAppendable) OpenAppendable(options *singleapp.Options, appname string, activeChunk bool) (appendable.Appendable, error)

func (*RemoteStorageAppendable) OpenInitialAppendable

func (r *RemoteStorageAppendable) OpenInitialAppendable(opts *multiapp.Options, singleAppOpts *singleapp.Options) (appendable.Appendable, int64, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL