mirror of
https://github.com/hanzoai/tasks.git
synced 2026-10-04 02:04:03 +00:00
zeekay
40351cce6f
Goes from 135 MB binary with 1153 files importing go.temporal.io and 224
importing google.golang.org/grpc to a 10 MB native binary with ZERO of
either.
Deleted:
- tasks/, tasktests/, service/, chasm/, client/, api/, proto/, tools/
- cmd/tools/, components/, docker/
- schema/{cassandra,elasticsearch,mysql,postgresql,sqlite}/
- 40 tainted common/ subdirs + 7 top-level common files
- tests/testutils (no longer referenced after surviving deps drop common)
New cmd/tasksd (~100 lines) boots tasks.Embed (zap.Node) + http.Server.
New pkg/tasks/embed.go registers ZAP handlers for the SDK opcode surface
(0x0060-0x00A5). Workflow handlers return a 501 "not yet implemented"
envelope; native engine lands behind this contract.
Build: go build ./cmd/tasksd → 10 MB
Vet: go vet ./... → clean
Boot: tasksd --zap-port 9999 --http :7243
Probes: /healthz, /v1/tasks/health → 200
UI: /_/tasks/, / → 200 (embedded Vite bundle)
ZAP: _tasks._tcp on :9999 (mDNS disabled; direct connect)
go.mod: tidy. No go.temporal.io. No google.golang.org/grpc.
456 lines
17 KiB
Go
456 lines
17 KiB
Go
// 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/enums/v1/workflow.proto\x1a%temporal/api/history/v1/message.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
|
|
}
|