Files
tasks/api/token/v1/message.go-helpers.pb.go
Roey BermanandGitHub 784deaf680 Nexus E2E implementation (#5779)
## What changed?

[Operation state
machine](https://github.com/temporalio/temporal/pull/5545)
[Nexus command
processing](https://github.com/temporalio/temporal/pull/5546)
[Implement Nexus start operation task
executors](https://github.com/temporalio/temporal/pull/5686)
[Implement Nexus async completion
endpoint](https://github.com/temporalio/temporal/pull/5735)

Upgrade API to support full E2E flow
https://github.com/temporalio/api/pull/363
2024-04-23 17:00:52 +00:00

290 lines
8.1 KiB
Go

// The MIT License
//
// Copyright (c) 2020 Temporal Technologies Inc. All rights reserved.
//
// Copyright (c) 2020 Uber Technologies, Inc.
//
// Permission is hereby granted, free of charge, to any person obtaining a copy
// of this software and associated documentation files (the "Software"), to deal
// in the Software without restriction, including without limitation the rights
// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
// copies of the Software, and to permit persons to whom the Software is
// furnished to do so, subject to the following conditions:
//
// The above copyright notice and this permission notice shall be included in
// all copies or substantial portions of the Software.
//
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
// THE SOFTWARE.
// Code generated by protoc-gen-go-helpers. DO NOT EDIT.
package token
import (
"google.golang.org/protobuf/proto"
)
// Marshal an object of type HistoryContinuation to the protobuf v3 wire format
func (val *HistoryContinuation) Marshal() ([]byte, error) {
return proto.Marshal(val)
}
// Unmarshal an object of type HistoryContinuation from the protobuf v3 wire format
func (val *HistoryContinuation) Unmarshal(buf []byte) error {
return proto.Unmarshal(buf, val)
}
// Size returns the size of the object, in bytes, once serialized
func (val *HistoryContinuation) Size() int {
return proto.Size(val)
}
// Equal returns whether two HistoryContinuation 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 *HistoryContinuation) Equal(that interface{}) bool {
if that == nil {
return this == nil
}
var that1 *HistoryContinuation
switch t := that.(type) {
case *HistoryContinuation:
that1 = t
case HistoryContinuation:
that1 = &t
default:
return false
}
return proto.Equal(this, that1)
}
// Marshal an object of type RawHistoryContinuation to the protobuf v3 wire format
func (val *RawHistoryContinuation) Marshal() ([]byte, error) {
return proto.Marshal(val)
}
// Unmarshal an object of type RawHistoryContinuation from the protobuf v3 wire format
func (val *RawHistoryContinuation) Unmarshal(buf []byte) error {
return proto.Unmarshal(buf, val)
}
// Size returns the size of the object, in bytes, once serialized
func (val *RawHistoryContinuation) Size() int {
return proto.Size(val)
}
// Equal returns whether two RawHistoryContinuation 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 *RawHistoryContinuation) Equal(that interface{}) bool {
if that == nil {
return this == nil
}
var that1 *RawHistoryContinuation
switch t := that.(type) {
case *RawHistoryContinuation:
that1 = t
case RawHistoryContinuation:
that1 = &t
default:
return false
}
return proto.Equal(this, that1)
}
// Marshal an object of type Task to the protobuf v3 wire format
func (val *Task) Marshal() ([]byte, error) {
return proto.Marshal(val)
}
// Unmarshal an object of type Task from the protobuf v3 wire format
func (val *Task) Unmarshal(buf []byte) error {
return proto.Unmarshal(buf, val)
}
// Size returns the size of the object, in bytes, once serialized
func (val *Task) Size() int {
return proto.Size(val)
}
// Equal returns whether two Task 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 *Task) Equal(that interface{}) bool {
if that == nil {
return this == nil
}
var that1 *Task
switch t := that.(type) {
case *Task:
that1 = t
case Task:
that1 = &t
default:
return false
}
return proto.Equal(this, that1)
}
// Marshal an object of type QueryTask to the protobuf v3 wire format
func (val *QueryTask) Marshal() ([]byte, error) {
return proto.Marshal(val)
}
// Unmarshal an object of type QueryTask from the protobuf v3 wire format
func (val *QueryTask) Unmarshal(buf []byte) error {
return proto.Unmarshal(buf, val)
}
// Size returns the size of the object, in bytes, once serialized
func (val *QueryTask) Size() int {
return proto.Size(val)
}
// Equal returns whether two QueryTask 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 *QueryTask) Equal(that interface{}) bool {
if that == nil {
return this == nil
}
var that1 *QueryTask
switch t := that.(type) {
case *QueryTask:
that1 = t
case QueryTask:
that1 = &t
default:
return false
}
return proto.Equal(this, that1)
}
// Marshal an object of type NexusTask to the protobuf v3 wire format
func (val *NexusTask) Marshal() ([]byte, error) {
return proto.Marshal(val)
}
// Unmarshal an object of type NexusTask from the protobuf v3 wire format
func (val *NexusTask) Unmarshal(buf []byte) error {
return proto.Unmarshal(buf, val)
}
// Size returns the size of the object, in bytes, once serialized
func (val *NexusTask) Size() int {
return proto.Size(val)
}
// Equal returns whether two NexusTask 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 *NexusTask) Equal(that interface{}) bool {
if that == nil {
return this == nil
}
var that1 *NexusTask
switch t := that.(type) {
case *NexusTask:
that1 = t
case NexusTask:
that1 = &t
default:
return false
}
return proto.Equal(this, that1)
}
// Marshal an object of type HistoryEventRef to the protobuf v3 wire format
func (val *HistoryEventRef) Marshal() ([]byte, error) {
return proto.Marshal(val)
}
// Unmarshal an object of type HistoryEventRef from the protobuf v3 wire format
func (val *HistoryEventRef) Unmarshal(buf []byte) error {
return proto.Unmarshal(buf, val)
}
// Size returns the size of the object, in bytes, once serialized
func (val *HistoryEventRef) Size() int {
return proto.Size(val)
}
// Equal returns whether two HistoryEventRef 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 *HistoryEventRef) Equal(that interface{}) bool {
if that == nil {
return this == nil
}
var that1 *HistoryEventRef
switch t := that.(type) {
case *HistoryEventRef:
that1 = t
case HistoryEventRef:
that1 = &t
default:
return false
}
return proto.Equal(this, that1)
}
// Marshal an object of type NexusOperationCompletion to the protobuf v3 wire format
func (val *NexusOperationCompletion) Marshal() ([]byte, error) {
return proto.Marshal(val)
}
// Unmarshal an object of type NexusOperationCompletion from the protobuf v3 wire format
func (val *NexusOperationCompletion) Unmarshal(buf []byte) error {
return proto.Unmarshal(buf, val)
}
// Size returns the size of the object, in bytes, once serialized
func (val *NexusOperationCompletion) Size() int {
return proto.Size(val)
}
// Equal returns whether two NexusOperationCompletion 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 *NexusOperationCompletion) Equal(that interface{}) bool {
if that == nil {
return this == nil
}
var that1 *NexusOperationCompletion
switch t := that.(type) {
case *NexusOperationCompletion:
that1 = t
case NexusOperationCompletion:
that1 = &t
default:
return false
}
return proto.Equal(this, that1)
}