-
Notifications
You must be signed in to change notification settings - Fork 2
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Support attach and detach exporters from service
This adds support for attach and detaching exporters from service. This is supported using two new fields on the service resource, metric_exporter_id and log_exporter_id. This change also adds a data source to import existing exporters by name.
- Loading branch information
Showing
27 changed files
with
838 additions
and
61 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,24 @@ | ||
| --- | ||
| # generated by https://github.com/hashicorp/terraform-plugin-docs | ||
| page_title: "timescale_exporter Data Source - terraform-provider-timescale" | ||
| subcategory: "" | ||
| description: |- | ||
| Exporter data source | ||
| --- | ||
|
|
||
| # timescale_exporter (Data Source) | ||
|
|
||
| Exporter data source | ||
|
|
||
|
|
||
|
|
||
| <!-- schema generated by tfplugindocs --> | ||
| ## Schema | ||
|
|
||
| ### Required | ||
|
|
||
| - `name` (String) The name of this exporter. Exporter names must be unique in order to manage them using Terraform. | ||
|
|
||
| ### Read-Only | ||
|
|
||
| - `id` (String) exporter id is the unique identifier for an exporter |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,34 @@ | ||
| terraform { | ||
| required_providers { | ||
| timescale = { | ||
| source = "registry.terraform.io/providers/timescale" | ||
| version = "~> 1.0" | ||
| } | ||
| } | ||
| } | ||
|
|
||
| variable "ts_access_key" { | ||
| type = string | ||
| } | ||
|
|
||
| variable "ts_secret_key" { | ||
| type = string | ||
| } | ||
|
|
||
| variable "ts_project_id" { | ||
| type = string | ||
| } | ||
|
|
||
| provider "timescale" { | ||
| access_key = var.ts_access_key | ||
| secret_key = var.ts_secret_key | ||
| project_id = var.ts_project_id | ||
| } | ||
|
|
||
| data "timescale_exporter" "exporter" { | ||
| name = "exporter_name" | ||
| } | ||
|
|
||
| output "products_list" { | ||
| value = data.timescale_exporter.exporter.id | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,172 @@ | ||
| package client | ||
|
|
||
| import ( | ||
| "context" | ||
| "encoding/json" | ||
| "errors" | ||
| "time" | ||
|
|
||
| "github.com/hashicorp/terraform-plugin-log/tflog" | ||
| "github.com/samber/lo" | ||
| ) | ||
|
|
||
| type Exporter struct { | ||
| ID string `json:"id"` | ||
| ProjectID string `json:"projectId"` | ||
| Created time.Time `json:"created"` | ||
| Name string `json:"name"` | ||
| Type string `json:"type"` | ||
| RegionCode string `json:"regionCode"` | ||
| Config json.RawMessage `json:"config"` | ||
| } | ||
|
|
||
| type GetAllMetricExportersResponse struct { | ||
| Exporters []*Exporter `json:"getAllMetricExporters"` | ||
| } | ||
|
|
||
| type GetAllGenericExporterResponse struct { | ||
| Exporters []*Exporter `json:"getAllGenericExporters"` | ||
| } | ||
|
|
||
| type GetExporterByNameRequest struct { | ||
| Name string | ||
| } | ||
|
|
||
| type AttachExporterRequest struct { | ||
| ServiceID string | ||
| ExporterID string | ||
| } | ||
|
|
||
| type DetachExporterRequest struct { | ||
| ServiceID string | ||
| ExporterID string | ||
| } | ||
|
|
||
| func (c *Client) getAllMetricExporters(ctx context.Context) ([]*Exporter, error) { | ||
| tflog.Trace(ctx, "MetricExporter.GetAll") | ||
| req := graphQLRequest{ | ||
| operationName: "GetAllMetricExporters", | ||
| query: GetAllMetricExporters, | ||
| variables: map[string]interface{}{ | ||
| "projectId": c.projectID, | ||
| }, | ||
| } | ||
| var resp Response[GetAllMetricExportersResponse] | ||
| err := c.do(ctx, req.build(), &resp) | ||
| if err = coalesceErrors(resp, err); err != nil { | ||
| return nil, err | ||
| } | ||
| return resp.Data.Exporters, nil | ||
| } | ||
|
|
||
| func (c *Client) getAllLogExporters(ctx context.Context) ([]*Exporter, error) { | ||
| tflog.Trace(ctx, "MetricExporter.GetAllLogExporters") | ||
| req := graphQLRequest{ | ||
| operationName: "GetAllGenericExporters", | ||
| query: GetAllGenericMetricExporters, | ||
| variables: map[string]interface{}{ | ||
| "projectId": c.projectID, | ||
| }, | ||
| } | ||
| var resp Response[GetAllGenericExporterResponse] | ||
| err := c.do(ctx, req.build(), &resp) | ||
| if err = coalesceErrors(resp, err); err != nil { | ||
| return nil, err | ||
| } | ||
| return resp.Data.Exporters, nil | ||
| } | ||
|
|
||
| func (c *Client) getAllExporters(ctx context.Context) ([]*Exporter, error) { | ||
| tflog.Trace(ctx, "Client.getAllExporters") | ||
| metricExporters, err := c.getAllMetricExporters(ctx) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| logExporters, err := c.getAllLogExporters(ctx) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| return append(metricExporters, logExporters...), nil | ||
| } | ||
|
|
||
| func (c *Client) GetExporterByName(ctx context.Context, request *GetExporterByNameRequest) (*Exporter, error) { | ||
| tflog.Trace(ctx, "Client.GetExporterByName") | ||
| exporters, err := c.getAllExporters(ctx) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| e := lo.Filter(exporters, func(e *Exporter, _ int) bool { | ||
| return e.Name == request.Name | ||
| }) | ||
| if len(e) == 0 { | ||
| return nil, errNotFound | ||
| } | ||
| if len(e) > 1 { | ||
| return nil, errors.New("exporter names must be unique for importing") | ||
| } | ||
| return e[0], nil | ||
| } | ||
|
|
||
| func (c *Client) AttachMetricExporter(ctx context.Context, request *AttachExporterRequest) error { | ||
| tflog.Trace(ctx, "Client.AttachMetricExporter") | ||
| req := &graphQLRequest{ | ||
| operationName: "AttachServiceToMetricExporter", | ||
| query: AttachMetricExporterMutation, | ||
| variables: map[string]interface{}{ | ||
| "projectId": c.projectID, | ||
| "serviceId": request.ServiceID, | ||
| "exporterId": request.ExporterID, | ||
| }, | ||
| } | ||
| var resp Response[any] | ||
| err := c.do(ctx, req.build(), &resp) | ||
| return coalesceErrors(resp, err) | ||
| } | ||
|
|
||
| func (c *Client) AttachLogExporter(ctx context.Context, request *AttachExporterRequest) error { | ||
| tflog.Trace(ctx, "Client.AttachLogExporter") | ||
| req := &graphQLRequest{ | ||
| operationName: "AttachServiceToGenericExporter", | ||
| query: AttachGenericExporterMutation, | ||
| variables: map[string]interface{}{ | ||
| "projectId": c.projectID, | ||
| "serviceId": request.ServiceID, | ||
| "exporterId": request.ExporterID, | ||
| }, | ||
| } | ||
| var resp Response[any] | ||
| err := c.do(ctx, req.build(), &resp) | ||
| return coalesceErrors(resp, err) | ||
| } | ||
|
|
||
| func (c *Client) DetachLogExporter(ctx context.Context, request *DetachExporterRequest) error { | ||
| tflog.Trace(ctx, "Client.DetachLogExporter") | ||
| req := &graphQLRequest{ | ||
| operationName: "DetachServiceFromGenericExporter", | ||
| query: DetachGenericMetricExporterMutation, | ||
| variables: map[string]interface{}{ | ||
| "projectId": c.projectID, | ||
| "serviceId": request.ServiceID, | ||
| "exporterId": request.ExporterID, | ||
| }, | ||
| } | ||
| var resp Response[any] | ||
| err := c.do(ctx, req.build(), &resp) | ||
| return coalesceErrors(resp, err) | ||
| } | ||
|
|
||
| func (c *Client) DetachMetricExporter(ctx context.Context, request *DetachExporterRequest) error { | ||
| tflog.Trace(ctx, "Client.DetachMetricExporter") | ||
| req := &graphQLRequest{ | ||
| operationName: "DetachServiceFromMetricExporter", | ||
| query: DetachMetricExporterMutation, | ||
| variables: map[string]interface{}{ | ||
| "projectId": c.projectID, | ||
| "serviceId": request.ServiceID, | ||
| "exporterId": request.ExporterID, | ||
| }, | ||
| } | ||
| var resp Response[any] | ||
| err := c.do(ctx, req.build(), &resp) | ||
| return coalesceErrors(resp, err) | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,46 @@ | ||
| package client | ||
|
|
||
| import ( | ||
| "errors" | ||
| "strings" | ||
| ) | ||
|
|
||
| type graphQLRequest struct { | ||
| operationName string | ||
| query string | ||
| variables map[string]interface{} | ||
| } | ||
|
|
||
| func (g *graphQLRequest) build() map[string]interface{} { | ||
| return map[string]interface{}{ | ||
| "operationName": g.operationName, | ||
| "query": g.query, | ||
| "variables": g.variables, | ||
| } | ||
| } | ||
|
|
||
| type Error struct { | ||
| Message string `json:"message"` | ||
| Path []string `json:"path"` | ||
| } | ||
|
|
||
| func (e *Error) Error() string { | ||
| return e.Message + " " + strings.Join(e.Path, ".") | ||
| } | ||
|
|
||
| func coalesceErrors[T any](resp Response[T], err error) error { | ||
| if err != nil { | ||
| return err | ||
| } | ||
| if len(resp.Errors) > 0 { | ||
| errs := make([]error, len(resp.Errors)) | ||
| for idx, e := range resp.Errors { | ||
| errs[idx] = e | ||
| } | ||
| return errors.Join(errs...) | ||
| } | ||
| if resp.Data == nil { | ||
| return errNotFound | ||
| } | ||
| return nil | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,7 @@ | ||
| mutation AttachServiceToGenericExporter($projectId: ID!, $serviceId: ID!, $exporterId: String!) { | ||
| attachServiceToGenericExporter(data: { | ||
| projectId: $projectId, | ||
| serviceId: $serviceId, | ||
| exporterId: $exporterId} | ||
| ) | ||
| } |
Oops, something went wrong.