hanzoai/tasks
2
0
Fork 0
mirror of https://github.com/hanzoai/tasks.git synced 2026-10-04 02:04:03 +00:00
Code Issues Packages Projects Releases Wiki Activity
Files
release/v1.29.x
tasks/api/archiver/v1/message.pb.go
T
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

456 lines
17 KiB
Go
Raw Permalink Blame History

// Code generated by protoc-gen-go. DO NOT EDIT.
// plugins:
// protoc-gen-go
// protoc
// source: temporal/server/api/archiver/v1/message.proto
package archiver
import (
reflect "reflect"
sync "sync"
unsafe "unsafe"
v12 "go.temporal.io/api/common/v1"
v11 "go.temporal.io/api/enums/v1"
v1 "go.temporal.io/api/history/v1"
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
durationpb "google.golang.org/protobuf/types/known/durationpb"
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 HistoryBlobHeader struct {
state protoimpl.MessageState `protogen:"open.v1"`
Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
NamespaceId string `protobuf:"bytes,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
WorkflowId string `protobuf:"bytes,3,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
RunId string `protobuf:"bytes,4,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
IsLast bool `protobuf:"varint,5,opt,name=is_last,json=isLast,proto3" json:"is_last,omitempty"`
FirstFailoverVersion int64 `protobuf:"varint,6,opt,name=first_failover_version,json=firstFailoverVersion,proto3" json:"first_failover_version,omitempty"`
LastFailoverVersion int64 `protobuf:"varint,7,opt,name=last_failover_version,json=lastFailoverVersion,proto3" json:"last_failover_version,omitempty"`
FirstEventId int64 `protobuf:"varint,8,opt,name=first_event_id,json=firstEventId,proto3" json:"first_event_id,omitempty"`
LastEventId int64 `protobuf:"varint,9,opt,name=last_event_id,json=lastEventId,proto3" json:"last_event_id,omitempty"`
EventCount int64 `protobuf:"varint,10,opt,name=event_count,json=eventCount,proto3" json:"event_count,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *HistoryBlobHeader) Reset() {
*x = HistoryBlobHeader{}
mi := &file_temporal_server_api_archiver_v1_message_proto_msgTypes[0]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *HistoryBlobHeader) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*HistoryBlobHeader) ProtoMessage() {}
func (x *HistoryBlobHeader) ProtoReflect() protoreflect.Message {
mi := &file_temporal_server_api_archiver_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 HistoryBlobHeader.ProtoReflect.Descriptor instead.
func (*HistoryBlobHeader) Descriptor() ([]byte, []int) {
return file_temporal_server_api_archiver_v1_message_proto_rawDescGZIP(), []int{0}
}
func (x *HistoryBlobHeader) GetNamespace() string {
if x != nil {
return x.Namespace
}
return ""
}
func (x *HistoryBlobHeader) GetNamespaceId() string {
if x != nil {
return x.NamespaceId
}
return ""
}
func (x *HistoryBlobHeader) GetWorkflowId() string {
if x != nil {
return x.WorkflowId
}
return ""
}
func (x *HistoryBlobHeader) GetRunId() string {
if x != nil {
return x.RunId
}
return ""
}
func (x *HistoryBlobHeader) GetIsLast() bool {
if x != nil {
return x.IsLast
}
return false
}
func (x *HistoryBlobHeader) GetFirstFailoverVersion() int64 {
if x != nil {
return x.FirstFailoverVersion
}
return 0
}
func (x *HistoryBlobHeader) GetLastFailoverVersion() int64 {
if x != nil {
return x.LastFailoverVersion
}
return 0
}
func (x *HistoryBlobHeader) GetFirstEventId() int64 {
if x != nil {
return x.FirstEventId
}
return 0
}
func (x *HistoryBlobHeader) GetLastEventId() int64 {
if x != nil {
return x.LastEventId
}
return 0
}
func (x *HistoryBlobHeader) GetEventCount() int64 {
if x != nil {
return x.EventCount
}
return 0
}
type HistoryBlob struct {
state protoimpl.MessageState `protogen:"open.v1"`
Header *HistoryBlobHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
Body []*v1.History `protobuf:"bytes,2,rep,name=body,proto3" json:"body,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *HistoryBlob) Reset() {
*x = HistoryBlob{}
mi := &file_temporal_server_api_archiver_v1_message_proto_msgTypes[1]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *HistoryBlob) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*HistoryBlob) ProtoMessage() {}
func (x *HistoryBlob) ProtoReflect() protoreflect.Message {
mi := &file_temporal_server_api_archiver_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 HistoryBlob.ProtoReflect.Descriptor instead.
func (*HistoryBlob) Descriptor() ([]byte, []int) {
return file_temporal_server_api_archiver_v1_message_proto_rawDescGZIP(), []int{1}
}
func (x *HistoryBlob) GetHeader() *HistoryBlobHeader {
if x != nil {
return x.Header
}
return nil
}
func (x *HistoryBlob) GetBody() []*v1.History {
if x != nil {
return x.Body
}
return nil
}
// VisibilityRecord is a single workflow visibility record in archive.
type VisibilityRecord struct {
state protoimpl.MessageState `protogen:"open.v1"`
NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
WorkflowId string `protobuf:"bytes,3,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
RunId string `protobuf:"bytes,4,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
WorkflowTypeName string `protobuf:"bytes,5,opt,name=workflow_type_name,json=workflowTypeName,proto3" json:"workflow_type_name,omitempty"`
StartTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
ExecutionTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=execution_time,json=executionTime,proto3" json:"execution_time,omitempty"`
CloseTime *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=close_time,json=closeTime,proto3" json:"close_time,omitempty"`
Status v11.WorkflowExecutionStatus `protobuf:"varint,9,opt,name=status,proto3,enum=temporal.api.enums.v1.WorkflowExecutionStatus" json:"status,omitempty"`
HistoryLength int64 `protobuf:"varint,10,opt,name=history_length,json=historyLength,proto3" json:"history_length,omitempty"`
Memo *v12.Memo `protobuf:"bytes,11,opt,name=memo,proto3" json:"memo,omitempty"`
SearchAttributes map[string]string `protobuf:"bytes,12,rep,name=search_attributes,json=searchAttributes,proto3" json:"search_attributes,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
HistoryArchivalUri string `protobuf:"bytes,13,opt,name=history_archival_uri,json=historyArchivalUri,proto3" json:"history_archival_uri,omitempty"`
ExecutionDuration *durationpb.Duration `protobuf:"bytes,14,opt,name=execution_duration,json=executionDuration,proto3" json:"execution_duration,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *VisibilityRecord) Reset() {
*x = VisibilityRecord{}
mi := &file_temporal_server_api_archiver_v1_message_proto_msgTypes[2]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *VisibilityRecord) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*VisibilityRecord) ProtoMessage() {}
func (x *VisibilityRecord) ProtoReflect() protoreflect.Message {
mi := &file_temporal_server_api_archiver_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 VisibilityRecord.ProtoReflect.Descriptor instead.
func (*VisibilityRecord) Descriptor() ([]byte, []int) {
return file_temporal_server_api_archiver_v1_message_proto_rawDescGZIP(), []int{2}
}
func (x *VisibilityRecord) GetNamespaceId() string {
if x != nil {
return x.NamespaceId
}
return ""
}
func (x *VisibilityRecord) GetNamespace() string {
if x != nil {
return x.Namespace
}
return ""
}
func (x *VisibilityRecord) GetWorkflowId() string {
if x != nil {
return x.WorkflowId
}
return ""
}
func (x *VisibilityRecord) GetRunId() string {
if x != nil {
return x.RunId
}
return ""
}
func (x *VisibilityRecord) GetWorkflowTypeName() string {
if x != nil {
return x.WorkflowTypeName
}
return ""
}
func (x *VisibilityRecord) GetStartTime() *timestamppb.Timestamp {
if x != nil {
return x.StartTime
}
return nil
}
func (x *VisibilityRecord) GetExecutionTime() *timestamppb.Timestamp {
if x != nil {
return x.ExecutionTime
}
return nil
}
func (x *VisibilityRecord) GetCloseTime() *timestamppb.Timestamp {
if x != nil {
return x.CloseTime
}
return nil
}
func (x *VisibilityRecord) GetStatus() v11.WorkflowExecutionStatus {
if x != nil {
return x.Status
}
return v11.WorkflowExecutionStatus(0)
}
func (x *VisibilityRecord) GetHistoryLength() int64 {
if x != nil {
return x.HistoryLength
}
return 0
}
func (x *VisibilityRecord) GetMemo() *v12.Memo {
if x != nil {
return x.Memo
}
return nil
}
func (x *VisibilityRecord) GetSearchAttributes() map[string]string {
if x != nil {
return x.SearchAttributes
}
return nil
}
func (x *VisibilityRecord) GetHistoryArchivalUri() string {
if x != nil {
return x.HistoryArchivalUri
}
return ""
}
func (x *VisibilityRecord) GetExecutionDuration() *durationpb.Duration {
if x != nil {
return x.ExecutionDuration
}
return nil
}
var File_temporal_server_api_archiver_v1_message_proto protoreflect.FileDescriptor
const file_temporal_server_api_archiver_v1_message_proto_rawDesc = "" +
"\n" +
"-temporal/server/api/archiver/v1/message.proto\x12\x1ftemporal.server.api.archiver.v1\x1a\x1egoogle/protobuf/duration.proto\x1a\x1fgoogle/protobuf/timestamp.proto\x1a$temporal/api/common/v1/message.proto\x1a%temporal/api/history/v1/message.proto\x1a$temporal/api/enums/v1/workflow.proto\"\xfa\x02\n" +
"\x11HistoryBlobHeader\x12\x1c\n" +
"\tnamespace\x18\x01 \x01(\tR\tnamespace\x12!\n" +
"\fnamespace_id\x18\x02 \x01(\tR\vnamespaceId\x12\x1f\n" +
"\vworkflow_id\x18\x03 \x01(\tR\n" +
"workflowId\x12\x15\n" +
"\x06run_id\x18\x04 \x01(\tR\x05runId\x12\x17\n" +
"\ais_last\x18\x05 \x01(\bR\x06isLast\x124\n" +
"\x16first_failover_version\x18\x06 \x01(\x03R\x14firstFailoverVersion\x122\n" +
"\x15last_failover_version\x18\a \x01(\x03R\x13lastFailoverVersion\x12$\n" +
"\x0efirst_event_id\x18\b \x01(\x03R\ffirstEventId\x12\"\n" +
"\rlast_event_id\x18\t \x01(\x03R\vlastEventId\x12\x1f\n" +
"\vevent_count\x18\n" +
" \x01(\x03R\n" +
"eventCount\"\x8f\x01\n" +
"\vHistoryBlob\x12J\n" +
"\x06header\x18\x01 \x01(\v22.temporal.server.api.archiver.v1.HistoryBlobHeaderR\x06header\x124\n" +
"\x04body\x18\x02 \x03(\v2 .temporal.api.history.v1.HistoryR\x04body\"\xca\x06\n" +
"\x10VisibilityRecord\x12!\n" +
"\fnamespace_id\x18\x01 \x01(\tR\vnamespaceId\x12\x1c\n" +
"\tnamespace\x18\x02 \x01(\tR\tnamespace\x12\x1f\n" +
"\vworkflow_id\x18\x03 \x01(\tR\n" +
"workflowId\x12\x15\n" +
"\x06run_id\x18\x04 \x01(\tR\x05runId\x12,\n" +
"\x12workflow_type_name\x18\x05 \x01(\tR\x10workflowTypeName\x129\n" +
"\n" +
"start_time\x18\x06 \x01(\v2\x1a.google.protobuf.TimestampR\tstartTime\x12A\n" +
"\x0eexecution_time\x18\a \x01(\v2\x1a.google.protobuf.TimestampR\rexecutionTime\x129\n" +
"\n" +
"close_time\x18\b \x01(\v2\x1a.google.protobuf.TimestampR\tcloseTime\x12F\n" +
"\x06status\x18\t \x01(\x0e2..temporal.api.enums.v1.WorkflowExecutionStatusR\x06status\x12%\n" +
"\x0ehistory_length\x18\n" +
" \x01(\x03R\rhistoryLength\x120\n" +
"\x04memo\x18\v \x01(\v2\x1c.temporal.api.common.v1.MemoR\x04memo\x12t\n" +
"\x11search_attributes\x18\f \x03(\v2G.temporal.server.api.archiver.v1.VisibilityRecord.SearchAttributesEntryR\x10searchAttributes\x120\n" +
"\x14history_archival_uri\x18\r \x01(\tR\x12historyArchivalUri\x12H\n" +
"\x12execution_duration\x18\x0e \x01(\v2\x19.google.protobuf.DurationR\x11executionDuration\x1aC\n" +
"\x15SearchAttributesEntry\x12\x10\n" +
"\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n" +
"\x05value\x18\x02 \x01(\tR\x05value:\x028\x01B0Z.go.temporal.io/server/api/archiver/v1;archiverb\x06proto3"
var (
file_temporal_server_api_archiver_v1_message_proto_rawDescOnce sync.Once
file_temporal_server_api_archiver_v1_message_proto_rawDescData []byte
)
func file_temporal_server_api_archiver_v1_message_proto_rawDescGZIP() []byte {
file_temporal_server_api_archiver_v1_message_proto_rawDescOnce.Do(func() {
file_temporal_server_api_archiver_v1_message_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_temporal_server_api_archiver_v1_message_proto_rawDesc), len(file_temporal_server_api_archiver_v1_message_proto_rawDesc)))
})
return file_temporal_server_api_archiver_v1_message_proto_rawDescData
}
var file_temporal_server_api_archiver_v1_message_proto_msgTypes = make([]protoimpl.MessageInfo, 4)
var file_temporal_server_api_archiver_v1_message_proto_goTypes = []any{
(*HistoryBlobHeader)(nil), // 0: temporal.server.api.archiver.v1.HistoryBlobHeader
(*HistoryBlob)(nil), // 1: temporal.server.api.archiver.v1.HistoryBlob
(*VisibilityRecord)(nil), // 2: temporal.server.api.archiver.v1.VisibilityRecord
nil, // 3: temporal.server.api.archiver.v1.VisibilityRecord.SearchAttributesEntry
(*v1.History)(nil), // 4: temporal.api.history.v1.History
(*timestamppb.Timestamp)(nil), // 5: google.protobuf.Timestamp
(v11.WorkflowExecutionStatus)(0), // 6: temporal.api.enums.v1.WorkflowExecutionStatus
(*v12.Memo)(nil), // 7: temporal.api.common.v1.Memo
(*durationpb.Duration)(nil), // 8: google.protobuf.Duration
}
var file_temporal_server_api_archiver_v1_message_proto_depIdxs = []int32{
0, // 0: temporal.server.api.archiver.v1.HistoryBlob.header:type_name -> temporal.server.api.archiver.v1.HistoryBlobHeader
4, // 1: temporal.server.api.archiver.v1.HistoryBlob.body:type_name -> temporal.api.history.v1.History
5, // 2: temporal.server.api.archiver.v1.VisibilityRecord.start_time:type_name -> google.protobuf.Timestamp
5, // 3: temporal.server.api.archiver.v1.VisibilityRecord.execution_time:type_name -> google.protobuf.Timestamp
5, // 4: temporal.server.api.archiver.v1.VisibilityRecord.close_time:type_name -> google.protobuf.Timestamp
6, // 5: temporal.server.api.archiver.v1.VisibilityRecord.status:type_name -> temporal.api.enums.v1.WorkflowExecutionStatus
7, // 6: temporal.server.api.archiver.v1.VisibilityRecord.memo:type_name -> temporal.api.common.v1.Memo
3, // 7: temporal.server.api.archiver.v1.VisibilityRecord.search_attributes:type_name -> temporal.server.api.archiver.v1.VisibilityRecord.SearchAttributesEntry
8, // 8: temporal.server.api.archiver.v1.VisibilityRecord.execution_duration:type_name -> google.protobuf.Duration
9, // [9:9] is the sub-list for method output_type
9, // [9:9] is the sub-list for method input_type
9, // [9:9] is the sub-list for extension type_name
9, // [9:9] is the sub-list for extension extendee
0, // [0:9] is the sub-list for field type_name
}
func init() { file_temporal_server_api_archiver_v1_message_proto_init() }
func file_temporal_server_api_archiver_v1_message_proto_init() {
if File_temporal_server_api_archiver_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_archiver_v1_message_proto_rawDesc), len(file_temporal_server_api_archiver_v1_message_proto_rawDesc)),
NumEnums: 0,
NumMessages: 4,
NumExtensions: 0,
NumServices: 0,
},
GoTypes: file_temporal_server_api_archiver_v1_message_proto_goTypes,
DependencyIndexes: file_temporal_server_api_archiver_v1_message_proto_depIdxs,
MessageInfos: file_temporal_server_api_archiver_v1_message_proto_msgTypes,
}.Build()
File_temporal_server_api_archiver_v1_message_proto = out.File
file_temporal_server_api_archiver_v1_message_proto_goTypes = nil
file_temporal_server_api_archiver_v1_message_proto_depIdxs = nil
}
Reference in New Issue View Git Blame Copy Permalink