bucket

Documentation

Index

• type ACLHeader
• type ACLHeaders
• type Bucket
  • func New(ctx context.Context, bucket, region string, iam *sdkiam.Client, ...) Bucket
• type WalkFunc

Types

type ACLHeader

type ACLHeader uint8

const (
	ACLHeaderNone ACLHeader = iota
	ACLHeaderFullControl
	ACLHeaderWrite
	ACLHeaderRead
	ACLHeaderWriteACP
	ACLHeaderReadACP
)

type ACLHeaders

type ACLHeaders map[ACLHeader]string

type Bucket

type Bucket interface {
	Check() liberr.Error

	List() ([]sdkstp.Bucket, liberr.Error)
	Walk(f WalkFunc) liberr.Error
	Create(RegionConstraint string) liberr.Error
	CreateWithLock(RegionConstraint string) liberr.Error
	Delete() liberr.Error

	SetVersioning(state bool) liberr.Error
	GetVersioning() (string, liberr.Error)

	LoadReplication() (*sdkstp.ReplicationConfiguration, liberr.Error)
	EnableReplication(srcRoleARN, dstRoleARN, dstBucketName string) liberr.Error
	DeleteReplication() liberr.Error

	PutWebsite(index, error string) liberr.Error
	GetWebsite() (*sdksss.GetBucketWebsiteOutput, liberr.Error)

	SetCORS(cors []sdkstp.CORSRule) liberr.Error
	GetCORS() ([]sdkstp.CORSRule, liberr.Error)

	GetACL() (*sdkstp.AccessControlPolicy, liberr.Error)
	SetACL(ACP *sdkstp.AccessControlPolicy, cannedACL sdkstp.BucketCannedACL, header ACLHeaders) liberr.Error
	SetACLPolicy(ACP *sdkstp.AccessControlPolicy) liberr.Error
	SetACLHeader(cannedACL sdkstp.BucketCannedACL, header ACLHeaders) liberr.Error

	GetLifeCycle() ([]sdkstp.LifecycleRule, liberr.Error)
	SetLifeCycle(rules ...sdkstp.LifecycleRule) liberr.Error
	GetLock() (*sdkstp.ObjectLockConfiguration, liberr.Error)
	SetLock(cfg sdkstp.ObjectLockConfiguration, token string) liberr.Error
}

func New

func New(ctx context.Context, bucket, region string, iam *sdkiam.Client, s3 *sdksss.Client) Bucket

type WalkFunc

type WalkFunc func(err liberr.Error, bucket sdkstp.Bucket) liberr.Error