Class v1.LineageClient (1.1.0)

Package

Constructors

(constructor)(opts, gaxInstance)

constructor(opts?: ClientOptions, gaxInstance?: typeof gax | typeof gax.fallback);

Properties

apiEndpoint

static get apiEndpoint(): string;

auth

auth: gax.GoogleAuth;

descriptors

descriptors: Descriptors;

innerApiCalls

innerApiCalls: {
        [name: string]: Function;
    };

lineageStub

lineageStub?: Promise<{
        [name: string]: Function;
    }>;

operationsClient

operationsClient: gax.OperationsClient;

pathTemplates

pathTemplates: {
        [name: string]: gax.PathTemplate;
    };

port

static get port(): number;

scopes

static get scopes(): string[];

servicePath

static get servicePath(): string;

warn

warn: (code: string, message: string, warnType?: string) => void;

Methods

batchSearchLinkProcesses(request, options)

batchSearchLinkProcesses(request?: protos.google.cloud.datacatalog.lineage.v1.IBatchSearchLinkProcessesRequest, options?: CallOptions): Promise<[
        protos.google.cloud.datacatalog.lineage.v1.IProcessLinks[],
        protos.google.cloud.datacatalog.lineage.v1.IBatchSearchLinkProcessesRequest | null,
        protos.google.cloud.datacatalog.lineage.v1.IBatchSearchLinkProcessesResponse
    ]>;

batchSearchLinkProcesses(request, options, callback)

batchSearchLinkProcesses(request: protos.google.cloud.datacatalog.lineage.v1.IBatchSearchLinkProcessesRequest, options: CallOptions, callback: PaginationCallback<protos.google.cloud.datacatalog.lineage.v1.IBatchSearchLinkProcessesRequest, protos.google.cloud.datacatalog.lineage.v1.IBatchSearchLinkProcessesResponse | null | undefined, protos.google.cloud.datacatalog.lineage.v1.IProcessLinks>): void;

batchSearchLinkProcesses(request, callback)

batchSearchLinkProcesses(request: protos.google.cloud.datacatalog.lineage.v1.IBatchSearchLinkProcessesRequest, callback: PaginationCallback<protos.google.cloud.datacatalog.lineage.v1.IBatchSearchLinkProcessesRequest, protos.google.cloud.datacatalog.lineage.v1.IBatchSearchLinkProcessesResponse | null | undefined, protos.google.cloud.datacatalog.lineage.v1.IProcessLinks>): void;

batchSearchLinkProcessesAsync(request, options)

batchSearchLinkProcessesAsync(request?: protos.google.cloud.datacatalog.lineage.v1.IBatchSearchLinkProcessesRequest, options?: CallOptions): AsyncIterable<protos.google.cloud.datacatalog.lineage.v1.IProcessLinks>;

  /**
   * This snippet has been automatically generated and should be regarded as a code template only.
   * It will require modifications to work.
   * It may require correct/in-range values for request initialization.
   * TODO(developer): Uncomment these variables before running the sample.
   */
  /**
   *  Required. The project and location where you want to search.
   */
  // const parent = 'abc123'
  /**
   *  Required. An array of links to check for their associated LineageProcesses.
   *  The maximum number of items in this array is 100.
   *  If the request contains more than 100 links, it returns the
   *  `INVALID_ARGUMENT` error.
   *  Format: `projects/{project}/locations/{location}/links/{link}`.
   */
  // const links = ['abc','def']
  /**
   *  The maximum number of processes to return in a single page of the response.
   *  A page may contain fewer results than this value.
   */
  // const pageSize = 1234
  /**
   *  The page token received from a previous `BatchSearchLinkProcesses` call.
   *  Use it to get the next page.
   *  When requesting subsequent pages of a response, remember that
   *  all parameters must match the values you provided
   *  in the original request.
   */
  // const pageToken = 'abc123'

  // Imports the Lineage library
  const {LineageClient} = require('@google-cloud/lineage').v1;

  // Instantiates a client
  const lineageClient = new LineageClient();

  async function callBatchSearchLinkProcesses() {
    // Construct request
    const request = {
      parent,
      links,
    };

    // Run request
    const iterable = await lineageClient.batchSearchLinkProcessesAsync(request);
    for await (const response of iterable) {
        console.log(response);
    }
  }

  callBatchSearchLinkProcesses();

batchSearchLinkProcessesStream(request, options)

batchSearchLinkProcessesStream(request?: protos.google.cloud.datacatalog.lineage.v1.IBatchSearchLinkProcessesRequest, options?: CallOptions): Transform;

cancelOperation(request, options, callback)

cancelOperation(request: protos.google.longrunning.CancelOperationRequest, options?: gax.CallOptions | Callback<protos.google.protobuf.Empty, protos.google.longrunning.CancelOperationRequest, {} | undefined | null>, callback?: Callback<protos.google.longrunning.CancelOperationRequest, protos.google.protobuf.Empty, {} | undefined | null>): Promise<protos.google.protobuf.Empty>;

const client = longrunning.operationsClient();
await client.cancelOperation({name: ''});

checkDeleteProcessProgress(name)

checkDeleteProcessProgress(name: string): Promise<LROperation<protos.google.protobuf.Empty, protos.google.cloud.datacatalog.lineage.v1.OperationMetadata>>;

  /**
   * This snippet has been automatically generated and should be regarded as a code template only.
   * It will require modifications to work.
   * It may require correct/in-range values for request initialization.
   * TODO(developer): Uncomment these variables before running the sample.
   */
  /**
   *  Required. The name of the process to delete.
   */
  // const name = 'abc123'
  /**
   *  If set to true and the process is not found, the request
   *  succeeds but the server doesn't perform any actions.
   */
  // const allowMissing = true

  // Imports the Lineage library
  const {LineageClient} = require('@google-cloud/lineage').v1;

  // Instantiates a client
  const lineageClient = new LineageClient();

  async function callDeleteProcess() {
    // Construct request
    const request = {
      name,
    };

    // Run request
    const [operation] = await lineageClient.deleteProcess(request);
    const [response] = await operation.promise();
    console.log(response);
  }

  callDeleteProcess();

