Aclp logs support

.github/workflows/ci.yml

@@ -3,6 +3,14 @@ name: Continuous Integration
 on:
   workflow_dispatch:
     inputs:
+      run_aclp_logs_stream_tests:
+        description: 'Set this parameter to "true" to run ACLP logs stream related test cases'
+        required: false
+        default: 'false'
+        type: choice
+        options:
+          - 'true'
+          - 'false'
       test_report_upload:
         description: 'Indicates whether to upload the test report to object storage. Defaults to "false"'
         type: choice
@@ -105,6 +113,7 @@ jobs:
           make test | go-junit-report -set-exit-code -iocopy -out $REPORT_FILENAME
         env:
           SKIP_LINT: 1
+          RUN_ACLP_LOGS_STREAM_TESTS: ${{ github.event.inputs.run_aclp_logs_stream_tests }}
 
       - name: Upload test results to bucket
         if: always() && github.repository == 'linode/linodego' && github.ref == 'refs/heads/main' && (github.event_name == 'push' || github.event_name == 'pull_request' || (github.event_name == 'workflow_dispatch' && inputs.test_report_upload == 'true'))

.github/workflows/integration_tests_pr.yml

@@ -2,6 +2,14 @@ on:
   pull_request:
   workflow_dispatch:
     inputs:
+      run_aclp_logs_stream_tests:
+        description: 'Set this parameter to "true" to run ACLP logs stream related test cases'
+        required: false
+        default: 'false'
+        type: choice
+        options:
+          - 'true'
+          - 'false'
       sha:
         description: 'The hash value of the commit.'
         required: true
@@ -40,11 +48,13 @@ jobs:
         if: ${{ inputs.module != '' && steps.disallowed-char-check.outputs.match == '' }}
         env:
           LINODE_TOKEN: ${{ secrets.DX_LINODE_TOKEN }}
+          RUN_ACLP_LOGS_STREAM_TESTS: ${{ github.event.inputs.run_aclp_logs_stream_tests }}
 
       - run: make fixtures
         if: ${{ inputs.module == '' }}
         env:
           LINODE_TOKEN: ${{ secrets.DX_LINODE_TOKEN }}
+          RUN_ACLP_LOGS_STREAM_TESTS: ${{ github.event.inputs.run_aclp_logs_stream_tests }}
 
       - name: Get the hash value of the latest commit from the PR branch
         uses: octokit/graphql-action@v2.x

monitor_log_destinations.go

