policy

package

Go to main page

Versions in this module

v0

v0.5.13

Jan 21, 2025

Changes in this version

+ type ReplicationPolicyDest string

+ func (d ReplicationPolicyDest) Parse() (storage string, bucket *string)

type ReplicationPolicyStatusExtended

+ ToBucket *string

v0.5.12

Nov 28, 2024

v0.5.11

Nov 19, 2024

v0.5.10

Nov 18, 2024

v0.5.9

Nov 15, 2024

v0.5.8

Oct 29, 2024

v0.5.7

Aug 26, 2024

v0.5.6

Jun 11, 2024

v0.5.5

Jun 10, 2024

v0.5.4

Jun 5, 2024

v0.5.3

Apr 30, 2024

v0.5.2

Feb 6, 2024

Changes in this version

type ReplicationPolicyStatus

+ SwitchStatus SwitchStatus

type ReplicationSwitch

+ func (r *ReplicationSwitch) SetOldFollowers(f map[string]tasks.Priority)

type Service

+ DoReplicationSwitch func(ctx context.Context, user, bucket, newMain string) error

+ ReplicationSwitchDone func(ctx context.Context, user, bucket string) error

+ type SwitchStatus int

+ const Done

+ const InProgress

+ const NotStarted

v0.5.1

Jan 31, 2024

v0.5.0

Jan 18, 2024

Changes in this version

+ type ReplicationPolicies struct

+ From string

+ To map[string]tasks.Priority

+ type ReplicationPolicyStatus struct

+ AgentURL string

+ CreatedAt time.Time

+ Events int64

+ EventsDone int64

+ InitBytesDone int64

+ InitBytesListed int64

+ InitDoneAt *time.Time

+ InitObjDone int64

+ InitObjListed int64

+ IsPaused bool

+ LastEmittedAt *time.Time

+ LastProcessedAt *time.Time

+ ListingStarted bool

+ type ReplicationPolicyStatusExtended struct

+ Bucket string

+ From string

+ To string

+ User string

+ type ReplicationSwitch struct

+ DoneAt time.Time

+ IsDone bool

+ MultipartTTL time.Duration

+ OldFollowers string

+ OldMain string

+ StartedAt time.Time

+ func (r ReplicationSwitch) GetOldFollowers() map[string]tasks.Priority

+ type Service interface

+ AddBucketReplicationPolicy func(ctx context.Context, user, bucket, from string, to string, ...) error

+ AddUserReplicationPolicy func(ctx context.Context, user string, from string, to string, ...) error

+ AddUserRoutingPolicy func(ctx context.Context, user, toStorage string) error

+ DeleteBucketReplicationsByUser func(ctx context.Context, user, from string, to string) ([]string, error)

+ DeleteReplication func(ctx context.Context, user, bucket, from string, to string) error

+ DeleteUserReplication func(ctx context.Context, user string, from string, to string) error

+ GetBucketReplicationPolicies func(ctx context.Context, user, bucket string) (ReplicationPolicies, error)

+ GetReplicationPolicyInfo func(ctx context.Context, user, bucket, from, to string) (ReplicationPolicyStatus, error)

+ GetReplicationSwitch func(ctx context.Context, user, bucket string) (ReplicationSwitch, error)

+ GetRoutingPolicy func(ctx context.Context, user, bucket string) (string, error)

+ GetUserReplicationPolicies func(ctx context.Context, user string) (ReplicationPolicies, error)

+ GetUserRoutingPolicy func(ctx context.Context, user string) (string, error)

+ IncReplEvents func(ctx context.Context, user, bucket, from, to string, eventTime time.Time) error

+ IncReplEventsDone func(ctx context.Context, user, bucket, from, to string, eventTime time.Time) error

+ IncReplInitObjDone func(ctx context.Context, user, bucket, from, to string, bytes int64, ...) error

+ IncReplInitObjListed func(ctx context.Context, user, bucket, from, to string, bytes int64, ...) error

+ IsReplicationPolicyExists func(ctx context.Context, user, bucket, from, to string) (bool, error)

+ IsReplicationPolicyPaused func(ctx context.Context, user, bucket, from, to string) (bool, error)

+ IsReplicationSwitchInProgress func(ctx context.Context, user, bucket string) (bool, error)

+ ListReplicationPolicyInfo func(ctx context.Context) ([]ReplicationPolicyStatusExtended, error)

+ ObjListStarted func(ctx context.Context, user, bucket, from, to string) error

+ PauseReplication func(ctx context.Context, user, bucket, from string, to string) error

+ ResumeReplication func(ctx context.Context, user, bucket, from string, to string) error

+ func NewService(client *redis.Client) Service

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