mirror of
https://github.com/hanzoai/tasks.git
synced 2026-11-03 03:56:04 +00:00
## What changed? - [[Nexus-Chasm] Improve nexus operation dynamic config](https://github.com/temporalio/temporal/commit/59a7068417085b199a7d65efa0d02f6b117be6bc) - [[Nexus-Chasm] Improve operation state machine and task handlers](https://github.com/temporalio/temporal/commit/c6f1fa83b285c87dba92fdb7970aa695476cb277) - [[Nexus-Chasm] Refactor workflow registry and nexus workflow integration](https://github.com/temporalio/temporal/commit/45d0cfca84a1e3b0669e6994a27198de7bff4a33) ## Why? - Cleanup - Improved test coverage - Bug fixes
266 lines
7.4 KiB
Go
266 lines
7.4 KiB
Go
// Code generated by protoc-gen-go-helpers. DO NOT EDIT.
|
|
package nexusoperationpb
|
|
|
|
import (
|
|
"google.golang.org/protobuf/proto"
|
|
)
|
|
|
|
// Marshal an object of type ScheduleToStartTimeoutTask to the protobuf v3 wire format
|
|
func (val *ScheduleToStartTimeoutTask) Marshal() ([]byte, error) {
|
|
return proto.Marshal(val)
|
|
}
|
|
|
|
// Unmarshal an object of type ScheduleToStartTimeoutTask from the protobuf v3 wire format
|
|
func (val *ScheduleToStartTimeoutTask) Unmarshal(buf []byte) error {
|
|
return proto.Unmarshal(buf, val)
|
|
}
|
|
|
|
// Size returns the size of the object, in bytes, once serialized
|
|
func (val *ScheduleToStartTimeoutTask) Size() int {
|
|
return proto.Size(val)
|
|
}
|
|
|
|
// Equal returns whether two ScheduleToStartTimeoutTask 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 *ScheduleToStartTimeoutTask) Equal(that interface{}) bool {
|
|
if that == nil {
|
|
return this == nil
|
|
}
|
|
|
|
var that1 *ScheduleToStartTimeoutTask
|
|
switch t := that.(type) {
|
|
case *ScheduleToStartTimeoutTask:
|
|
that1 = t
|
|
case ScheduleToStartTimeoutTask:
|
|
that1 = &t
|
|
default:
|
|
return false
|
|
}
|
|
|
|
return proto.Equal(this, that1)
|
|
}
|
|
|
|
// Marshal an object of type StartToCloseTimeoutTask to the protobuf v3 wire format
|
|
func (val *StartToCloseTimeoutTask) Marshal() ([]byte, error) {
|
|
return proto.Marshal(val)
|
|
}
|
|
|
|
// Unmarshal an object of type StartToCloseTimeoutTask from the protobuf v3 wire format
|
|
func (val *StartToCloseTimeoutTask) Unmarshal(buf []byte) error {
|
|
return proto.Unmarshal(buf, val)
|
|
}
|
|
|
|
// Size returns the size of the object, in bytes, once serialized
|
|
func (val *StartToCloseTimeoutTask) Size() int {
|
|
return proto.Size(val)
|
|
}
|
|
|
|
// Equal returns whether two StartToCloseTimeoutTask 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 *StartToCloseTimeoutTask) Equal(that interface{}) bool {
|
|
if that == nil {
|
|
return this == nil
|
|
}
|
|
|
|
var that1 *StartToCloseTimeoutTask
|
|
switch t := that.(type) {
|
|
case *StartToCloseTimeoutTask:
|
|
that1 = t
|
|
case StartToCloseTimeoutTask:
|
|
that1 = &t
|
|
default:
|
|
return false
|
|
}
|
|
|
|
return proto.Equal(this, that1)
|
|
}
|
|
|
|
// Marshal an object of type ScheduleToCloseTimeoutTask to the protobuf v3 wire format
|
|
func (val *ScheduleToCloseTimeoutTask) Marshal() ([]byte, error) {
|
|
return proto.Marshal(val)
|
|
}
|
|
|
|
// Unmarshal an object of type ScheduleToCloseTimeoutTask from the protobuf v3 wire format
|
|
func (val *ScheduleToCloseTimeoutTask) Unmarshal(buf []byte) error {
|
|
return proto.Unmarshal(buf, val)
|
|
}
|
|
|
|
// Size returns the size of the object, in bytes, once serialized
|
|
func (val *ScheduleToCloseTimeoutTask) Size() int {
|
|
return proto.Size(val)
|
|
}
|
|
|
|
// Equal returns whether two ScheduleToCloseTimeoutTask 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 *ScheduleToCloseTimeoutTask) Equal(that interface{}) bool {
|
|
if that == nil {
|
|
return this == nil
|
|
}
|
|
|
|
var that1 *ScheduleToCloseTimeoutTask
|
|
switch t := that.(type) {
|
|
case *ScheduleToCloseTimeoutTask:
|
|
that1 = t
|
|
case ScheduleToCloseTimeoutTask:
|
|
that1 = &t
|
|
default:
|
|
return false
|
|
}
|
|
|
|
return proto.Equal(this, that1)
|
|
}
|
|
|
|
// Marshal an object of type InvocationTask to the protobuf v3 wire format
|
|
func (val *InvocationTask) Marshal() ([]byte, error) {
|
|
return proto.Marshal(val)
|
|
}
|
|
|
|
// Unmarshal an object of type InvocationTask from the protobuf v3 wire format
|
|
func (val *InvocationTask) Unmarshal(buf []byte) error {
|
|
return proto.Unmarshal(buf, val)
|
|
}
|
|
|
|
// Size returns the size of the object, in bytes, once serialized
|
|
func (val *InvocationTask) Size() int {
|
|
return proto.Size(val)
|
|
}
|
|
|
|
// Equal returns whether two InvocationTask 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 *InvocationTask) Equal(that interface{}) bool {
|
|
if that == nil {
|
|
return this == nil
|
|
}
|
|
|
|
var that1 *InvocationTask
|
|
switch t := that.(type) {
|
|
case *InvocationTask:
|
|
that1 = t
|
|
case InvocationTask:
|
|
that1 = &t
|
|
default:
|
|
return false
|
|
}
|
|
|
|
return proto.Equal(this, that1)
|
|
}
|
|
|
|
// Marshal an object of type InvocationBackoffTask to the protobuf v3 wire format
|
|
func (val *InvocationBackoffTask) Marshal() ([]byte, error) {
|
|
return proto.Marshal(val)
|
|
}
|
|
|
|
// Unmarshal an object of type InvocationBackoffTask from the protobuf v3 wire format
|
|
func (val *InvocationBackoffTask) Unmarshal(buf []byte) error {
|
|
return proto.Unmarshal(buf, val)
|
|
}
|
|
|
|
// Size returns the size of the object, in bytes, once serialized
|
|
func (val *InvocationBackoffTask) Size() int {
|
|
return proto.Size(val)
|
|
}
|
|
|
|
// Equal returns whether two InvocationBackoffTask 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 *InvocationBackoffTask) Equal(that interface{}) bool {
|
|
if that == nil {
|
|
return this == nil
|
|
}
|
|
|
|
var that1 *InvocationBackoffTask
|
|
switch t := that.(type) {
|
|
case *InvocationBackoffTask:
|
|
that1 = t
|
|
case InvocationBackoffTask:
|
|
that1 = &t
|
|
default:
|
|
return false
|
|
}
|
|
|
|
return proto.Equal(this, that1)
|
|
}
|
|
|
|
// Marshal an object of type CancellationTask to the protobuf v3 wire format
|
|
func (val *CancellationTask) Marshal() ([]byte, error) {
|
|
return proto.Marshal(val)
|
|
}
|
|
|
|
// Unmarshal an object of type CancellationTask from the protobuf v3 wire format
|
|
func (val *CancellationTask) Unmarshal(buf []byte) error {
|
|
return proto.Unmarshal(buf, val)
|
|
}
|
|
|
|
// Size returns the size of the object, in bytes, once serialized
|
|
func (val *CancellationTask) Size() int {
|
|
return proto.Size(val)
|
|
}
|
|
|
|
// Equal returns whether two CancellationTask 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 *CancellationTask) Equal(that interface{}) bool {
|
|
if that == nil {
|
|
return this == nil
|
|
}
|
|
|
|
var that1 *CancellationTask
|
|
switch t := that.(type) {
|
|
case *CancellationTask:
|
|
that1 = t
|
|
case CancellationTask:
|
|
that1 = &t
|
|
default:
|
|
return false
|
|
}
|
|
|
|
return proto.Equal(this, that1)
|
|
}
|
|
|
|
// Marshal an object of type CancellationBackoffTask to the protobuf v3 wire format
|
|
func (val *CancellationBackoffTask) Marshal() ([]byte, error) {
|
|
return proto.Marshal(val)
|
|
}
|
|
|
|
// Unmarshal an object of type CancellationBackoffTask from the protobuf v3 wire format
|
|
func (val *CancellationBackoffTask) Unmarshal(buf []byte) error {
|
|
return proto.Unmarshal(buf, val)
|
|
}
|
|
|
|
// Size returns the size of the object, in bytes, once serialized
|
|
func (val *CancellationBackoffTask) Size() int {
|
|
return proto.Size(val)
|
|
}
|
|
|
|
// Equal returns whether two CancellationBackoffTask 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 *CancellationBackoffTask) Equal(that interface{}) bool {
|
|
if that == nil {
|
|
return this == nil
|
|
}
|
|
|
|
var that1 *CancellationBackoffTask
|
|
switch t := that.(type) {
|
|
case *CancellationBackoffTask:
|
|
that1 = t
|
|
case CancellationBackoffTask:
|
|
that1 = &t
|
|
default:
|
|
return false
|
|
}
|
|
|
|
return proto.Equal(this, that1)
|
|
}
|