gcp

package
v0.9.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 22, 2026 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ConnectionMethodServiceAccountKey = "serviceAccountKey"
	ConnectionMethodWIF               = "workloadIdentityFederation"

	PubSubSecretName = "pubsub.events.secret"
)

Variables

This section is empty.

Functions

func ExchangeToken

func ExchangeToken(ctx context.Context, httpClient core.HTTPContext, oidcToken, audience string) (accessToken string, expiresIn time.Duration, err error)

Types

type AuditLogEvent

type AuditLogEvent struct {
	ServiceName  string `json:"serviceName" mapstructure:"serviceName"`
	MethodName   string `json:"methodName" mapstructure:"methodName"`
	ResourceName string `json:"resourceName" mapstructure:"resourceName"`
	LogName      string `json:"logName" mapstructure:"logName"`
	Timestamp    string `json:"timestamp" mapstructure:"timestamp"`
	InsertID     string `json:"insertId" mapstructure:"insertId"`
	Data         any    `json:"data" mapstructure:"data"`
}

AuditLogEvent is the normalized event structure extracted from a Cloud Logging audit log entry, used both for subscription pattern matching and as the message payload delivered to triggers via OnIntegrationMessage.

type AuditLogEventPattern

type AuditLogEventPattern struct {
	ServiceName string `json:"serviceName" mapstructure:"serviceName"`
	MethodName  string `json:"methodName" mapstructure:"methodName"`
}

AuditLogEventPattern is the subscription pattern used to match incoming events against trigger subscriptions. Only non-empty fields are matched.

type Configuration

type Configuration struct {
	ConnectionMethod          string `json:"connectionMethod" mapstructure:"connectionMethod"`
	ServiceAccountKey         string `json:"serviceAccountKey" mapstructure:"serviceAccountKey"`
	WorkloadIdentityProvider  string `json:"workloadIdentityProvider" mapstructure:"workloadIdentityProvider"`
	WorkloadIdentityProjectID string `json:"workloadIdentityProjectId" mapstructure:"workloadIdentityProjectId"`
}

type GCP

type GCP struct{}

func (*GCP) Actions

func (g *GCP) Actions() []core.Action

func (*GCP) Cleanup

func (g *GCP) Cleanup(ctx core.IntegrationCleanupContext) error

func (*GCP) Components

func (g *GCP) Components() []core.Component

func (*GCP) Configuration

func (g *GCP) Configuration() []configuration.Field

func (*GCP) Description

func (g *GCP) Description() string

func (*GCP) HandleAction

func (g *GCP) HandleAction(ctx core.IntegrationActionContext) error

func (*GCP) HandleRequest

func (g *GCP) HandleRequest(ctx core.HTTPRequestContext)

func (*GCP) Icon

func (g *GCP) Icon() string

func (*GCP) Instructions

func (g *GCP) Instructions() string

func (*GCP) Label

func (g *GCP) Label() string

func (*GCP) ListResources

func (g *GCP) ListResources(resourceType string, ctx core.ListResourcesContext) ([]core.IntegrationResource, error)

func (*GCP) Name

func (g *GCP) Name() string

func (*GCP) Sync

func (g *GCP) Sync(ctx core.SyncContext) error

func (*GCP) Triggers

func (g *GCP) Triggers() []core.Trigger

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL