/**
 * Generated by the protoc-gen-ts.  DO NOT EDIT!
 * compiler version: 0.0.0
 * source: jetpack/proto/runtime/v1alpha1/task.proto
 * git: https://github.com/thesayyn/protoc-gen-ts */
import * as dependency_1 from "./remote";
import * as pb_1 from "google-protobuf";
export namespace task {
    export class PersistedTask extends pb_1.Message {
        #one_of_decls = [];
        constructor(data?: any[] | {
            id?: string;
            qualified_symbol?: string;
            encoded_args?: Uint8Array;
            manifest?: Uint8Array;
            status?: PersistedTask.Status;
            result?: dependency_1.remote.Result;
            app_name?: string;
            project_id?: string;
            parent_task_id?: string;
            with_checkpointing?: boolean;
            current_iteration?: number;
            execution_mode?: PersistedTask.ExecutionMode;
        }) {
            super();
            pb_1.Message.initialize(this, Array.isArray(data) ? data : [], 0, -1, [], this.#one_of_decls);
            if (!Array.isArray(data) && typeof data == "object") {
                if ("id" in data && data.id != undefined) {
                    this.id = data.id;
                }
                if ("qualified_symbol" in data && data.qualified_symbol != undefined) {
                    this.qualified_symbol = data.qualified_symbol;
                }
                if ("encoded_args" in data && data.encoded_args != undefined) {
                    this.encoded_args = data.encoded_args;
                }
                if ("manifest" in data && data.manifest != undefined) {
                    this.manifest = data.manifest;
                }
                if ("status" in data && data.status != undefined) {
                    this.status = data.status;
                }
                if ("result" in data && data.result != undefined) {
                    this.result = data.result;
                }
                if ("app_name" in data && data.app_name != undefined) {
                    this.app_name = data.app_name;
                }
                if ("project_id" in data && data.project_id != undefined) {
                    this.project_id = data.project_id;
                }
                if ("parent_task_id" in data && data.parent_task_id != undefined) {
                    this.parent_task_id = data.parent_task_id;
                }
                if ("with_checkpointing" in data && data.with_checkpointing != undefined) {
                    this.with_checkpointing = data.with_checkpointing;
                }
                if ("current_iteration" in data && data.current_iteration != undefined) {
                    this.current_iteration = data.current_iteration;
                }
                if ("execution_mode" in data && data.execution_mode != undefined) {
                    this.execution_mode = data.execution_mode;
                }
            }
        }
        get id() {
            return pb_1.Message.getField(this, 1) as string;
        }
        set id(value: string) {
            pb_1.Message.setField(this, 1, value);
        }
        get qualified_symbol() {
            return pb_1.Message.getField(this, 2) as string;
        }
        set qualified_symbol(value: string) {
            pb_1.Message.setField(this, 2, value);
        }
        get encoded_args() {
            return pb_1.Message.getField(this, 3) as Uint8Array;
        }
        set encoded_args(value: Uint8Array) {
            pb_1.Message.setField(this, 3, value);
        }
        get manifest() {
            return pb_1.Message.getField(this, 4) as Uint8Array;
        }
        set manifest(value: Uint8Array) {
            pb_1.Message.setField(this, 4, value);
        }
        get status() {
            return pb_1.Message.getField(this, 5) as PersistedTask.Status;
        }
        set status(value: PersistedTask.Status) {
            pb_1.Message.setField(this, 5, value);
        }
        get result() {
            return pb_1.Message.getWrapperField(this, dependency_1.remote.Result, 6) as dependency_1.remote.Result;
        }
        set result(value: dependency_1.remote.Result) {
            pb_1.Message.setWrapperField(this, 6, value);
        }
        get app_name() {
            return pb_1.Message.getField(this, 7) as string;
        }
        set app_name(value: string) {
            pb_1.Message.setField(this, 7, value);
        }
        get project_id() {
            return pb_1.Message.getField(this, 12) as string;
        }
        set project_id(value: string) {
            pb_1.Message.setField(this, 12, value);
        }
        get parent_task_id() {
            return pb_1.Message.getField(this, 8) as string;
        }
        set parent_task_id(value: string) {
            pb_1.Message.setField(this, 8, value);
        }
        get with_checkpointing() {
            return pb_1.Message.getField(this, 9) as boolean;
        }
        set with_checkpointing(value: boolean) {
            pb_1.Message.setField(this, 9, value);
        }
        get current_iteration() {
            return pb_1.Message.getField(this, 10) as number;
        }
        set current_iteration(value: number) {
            pb_1.Message.setField(this, 10, value);
        }
        get execution_mode() {
            return pb_1.Message.getField(this, 11) as PersistedTask.ExecutionMode;
        }
        set execution_mode(value: PersistedTask.ExecutionMode) {
            pb_1.Message.setField(this, 11, value);
        }
        static fromObject(data: {
            id?: string;
            qualified_symbol?: string;
            encoded_args?: Uint8Array;
            manifest?: Uint8Array;
            status?: PersistedTask.Status;
            result?: ReturnType<typeof dependency_1.remote.Result.prototype.toObject>;
            app_name?: string;
            project_id?: string;
            parent_task_id?: string;
            with_checkpointing?: boolean;
            current_iteration?: number;
            execution_mode?: PersistedTask.ExecutionMode;
        }) {
            const message = new PersistedTask({});
            if (data.id != null) {
                message.id = data.id;
            }
            if (data.qualified_symbol != null) {
                message.qualified_symbol = data.qualified_symbol;
            }
            if (data.encoded_args != null) {
                message.encoded_args = data.encoded_args;
            }
            if (data.manifest != null) {
                message.manifest = data.manifest;
            }
            if (data.status != null) {
                message.status = data.status;
            }
            if (data.result != null) {
                message.result = dependency_1.remote.Result.fromObject(data.result);
            }
            if (data.app_name != null) {
                message.app_name = data.app_name;
            }
            if (data.project_id != null) {
                message.project_id = data.project_id;
            }
            if (data.parent_task_id != null) {
                message.parent_task_id = data.parent_task_id;
            }
            if (data.with_checkpointing != null) {
                message.with_checkpointing = data.with_checkpointing;
            }
            if (data.current_iteration != null) {
                message.current_iteration = data.current_iteration;
            }
            if (data.execution_mode != null) {
                message.execution_mode = data.execution_mode;
            }
            return message;
        }
        toObject() {
            const data: {
                id?: string;
                qualified_symbol?: string;
                encoded_args?: Uint8Array;
                manifest?: Uint8Array;
                status?: PersistedTask.Status;
                result?: ReturnType<typeof dependency_1.remote.Result.prototype.toObject>;
                app_name?: string;
                project_id?: string;
                parent_task_id?: string;
                with_checkpointing?: boolean;
                current_iteration?: number;
                execution_mode?: PersistedTask.ExecutionMode;
            } = {};
            if (this.id != null) {
                data.id = this.id;
            }
            if (this.qualified_symbol != null) {
                data.qualified_symbol = this.qualified_symbol;
            }
            if (this.encoded_args != null) {
                data.encoded_args = this.encoded_args;
            }
            if (this.manifest != null) {
                data.manifest = this.manifest;
            }
            if (this.status != null) {
                data.status = this.status;
            }
            if (this.result != null) {
                data.result = this.result.toObject();
            }
            if (this.app_name != null) {
                data.app_name = this.app_name;
            }
            if (this.project_id != null) {
                data.project_id = this.project_id;
            }
            if (this.parent_task_id != null) {
                data.parent_task_id = this.parent_task_id;
            }
            if (this.with_checkpointing != null) {
                data.with_checkpointing = this.with_checkpointing;
            }
            if (this.current_iteration != null) {
                data.current_iteration = this.current_iteration;
            }
            if (this.execution_mode != null) {
                data.execution_mode = this.execution_mode;
            }
            return data;
        }
        serialize(): Uint8Array;
        serialize(w: pb_1.BinaryWriter): void;
        serialize(w?: pb_1.BinaryWriter): Uint8Array | void {
            const writer = w || new pb_1.BinaryWriter();
            if (typeof this.id === "string" && this.id.length)
                writer.writeString(1, this.id);
            if (typeof this.qualified_symbol === "string" && this.qualified_symbol.length)
                writer.writeString(2, this.qualified_symbol);
            if (this.encoded_args !== undefined)
                writer.writeBytes(3, this.encoded_args);
            if (this.manifest !== undefined)
                writer.writeBytes(4, this.manifest);
            if (this.status !== undefined)
                writer.writeEnum(5, this.status);
            if (this.result !== undefined)
                writer.writeMessage(6, this.result, () => this.result.serialize(writer));
            if (typeof this.app_name === "string" && this.app_name.length)
                writer.writeString(7, this.app_name);
            if (typeof this.project_id === "string" && this.project_id.length)
                writer.writeString(12, this.project_id);
            if (typeof this.parent_task_id === "string" && this.parent_task_id.length)
                writer.writeString(8, this.parent_task_id);
            if (this.with_checkpointing !== undefined)
                writer.writeBool(9, this.with_checkpointing);
            if (this.current_iteration !== undefined)
                writer.writeInt32(10, this.current_iteration);
            if (this.execution_mode !== undefined)
                writer.writeEnum(11, this.execution_mode);
            if (!w)
                return writer.getResultBuffer();
        }
        static deserialize(bytes: Uint8Array | pb_1.BinaryReader): PersistedTask {
            const reader = bytes instanceof pb_1.BinaryReader ? bytes : new pb_1.BinaryReader(bytes), message = new PersistedTask();
            while (reader.nextField()) {
                if (reader.isEndGroup())
                    break;
                switch (reader.getFieldNumber()) {
                    case 1:
                        message.id = reader.readString();
                        break;
                    case 2:
                        message.qualified_symbol = reader.readString();
                        break;
                    case 3:
                        message.encoded_args = reader.readBytes();
                        break;
                    case 4:
                        message.manifest = reader.readBytes();
                        break;
                    case 5:
                        message.status = reader.readEnum();
                        break;
                    case 6:
                        reader.readMessage(message.result, () => message.result = dependency_1.remote.Result.deserialize(reader));
                        break;
                    case 7:
                        message.app_name = reader.readString();
                        break;
                    case 12:
                        message.project_id = reader.readString();
                        break;
                    case 8:
                        message.parent_task_id = reader.readString();
                        break;
                    case 9:
                        message.with_checkpointing = reader.readBool();
                        break;
                    case 10:
                        message.current_iteration = reader.readInt32();
                        break;
                    case 11:
                        message.execution_mode = reader.readEnum();
                        break;
                    default: reader.skipField();
                }
            }
            return message;
        }
        serializeBinary(): Uint8Array {
            return this.serialize();
        }
        static deserializeBinary(bytes: Uint8Array): PersistedTask {
            return PersistedTask.deserialize(bytes);
        }
    }
    export namespace PersistedTask {
        export enum Status {
            UNKNOWN = 0,
            CREATED = 1,
            WAITING = 2,
            READY = 3,
            RUNNING = 4,
            SUCCEEDED = 5,
            CANCELLING = 6,
            CANCELLED = 7,
            FAILING = 8,
            FAILED = 9
        }
        export enum ExecutionMode {
            EXECUTION_JOB = 0,
            EXECUTION_WORKER_PUSH = 1
        }
    }
    export class CheckpointTracker extends pb_1.Message {
        #one_of_decls = [];
        constructor(data?: any[] | {
            id?: string;
            checkpoints?: Map<string, string>;
        }) {
            super();
            pb_1.Message.initialize(this, Array.isArray(data) ? data : [], 0, -1, [], this.#one_of_decls);
            if (!Array.isArray(data) && typeof data == "object") {
                if ("id" in data && data.id != undefined) {
                    this.id = data.id;
                }
                if ("checkpoints" in data && data.checkpoints != undefined) {
                    this.checkpoints = data.checkpoints;
                }
            }
            if (!this.checkpoints)
                this.checkpoints = new Map();
        }
        get id() {
            return pb_1.Message.getField(this, 1) as string;
        }
        set id(value: string) {
            pb_1.Message.setField(this, 1, value);
        }
        get checkpoints() {
            return pb_1.Message.getField(this, 2) as any as Map<string, string>;
        }
        set checkpoints(value: Map<string, string>) {
            pb_1.Message.setField(this, 2, value as any);
        }
        static fromObject(data: {
            id?: string;
            checkpoints?: {
                [key: string]: string;
            };
        }) {
            const message = new CheckpointTracker({});
            if (data.id != null) {
                message.id = data.id;
            }
            if (typeof data.checkpoints == "object") {
                message.checkpoints = new Map(Object.entries(data.checkpoints));
            }
            return message;
        }
        toObject() {
            const data: {
                id?: string;
                checkpoints?: {
                    [key: string]: string;
                };
            } = {};
            if (this.id != null) {
                data.id = this.id;
            }
            if (this.checkpoints.size > 0) {
                data.checkpoints = Object.fromEntries(this.checkpoints);
            }
            return data;
        }
        serialize(): Uint8Array;
        serialize(w: pb_1.BinaryWriter): void;
        serialize(w?: pb_1.BinaryWriter): Uint8Array | void {
            const writer = w || new pb_1.BinaryWriter();
            if (typeof this.id === "string" && this.id.length)
                writer.writeString(1, this.id);
            for (const [key, value] of this.checkpoints) {
                writer.writeMessage(2, this.checkpoints, () => {
                    writer.writeString(1, key);
                    writer.writeString(2, value);
                });
            }
            if (!w)
                return writer.getResultBuffer();
        }
        static deserialize(bytes: Uint8Array | pb_1.BinaryReader): CheckpointTracker {
            const reader = bytes instanceof pb_1.BinaryReader ? bytes : new pb_1.BinaryReader(bytes), message = new CheckpointTracker();
            while (reader.nextField()) {
                if (reader.isEndGroup())
                    break;
                switch (reader.getFieldNumber()) {
                    case 1:
                        message.id = reader.readString();
                        break;
                    case 2:
                        reader.readMessage(message, () => pb_1.Map.deserializeBinary(message.checkpoints as any, reader, reader.readString, reader.readString));
                        break;
                    default: reader.skipField();
                }
            }
            return message;
        }
        serializeBinary(): Uint8Array {
            return this.serialize();
        }
        static deserializeBinary(bytes: Uint8Array): CheckpointTracker {
            return CheckpointTracker.deserialize(bytes);
        }
    }
}