task_go_proto

package
v0.0.0-...-c28e036 Latest Latest
Warning

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

 Go to latest Published: Jul 17, 2019 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var FailureType_name = map[int32]string{
	0:  "UNSET_FAILURE_TYPE",
	1:  "UNKNOWN_FAILURE",
	2:  "FILE_MODIFIED_FAILURE",
	3:  "HASH_MISMATCH_FAILURE",
	4:  "PRECONDITION_FAILURE",
	5:  "FILE_NOT_FOUND_FAILURE",
	6:  "PERMISSION_FAILURE",
	7:  "NOT_ACTIVE_JOBRUN",
	8:  "AGENT_UNSUPPORTED_VERSION",
	9:  "SERVICE_UNSUPPORTED_VERSION",
	10: "BLACKLISTED_AGENT_VERSION",
	11: "SOURCE_DIR_NOT_FOUND",
	12: "INVALID_FILE_NAME",
	13: "NOT_SERVICE_INDUCED_UNKNOWN_FAILURE",
}
View Source 
var FailureType_value = map[string]int32{
	"UNSET_FAILURE_TYPE":                  0,
	"UNKNOWN_FAILURE":                     1,
	"FILE_MODIFIED_FAILURE":               2,
	"HASH_MISMATCH_FAILURE":               3,
	"PRECONDITION_FAILURE":                4,
	"FILE_NOT_FOUND_FAILURE":              5,
	"PERMISSION_FAILURE":                  6,
	"NOT_ACTIVE_JOBRUN":                   7,
	"AGENT_UNSUPPORTED_VERSION":           8,
	"SERVICE_UNSUPPORTED_VERSION":         9,
	"BLACKLISTED_AGENT_VERSION":           10,
	"SOURCE_DIR_NOT_FOUND":                11,
	"INVALID_FILE_NAME":                   12,
	"NOT_SERVICE_INDUCED_UNKNOWN_FAILURE": 13,
}
View Source 
var Status_name = map[int32]string{
	0: "UNSET_STATUS",
	1: "READY",
	2: "FAILED",
	3: "SUCCESS",
}
View Source 
var Status_value = map[string]int32{
	"UNSET_STATUS": 0,
	"READY":        1,
	"FAILED":       2,
	"SUCCESS":      3,
}
View Source 
var Type_name = map[int32]string{
	0: "UNSET_TYPE",
	1: "LIST",
	2: "PROCESS_LIST",
	3: "COPY",
	4: "COPY_BUNDLE",
	5: "PROCESS_UNEXPLORED_DIRS",
	6: "DELETE_BUNDLE",
	7: "PROCESS_DELETE_DIRS",
}
View Source 
var Type_value = map[string]int32{
	"UNSET_TYPE":              0,
	"LIST":                    1,
	"PROCESS_LIST":            2,
	"COPY":                    3,
	"COPY_BUNDLE":             4,
	"PROCESS_UNEXPLORED_DIRS": 5,
	"DELETE_BUNDLE":           6,
	"PROCESS_DELETE_DIRS":     7,
}

Functions

This section is empty.

Types

type BundledFile 

type BundledFile struct {
	CopySpec       *CopySpec   `protobuf:"bytes,1,opt,name=copy_spec,json=copySpec,proto3" json:"copy_spec,omitempty"`
	Status         Status      `protobuf:"varint,2,opt,name=status,proto3,enum=cloud_ingest_task.Status" json:"status,omitempty"`
	FailureType    FailureType `` /* 130-byte string literal not displayed */
	FailureMessage string      `protobuf:"bytes,4,opt,name=failure_message,json=failureMessage,proto3" json:"failure_message,omitempty"`
	// The copy_log should be populated by the Agent in the resp_spec within the
	// TaskRespMsg. The DCP should clear this field before persisting this spec to
	// Spanner.
	CopyLog              *CopyLog `protobuf:"bytes,5,opt,name=copy_log,json=copyLog,proto3" json:"copy_log,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Contains the information for a single file within a Copy Bundle task.

func (*BundledFile) Descriptor 

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

func (*BundledFile) GetCopyLog 

func (m *BundledFile) GetCopyLog() *CopyLog

func (*BundledFile) GetCopySpec 

func (m *BundledFile) GetCopySpec() *CopySpec

func (*BundledFile) GetFailureMessage 

func (m *BundledFile) GetFailureMessage() string

func (*BundledFile) GetFailureType 

func (m *BundledFile) GetFailureType() FailureType

func (*BundledFile) GetStatus 

func (m *BundledFile) GetStatus() Status

func (*BundledFile) ProtoMessage 

func (*BundledFile) ProtoMessage()

func (*BundledFile) Reset 

func (m *BundledFile) Reset()

func (*BundledFile) String 

func (m *BundledFile) String() string

func (*BundledFile) XXX_DiscardUnknown 

func (m *BundledFile) XXX_DiscardUnknown()

func (*BundledFile) XXX_Marshal 

func (m *BundledFile) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BundledFile) XXX_Merge 

func (m *BundledFile) XXX_Merge(src proto.Message)

func (*BundledFile) XXX_Size 

func (m *BundledFile) XXX_Size() int

func (*BundledFile) XXX_Unmarshal 

func (m *BundledFile) XXX_Unmarshal(b []byte) error

type BundledFileLog 

type BundledFileLog struct {
	Status               Status      `protobuf:"varint,1,opt,name=status,proto3,enum=cloud_ingest_task.Status" json:"status,omitempty"`
	FailureType          FailureType `` /* 130-byte string literal not displayed */
	FailureMessage       string      `protobuf:"bytes,3,opt,name=failure_message,json=failureMessage,proto3" json:"failure_message,omitempty"`
	CopyLog              *CopyLog    `protobuf:"bytes,4,opt,name=copy_log,json=copyLog,proto3" json:"copy_log,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*BundledFileLog) Descriptor 

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

func (*BundledFileLog) GetCopyLog 

func (m *BundledFileLog) GetCopyLog() *CopyLog

func (*BundledFileLog) GetFailureMessage 

func (m *BundledFileLog) GetFailureMessage() string

func (*BundledFileLog) GetFailureType 

func (m *BundledFileLog) GetFailureType() FailureType

func (*BundledFileLog) GetStatus 

func (m *BundledFileLog) GetStatus() Status

func (*BundledFileLog) ProtoMessage 

func (*BundledFileLog) ProtoMessage()

func (*BundledFileLog) Reset 

func (m *BundledFileLog) Reset()

func (*BundledFileLog) String 

func (m *BundledFileLog) String() string

func (*BundledFileLog) XXX_DiscardUnknown 

func (m *BundledFileLog) XXX_DiscardUnknown()

func (*BundledFileLog) XXX_Marshal 

func (m *BundledFileLog) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BundledFileLog) XXX_Merge 

func (m *BundledFileLog) XXX_Merge(src proto.Message)

func (*BundledFileLog) XXX_Size 

func (m *BundledFileLog) XXX_Size() int

func (*BundledFileLog) XXX_Unmarshal 

func (m *BundledFileLog) XXX_Unmarshal(b []byte) error

type BundledObject 

type BundledObject struct {
	DeleteObjectSpec     *DeleteObjectSpec `protobuf:"bytes,1,opt,name=delete_object_spec,json=deleteObjectSpec,proto3" json:"delete_object_spec,omitempty"`
	Status               Status            `protobuf:"varint,2,opt,name=status,proto3,enum=cloud_ingest_task.Status" json:"status,omitempty"`
	FailureType          FailureType       `` /* 130-byte string literal not displayed */
	FailureMessage       string            `protobuf:"bytes,4,opt,name=failure_message,json=failureMessage,proto3" json:"failure_message,omitempty"`
	BundledObjectLog     *BundledObjectLog `protobuf:"bytes,5,opt,name=bundled_object_log,json=bundledObjectLog,proto3" json:"bundled_object_log,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Contains the information for a single object within a Delete Bundle task.

func (*BundledObject) Descriptor 

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

func (*BundledObject) GetBundledObjectLog 

func (m *BundledObject) GetBundledObjectLog() *BundledObjectLog

func (*BundledObject) GetDeleteObjectSpec 

func (m *BundledObject) GetDeleteObjectSpec() *DeleteObjectSpec

func (*BundledObject) GetFailureMessage 

func (m *BundledObject) GetFailureMessage() string

func (*BundledObject) GetFailureType 

func (m *BundledObject) GetFailureType() FailureType

func (*BundledObject) GetStatus 

func (m *BundledObject) GetStatus() Status

func (*BundledObject) ProtoMessage 

func (*BundledObject) ProtoMessage()

func (*BundledObject) Reset 

func (m *BundledObject) Reset()

func (*BundledObject) String 

func (m *BundledObject) String() string

func (*BundledObject) XXX_DiscardUnknown 

func (m *BundledObject) XXX_DiscardUnknown()

func (*BundledObject) XXX_Marshal 

func (m *BundledObject) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BundledObject) XXX_Merge 

func (m *BundledObject) XXX_Merge(src proto.Message)

func (*BundledObject) XXX_Size 

func (m *BundledObject) XXX_Size() int

func (*BundledObject) XXX_Unmarshal 

func (m *BundledObject) XXX_Unmarshal(b []byte) error

type BundledObjectLog 

type BundledObjectLog struct {
	Status               Status      `protobuf:"varint,1,opt,name=status,proto3,enum=cloud_ingest_task.Status" json:"status,omitempty"`
	FailureType          FailureType `` /* 130-byte string literal not displayed */
	FailureMessage       string      `protobuf:"bytes,3,opt,name=failure_message,json=failureMessage,proto3" json:"failure_message,omitempty"`
	DstBucket            string      `protobuf:"bytes,6,opt,name=dst_bucket,json=dstBucket,proto3" json:"dst_bucket,omitempty"`
	DstObject            string      `protobuf:"bytes,4,opt,name=dst_object,json=dstObject,proto3" json:"dst_object,omitempty"`
	DstObjectBytes       int64       `protobuf:"varint,5,opt,name=dst_object_bytes,json=dstObjectBytes,proto3" json:"dst_object_bytes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*BundledObjectLog) Descriptor 

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

func (*BundledObjectLog) GetDstBucket 

func (m *BundledObjectLog) GetDstBucket() string

func (*BundledObjectLog) GetDstObject 

func (m *BundledObjectLog) GetDstObject() string

func (*BundledObjectLog) GetDstObjectBytes 

func (m *BundledObjectLog) GetDstObjectBytes() int64

func (*BundledObjectLog) GetFailureMessage 

func (m *BundledObjectLog) GetFailureMessage() string

func (*BundledObjectLog) GetFailureType 

func (m *BundledObjectLog) GetFailureType() FailureType

func (*BundledObjectLog) GetStatus 

func (m *BundledObjectLog) GetStatus() Status

func (*BundledObjectLog) ProtoMessage 

func (*BundledObjectLog) ProtoMessage()

func (*BundledObjectLog) Reset 

func (m *BundledObjectLog) Reset()

func (*BundledObjectLog) String 

func (m *BundledObjectLog) String() string

func (*BundledObjectLog) XXX_DiscardUnknown 

func (m *BundledObjectLog) XXX_DiscardUnknown()

func (*BundledObjectLog) XXX_Marshal 

func (m *BundledObjectLog) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BundledObjectLog) XXX_Merge 

func (m *BundledObjectLog) XXX_Merge(src proto.Message)

func (*BundledObjectLog) XXX_Size 

func (m *BundledObjectLog) XXX_Size() int

func (*BundledObjectLog) XXX_Unmarshal 

func (m *BundledObjectLog) XXX_Unmarshal(b []byte) error

type CopyBundleLog 

type CopyBundleLog struct {
	FilesCopied          int64             `protobuf:"varint,1,opt,name=files_copied,json=filesCopied,proto3" json:"files_copied,omitempty"`
	BytesCopied          int64             `protobuf:"varint,2,opt,name=bytes_copied,json=bytesCopied,proto3" json:"bytes_copied,omitempty"`
	FilesFailed          int64             `protobuf:"varint,3,opt,name=files_failed,json=filesFailed,proto3" json:"files_failed,omitempty"`
	BytesFailed          int64             `protobuf:"varint,4,opt,name=bytes_failed,json=bytesFailed,proto3" json:"bytes_failed,omitempty"`
	BundledFilesLogs     []*BundledFileLog `protobuf:"bytes,5,rep,name=bundled_files_logs,json=bundledFilesLogs,proto3" json:"bundled_files_logs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Contains log fields for a CopyBundle task.

func (*CopyBundleLog) Descriptor 

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

func (*CopyBundleLog) GetBundledFilesLogs 

func (m *CopyBundleLog) GetBundledFilesLogs() []*BundledFileLog

func (*CopyBundleLog) GetBytesCopied 

func (m *CopyBundleLog) GetBytesCopied() int64

func (*CopyBundleLog) GetBytesFailed 

func (m *CopyBundleLog) GetBytesFailed() int64

func (*CopyBundleLog) GetFilesCopied 

func (m *CopyBundleLog) GetFilesCopied() int64

func (*CopyBundleLog) GetFilesFailed 

func (m *CopyBundleLog) GetFilesFailed() int64

func (*CopyBundleLog) ProtoMessage 

func (*CopyBundleLog) ProtoMessage()

func (*CopyBundleLog) Reset 

func (m *CopyBundleLog) Reset()

func (*CopyBundleLog) String 

func (m *CopyBundleLog) String() string

func (*CopyBundleLog) XXX_DiscardUnknown 

func (m *CopyBundleLog) XXX_DiscardUnknown()

func (*CopyBundleLog) XXX_Marshal 

func (m *CopyBundleLog) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CopyBundleLog) XXX_Merge 

func (m *CopyBundleLog) XXX_Merge(src proto.Message)

func (*CopyBundleLog) XXX_Size 

func (m *CopyBundleLog) XXX_Size() int

func (*CopyBundleLog) XXX_Unmarshal 

func (m *CopyBundleLog) XXX_Unmarshal(b []byte) error

type CopyBundleSpec 

type CopyBundleSpec struct {
	BundledFiles         []*BundledFile `protobuf:"bytes,1,rep,name=bundled_files,json=bundledFiles,proto3" json:"bundled_files,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

Contains the information about a Copy Bundle task. A Copy Bundle task is responsible for copying multiple files to GCS.

func (*CopyBundleSpec) Descriptor 

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

func (*CopyBundleSpec) GetBundledFiles 

func (m *CopyBundleSpec) GetBundledFiles() []*BundledFile

func (*CopyBundleSpec) ProtoMessage 

func (*CopyBundleSpec) ProtoMessage()

func (*CopyBundleSpec) Reset 

func (m *CopyBundleSpec) Reset()

func (*CopyBundleSpec) String 

func (m *CopyBundleSpec) String() string

func (*CopyBundleSpec) XXX_DiscardUnknown 

func (m *CopyBundleSpec) XXX_DiscardUnknown()

func (*CopyBundleSpec) XXX_Marshal 

func (m *CopyBundleSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CopyBundleSpec) XXX_Merge 

func (m *CopyBundleSpec) XXX_Merge(src proto.Message)

func (*CopyBundleSpec) XXX_Size 

func (m *CopyBundleSpec) XXX_Size() int

func (*CopyBundleSpec) XXX_Unmarshal 

func (m *CopyBundleSpec) XXX_Unmarshal(b []byte) error

type CopyLog 

type CopyLog struct {
	SrcFile              string   `protobuf:"bytes,1,opt,name=src_file,json=srcFile,proto3" json:"src_file,omitempty"`
	SrcBytes             int64    `protobuf:"varint,2,opt,name=src_bytes,json=srcBytes,proto3" json:"src_bytes,omitempty"`
	SrcMTime             int64    `protobuf:"varint,3,opt,name=src_m_time,json=srcMTime,proto3" json:"src_m_time,omitempty"`
	SrcCrc32C            uint32   `protobuf:"varint,4,opt,name=src_crc32c,json=srcCrc32c,proto3" json:"src_crc32c,omitempty"`
	DstFile              string   `protobuf:"bytes,5,opt,name=dst_file,json=dstFile,proto3" json:"dst_file,omitempty"`
	DstBytes             int64    `protobuf:"varint,6,opt,name=dst_bytes,json=dstBytes,proto3" json:"dst_bytes,omitempty"`
	DstMTime             int64    `protobuf:"varint,7,opt,name=dst_m_time,json=dstMTime,proto3" json:"dst_m_time,omitempty"`
	DstCrc32C            uint32   `protobuf:"varint,8,opt,name=dst_crc32c,json=dstCrc32c,proto3" json:"dst_crc32c,omitempty"`
	BytesCopied          int64    `protobuf:"varint,9,opt,name=bytes_copied,json=bytesCopied,proto3" json:"bytes_copied,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Contains log fields for a Copy task.

func (*CopyLog) Descriptor 

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

func (*CopyLog) GetBytesCopied 

func (m *CopyLog) GetBytesCopied() int64

func (*CopyLog) GetDstBytes 

func (m *CopyLog) GetDstBytes() int64

func (*CopyLog) GetDstCrc32C 

func (m *CopyLog) GetDstCrc32C() uint32

func (*CopyLog) GetDstFile 

func (m *CopyLog) GetDstFile() string

func (*CopyLog) GetDstMTime 

func (m *CopyLog) GetDstMTime() int64

func (*CopyLog) GetSrcBytes 

func (m *CopyLog) GetSrcBytes() int64

func (*CopyLog) GetSrcCrc32C 

func (m *CopyLog) GetSrcCrc32C() uint32

func (*CopyLog) GetSrcFile 

func (m *CopyLog) GetSrcFile() string

func (*CopyLog) GetSrcMTime 

func (m *CopyLog) GetSrcMTime() int64

func (*CopyLog) ProtoMessage 

func (*CopyLog) ProtoMessage()

func (*CopyLog) Reset 

func (m *CopyLog) Reset()

func (*CopyLog) String 

func (m *CopyLog) String() string

func (*CopyLog) XXX_DiscardUnknown 

func (m *CopyLog) XXX_DiscardUnknown()

func (*CopyLog) XXX_Marshal 

func (m *CopyLog) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CopyLog) XXX_Merge 

func (m *CopyLog) XXX_Merge(src proto.Message)

func (*CopyLog) XXX_Size 

func (m *CopyLog) XXX_Size() int

func (*CopyLog) XXX_Unmarshal 

func (m *CopyLog) XXX_Unmarshal(b []byte) error

type CopySpec 

type CopySpec struct {
	SrcFile               string `protobuf:"bytes,1,opt,name=src_file,json=srcFile,proto3" json:"src_file,omitempty"`
	DstBucket             string `protobuf:"bytes,2,opt,name=dst_bucket,json=dstBucket,proto3" json:"dst_bucket,omitempty"`
	DstObject             string `protobuf:"bytes,3,opt,name=dst_object,json=dstObject,proto3" json:"dst_object,omitempty"`
	ExpectedGenerationNum int64  `` /* 127-byte string literal not displayed */
	// Fields only for managing resumable copies.
	FileBytes            int64    `protobuf:"varint,6,opt,name=file_bytes,json=fileBytes,proto3" json:"file_bytes,omitempty"`
	FileMTime            int64    `protobuf:"varint,7,opt,name=file_m_time,json=fileMTime,proto3" json:"file_m_time,omitempty"`
	BytesCopied          int64    `protobuf:"varint,8,opt,name=bytes_copied,json=bytesCopied,proto3" json:"bytes_copied,omitempty"`
	Crc32C               uint32   `protobuf:"varint,9,opt,name=crc32c,proto3" json:"crc32c,omitempty"`
	ResumableUploadId    string   `protobuf:"bytes,11,opt,name=resumable_upload_id,json=resumableUploadId,proto3" json:"resumable_upload_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Contains the information about a copy task. A copy task is responsible for copying a single file.

func (*CopySpec) Descriptor 

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

func (*CopySpec) GetBytesCopied 

func (m *CopySpec) GetBytesCopied() int64

func (*CopySpec) GetCrc32C 

func (m *CopySpec) GetCrc32C() uint32

func (*CopySpec) GetDstBucket 

func (m *CopySpec) GetDstBucket() string

func (*CopySpec) GetDstObject 

func (m *CopySpec) GetDstObject() string

func (*CopySpec) GetExpectedGenerationNum 

func (m *CopySpec) GetExpectedGenerationNum() int64

func (*CopySpec) GetFileBytes 

func (m *CopySpec) GetFileBytes() int64

func (*CopySpec) GetFileMTime 

func (m *CopySpec) GetFileMTime() int64

func (*CopySpec) GetResumableUploadId 

func (m *CopySpec) GetResumableUploadId() string

func (*CopySpec) GetSrcFile 

func (m *CopySpec) GetSrcFile() string

func (*CopySpec) ProtoMessage 

func (*CopySpec) ProtoMessage()

func (*CopySpec) Reset 

func (m *CopySpec) Reset()

func (*CopySpec) String 

func (m *CopySpec) String() string

func (*CopySpec) XXX_DiscardUnknown 

func (m *CopySpec) XXX_DiscardUnknown()

func (*CopySpec) XXX_Marshal 

func (m *CopySpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CopySpec) XXX_Merge 

func (m *CopySpec) XXX_Merge(src proto.Message)

func (*CopySpec) XXX_Size 

func (m *CopySpec) XXX_Size() int

func (*CopySpec) XXX_Unmarshal 

func (m *CopySpec) XXX_Unmarshal(b []byte) error

type DeleteBundleLog 

type DeleteBundleLog struct {
	ObjectsDeleted       int64               `protobuf:"varint,1,opt,name=objects_deleted,json=objectsDeleted,proto3" json:"objects_deleted,omitempty"`
	BytesDeleted         int64               `protobuf:"varint,2,opt,name=bytes_deleted,json=bytesDeleted,proto3" json:"bytes_deleted,omitempty"`
	ObjectsFailed        int64               `protobuf:"varint,3,opt,name=objects_failed,json=objectsFailed,proto3" json:"objects_failed,omitempty"`
	BytesFailed          int64               `protobuf:"varint,4,opt,name=bytes_failed,json=bytesFailed,proto3" json:"bytes_failed,omitempty"`
	BundledObjectsLogs   []*BundledObjectLog `protobuf:"bytes,5,rep,name=bundled_objects_logs,json=bundledObjectsLogs,proto3" json:"bundled_objects_logs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

Contains log fields for a DeleteBundle task.

func (*DeleteBundleLog) Descriptor 

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

func (*DeleteBundleLog) GetBundledObjectsLogs 

func (m *DeleteBundleLog) GetBundledObjectsLogs() []*BundledObjectLog

func (*DeleteBundleLog) GetBytesDeleted 

func (m *DeleteBundleLog) GetBytesDeleted() int64

func (*DeleteBundleLog) GetBytesFailed 

func (m *DeleteBundleLog) GetBytesFailed() int64

func (*DeleteBundleLog) GetObjectsDeleted 

func (m *DeleteBundleLog) GetObjectsDeleted() int64

func (*DeleteBundleLog) GetObjectsFailed 

func (m *DeleteBundleLog) GetObjectsFailed() int64

func (*DeleteBundleLog) ProtoMessage 

func (*DeleteBundleLog) ProtoMessage()

func (*DeleteBundleLog) Reset 

func (m *DeleteBundleLog) Reset()

func (*DeleteBundleLog) String 

func (m *DeleteBundleLog) String() string

func (*DeleteBundleLog) XXX_DiscardUnknown 

func (m *DeleteBundleLog) XXX_DiscardUnknown()

func (*DeleteBundleLog) XXX_Marshal 

func (m *DeleteBundleLog) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteBundleLog) XXX_Merge 

func (m *DeleteBundleLog) XXX_Merge(src proto.Message)

func (*DeleteBundleLog) XXX_Size 

func (m *DeleteBundleLog) XXX_Size() int

func (*DeleteBundleLog) XXX_Unmarshal 

func (m *DeleteBundleLog) XXX_Unmarshal(b []byte) error

type DeleteBundleSpec 

type DeleteBundleSpec struct {
	BundledObjects       []*BundledObject `protobuf:"bytes,1,rep,name=bundled_objects,json=bundledObjects,proto3" json:"bundled_objects,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

Contains the information about a Delete Bundle task. A Delete Bundle task is responsible for deleting multiple objects in GCS.

func (*DeleteBundleSpec) Descriptor 

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

func (*DeleteBundleSpec) GetBundledObjects 

func (m *DeleteBundleSpec) GetBundledObjects() []*BundledObject

func (*DeleteBundleSpec) ProtoMessage 

func (*DeleteBundleSpec) ProtoMessage()

func (*DeleteBundleSpec) Reset 

func (m *DeleteBundleSpec) Reset()

func (*DeleteBundleSpec) String 

func (m *DeleteBundleSpec) String() string

func (*DeleteBundleSpec) XXX_DiscardUnknown 

func (m *DeleteBundleSpec) XXX_DiscardUnknown()

func (*DeleteBundleSpec) XXX_Marshal 

func (m *DeleteBundleSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteBundleSpec) XXX_Merge 

func (m *DeleteBundleSpec) XXX_Merge(src proto.Message)

func (*DeleteBundleSpec) XXX_Size 

func (m *DeleteBundleSpec) XXX_Size() int

func (*DeleteBundleSpec) XXX_Unmarshal 

func (m *DeleteBundleSpec) XXX_Unmarshal(b []byte) error

type DeleteObjectSpec 

type DeleteObjectSpec struct {
	DstBucket            string   `protobuf:"bytes,1,opt,name=dst_bucket,json=dstBucket,proto3" json:"dst_bucket,omitempty"`
	DstObject            string   `protobuf:"bytes,2,opt,name=dst_object,json=dstObject,proto3" json:"dst_object,omitempty"`
	GenerationNum        int64    `protobuf:"varint,3,opt,name=generation_num,json=generationNum,proto3" json:"generation_num,omitempty"`
	DstObjectBytes       int64    `protobuf:"varint,4,opt,name=dst_object_bytes,json=dstObjectBytes,proto3" json:"dst_object_bytes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Contains the information to delete a GCS object.

func (*DeleteObjectSpec) Descriptor 

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

func (*DeleteObjectSpec) GetDstBucket 

func (m *DeleteObjectSpec) GetDstBucket() string

func (*DeleteObjectSpec) GetDstObject 

func (m *DeleteObjectSpec) GetDstObject() string

func (*DeleteObjectSpec) GetDstObjectBytes 

func (m *DeleteObjectSpec) GetDstObjectBytes() int64

func (*DeleteObjectSpec) GetGenerationNum 

func (m *DeleteObjectSpec) GetGenerationNum() int64

func (*DeleteObjectSpec) ProtoMessage 

func (*DeleteObjectSpec) ProtoMessage()

func (*DeleteObjectSpec) Reset 

func (m *DeleteObjectSpec) Reset()

func (*DeleteObjectSpec) String 

func (m *DeleteObjectSpec) String() string

func (*DeleteObjectSpec) XXX_DiscardUnknown 

func (m *DeleteObjectSpec) XXX_DiscardUnknown()

func (*DeleteObjectSpec) XXX_Marshal 

func (m *DeleteObjectSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteObjectSpec) XXX_Merge 

func (m *DeleteObjectSpec) XXX_Merge(src proto.Message)

func (*DeleteObjectSpec) XXX_Size 

func (m *DeleteObjectSpec) XXX_Size() int

func (*DeleteObjectSpec) XXX_Unmarshal 

func (m *DeleteObjectSpec) XXX_Unmarshal(b []byte) error

type FailureType 

type FailureType int32

Specifies the classes of failures that a task can have. 

const (
	FailureType_UNSET_FAILURE_TYPE     FailureType = 0
	FailureType_UNKNOWN_FAILURE        FailureType = 1
	FailureType_FILE_MODIFIED_FAILURE  FailureType = 2
	FailureType_HASH_MISMATCH_FAILURE  FailureType = 3
	FailureType_PRECONDITION_FAILURE   FailureType = 4
	FailureType_FILE_NOT_FOUND_FAILURE FailureType = 5
	FailureType_PERMISSION_FAILURE     FailureType = 6
	FailureType_NOT_ACTIVE_JOBRUN      FailureType = 7
	// The agent does not support the task's Job Run Version.
	FailureType_AGENT_UNSUPPORTED_VERSION FailureType = 8
	// The service does not support the task's Job Run Version.
	FailureType_SERVICE_UNSUPPORTED_VERSION FailureType = 9
	// The task was completed by an agent with a blacklisted agent version.
	FailureType_BLACKLISTED_AGENT_VERSION FailureType = 10
	// The agent processing this task could not find the source directory.
	FailureType_SOURCE_DIR_NOT_FOUND FailureType = 11
	// The name of the file is invalid.
	FailureType_INVALID_FILE_NAME FailureType = 12
	// The agent processing a copybundle task and all bundle files fail with not service-induced error.
	FailureType_NOT_SERVICE_INDUCED_UNKNOWN_FAILURE FailureType = 13
)

func (FailureType) EnumDescriptor 

func (FailureType) EnumDescriptor() ([]byte, []int)

func (FailureType) String 

func (x FailureType) String() string

type ListLog 

type ListLog struct {
	FilesFound int64 `protobuf:"varint,1,opt,name=files_found,json=filesFound,proto3" json:"files_found,omitempty"`
	BytesFound int64 `protobuf:"varint,2,opt,name=bytes_found,json=bytesFound,proto3" json:"bytes_found,omitempty"`
	// This is a count of directories that were discovered by this list task that
	// were not previously discovered by any other list task.
	DirsFound int64 `protobuf:"varint,3,opt,name=dirs_found,json=dirsFound,proto3" json:"dirs_found,omitempty"`
	// This is a count of the number of directories that were listed by this list
	// task.
	DirsListed int64 `protobuf:"varint,4,opt,name=dirs_listed,json=dirsListed,proto3" json:"dirs_listed,omitempty"`
	// This is a count of directories that were either
	// a) discovered by this list task
	// or
	// b) included in the list spec's src_directories list
	// AND were not listed as part of this list task.
	DirsNotListed int64 `protobuf:"varint,5,opt,name=dirs_not_listed,json=dirsNotListed,proto3" json:"dirs_not_listed,omitempty"`
	// A list of directories that were included in the list spec's
	// src_directories field but were not found on-prem.
	DirsNotFound         []string `protobuf:"bytes,6,rep,name=dirs_not_found,json=dirsNotFound,proto3" json:"dirs_not_found,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Contains log fields for a List task.

func (*ListLog) Descriptor 

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

func (*ListLog) GetBytesFound 

func (m *ListLog) GetBytesFound() int64

func (*ListLog) GetDirsFound 

func (m *ListLog) GetDirsFound() int64

func (*ListLog) GetDirsListed 

func (m *ListLog) GetDirsListed() int64

func (*ListLog) GetDirsNotFound 

func (m *ListLog) GetDirsNotFound() []string

func (*ListLog) GetDirsNotListed 

func (m *ListLog) GetDirsNotListed() int64

func (*ListLog) GetFilesFound 

func (m *ListLog) GetFilesFound() int64

func (*ListLog) ProtoMessage 

func (*ListLog) ProtoMessage()

func (*ListLog) Reset 

func (m *ListLog) Reset()

func (*ListLog) String 

func (m *ListLog) String() string

func (*ListLog) XXX_DiscardUnknown 

func (m *ListLog) XXX_DiscardUnknown()

func (*ListLog) XXX_Marshal 

func (m *ListLog) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListLog) XXX_Merge 

func (m *ListLog) XXX_Merge(src proto.Message)

func (*ListLog) XXX_Size 

func (m *ListLog) XXX_Size() int

func (*ListLog) XXX_Unmarshal 

func (m *ListLog) XXX_Unmarshal(b []byte) error

type ListSpec 

type ListSpec struct {
	DstListResultBucket string `protobuf:"bytes,1,opt,name=dst_list_result_bucket,json=dstListResultBucket,proto3" json:"dst_list_result_bucket,omitempty"`
	DstListResultObject string `protobuf:"bytes,2,opt,name=dst_list_result_object,json=dstListResultObject,proto3" json:"dst_list_result_object,omitempty"`
	// GCS object for the list of unexplored directories (directories
	// that were discovered but not yet listed).
	DstUnexploredDirsObject string `` /* 134-byte string literal not displayed */
	// On-Premises directories to list.
	SrcDirectories []string `protobuf:"bytes,3,rep,name=src_directories,json=srcDirectories,proto3" json:"src_directories,omitempty"`
	// Expected GCS generation number for dst_list_result_object. Used for
	// Job Run Version 2 and below.
	ExpectedGenerationNum int64 `` /* 127-byte string literal not displayed */
	// Expected GCS generation number for dst_list_result_object. Used for
	// Job Run Version 3 and above.
	ListResultExpectedGenerationNum int64 `` /* 161-byte string literal not displayed */
	// Expected GCS generation number for dst_unexplored_dirs_object.
	UnexploredDirsExpectedGenerationNum int64 `` /* 173-byte string literal not displayed */
	// The root directory specified in the JobConfig.
	RootDirectory        string   `protobuf:"bytes,8,opt,name=root_directory,json=rootDirectory,proto3" json:"root_directory,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Contains the information about a list task. A list task is responsible for listing the contents of a directory.

func (*ListSpec) Descriptor 

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

func (*ListSpec) GetDstListResultBucket 

func (m *ListSpec) GetDstListResultBucket() string

func (*ListSpec) GetDstListResultObject 

func (m *ListSpec) GetDstListResultObject() string

func (*ListSpec) GetDstUnexploredDirsObject 

func (m *ListSpec) GetDstUnexploredDirsObject() string

func (*ListSpec) GetExpectedGenerationNum 

func (m *ListSpec) GetExpectedGenerationNum() int64

func (*ListSpec) GetListResultExpectedGenerationNum 

func (m *ListSpec) GetListResultExpectedGenerationNum() int64

func (*ListSpec) GetRootDirectory 

func (m *ListSpec) GetRootDirectory() string

func (*ListSpec) GetSrcDirectories 

func (m *ListSpec) GetSrcDirectories() []string

func (*ListSpec) GetUnexploredDirsExpectedGenerationNum 

func (m *ListSpec) GetUnexploredDirsExpectedGenerationNum() int64

func (*ListSpec) ProtoMessage 

func (*ListSpec) ProtoMessage()

func (*ListSpec) Reset 

func (m *ListSpec) Reset()

func (*ListSpec) String 

func (m *ListSpec) String() string

func (*ListSpec) XXX_DiscardUnknown 

func (m *ListSpec) XXX_DiscardUnknown()

func (*ListSpec) XXX_Marshal 

func (m *ListSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListSpec) XXX_Merge 

func (m *ListSpec) XXX_Merge(src proto.Message)

func (*ListSpec) XXX_Size 

func (m *ListSpec) XXX_Size() int

func (*ListSpec) XXX_Unmarshal 

func (m *ListSpec) XXX_Unmarshal(b []byte) error

type Log 

type Log struct {
	// Types that are valid to be assigned to Log:
	//	*Log_ListLog
	//	*Log_ProcessListLog
	//	*Log_CopyLog
	//	*Log_CopyBundleLog
	//	*Log_ProcessUnexploredDirsLog
	//	*Log_DeleteBundleLog
	Log                  isLog_Log `protobuf_oneof:"log"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

Contains log information for a task. This message is suitable for the "Log" field in the LogEntries Spanner queue. Note that this info is eventually dumped into the user's GCS bucket.

func (*Log) Descriptor 

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

func (*Log) GetCopyBundleLog 

func (m *Log) GetCopyBundleLog() *CopyBundleLog

func (*Log) GetCopyLog 

func (m *Log) GetCopyLog() *CopyLog

func (*Log) GetDeleteBundleLog 

func (m *Log) GetDeleteBundleLog() *DeleteBundleLog

func (*Log) GetListLog 

func (m *Log) GetListLog() *ListLog

func (*Log) GetLog 

func (m *Log) GetLog() isLog_Log

func (*Log) GetProcessListLog 

func (m *Log) GetProcessListLog() *ProcessListLog

func (*Log) GetProcessUnexploredDirsLog 

func (m *Log) GetProcessUnexploredDirsLog() *ProcessUnexploredDirsLog

func (*Log) ProtoMessage 

func (*Log) ProtoMessage()

func (*Log) Reset 

func (m *Log) Reset()

func (*Log) String 

func (m *Log) String() string

func (*Log) XXX_DiscardUnknown 

func (m *Log) XXX_DiscardUnknown()

func (*Log) XXX_Marshal 

func (m *Log) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Log) XXX_Merge 

func (m *Log) XXX_Merge(src proto.Message)

func (*Log) XXX_OneofWrappers 

func (*Log) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Log) XXX_Size 

func (m *Log) XXX_Size() int

func (*Log) XXX_Unmarshal 

func (m *Log) XXX_Unmarshal(b []byte) error

type Log_CopyBundleLog 

type Log_CopyBundleLog struct {
	CopyBundleLog *CopyBundleLog `protobuf:"bytes,4,opt,name=copy_bundle_log,json=copyBundleLog,proto3,oneof"`
}

type Log_CopyLog 

type Log_CopyLog struct {
	CopyLog *CopyLog `protobuf:"bytes,3,opt,name=copy_log,json=copyLog,proto3,oneof"`
}

type Log_DeleteBundleLog 

type Log_DeleteBundleLog struct {
	DeleteBundleLog *DeleteBundleLog `protobuf:"bytes,6,opt,name=delete_bundle_log,json=deleteBundleLog,proto3,oneof"`
}

type Log_ListLog 

type Log_ListLog struct {
	ListLog *ListLog `protobuf:"bytes,1,opt,name=list_log,json=listLog,proto3,oneof"`
}

type Log_ProcessListLog 

type Log_ProcessListLog struct {
	ProcessListLog *ProcessListLog `protobuf:"bytes,2,opt,name=process_list_log,json=processListLog,proto3,oneof"`
}

type Log_ProcessUnexploredDirsLog 

type Log_ProcessUnexploredDirsLog struct {
	ProcessUnexploredDirsLog *ProcessUnexploredDirsLog `protobuf:"bytes,5,opt,name=process_unexplored_dirs_log,json=processUnexploredDirsLog,proto3,oneof"`
}

type ProcessDeleteDirsSpec 

type ProcessDeleteDirsSpec struct {
	DstBucket            string   `protobuf:"bytes,1,opt,name=dst_bucket,json=dstBucket,proto3" json:"dst_bucket,omitempty"`
	Prefix               []string `protobuf:"bytes,2,rep,name=prefix,proto3" json:"prefix,omitempty"`
	PrefixOffset         int64    `protobuf:"varint,3,opt,name=prefix_offset,json=prefixOffset,proto3" json:"prefix_offset,omitempty"`
	ObjectOffset         int64    `protobuf:"varint,4,opt,name=object_offset,json=objectOffset,proto3" json:"object_offset,omitempty"`
	ContinuationToken    string   `protobuf:"bytes,5,opt,name=continuation_token,json=continuationToken,proto3" json:"continuation_token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Contains the information about a Process Delete Dirs task. A Process Delete Dirs task is responsible for generating delete bundle tasks for children of deleted directories. Deleting a directory results in deleting all objects in GCS with a shared prefix.

func (*ProcessDeleteDirsSpec) Descriptor 

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

func (*ProcessDeleteDirsSpec) GetContinuationToken 

func (m *ProcessDeleteDirsSpec) GetContinuationToken() string

func (*ProcessDeleteDirsSpec) GetDstBucket 

func (m *ProcessDeleteDirsSpec) GetDstBucket() string

func (*ProcessDeleteDirsSpec) GetObjectOffset 

func (m *ProcessDeleteDirsSpec) GetObjectOffset() int64

func (*ProcessDeleteDirsSpec) GetPrefix 

func (m *ProcessDeleteDirsSpec) GetPrefix() []string

func (*ProcessDeleteDirsSpec) GetPrefixOffset 

func (m *ProcessDeleteDirsSpec) GetPrefixOffset() int64

func (*ProcessDeleteDirsSpec) ProtoMessage 

func (*ProcessDeleteDirsSpec) ProtoMessage()

func (*ProcessDeleteDirsSpec) Reset 

func (m *ProcessDeleteDirsSpec) Reset()

func (*ProcessDeleteDirsSpec) String 

func (m *ProcessDeleteDirsSpec) String() string

func (*ProcessDeleteDirsSpec) XXX_DiscardUnknown 

func (m *ProcessDeleteDirsSpec) XXX_DiscardUnknown()

func (*ProcessDeleteDirsSpec) XXX_Marshal 

func (m *ProcessDeleteDirsSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProcessDeleteDirsSpec) XXX_Merge 

func (m *ProcessDeleteDirsSpec) XXX_Merge(src proto.Message)

func (*ProcessDeleteDirsSpec) XXX_Size 

func (m *ProcessDeleteDirsSpec) XXX_Size() int

func (*ProcessDeleteDirsSpec) XXX_Unmarshal 

func (m *ProcessDeleteDirsSpec) XXX_Unmarshal(b []byte) error

type ProcessListLog 

type ProcessListLog struct {
	EntriesProcessed     int64    `protobuf:"varint,1,opt,name=entries_processed,json=entriesProcessed,proto3" json:"entries_processed,omitempty"`
	StartingOffset       int64    `protobuf:"varint,2,opt,name=starting_offset,json=startingOffset,proto3" json:"starting_offset,omitempty"`
	EndingOffset         int64    `protobuf:"varint,3,opt,name=ending_offset,json=endingOffset,proto3" json:"ending_offset,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Contains log fields for a ProcessList task.

func (*ProcessListLog) Descriptor 

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

func (*ProcessListLog) GetEndingOffset 

func (m *ProcessListLog) GetEndingOffset() int64

func (*ProcessListLog) GetEntriesProcessed 

func (m *ProcessListLog) GetEntriesProcessed() int64

func (*ProcessListLog) GetStartingOffset 

func (m *ProcessListLog) GetStartingOffset() int64

func (*ProcessListLog) ProtoMessage 

func (*ProcessListLog) ProtoMessage()

func (*ProcessListLog) Reset 

func (m *ProcessListLog) Reset()

func (*ProcessListLog) String 

func (m *ProcessListLog) String() string

func (*ProcessListLog) XXX_DiscardUnknown 

func (m *ProcessListLog) XXX_DiscardUnknown()

func (*ProcessListLog) XXX_Marshal 

func (m *ProcessListLog) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProcessListLog) XXX_Merge 

func (m *ProcessListLog) XXX_Merge(src proto.Message)

func (*ProcessListLog) XXX_Size 

func (m *ProcessListLog) XXX_Size() int

func (*ProcessListLog) XXX_Unmarshal 

func (m *ProcessListLog) XXX_Unmarshal(b []byte) error

type ProcessListSpec 

type ProcessListSpec struct {
	DstListResultBucket  string   `protobuf:"bytes,1,opt,name=dst_list_result_bucket,json=dstListResultBucket,proto3" json:"dst_list_result_bucket,omitempty"`
	DstListResultObject  string   `protobuf:"bytes,2,opt,name=dst_list_result_object,json=dstListResultObject,proto3" json:"dst_list_result_object,omitempty"`
	SrcDirectory         string   `protobuf:"bytes,3,opt,name=src_directory,json=srcDirectory,proto3" json:"src_directory,omitempty"`
	ByteOffset           int64    `protobuf:"varint,4,opt,name=byte_offset,json=byteOffset,proto3" json:"byte_offset,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Contains the information about a process list task. A process list task is responsible for processing the list file produced by a list task.

func (*ProcessListSpec) Descriptor 

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

func (*ProcessListSpec) GetByteOffset 

func (m *ProcessListSpec) GetByteOffset() int64

func (*ProcessListSpec) GetDstListResultBucket 

func (m *ProcessListSpec) GetDstListResultBucket() string

func (*ProcessListSpec) GetDstListResultObject 

func (m *ProcessListSpec) GetDstListResultObject() string

func (*ProcessListSpec) GetSrcDirectory 

func (m *ProcessListSpec) GetSrcDirectory() string

func (*ProcessListSpec) ProtoMessage 

func (*ProcessListSpec) ProtoMessage()

func (*ProcessListSpec) Reset 

func (m *ProcessListSpec) Reset()

func (*ProcessListSpec) String 

func (m *ProcessListSpec) String() string

func (*ProcessListSpec) XXX_DiscardUnknown 

func (m *ProcessListSpec) XXX_DiscardUnknown()

func (*ProcessListSpec) XXX_Marshal 

func (m *ProcessListSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProcessListSpec) XXX_Merge 

func (m *ProcessListSpec) XXX_Merge(src proto.Message)

func (*ProcessListSpec) XXX_Size 

func (m *ProcessListSpec) XXX_Size() int

func (*ProcessListSpec) XXX_Unmarshal 

func (m *ProcessListSpec) XXX_Unmarshal(b []byte) error

type ProcessUnexploredDirsLog 

type ProcessUnexploredDirsLog struct {
	EntriesProcessed     int64    `protobuf:"varint,1,opt,name=entries_processed,json=entriesProcessed,proto3" json:"entries_processed,omitempty"`
	StartingOffset       int64    `protobuf:"varint,2,opt,name=starting_offset,json=startingOffset,proto3" json:"starting_offset,omitempty"`
	EndingOffset         int64    `protobuf:"varint,3,opt,name=ending_offset,json=endingOffset,proto3" json:"ending_offset,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Contains log fields for a ProcessUnexploredDirs task.

func (*ProcessUnexploredDirsLog) Descriptor 

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

func (*ProcessUnexploredDirsLog) GetEndingOffset 

func (m *ProcessUnexploredDirsLog) GetEndingOffset() int64

func (*ProcessUnexploredDirsLog) GetEntriesProcessed 

func (m *ProcessUnexploredDirsLog) GetEntriesProcessed() int64

func (*ProcessUnexploredDirsLog) GetStartingOffset 

func (m *ProcessUnexploredDirsLog) GetStartingOffset() int64

func (*ProcessUnexploredDirsLog) ProtoMessage 

func (*ProcessUnexploredDirsLog) ProtoMessage()

func (*ProcessUnexploredDirsLog) Reset 

func (m *ProcessUnexploredDirsLog) Reset()

func (*ProcessUnexploredDirsLog) String 

func (m *ProcessUnexploredDirsLog) String() string

func (*ProcessUnexploredDirsLog) XXX_DiscardUnknown 

func (m *ProcessUnexploredDirsLog) XXX_DiscardUnknown()

func (*ProcessUnexploredDirsLog) XXX_Marshal 

func (m *ProcessUnexploredDirsLog) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProcessUnexploredDirsLog) XXX_Merge 

func (m *ProcessUnexploredDirsLog) XXX_Merge(src proto.Message)

func (*ProcessUnexploredDirsLog) XXX_Size 

func (m *ProcessUnexploredDirsLog) XXX_Size() int

func (*ProcessUnexploredDirsLog) XXX_Unmarshal 

func (m *ProcessUnexploredDirsLog) XXX_Unmarshal(b []byte) error

type ProcessUnexploredDirsSpec 

type ProcessUnexploredDirsSpec struct {
	// GCS bucket for list task output.
	DstListResultBucket string `protobuf:"bytes,1,opt,name=dst_list_result_bucket,json=dstListResultBucket,proto3" json:"dst_list_result_bucket,omitempty"`
	// GCS object for the unexplored dirs file.
	DstUnexploredDirsObject string `` /* 134-byte string literal not displayed */
	// Unexplored dirs file bytes processed so far.
	ByteOffset           int64    `protobuf:"varint,3,opt,name=byte_offset,json=byteOffset,proto3" json:"byte_offset,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Contains the information about a process unlisted dirs task. A process unlisted dirs task is responsible for processing the unexplored dirs file produced by a list task.

func (*ProcessUnexploredDirsSpec) Descriptor 

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

func (*ProcessUnexploredDirsSpec) GetByteOffset 

func (m *ProcessUnexploredDirsSpec) GetByteOffset() int64

func (*ProcessUnexploredDirsSpec) GetDstListResultBucket 

func (m *ProcessUnexploredDirsSpec) GetDstListResultBucket() string

func (*ProcessUnexploredDirsSpec) GetDstUnexploredDirsObject 

func (m *ProcessUnexploredDirsSpec) GetDstUnexploredDirsObject() string

func (*ProcessUnexploredDirsSpec) ProtoMessage 

func (*ProcessUnexploredDirsSpec) ProtoMessage()

func (*ProcessUnexploredDirsSpec) Reset 

func (m *ProcessUnexploredDirsSpec) Reset()

func (*ProcessUnexploredDirsSpec) String 

func (m *ProcessUnexploredDirsSpec) String() string

func (*ProcessUnexploredDirsSpec) XXX_DiscardUnknown 

func (m *ProcessUnexploredDirsSpec) XXX_DiscardUnknown()

func (*ProcessUnexploredDirsSpec) XXX_Marshal 

func (m *ProcessUnexploredDirsSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProcessUnexploredDirsSpec) XXX_Merge 

func (m *ProcessUnexploredDirsSpec) XXX_Merge(src proto.Message)

func (*ProcessUnexploredDirsSpec) XXX_Size 

func (m *ProcessUnexploredDirsSpec) XXX_Size() int

func (*ProcessUnexploredDirsSpec) XXX_Unmarshal 

func (m *ProcessUnexploredDirsSpec) XXX_Unmarshal(b []byte) error

type Spec 

type Spec struct {
	// Types that are valid to be assigned to Spec:
	//	*Spec_ListSpec
	//	*Spec_ProcessListSpec
	//	*Spec_CopySpec
	//	*Spec_CopyBundleSpec
	//	*Spec_ProcessUnexploredDirsSpec
	//	*Spec_DeleteBundleSpec
	//	*Spec_ProcessDeleteDirsSpec
	Spec                 isSpec_Spec `protobuf_oneof:"spec"`
	IssuanceNumber       int64       `protobuf:"varint,8,opt,name=issuance_number,json=issuanceNumber,proto3" json:"issuance_number,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

Contains information about a task. A task is a unit of work, one of: 1) listing the contents of a single directory 2) processing a list file 3) copying a single file 4) copying a bundle of files 5) processing a list of unexplored directories 6) deleting a bundle of objects. 7) processing a list of "directories" and generating delete bundle tasks for children of those "directories". Tasks might be incremental and require multiple request-response round trips to complete.

