sdk

package
v1.39.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 28, 2024 License: MIT Imports: 6 Imported by: 7

Documentation

Overview

Code generated by protoc-gen-go-helpers. DO NOT EDIT.

Code generated by protoc-gen-go-helpers. DO NOT EDIT.

Code generated by protoc-gen-go-helpers. DO NOT EDIT.

Code generated by protoc-gen-go-helpers. DO NOT EDIT.

Index

Constants

This section is empty.

Variables

View Source
var File_temporal_api_sdk_v1_enhanced_stack_trace_proto protoreflect.FileDescriptor
View Source
var File_temporal_api_sdk_v1_task_complete_metadata_proto protoreflect.FileDescriptor
View Source
var File_temporal_api_sdk_v1_user_metadata_proto protoreflect.FileDescriptor
View Source
var File_temporal_api_sdk_v1_workflow_metadata_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type EnhancedStackTrace added in v1.35.0

type EnhancedStackTrace struct {

	// Information pertaining to the SDK that the trace has been captured from.
	Sdk *StackTraceSDKInfo `protobuf:"bytes,1,opt,name=sdk,proto3" json:"sdk,omitempty"`
	// Mapping of file path to file contents.
	Sources map[string]*StackTraceFileSlice `` /* 155-byte string literal not displayed */
	// Collection of stacks captured.
	Stacks []*StackTrace `protobuf:"bytes,3,rep,name=stacks,proto3" json:"stacks,omitempty"`
	// contains filtered or unexported fields
}

Internal structure used to create worker stack traces with references to code.

func (*EnhancedStackTrace) Descriptor deprecated added in v1.35.0

func (*EnhancedStackTrace) Descriptor() ([]byte, []int)

Deprecated: Use EnhancedStackTrace.ProtoReflect.Descriptor instead.

func (*EnhancedStackTrace) Equal added in v1.35.0

func (this *EnhancedStackTrace) Equal(that interface{}) bool

Equal returns whether two EnhancedStackTrace 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 (*EnhancedStackTrace) GetSdk added in v1.35.0

func (*EnhancedStackTrace) GetSources added in v1.35.0

func (x *EnhancedStackTrace) GetSources() map[string]*StackTraceFileSlice

func (*EnhancedStackTrace) GetStacks added in v1.35.0

func (x *EnhancedStackTrace) GetStacks() []*StackTrace

func (*EnhancedStackTrace) Marshal added in v1.35.0

func (val *EnhancedStackTrace) Marshal() ([]byte, error)

Marshal an object of type EnhancedStackTrace to the protobuf v3 wire format

func (*EnhancedStackTrace) ProtoMessage added in v1.35.0

func (*EnhancedStackTrace) ProtoMessage()

func (*EnhancedStackTrace) ProtoReflect added in v1.35.0

func (x *EnhancedStackTrace) ProtoReflect() protoreflect.Message

func (*EnhancedStackTrace) Reset added in v1.35.0

func (x *EnhancedStackTrace) Reset()

func (*EnhancedStackTrace) Size added in v1.35.0

func (val *EnhancedStackTrace) Size() int

Size returns the size of the object, in bytes, once serialized

func (*EnhancedStackTrace) String added in v1.35.0

func (x *EnhancedStackTrace) String() string

func (*EnhancedStackTrace) Unmarshal added in v1.35.0

func (val *EnhancedStackTrace) Unmarshal(buf []byte) error

Unmarshal an object of type EnhancedStackTrace from the protobuf v3 wire format

type StackTrace added in v1.35.0

type StackTrace struct {

	// Collection of `FileLocation`s, each for a stack frame that comprise a stack trace.
	Locations []*StackTraceFileLocation `protobuf:"bytes,1,rep,name=locations,proto3" json:"locations,omitempty"`
	// contains filtered or unexported fields
}

Collection of FileLocation messages from a single stack.

func (*StackTrace) Descriptor deprecated added in v1.35.0

func (*StackTrace) Descriptor() ([]byte, []int)

Deprecated: Use StackTrace.ProtoReflect.Descriptor instead.

func (*StackTrace) Equal added in v1.35.0