checkDeleteRunProgress(name)

checkDeleteRunProgress(name: string): Promise<LROperation<protos.google.protobuf.Empty, protos.google.cloud.datacatalog.lineage.v1.OperationMetadata>>;

  /**
   * This snippet has been automatically generated and should be regarded as a code template only.
   * It will require modifications to work.
   * It may require correct/in-range values for request initialization.
   * TODO(developer): Uncomment these variables before running the sample.
   */
  /**
   *  Required. The name of the run to delete.
   */
  // const name = 'abc123'
  /**
   *  If set to true and the run is not found, the request
   *  succeeds but the server doesn't perform any actions.
   */
  // const allowMissing = true

  // Imports the Lineage library
  const {LineageClient} = require('@google-cloud/lineage').v1;

  // Instantiates a client
  const lineageClient = new LineageClient();

  async function callDeleteRun() {
    // Construct request
    const request = {
      name,
    };

    // Run request
    const [operation] = await lineageClient.deleteRun(request);
    const [response] = await operation.promise();
    console.log(response);
  }

  callDeleteRun();

close()

close(): Promise<void>;

createLineageEvent(request, options)

createLineageEvent(request?: protos.google.cloud.datacatalog.lineage.v1.ICreateLineageEventRequest, options?: CallOptions): Promise<[
        protos.google.cloud.datacatalog.lineage.v1.ILineageEvent,
        (protos.google.cloud.datacatalog.lineage.v1.ICreateLineageEventRequest | undefined),
        {} | undefined
    ]>;

  /**
   * This snippet has been automatically generated and should be regarded as a code template only.
   * It will require modifications to work.
   * It may require correct/in-range values for request initialization.
   * TODO(developer): Uncomment these variables before running the sample.
   */
  /**
   *  Required. The name of the run that should own the lineage event.
   */
  // const parent = 'abc123'
  /**
   *  Required. The lineage event to create.
   */
  // const lineageEvent = {}
  /**
   *  A unique identifier for this request. Restricted to 36 ASCII characters.
   *  A random UUID is recommended. This request is idempotent only if a
   *  `request_id` is provided.
   */
  // const requestId = 'abc123'

  // Imports the Lineage library
  const {LineageClient} = require('@google-cloud/lineage').v1;

  // Instantiates a client
  const lineageClient = new LineageClient();

  async function callCreateLineageEvent() {
    // Construct request
    const request = {
      parent,
      lineageEvent,
    };

    // Run request
    const response = await lineageClient.createLineageEvent(request);
    console.log(response);
  }

  callCreateLineageEvent();

createLineageEvent(request, options, callback)

createLineageEvent(request: protos.google.cloud.datacatalog.lineage.v1.ICreateLineageEventRequest, options: CallOptions, callback: Callback<protos.google.cloud.datacatalog.lineage.v1.ILineageEvent, protos.google.cloud.datacatalog.lineage.v1.ICreateLineageEventRequest | null | undefined, {} | null | undefined>): void;

createLineageEvent(request, callback)

createLineageEvent(request: protos.google.cloud.datacatalog.lineage.v1.ICreateLineageEventRequest, callback: Callback<protos.google.cloud.datacatalog.lineage.v1.ILineageEvent, protos.google.cloud.datacatalog.lineage.v1.ICreateLineageEventRequest | null | undefined, {} | null | undefined>): void;

createProcess(request, options)

createProcess(request?: protos.google.cloud.datacatalog.lineage.v1.ICreateProcessRequest, options?: CallOptions): Promise<[
        protos.google.cloud.datacatalog.lineage.v1.IProcess,
        (protos.google.cloud.datacatalog.lineage.v1.ICreateProcessRequest | undefined),
        {} | undefined
    ]>;

  /**
   * This snippet has been automatically generated and should be regarded as a code template only.
   * It will require modifications to work.
   * It may require correct/in-range values for request initialization.
   * TODO(developer): Uncomment these variables before running the sample.
   */
  /**
   *  Required. The name of the project and its location that should own the
   *  process.
   */
  // const parent = 'abc123'
  /**
   *  Required. The process to create.
   */
  // const process = {}
  /**
   *  A unique identifier for this request. Restricted to 36 ASCII characters.
   *  A random UUID is recommended. This request is idempotent only if a
   *  `request_id` is provided.
   */
  // const requestId = 'abc123'

  // Imports the Lineage library
  const {LineageClient} = require('@google-cloud/lineage').v1;

  // Instantiates a client
  const lineageClient = new LineageClient();

  async function callCreateProcess() {
    // Construct request
    const request = {
      parent,
      process,
    };

    // Run request
    const response = await lineageClient.createProcess(request);
    console.log(response);
  }

  callCreateProcess();

createProcess(request, options, callback)

createProcess(request: protos.google.cloud.datacatalog.lineage.v1.ICreateProcessRequest, options: CallOptions, callback: Callback<protos.google.cloud.datacatalog.lineage.v1.IProcess, protos.google.cloud.datacatalog.lineage.v1.ICreateProcessRequest | null | undefined, {} | null | undefined>): void;

createProcess(request, callback)

createProcess(request: protos.google.cloud.datacatalog.lineage.v1.ICreateProcessRequest, callback: Callback<protos.google.cloud.datacatalog.lineage.v1.IProcess, protos.google.cloud.datacatalog.lineage.v1.ICreateProcessRequest | null | undefined, {} | null | undefined>): void;

createRun(request, options)

createRun(request?: protos.google.cloud.datacatalog.lineage.v1.ICreateRunRequest, options?: CallOptions): Promise<[
        protos.google.cloud.datacatalog.lineage.v1.IRun,
        protos.google.cloud.datacatalog.lineage.v1.ICreateRunRequest | undefined,
        {} | undefined
    ]>;

  /**
   * This snippet has been automatically generated and should be regarded as a code template only.
   * It will require modifications to work.
   * It may require correct/in-range values for request initialization.
   * TODO(developer): Uncomment these variables before running the sample.
   */
  /**
   *  Required. The name of the process that should own the run.
   */
  // const parent = 'abc123'
  /**
   *  Required. The run to create.
   */
  // const run = {}
  /**
   *  A unique identifier for this request. Restricted to 36 ASCII characters.
   *  A random UUID is recommended. This request is idempotent only if a
   *  `request_id` is provided.
   */
  // const requestId = 'abc123'

  // Imports the Lineage library
  const {LineageClient} = require('@google-cloud/lineage').v1;

  // Instantiates a client
  const lineageClient = new LineageClient();

  async function callCreateRun() {
    // Construct request
    const request = {
      parent,
      run,
    };

    // Run request
    const response = await lineageClient.createRun(request);
    console.log(response);
  }

  callCreateRun();

createRun(request, options, callback)

createRun(request: protos.google.cloud.datacatalog.lineage.v1.ICreateRunRequest, options: CallOptions, callback: Callback<protos.google.cloud.datacatalog.lineage.v1.IRun, protos.google.cloud.datacatalog.lineage.v1.ICreateRunRequest | null | undefined, {} | null | undefined>): void;

createRun(request, callback)

createRun(request: protos.google.cloud.datacatalog.lineage.v1.ICreateRunRequest, callback: Callback<protos.google.cloud.datacatalog.lineage.v1.IRun, protos.google.cloud.datacatalog.lineage.v1.ICreateRunRequest | null | undefined, {} | null | undefined>): void;

deleteLineageEvent(request, options)

deleteLineageEvent(request?: protos.google.cloud.datacatalog.lineage.v1.IDeleteLineageEventRequest, options?: CallOptions): Promise<[
        protos.google.protobuf.IEmpty,
        (protos.google.cloud.datacatalog.lineage.v1.IDeleteLineageEventRequest | undefined),
        {} | undefined
    ]>;

  /**
   * This snippet has been automatically generated and should be regarded as a code template only.
   * It will require modifications to work.
   * It may require correct/in-range values for request initialization.
   * TODO(developer): Uncomment these variables before running the sample.
   */
  /**
   *  Required. The name of the lineage event to delete.
   */
  // const name = 'abc123'
  /**
   *  If set to true and the lineage event is not found, the request
   *  succeeds but the server doesn't perform any actions.
   */
  // const allowMissing = true

  // Imports the Lineage library
  const {LineageClient} = require('@google-cloud/lineage').v1;

  // Instantiates a client
  const lineageClient = new LineageClient();

  async function callDeleteLineageEvent() {
    // Construct request
    const request = {
      name,
    };

    // Run request
    const response = await lineageClient.deleteLineageEvent(request);
    console.log(response);
  }

  callDeleteLineageEvent();

deleteLineageEvent(request, options, callback)

deleteLineageEvent(request: protos.google.cloud.datacatalog.lineage.v1.IDeleteLineageEventRequest, options: CallOptions, callback: Callback<protos.google.protobuf.IEmpty, protos.google.cloud.datacatalog.lineage.v1.IDeleteLineageEventRequest | null | undefined, {} | null | undefined>): void;

deleteLineageEvent(request, callback)

deleteLineageEvent(request: protos.google.cloud.datacatalog.lineage.v1.IDeleteLineageEventRequest, callback: Callback<protos.google.protobuf.IEmpty, protos.google.cloud.datacatalog.lineage.v1.IDeleteLineageEventRequest | null | undefined, {} | null | undefined>): void;

deleteOperation(request, options, callback)

deleteOperation(request: protos.google.longrunning.DeleteOperationRequest, options?: gax.CallOptions | Callback<protos.google.protobuf.Empty, protos.google.longrunning.DeleteOperationRequest, {} | null | undefined>, callback?: Callback<protos.google.protobuf.Empty, protos.google.longrunning.DeleteOperationRequest, {} | null | undefined>): Promise<protos.google.protobuf.Empty>;

const client = longrunning.operationsClient();
await client.deleteOperation({name: ''});

deleteProcess(request, options)

deleteProcess(request?: protos.google.cloud.datacatalog.lineage.v1.IDeleteProcessRequest, options?: CallOptions): Promise<[
        LROperation<protos.google.protobuf.IEmpty, protos.google.cloud.datacatalog.lineage.v1.IOperationMetadata>,
        protos.google.longrunning.IOperation | undefined,
        {} | undefined
    ]>;

  /**
   * This snippet has been automatically generated and should be regarded as a code template only.
   * It will require modifications to work.
   * It may require correct/in-range values for request initialization.
   * TODO(developer): Uncomment these variables before running the sample.
   */
  /**
   *  Required. The name of the process to delete.
   */
  // const name = 'abc123'
  /**
   *  If set to true and the process is not found, the request
   *  succeeds but the server doesn't perform any actions.
   */
  // const allowMissing = true

  // Imports the Lineage library
  const {LineageClient} = require('@google-cloud/lineage').v1;

  // Instantiates a client
  const lineageClient = new LineageClient();

  async function callDeleteProcess() {
    // Construct request
    const request = {
      name,
    };

    // Run request
    const [operation] = await lineageClient.deleteProcess(request);
    const [response] = await operation.promise();
    console.log(response);
  }

  callDeleteProcess();

deleteProcess(request, options, callback)

deleteProcess(request: protos.google.cloud.datacatalog.lineage.v1.IDeleteProcessRequest, options: CallOptions, callback: Callback<LROperation<protos.google.protobuf.IEmpty, protos.google.cloud.datacatalog.lineage.v1.IOperationMetadata>, protos.google.longrunning.IOperation | null | undefined, {} | null | undefined>): void;

deleteProcess(request, callback)

