commonspb

package
v1.23.1 Latest Latest
Warning

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

 Go to latest Published: Apr 30, 2024 License: MIT Imports: 6 Imported by: 0

Documentation

Overview

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

Index

Constants

This section is empty.

Variables

View Source 
var File_temporal_server_api_common_v1_dlq_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type HistoryDLQKey 

type HistoryDLQKey struct {

	// task_category is the category of the task. The default values are defined in the TaskCategory enum. However, there
	// may also be other categories registered at runtime with the history/tasks package. As a result, the category here
	// is an integer instead of an enum to support both the default values and custom values.
	TaskCategory int32 `protobuf:"varint,1,opt,name=task_category,json=taskCategory,proto3" json:"task_category,omitempty"`
	// source_cluster and target_cluster must both be non-empty. For non-cross DC tasks, i.e. non-replication tasks,
	// they should be the same. The reason for this is that we may support wildcard clusters in the future, and we want
	// to differentiate between queues which go from one cluster to all other clusters, and queues which don't leave the
	// current cluster.
	SourceCluster string `protobuf:"bytes,2,opt,name=source_cluster,json=sourceCluster,proto3" json:"source_cluster,omitempty"`
	TargetCluster string `protobuf:"bytes,3,opt,name=target_cluster,json=targetCluster,proto3" json:"target_cluster,omitempty"`
	// contains filtered or unexported fields
}

HistoryDLQKey is a compound key that identifies a history DLQ.

func (*HistoryDLQKey) Descriptor deprecated 

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

Deprecated: Use HistoryDLQKey.ProtoReflect.Descriptor instead.

func (*HistoryDLQKey) Equal 

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

Equal returns whether two HistoryDLQKey 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 (*HistoryDLQKey) GetSourceCluster 

func (x *HistoryDLQKey) GetSourceCluster() string

func (*HistoryDLQKey) GetTargetCluster 

func (x *HistoryDLQKey) GetTargetCluster() string

func (*HistoryDLQKey) GetTaskCategory 

func (x *HistoryDLQKey) GetTaskCategory() int32

func (*HistoryDLQKey) Marshal 

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

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

func (*HistoryDLQKey) ProtoMessage 

func (*HistoryDLQKey) ProtoMessage()

func (*HistoryDLQKey) ProtoReflect 

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

func (*HistoryDLQKey) Reset 

func (x *HistoryDLQKey) Reset()

func (*HistoryDLQKey) Size 

func (val *HistoryDLQKey) Size() int

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

func (*HistoryDLQKey) String 

func (x *HistoryDLQKey) String() string

func (*HistoryDLQKey) Unmarshal 

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

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

type HistoryDLQTask 

type HistoryDLQTask struct {
	Metadata *HistoryDLQTaskMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// This is named payload to prevent stuttering (e.g. task.Task).
	Payload *HistoryTask `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

HistoryDLQTask is a history task that has been moved to the DLQ, so it also has a message ID (index within that queue).

func (*HistoryDLQTask) Descriptor deprecated 

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

Deprecated: Use HistoryDLQTask.ProtoReflect.Descriptor instead.

func (*HistoryDLQTask) Equal 

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

Equal returns whether two HistoryDLQTask 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 (*HistoryDLQTask) GetMetadata 

func (x *HistoryDLQTask) GetMetadata() *HistoryDLQTaskMetadata

func (*HistoryDLQTask) GetPayload 

func (x *HistoryDLQTask) GetPayload() *HistoryTask

func (*HistoryDLQTask) Marshal 

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

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

func (*HistoryDLQTask) ProtoMessage 

func (*HistoryDLQTask) ProtoMessage()

func (*HistoryDLQTask) ProtoReflect 

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

func (*HistoryDLQTask) Reset 

func (x *HistoryDLQTask) Reset()

func (*HistoryDLQTask) Size 

func (val *HistoryDLQTask) Size() int

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

func (*HistoryDLQTask) String 

func (x *HistoryDLQTask) String() string

func (*HistoryDLQTask) Unmarshal 

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

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

type HistoryDLQTaskMetadata 

type HistoryDLQTaskMetadata struct {

	// message_id is the zero-indexed sequence number of the message in the queue that contains this history task.
	MessageId int64 `protobuf:"varint,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	// contains filtered or unexported fields
}

func (*HistoryDLQTaskMetadata) Descriptor deprecated 

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

Deprecated: Use HistoryDLQTaskMetadata.ProtoReflect.Descriptor instead.

func (*HistoryDLQTaskMetadata) Equal 

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

Equal returns whether two HistoryDLQTaskMetadata 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 (*HistoryDLQTaskMetadata) GetMessageId 

func (x *HistoryDLQTaskMetadata) GetMessageId() int64

func (*HistoryDLQTaskMetadata) Marshal 

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

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

func (*HistoryDLQTaskMetadata) ProtoMessage 

func (*HistoryDLQTaskMetadata) ProtoMessage()

func (*HistoryDLQTaskMetadata) ProtoReflect 

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

func (*HistoryDLQTaskMetadata) Reset 

func (x *HistoryDLQTaskMetadata) Reset()

func (*HistoryDLQTaskMetadata) Size 

func (val *HistoryDLQTaskMetadata) Size() int

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

func (*HistoryDLQTaskMetadata) String 

func (x *HistoryDLQTaskMetadata) String() string

func (*HistoryDLQTaskMetadata) Unmarshal 

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

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

type HistoryTask 

type HistoryTask struct {

	// shard_id is included to avoid having to deserialize the task blob.
	ShardId int32        `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	Blob    *v1.DataBlob `protobuf:"bytes,2,opt,name=blob,proto3" json:"blob,omitempty"`
	// contains filtered or unexported fields
}

func (*HistoryTask) Descriptor deprecated 

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

Deprecated: Use HistoryTask.ProtoReflect.Descriptor instead.

func (*HistoryTask) Equal 

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

Equal returns whether two HistoryTask 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 (*HistoryTask) GetBlob 

func (x *HistoryTask) GetBlob() *v1.DataBlob

func (*HistoryTask) GetShardId 

func (x *HistoryTask) GetShardId() int32

func (*HistoryTask) Marshal 

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

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

func (*HistoryTask) ProtoMessage 

func (*HistoryTask) ProtoMessage()

func (*HistoryTask) ProtoReflect 

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

func (*HistoryTask) Reset 

func (x *HistoryTask) Reset()

func (*HistoryTask) Size 

func (val *HistoryTask) Size() int

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

func (*HistoryTask) String 

func (x *HistoryTask) String() string

func (*HistoryTask) Unmarshal 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.