Documentation
¶
Index ¶
- func GetBucket(ctx context.Context) string
- func GetInProgressZeroDowntime(ctx context.Context) *entity.ReplicationSwitchInfo
- func GetMethod(ctx context.Context) s3.Method
- func GetObject(ctx context.Context) string
- func GetReplications(ctx context.Context) []entity.UniversalReplicationID
- func GetRoutingPolicy(ctx context.Context) string
- func GetStorage(ctx context.Context) string
- func GetTraceID(ctx context.Context) string
- func GetUser(ctx context.Context) string
- func SetBucket(ctx context.Context, in string) context.Context
- func SetFlow(ctx context.Context, in Flow) context.Context
- func SetInProgressZeroDowntime(ctx context.Context, r entity.ReplicationSwitchInfo) context.Context
- func SetMethod(ctx context.Context, in s3.Method) context.Context
- func SetObject(ctx context.Context, in string) context.Context
- func SetReplications(ctx context.Context, r []entity.UniversalReplicationID) context.Context
- func SetRoutingPolicy(ctx context.Context, p string) context.Context
- func SetStorage(ctx context.Context, in string) context.Context
- func SetTraceID(ctx context.Context, in string) context.Context
- func SetUser(ctx context.Context, u string) context.Context
- type Flow
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetInProgressZeroDowntime ¶ added in v0.6.0
func GetInProgressZeroDowntime(ctx context.Context) *entity.ReplicationSwitchInfo
func GetReplications ¶ added in v0.6.0
func GetReplications(ctx context.Context) []entity.UniversalReplicationID
func GetRoutingPolicy ¶ added in v0.6.0
func GetStorage ¶
func GetTraceID ¶
func SetInProgressZeroDowntime ¶ added in v0.6.0
func SetReplications ¶ added in v0.6.0
func SetRoutingPolicy ¶ added in v0.6.0
Types ¶
Click to show internal directories.
Click to hide internal directories.