Documentation
¶
Index ¶
- Constants
- func NewTask[T ...](ctx context.Context, payload T, opts ...Opt) (*asynq.Task, error)
- type BucketCreatePayload
- type BucketDeletePayload
- type BucketSyncACLPayload
- type BucketSyncTagsPayload
- type ConsistencyCheckDeletePayload
- type ConsistencyCheckListPayload
- type ConsistencyCheckPayload
- type ConsistencyCheckReadinessPayload
- type CostEstimationListPayload
- type CostEstimationPayload
- type MigrateBucketListObjectsPayload
- type MigrateLocation
- type MigrateObjCopyPayload
- type ObjInfo
- type ObjPayload
- type ObjSyncACLPayload
- type ObjSyncTagsPayload
- type ObjectSyncPayload
- type Opt
- type Priority
- type SwitchWithDowntimePayload
- type Sync
- type SyncTask
- type ZeroDowntimeReplicationSwitchPayload
Constants ¶
View Source
const ( TypeBucketCreate = "bucket:create" TypeBucketDelete = "bucket:delete" TypeBucketSyncTags = "bucket:sync:tags" TypeBucketSyncACL = "bucket:sync:acl" TypeObjectSync = "object:sync" TypeObjectSyncTags = "object:sync:tags" TypeObjectSyncACL = "object:sync:acl" TypeMigrateBucketListObjects = "migrate:bucket:list_objects" TypeMigrateObjCopy = "migrate:object:copy" TypeApiCostEstimation = "api:cost_estimation" TypeApiCostEstimationList = "api:cost_estimation:list" TypeConsistencyCheck = "consistency" TypeConsistencyCheckList = "consistency:list" TypeConsistencyCheckReadiness = "consistency:readiness" TypeConsistencyCheckResult = "consistency:result" TypeApiZeroDowntimeSwitch = "api:switch_zero_downtime" TypeApiSwitchWithDowntime = "api:switch_w_downtime" )
A list of task types.
View Source
const ( QueueEventsDefault1 = "events1" QueueEvents2 = "events2" QueueEvents3 = "events3" QueueEvents4 = "events4" QueueEventsHighest5 = "events5" QueueMigrateBucketListObjects = "migrate_bucket_list_obj" QueueMigrateObjCopyDefault1 = "migrate_obj_copy1" QueueMigrateObjCopy2 = "migrate_obj_copy2" QueueMigrateObjCopy3 = "migrate_obj_copy3" QueueMigrateObjCopy4 = "migrate_obj_copy4" QueueMigrateObjCopyHighest5 = "migrate_obj_copy5" QueueAPI = "api" QueueConsistencyCheck = "consistency_check" )
Variables ¶
This section is empty.
Functions ¶
func NewTask ¶
func NewTask[T BucketCreatePayload | BucketDeletePayload | BucketSyncTagsPayload | BucketSyncACLPayload | ObjectSyncPayload | ObjSyncTagsPayload | ObjSyncACLPayload | MigrateBucketListObjectsPayload | MigrateObjCopyPayload | CostEstimationPayload | CostEstimationListPayload | ZeroDowntimeReplicationSwitchPayload | SwitchWithDowntimePayload | ConsistencyCheckPayload | ConsistencyCheckListPayload | ConsistencyCheckReadinessPayload | ConsistencyCheckDeletePayload](ctx context.Context, payload T, opts ...Opt) (*asynq.Task, error)
Types ¶
type BucketCreatePayload ¶
type BucketDeletePayload ¶
type BucketSyncACLPayload ¶
type BucketSyncTagsPayload ¶
type ConsistencyCheckDeletePayload ¶ added in v0.5.14
type ConsistencyCheckDeletePayload struct {
ID string
}
type ConsistencyCheckListPayload ¶ added in v0.5.14
type ConsistencyCheckListPayload struct {
MigrateLocation
Prefix string
ID string
StorageCount uint8
}
type ConsistencyCheckPayload ¶ added in v0.5.14
type ConsistencyCheckPayload struct {
ID string
Locations []MigrateLocation
}
type ConsistencyCheckReadinessPayload ¶ added in v0.5.14
type ConsistencyCheckReadinessPayload struct {
ID string
}
type CostEstimationPayload ¶
type CostEstimationPayload struct {
Sync
}
type MigrateLocation ¶ added in v0.5.14
type MigrateObjCopyPayload ¶
type MigrateObjCopyPayload struct {
Sync
Bucket string
Obj ObjPayload
}
type ObjPayload ¶
type ObjSyncACLPayload ¶
type ObjSyncTagsPayload ¶
type ObjectSyncPayload ¶
type Priority ¶
type Priority uint8
func (Priority) ConsistencyCheckQueue ¶ added in v0.5.14
func (Priority) EventQueue ¶
func (Priority) MigrationQueue ¶
type SwitchWithDowntimePayload ¶ added in v0.5.14
type Sync ¶
func (*Sync) GetToBucket ¶ added in v0.5.13
func (*Sync) GetToStorage ¶ added in v0.5.13
type ZeroDowntimeReplicationSwitchPayload ¶ added in v0.5.14
Click to show internal directories.
Click to hide internal directories.