func (this *StackTrace) Equal(that interface{}) bool

Equal returns whether two StackTrace 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 (*StackTrace) GetLocations added in v1.35.0

func (x *StackTrace) GetLocations() []*StackTraceFileLocation

func (*StackTrace) Marshal added in v1.35.0

func (val *StackTrace) Marshal() ([]byte, error)

Marshal an object of type StackTrace to the protobuf v3 wire format

func (*StackTrace) ProtoMessage added in v1.35.0

func (*StackTrace) ProtoMessage()

func (*StackTrace) ProtoReflect added in v1.35.0

func (x *StackTrace) ProtoReflect() protoreflect.Message

func (*StackTrace) Reset added in v1.35.0

func (x *StackTrace) Reset()

func (*StackTrace) Size added in v1.35.0

func (val *StackTrace) Size() int

Size returns the size of the object, in bytes, once serialized

func (*StackTrace) String added in v1.35.0

func (x *StackTrace) String() string

func (*StackTrace) Unmarshal added in v1.35.0

func (val *StackTrace) Unmarshal(buf []byte) error

Unmarshal an object of type StackTrace from the protobuf v3 wire format

type StackTraceFileLocation added in v1.35.0

type StackTraceFileLocation struct {

	// Path to source file (absolute or relative).
	// If the paths are relative, ensure that they are all relative to the same root.
	FilePath string `protobuf:"bytes,1,opt,name=file_path,json=filePath,proto3" json:"file_path,omitempty"`
	// Optional; If possible, SDK should send this -- this is required for displaying the code location.
	// If not provided, set to -1.
	Line int32 `protobuf:"varint,2,opt,name=line,proto3" json:"line,omitempty"`
	// Optional; if possible, SDK should send this.
	// If not provided, set to -1.
	Column int32 `protobuf:"varint,3,opt,name=column,proto3" json:"column,omitempty"`
	// Function name this line belongs to, if applicable.
	// Used for falling back to stack trace view.
	FunctionName string `protobuf:"bytes,4,opt,name=function_name,json=functionName,proto3" json:"function_name,omitempty"`
	// Flag to communicate whether a location should be hidden by default in the stack view.
	InternalCode bool `protobuf:"varint,5,opt,name=internal_code,json=internalCode,proto3" json:"internal_code,omitempty"`
	// contains filtered or unexported fields
}

More specific location details of a file: its path, precise line and column numbers if applicable, and function name if available. In essence, a pointer to a location in a file

func (*StackTraceFileLocation) Descriptor deprecated added in v1.35.0

func (*StackTraceFileLocation) Descriptor() ([]byte, []int)

Deprecated: Use StackTraceFileLocation.ProtoReflect.Descriptor instead.

func (*StackTraceFileLocation) Equal added in v1.35.0

func (this *StackTraceFileLocation) Equal(that interface{}) bool

Equal returns whether two StackTraceFileLocation 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 (*StackTraceFileLocation) GetColumn added in v1.35.0

func (x *StackTraceFileLocation) GetColumn() int32

func (*StackTraceFileLocation) GetFilePath added in v1.35.0

func (x *StackTraceFileLocation) GetFilePath() string

func (*StackTraceFileLocation) GetFunctionName added in v1.35.0

func (x *StackTraceFileLocation) GetFunctionName() string

func (*StackTraceFileLocation) GetInternalCode added in v1.35.0

func (x *StackTraceFileLocation) GetInternalCode() bool

func (*StackTraceFileLocation) GetLine added in v1.35.0

func (x *StackTraceFileLocation) GetLine() int32

func (*StackTraceFileLocation) Marshal added in v1.35.0

func (val *StackTraceFileLocation) Marshal() ([]byte, error)

Marshal an object of type StackTraceFileLocation to the protobuf v3 wire format

func (*StackTraceFileLocation) ProtoMessage added in v1.35.0

func (*StackTraceFileLocation) ProtoMessage()

func (*StackTraceFileLocation) ProtoReflect added in v1.35.0

func (x *StackTraceFileLocation) ProtoReflect() protoreflect.Message

