remoteapp

Documentation

Index

• Variables
• type Options
  • func DefaultOptions() *Options
  • func (opts *Options) Valid() bool
  • func (opts *Options) WithParallelUploads(parallelUploads int) *Options
  • func (opts *Options) WithRetryDelayExp(retryDelayExp float64) *Options
  • func (opts *Options) WithRetryDelayJitter(retryDelayJitter float64) *Options
  • func (opts *Options) WithRetryMaxDelay(retryMaxDelay time.Duration) *Options
  • func (opts *Options) WithRetryMinDelay(retryMinDelay time.Duration) *Options
• type RemoteStorageAppendable
  • func Open(path string, remotePath string, storage remotestorage.Storage, opts *Options) (*RemoteStorageAppendable, error)
  • func (r *RemoteStorageAppendable) Close() error
  • func (r *RemoteStorageAppendable) OpenAppendable(options *singleapp.Options, appname string, activeChunk bool) (appendable.Appendable, error)
  • func (r *RemoteStorageAppendable) OpenInitialAppendable(opts *multiapp.Options, singleAppOpts *singleapp.Options) (appendable.Appendable, int64, error)

Variables

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")
)

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)