func (*Spec) Descriptor 

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

func (*Spec) GetCopyBundleSpec 

func (m *Spec) GetCopyBundleSpec() *CopyBundleSpec

func (*Spec) GetCopySpec 

func (m *Spec) GetCopySpec() *CopySpec

func (*Spec) GetDeleteBundleSpec 

func (m *Spec) GetDeleteBundleSpec() *DeleteBundleSpec

func (*Spec) GetIssuanceNumber 

func (m *Spec) GetIssuanceNumber() int64

func (*Spec) GetListSpec 

func (m *Spec) GetListSpec() *ListSpec

func (*Spec) GetProcessDeleteDirsSpec 

func (m *Spec) GetProcessDeleteDirsSpec() *ProcessDeleteDirsSpec

func (*Spec) GetProcessListSpec 

func (m *Spec) GetProcessListSpec() *ProcessListSpec

func (*Spec) GetProcessUnexploredDirsSpec 

func (m *Spec) GetProcessUnexploredDirsSpec() *ProcessUnexploredDirsSpec

func (*Spec) GetSpec 

func (m *Spec) GetSpec() isSpec_Spec

func (*Spec) ProtoMessage 

func (*Spec) ProtoMessage()

func (*Spec) Reset 

func (m *Spec) Reset()

func (*Spec) String 