@@ -0,0 +1,208 @@
+package linodego
+
+import (
+	"context"
+	"encoding/json"
+	"time"
+
+	"github.com/linode/linodego/internal/parseabletime"
+)
+
+// LogsDestinationType represents the type of a logs destination.
+type LogsDestinationType string
+
+const (
+	LogsDestinationTypeAkamaiObjectStorage LogsDestinationType = "akamai_object_storage"
+	LogsDestinationTypeCustomHTTPS         LogsDestinationType = "custom_https"
+)
+
+// LogsDestinationStatus represents the status of a logs destination.
+type LogsDestinationStatus string
+
+const (
+	LogsDestinationStatusActive   LogsDestinationStatus = "active"
+	LogsDestinationStatusInactive LogsDestinationStatus = "inactive"
+)
+
+// LogsDestinationDetails represents the details block returned in a LogsDestination response.
+// Fields are populated based on the destination type.
+type LogsDestinationDetails struct {
+	// akamai_object_storage fields
+	AccessKeyID string `json:"access_key_id,omitempty"`
+	BucketName  string `json:"bucket_name,omitempty"`
+	Host        string `json:"host,omitempty"`
+	Path        string `json:"path,omitempty"`
+
+	// custom_https fields
+	EndpointURL              string                                   `json:"endpoint_url,omitempty"`
+	Authentication           *LogsDestinationCustomHTTPSAuthDetails   `json:"authentication,omitempty"`
+	ClientCertificateDetails *LogsDestinationClientCertificateDetails `json:"client_certificate_details,omitempty"`
+	ContentType              string                                   `json:"content_type,omitempty"`
+	CustomHeaders            []LogsDestinationCustomHTTPSHeader       `json:"custom_headers,omitempty"`
+	DataCompression          string                                   `json:"data_compression,omitempty"`
+}
+
+// LogsDestinationDetailsCreateOptions represents the details block used when creating
+// an akamai_object_storage LogsDestination.
+type LogsDestinationDetailsCreateOptions struct {
+	AccessKeyID     string  `json:"access_key_id"`
+	AccessKeySecret string  `json:"access_key_secret"`
+	BucketName      string  `json:"bucket_name"`
+	Host            string  `json:"host"`
+	Path            *string `json:"path,omitempty"`
+}
+
+// LogsDestinationCustomHTTPSAuthType represents the authentication type for a custom_https destination.
+type LogsDestinationCustomHTTPSAuthType string
+
+const (
+	LogsDestinationCustomHTTPSAuthTypeBasic LogsDestinationCustomHTTPSAuthType = "basic"
+	LogsDestinationCustomHTTPSAuthTypeNone  LogsDestinationCustomHTTPSAuthType = "none"
+)
+
+// LogsDestinationCustomHTTPSBasicAuthDetails holds credentials for basic authentication.
+// Both fields are required when authentication type is "basic".
+type LogsDestinationCustomHTTPSBasicAuthDetails struct {
+	Username string `json:"basic_authentication_user"`
+	Password string `json:"basic_authentication_password"`
+}
+
+// LogsDestinationCustomHTTPSAuthDetails holds authentication configuration for a custom_https destination.
+type LogsDestinationCustomHTTPSAuthDetails struct {
+	Type    LogsDestinationCustomHTTPSAuthType          `json:"type"`
+	Details *LogsDestinationCustomHTTPSBasicAuthDetails `json:"details,omitempty"`
+}
+
+// LogsDestinationCustomHTTPSHeader represents a single custom HTTP header.
+type LogsDestinationCustomHTTPSHeader struct {
+	Name  string `json:"name"`
+	Value string `json:"value"`
+}
+
+// LogsDestinationClientCertificateDetails contains TLS client certificate information
+type LogsDestinationClientCertificateDetails struct {
+	ClientCACertificate string `json:"client_ca_certificate"`
+	ClientCertificate   string `json:"client_certificate"`
+	ClientPrivateKey    string `json:"client_private_key"`
+	TLSHostname         string `json:"tls_hostname"`
+}
+
+// LogsDestinationCustomHTTPSDetailsCreateOptions represents the details block used when
+// creating a custom_https LogsDestination.
+type LogsDestinationCustomHTTPSDetailsCreateOptions struct {
+	EndpointURL              string                                   `json:"endpoint_url"`
+	Authentication           *LogsDestinationCustomHTTPSAuthDetails   `json:"authentication"`
+	ClientCertificateDetails *LogsDestinationClientCertificateDetails `json:"client_certificate_details,omitempty"`
+	ContentType              string                                   `json:"content_type,omitempty"`
+	CustomHeaders            []LogsDestinationCustomHTTPSHeader       `json:"custom_headers,omitempty"`
+	DataCompression          string                                   `json:"data_compression,omitempty"`
+}
+
+// LogsDestination represents a logs destination object.
+type LogsDestination struct {
+	Created   *time.Time             `json:"-"`
+	CreatedBy string                 `json:"created_by"`
+	Details   LogsDestinationDetails `json:"details"`
+	ID        int                    `json:"id"`
+	Label     string                 `json:"label"`
+	Status    LogsDestinationStatus  `json:"status"`
+	Type      LogsDestinationType    `json:"type"`
+	Updated   *time.Time             `json:"-"`
+	UpdatedBy string                 `json:"updated_by"`
+	Version   int                    `json:"version"`
+}
+
+// UnmarshalJSON implements the json.Unmarshaler interface for LogsDestination.
+func (i *LogsDestination) UnmarshalJSON(b []byte) error {
+	type Mask LogsDestination
+
+	p := struct {
+		*Mask
+
+		Created *parseabletime.ParseableTime `json:"created"`
+		Updated *parseabletime.ParseableTime `json:"updated"`
+	}{
+		Mask: (*Mask)(i),
+	}
+
+	if err := json.Unmarshal(b, &p); err != nil {
+		return err
+	}
+
+	i.Created = (*time.Time)(p.Created)
+	i.Updated = (*time.Time)(p.Updated)
+
+	return nil
+}
+
+const logsDestinationBaseEndpoint = "monitor/streams/destinations"
+
+// LogsDestinationCreateOptions are the options used to create a new logs destination.
+type LogsDestinationCreateOptions struct {
+	Label   string              `json:"label"`
+	Type    LogsDestinationType `json:"type"`
+	Details any                 `json:"details"`
+}
+
+// LogsDestinationDetailsUpdateOptions represents the details block used when updating
+// an akamai_object_storage LogsDestination.
+type LogsDestinationDetailsUpdateOptions struct {
+	AccessKeyID     string  `json:"access_key_id,omitempty"`
+	AccessKeySecret string  `json:"access_key_secret,omitempty"`
+	BucketName      string  `json:"bucket_name,omitempty"`
+	Host            string  `json:"host,omitempty"`
+	Path            *string `json:"path,omitempty"`
+}
+
+// LogsDestinationCustomHTTPSDetailsUpdateOptions represents the details block used when
+// updating a custom_https LogsDestination.
+type LogsDestinationCustomHTTPSDetailsUpdateOptions struct {
+	EndpointURL              string                                   `json:"endpoint_url,omitempty"`
+	Authentication           *LogsDestinationCustomHTTPSAuthDetails   `json:"authentication,omitempty"`
+	ClientCertificateDetails *LogsDestinationClientCertificateDetails `json:"client_certificate_details,omitempty"`
+	ContentType              string                                   `json:"content_type,omitempty"`
+	CustomHeaders            []LogsDestinationCustomHTTPSHeader       `json:"custom_headers,omitempty"`
+	DataCompression          string                                   `json:"data_compression,omitempty"`
+}
+
+// LogsDestinationUpdateOptions are the options used to update a LogsDestination.
+// Set Details to *LogsDestinationDetailsUpdateOptions for akamai_object_storage,
+// or *LogsDestinationCustomHTTPSDetailsUpdateOptions for custom_https.
+type LogsDestinationUpdateOptions struct {
+	Label   string `json:"label,omitempty"`
+	Details any    `json:"details,omitempty"`
+}
+
+// ListLogsDestinations returns a paginated list of logs destinations.
+func (c *Client) ListLogsDestinations(ctx context.Context, opts *ListOptions) ([]LogsDestination, error) {
+	return getPaginatedResults[LogsDestination](ctx, c, logsDestinationBaseEndpoint, opts)
+}
+
+// GetLogsDestination gets a single logs destination by ID.
+func (c *Client) GetLogsDestination(ctx context.Context, destinationID int) (*LogsDestination, error) {
+	e := formatAPIPath(logsDestinationBaseEndpoint+"/%d", destinationID)
+	return doGETRequest[LogsDestination](ctx, c, e)
+}
+
+// CreateLogsDestination creates a new logs destination.
+func (c *Client) CreateLogsDestination(ctx context.Context, opts LogsDestinationCreateOptions) (*LogsDestination, error) {
+	return doPOSTRequest[LogsDestination](ctx, c, logsDestinationBaseEndpoint, opts)
+}
+
+// UpdateLogsDestination updates a logs destination.
+func (c *Client) UpdateLogsDestination(ctx context.Context, destinationID int, opts LogsDestinationUpdateOptions) (*LogsDestination, error) {
+	e := formatAPIPath(logsDestinationBaseEndpoint+"/%d", destinationID)
+	return doPUTRequest[LogsDestination](ctx, c, e, opts)
+}
+
+// DeleteLogsDestination deletes a logs destination.
+func (c *Client) DeleteLogsDestination(ctx context.Context, destinationID int) error {
+	e := formatAPIPath(logsDestinationBaseEndpoint+"/%d", destinationID)
+	return doDELETERequest(ctx, c, e)
+}
+
+// ListLogsDestinationHistory returns the version history for a logs destination.
+func (c *Client) ListLogsDestinationHistory(ctx context.Context, destinationID int, opts *ListOptions) ([]LogsDestination, error) {
+	e := formatAPIPath(logsDestinationBaseEndpoint+"/%d/history", destinationID)
+	return getPaginatedResults[LogsDestination](ctx, c, e, opts)
+}