objcli

package

Go to main page

Versions in this module

v7

v7.3.3

Oct 21, 2025

v7.3.2

Sep 8, 2025

v7.3.1

Aug 13, 2025

v7.3.0

Aug 6, 2025

Changes in this version

type OperationPrecondition

+ const OperationPreconditionIfMatch

type PutObjectOptions

+ PreconditionData string

v7.2.1

Jul 21, 2025

v7.2.0

Jul 1, 2025

v7.1.1

Jun 30, 2025

v7.1.0

Jun 24, 2025

Changes in this version

type Client

+ DeleteObjectVersions func(ctx context.Context, opts DeleteObjectVersionsOptions) error

+ GetBucketLockingStatus func(ctx context.Context, opts GetBucketLockingStatusOptions) (*objval.BucketLockingStatus, error)

+ SetObjectLock func(ctx context.Context, opts SetObjectLockOptions) error

type CompleteMultipartUploadOptions

+ Lock *ObjectLock

+ Precondition OperationPrecondition

type CreateMultipartUploadOptions

+ Lock *ObjectLock

+ type DeleteObjectVersionsOptions struct

+ Bucket string

+ Versions []objval.ObjectVersion

+ type GetBucketLockingStatusOptions struct

+ Bucket string

type GetObjectAttrsOptions

+ VersionID string

type GetObjectOptions

+ VersionID string

type IterateObjectsOptions

+ Versions bool

type MockClient

+ func (_m *MockClient) DeleteObjectVersions(ctx context.Context, opts DeleteObjectVersionsOptions) error

+ func (_m *MockClient) GetBucketLockingStatus(ctx context.Context, opts GetBucketLockingStatusOptions) (*objval.BucketLockingStatus, error)

+ func (_m *MockClient) SetObjectLock(ctx context.Context, opts SetObjectLockOptions) error

+ type ObjectLock struct

+ Expiration time.Time

+ Type objval.LockType

+ func NewComplianceLock(expiration time.Time) *ObjectLock

+ type OperationPrecondition string

+ const OperationPreconditionOnlyIfAbsent

type PutObjectOptions

+ Lock *ObjectLock

+ Precondition OperationPrecondition

+ type SetObjectLockOptions struct

+ Bucket string

+ Key string

+ Lock *ObjectLock

+ VersionID string

type TestClient

+ TimeProvider timeprovider.TimeProvider

+ func (t *TestClient) DeleteObjectVersions(_ context.Context, opts DeleteObjectVersionsOptions) error

+ func (t *TestClient) GetBucketLockingStatus(_ context.Context, _ GetBucketLockingStatusOptions) (*objval.BucketLockingStatus, error)

+ func (t *TestClient) SetObjectLock(_ context.Context, opts SetObjectLockOptions) error

type UploadPartOptions

+ Lock *ObjectLock

+ Precondition OperationPrecondition

v7.0.0

Mar 20, 2025

Changes in this version

+ const NoPartNumber

+ const NoUploadID

+ var ErrExpectedNoUploadID = errors.New("received an unexpected upload id, cloud provider doesn't required upload ids")

+ var ErrIncludeAndExcludeAreMutuallyExclusive = errors.New("include/exclude are mutually exclusive")

+ func CopyReadSeeker(dst io.Writer, src io.ReadSeeker) (int64, error)

+ func SeekerLength(seeker io.Seeker) (int64, error)

+ func ShouldIgnore(query string, include, exclude []*regexp.Regexp) bool

+ func TestDownloadJSON(t *testing.T, client Client, key string, data any)

+ func TestDownloadRAW(t *testing.T, client Client, key string) []byte

+ func TestListObjects(t *testing.T, client Client, prefix string) []*objval.ObjectAttrs

+ func TestRequireKeyExists(t *testing.T, client Client, key string)

+ func TestRequireKeyNotFound(t *testing.T, client Client, key string)

+ func TestUploadJSON(t *testing.T, client Client, key string, body any)

+ func TestUploadRAW(t *testing.T, client Client, key string, body []byte)

+ type AbortMultipartUploadOptions struct

+ Bucket string

+ Key string

+ UploadID string

+ type AppendToObjectOptions struct

+ Body io.ReadSeeker

+ Bucket string

+ Key string

+ type Client interface

+ AbortMultipartUpload func(ctx context.Context, opts AbortMultipartUploadOptions) error

+ AppendToObject func(ctx context.Context, opts AppendToObjectOptions) error

+ Close func() error

+ CompleteMultipartUpload func(ctx context.Context, opts CompleteMultipartUploadOptions) error

+ CopyObject func(ctx context.Context, opts CopyObjectOptions) error

+ CreateMultipartUpload func(ctx context.Context, opts CreateMultipartUploadOptions) (string, error)

+ DeleteDirectory func(ctx context.Context, opts DeleteDirectoryOptions) error

+ DeleteObjects func(ctx context.Context, opts DeleteObjectsOptions) error

+ GetObject func(ctx context.Context, opts GetObjectOptions) (*objval.Object, error)

+ GetObjectAttrs func(ctx context.Context, opts GetObjectAttrsOptions) (*objval.ObjectAttrs, error)

+ IterateObjects func(ctx context.Context, opts IterateObjectsOptions) error

+ ListParts func(ctx context.Context, opts ListPartsOptions) ([]objval.Part, error)

+ Provider func() objval.Provider

+ PutObject func(ctx context.Context, opts PutObjectOptions) error

+ UploadPart func(ctx context.Context, opts UploadPartOptions) (objval.Part, error)

+ UploadPartCopy func(ctx context.Context, opts UploadPartCopyOptions) (objval.Part, error)

+ type CompleteMultipartUploadOptions struct

+ Bucket string

+ Key string

+ Parts []objval.Part

+ UploadID string

+ type CopyObjectOptions struct

+ DestinationBucket string

+ DestinationKey string

+ SourceBucket string

+ SourceKey string

+ type CreateMultipartUploadOptions struct

+ Bucket string

+ Key string

+ type DeleteDirectoryOptions struct

+ Bucket string

+ Prefix string

+ Versions bool

+ type DeleteObjectsOptions struct

+ Bucket string

+ Keys []string

+ type GetObjectAttrsOptions struct

+ Bucket string

+ Key string

+ type GetObjectOptions struct

+ Bucket string

+ ByteRange *objval.ByteRange

+ Key string

+ type IterateFunc func(attrs *objval.ObjectAttrs) error

+ type IterateObjectsOptions struct

+ Bucket string

+ Delimiter string

+ Exclude []*regexp.Regexp

+ Func IterateFunc

+ Include []*regexp.Regexp

+ Prefix string

+ type ListPartsOptions struct

+ Bucket string

+ Key string

+ UploadID string

+ type MockClient struct

+ func NewMockClient(t interface{ ... }) *MockClient

+ func (_m *MockClient) AbortMultipartUpload(ctx context.Context, opts AbortMultipartUploadOptions) error

+ func (_m *MockClient) AppendToObject(ctx context.Context, opts AppendToObjectOptions) error

+ func (_m *MockClient) Close() error

+ func (_m *MockClient) CompleteMultipartUpload(ctx context.Context, opts CompleteMultipartUploadOptions) error

+ func (_m *MockClient) CopyObject(ctx context.Context, opts CopyObjectOptions) error

+ func (_m *MockClient) CreateMultipartUpload(ctx context.Context, opts CreateMultipartUploadOptions) (string, error)

+ func (_m *MockClient) DeleteDirectory(ctx context.Context, opts DeleteDirectoryOptions) error

+ func (_m *MockClient) DeleteObjects(ctx context.Context, opts DeleteObjectsOptions) error

+ func (_m *MockClient) GetObject(ctx context.Context, opts GetObjectOptions) (*objval.Object, error)

+ func (_m *MockClient) GetObjectAttrs(ctx context.Context, opts GetObjectAttrsOptions) (*objval.ObjectAttrs, error)

+ func (_m *MockClient) IterateObjects(ctx context.Context, opts IterateObjectsOptions) error

+ func (_m *MockClient) ListParts(ctx context.Context, opts ListPartsOptions) ([]objval.Part, error)

+ func (_m *MockClient) Provider() objval.Provider

+ func (_m *MockClient) PutObject(ctx context.Context, opts PutObjectOptions) error

+ func (_m *MockClient) UploadPart(ctx context.Context, opts UploadPartOptions) (objval.Part, error)

+ func (_m *MockClient) UploadPartCopy(ctx context.Context, opts UploadPartCopyOptions) (objval.Part, error)

+ type PutObjectOptions struct

+ Body io.ReadSeeker

+ Bucket string

+ Key string

+ type RateLimitedClient struct

+ func NewRateLimitedClient(c Client, rl *rate.Limiter) *RateLimitedClient

+ func (r *RateLimitedClient) AbortMultipartUpload(ctx context.Context, opts AbortMultipartUploadOptions) error

+ func (r *RateLimitedClient) AppendToObject(ctx context.Context, opts AppendToObjectOptions) error

+ func (r *RateLimitedClient) CompleteMultipartUpload(ctx context.Context, opts CompleteMultipartUploadOptions) error

+ func (r *RateLimitedClient) CreateMultipartUpload(ctx context.Context, opts CreateMultipartUploadOptions) (string, error)

+ func (r *RateLimitedClient) DeleteDirectory(ctx context.Context, opts DeleteDirectoryOptions) error

+ func (r *RateLimitedClient) DeleteObjects(ctx context.Context, opts DeleteObjectsOptions) error

+ func (r *RateLimitedClient) GetObject(ctx context.Context, opts GetObjectOptions) (*objval.Object, error)

+ func (r *RateLimitedClient) GetObjectAttrs(ctx context.Context, opts GetObjectAttrsOptions) (*objval.ObjectAttrs, error)

+ func (r *RateLimitedClient) IterateObjects(ctx context.Context, opts IterateObjectsOptions) error

+ func (r *RateLimitedClient) ListParts(ctx context.Context, opts ListPartsOptions) ([]objval.Part, error)

+ func (r *RateLimitedClient) Provider() objval.Provider

+ func (r *RateLimitedClient) PutObject(ctx context.Context, opts PutObjectOptions) error

+ func (r *RateLimitedClient) UploadPart(ctx context.Context, opts UploadPartOptions) (objval.Part, error)

+ func (r *RateLimitedClient) UploadPartCopy(ctx context.Context, opts UploadPartCopyOptions) (objval.Part, error)

+ type TestClient struct

+ Buckets objval.TestBuckets

+ func NewTestClient(t *testing.T, provider objval.Provider) *TestClient

+ func (t *TestClient) AbortMultipartUpload(_ context.Context, opts AbortMultipartUploadOptions) error

+ func (t *TestClient) AppendToObject(_ context.Context, opts AppendToObjectOptions) error

+ func (t *TestClient) Close() error

+ func (t *TestClient) CompleteMultipartUpload(_ context.Context, opts CompleteMultipartUploadOptions) error

+ func (t *TestClient) CopyObject(_ context.Context, opts CopyObjectOptions) error

+ func (t *TestClient) CreateMultipartUpload(_ context.Context, _ CreateMultipartUploadOptions) (string, error)

+ func (t *TestClient) DeleteDirectory(_ context.Context, opts DeleteDirectoryOptions) error

+ func (t *TestClient) DeleteObjects(_ context.Context, opts DeleteObjectsOptions) error

+ func (t *TestClient) GetObject(_ context.Context, opts GetObjectOptions) (*objval.Object, error)

+ func (t *TestClient) GetObjectAttrs(_ context.Context, opts GetObjectAttrsOptions) (*objval.ObjectAttrs, error)

+ func (t *TestClient) IterateObjects(_ context.Context, opts IterateObjectsOptions) error

+ func (t *TestClient) ListParts(ctx context.Context, opts ListPartsOptions) ([]objval.Part, error)

+ func (t *TestClient) Provider() objval.Provider

+ func (t *TestClient) PutObject(_ context.Context, opts PutObjectOptions) error

+ func (t *TestClient) UploadPart(_ context.Context, opts UploadPartOptions) (objval.Part, error)

+ func (t *TestClient) UploadPartCopy(_ context.Context, opts UploadPartCopyOptions) (objval.Part, error)

+ type UploadPartCopyOptions struct

+ ByteRange *objval.ByteRange

+ DestinationBucket string

+ DestinationKey string

+ Number int

+ SourceBucket string

+ SourceKey string

+ UploadID string

+ type UploadPartOptions struct

+ Body io.ReadSeeker

+ Bucket string

+ Key string

+ Number int

+ UploadID string

Other modules containing this package

github.com/couchbase/tools-common/cloud

github.com/couchbase/tools-common/cloud/v2

github.com/couchbase/tools-common/cloud/v3

github.com/couchbase/tools-common/cloud/v4

github.com/couchbase/tools-common/cloud/v5

github.com/couchbase/tools-common/cloud/v6

github.com/couchbase/tools-common/cloud/v8

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