DATA-3916 Add protos for pipeline tracking (#671)

Co-authored-by: Katie Peters <[email protected]>
Co-authored-by: github-actions <41898282+github-actions[bot]@users.noreply.github.com>

Author: 3 people

app/datapipelines/v1/data_pipelines.pb.go

@@ -506,5 +506,66 @@ proto.viam.app.datapipelines.v1.DataPipelinesServicePromiseClient.prototype.disa
 };
 
 
+/**
+ * @const
+ * @type {!grpc.web.MethodDescriptor<
+ *   !proto.viam.app.datapipelines.v1.ListPipelineRunsRequest,
+ *   !proto.viam.app.datapipelines.v1.ListPipelineRunsResponse>}
+ */
+const methodDescriptor_DataPipelinesService_ListPipelineRuns = new grpc.web.MethodDescriptor(
+  '/viam.app.datapipelines.v1.DataPipelinesService/ListPipelineRuns',
+  grpc.web.MethodType.UNARY,
+  proto.viam.app.datapipelines.v1.ListPipelineRunsRequest,
+  proto.viam.app.datapipelines.v1.ListPipelineRunsResponse,
+  /**
+   * @param {!proto.viam.app.datapipelines.v1.ListPipelineRunsRequest} request
+   * @return {!Uint8Array}
+   */
+  function(request) {
+    return request.serializeBinary();
+  },
+  proto.viam.app.datapipelines.v1.ListPipelineRunsResponse.deserializeBinary
+);
+
+
+/**
+ * @param {!proto.viam.app.datapipelines.v1.ListPipelineRunsRequest} request The
+ *     request proto
+ * @param {?Object<string, string>} metadata User defined
+ *     call metadata
+ * @param {function(?grpc.web.RpcError, ?proto.viam.app.datapipelines.v1.ListPipelineRunsResponse)}
+ *     callback The callback function(error, response)
+ * @return {!grpc.web.ClientReadableStream<!proto.viam.app.datapipelines.v1.ListPipelineRunsResponse>|undefined}
+ *     The XHR Node Readable Stream
+ */
+proto.viam.app.datapipelines.v1.DataPipelinesServiceClient.prototype.listPipelineRuns =
+    function(request, metadata, callback) {
+  return this.client_.rpcCall(this.hostname_ +
+      '/viam.app.datapipelines.v1.DataPipelinesService/ListPipelineRuns',
+      request,
+      metadata || {},
+      methodDescriptor_DataPipelinesService_ListPipelineRuns,
+      callback);
+};
+
+
+/**
+ * @param {!proto.viam.app.datapipelines.v1.ListPipelineRunsRequest} request The
+ *     request proto
+ * @param {?Object<string, string>=} metadata User defined
+ *     call metadata
+ * @return {!Promise<!proto.viam.app.datapipelines.v1.ListPipelineRunsResponse>}
+ *     Promise that resolves to the response
+ */
+proto.viam.app.datapipelines.v1.DataPipelinesServicePromiseClient.prototype.listPipelineRuns =
+    function(request, metadata) {
+  return this.client_.unaryCall(this.hostname_ +
+      '/viam.app.datapipelines.v1.DataPipelinesService/ListPipelineRuns',
+      request,
+      metadata || {},
+      methodDescriptor_DataPipelinesService_ListPipelineRuns);
+};
+
+
 module.exports = proto.viam.app.datapipelines.v1;
 

app/datapipelines/v1/data_pipelines.pb.gw.go

@@ -360,3 +360,123 @@ export namespace DisableDataPipelineResponse {
   }
 }
 
+export class ListPipelineRunsRequest extends jspb.Message {
+  getId(): string;
+  setId(value: string): void;
+
+  getPageSize(): number;
+  setPageSize(value: number): void;
+
+  getPageToken(): string;
+  setPageToken(value: string): void;
+
+  serializeBinary(): Uint8Array;
+  toObject(includeInstance?: boolean): ListPipelineRunsRequest.AsObject;
+  static toObject(includeInstance: boolean, msg: ListPipelineRunsRequest): ListPipelineRunsRequest.AsObject;
+  static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
+  static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
+  static serializeBinaryToWriter(message: ListPipelineRunsRequest, writer: jspb.BinaryWriter): void;
+  static deserializeBinary(bytes: Uint8Array): ListPipelineRunsRequest;
+  static deserializeBinaryFromReader(message: ListPipelineRunsRequest, reader: jspb.BinaryReader): ListPipelineRunsRequest;
+}
+
+export namespace ListPipelineRunsRequest {
+  export type AsObject = {
+    id: string,
+    pageSize: number,
+    pageToken: string,
+  }
+}
+
+export class ListPipelineRunsResponse extends jspb.Message {
+  getPipelineId(): string;
+  setPipelineId(value: string): void;
+
+  clearRunsList(): void;
+  getRunsList(): Array<PipelineRun>;
+  setRunsList(value: Array<PipelineRun>): void;
+  addRuns(value?: PipelineRun, index?: number): PipelineRun;
+
+  getNextPageToken(): string;
+  setNextPageToken(value: string): void;
+
+  serializeBinary(): Uint8Array;
+  toObject(includeInstance?: boolean): ListPipelineRunsResponse.AsObject;
+  static toObject(includeInstance: boolean, msg: ListPipelineRunsResponse): ListPipelineRunsResponse.AsObject;
+  static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
+  static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
+  static serializeBinaryToWriter(message: ListPipelineRunsResponse, writer: jspb.BinaryWriter): void;
+  static deserializeBinary(bytes: Uint8Array): ListPipelineRunsResponse;
+  static deserializeBinaryFromReader(message: ListPipelineRunsResponse, reader: jspb.BinaryReader): ListPipelineRunsResponse;
+}
+
+export namespace ListPipelineRunsResponse {
+  export type AsObject = {
+    pipelineId: string,
+    runsList: Array<PipelineRun.AsObject>,
+    nextPageToken: string,
+  }
+}
+
+export class PipelineRun extends jspb.Message {
+  getId(): string;
+  setId(value: string): void;
+
+  hasStartTime(): boolean;
+  clearStartTime(): void;
+  getStartTime(): google_protobuf_timestamp_pb.Timestamp | undefined;
+  setStartTime(value?: google_protobuf_timestamp_pb.Timestamp): void;
+
+  hasEndTime(): boolean;
+  clearEndTime(): void;
+  getEndTime(): google_protobuf_timestamp_pb.Timestamp | undefined;
+  setEndTime(value?: google_protobuf_timestamp_pb.Timestamp): void;
+
+  hasDataStartTime(): boolean;
+  clearDataStartTime(): void;
+  getDataStartTime(): google_protobuf_timestamp_pb.Timestamp | undefined;
+  setDataStartTime(value?: google_protobuf_timestamp_pb.Timestamp): void;
+
+  hasDataEndTime(): boolean;
+  clearDataEndTime(): void;
+  getDataEndTime(): google_protobuf_timestamp_pb.Timestamp | undefined;
+  setDataEndTime(value?: google_protobuf_timestamp_pb.Timestamp): void;
+
+  getStatus(): PipelineRunStatusMap[keyof PipelineRunStatusMap];
+  setStatus(value: PipelineRunStatusMap[keyof PipelineRunStatusMap]): void;
+
+  getReason(): string;
+  setReason(value: string): void;
+
+  serializeBinary(): Uint8Array;
+  toObject(includeInstance?: boolean): PipelineRun.AsObject;
+  static toObject(includeInstance: boolean, msg: PipelineRun): PipelineRun.AsObject;
+  static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
+  static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
+  static serializeBinaryToWriter(message: PipelineRun, writer: jspb.BinaryWriter): void;
+  static deserializeBinary(bytes: Uint8Array): PipelineRun;
+  static deserializeBinaryFromReader(message: PipelineRun, reader: jspb.BinaryReader): PipelineRun;
+}
+
+export namespace PipelineRun {
+  export type AsObject = {
+    id: string,
+    startTime?: google_protobuf_timestamp_pb.Timestamp.AsObject,
+    endTime?: google_protobuf_timestamp_pb.Timestamp.AsObject,
+    dataStartTime?: google_protobuf_timestamp_pb.Timestamp.AsObject,
+    dataEndTime?: google_protobuf_timestamp_pb.Timestamp.AsObject,
+    status: PipelineRunStatusMap[keyof PipelineRunStatusMap],
+    reason: string,
+  }
+}
+
+export interface PipelineRunStatusMap {
+  PIPELINE_RUN_STATUS_UNSPECIFIED: 0;
+  PIPELINE_RUN_STATUS_SCHEDULED: 1;
+  PIPELINE_RUN_STATUS_STARTED: 2;
+  PIPELINE_RUN_STATUS_COMPLETED: 3;
+  PIPELINE_RUN_STATUS_FAILED: 4;
+}
+
+export const PipelineRunStatus: PipelineRunStatusMap;
+