func (m *Spec) String() string

func (*Spec) XXX_DiscardUnknown 

func (m *Spec) XXX_DiscardUnknown()

func (*Spec) XXX_Marshal 

func (m *Spec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Spec) XXX_Merge 

func (m *Spec) XXX_Merge(src proto.Message)

func (*Spec) XXX_OneofWrappers 

func (*Spec) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Spec) XXX_Size 

func (m *Spec) XXX_Size() int

func (*Spec) XXX_Unmarshal 

func (m *Spec) XXX_Unmarshal(b []byte) error

type Spec_CopyBundleSpec 

type Spec_CopyBundleSpec struct {
	CopyBundleSpec *CopyBundleSpec `protobuf:"bytes,4,opt,name=copy_bundle_spec,json=copyBundleSpec,proto3,oneof"`
}

type Spec_CopySpec 

type Spec_CopySpec struct {
	CopySpec *CopySpec `protobuf:"bytes,3,opt,name=copy_spec,json=copySpec,proto3,oneof"`
}

type Spec_DeleteBundleSpec 

type Spec_DeleteBundleSpec struct {
	DeleteBundleSpec *DeleteBundleSpec `protobuf:"bytes,6,opt,name=delete_bundle_spec,json=deleteBundleSpec,proto3,oneof"`
}

