pipes

package
v0.9.0 Latest Latest
Warning

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

 Go to latest Published: Apr 16, 2026 License: MIT Imports: 15 Imported by: 0

Documentation

Overview

Package pipes implements the AWS EventBridge Pipes service emulation.

Index

Constants

View Source 
const (
	// Desired states.
	DesiredStateRunning = "RUNNING"
	DesiredStateStopped = "STOPPED"

	// Current states.
	CurrentStateRunning  = "RUNNING"
	CurrentStateStopped  = "STOPPED"
	CurrentStateCreating = "CREATING"
	CurrentStateUpdating = "UPDATING"
	CurrentStateDeleting = "DELETING"
	CurrentStateStarting = "STARTING"
	CurrentStateStopping = "STOPPING"

	// Failed states.
	CurrentStateCreateFailed         = "CREATE_FAILED"
	CurrentStateUpdateFailed         = "UPDATE_FAILED"
	CurrentStateStartFailed          = "START_FAILED"
	CurrentStateStopFailed           = "STOP_FAILED"
	CurrentStateDeleteFailed         = "DELETE_FAILED"
	CurrentStateCreateRollbackFailed = "CREATE_ROLLBACK_FAILED"
	CurrentStateDeleteRollbackFailed = "DELETE_ROLLBACK_FAILED"
	CurrentStateUpdateRollbackFailed = "UPDATE_ROLLBACK_FAILED"
)

Pipe state constants.

Variables

This section is empty.

Functions

This section is empty.

Types

type AWSTimestamp 

type AWSTimestamp struct {
	time.Time
}

AWSTimestamp represents a timestamp in AWS format (Unix epoch seconds as float64).

func (AWSTimestamp) MarshalJSON 

func (t AWSTimestamp) MarshalJSON() ([]byte, error)

MarshalJSON marshals the timestamp to Unix epoch seconds.

func (*AWSTimestamp) UnmarshalJSON 

func (t *AWSTimestamp) UnmarshalJSON(data []byte) error

UnmarshalJSON unmarshals Unix epoch seconds to a timestamp.

type AwsVpcConfiguration 

type AwsVpcConfiguration struct {
	AssignPublicIp string   `json:"AssignPublicIp,omitempty"`
	SecurityGroups []string `json:"SecurityGroups,omitempty"`
	Subnets        []string `json:"Subnets,omitempty"`
}

AwsVpcConfiguration contains VPC configuration.

type CloudwatchLogsLogDestination 

type CloudwatchLogsLogDestination struct {
	LogGroupArn string `json:"LogGroupArn,omitempty"`
}

CloudwatchLogsLogDestination contains CloudWatch Logs destination configuration.

type ContainerOverride 

type ContainerOverride struct {
	Name    string   `json:"Name,omitempty"`
	Command []string `json:"Command,omitempty"`
}

ContainerOverride contains container overrides.

type CreatePipeInput 

type CreatePipeInput struct {
	Name                 string                `json:"Name,omitempty"`
	Source               string                `json:"Source,omitempty"`
	Target               string                `json:"Target,omitempty"`
	RoleArn              string                `json:"RoleArn,omitempty"`
	Description          string                `json:"Description,omitempty"`
	DesiredState         string                `json:"DesiredState,omitempty"`
	Enrichment           string                `json:"Enrichment,omitempty"`
	EnrichmentParameters *EnrichmentParameters `json:"EnrichmentParameters,omitempty"`
	SourceParameters     *SourceParameters     `json:"SourceParameters,omitempty"`
	TargetParameters     *TargetParameters     `json:"TargetParameters,omitempty"`
	LogConfiguration     *LogConfiguration     `json:"LogConfiguration,omitempty"`
	KmsKeyIdentifier     string                `json:"KmsKeyIdentifier,omitempty"`
	Tags                 map[string]string     `json:"Tags,omitempty"`
}

CreatePipeInput represents the input for CreatePipe.

type CreatePipeOutput 

type CreatePipeOutput struct {
	Arn              string       `json:"Arn,omitempty"`
	Name             string       `json:"Name,omitempty"`
	DesiredState     string       `json:"DesiredState,omitempty"`
	CurrentState     string       `json:"CurrentState,omitempty"`
	CreationTime     AWSTimestamp `json:"CreationTime,omitempty"`
	LastModifiedTime AWSTimestamp `json:"LastModifiedTime,omitempty"`
}

CreatePipeOutput represents the output for CreatePipe.

type DeadLetterConfig 

type DeadLetterConfig struct {
	Arn string `json:"Arn,omitempty"`
}

DeadLetterConfig contains dead letter queue configuration.

type DeletePipeOutput 

type DeletePipeOutput struct {
	Arn              string       `json:"Arn,omitempty"`
	Name             string       `json:"Name,omitempty"`
	DesiredState     string       `json:"DesiredState,omitempty"`
	CurrentState     string       `json:"CurrentState,omitempty"`
	CreationTime     AWSTimestamp `json:"CreationTime,omitempty"`
	LastModifiedTime AWSTimestamp `json:"LastModifiedTime,omitempty"`
}

DeletePipeOutput represents the output for DeletePipe.

type DescribePipeOutput 

type DescribePipeOutput struct {
	Arn                  string                `json:"Arn,omitempty"`
	Name                 string                `json:"Name,omitempty"`
	Source               string                `json:"Source,omitempty"`
	Target               string                `json:"Target,omitempty"`
	RoleArn              string                `json:"RoleArn,omitempty"`
	Description          string                `json:"Description,omitempty"`
	DesiredState         string                `json:"DesiredState,omitempty"`
	CurrentState         string                `json:"CurrentState,omitempty"`
	StateReason          string                `json:"StateReason,omitempty"`
	Enrichment           string                `json:"Enrichment,omitempty"`
	EnrichmentParameters *EnrichmentParameters `json:"EnrichmentParameters,omitempty"`
	SourceParameters     *SourceParameters     `json:"SourceParameters,omitempty"`
	TargetParameters     *TargetParameters     `json:"TargetParameters,omitempty"`
	LogConfiguration     *LogConfiguration     `json:"LogConfiguration,omitempty"`
	KmsKeyIdentifier     string                `json:"KmsKeyIdentifier,omitempty"`
	Tags                 map[string]string     `json:"Tags,omitempty"`
	CreationTime         AWSTimestamp          `json:"CreationTime,omitempty"`
	LastModifiedTime     AWSTimestamp          `json:"LastModifiedTime,omitempty"`
}

DescribePipeOutput represents the output for DescribePipe.

type DynamoDBStreamSourceParameters 

type DynamoDBStreamSourceParameters struct {
	BatchSize                      int32             `json:"BatchSize,omitempty"`
	DeadLetterConfig               *DeadLetterConfig `json:"DeadLetterConfig,omitempty"`
	MaximumBatchingWindowInSeconds int32             `json:"MaximumBatchingWindowInSeconds,omitempty"`
	MaximumRecordAgeInSeconds      int32             `json:"MaximumRecordAgeInSeconds,omitempty"`
	MaximumRetryAttempts           int32             `json:"MaximumRetryAttempts,omitempty"`
	OnPartialBatchItemFailure      string            `json:"OnPartialBatchItemFailure,omitempty"`
	ParallelizationFactor          int32             `json:"ParallelizationFactor,omitempty"`
	StartingPosition               string            `json:"StartingPosition,omitempty"`
}

DynamoDBStreamSourceParameters contains DynamoDB stream source parameters.

type EcsTargetParameters 

type EcsTargetParameters struct {
	TaskDefinitionArn    string                `json:"TaskDefinitionArn,omitempty"`
	TaskCount            int32                 `json:"TaskCount,omitempty"`
	LaunchType           string                `json:"LaunchType,omitempty"`
	NetworkConfiguration *NetworkConfiguration `json:"NetworkConfiguration,omitempty"`
	Overrides            *EcsTaskOverride      `json:"Overrides,omitempty"`
}