func (*StackTraceFileLocation) Reset added in v1.35.0

func (x *StackTraceFileLocation) Reset()

func (*StackTraceFileLocation) Size added in v1.35.0

func (val *StackTraceFileLocation) Size() int

Size returns the size of the object, in bytes, once serialized

func (*StackTraceFileLocation) String added in v1.35.0

func (x *StackTraceFileLocation) String() string

func (*StackTraceFileLocation) Unmarshal added in v1.35.0

func (val *StackTraceFileLocation) Unmarshal(buf []byte) error

Unmarshal an object of type StackTraceFileLocation from the protobuf v3 wire format

type StackTraceFileSlice added in v1.35.0

type StackTraceFileSlice struct {

	// Only used (possibly) to trim the file without breaking syntax highlighting. This is not optional, unlike
	// the `line` property of a `StackTraceFileLocation`.
	// (-- api-linter: core::0141::forbidden-types=disabled
	//
	//	aip.dev/not-precedent: These really shouldn't have negative values. --)
	LineOffset uint32 `protobuf:"varint,1,opt,name=line_offset,json=lineOffset,proto3" json:"line_offset,omitempty"`
	// Slice of a file with the respective OS-specific line terminator.
	Content string `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

"Slice" of a file starting at line_offset -- a line offset and code fragment corresponding to the worker's stack.

func (*StackTraceFileSlice) Descriptor deprecated added in v1.35.0

func (*StackTraceFileSlice) Descriptor() ([]byte, []int)

Deprecated: Use StackTraceFileSlice.ProtoReflect.Descriptor instead.

func (*StackTraceFileSlice) Equal added in v1.35.0

func (this *StackTraceFileSlice) Equal(that interface{}) bool

Equal returns whether two StackTraceFileSlice 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 (*StackTraceFileSlice) GetContent added in v1.35.0

func (x *StackTraceFileSlice) GetContent() string

func (*StackTraceFileSlice) GetLineOffset added in v1.35.0

func (x *StackTraceFileSlice) GetLineOffset() uint32

func (*StackTraceFileSlice) Marshal added in v1.35.0

func (val *StackTraceFileSlice) Marshal() ([]byte, error)

Marshal an object of type StackTraceFileSlice to the protobuf v3 wire format

func (*StackTraceFileSlice) ProtoMessage added in v1.35.0

func (*StackTraceFileSlice) ProtoMessage()

func (*StackTraceFileSlice) ProtoReflect added in v1.35.0

func (x *StackTraceFileSlice) ProtoReflect() protoreflect.Message

func (*StackTraceFileSlice) Reset added in v1.35.0

func (x *StackTraceFileSlice) Reset()

func (*StackTraceFileSlice) Size added in v1.35.0

func (val *StackTraceFileSlice) Size() int

Size returns the size of the object, in bytes, once serialized

func (*StackTraceFileSlice) String added in v1.35.0

func (x *StackTraceFileSlice) String() string

func (*StackTraceFileSlice) Unmarshal added in v1.35.0

func (val *StackTraceFileSlice) Unmarshal(buf []byte) error

Unmarshal an object of type StackTraceFileSlice from the protobuf v3 wire format

type StackTraceSDKInfo added in v1.35.0

type StackTraceSDKInfo struct {

	// Name of the SDK
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Version string of the SDK
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

Information pertaining to the SDK that the trace has been captured from. (-- api-linter: core::0123::resource-annotation=disabled

aip.dev/not-precedent: Naming SDK version is optional. --)

func (*StackTraceSDKInfo) Descriptor deprecated added in v1.35.0

func (*StackTraceSDKInfo) Descriptor() ([]byte, []int)

Deprecated: Use StackTraceSDKInfo.ProtoReflect.Descriptor instead.

func (*StackTraceSDKInfo) Equal added in v1.35.0

func (this *StackTraceSDKInfo) Equal(that interface{}) bool

Equal returns whether two StackTraceSDKInfo 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 (*StackTraceSDKInfo) GetName added in v1.35.0

func (x *StackTraceSDKInfo) GetName() string

func (*StackTraceSDKInfo) GetVersion added in v1.35.0

func (x *StackTraceSDKInfo) GetVersion() string

func (*StackTraceSDKInfo) Marshal added in v1.35.0

func (val *StackTraceSDKInfo) Marshal() ([]byte, error)

Marshal an object of type StackTraceSDKInfo to the protobuf v3 wire format

func (*StackTraceSDKInfo) ProtoMessage added in v1.35.0

func (*StackTraceSDKInfo) ProtoMessage()

func (*StackTraceSDKInfo) ProtoReflect added in v1.35.0

func (x *StackTraceSDKInfo) ProtoReflect() protoreflect.Message

func (*StackTraceSDKInfo) Reset added in v1.35.0

func (x *StackTraceSDKInfo) Reset()

func (*StackTraceSDKInfo) Size added in v1.35.0

func (val *StackTraceSDKInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*StackTraceSDKInfo) String added in v1.35.0

func (x *StackTraceSDKInfo) String() string

func (*StackTraceSDKInfo) Unmarshal added in v1.35.0

func (val *StackTraceSDKInfo) Unmarshal(buf []byte) error

Unmarshal an object of type StackTraceSDKInfo from the protobuf v3 wire format

type UserMetadata added in v1.34.0

type UserMetadata struct {

	// Short-form text that provides a summary. This payload should be a "json/plain"-encoded payload
	// that is a single JSON string for use in user interfaces. User interface formatting may not
	// apply to this text when used in "title" situations. The payload data section is limited to 400
	// bytes by default.
	Summary *v1.Payload `protobuf:"bytes,1,opt,name=summary,proto3" json:"summary,omitempty"`
	// Long-form text that provides details. This payload should be a "json/plain"-encoded payload
	// that is a single JSON string for use in user interfaces. User interface formatting may apply to
	// this text in common use. The payload data section is limited to 20000 bytes by default.
	Details *v1.Payload `protobuf:"bytes,2,opt,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

Information a user can set, often for use by user interfaces.

func (*UserMetadata) Descriptor deprecated added in v1.34.0

func (*UserMetadata) Descriptor() ([]byte, []int)

Deprecated: Use UserMetadata.ProtoReflect.Descriptor instead.

func (*UserMetadata) Equal added in v1.34.0

func (this *UserMetadata) Equal(that interface{}) bool

Equal returns whether two UserMetadata 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 (*UserMetadata) GetDetails added in v1.34.0

func (x *UserMetadata) GetDetails() *v1.Payload

func (*UserMetadata) GetSummary added in v1.34.0

func (x *UserMetadata) GetSummary() *v1.Payload

func (*UserMetadata) Marshal added in v1.34.0

func (val *UserMetadata) Marshal() ([]byte, error)

Marshal an object of type UserMetadata to the protobuf v3 wire format

func (*UserMetadata) ProtoMessage added in v1.34.0

func (*UserMetadata) ProtoMessage()

func (*UserMetadata) ProtoReflect added in v1.34.0

func (x *UserMetadata) ProtoReflect() protoreflect.Message

func (*UserMetadata) Reset added in v1.34.0

func (x *UserMetadata) Reset()

func (*UserMetadata) Size added in v1.34.0

func (val *UserMetadata) Size() int

Size returns the size of the object, in bytes, once serialized

func (*UserMetadata) String added in v1.34.0

func (x *UserMetadata) String() string

func (*UserMetadata) Unmarshal added in v1.34.0

func (val *UserMetadata) Unmarshal(buf []byte) error

Unmarshal an object of type UserMetadata from the protobuf v3 wire format

type WorkflowDefinition added in v1.27.0

type WorkflowDefinition struct {

	// A name scoped by the task queue that maps to this workflow definition.
	// If missing, this workflow is a dynamic workflow.
	Type              string                           `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	QueryDefinitions  []*WorkflowInteractionDefinition `protobuf:"bytes,2,rep,name=query_definitions,json=queryDefinitions,proto3" json:"query_definitions,omitempty"`
	SignalDefinitions []*WorkflowInteractionDefinition `protobuf:"bytes,3,rep,name=signal_definitions,json=signalDefinitions,proto3" json:"signal_definitions,omitempty"`
	UpdateDefinitions []*WorkflowInteractionDefinition `protobuf:"bytes,4,rep,name=update_definitions,json=updateDefinitions,proto3" json:"update_definitions,omitempty"`
	// contains filtered or unexported fields
}

(-- api-linter: core::0203::optional=disabled --)

func (*WorkflowDefinition) Descriptor deprecated added in v1.27.0

func (*WorkflowDefinition) Descriptor() ([]byte, []int)

Deprecated: Use WorkflowDefinition.ProtoReflect.Descriptor instead.

func (*WorkflowDefinition) Equal added in v1.27.0

func (this *WorkflowDefinition) Equal(that interface{}) bool

Equal returns whether two WorkflowDefinition 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 (*WorkflowDefinition) GetQueryDefinitions added in v1.27.0

func (x *WorkflowDefinition) GetQueryDefinitions() []*WorkflowInteractionDefinition

func (*WorkflowDefinition) GetSignalDefinitions added in v1.27.0

func (x *WorkflowDefinition) GetSignalDefinitions() []*WorkflowInteractionDefinition

func (*WorkflowDefinition) GetType added in v1.27.0

func (x *WorkflowDefinition) GetType() string

func (*WorkflowDefinition) GetUpdateDefinitions added in v1.27.0

func (x *WorkflowDefinition) GetUpdateDefinitions() []*WorkflowInteractionDefinition

func (*WorkflowDefinition) Marshal added in v1.27.0

func (val *WorkflowDefinition) Marshal() ([]byte, error)

Marshal an object of type WorkflowDefinition to the protobuf v3 wire format

func (*WorkflowDefinition) ProtoMessage added in v1.27.0

func (*WorkflowDefinition) ProtoMessage()

func (*WorkflowDefinition) ProtoReflect added in v1.27.0

func (x *WorkflowDefinition) ProtoReflect() protoreflect.Message

func (*WorkflowDefinition) Reset added in v1.27.0

func (x *WorkflowDefinition) Reset()

func (*WorkflowDefinition) Size added in v1.27.0

func (val *WorkflowDefinition) Size() int

Size returns the size of the object, in bytes, once serialized

func (*WorkflowDefinition) String added in v1.27.0

func (x *WorkflowDefinition) String() string

func (*WorkflowDefinition) Unmarshal added in v1.27.0

func (val *WorkflowDefinition) Unmarshal(buf []byte) error

Unmarshal an object of type WorkflowDefinition from the protobuf v3 wire format

type WorkflowInteractionDefinition added in v1.27.0

type WorkflowInteractionDefinition struct {

	// An optional name for the handler. If missing, it represents
	// a dynamic handler that processes any interactions not handled by others.
	// There is at most one dynamic handler per workflow and interaction kind.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// An optional interaction description provided by the application.
	// By convention, external tools may interpret its first part,
	// i.e., ending with a line break, as a summary of the description.
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

(-- api-linter: core::0123::resource-annotation=disabled

aip.dev/not-precedent: The `name` field is optional. --)

(-- api-linter: core::0203::optional=disabled --)

func (*WorkflowInteractionDefinition) Descriptor deprecated added in v1.27.0

func (*WorkflowInteractionDefinition) Descriptor() ([]byte, []int)

Deprecated: Use WorkflowInteractionDefinition.ProtoReflect.Descriptor instead.

func (*WorkflowInteractionDefinition) Equal added in v1.27.0

func (this *WorkflowInteractionDefinition) Equal(that interface{}) bool

Equal returns whether two WorkflowInteractionDefinition 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 (*WorkflowInteractionDefinition) GetDescription added in v1.27.0

func (x *WorkflowInteractionDefinition) GetDescription() string

func (*WorkflowInteractionDefinition) GetName added in v1.27.0

func (*WorkflowInteractionDefinition) Marshal added in v1.27.0

func (val *WorkflowInteractionDefinition) Marshal() ([]byte, error)

Marshal an object of type WorkflowInteractionDefinition to the protobuf v3 wire format

func (*WorkflowInteractionDefinition) ProtoMessage added in v1.27.0

func (*WorkflowInteractionDefinition) ProtoMessage()

func (*WorkflowInteractionDefinition) ProtoReflect added in v1.27.0

func (*WorkflowInteractionDefinition) Reset added in v1.27.0

func (x *WorkflowInteractionDefinition) Reset()

func (*WorkflowInteractionDefinition) Size added in v1.27.0

func (val *WorkflowInteractionDefinition) Size() int

Size returns the size of the object, in bytes, once serialized

func (*WorkflowInteractionDefinition) String added in v1.27.0

func (*WorkflowInteractionDefinition) Unmarshal added in v1.27.0

func (val *WorkflowInteractionDefinition) Unmarshal(buf []byte) error

Unmarshal an object of type WorkflowInteractionDefinition from the protobuf v3 wire format

type WorkflowMetadata added in v1.27.0

type WorkflowMetadata struct {

	// Metadata provided at declaration or creation time.
	Definition *WorkflowDefinition `protobuf:"bytes,1,opt,name=definition,proto3" json:"definition,omitempty"`
	// Current long-form details of the workflow's state. This is used by user interfaces to show
	// long-form text. This text may be formatted by the user interface.
	CurrentDetails string `protobuf:"bytes,2,opt,name=current_details,json=currentDetails,proto3" json:"current_details,omitempty"`
	// contains filtered or unexported fields
}

The name of the query to retrieve this information is `__temporal_workflow_metadata`.

func (*WorkflowMetadata) Descriptor deprecated added in v1.27.0

func (*WorkflowMetadata) Descriptor() ([]byte, []int)

Deprecated: Use WorkflowMetadata.ProtoReflect.Descriptor instead.

func (*WorkflowMetadata) Equal added in v1.27.0

func (this *WorkflowMetadata) Equal(that interface{}) bool

Equal returns whether two WorkflowMetadata 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 (*WorkflowMetadata) GetCurrentDetails added in v1.34.0

func (x *WorkflowMetadata) GetCurrentDetails() string

func (*WorkflowMetadata) GetDefinition added in v1.27.0

func (x *WorkflowMetadata) GetDefinition() *WorkflowDefinition

func (*WorkflowMetadata) Marshal added in v1.27.0

func (val *WorkflowMetadata) Marshal() ([]byte, error)

Marshal an object of type WorkflowMetadata to the protobuf v3 wire format

func (*WorkflowMetadata) ProtoMessage added in v1.27.0

func (*WorkflowMetadata) ProtoMessage()

func (*WorkflowMetadata) ProtoReflect added in v1.27.0

func (x *WorkflowMetadata) ProtoReflect() protoreflect.Message

func (*WorkflowMetadata) Reset added in v1.27.0

func (x *WorkflowMetadata) Reset()

func (*WorkflowMetadata) Size added in v1.27.0

func (val *WorkflowMetadata) Size() int

Size returns the size of the object, in bytes, once serialized

func (*WorkflowMetadata) String added in v1.27.0

func (x *WorkflowMetadata) String() string

func (*WorkflowMetadata) Unmarshal added in v1.27.0

func (val *WorkflowMetadata) Unmarshal(buf []byte) error

Unmarshal an object of type WorkflowMetadata from the protobuf v3 wire format

type WorkflowTaskCompletedMetadata

type WorkflowTaskCompletedMetadata struct {

	// Internal flags used by the core SDK. SDKs using flags must comply with the following behavior:
	//
	// During replay:
	//   - If a flag is not recognized (value is too high or not defined), it must fail the workflow
	//     task.
	//   - If a flag is recognized, it is stored in a set of used flags for the run. Code checks for
	//     that flag during and after this WFT are allowed to assume that the flag is present.
	//   - If a code check for a flag does not find the flag in the set of used flags, it must take
	//     the branch corresponding to the absence of that flag.
	//
	// During non-replay execution of new WFTs:
	//   - The SDK is free to use all flags it knows about. It must record any newly-used (IE: not
	//     previously recorded) flags when completing the WFT.
	//
	// SDKs which are too old to even know about this field at all are considered to produce
	// undefined behavior if they replay workflows which used this mechanism.
	//
	// (-- api-linter: core::0141::forbidden-types=disabled
	//
	//	aip.dev/not-precedent: These really shouldn't have negative values. --)
	CoreUsedFlags []uint32 `protobuf:"varint,1,rep,packed,name=core_used_flags,json=coreUsedFlags,proto3" json:"core_used_flags,omitempty"`
	// Flags used by the SDK lang. No attempt is made to distinguish between different SDK languages
	// here as processing a workflow with a different language than the one which authored it is
	// already undefined behavior. See `core_used_patches` for more.
	//
	// (-- api-linter: core::0141::forbidden-types=disabled
	//
	//	aip.dev/not-precedent: These really shouldn't have negative values. --)
	LangUsedFlags []uint32 `protobuf:"varint,2,rep,packed,name=lang_used_flags,json=langUsedFlags,proto3" json:"lang_used_flags,omitempty"`
	// Name of the SDK that processed the task. This is usually something like "temporal-go" and is
	// usually the same as client-name gRPC header. This should only be set if its value changed
	// since the last time recorded on the workflow (or be set on the first task).
	//
	// (-- api-linter: core::0122::name-suffix=disabled
	//
	//	aip.dev/not-precedent: We're ok with a name suffix here. --)
	SdkName string `protobuf:"bytes,3,opt,name=sdk_name,json=sdkName,proto3" json:"sdk_name,omitempty"`
	// Version of the SDK that processed the task. This is usually something like "1.20.0" and is
	// usually the same as client-version gRPC header. This should only be set if its value changed
	// since the last time recorded on the workflow (or be set on the first task).
	SdkVersion string `protobuf:"bytes,4,opt,name=sdk_version,json=sdkVersion,proto3" json:"sdk_version,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowTaskCompletedMetadata) Descriptor deprecated

func (*WorkflowTaskCompletedMetadata) Descriptor() ([]byte, []int)

Deprecated: Use WorkflowTaskCompletedMetadata.ProtoReflect.Descriptor instead.

func (*WorkflowTaskCompletedMetadata) Equal

func (this *WorkflowTaskCompletedMetadata) Equal(that interface{}) bool

Equal returns whether two WorkflowTaskCompletedMetadata 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 (*WorkflowTaskCompletedMetadata) GetCoreUsedFlags

func (x *WorkflowTaskCompletedMetadata) GetCoreUsedFlags() []uint32

func (*WorkflowTaskCompletedMetadata) GetLangUsedFlags

func (x *WorkflowTaskCompletedMetadata) GetLangUsedFlags() []uint32

func (*WorkflowTaskCompletedMetadata) GetSdkName added in v1.24.0

func (x *WorkflowTaskCompletedMetadata) GetSdkName() string

func (*WorkflowTaskCompletedMetadata) GetSdkVersion added in v1.24.0

func (x *WorkflowTaskCompletedMetadata) GetSdkVersion() string

func (*WorkflowTaskCompletedMetadata) Marshal

func (val *WorkflowTaskCompletedMetadata) Marshal() ([]byte, error)

Marshal an object of type WorkflowTaskCompletedMetadata to the protobuf v3 wire format

func (*WorkflowTaskCompletedMetadata) ProtoMessage

func (*WorkflowTaskCompletedMetadata) ProtoMessage()

func (*WorkflowTaskCompletedMetadata) ProtoReflect added in v1.26.1

func (*WorkflowTaskCompletedMetadata) Reset

func (x *WorkflowTaskCompletedMetadata) Reset()

func (*WorkflowTaskCompletedMetadata) Size

func (val *WorkflowTaskCompletedMetadata) Size() int

Size returns the size of the object, in bytes, once serialized

func (*WorkflowTaskCompletedMetadata) String

func (*WorkflowTaskCompletedMetadata) Unmarshal

func (val *WorkflowTaskCompletedMetadata) Unmarshal(buf []byte) error

Unmarshal an object of type WorkflowTaskCompletedMetadata from the protobuf v3 wire format

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL