Add tables steampipecloud_process, steampipecloud_workspace_pipeline …

…and steampipecloud_workspace_process . (#31)

Co-authored-by: Ved misra <[email protected]>

docs/tables/steampipecloud_process.md

@@ -0,0 +1,71 @@
+# Table: steampipecloud_process
+
+Allows to track various activities performed on an identity in Steampipe Cloud.
+
+## Examples
+
+### Basic info
+
+```sql
+select
+  id,
+  identity_handle,
+  identity_type,
+  pipeline_id,
+  type,
+  state,
+  created_at
+from
+  steampipecloud_process;
+```
+
+### List processes that are being run by an identity pipeline
+
+```sql
+select
+  id,
+  identity_handle,
+  identity_type,
+  pipeline_id,
+  type,
+  state,
+  created_at
+from
+  steampipecloud_process
+where
+  pipeline_id is not null;
+```
+
+### List user processes
+
+```sql
+select
+  id,
+  identity_handle,
+  identity_type,
+  pipeline_id,
+  type,
+  state,
+  created_at
+from
+  steampipecloud_process
+where
+  identity_type = 'user';
+```
+
+### List running processes
+
+```sql
+select
+  id,
+  identity_handle,
+  identity_type,
+  pipeline_id,
+  type,
+  state,
+  created_at
+from
+  steampipecloud_process
+where
+  state = 'running';
+```

docs/tables/steampipecloud_workspace_pipeline.md

@@ -0,0 +1,117 @@
+# Table: steampipecloud_workspace_pipeline
+
+Pipelines allow users to run different kinds of activities in Steampipe Cloud on a schedule.
+
+**Important notes:**
+
+This table supports optional quals. Queries with optional quals in the `where` clause are optimised to use Steampipe Cloud filters.
+
+Optional quals are supported for the following columns:
+
+- `created_at`
+- `id`
+- `identity_handle`
+- `identity_id`
+- `pipeline`
+- `query_where` - Allows use of [query filters](https://steampipe.io/docs/cloud/reference/query-filter). For a list of supported columns for pipelines, please see [Supported APIs and Columns](https://steampipe.io/docs/cloud/reference/query-filter#supported-apis--columns). Please note that any query filter passed into the `query_where` qual will be combined with other optional quals.
+- `title`
+- `updated_at`
+- `workspace_handle`
+- `workspace_id`
+
+## Examples
+
+### Basic info
+
+```sql
+select
+  id,
+  identity_handle,
+  workspace_handle,
+  title,
+  frequency,
+  pipeline,
+  args,
+  tags,
+  last_process_id
+from
+  steampipecloud_workspace_pipeline;
+```
+
+### List pipelines for a specific workspace
+
+```sql
+select
+  id,
+  identity_handle,
+  workspace_handle,
+  title,
+  frequency,
+  pipeline,
+  args,
+  tags,
+  last_process_id
+from
+  steampipecloud_workspace_pipeline
+where
+  workspace_handle = 'dev';
+```
+
+### List pipelines of frequency type `interval` for a specific workspace
+
+```sql
+select
+  id,
+  identity_handle,
+  workspace_handle,
+  title,
+  frequency,
+  pipeline,
+  args,
+  tags,
+  last_process_id
+from
+  steampipecloud_workspace_pipeline
+where
+  workspace_handle = 'dev'
+  and frequency->>'type' = 'interval';
+```
+
+### List pipelines for the `AWS Compliance CIS v1.4.0` dashboard created in the last 7 days
+
+```sql
+select
+  id,
+  identity_handle,
+  workspace_handle,
+  title,
+  frequency,
+  pipeline,
+  args,
+  tags,
+  last_process_id
+from
+  steampipecloud_workspace_pipeline
+where
+  args->>'resource' = 'aws_compliance.benchmark.cis_v140'
+  and created_at >= now() - interval '7 days';
+```
+
+### List pipelines for the `AWS Compliance CIS v1.4.0` dashboard created in the last 7 days using [query filter](https://steampipe.io/docs/cloud/reference/query-filter)
+
+```sql
+select
+  id,
+  identity_handle,
+  workspace_handle,
+  title,
+  frequency,
+  pipeline,
+  args,
+  tags,
+  last_process_id
+from
+  steampipecloud_workspace_pipeline
+where
+  query_where = 'title = ''Scheduled snapshot: CIS v1.4.0'' and created_at >= now() - interval ''7 days''';
+```

docs/tables/steampipecloud_workspace_process.md

@@ -0,0 +1,90 @@
+# Table: steampipecloud_workspace_process
+
+Allows to track various activities performed on a workspace of an identity in Steampipe Cloud.
+
+**Important notes:**
+
+This table supports optional quals. Queries with optional quals in the `where` clause are optimised to use Steampipe Cloud filters.
+
+Optional quals are supported for the following columns:
+
+- `created_at`
+- `id`
+- `identity_handle`
+- `identity_id`
+- `pipeline_id`
+- `query_where` - Allows use of [query filters](https://steampipe.io/docs/cloud/reference/query-filter). For a list of supported columns for workspace proceses, please see [Supported APIs and Columns](https://steampipe.io/docs/cloud/reference/query-filter#supported-apis--columns). Please note that any query filter passed into the `query_where` qual will be combined with other optional quals.
+- `state`
+- `type`
+- `updated_at`
+- `workspace_handle`
+- `workspace_id`
+
+## Examples
+
+### Basic info
+
+```sql
+select
+  id,
+  identity_handle,
+  workspace_handle,
+  pipeline_id,
+  type,
+  state,
+  created_at
+from
+  steampipecloud_workspace_process;
+```
+
+### List processes for a pipeline
+
+```sql
+select
+  id,
+  identity_handle,
+  workspace_handle,
+  pipeline_id,
+  type,
+  state,
+  created_at
+from
+  steampipecloud_workspace_process
+where
+  pipeline_id = 'pipe_cfcgiefm1tumv1dis7lg';
+```
+
+### List running processes for a pipeline
+
+```sql
+select
+  id,
+  identity_handle,
+  workspace_handle,
+  pipeline_id,
+  type,
+  state,
+  created_at
+from
+  steampipecloud_workspace_process
+where
+  pipeline_id = 'pipe_cfcgiefm1tumv1dis7lg'
+  and state = 'running';
+```
+
+### List running processes for a pipeline using [query filter](https://steampipe.io/docs/cloud/reference/query-filter)
+
+```sql
+select
+  id,
+  identity_handle,
+  workspace_handle,
+  pipeline_id,
+  type,
+  state,
+  created_at
+from
+  steampipecloud_workspace_process
+where
+  query_where = 'pipeline_id = ''pipe_cfcgiefm1tumv1dis7lg'' and state = ''running''';
+```

docs/tables/steampipecloud_workspace_snapshot.md

@@ -12,9 +12,7 @@ Optional quals are supported for the following columns:
 - `dashboard_name`
 - `dashboard_title`
 - `id`
-- `inputs`
 - `query_where` - Allows use of [query filters](https://steampipe.io/docs/cloud/reference/query-filter). For a list of supported columns for snapshots, please see [Supported APIs and Columns](https://steampipe.io/docs/cloud/reference/query-filter#supported-apis--columns). Please note that any query filter passed into the `query_where` qual will be combined with other optional quals.
-- `tags`
 - `visibility`
 
 ## Examples

go.mod

@@ -3,7 +3,7 @@ module steampipe-plugin-steampipecloud
 go 1.19
 
 require (
-	github.com/turbot/steampipe-cloud-sdk-go v0.3.0
+	github.com/turbot/steampipe-cloud-sdk-go v0.5.0
 	github.com/turbot/steampipe-plugin-sdk/v4 v4.1.8
 )
 

go.sum

@@ -418,8 +418,8 @@ github.com/tkrajina/go-reflector v0.5.4 h1:dS9aJEa/eYNQU/fwsb5CSiATOxcNyA/gG/A7a
 github.com/tkrajina/go-reflector v0.5.4/go.mod h1:9PyLgEOzc78ey/JmQQHbW8cQJ1oucLlNQsg8yFvkVk8=
 github.com/turbot/go-kit v0.4.0 h1:EdD7Bf2EGAjvHRGQxRiWpDawzZSk3T+eghqbj74qiSc=
 github.com/turbot/go-kit v0.4.0/go.mod h1:SBdPRngbEfYubiR81iAVtO43oPkg1+ASr+XxvgbH7/k=
-github.com/turbot/steampipe-cloud-sdk-go v0.3.0 h1:2x0VlzAYoRZBWfYxZ3Z0kkMmERtZF8alfY3uctqWhGA=
-github.com/turbot/steampipe-cloud-sdk-go v0.3.0/go.mod h1:8M2CspUHgCGqDCJV+FNn+boBPyLRHyzDinYnoZ/kZYw=
+github.com/turbot/steampipe-cloud-sdk-go v0.5.0 h1:sgMpUL/gLnT5/9v6LaUDITo40npvSn+RQD5maT03wRQ=
+github.com/turbot/steampipe-cloud-sdk-go v0.5.0/go.mod h1:8M2CspUHgCGqDCJV+FNn+boBPyLRHyzDinYnoZ/kZYw=
 github.com/turbot/steampipe-plugin-sdk/v4 v4.1.8 h1:4/fEpsrWNSKA/p2otsibzijBCf4f35Y8jIgUcJgd0Ng=
 github.com/turbot/steampipe-plugin-sdk/v4 v4.1.8/go.mod h1:t1uwq6KylUr2CzIinxeTafoktJvX8yWmhaoWCJJc4YI=
 github.com/vmihailenco/msgpack v3.3.3+incompatible/go.mod h1:fy3FlTQTDXWkZ7Bh6AcGMlsjHatGryHQYUTf1ShIgkk=

steampipecloud/plugin.go

@@ -23,6 +23,7 @@ func Plugin(ctx context.Context) *plugin.Plugin {
 			"steampipecloud_connection":                    tableSteampipeCloudConnection(ctx),
 			"steampipecloud_organization_member":           tableSteampipeCloudOrganizationMember(ctx),
 			"steampipecloud_organization":                  tableSteampipeCloudOrganization(ctx),
+			"steampipecloud_process":                       tableSteampipeCloudProcess(ctx),
 			"steampipecloud_organization_workspace_member": tableSteampipeCloudOrganizationWorkspaceMember(ctx),
 			"steampipecloud_token":                         tableSteampipeCloudToken(ctx),
 			"steampipecloud_user":                          tableSteampipeCloudUser(ctx),
@@ -33,6 +34,8 @@ func Plugin(ctx context.Context) *plugin.Plugin {
 			"steampipecloud_workspace_mod":                 tableSteampipeCloudWorkspaceMod(ctx),
 			"steampipecloud_workspace_mod_variable":        tableSteampipeCloudWorkspaceModVariable(ctx),
 			"steampipecloud_workspace_db_log":              tableSteampipeCloudWorkspaceDBLog(ctx),
+			"steampipecloud_workspace_pipeline":            tableSteampipeCloudWorkspacePipeline(ctx),
+			"steampipecloud_workspace_process":             tableSteampipeCloudWorkspaceProcess(ctx),
 			"steampipecloud_workspace_snapshot":            tableSteampipeCloudWorkspaceSnapshot(ctx),
 		},
 	}