EcsTargetParameters contains ECS target parameters.

type EcsTaskOverride 

type EcsTaskOverride struct {
	ContainerOverrides []ContainerOverride `json:"ContainerOverrides,omitempty"`
	Cpu                string              `json:"Cpu,omitempty"`
	Memory             string              `json:"Memory,omitempty"`
	TaskRoleArn        string              `json:"TaskRoleArn,omitempty"`
}

EcsTaskOverride contains ECS task overrides.

type EnrichmentHttpParameters 

type EnrichmentHttpParameters struct {
	HeaderParameters      map[string]string `json:"HeaderParameters,omitempty"`
	PathParameterValues   []string          `json:"PathParameterValues,omitempty"`
	QueryStringParameters map[string]string `json:"QueryStringParameters,omitempty"`
}

EnrichmentHttpParameters contains HTTP parameters for enrichment.

type EnrichmentParameters 

type EnrichmentParameters struct {
	HttpParameters *EnrichmentHttpParameters `json:"HttpParameters,omitempty"`
	InputTemplate  string                    `json:"InputTemplate,omitempty"`
}

EnrichmentParameters contains enrichment configuration.

type Error 

type Error struct {
	Code    string
	Message string
}

Error represents a Pipes service error.

func (*Error) Error 

func (e *Error) Error() string

Error implements the error interface.

func (*Error) ErrorCode 

func (e *Error) ErrorCode() string

ErrorCode returns the error code.

func (*Error) HTTPStatusCode 

func (e *Error) HTTPStatusCode() int

HTTPStatusCode returns the HTTP status code for the error.

type ErrorResponse 

type ErrorResponse struct {
	Message string `json:"message,omitempty"`
}

ErrorResponse represents an error response.

type Filter 

type Filter struct {
	Pattern string `json:"Pattern,omitempty"`
}

Filter represents an event filter.

type FilterCriteria 

type FilterCriteria struct {
	Filters []Filter `json:"Filters,omitempty"`
}

FilterCriteria contains event filter criteria.

type FirehoseLogDestination 

type FirehoseLogDestination struct {
	DeliveryStreamArn string `json:"DeliveryStreamArn,omitempty"`
}

FirehoseLogDestination contains Firehose destination configuration.

type KinesisStreamSourceParameters 

type KinesisStreamSourceParameters struct {
	BatchSize                      int32             `json:"BatchSize,omitempty"`
	DeadLetterConfig               *DeadLetterConfig `json:"DeadLetterConfig,omitempty"`
	MaximumBatchingWindowInSeconds int32             `json:"MaximumBatchingWindowInSeconds,omitempty"`
	MaximumRecordAgeInSeconds      int32             `json:"MaximumRecordAgeInSeconds,omitempty"`
	MaximumRetryAttempts           int32             `json:"MaximumRetryAttempts,omitempty"`
	OnPartialBatchItemFailure      string            `json:"OnPartialBatchItemFailure,omitempty"`
	ParallelizationFactor          int32             `json:"ParallelizationFactor,omitempty"`
	StartingPosition               string            `json:"StartingPosition,omitempty"`
	StartingPositionTimestamp      AWSTimestamp      `json:"StartingPositionTimestamp,omitempty"`
}

KinesisStreamSourceParameters contains Kinesis stream source parameters.

type LambdaTargetParameters 

type LambdaTargetParameters struct {
	InvocationType string `json:"InvocationType,omitempty"`
}

LambdaTargetParameters contains Lambda target parameters.

type ListPipesInput 

type ListPipesInput struct {
	CurrentState string `json:"CurrentState,omitempty"`
	DesiredState string `json:"DesiredState,omitempty"`
	Limit        int32  `json:"Limit,omitempty"`
	NamePrefix   string `json:"NamePrefix,omitempty"`
	NextToken    string `json:"NextToken,omitempty"`
	SourcePrefix string `json:"SourcePrefix,omitempty"`
	TargetPrefix string `json:"TargetPrefix,omitempty"`
}

ListPipesInput represents the input for ListPipes.

type ListPipesOutput 

type ListPipesOutput struct {
	Pipes     []*PipeSummary `json:"Pipes,omitempty"`
	NextToken string         `json:"NextToken,omitempty"`
}

ListPipesOutput represents the output for ListPipes.

type ListTagsForResourceOutput 

type ListTagsForResourceOutput struct {
	Tags map[string]string `json:"tags,omitempty"`
}

ListTagsForResourceOutput represents the output for ListTagsForResource.

type LogConfiguration 

type LogConfiguration struct {
	Level                        string                        `json:"Level,omitempty"`
	CloudwatchLogsLogDestination *CloudwatchLogsLogDestination `json:"CloudwatchLogsLogDestination,omitempty"`
	FirehoseLogDestination       *FirehoseLogDestination       `json:"FirehoseLogDestination,omitempty"`
	S3LogDestination             *S3LogDestination             `json:"S3LogDestination,omitempty"`
	IncludeExecutionData         []string                      `json:"IncludeExecutionData,omitempty"`
}

LogConfiguration contains logging configuration.

type MemoryStorage 

type MemoryStorage struct {
	Pipes map[string]*Pipe `json:"pipes"` // keyed by name
	// contains filtered or unexported fields
}

MemoryStorage implements the Storage interface using in-memory storage.

func NewMemoryStorage 

func NewMemoryStorage(opts ...Option) *MemoryStorage

NewMemoryStorage creates a new MemoryStorage.

func (*MemoryStorage) Close added in v0.6.0 

func (m *MemoryStorage) Close() error

Close saves the storage state to disk if persistence is enabled.

func (*MemoryStorage) CreatePipe 

func (m *MemoryStorage) CreatePipe(_ context.Context, req *CreatePipeInput) (*Pipe, error)

CreatePipe creates a new pipe.

func (*MemoryStorage) DeletePipe 

func (m *MemoryStorage) DeletePipe(_ context.Context, name string) (*Pipe, error)

DeletePipe deletes a pipe by name.

func (*MemoryStorage) DescribePipe 

func (m *MemoryStorage) DescribePipe(_ context.Context, name string) (*Pipe, error)

DescribePipe retrieves a pipe by name.

func (*MemoryStorage) ListPipes 

func (m *MemoryStorage) ListPipes(_ context.Context, req *ListPipesInput) (*ListPipesOutput, error)

ListPipes lists pipes with optional filters.

func (*MemoryStorage) ListTagsForResource 

func (m *MemoryStorage) ListTagsForResource(_ context.Context, arn string) (map[string]string, error)

ListTagsForResource lists tags for a pipe.

func (*MemoryStorage) MarshalJSON added in v0.6.0 

func (m *MemoryStorage) MarshalJSON() ([]byte, error)

MarshalJSON serializes the storage state to JSON.

func (*MemoryStorage) StartPipe 

func (m *MemoryStorage) StartPipe(_ context.Context, name string) (*Pipe, error)

StartPipe starts a stopped pipe.

func (*MemoryStorage) StopPipe 

func (m *MemoryStorage) StopPipe(_ context.Context, name string) (*Pipe, error)

StopPipe stops a running pipe.

func (*MemoryStorage) TagResource 

func (m *MemoryStorage) TagResource(_ context.Context, arn string, tags map[string]string) error

TagResource adds tags to a pipe.

func (*MemoryStorage) UnmarshalJSON added in v0.6.0 

func (m *MemoryStorage) UnmarshalJSON(data []byte) error

UnmarshalJSON restores the storage state from JSON.

func (*MemoryStorage) UntagResource 

func (m *MemoryStorage) UntagResource(_ context.Context, arn string, tagKeys []string) error

UntagResource removes tags from a pipe.

func (*MemoryStorage) UpdatePipe 

func (m *MemoryStorage) UpdatePipe(_ context.Context, req *UpdatePipeInput) (*Pipe, error)

UpdatePipe updates an existing pipe.

type NetworkConfiguration 

type NetworkConfiguration struct {
	AwsVpcConfiguration *AwsVpcConfiguration `json:"AwsvpcConfiguration,omitempty"`
}

NetworkConfiguration contains network configuration for ECS tasks.

type Option added in v0.6.0 

type Option func(*MemoryStorage)

Option is a configuration option for MemoryStorage.

func WithDataDir added in v0.6.0 

func WithDataDir(dir string) Option

WithDataDir enables persistent storage in the specified directory.

type Pipe 

type Pipe struct {
	Arn                  string                `json:"Arn,omitempty"`
	Name                 string                `json:"Name,omitempty"`
	Source               string                `json:"Source,omitempty"`
	Target               string                `json:"Target,omitempty"`
	RoleArn              string                `json:"RoleArn,omitempty"`
	Description          string                `json:"Description,omitempty"`
	DesiredState         string                `json:"DesiredState,omitempty"`
	CurrentState         string                `json:"CurrentState,omitempty"`
	StateReason          string                `json:"StateReason,omitempty"`
	Enrichment           string                `json:"Enrichment,omitempty"`
	EnrichmentParameters *EnrichmentParameters `json:"EnrichmentParameters,omitempty"`
	SourceParameters     *SourceParameters     `json:"SourceParameters,omitempty"`
	TargetParameters     *TargetParameters     `json:"TargetParameters,omitempty"`
	LogConfiguration     *LogConfiguration     `json:"LogConfiguration,omitempty"`
	KmsKeyIdentifier     string                `json:"KmsKeyIdentifier,omitempty"`
	Tags                 map[string]string     `json:"Tags,omitempty"`
	CreationTime         AWSTimestamp          `json:"CreationTime,omitempty"`
	LastModifiedTime     AWSTimestamp          `json:"LastModifiedTime,omitempty"`
}

Pipe represents an EventBridge Pipe.

type PipeSummary 

type PipeSummary struct {
	Arn              string       `json:"Arn,omitempty"`
	Name             string       `json:"Name,omitempty"`
	Source           string       `json:"Source,omitempty"`
	Target           string       `json:"Target,omitempty"`
	DesiredState     string       `json:"DesiredState,omitempty"`
	CurrentState     string       `json:"CurrentState,omitempty"`
	StateReason      string       `json:"StateReason,omitempty"`
	Enrichment       string       `json:"Enrichment,omitempty"`
	CreationTime     AWSTimestamp `json:"CreationTime,omitempty"`
	LastModifiedTime AWSTimestamp `json:"LastModifiedTime,omitempty"`
}

PipeSummary represents a pipe summary for list operations.

type S3LogDestination 

type S3LogDestination struct {
	BucketName   string `json:"BucketName,omitempty"`
	BucketOwner  string `json:"BucketOwner,omitempty"`
	OutputFormat string `json:"OutputFormat,omitempty"`
	Prefix       string `json:"Prefix,omitempty"`
}

S3LogDestination contains S3 destination configuration.

type Service 

type Service struct {
	// contains filtered or unexported fields
}

Service implements the EventBridge Pipes service.

func New 

func New(storage Storage) *Service

New creates a new Pipes service.

func (*Service) Close added in v0.6.0 

func (s *Service) Close() error

Close saves the storage state if persistence is enabled.

func (*Service) CreatePipe 

func (s *Service) CreatePipe(w http.ResponseWriter, r *http.Request)

CreatePipe handles the CreatePipe API operation.

func (*Service) DeletePipe 

func (s *Service) DeletePipe(w http.ResponseWriter, r *http.Request)

DeletePipe handles the DeletePipe API operation.

func (*Service) DescribePipe 

func (s *Service) DescribePipe(w http.ResponseWriter, r *http.Request)

DescribePipe handles the DescribePipe API operation.

func (*Service) ListPipes 

func (s *Service) ListPipes(w http.ResponseWriter, r *http.Request)

ListPipes handles the ListPipes API operation.

func (*Service) ListTagsForResource 

func (s *Service) ListTagsForResource(w http.ResponseWriter, r *http.Request)

ListTagsForResource handles the ListTagsForResource API operation.

func (*Service) Name 

func (s *Service) Name() string

Name returns the service name.

func (*Service) RegisterRoutes 

func (s *Service) RegisterRoutes(r service.Router)

RegisterRoutes registers the Pipes routes.

func (*Service) StartPipe 

func (s *Service) StartPipe(w http.ResponseWriter, r *http.Request)

StartPipe handles the StartPipe API operation.

func (*Service) StopPipe 

func (s *Service) StopPipe(w http.ResponseWriter, r *http.Request)

StopPipe handles the StopPipe API operation.

func (*Service) TagResource 

func (s *Service) TagResource(w http.ResponseWriter, r *http.Request)

TagResource handles the TagResource API operation.

func (*Service) UntagResource 

func (s *Service) UntagResource(w http.ResponseWriter, r *http.Request)

UntagResource handles the UntagResource API operation.

func (*Service) UpdatePipe 

func (s *Service) UpdatePipe(w http.ResponseWriter, r *http.Request)

UpdatePipe handles the UpdatePipe API operation.

type SourceParameters 

type SourceParameters struct {
	FilterCriteria           *FilterCriteria                 `json:"FilterCriteria,omitempty"`
	DynamoDBStreamParameters *DynamoDBStreamSourceParameters `json:"DynamoDBStreamParameters,omitempty"`
	KinesisStreamParameters  *KinesisStreamSourceParameters  `json:"KinesisStreamParameters,omitempty"`
	SqsQueueParameters       *SqsQueueSourceParameters       `json:"SqsQueueParameters,omitempty"`
}

SourceParameters contains source configuration. This is simplified - AWS has many source types with different parameters.

type SqsQueueSourceParameters 

type SqsQueueSourceParameters struct {
	BatchSize                      int32 `json:"BatchSize,omitempty"`
	MaximumBatchingWindowInSeconds int32 `json:"MaximumBatchingWindowInSeconds,omitempty"`
}

SqsQueueSourceParameters contains SQS queue source parameters.

type SqsTargetParameters 

type SqsTargetParameters struct {
	MessageDeduplicationId string `json:"MessageDeduplicationId,omitempty"`
	MessageGroupId         string `json:"MessageGroupId,omitempty"`
}

SqsTargetParameters contains SQS target parameters.

type StartPipeOutput 

type StartPipeOutput struct {
	Arn              string       `json:"Arn,omitempty"`
	Name             string       `json:"Name,omitempty"`
	DesiredState     string       `json:"DesiredState,omitempty"`
	CurrentState     string       `json:"CurrentState,omitempty"`
	CreationTime     AWSTimestamp `json:"CreationTime,omitempty"`
	LastModifiedTime AWSTimestamp `json:"LastModifiedTime,omitempty"`
}

StartPipeOutput represents the output for StartPipe.

type StopPipeOutput 

type StopPipeOutput struct {
	Arn              string       `json:"Arn,omitempty"`
	Name             string       `json:"Name,omitempty"`
	DesiredState     string       `json:"DesiredState,omitempty"`
	CurrentState     string       `json:"CurrentState,omitempty"`
	CreationTime     AWSTimestamp `json:"CreationTime,omitempty"`
	LastModifiedTime AWSTimestamp `json:"LastModifiedTime,omitempty"`
}

StopPipeOutput represents the output for StopPipe.