deleteProcess(request: protos.google.cloud.datacatalog.lineage.v1.IDeleteProcessRequest, callback: Callback<LROperation<protos.google.protobuf.IEmpty, protos.google.cloud.datacatalog.lineage.v1.IOperationMetadata>, protos.google.longrunning.IOperation | null | undefined, {} | null | undefined>): void;

deleteRun(request, options)

deleteRun(request?: protos.google.cloud.datacatalog.lineage.v1.IDeleteRunRequest, options?: CallOptions): Promise<[
        LROperation<protos.google.protobuf.IEmpty, protos.google.cloud.datacatalog.lineage.v1.IOperationMetadata>,
        protos.google.longrunning.IOperation | undefined,
        {} | undefined
    ]>;

  /**
   * This snippet has been automatically generated and should be regarded as a code template only.
   * It will require modifications to work.
   * It may require correct/in-range values for request initialization.
   * TODO(developer): Uncomment these variables before running the sample.
   */
  /**
   *  Required. The name of the run to delete.
   */
  // const name = 'abc123'
  /**
   *  If set to true and the run is not found, the request
   *  succeeds but the server doesn't perform any actions.
   */
  // const allowMissing = true

  // Imports the Lineage library
  const {LineageClient} = require('@google-cloud/lineage').v1;

  // Instantiates a client
  const lineageClient = new LineageClient();

  async function callDeleteRun() {
    // Construct request
    const request = {
      name,
    };

    // Run request
    const [operation] = await lineageClient.deleteRun(request);
    const [response] = await operation.promise();
    console.log(response);
  }

  callDeleteRun();

deleteRun(request, options, callback)

deleteRun(request: protos.google.cloud.datacatalog.lineage.v1.IDeleteRunRequest, options: CallOptions, callback: Callback<LROperation<protos.google.protobuf.IEmpty, protos.google.cloud.datacatalog.lineage.v1.IOperationMetadata>, protos.google.longrunning.IOperation | null | undefined, {} | null | undefined>): void;

deleteRun(request, callback)

deleteRun(request: protos.google.cloud.datacatalog.lineage.v1.IDeleteRunRequest, callback: Callback<LROperation<protos.google.protobuf.IEmpty, protos.google.cloud.datacatalog.lineage.v1.IOperationMetadata>, protos.google.longrunning.IOperation | null | undefined, {} | null | undefined>): void;

getLineageEvent(request, options)

getLineageEvent(request?: protos.google.cloud.datacatalog.lineage.v1.IGetLineageEventRequest, options?: CallOptions): Promise<[
        protos.google.cloud.datacatalog.lineage.v1.ILineageEvent,
        (protos.google.cloud.datacatalog.lineage.v1.IGetLineageEventRequest | undefined),
        {} | undefined
    ]>;

  /**
   * This snippet has been automatically generated and should be regarded as a code template only.
   * It will require modifications to work.
   * It may require correct/in-range values for request initialization.
   * TODO(developer): Uncomment these variables before running the sample.
   */
  /**
   *  Required. The name of the lineage event to get.
   */
  // const name = 'abc123'

  // Imports the Lineage library
  const {LineageClient} = require('@google-cloud/lineage').v1;

  // Instantiates a client
  const lineageClient = new LineageClient();

  async function callGetLineageEvent() {
    // Construct request
    const request = {
      name,
    };

    // Run request
    const response = await lineageClient.getLineageEvent(request);
    console.log(response);
  }

  callGetLineageEvent();

getLineageEvent(request, options, callback)

getLineageEvent(request: protos.google.cloud.datacatalog.lineage.v1.IGetLineageEventRequest, options: CallOptions, callback: Callback<protos.google.cloud.datacatalog.lineage.v1.ILineageEvent, protos.google.cloud.datacatalog.lineage.v1.IGetLineageEventRequest | null | undefined, {} | null | undefined>): void;

getLineageEvent(request, callback)

getLineageEvent(request: protos.google.cloud.datacatalog.lineage.v1.IGetLineageEventRequest, callback: Callback<protos.google.cloud.datacatalog.lineage.v1.ILineageEvent, protos.google.cloud.datacatalog.lineage.v1.IGetLineageEventRequest | null | undefined, {} | null | undefined>): void;

getOperation(request, options, callback)

getOperation(request: protos.google.longrunning.GetOperationRequest, options?: gax.CallOptions | Callback<protos.google.longrunning.Operation, protos.google.longrunning.GetOperationRequest, {} | null | undefined>, callback?: Callback<protos.google.longrunning.Operation, protos.google.longrunning.GetOperationRequest, {} | null | undefined>): Promise<[protos.google.longrunning.Operation]>;

const client = longrunning.operationsClient();
const name = '';
const [response] = await client.getOperation({name});
// doThingsWith(response)

getProcess(request, options)

getProcess(request?: protos.google.cloud.datacatalog.lineage.v1.IGetProcessRequest, options?: CallOptions): Promise<[
        protos.google.cloud.datacatalog.lineage.v1.IProcess,
        protos.google.cloud.datacatalog.lineage.v1.IGetProcessRequest | undefined,
        {} | undefined
    ]>;

  /**
   * This snippet has been automatically generated and should be regarded as a code template only.
   * It will require modifications to work.
   * It may require correct/in-range values for request initialization.
   * TODO(developer): Uncomment these variables before running the sample.
   */
  /**
   *  Required. The name of the process to get.
   */
  // const name = 'abc123'

  // Imports the Lineage library
  const {LineageClient} = require('@google-cloud/lineage').v1;

  // Instantiates a client
  const lineageClient = new LineageClient();

  async function callGetProcess() {
    // Construct request
    const request = {
      name,
    };

    // Run request
    const response = await lineageClient.getProcess(request);
    console.log(response);
  }

  callGetProcess();

getProcess(request, options, callback)

getProcess(request: protos.google.cloud.datacatalog.lineage.v1.IGetProcessRequest, options: CallOptions, callback: Callback<protos.google.cloud.datacatalog.lineage.v1.IProcess, protos.google.cloud.datacatalog.lineage.v1.IGetProcessRequest | null | undefined, {} | null | undefined>): void;

