Add priority attribute to SyncWorkflowStateTask (#5819)

## What changed?
<!-- Describe what has changed in this PR -->
Add priority attribute to Replication Task and SyncWorkflowState task
## Why?
<!-- Tell your future self why have you made these changes -->
To distinguish priority on task priority on replication stack
## How did you test it?
<!-- How have you verified this change? Tested locally? Added a unit
test? Checked in staging env? -->
Unit test and integration test
## Potential risks
<!-- Assuming the worst case, what can be broken when deploying this
change to production? -->
Failed to serailize/deserailize. Current tests should be able to capture
it.
## Documentation
<!-- Have you made sure this change doesn't falsify anything currently
stated in `docs/`? If significant
new behavior is added, have you described that in `docs/`? -->
n/a
## Is hotfix candidate?
<!-- Is this PR a hotfix candidate or does it require a notification to
be sent to the broader community? (Yes/No) -->
no
This commit is contained in:
Will Duan
2024-05-01 12:13:46 -07:00
committed by GitHub
parent 7b4349976f
commit 4e6eb5899d
12 changed files with 1388 additions and 1174 deletions

View File

@@ -177,6 +177,43 @@ func (this *SyncReplicationState) Equal(that interface{}) bool {
return proto.Equal(this, that1)
}
// Marshal an object of type ReplicationState to the protobuf v3 wire format
func (val *ReplicationState) Marshal() ([]byte, error) {
return proto.Marshal(val)
}
// Unmarshal an object of type ReplicationState from the protobuf v3 wire format
func (val *ReplicationState) Unmarshal(buf []byte) error {
return proto.Unmarshal(buf, val)
}
// Size returns the size of the object, in bytes, once serialized
func (val *ReplicationState) Size() int {
return proto.Size(val)
}
// Equal returns whether two ReplicationState values are equivalent by recursively
// comparing the message's fields.
// For more information see the documentation for
// https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (this *ReplicationState) Equal(that interface{}) bool {
if that == nil {
return this == nil
}
var that1 *ReplicationState
switch t := that.(type) {
case *ReplicationState:
that1 = t
case ReplicationState:
that1 = &t
default:
return false
}
return proto.Equal(this, that1)
}
// Marshal an object of type ReplicationMessages to the protobuf v3 wire format
func (val *ReplicationMessages) Marshal() ([]byte, error) {
return proto.Marshal(val)

File diff suppressed because it is too large Load Diff