Files
tasks/api/token/v1/message.pb.go
Alex ShtinandGitHub 8e8f1b0f7c Remove license header from every file (#7689)
## What changed?
<!-- Describe what has changed in this PR -->
Remove license header from every file. Because it is really hard to
follow in this PR here is the summary:
1. License header is removed from all `.go` and `.proto` files
:fireworks::fireworks:🎆.
2. `LICENSE` file in the root directory has only Temporal and Uber
copyrights.
3. 5 other `LICENSE` files added to the packages which have copyrights
different from Temporal and Uber: Datadog, Xargin, "Mat Ryer, Tyler
Bunnell and contributors".
4. `license_file` flag is removed from all code generation tools.
5. `copyright_file` flag is removed from `go:generate mockgen`
directive.
6. All copyright related targets are removed from `Makefile`.
7. Updated Temporal copyright year to 2025 everywhere.

## Why?
<!-- Tell your future self why have you made these changes -->
I double checked with legal department that it is not needed to have
license header in every file. One file per repo is enough. I put all
copyrights to the root `LICENSE` file and removed header from all other
files. Also updated tools and `Makefile`.
2025-05-01 18:50:21 -07:00

771 lines
26 KiB
Go

// Code generated by protoc-gen-go. DO NOT EDIT.
// plugins:
// protoc-gen-go
// protoc
// source: temporal/server/api/token/v1/message.proto
package token
import (
reflect "reflect"
sync "sync"
unsafe "unsafe"
v12 "go.temporal.io/server/api/clock/v1"
v1 "go.temporal.io/server/api/history/v1"
v11 "go.temporal.io/server/api/persistence/v1"
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
timestamppb "google.golang.org/protobuf/types/known/timestamppb"
)
const (
// Verify that this generated code is sufficiently up-to-date.
_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
// Verify that runtime/protoimpl is sufficiently up-to-date.
_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
)
type HistoryContinuation struct {
state protoimpl.MessageState `protogen:"open.v1"`
RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
FirstEventId int64 `protobuf:"varint,2,opt,name=first_event_id,json=firstEventId,proto3" json:"first_event_id,omitempty"`
NextEventId int64 `protobuf:"varint,3,opt,name=next_event_id,json=nextEventId,proto3" json:"next_event_id,omitempty"`
IsWorkflowRunning bool `protobuf:"varint,5,opt,name=is_workflow_running,json=isWorkflowRunning,proto3" json:"is_workflow_running,omitempty"`
PersistenceToken []byte `protobuf:"bytes,6,opt,name=persistence_token,json=persistenceToken,proto3" json:"persistence_token,omitempty"`
TransientWorkflowTask *v1.TransientWorkflowTaskInfo `protobuf:"bytes,7,opt,name=transient_workflow_task,json=transientWorkflowTask,proto3" json:"transient_workflow_task,omitempty"`
BranchToken []byte `protobuf:"bytes,8,opt,name=branch_token,json=branchToken,proto3" json:"branch_token,omitempty"`
VersionHistoryItem *v1.VersionHistoryItem `protobuf:"bytes,10,opt,name=version_history_item,json=versionHistoryItem,proto3" json:"version_history_item,omitempty"`
VersionedTransition *v11.VersionedTransition `protobuf:"bytes,11,opt,name=versioned_transition,json=versionedTransition,proto3" json:"versioned_transition,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *HistoryContinuation) Reset() {
*x = HistoryContinuation{}
mi := &file_temporal_server_api_token_v1_message_proto_msgTypes[0]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *HistoryContinuation) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*HistoryContinuation) ProtoMessage() {}
func (x *HistoryContinuation) ProtoReflect() protoreflect.Message {
mi := &file_temporal_server_api_token_v1_message_proto_msgTypes[0]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use HistoryContinuation.ProtoReflect.Descriptor instead.
func (*HistoryContinuation) Descriptor() ([]byte, []int) {
return file_temporal_server_api_token_v1_message_proto_rawDescGZIP(), []int{0}
}
func (x *HistoryContinuation) GetRunId() string {
if x != nil {
return x.RunId
}
return ""
}
func (x *HistoryContinuation) GetFirstEventId() int64 {
if x != nil {
return x.FirstEventId
}
return 0
}
func (x *HistoryContinuation) GetNextEventId() int64 {
if x != nil {
return x.NextEventId
}
return 0
}
func (x *HistoryContinuation) GetIsWorkflowRunning() bool {
if x != nil {
return x.IsWorkflowRunning
}
return false
}
func (x *HistoryContinuation) GetPersistenceToken() []byte {
if x != nil {
return x.PersistenceToken
}
return nil
}
func (x *HistoryContinuation) GetTransientWorkflowTask() *v1.TransientWorkflowTaskInfo {
if x != nil {
return x.TransientWorkflowTask
}
return nil
}
func (x *HistoryContinuation) GetBranchToken() []byte {
if x != nil {
return x.BranchToken
}
return nil
}
func (x *HistoryContinuation) GetVersionHistoryItem() *v1.VersionHistoryItem {
if x != nil {
return x.VersionHistoryItem
}
return nil
}
func (x *HistoryContinuation) GetVersionedTransition() *v11.VersionedTransition {
if x != nil {
return x.VersionedTransition
}
return nil
}
type RawHistoryContinuation struct {
state protoimpl.MessageState `protogen:"open.v1"`
NamespaceId string `protobuf:"bytes,10,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
WorkflowId string `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
RunId string `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
StartEventId int64 `protobuf:"varint,4,opt,name=start_event_id,json=startEventId,proto3" json:"start_event_id,omitempty"`
StartEventVersion int64 `protobuf:"varint,5,opt,name=start_event_version,json=startEventVersion,proto3" json:"start_event_version,omitempty"`
EndEventId int64 `protobuf:"varint,6,opt,name=end_event_id,json=endEventId,proto3" json:"end_event_id,omitempty"`
EndEventVersion int64 `protobuf:"varint,7,opt,name=end_event_version,json=endEventVersion,proto3" json:"end_event_version,omitempty"`
PersistenceToken []byte `protobuf:"bytes,8,opt,name=persistence_token,json=persistenceToken,proto3" json:"persistence_token,omitempty"`
VersionHistories *v1.VersionHistories `protobuf:"bytes,9,opt,name=version_histories,json=versionHistories,proto3" json:"version_histories,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *RawHistoryContinuation) Reset() {
*x = RawHistoryContinuation{}
mi := &file_temporal_server_api_token_v1_message_proto_msgTypes[1]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *RawHistoryContinuation) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*RawHistoryContinuation) ProtoMessage() {}
func (x *RawHistoryContinuation) ProtoReflect() protoreflect.Message {
mi := &file_temporal_server_api_token_v1_message_proto_msgTypes[1]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use RawHistoryContinuation.ProtoReflect.Descriptor instead.
func (*RawHistoryContinuation) Descriptor() ([]byte, []int) {
return file_temporal_server_api_token_v1_message_proto_rawDescGZIP(), []int{1}
}
func (x *RawHistoryContinuation) GetNamespaceId() string {
if x != nil {
return x.NamespaceId
}
return ""
}
func (x *RawHistoryContinuation) GetWorkflowId() string {
if x != nil {
return x.WorkflowId
}
return ""
}
func (x *RawHistoryContinuation) GetRunId() string {
if x != nil {
return x.RunId
}
return ""
}
func (x *RawHistoryContinuation) GetStartEventId() int64 {
if x != nil {
return x.StartEventId
}
return 0
}
func (x *RawHistoryContinuation) GetStartEventVersion() int64 {
if x != nil {
return x.StartEventVersion
}
return 0
}
func (x *RawHistoryContinuation) GetEndEventId() int64 {
if x != nil {
return x.EndEventId
}
return 0
}
func (x *RawHistoryContinuation) GetEndEventVersion() int64 {
if x != nil {
return x.EndEventVersion
}
return 0
}
func (x *RawHistoryContinuation) GetPersistenceToken() []byte {
if x != nil {
return x.PersistenceToken
}
return nil
}
func (x *RawHistoryContinuation) GetVersionHistories() *v1.VersionHistories {
if x != nil {
return x.VersionHistories
}
return nil
}
type Task struct {
state protoimpl.MessageState `protogen:"open.v1"`
NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
WorkflowId string `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
RunId string `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
ScheduledEventId int64 `protobuf:"varint,4,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"`
Attempt int32 `protobuf:"varint,5,opt,name=attempt,proto3" json:"attempt,omitempty"`
ActivityId string `protobuf:"bytes,6,opt,name=activity_id,json=activityId,proto3" json:"activity_id,omitempty"`
WorkflowType string `protobuf:"bytes,7,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"`
ActivityType string `protobuf:"bytes,8,opt,name=activity_type,json=activityType,proto3" json:"activity_type,omitempty"`
Clock *v12.VectorClock `protobuf:"bytes,9,opt,name=clock,proto3" json:"clock,omitempty"`
StartedEventId int64 `protobuf:"varint,10,opt,name=started_event_id,json=startedEventId,proto3" json:"started_event_id,omitempty"`
Version int64 `protobuf:"varint,11,opt,name=version,proto3" json:"version,omitempty"`
StartedTime *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=started_time,json=startedTime,proto3" json:"started_time,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *Task) Reset() {
*x = Task{}
mi := &file_temporal_server_api_token_v1_message_proto_msgTypes[2]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Task) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*Task) ProtoMessage() {}
func (x *Task) ProtoReflect() protoreflect.Message {
mi := &file_temporal_server_api_token_v1_message_proto_msgTypes[2]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use Task.ProtoReflect.Descriptor instead.
func (*Task) Descriptor() ([]byte, []int) {
return file_temporal_server_api_token_v1_message_proto_rawDescGZIP(), []int{2}
}
func (x *Task) GetNamespaceId() string {
if x != nil {
return x.NamespaceId
}
return ""
}
func (x *Task) GetWorkflowId() string {
if x != nil {
return x.WorkflowId
}
return ""
}
func (x *Task) GetRunId() string {
if x != nil {
return x.RunId
}
return ""
}
func (x *Task) GetScheduledEventId() int64 {
if x != nil {
return x.ScheduledEventId
}
return 0
}
func (x *Task) GetAttempt() int32 {
if x != nil {
return x.Attempt
}
return 0
}
func (x *Task) GetActivityId() string {
if x != nil {
return x.ActivityId
}
return ""
}
func (x *Task) GetWorkflowType() string {
if x != nil {
return x.WorkflowType
}
return ""
}
func (x *Task) GetActivityType() string {
if x != nil {
return x.ActivityType
}
return ""
}
func (x *Task) GetClock() *v12.VectorClock {
if x != nil {
return x.Clock
}
return nil
}
func (x *Task) GetStartedEventId() int64 {
if x != nil {
return x.StartedEventId
}
return 0
}
func (x *Task) GetVersion() int64 {
if x != nil {
return x.Version
}
return 0
}
func (x *Task) GetStartedTime() *timestamppb.Timestamp {
if x != nil {
return x.StartedTime
}
return nil
}
type QueryTask struct {
state protoimpl.MessageState `protogen:"open.v1"`
NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
TaskQueue string `protobuf:"bytes,2,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
TaskId string `protobuf:"bytes,3,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *QueryTask) Reset() {
*x = QueryTask{}
mi := &file_temporal_server_api_token_v1_message_proto_msgTypes[3]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *QueryTask) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*QueryTask) ProtoMessage() {}
func (x *QueryTask) ProtoReflect() protoreflect.Message {
mi := &file_temporal_server_api_token_v1_message_proto_msgTypes[3]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use QueryTask.ProtoReflect.Descriptor instead.
func (*QueryTask) Descriptor() ([]byte, []int) {
return file_temporal_server_api_token_v1_message_proto_rawDescGZIP(), []int{3}
}
func (x *QueryTask) GetNamespaceId() string {
if x != nil {
return x.NamespaceId
}
return ""
}
func (x *QueryTask) GetTaskQueue() string {
if x != nil {
return x.TaskQueue
}
return ""
}
func (x *QueryTask) GetTaskId() string {
if x != nil {
return x.TaskId
}
return ""
}
type NexusTask struct {
state protoimpl.MessageState `protogen:"open.v1"`
NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
TaskQueue string `protobuf:"bytes,2,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
TaskId string `protobuf:"bytes,3,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *NexusTask) Reset() {
*x = NexusTask{}
mi := &file_temporal_server_api_token_v1_message_proto_msgTypes[4]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *NexusTask) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*NexusTask) ProtoMessage() {}
func (x *NexusTask) ProtoReflect() protoreflect.Message {
mi := &file_temporal_server_api_token_v1_message_proto_msgTypes[4]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use NexusTask.ProtoReflect.Descriptor instead.
func (*NexusTask) Descriptor() ([]byte, []int) {
return file_temporal_server_api_token_v1_message_proto_rawDescGZIP(), []int{4}
}
func (x *NexusTask) GetNamespaceId() string {
if x != nil {
return x.NamespaceId
}
return ""
}
func (x *NexusTask) GetTaskQueue() string {
if x != nil {
return x.TaskQueue
}
return ""
}
func (x *NexusTask) GetTaskId() string {
if x != nil {
return x.TaskId
}
return ""
}
// A reference for loading a history event.
type HistoryEventRef struct {
state protoimpl.MessageState `protogen:"open.v1"`
// Event ID.
EventId int64 `protobuf:"varint,1,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
// Event batch ID - the first event ID in the batch the event was stored in.
EventBatchId int64 `protobuf:"varint,2,opt,name=event_batch_id,json=eventBatchId,proto3" json:"event_batch_id,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *HistoryEventRef) Reset() {
*x = HistoryEventRef{}
mi := &file_temporal_server_api_token_v1_message_proto_msgTypes[5]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *HistoryEventRef) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*HistoryEventRef) ProtoMessage() {}
func (x *HistoryEventRef) ProtoReflect() protoreflect.Message {
mi := &file_temporal_server_api_token_v1_message_proto_msgTypes[5]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use HistoryEventRef.ProtoReflect.Descriptor instead.
func (*HistoryEventRef) Descriptor() ([]byte, []int) {
return file_temporal_server_api_token_v1_message_proto_rawDescGZIP(), []int{5}
}
func (x *HistoryEventRef) GetEventId() int64 {
if x != nil {
return x.EventId
}
return 0
}
func (x *HistoryEventRef) GetEventBatchId() int64 {
if x != nil {
return x.EventBatchId
}
return 0
}
// A completion token for a Nexus operation started from a workflow.
type NexusOperationCompletion struct {
state protoimpl.MessageState `protogen:"open.v1"`
// Namespace UUID.
NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
// Workflow ID.
WorkflowId string `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
// Run ID at the time this token was generated.
RunId string `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
// Reference including the path to the backing Operation state machine and a version + transition count for
// staleness checks.
Ref *v11.StateMachineRef `protobuf:"bytes,4,opt,name=ref,proto3" json:"ref,omitempty"`
// Request ID embedded in the NexusOperationScheduledEvent.
// Allows completing a started operation after a workflow has been reset.
RequestId string `protobuf:"bytes,5,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *NexusOperationCompletion) Reset() {
*x = NexusOperationCompletion{}
mi := &file_temporal_server_api_token_v1_message_proto_msgTypes[6]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *NexusOperationCompletion) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*NexusOperationCompletion) ProtoMessage() {}
func (x *NexusOperationCompletion) ProtoReflect() protoreflect.Message {
mi := &file_temporal_server_api_token_v1_message_proto_msgTypes[6]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use NexusOperationCompletion.ProtoReflect.Descriptor instead.
func (*NexusOperationCompletion) Descriptor() ([]byte, []int) {
return file_temporal_server_api_token_v1_message_proto_rawDescGZIP(), []int{6}
}
func (x *NexusOperationCompletion) GetNamespaceId() string {
if x != nil {
return x.NamespaceId
}
return ""
}
func (x *NexusOperationCompletion) GetWorkflowId() string {
if x != nil {
return x.WorkflowId
}
return ""
}
func (x *NexusOperationCompletion) GetRunId() string {
if x != nil {
return x.RunId
}
return ""
}
func (x *NexusOperationCompletion) GetRef() *v11.StateMachineRef {
if x != nil {
return x.Ref
}
return nil
}
func (x *NexusOperationCompletion) GetRequestId() string {
if x != nil {
return x.RequestId
}
return ""
}
var File_temporal_server_api_token_v1_message_proto protoreflect.FileDescriptor
const file_temporal_server_api_token_v1_message_proto_rawDesc = "" +
"\n" +
"*temporal/server/api/token/v1/message.proto\x12\x1ctemporal.server.api.token.v1\x1a\x1fgoogle/protobuf/timestamp.proto\x1a*temporal/server/api/clock/v1/message.proto\x1a,temporal/server/api/history/v1/message.proto\x1a,temporal/server/api/persistence/v1/hsm.proto\"\xc1\x04\n" +
"\x13HistoryContinuation\x12\x15\n" +
"\x06run_id\x18\x01 \x01(\tR\x05runId\x12$\n" +
"\x0efirst_event_id\x18\x02 \x01(\x03R\ffirstEventId\x12\"\n" +
"\rnext_event_id\x18\x03 \x01(\x03R\vnextEventId\x12.\n" +
"\x13is_workflow_running\x18\x05 \x01(\bR\x11isWorkflowRunning\x12+\n" +
"\x11persistence_token\x18\x06 \x01(\fR\x10persistenceToken\x12q\n" +
"\x17transient_workflow_task\x18\a \x01(\v29.temporal.server.api.history.v1.TransientWorkflowTaskInfoR\x15transientWorkflowTask\x12!\n" +
"\fbranch_token\x18\b \x01(\fR\vbranchToken\x12d\n" +
"\x14version_history_item\x18\n" +
" \x01(\v22.temporal.server.api.history.v1.VersionHistoryItemR\x12versionHistoryItem\x12j\n" +
"\x14versioned_transition\x18\v \x01(\v27.temporal.server.api.persistence.v1.VersionedTransitionR\x13versionedTransitionJ\x04\b\t\x10\n" +
"\"\xa9\x03\n" +
"\x16RawHistoryContinuation\x12!\n" +
"\fnamespace_id\x18\n" +
" \x01(\tR\vnamespaceId\x12\x1f\n" +
"\vworkflow_id\x18\x02 \x01(\tR\n" +
"workflowId\x12\x15\n" +
"\x06run_id\x18\x03 \x01(\tR\x05runId\x12$\n" +
"\x0estart_event_id\x18\x04 \x01(\x03R\fstartEventId\x12.\n" +
"\x13start_event_version\x18\x05 \x01(\x03R\x11startEventVersion\x12 \n" +
"\fend_event_id\x18\x06 \x01(\x03R\n" +
"endEventId\x12*\n" +
"\x11end_event_version\x18\a \x01(\x03R\x0fendEventVersion\x12+\n" +
"\x11persistence_token\x18\b \x01(\fR\x10persistenceToken\x12]\n" +
"\x11version_histories\x18\t \x01(\v20.temporal.server.api.history.v1.VersionHistoriesR\x10versionHistoriesJ\x04\b\x01\x10\x02\"\xd8\x03\n" +
"\x04Task\x12!\n" +
"\fnamespace_id\x18\x01 \x01(\tR\vnamespaceId\x12\x1f\n" +
"\vworkflow_id\x18\x02 \x01(\tR\n" +
"workflowId\x12\x15\n" +
"\x06run_id\x18\x03 \x01(\tR\x05runId\x12,\n" +
"\x12scheduled_event_id\x18\x04 \x01(\x03R\x10scheduledEventId\x12\x18\n" +
"\aattempt\x18\x05 \x01(\x05R\aattempt\x12\x1f\n" +
"\vactivity_id\x18\x06 \x01(\tR\n" +
"activityId\x12#\n" +
"\rworkflow_type\x18\a \x01(\tR\fworkflowType\x12#\n" +
"\ractivity_type\x18\b \x01(\tR\factivityType\x12?\n" +
"\x05clock\x18\t \x01(\v2).temporal.server.api.clock.v1.VectorClockR\x05clock\x12(\n" +
"\x10started_event_id\x18\n" +
" \x01(\x03R\x0estartedEventId\x12\x18\n" +
"\aversion\x18\v \x01(\x03R\aversion\x12=\n" +
"\fstarted_time\x18\f \x01(\v2\x1a.google.protobuf.TimestampR\vstartedTime\"f\n" +
"\tQueryTask\x12!\n" +
"\fnamespace_id\x18\x01 \x01(\tR\vnamespaceId\x12\x1d\n" +
"\n" +
"task_queue\x18\x02 \x01(\tR\ttaskQueue\x12\x17\n" +
"\atask_id\x18\x03 \x01(\tR\x06taskId\"f\n" +
"\tNexusTask\x12!\n" +
"\fnamespace_id\x18\x01 \x01(\tR\vnamespaceId\x12\x1d\n" +
"\n" +
"task_queue\x18\x02 \x01(\tR\ttaskQueue\x12\x17\n" +
"\atask_id\x18\x03 \x01(\tR\x06taskId\"R\n" +
"\x0fHistoryEventRef\x12\x19\n" +
"\bevent_id\x18\x01 \x01(\x03R\aeventId\x12$\n" +
"\x0eevent_batch_id\x18\x02 \x01(\x03R\feventBatchId\"\xdb\x01\n" +
"\x18NexusOperationCompletion\x12!\n" +
"\fnamespace_id\x18\x01 \x01(\tR\vnamespaceId\x12\x1f\n" +
"\vworkflow_id\x18\x02 \x01(\tR\n" +
"workflowId\x12\x15\n" +
"\x06run_id\x18\x03 \x01(\tR\x05runId\x12E\n" +
"\x03ref\x18\x04 \x01(\v23.temporal.server.api.persistence.v1.StateMachineRefR\x03ref\x12\x1d\n" +
"\n" +
"request_id\x18\x05 \x01(\tR\trequestIdB*Z(go.temporal.io/server/api/token/v1;tokenb\x06proto3"
var (
file_temporal_server_api_token_v1_message_proto_rawDescOnce sync.Once
file_temporal_server_api_token_v1_message_proto_rawDescData []byte
)
func file_temporal_server_api_token_v1_message_proto_rawDescGZIP() []byte {
file_temporal_server_api_token_v1_message_proto_rawDescOnce.Do(func() {
file_temporal_server_api_token_v1_message_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_temporal_server_api_token_v1_message_proto_rawDesc), len(file_temporal_server_api_token_v1_message_proto_rawDesc)))
})
return file_temporal_server_api_token_v1_message_proto_rawDescData
}
var file_temporal_server_api_token_v1_message_proto_msgTypes = make([]protoimpl.MessageInfo, 7)
var file_temporal_server_api_token_v1_message_proto_goTypes = []any{
(*HistoryContinuation)(nil), // 0: temporal.server.api.token.v1.HistoryContinuation
(*RawHistoryContinuation)(nil), // 1: temporal.server.api.token.v1.RawHistoryContinuation
(*Task)(nil), // 2: temporal.server.api.token.v1.Task
(*QueryTask)(nil), // 3: temporal.server.api.token.v1.QueryTask
(*NexusTask)(nil), // 4: temporal.server.api.token.v1.NexusTask
(*HistoryEventRef)(nil), // 5: temporal.server.api.token.v1.HistoryEventRef
(*NexusOperationCompletion)(nil), // 6: temporal.server.api.token.v1.NexusOperationCompletion
(*v1.TransientWorkflowTaskInfo)(nil), // 7: temporal.server.api.history.v1.TransientWorkflowTaskInfo
(*v1.VersionHistoryItem)(nil), // 8: temporal.server.api.history.v1.VersionHistoryItem
(*v11.VersionedTransition)(nil), // 9: temporal.server.api.persistence.v1.VersionedTransition
(*v1.VersionHistories)(nil), // 10: temporal.server.api.history.v1.VersionHistories
(*v12.VectorClock)(nil), // 11: temporal.server.api.clock.v1.VectorClock
(*timestamppb.Timestamp)(nil), // 12: google.protobuf.Timestamp
(*v11.StateMachineRef)(nil), // 13: temporal.server.api.persistence.v1.StateMachineRef
}
var file_temporal_server_api_token_v1_message_proto_depIdxs = []int32{
7, // 0: temporal.server.api.token.v1.HistoryContinuation.transient_workflow_task:type_name -> temporal.server.api.history.v1.TransientWorkflowTaskInfo
8, // 1: temporal.server.api.token.v1.HistoryContinuation.version_history_item:type_name -> temporal.server.api.history.v1.VersionHistoryItem
9, // 2: temporal.server.api.token.v1.HistoryContinuation.versioned_transition:type_name -> temporal.server.api.persistence.v1.VersionedTransition
10, // 3: temporal.server.api.token.v1.RawHistoryContinuation.version_histories:type_name -> temporal.server.api.history.v1.VersionHistories
11, // 4: temporal.server.api.token.v1.Task.clock:type_name -> temporal.server.api.clock.v1.VectorClock
12, // 5: temporal.server.api.token.v1.Task.started_time:type_name -> google.protobuf.Timestamp
13, // 6: temporal.server.api.token.v1.NexusOperationCompletion.ref:type_name -> temporal.server.api.persistence.v1.StateMachineRef
7, // [7:7] is the sub-list for method output_type
7, // [7:7] is the sub-list for method input_type
7, // [7:7] is the sub-list for extension type_name
7, // [7:7] is the sub-list for extension extendee
0, // [0:7] is the sub-list for field type_name
}
func init() { file_temporal_server_api_token_v1_message_proto_init() }
func file_temporal_server_api_token_v1_message_proto_init() {
if File_temporal_server_api_token_v1_message_proto != nil {
return
}
type x struct{}
out := protoimpl.TypeBuilder{
File: protoimpl.DescBuilder{
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_token_v1_message_proto_rawDesc), len(file_temporal_server_api_token_v1_message_proto_rawDesc)),
NumEnums: 0,
NumMessages: 7,
NumExtensions: 0,
NumServices: 0,
},
GoTypes: file_temporal_server_api_token_v1_message_proto_goTypes,
DependencyIndexes: file_temporal_server_api_token_v1_message_proto_depIdxs,
MessageInfos: file_temporal_server_api_token_v1_message_proto_msgTypes,
}.Build()
File_temporal_server_api_token_v1_message_proto = out.File
file_temporal_server_api_token_v1_message_proto_goTypes = nil
file_temporal_server_api_token_v1_message_proto_depIdxs = nil
}