getProcess(request, callback)

getProcess(request: protos.google.cloud.datacatalog.lineage.v1.IGetProcessRequest, callback: Callback<protos.google.cloud.datacatalog.lineage.v1.IProcess, protos.google.cloud.datacatalog.lineage.v1.IGetProcessRequest | null | undefined, {} | null | undefined>): void;

getProjectId()

getProjectId(): Promise<string>;

getProjectId(callback)

getProjectId(callback: Callback<string, undefined, undefined>): void;

getRun(request, options)

getRun(request?: protos.google.cloud.datacatalog.lineage.v1.IGetRunRequest, options?: CallOptions): Promise<[
        protos.google.cloud.datacatalog.lineage.v1.IRun,
        protos.google.cloud.datacatalog.lineage.v1.IGetRunRequest | undefined,
        {} | undefined
    ]>;

  /**
   * This snippet has been automatically generated and should be regarded as a code template only.
   * It will require modifications to work.
   * It may require correct/in-range values for request initialization.
   * TODO(developer): Uncomment these variables before running the sample.
   */
  /**
   *  Required. The name of the run to get.
   */
  // const name = 'abc123'

  // Imports the Lineage library
  const {LineageClient} = require('@google-cloud/lineage').v1;

  // Instantiates a client
  const lineageClient = new LineageClient();

  async function callGetRun() {
    // Construct request
    const request = {
      name,
    };

    // Run request
    const response = await lineageClient.getRun(request);
    console.log(response);
  }

  callGetRun();

getRun(request, options, callback)

getRun(request: protos.google.cloud.datacatalog.lineage.v1.IGetRunRequest, options: CallOptions, callback: Callback<protos.google.cloud.datacatalog.lineage.v1.IRun, protos.google.cloud.datacatalog.lineage.v1.IGetRunRequest | null | undefined, {} | null | undefined>): void;

getRun(request, callback)

getRun(request: protos.google.cloud.datacatalog.lineage.v1.IGetRunRequest, callback: Callback<protos.google.cloud.datacatalog.lineage.v1.IRun, protos.google.cloud.datacatalog.lineage.v1.IGetRunRequest | null | undefined, {} | null | undefined>): void;

initialize()

initialize(): Promise<{
        [name: string]: Function;
    }>;

lineageEventPath(project, location, process, run, lineageEvent)

lineageEventPath(project: string, location: string, process: string, run: string, lineageEvent: string): string;

listLineageEvents(request, options)

listLineageEvents(request?: protos.google.cloud.datacatalog.lineage.v1.IListLineageEventsRequest, options?: CallOptions): Promise<[
        protos.google.cloud.datacatalog.lineage.v1.ILineageEvent[],
        protos.google.cloud.datacatalog.lineage.v1.IListLineageEventsRequest | null,
        protos.google.cloud.datacatalog.lineage.v1.IListLineageEventsResponse
    ]>;

listLineageEvents(request, options, callback)

listLineageEvents(request: protos.google.cloud.datacatalog.lineage.v1.IListLineageEventsRequest, options: CallOptions, callback: PaginationCallback<protos.google.cloud.datacatalog.lineage.v1.IListLineageEventsRequest, protos.google.cloud.datacatalog.lineage.v1.IListLineageEventsResponse | null | undefined, protos.google.cloud.datacatalog.lineage.v1.ILineageEvent>): void;

listLineageEvents(request, callback)

listLineageEvents(request: protos.google.cloud.datacatalog.lineage.v1.IListLineageEventsRequest, callback: PaginationCallback<protos.google.cloud.datacatalog.lineage.v1.IListLineageEventsRequest, protos.google.cloud.datacatalog.lineage.v1.IListLineageEventsResponse | null | undefined, protos.google.cloud.datacatalog.lineage.v1.ILineageEvent>): void;

listLineageEventsAsync(request, options)

listLineageEventsAsync(request?: protos.google.cloud.datacatalog.lineage.v1.IListLineageEventsRequest, options?: CallOptions): AsyncIterable<protos.google.cloud.datacatalog.lineage.v1.ILineageEvent>;

  /**
   * This snippet has been automatically generated and should be regarded as a code template only.
   * It will require modifications to work.
   * It may require correct/in-range values for request initialization.
   * TODO(developer): Uncomment these variables before running the sample.
   */
  /**
   *  Required. The name of the run that owns the collection of lineage events to
   *  get.
   */
  // const parent = 'abc123'
  /**
   *  The maximum number of lineage events to return.
   *  The service may return fewer events than this value.
   *  If unspecified, at most 50 events are returned. The maximum value is 100;
   *  values greater than 100 are cut to 100.
   */
  // const pageSize = 1234
  /**
   *  The page token received from a previous `ListLineageEvents` call. Specify
   *  it to get the next page.
   *  When paginating, all other parameters specified in this call must
   *  match the parameters of the call that provided the page token.
   */
  // const pageToken = 'abc123'

  // Imports the Lineage library
  const {LineageClient} = require('@google-cloud/lineage').v1;

  // Instantiates a client
  const lineageClient = new LineageClient();

  async function callListLineageEvents() {
    // Construct request
    const request = {
      parent,
    };

    // Run request
    const iterable = await lineageClient.listLineageEventsAsync(request);
    for await (const response of iterable) {
        console.log(response);
    }
  }

  callListLineageEvents();

listLineageEventsStream(request, options)

listLineageEventsStream(request?: protos.google.cloud.datacatalog.lineage.v1.IListLineageEventsRequest, options?: CallOptions): Transform;

listOperationsAsync(request, options)

listOperationsAsync(request: protos.google.longrunning.ListOperationsRequest, options?: gax.CallOptions): AsyncIterable<protos.google.longrunning.ListOperationsResponse>;

const client = longrunning.operationsClient();
for await (const response of client.listOperationsAsync(request));
// doThingsWith(response)

listProcesses(request, options)

listProcesses(request?: protos.google.cloud.datacatalog.lineage.v1.IListProcessesRequest, options?: CallOptions): Promise<[
        protos.google.cloud.datacatalog.lineage.v1.IProcess[],
        protos.google.cloud.datacatalog.lineage.v1.IListProcessesRequest | null,
        protos.google.cloud.datacatalog.lineage.v1.IListProcessesResponse
    ]>;

listProcesses(request, options, callback)

listProcesses(request: protos.google.cloud.datacatalog.lineage.v1.IListProcessesRequest, options: CallOptions, callback: PaginationCallback<protos.google.cloud.datacatalog.lineage.v1.IListProcessesRequest, protos.google.cloud.datacatalog.lineage.v1.IListProcessesResponse | null | undefined, protos.google.cloud.datacatalog.lineage.v1.IProcess>): void;

listProcesses(request, callback)

listProcesses(request: protos.google.cloud.datacatalog.lineage.v1.IListProcessesRequest, callback: PaginationCallback<protos.google.cloud.datacatalog.lineage.v1.IListProcessesRequest, protos.google.cloud.datacatalog.lineage.v1.IListProcessesResponse | null | undefined, protos.google.cloud.datacatalog.lineage.v1.IProcess>): void;

listProcessesAsync(request, options)

listProcessesAsync(request?: protos.google.cloud.datacatalog.lineage.v1.IListProcessesRequest, options?: CallOptions): AsyncIterable<protos.google.cloud.datacatalog.lineage.v1.IProcess>;

  /**
   * This snippet has been automatically generated and should be regarded as a code template only.
   * It will require modifications to work.
   * It may require correct/in-range values for request initialization.
   * TODO(developer): Uncomment these variables before running the sample.
   */
  /**
   *  Required. The name of the project and its location that owns this
   *  collection of processes.
   */
  // const parent = 'abc123'
  /**
   *  The maximum number of processes to return. The service may return
   *  fewer than this value. If unspecified, at most 50 processes are
   *  returned. The maximum value is 100; values greater than 100 are cut to
   *  100.
   */
  // const pageSize = 1234
  /**
   *  The page token received from a previous `ListProcesses` call. Specify
   *  it to get the next page.
   *  When paginating, all other parameters specified in this call must
   *  match the parameters of the call that provided the page token.
   */
  // const pageToken = 'abc123'

  // Imports the Lineage library
  const {LineageClient} = require('@google-cloud/lineage').v1;

  // Instantiates a client
  const lineageClient = new LineageClient();

  async function callListProcesses() {
    // Construct request
    const request = {
      parent,
    };

    // Run request
    const iterable = await lineageClient.listProcessesAsync(request);
    for await (const response of iterable) {
        console.log(response);
    }
  }

  callListProcesses();

listProcessesStream(request, options)

listProcessesStream(request?: protos.google.cloud.datacatalog.lineage.v1.IListProcessesRequest, options?: CallOptions): Transform;

listRuns(request, options)

listRuns(request?: protos.google.cloud.datacatalog.lineage.v1.IListRunsRequest, options?: CallOptions): Promise<[
        protos.google.cloud.datacatalog.lineage.v1.IRun[],
        protos.google.cloud.datacatalog.lineage.v1.IListRunsRequest | null,
        protos.google.cloud.datacatalog.lineage.v1.IListRunsResponse
    ]>;

listRuns(request, options, callback)

listRuns(request: protos.google.cloud.datacatalog.lineage.v1.IListRunsRequest, options: CallOptions, callback: PaginationCallback<protos.google.cloud.datacatalog.lineage.v1.IListRunsRequest, protos.google.cloud.datacatalog.lineage.v1.IListRunsResponse | null | undefined, protos.google.cloud.datacatalog.lineage.v1.IRun>): void;

listRuns(request, callback)

listRuns(request: protos.google.cloud.datacatalog.lineage.v1.IListRunsRequest, callback: PaginationCallback<protos.google.cloud.datacatalog.lineage.v1.IListRunsRequest, protos.google.cloud.datacatalog.lineage.v1.IListRunsResponse | null | undefined, protos.google.cloud.datacatalog.lineage.v1.IRun>): void;

listRunsAsync(request, options)

listRunsAsync(request?: protos.google.cloud.datacatalog.lineage.v1.IListRunsRequest, options?: CallOptions): AsyncIterable<protos.google.cloud.datacatalog.lineage.v1.IRun>;

  /**
   * This snippet has been automatically generated and should be regarded as a code template only.
   * It will require modifications to work.
   * It may require correct/in-range values for request initialization.
   * TODO(developer): Uncomment these variables before running the sample.
   */
  /**
   *  Required. The name of process that owns this collection of runs.
   */
  // const parent = 'abc123'
  /**
   *  The maximum number of runs to return. The service may return
   *  fewer than this value. If unspecified, at most 50 runs are
   *  returned. The maximum value is 100; values greater than 100 are cut to
   *  100.
   */
  // const pageSize = 1234
  /**
   *  The page token received from a previous `ListRuns` call. Specify
   *  it to get the next page.
   *  When paginating, all other parameters specified in this call must
   *  match the parameters of the call that provided the page token.
   */
  // const pageToken = 'abc123'

  // Imports the Lineage library
  const {LineageClient} = require('@google-cloud/lineage').v1;

  // Instantiates a client
  const lineageClient = new LineageClient();

  async function callListRuns() {
    // Construct request
    const request = {
      parent,
    };

    // Run request
    const iterable = await lineageClient.listRunsAsync(request);
    for await (const response of iterable) {
        console.log(response);
    }
  }

  callListRuns();

listRunsStream(request, options)

listRunsStream(request?: protos.google.cloud.datacatalog.lineage.v1.IListRunsRequest, options?: CallOptions): Transform;

locationPath(project, location)

locationPath(project: string, location: string): string;