type Spec_ListSpec 

type Spec_ListSpec struct {
	ListSpec *ListSpec `protobuf:"bytes,1,opt,name=list_spec,json=listSpec,proto3,oneof"`
}

type Spec_ProcessDeleteDirsSpec 

type Spec_ProcessDeleteDirsSpec struct {
	ProcessDeleteDirsSpec *ProcessDeleteDirsSpec `protobuf:"bytes,7,opt,name=process_delete_dirs_spec,json=processDeleteDirsSpec,proto3,oneof"`
}

type Spec_ProcessListSpec 

type Spec_ProcessListSpec struct {
	ProcessListSpec *ProcessListSpec `protobuf:"bytes,2,opt,name=process_list_spec,json=processListSpec,proto3,oneof"`
}

type Spec_ProcessUnexploredDirsSpec 

type Spec_ProcessUnexploredDirsSpec struct {
	ProcessUnexploredDirsSpec *ProcessUnexploredDirsSpec `protobuf:"bytes,5,opt,name=process_unexplored_dirs_spec,json=processUnexploredDirsSpec,proto3,oneof"`
}

type Status 

type Status int32

Specifies the current status of the cloud ingest task. 

const (
	Status_UNSET_STATUS Status = 0
	Status_READY        Status = 1
	Status_FAILED       Status = 2
	Status_SUCCESS      Status = 3
)