type Storage 

type Storage interface {
	// CreatePipe creates a new pipe.
	CreatePipe(ctx context.Context, req *CreatePipeInput) (*Pipe, error)

	// DescribePipe retrieves a pipe by name.
	DescribePipe(ctx context.Context, name string) (*Pipe, error)

	// UpdatePipe updates an existing pipe.
	UpdatePipe(ctx context.Context, req *UpdatePipeInput) (*Pipe, error)

	// DeletePipe deletes a pipe by name.
	DeletePipe(ctx context.Context, name string) (*Pipe, error)

	// ListPipes lists pipes with optional filters.
	ListPipes(ctx context.Context, req *ListPipesInput) (*ListPipesOutput, error)

	// StartPipe starts a stopped pipe.
	StartPipe(ctx context.Context, name string) (*Pipe, error)

	// StopPipe stops a running pipe.
	StopPipe(ctx context.Context, name string) (*Pipe, error)

	// TagResource adds tags to a pipe.
	TagResource(ctx context.Context, arn string, tags map[string]string) error

	// UntagResource removes tags from a pipe.
	UntagResource(ctx context.Context, arn string, tagKeys []string) error

	// ListTagsForResource lists tags for a pipe.
	ListTagsForResource(ctx context.Context, arn string) (map[string]string, error)
}

Storage defines the interface for pipe storage operations.

type TagResourceInput 

type TagResourceInput struct {
	ResourceArn string            `json:"resourceArn,omitempty"`
	Tags        map[string]string `json:"tags,omitempty"`
}

TagResourceInput represents the input for TagResource.

type TargetParameters 

type TargetParameters struct {
	InputTemplate            string                  `json:"InputTemplate,omitempty"`
	LambdaFunctionParameters *LambdaTargetParameters `json:"LambdaFunctionParameters,omitempty"`
	SqsQueueParameters       *SqsTargetParameters    `json:"SqsQueueParameters,omitempty"`
	EcsTaskParameters        *EcsTargetParameters    `json:"EcsTaskParameters,omitempty"`
}

TargetParameters contains target configuration. This is simplified - AWS has many target types with different parameters.

type UntagResourceInput 

type UntagResourceInput struct {
	ResourceArn string   `json:"resourceArn,omitempty"`
	TagKeys     []string `json:"tagKeys,omitempty"`
}

UntagResourceInput represents the input for UntagResource.

type UpdatePipeInput 

type UpdatePipeInput struct {
	Name                 string                `json:"Name,omitempty"`
	RoleArn              string                `json:"RoleArn,omitempty"`
	Description          string                `json:"Description,omitempty"`
	DesiredState         string                `json:"DesiredState,omitempty"`
	Source               string                `json:"Source,omitempty"`
	Target               string                `json:"Target,omitempty"`
	Enrichment           string                `json:"Enrichment,omitempty"`
	EnrichmentParameters *EnrichmentParameters `json:"EnrichmentParameters,omitempty"`
	SourceParameters     *SourceParameters     `json:"SourceParameters,omitempty"`
	TargetParameters     *TargetParameters     `json:"TargetParameters,omitempty"`
	LogConfiguration     *LogConfiguration     `json:"LogConfiguration,omitempty"`
	KmsKeyIdentifier     string                `json:"KmsKeyIdentifier,omitempty"`
}

UpdatePipeInput represents the input for UpdatePipe.

type UpdatePipeOutput 

type UpdatePipeOutput struct {
	Arn              string       `json:"Arn,omitempty"`
	Name             string       `json:"Name,omitempty"`
	DesiredState     string       `json:"DesiredState,omitempty"`
	CurrentState     string       `json:"CurrentState,omitempty"`
	CreationTime     AWSTimestamp `json:"CreationTime,omitempty"`
	LastModifiedTime AWSTimestamp `json:"LastModifiedTime,omitempty"`
}

UpdatePipeOutput represents the output for UpdatePipe.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.