matchLineageEventFromLineageEventName(lineageEventName)

matchLineageEventFromLineageEventName(lineageEventName: string): string | number;

matchLocationFromLineageEventName(lineageEventName)

matchLocationFromLineageEventName(lineageEventName: string): string | number;

matchLocationFromLocationName(locationName)

matchLocationFromLocationName(locationName: string): string | number;

matchLocationFromProcessName(processName)

matchLocationFromProcessName(processName: string): string | number;

matchLocationFromRunName(runName)

matchLocationFromRunName(runName: string): string | number;

matchProcessFromLineageEventName(lineageEventName)

matchProcessFromLineageEventName(lineageEventName: string): string | number;

matchProcessFromProcessName(processName)

matchProcessFromProcessName(processName: string): string | number;

matchProcessFromRunName(runName)

matchProcessFromRunName(runName: string): string | number;

matchProjectFromLineageEventName(lineageEventName)

matchProjectFromLineageEventName(lineageEventName: string): string | number;

matchProjectFromLocationName(locationName)

matchProjectFromLocationName(locationName: string): string | number;

matchProjectFromProcessName(processName)

matchProjectFromProcessName(processName: string): string | number;

matchProjectFromProjectName(projectName)

matchProjectFromProjectName(projectName: string): string | number;

matchProjectFromRunName(runName)

matchProjectFromRunName(runName: string): string | number;

matchRunFromLineageEventName(lineageEventName)

matchRunFromLineageEventName(lineageEventName: string): string | number;

matchRunFromRunName(runName)

matchRunFromRunName(runName: string): string | number;

processOpenLineageRunEvent(request, options)

processOpenLineageRunEvent(request?: protos.google.cloud.datacatalog.lineage.v1.IProcessOpenLineageRunEventRequest, options?: CallOptions): Promise<[
        protos.google.cloud.datacatalog.lineage.v1.IProcessOpenLineageRunEventResponse,
        (protos.google.cloud.datacatalog.lineage.v1.IProcessOpenLineageRunEventRequest | undefined),
        {} | undefined
    ]>;

  /**
   * This snippet has been automatically generated and should be regarded as a code template only.
   * It will require modifications to work.
   * It may require correct/in-range values for request initialization.
   * TODO(developer): Uncomment these variables before running the sample.
   */
  /**
   *  Required. The name of the project and its location that should own the
   *  process, run, and lineage event.
   */
  // const parent = 'abc123'
  /**
   *  Required. OpenLineage message following OpenLineage format:
   *  https://github.com/OpenLineage/OpenLineage/blob/main/spec/OpenLineage.json
   */
  // const openLineage = {}
  /**
   *  A unique identifier for this request. Restricted to 36 ASCII characters.
   *  A random UUID is recommended. This request is idempotent only if a
   *  `request_id` is provided.
   */
  // const requestId = 'abc123'

  // Imports the Lineage library
  const {LineageClient} = require('@google-cloud/lineage').v1;

  // Instantiates a client
  const lineageClient = new LineageClient();

  async function callProcessOpenLineageRunEvent() {
    // Construct request
    const request = {
      parent,
      openLineage,
    };

    // Run request
    const response = await lineageClient.processOpenLineageRunEvent(request);
    console.log(response);
  }

  callProcessOpenLineageRunEvent();

processOpenLineageRunEvent(request, options, callback)

processOpenLineageRunEvent(request: protos.google.cloud.datacatalog.lineage.v1.IProcessOpenLineageRunEventRequest, options: CallOptions, callback: Callback<protos.google.cloud.datacatalog.lineage.v1.IProcessOpenLineageRunEventResponse, protos.google.cloud.datacatalog.lineage.v1.IProcessOpenLineageRunEventRequest | null | undefined, {} | null | undefined>): void;

processOpenLineageRunEvent(request, callback)

processOpenLineageRunEvent(request: protos.google.cloud.datacatalog.lineage.v1.IProcessOpenLineageRunEventRequest, callback: Callback<protos.google.cloud.datacatalog.lineage.v1.IProcessOpenLineageRunEventResponse, protos.google.cloud.datacatalog.lineage.v1.IProcessOpenLineageRunEventRequest | null | undefined, {} | null | undefined>): void;

processPath(project, location, process)

processPath(project: string, location: string, process: string): string;

projectPath(project)

projectPath(project: string): string;

runPath(project, location, process, run)

runPath(project: string, location: string, process: string, run: string): string;

searchLinks(request, options)

searchLinks(request?: protos.google.cloud.datacatalog.lineage.v1.ISearchLinksRequest, options?: CallOptions): Promise<[
        protos.google.cloud.datacatalog.lineage.v1.ILink[],
        protos.google.cloud.datacatalog.lineage.v1.ISearchLinksRequest | null,
        protos.google.cloud.datacatalog.lineage.v1.ISearchLinksResponse
    ]>;

searchLinks(request, options, callback)

searchLinks(request: protos.google.cloud.datacatalog.lineage.v1.ISearchLinksRequest, options: CallOptions, callback: PaginationCallback<protos.google.cloud.datacatalog.lineage.v1.ISearchLinksRequest, protos.google.cloud.datacatalog.lineage.v1.ISearchLinksResponse | null | undefined, protos.google.cloud.datacatalog.lineage.v1.ILink>): void;

searchLinks(request, callback)

searchLinks(request: protos.google.cloud.datacatalog.lineage.v1.ISearchLinksRequest, callback: PaginationCallback<protos.google.cloud.datacatalog.lineage.v1.ISearchLinksRequest, protos.google.cloud.datacatalog.lineage.v1.ISearchLinksResponse | null | undefined, protos.google.cloud.datacatalog.lineage.v1.ILink>): void;

searchLinksAsync(request, options)