func (Status) EnumDescriptor 

func (Status) EnumDescriptor() ([]byte, []int)

func (Status) String 

func (x Status) String() string

type TaskReqMsg 

type TaskReqMsg struct {
	TaskRelRsrcName      string   `protobuf:"bytes,1,opt,name=task_rel_rsrc_name,json=taskRelRsrcName,proto3" json:"task_rel_rsrc_name,omitempty"`
	JobrunRelRsrcName    string   `protobuf:"bytes,3,opt,name=jobrun_rel_rsrc_name,json=jobrunRelRsrcName,proto3" json:"jobrun_rel_rsrc_name,omitempty"`
	JobRunVersion        string   `protobuf:"bytes,4,opt,name=job_run_version,json=jobRunVersion,proto3" json:"job_run_version,omitempty"`
	Spec                 *Spec    `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Contains the message sent from the DCP to an Agent to issue a task request.

func (*TaskReqMsg) Descriptor 

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

func (*TaskReqMsg) GetJobRunVersion 

func (m *TaskReqMsg) GetJobRunVersion() string

func (*TaskReqMsg) GetJobrunRelRsrcName 

func (m *TaskReqMsg) GetJobrunRelRsrcName() string

func (*TaskReqMsg) GetSpec 

func (m *TaskReqMsg) GetSpec() *Spec

func (*TaskReqMsg) GetTaskRelRsrcName 

func (m *TaskReqMsg) GetTaskRelRsrcName() string

func (*TaskReqMsg) ProtoMessage 

func (*TaskReqMsg) ProtoMessage()

func (*TaskReqMsg) Reset 

func (m *TaskReqMsg) Reset()

func (*TaskReqMsg) String 

func (m *TaskReqMsg) String() string

func (*TaskReqMsg) XXX_DiscardUnknown 

func (m *TaskReqMsg) XXX_DiscardUnknown()

func (*TaskReqMsg) XXX_Marshal 

func (m *TaskReqMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskReqMsg) XXX_Merge 

func (m *TaskReqMsg) XXX_Merge(src proto.Message)

func (*TaskReqMsg) XXX_Size 

func (m *TaskReqMsg) XXX_Size() int

func (*TaskReqMsg) XXX_Unmarshal 

func (m *TaskReqMsg) XXX_Unmarshal(b []byte) error

type TaskRespMsg 

type TaskRespMsg struct {
	TaskRelRsrcName string      `protobuf:"bytes,1,opt,name=task_rel_rsrc_name,json=taskRelRsrcName,proto3" json:"task_rel_rsrc_name,omitempty"`
	JobRunVersion   string      `protobuf:"bytes,8,opt,name=job_run_version,json=jobRunVersion,proto3" json:"job_run_version,omitempty"`
	AgentVersion    string      `protobuf:"bytes,9,opt,name=agent_version,json=agentVersion,proto3" json:"agent_version,omitempty"`
	Status          string      `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	FailureType     FailureType `` /* 130-byte string literal not displayed */
	FailureMessage  string      `protobuf:"bytes,4,opt,name=failure_message,json=failureMessage,proto3" json:"failure_message,omitempty"`
	Log             *Log        `protobuf:"bytes,5,opt,name=log,proto3" json:"log,omitempty"`
	ReqSpec         *Spec       `protobuf:"bytes,6,opt,name=req_spec,json=reqSpec,proto3" json:"req_spec,omitempty"`
	RespSpec        *Spec       `protobuf:"bytes,7,opt,name=resp_spec,json=respSpec,proto3" json:"resp_spec,omitempty"`
	// Pub/Sub request message publish time.
	ReqPublishTime *timestamp.Timestamp `protobuf:"bytes,10,opt,name=req_publish_time,json=reqPublishTime,proto3" json:"req_publish_time,omitempty"`
	// Agent-measured start of request processing.
	ReqStartTime *timestamp.Timestamp `protobuf:"bytes,11,opt,name=req_start_time,json=reqStartTime,proto3" json:"req_start_time,omitempty"`
	// Agent-measured Pub/Sub response publish time.
	RespPublishTime      *timestamp.Timestamp    `protobuf:"bytes,12,opt,name=resp_publish_time,json=respPublishTime,proto3" json:"resp_publish_time,omitempty"`
	AgentId              *pulse_go_proto.AgentId `protobuf:"bytes,13,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

Contains the message sent from the Agent to the DCP in response to a task request. Note that in the case where the Task is a CopyBundle, these top level fields apply to the entire CopyBundle. For info about the individual files, examine the CopyBundleSpec within the resp_spec.

func (*TaskRespMsg) Descriptor 

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

func (*TaskRespMsg) GetAgentId 

func (m *TaskRespMsg) GetAgentId() *pulse_go_proto.AgentId

func (*TaskRespMsg) GetAgentVersion 

func (m *TaskRespMsg) GetAgentVersion() string

func (*TaskRespMsg) GetFailureMessage 

func (m *TaskRespMsg) GetFailureMessage() string

func (*TaskRespMsg) GetFailureType 

func (m *TaskRespMsg) GetFailureType() FailureType

func (*TaskRespMsg) GetJobRunVersion 

func (m *TaskRespMsg) GetJobRunVersion() string

func (*TaskRespMsg) GetLog 

func (m *TaskRespMsg) GetLog() *Log

func (*TaskRespMsg) GetReqPublishTime 

func (m *TaskRespMsg) GetReqPublishTime() *timestamp.Timestamp

func (*TaskRespMsg) GetReqSpec 

func (m *TaskRespMsg) GetReqSpec() *Spec

func (*TaskRespMsg) GetReqStartTime 

func (m *TaskRespMsg) GetReqStartTime() *timestamp.Timestamp

func (*TaskRespMsg) GetRespPublishTime 

func (m *TaskRespMsg) GetRespPublishTime() *timestamp.Timestamp

func (*TaskRespMsg) GetRespSpec 

func (m *TaskRespMsg) GetRespSpec() *Spec

func (*TaskRespMsg) GetStatus 

func (m *TaskRespMsg) GetStatus() string

func (*TaskRespMsg) GetTaskRelRsrcName 

func (m *TaskRespMsg) GetTaskRelRsrcName() string

func (*TaskRespMsg) ProtoMessage 

func (*TaskRespMsg) ProtoMessage()

func (*TaskRespMsg) Reset 

func (m *TaskRespMsg) Reset()

func (*TaskRespMsg) String 

func (m *TaskRespMsg) String() string

func (*TaskRespMsg) XXX_DiscardUnknown 

func (m *TaskRespMsg) XXX_DiscardUnknown()

func (*TaskRespMsg) XXX_Marshal 

func (m *TaskRespMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskRespMsg) XXX_Merge 

func (m *TaskRespMsg) XXX_Merge(src proto.Message)

func (*TaskRespMsg) XXX_Size 

func (m *TaskRespMsg) XXX_Size() int

func (*TaskRespMsg) XXX_Unmarshal 

func (m *TaskRespMsg) XXX_Unmarshal(b []byte) error

type Type 

type Type int32

Specifies the task operation that a task performs. 

const (
	Type_UNSET_TYPE              Type = 0
	Type_LIST                    Type = 1
	Type_PROCESS_LIST            Type = 2
	Type_COPY                    Type = 3
	Type_COPY_BUNDLE             Type = 4
	Type_PROCESS_UNEXPLORED_DIRS Type = 5
	Type_DELETE_BUNDLE           Type = 6
	Type_PROCESS_DELETE_DIRS     Type = 7
)

func (Type) EnumDescriptor 

func (Type) EnumDescriptor() ([]byte, []int)

func (Type) String 

func (x Type) String() string

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.