objstore

Documentation

Index

• type Multi
  • func New(periodicConfigs []config.PeriodConfig, storageConfig storage.Config, ...) (*Multi, error)
  • func NewTestStorage(t testing.TB) (*Multi, error)
  • func (m *Multi) DeleteObject(ctx context.Context, objectKey string) error
  • func (m *Multi) GetAttributes(ctx context.Context, objectKey string) (client.ObjectAttributes, error)
  • func (m *Multi) GetObject(ctx context.Context, objectKey string) (io.ReadCloser, int64, error)
  • func (m *Multi) GetObjectRange(ctx context.Context, objectKey string, off, length int64) (io.ReadCloser, error)
  • func (m *Multi) GetStoreFor(ts model.Time) (client.ObjectClient, error)
  • func (m *Multi) IsObjectNotFoundErr(err error) bool
  • func (m *Multi) IsRetryableErr(err error) bool
  • func (m *Multi) List(ctx context.Context, prefix string, delimiter string) ([]client.StorageObject, []client.StorageCommonPrefix, error)
  • func (m *Multi) ObjectExists(ctx context.Context, objectKey string) (bool, error)
  • func (m *Multi) PutObject(ctx context.Context, objectKey string, object io.Reader) error
  • func (m *Multi) Stop()

Types

type Multi

type Multi struct {
	// contains filtered or unexported fields
}

func New

func New(
	periodicConfigs []config.PeriodConfig,
	storageConfig storage.Config,
	clientMetrics storage.ClientMetrics,
) (*Multi, error)

func NewTestStorage

func NewTestStorage(t testing.TB) (*Multi, error)

func (*Multi) DeleteObject

func (m *Multi) DeleteObject(ctx context.Context, objectKey string) error

func (*Multi) GetAttributes

func (m *Multi) GetAttributes(ctx context.Context, objectKey string) (client.ObjectAttributes, error)

func (*Multi) GetObject

func (m *Multi) GetObject(ctx context.Context, objectKey string) (io.ReadCloser, int64, error)

func (*Multi) GetObjectRange

func (m *Multi) GetObjectRange(ctx context.Context, objectKey string, off, length int64) (io.ReadCloser, error)

func (*Multi) GetStoreFor

func (m *Multi) GetStoreFor(ts model.Time) (client.ObjectClient, error)

func (*Multi) IsObjectNotFoundErr

func (m *Multi) IsObjectNotFoundErr(err error) bool

func (*Multi) IsRetryableErr

func (m *Multi) IsRetryableErr(err error) bool

func (*Multi) List

func (m *Multi) List(ctx context.Context, prefix string, delimiter string) ([]client.StorageObject, []client.StorageCommonPrefix, error)

func (*Multi) ObjectExists

func (m *Multi) ObjectExists(ctx context.Context, objectKey string) (bool, error)

func (*Multi) PutObject

func (m *Multi) PutObject(ctx context.Context, objectKey string, object io.Reader) error

func (*Multi) Stop

func (m *Multi) Stop()