searchLinksAsync(request?: protos.google.cloud.datacatalog.lineage.v1.ISearchLinksRequest, options?: CallOptions): AsyncIterable<protos.google.cloud.datacatalog.lineage.v1.ILink>;

  /**
   * This snippet has been automatically generated and should be regarded as a code template only.
   * It will require modifications to work.
   * It may require correct/in-range values for request initialization.
   * TODO(developer): Uncomment these variables before running the sample.
   */
  /**
   *  Required. The project and location you want search in.
   */
  // const parent = 'abc123'
  /**
   *  Optional. Send asset information in the **source** field to retrieve all
   *  links that lead from the specified asset to downstream assets.
   */
  // const source = {}
  /**
   *  Optional. Send asset information in the **target** field to retrieve all
   *  links that lead from upstream assets to the specified asset.
   */
  // const target = {}
  /**
   *  Optional. The maximum number of links to return in a single page of the
   *  response. A page may contain fewer links than this value. If unspecified,
   *  at most 10 links are returned.
   *  Maximum value is 100; values greater than 100 are reduced to 100.
   */
  // const pageSize = 1234
  /**
   *  Optional. The page token received from a previous `SearchLinksRequest`
   *  call. Use it to get the next page.
   *  When requesting subsequent pages of a response, remember that
   *  all parameters must match the values you provided
   *  in the original request.
   */
  // const pageToken = 'abc123'

  // Imports the Lineage library
  const {LineageClient} = require('@google-cloud/lineage').v1;

  // Instantiates a client
  const lineageClient = new LineageClient();

  async function callSearchLinks() {
    // Construct request
    const request = {
      parent,
    };

    // Run request
    const iterable = await lineageClient.searchLinksAsync(request);
    for await (const response of iterable) {
        console.log(response);
    }
  }

  callSearchLinks();

searchLinksStream(request, options)

searchLinksStream(request?: protos.google.cloud.datacatalog.lineage.v1.ISearchLinksRequest, options?: CallOptions): Transform;

updateProcess(request, options)

updateProcess(request?: protos.google.cloud.datacatalog.lineage.v1.IUpdateProcessRequest, options?: CallOptions): Promise<[
        protos.google.cloud.datacatalog.lineage.v1.IProcess,
        (protos.google.cloud.datacatalog.lineage.v1.IUpdateProcessRequest | undefined),
        {} | undefined
    ]>;

  /**
   * This snippet has been automatically generated and should be regarded as a code template only.
   * It will require modifications to work.
   * It may require correct/in-range values for request initialization.
   * TODO(developer): Uncomment these variables before running the sample.
   */
  /**
   *  Required. The lineage process to update.
   *  The process's `name` field is used to identify the process to update.
   */
  // const process = {}
  /**
   *  The list of fields to update. Currently not used. The whole message is
   *  updated.
   */
  // const updateMask = {}
  /**
   *  If set to true and the process is not found, the request inserts it.
   */
  // const allowMissing = true

  // Imports the Lineage library
  const {LineageClient} = require('@google-cloud/lineage').v1;

  // Instantiates a client
  const lineageClient = new LineageClient();

  async function callUpdateProcess() {
    // Construct request
    const request = {
      process,
    };

    // Run request
    const response = await lineageClient.updateProcess(request);
    console.log(response);
  }

  callUpdateProcess();

updateProcess(request, options, callback)

updateProcess(request: protos.google.cloud.datacatalog.lineage.v1.IUpdateProcessRequest, options: CallOptions, callback: Callback<protos.google.cloud.datacatalog.lineage.v1.IProcess, protos.google.cloud.datacatalog.lineage.v1.IUpdateProcessRequest | null | undefined, {} | null | undefined>): void;

updateProcess(request, callback)

updateProcess(request: protos.google.cloud.datacatalog.lineage.v1.IUpdateProcessRequest, callback: Callback<protos.google.cloud.datacatalog.lineage.v1.IProcess, protos.google.cloud.datacatalog.lineage.v1.IUpdateProcessRequest | null | undefined, {} | null | undefined>): void;

updateRun(request, options)

updateRun(request?: protos.google.cloud.datacatalog.lineage.v1.IUpdateRunRequest, options?: CallOptions): Promise<[
        protos.google.cloud.datacatalog.lineage.v1.IRun,
        protos.google.cloud.datacatalog.lineage.v1.IUpdateRunRequest | undefined,
        {} | undefined
    ]>;

  /**
   * This snippet has been automatically generated and should be regarded as a code template only.
   * It will require modifications to work.
   * It may require correct/in-range values for request initialization.
   * TODO(developer): Uncomment these variables before running the sample.
   */
  /**
   *  Required. The lineage run to update.
   *  The run's `name` field is used to identify the run to update.
   *  Format:
   *  `projects/{project}/locations/{location}/processes/{process}/runs/{run}`.
   */
  // const run = {}
  /**
   *  The list of fields to update. Currently not used. The whole message is
   *  updated.
   */
  // const updateMask = {}
  /**
   *  If set to true and the run is not found, the request creates it.
   */
  // const allowMissing = true

  // Imports the Lineage library
  const {LineageClient} = require('@google-cloud/lineage').v1;

  // Instantiates a client
  const lineageClient = new LineageClient();

  async function callUpdateRun() {
    // Construct request
    const request = {
      run,
    };

    // Run request
    const response = await lineageClient.updateRun(request);
    console.log(response);
  }

  callUpdateRun();

updateRun(request, options, callback)

updateRun(request: protos.google.cloud.datacatalog.lineage.v1.IUpdateRunRequest, options: CallOptions, callback: Callback<protos.google.cloud.datacatalog.lineage.v1.IRun, protos.google.cloud.datacatalog.lineage.v1.IUpdateRunRequest | null | undefined, {} | null | undefined>): void;

updateRun(request, callback)

updateRun(request: protos.google.cloud.datacatalog.lineage.v1.IUpdateRunRequest, callback: Callback<protos.google.cloud.datacatalog.lineage.v1.IRun, protos.google.cloud.datacatalog.lineage.v1.IUpdateRunRequest | null | undefined, {} | null | undefined>): void;