v1alpha1

package
v1.0.17 Latest Latest
Warning

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

 Go to latest Published: Feb 20, 2025 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

+k8s:deepcopy-gen=package Package v1alpha1 is the v1alpha1 version of the pipes.services.k8s.aws API. +groupName=pipes.services.k8s.aws

Index

Constants

This section is empty.

Variables

View Source 
var (
	// GroupVersion is the API Group Version used to register the objects
	GroupVersion = schema.GroupVersion{Group: "pipes.services.k8s.aws", Version: "v1alpha1"}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersion}

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)

Functions

This section is empty.

Types

type AWSVPCConfiguration 

type AWSVPCConfiguration struct {
	AssignPublicIP *string   `json:"assignPublicIP,omitempty"`
	SecurityGroups []*string `json:"securityGroups,omitempty"`
	Subnets        []*string `json:"subnets,omitempty"`
}

This structure specifies the VPC subnets and security groups for the task, and whether a public IP address is to be used. This structure is relevant only for ECS tasks that use the awsvpc network mode.

func (*AWSVPCConfiguration) DeepCopy 

func (in *AWSVPCConfiguration) DeepCopy() *AWSVPCConfiguration

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AWSVPCConfiguration.

func (*AWSVPCConfiguration) DeepCopyInto 

func (in *AWSVPCConfiguration) DeepCopyInto(out *AWSVPCConfiguration)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AssignPublicIP 

type AssignPublicIP string
const (
	AssignPublicIP_ENABLED  AssignPublicIP = "ENABLED"
	AssignPublicIP_DISABLED AssignPublicIP = "DISABLED"
)

type BatchArrayProperties 

type BatchArrayProperties struct {
	Size *int64 `json:"size,omitempty"`
}

The array properties for the submitted job, such as the size of the array. The array size can be between 2 and 10,000. If you specify array properties for a job, it becomes an array job. This parameter is used only if the target is an Batch job.

func (*BatchArrayProperties) DeepCopy 

func (in *BatchArrayProperties) DeepCopy() *BatchArrayProperties

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BatchArrayProperties.

func (*BatchArrayProperties) DeepCopyInto 

func (in *BatchArrayProperties) DeepCopyInto(out *BatchArrayProperties)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type BatchContainerOverrides 

type BatchContainerOverrides struct {
	Command              []*string                   `json:"command,omitempty"`
	Environment          []*BatchEnvironmentVariable `json:"environment,omitempty"`
	InstanceType         *string                     `json:"instanceType,omitempty"`
	ResourceRequirements []*BatchResourceRequirement `json:"resourceRequirements,omitempty"`
}

The overrides that are sent to a container.

func (*BatchContainerOverrides) DeepCopy 

func (in *BatchContainerOverrides) DeepCopy() *BatchContainerOverrides

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BatchContainerOverrides.

func (*BatchContainerOverrides) DeepCopyInto 

func (in *BatchContainerOverrides) DeepCopyInto(out *BatchContainerOverrides)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type BatchEnvironmentVariable 

type BatchEnvironmentVariable struct {
	Name  *string `json:"name,omitempty"`
	Value *string `json:"value,omitempty"`
}

The environment variables to send to the container. You can add new environment variables, which are added to the container at launch, or you can override the existing environment variables from the Docker image or the task definition.

Environment variables cannot start with "Batch". This naming convention is reserved for variables that Batch sets.

func (*BatchEnvironmentVariable) DeepCopy 

func (in *BatchEnvironmentVariable) DeepCopy() *BatchEnvironmentVariable

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BatchEnvironmentVariable.

func (*BatchEnvironmentVariable) DeepCopyInto 

func (in *BatchEnvironmentVariable) DeepCopyInto(out *BatchEnvironmentVariable)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type BatchJobDependency 

type BatchJobDependency struct {
	JobID *string `json:"jobID,omitempty"`
	Type  *string `json:"type_,omitempty"`
}

An object that represents an Batch job dependency.

func (*BatchJobDependency) DeepCopy 

func (in *BatchJobDependency) DeepCopy() *BatchJobDependency

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BatchJobDependency.

func (*BatchJobDependency) DeepCopyInto 

func (in *BatchJobDependency) DeepCopyInto(out *BatchJobDependency)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type BatchJobDependencyType 

type BatchJobDependencyType string
const (
	BatchJobDependencyType_N_TO_N     BatchJobDependencyType = "N_TO_N"
	BatchJobDependencyType_SEQUENTIAL BatchJobDependencyType = "SEQUENTIAL"
)

type BatchResourceRequirement 

type BatchResourceRequirement struct {
	Type  *string `json:"type_,omitempty"`
	Value *string `json:"value,omitempty"`
}

The type and amount of a resource to assign to a container. The supported resources include GPU, MEMORY, and VCPU.

func (*BatchResourceRequirement) DeepCopy 

func (in *BatchResourceRequirement) DeepCopy() *BatchResourceRequirement

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BatchResourceRequirement.

func (*BatchResourceRequirement) DeepCopyInto 

func (in *BatchResourceRequirement) DeepCopyInto(out *BatchResourceRequirement)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type BatchResourceRequirementType 

type BatchResourceRequirementType string
const (
	BatchResourceRequirementType_GPU    BatchResourceRequirementType = "GPU"
	BatchResourceRequirementType_MEMORY BatchResourceRequirementType = "MEMORY"
	BatchResourceRequirementType_VCPU   BatchResourceRequirementType = "VCPU"
)

type BatchRetryStrategy 

type BatchRetryStrategy struct {
	Attempts *int64 `json:"attempts,omitempty"`
}

The retry strategy that's associated with a job. For more information, see Automated job retries (https://docs.aws.amazon.com/batch/latest/userguide/job_retries.html) in the Batch User Guide.

func (*BatchRetryStrategy) DeepCopy 

func (in *BatchRetryStrategy) DeepCopy() *BatchRetryStrategy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BatchRetryStrategy.

func (*BatchRetryStrategy) DeepCopyInto 

func (in *BatchRetryStrategy) DeepCopyInto(out *BatchRetryStrategy)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type CapacityProviderStrategyItem 

type CapacityProviderStrategyItem struct {
	Base             *int64  `json:"base,omitempty"`
	CapacityProvider *string `json:"capacityProvider,omitempty"`
	Weight           *int64  `json:"weight,omitempty"`
}

The details of a capacity provider strategy. To learn more, see CapacityProviderStrategyItem (https://docs.aws.amazon.com/AmazonECS/latest/APIReference/API_CapacityProviderStrategyItem.html) in the Amazon ECS API Reference.

func (*CapacityProviderStrategyItem) DeepCopy 

func (in *CapacityProviderStrategyItem) DeepCopy() *CapacityProviderStrategyItem

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CapacityProviderStrategyItem.

func (*CapacityProviderStrategyItem) DeepCopyInto 

func (in *CapacityProviderStrategyItem) DeepCopyInto(out *CapacityProviderStrategyItem)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type CloudwatchLogsLogDestination added in v1.0.15 

type CloudwatchLogsLogDestination struct {
	LogGroupARN *string `json:"logGroupARN,omitempty"`
}

The Amazon CloudWatch Logs logging configuration settings for the pipe.

func (*CloudwatchLogsLogDestination) DeepCopy added in v1.0.15 

func (in *CloudwatchLogsLogDestination) DeepCopy() *CloudwatchLogsLogDestination

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudwatchLogsLogDestination.

func (*CloudwatchLogsLogDestination) DeepCopyInto added in v1.0.15 

func (in *CloudwatchLogsLogDestination) DeepCopyInto(out *CloudwatchLogsLogDestination)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type CloudwatchLogsLogDestinationParameters added in v1.0.15 

type CloudwatchLogsLogDestinationParameters struct {
	LogGroupARN *string `json:"logGroupARN,omitempty"`
}

The Amazon CloudWatch Logs logging configuration settings for the pipe.

func (*CloudwatchLogsLogDestinationParameters) DeepCopy added in v1.0.15 

func (in *CloudwatchLogsLogDestinationParameters) DeepCopy() *CloudwatchLogsLogDestinationParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudwatchLogsLogDestinationParameters.

func (*CloudwatchLogsLogDestinationParameters) DeepCopyInto added in v1.0.15 

func (in *CloudwatchLogsLogDestinationParameters) DeepCopyInto(out *CloudwatchLogsLogDestinationParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DeadLetterConfig 

type DeadLetterConfig struct {
	ARN *string `json:"arn,omitempty"`
}

A DeadLetterConfig object that contains information about a dead-letter queue configuration.

func (*DeadLetterConfig) DeepCopy 

func (in *DeadLetterConfig) DeepCopy() *DeadLetterConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeadLetterConfig.

func (*DeadLetterConfig) DeepCopyInto 

func (in *DeadLetterConfig) DeepCopyInto(out *DeadLetterConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DimensionValueType added in v1.0.15 

type DimensionValueType string
const (
	DimensionValueType_VARCHAR DimensionValueType = "VARCHAR"
)

type DynamoDBStreamStartPosition 

type DynamoDBStreamStartPosition string
const (
	DynamoDBStreamStartPosition_TRIM_HORIZON DynamoDBStreamStartPosition = "TRIM_HORIZON"
	DynamoDBStreamStartPosition_LATEST       DynamoDBStreamStartPosition = "LATEST"
)

type ECSContainerOverride 

type ECSContainerOverride struct {
	Command              []*string                 `json:"command,omitempty"`
	CPU                  *int64                    `json:"cpu,omitempty"`
	Environment          []*ECSEnvironmentVariable `json:"environment,omitempty"`
	EnvironmentFiles     []*ECSEnvironmentFile     `json:"environmentFiles,omitempty"`
	Memory               *int64                    `json:"memory,omitempty"`
	MemoryReservation    *int64                    `json:"memoryReservation,omitempty"`
	Name                 *string                   `json:"name,omitempty"`
	ResourceRequirements []*ECSResourceRequirement `json:"resourceRequirements,omitempty"`
}

The overrides that are sent to a container. An empty container override can be passed in. An example of an empty container override is {"containerOverrides": [ ] }. If a non-empty container override is specified, the name parameter must be included.

func (*ECSContainerOverride) DeepCopy 

func (in *ECSContainerOverride) DeepCopy() *ECSContainerOverride

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ECSContainerOverride.

func (*ECSContainerOverride) DeepCopyInto 

func (in *ECSContainerOverride) DeepCopyInto(out *ECSContainerOverride)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ECSEnvironmentFile 

type ECSEnvironmentFile struct {
	Type  *string `json:"type_,omitempty"`
	Value *string `json:"value,omitempty"`
}

A list of files containing the environment variables to pass to a container. You can specify up to ten environment files. The file must have a .env file extension. Each line in an environment file should contain an environment variable in VARIABLE=VALUE format. Lines beginning with # are treated as comments and are ignored. For more information about the environment variable file syntax, see Declare default environment variables in file (https://docs.docker.com/compose/env-file/).

If there are environment variables specified using the environment parameter in a container definition, they take precedence over the variables contained within an environment file. If multiple environment files are specified that contain the same variable, they're processed from the top down. We recommend that you use unique variable names. For more information, see Specifying environment variables (https://docs.aws.amazon.com/AmazonECS/latest/developerguide/taskdef-envfiles.html) in the Amazon Elastic Container Service Developer Guide.

This parameter is only supported for tasks hosted on Fargate using the following platform versions:

  • Linux platform version 1.4.0 or later.

  • Windows platform version 1.0.0 or later.

func (*ECSEnvironmentFile) DeepCopy 

func (in *ECSEnvironmentFile) DeepCopy() *ECSEnvironmentFile

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ECSEnvironmentFile.

func (*ECSEnvironmentFile) DeepCopyInto 

func (in *ECSEnvironmentFile) DeepCopyInto(out *ECSEnvironmentFile)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ECSEnvironmentFileType 

type ECSEnvironmentFileType string
const (
	ECSEnvironmentFileType_s3 ECSEnvironmentFileType = "s3"
)

type ECSEnvironmentVariable 

type ECSEnvironmentVariable struct {
	Name  *string `json:"name,omitempty"`
	Value *string `json:"value,omitempty"`
}

The environment variables to send to the container. You can add new environment variables, which are added to the container at launch, or you can override the existing environment variables from the Docker image or the task definition. You must also specify a container name.

func (*ECSEnvironmentVariable) DeepCopy 

func (in *ECSEnvironmentVariable) DeepCopy() *ECSEnvironmentVariable

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ECSEnvironmentVariable.

func (*ECSEnvironmentVariable) DeepCopyInto 

func (in *ECSEnvironmentVariable) DeepCopyInto(out *ECSEnvironmentVariable)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ECSEphemeralStorage 

type ECSEphemeralStorage struct {
	SizeInGiB *int64 `json:"sizeInGiB,omitempty"`
}

The amount of ephemeral storage to allocate for the task. This parameter is used to expand the total amount of ephemeral storage available, beyond the default amount, for tasks hosted on Fargate. For more information, see Fargate task storage (https://docs.aws.amazon.com/AmazonECS/latest/userguide/using_data_volumes.html) in the Amazon ECS User Guide for Fargate.

This parameter is only supported for tasks hosted on Fargate using Linux platform version 1.4.0 or later. This parameter is not supported for Windows containers on Fargate.

func (*ECSEphemeralStorage) DeepCopy 

func (in *ECSEphemeralStorage) DeepCopy() *ECSEphemeralStorage

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ECSEphemeralStorage.

func (*ECSEphemeralStorage) DeepCopyInto 

func (in *ECSEphemeralStorage) DeepCopyInto(out *ECSEphemeralStorage)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ECSInferenceAcceleratorOverride 

type ECSInferenceAcceleratorOverride struct {
	DeviceName *string `json:"deviceName,omitempty"`
	DeviceType *string `json:"deviceType,omitempty"`
}

Details on an Elastic Inference accelerator task override. This parameter is used to override the Elastic Inference accelerator specified in the task definition. For more information, see Working with Amazon Elastic Inference on Amazon ECS (https://docs.aws.amazon.com/AmazonECS/latest/userguide/ecs-inference.html) in the Amazon Elastic Container Service Developer Guide.

func (*ECSInferenceAcceleratorOverride) DeepCopy 

func (in *ECSInferenceAcceleratorOverride) DeepCopy() *ECSInferenceAcceleratorOverride

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ECSInferenceAcceleratorOverride.

func (*ECSInferenceAcceleratorOverride) DeepCopyInto 

func (in *ECSInferenceAcceleratorOverride) DeepCopyInto(out *ECSInferenceAcceleratorOverride)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ECSResourceRequirement 

type ECSResourceRequirement struct {
	Type  *string `json:"type_,omitempty"`
	Value *string `json:"value,omitempty"`
}

The type and amount of a resource to assign to a container. The supported resource types are GPUs and Elastic Inference accelerators. For more information, see Working with GPUs on Amazon ECS (https://docs.aws.amazon.com/AmazonECS/latest/developerguide/ecs-gpu.html) or Working with Amazon Elastic Inference on Amazon ECS (https://docs.aws.amazon.com/AmazonECS/latest/developerguide/ecs-inference.html) in the Amazon Elastic Container Service Developer Guide

func (*ECSResourceRequirement) DeepCopy 

func (in *ECSResourceRequirement) DeepCopy() *ECSResourceRequirement

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ECSResourceRequirement.

func (*ECSResourceRequirement) DeepCopyInto 

func (in *ECSResourceRequirement) DeepCopyInto(out *ECSResourceRequirement)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ECSResourceRequirementType 

type ECSResourceRequirementType string
const (
	ECSResourceRequirementType_GPU                  ECSResourceRequirementType = "GPU"
	ECSResourceRequirementType_InferenceAccelerator ECSResourceRequirementType = "InferenceAccelerator"
)

type ECSTaskOverride 

type ECSTaskOverride struct {
	ContainerOverrides []*ECSContainerOverride `json:"containerOverrides,omitempty"`
	CPU                *string                 `json:"cpu,omitempty"`
	// The amount of ephemeral storage to allocate for the task. This parameter
	// is used to expand the total amount of ephemeral storage available, beyond
	// the default amount, for tasks hosted on Fargate. For more information, see
	// Fargate task storage (https://docs.aws.amazon.com/AmazonECS/latest/userguide/using_data_volumes.html)
	// in the Amazon ECS User Guide for Fargate.
	//
	// This parameter is only supported for tasks hosted on Fargate using Linux
	// platform version 1.4.0 or later. This parameter is not supported for Windows
	// containers on Fargate.
	EphemeralStorage              *ECSEphemeralStorage               `json:"ephemeralStorage,omitempty"`
	ExecutionRoleARN              *string                            `json:"executionRoleARN,omitempty"`
	InferenceAcceleratorOverrides []*ECSInferenceAcceleratorOverride `json:"inferenceAcceleratorOverrides,omitempty"`
	Memory                        *string                            `json:"memory,omitempty"`
	TaskRoleARN                   *string                            `json:"taskRoleARN,omitempty"`
}

The overrides that are associated with a task.

func (*ECSTaskOverride) DeepCopy 

func (in *ECSTaskOverride) DeepCopy() *ECSTaskOverride

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ECSTaskOverride.

func (*ECSTaskOverride) DeepCopyInto 

func (in *ECSTaskOverride) DeepCopyInto(out *ECSTaskOverride)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type EpochTimeUnit added in v1.0.15 

type EpochTimeUnit string
const (
	EpochTimeUnit_MILLISECONDS EpochTimeUnit = "MILLISECONDS"
	EpochTimeUnit_SECONDS      EpochTimeUnit = "SECONDS"
	EpochTimeUnit_MICROSECONDS EpochTimeUnit = "MICROSECONDS"
	EpochTimeUnit_NANOSECONDS  EpochTimeUnit = "NANOSECONDS"
)

type Filter 

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

Filter events using an event pattern. For more information, see Events and Event Patterns (https://docs.aws.amazon.com/eventbridge/latest/userguide/eventbridge-and-event-patterns.html) in the Amazon EventBridge User Guide.

func (*Filter) DeepCopy 

func (in *Filter) DeepCopy() *Filter

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Filter.

func (*Filter) DeepCopyInto 

func (in *Filter) DeepCopyInto(out *Filter)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type FilterCriteria 

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

The collection of event patterns used to filter events.

To remove a filter, specify a FilterCriteria object with an empty array of Filter objects.

For more information, see Events and Event Patterns (https://docs.aws.amazon.com/eventbridge/latest/userguide/eventbridge-and-event-patterns.html) in the Amazon EventBridge User Guide.

func (*FilterCriteria) DeepCopy 

func (in *FilterCriteria) DeepCopy() *FilterCriteria

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FilterCriteria.

func (*FilterCriteria) DeepCopyInto 

func (in *FilterCriteria) DeepCopyInto(out *FilterCriteria)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type FirehoseLogDestination added in v1.0.15 

type FirehoseLogDestination struct {
	DeliveryStreamARN *string `json:"deliveryStreamARN,omitempty"`
}

The Amazon Data Firehose logging configuration settings for the pipe.

func (*FirehoseLogDestination) DeepCopy added in v1.0.15 

func (in *FirehoseLogDestination) DeepCopy() *FirehoseLogDestination

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FirehoseLogDestination.

func (*FirehoseLogDestination) DeepCopyInto added in v1.0.15 

func (in *FirehoseLogDestination) DeepCopyInto(out *FirehoseLogDestination)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type FirehoseLogDestinationParameters added in v1.0.15 

type FirehoseLogDestinationParameters struct {
	DeliveryStreamARN *string `json:"deliveryStreamARN,omitempty"`
}

The Amazon Data Firehose logging configuration settings for the pipe.

func (*FirehoseLogDestinationParameters) DeepCopy added in v1.0.15 

func (in *FirehoseLogDestinationParameters) DeepCopy() *FirehoseLogDestinationParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FirehoseLogDestinationParameters.

func (*FirehoseLogDestinationParameters) DeepCopyInto added in v1.0.15 

func (in *FirehoseLogDestinationParameters) DeepCopyInto(out *FirehoseLogDestinationParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type IncludeExecutionDataOption added in v1.0.15 

type IncludeExecutionDataOption string
const (
	IncludeExecutionDataOption_ALL IncludeExecutionDataOption = "ALL"
)

type KinesisStreamStartPosition 

type KinesisStreamStartPosition string
const (
	KinesisStreamStartPosition_TRIM_HORIZON KinesisStreamStartPosition = "TRIM_HORIZON"
	KinesisStreamStartPosition_LATEST       KinesisStreamStartPosition = "LATEST"
	KinesisStreamStartPosition_AT_TIMESTAMP KinesisStreamStartPosition = "AT_TIMESTAMP"
)

type LaunchType 

type LaunchType string
const (
	LaunchType_EC2      LaunchType = "EC2"
	LaunchType_FARGATE  LaunchType = "FARGATE"
	LaunchType_EXTERNAL LaunchType = "EXTERNAL"
)

type LogLevel added in v1.0.15 

type LogLevel string
const (
	LogLevel_OFF   LogLevel = "OFF"
	LogLevel_ERROR LogLevel = "ERROR"
	LogLevel_INFO  LogLevel = "INFO"
	LogLevel_TRACE LogLevel = "TRACE"
)

type MQBrokerAccessCredentials 

type MQBrokerAccessCredentials struct {
	// // Optional SecretManager ARN which stores the database credentials
	BasicAuth *string `json:"basicAuth,omitempty"`
}

The Secrets Manager secret that stores your broker credentials.

func (*MQBrokerAccessCredentials) DeepCopy 

func (in *MQBrokerAccessCredentials) DeepCopy() *MQBrokerAccessCredentials

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MQBrokerAccessCredentials.

func (*MQBrokerAccessCredentials) DeepCopyInto 

func (in *MQBrokerAccessCredentials) DeepCopyInto(out *MQBrokerAccessCredentials)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type MSKAccessCredentials 

type MSKAccessCredentials struct {
	// // Optional SecretManager ARN which stores the database credentials
	ClientCertificateTLSAuth *string `json:"clientCertificateTLSAuth,omitempty"`
	// // Optional SecretManager ARN which stores the database credentials
	SASLSCRAM512Auth *string `json:"saslSCRAM512Auth,omitempty"`
}

The Secrets Manager secret that stores your stream credentials.

func (*MSKAccessCredentials) DeepCopy 

func (in *MSKAccessCredentials) DeepCopy() *MSKAccessCredentials

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MSKAccessCredentials.

func (*MSKAccessCredentials) DeepCopyInto 

func (in *MSKAccessCredentials) DeepCopyInto(out *MSKAccessCredentials)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type MSKStartPosition 

type MSKStartPosition string
const (
	MSKStartPosition_TRIM_HORIZON MSKStartPosition = "TRIM_HORIZON"
	MSKStartPosition_LATEST       MSKStartPosition = "LATEST"
)

type MeasureValueType added in v1.0.15 

type MeasureValueType string
const (
	MeasureValueType_DOUBLE    MeasureValueType = "DOUBLE"
	MeasureValueType_BIGINT    MeasureValueType = "BIGINT"
	MeasureValueType_VARCHAR   MeasureValueType = "VARCHAR"
	MeasureValueType_BOOLEAN   MeasureValueType = "BOOLEAN"
	MeasureValueType_TIMESTAMP MeasureValueType = "TIMESTAMP"
)

type NetworkConfiguration 

type NetworkConfiguration struct {
	// This structure specifies the VPC subnets and security groups for the task,
	// and whether a public IP address is to be used. This structure is relevant
	// only for ECS tasks that use the awsvpc network mode.
	AWSVPCConfiguration *AWSVPCConfiguration `json:"awsVPCConfiguration,omitempty"`
}

This structure specifies the network configuration for an Amazon ECS task.

func (*NetworkConfiguration) DeepCopy 

func (in *NetworkConfiguration) DeepCopy() *NetworkConfiguration

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NetworkConfiguration.

func (*NetworkConfiguration) DeepCopyInto 

func (in *NetworkConfiguration) DeepCopyInto(out *NetworkConfiguration)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OnPartialBatchItemFailureStreams 

type OnPartialBatchItemFailureStreams string
const (
	OnPartialBatchItemFailureStreams_AUTOMATIC_BISECT OnPartialBatchItemFailureStreams = "AUTOMATIC_BISECT"
)

type Pipe 

type Pipe struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              PipeSpec   `json:"spec,omitempty"`
	Status            PipeStatus `json:"status,omitempty"`
}

Pipe is the Schema for the Pipes API +kubebuilder:object:root=true +kubebuilder:subresource:status +kubebuilder:printcolumn:name="ARN",type=string,priority=1,JSONPath=`.status.ackResourceMetadata.arn` +kubebuilder:printcolumn:name="SOURCE",type=string,priority=1,JSONPath=`.spec.source` +kubebuilder:printcolumn:name="STATE",type=string,priority=0,JSONPath=`.status.currentState` +kubebuilder:printcolumn:name="TARGET",type=string,priority=1,JSONPath=`.spec.target` +kubebuilder:printcolumn:name="Synced",type="string",priority=0,JSONPath=".status.conditions[?(@.type==\"ACK.ResourceSynced\")].status" +kubebuilder:printcolumn:name="Age",type="date",priority=0,JSONPath=".metadata.creationTimestamp"

func (*Pipe) DeepCopy 

func (in *Pipe) DeepCopy() *Pipe

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Pipe.

func (*Pipe) DeepCopyInto 

func (in *Pipe) DeepCopyInto(out *Pipe)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Pipe) DeepCopyObject 

func (in *Pipe) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type PipeEnrichmentHTTPParameters 

type PipeEnrichmentHTTPParameters struct {
	HeaderParameters      map[string]*string `json:"headerParameters,omitempty"`
	PathParameterValues   []*string          `json:"pathParameterValues,omitempty"`
	QueryStringParameters map[string]*string `json:"queryStringParameters,omitempty"`
}

These are custom parameter to be used when the target is an API Gateway REST APIs or EventBridge ApiDestinations. In the latter case, these are merged with any InvocationParameters specified on the Connection, with any values from the Connection taking precedence.

func (*PipeEnrichmentHTTPParameters) DeepCopy 

func (in *PipeEnrichmentHTTPParameters) DeepCopy() *PipeEnrichmentHTTPParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PipeEnrichmentHTTPParameters.

func (*PipeEnrichmentHTTPParameters) DeepCopyInto 

func (in *PipeEnrichmentHTTPParameters) DeepCopyInto(out *PipeEnrichmentHTTPParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PipeEnrichmentParameters 

type PipeEnrichmentParameters struct {
	// These are custom parameter to be used when the target is an API Gateway REST
	// APIs or EventBridge ApiDestinations. In the latter case, these are merged
	// with any InvocationParameters specified on the Connection, with any values
	// from the Connection taking precedence.
	HTTPParameters *PipeEnrichmentHTTPParameters `json:"httpParameters,omitempty"`
	InputTemplate  *string                       `json:"inputTemplate,omitempty"`
}

The parameters required to set up enrichment on your pipe.

func (*PipeEnrichmentParameters) DeepCopy 

func (in *PipeEnrichmentParameters) DeepCopy() *PipeEnrichmentParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PipeEnrichmentParameters.

func (*PipeEnrichmentParameters) DeepCopyInto 

func (in *PipeEnrichmentParameters) DeepCopyInto(out *PipeEnrichmentParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PipeList 

type PipeList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Pipe `json:"items"`
}

PipeList contains a list of Pipe +kubebuilder:object:root=true

func (*PipeList) DeepCopy 

func (in *PipeList) DeepCopy() *PipeList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PipeList.

func (*PipeList) DeepCopyInto 

func (in *PipeList) DeepCopyInto(out *PipeList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*PipeList) DeepCopyObject 

func (in *PipeList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type PipeLogConfiguration added in v1.0.15 

type PipeLogConfiguration struct {
	// The Amazon CloudWatch Logs logging configuration settings for the pipe.
	CloudwatchLogsLogDestination *CloudwatchLogsLogDestination `json:"cloudwatchLogsLogDestination,omitempty"`
	// The Amazon Data Firehose logging configuration settings for the pipe.
	FirehoseLogDestination *FirehoseLogDestination `json:"firehoseLogDestination,omitempty"`
	IncludeExecutionData   []*string               `json:"includeExecutionData,omitempty"`
	Level                  *string                 `json:"level,omitempty"`
	// The Amazon S3 logging configuration settings for the pipe.
	S3LogDestination *S3LogDestination `json:"s3LogDestination,omitempty"`
}

The logging configuration settings for the pipe.

func (*PipeLogConfiguration) DeepCopy added in v1.0.15 

func (in *PipeLogConfiguration) DeepCopy() *PipeLogConfiguration

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PipeLogConfiguration.

func (*PipeLogConfiguration) DeepCopyInto added in v1.0.15 

func (in *PipeLogConfiguration) DeepCopyInto(out *PipeLogConfiguration)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PipeLogConfigurationParameters added in v1.0.15 

type PipeLogConfigurationParameters struct {
	// The Amazon CloudWatch Logs logging configuration settings for the pipe.
	CloudwatchLogsLogDestination *CloudwatchLogsLogDestinationParameters `json:"cloudwatchLogsLogDestination,omitempty"`
	// The Amazon Data Firehose logging configuration settings for the pipe.
	FirehoseLogDestination *FirehoseLogDestinationParameters `json:"firehoseLogDestination,omitempty"`
	IncludeExecutionData   []*string                         `json:"includeExecutionData,omitempty"`
	Level                  *string                           `json:"level,omitempty"`
	// The Amazon S3 logging configuration settings for the pipe.
	S3LogDestination *S3LogDestinationParameters `json:"s3LogDestination,omitempty"`
}

Specifies the logging configuration settings for the pipe.

When you call UpdatePipe, EventBridge updates the fields in the PipeLogConfigurationParameters object atomically as one and overrides existing values. This is by design. If you don't specify an optional field in any of the Amazon Web Services service parameters objects (CloudwatchLogsLogDestinationParameters, FirehoseLogDestinationParameters, or S3LogDestinationParameters), EventBridge sets that field to its system-default value during the update.

For example, suppose when you created the pipe you specified a Firehose stream log destination. You then update the pipe to add an Amazon S3 log destination. In addition to specifying the S3LogDestinationParameters for the new log destination, you must also specify the fields in the FirehoseLogDestinationParameters object in order to retain the Firehose stream log destination.

For more information on generating pipe log records, see Log EventBridge Pipes (eventbridge/latest/userguide/eb-pipes-logs.html) in the Amazon EventBridge User Guide.

func (*PipeLogConfigurationParameters) DeepCopy added in v1.0.15 

func (in *PipeLogConfigurationParameters) DeepCopy() *PipeLogConfigurationParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PipeLogConfigurationParameters.

func (*PipeLogConfigurationParameters) DeepCopyInto added in v1.0.15 

func (in *PipeLogConfigurationParameters) DeepCopyInto(out *PipeLogConfigurationParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PipeSourceActiveMQBrokerParameters 

type PipeSourceActiveMQBrokerParameters struct {
	BatchSize *int64 `json:"batchSize,omitempty"`
	// The Secrets Manager secret that stores your broker credentials.
	Credentials                    *MQBrokerAccessCredentials `json:"credentials,omitempty"`
	MaximumBatchingWindowInSeconds *int64                     `json:"maximumBatchingWindowInSeconds,omitempty"`
	QueueName                      *string                    `json:"queueName,omitempty"`
}

The parameters for using an Active MQ broker as a source.

func (*PipeSourceActiveMQBrokerParameters) DeepCopy 

func (in *PipeSourceActiveMQBrokerParameters) DeepCopy() *PipeSourceActiveMQBrokerParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PipeSourceActiveMQBrokerParameters.

func (*PipeSourceActiveMQBrokerParameters) DeepCopyInto 

func (in *PipeSourceActiveMQBrokerParameters) DeepCopyInto(out *PipeSourceActiveMQBrokerParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PipeSourceDynamoDBStreamParameters 

type PipeSourceDynamoDBStreamParameters struct {
	BatchSize *int64 `json:"batchSize,omitempty"`
	// A DeadLetterConfig object that contains information about a dead-letter queue
	// configuration.
	DeadLetterConfig               *DeadLetterConfig `json:"deadLetterConfig,omitempty"`
	MaximumBatchingWindowInSeconds *int64            `json:"maximumBatchingWindowInSeconds,omitempty"`
	MaximumRecordAgeInSeconds      *int64            `json:"maximumRecordAgeInSeconds,omitempty"`
	MaximumRetryAttempts           *int64            `json:"maximumRetryAttempts,omitempty"`
	OnPartialBatchItemFailure      *string           `json:"onPartialBatchItemFailure,omitempty"`
	ParallelizationFactor          *int64            `json:"parallelizationFactor,omitempty"`
	StartingPosition               *string           `json:"startingPosition,omitempty"`
}

The parameters for using a DynamoDB stream as a source.

func (*PipeSourceDynamoDBStreamParameters) DeepCopy 

func (in *PipeSourceDynamoDBStreamParameters) DeepCopy() *PipeSourceDynamoDBStreamParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PipeSourceDynamoDBStreamParameters.

func (*PipeSourceDynamoDBStreamParameters) DeepCopyInto 

func (in *PipeSourceDynamoDBStreamParameters) DeepCopyInto(out *PipeSourceDynamoDBStreamParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PipeSourceKinesisStreamParameters 

type PipeSourceKinesisStreamParameters struct {
	BatchSize *int64 `json:"batchSize,omitempty"`
	// A DeadLetterConfig object that contains information about a dead-letter queue
	// configuration.
	DeadLetterConfig               *DeadLetterConfig `json:"deadLetterConfig,omitempty"`
	MaximumBatchingWindowInSeconds *int64            `json:"maximumBatchingWindowInSeconds,omitempty"`
	MaximumRecordAgeInSeconds      *int64            `json:"maximumRecordAgeInSeconds,omitempty"`
	MaximumRetryAttempts           *int64            `json:"maximumRetryAttempts,omitempty"`
	OnPartialBatchItemFailure      *string           `json:"onPartialBatchItemFailure,omitempty"`
	ParallelizationFactor          *int64            `json:"parallelizationFactor,omitempty"`
	StartingPosition               *string           `json:"startingPosition,omitempty"`
	StartingPositionTimestamp      *metav1.Time      `json:"startingPositionTimestamp,omitempty"`
}

The parameters for using a Kinesis stream as a source.

func (*PipeSourceKinesisStreamParameters) DeepCopy 

func (in *PipeSourceKinesisStreamParameters) DeepCopy() *PipeSourceKinesisStreamParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PipeSourceKinesisStreamParameters.

func (*PipeSourceKinesisStreamParameters) DeepCopyInto 

func (in *PipeSourceKinesisStreamParameters) DeepCopyInto(out *PipeSourceKinesisStreamParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PipeSourceManagedStreamingKafkaParameters 

type PipeSourceManagedStreamingKafkaParameters struct {
	BatchSize       *int64  `json:"batchSize,omitempty"`
	ConsumerGroupID *string `json:"consumerGroupID,omitempty"`
	// The Secrets Manager secret that stores your stream credentials.
	Credentials                    *MSKAccessCredentials `json:"credentials,omitempty"`
	MaximumBatchingWindowInSeconds *int64                `json:"maximumBatchingWindowInSeconds,omitempty"`
	StartingPosition               *string               `json:"startingPosition,omitempty"`
	TopicName                      *string               `json:"topicName,omitempty"`
}

The parameters for using an MSK stream as a source.

func (*PipeSourceManagedStreamingKafkaParameters) DeepCopy 

func (in *PipeSourceManagedStreamingKafkaParameters) DeepCopy() *PipeSourceManagedStreamingKafkaParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PipeSourceManagedStreamingKafkaParameters.

func (*PipeSourceManagedStreamingKafkaParameters) DeepCopyInto 

func (in *PipeSourceManagedStreamingKafkaParameters) DeepCopyInto(out *PipeSourceManagedStreamingKafkaParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PipeSourceParameters 

type PipeSourceParameters struct {
	// The parameters for using an Active MQ broker as a source.
	ActiveMQBrokerParameters *PipeSourceActiveMQBrokerParameters `json:"activeMQBrokerParameters,omitempty"`
	// The parameters for using a DynamoDB stream as a source.
	DynamoDBStreamParameters *PipeSourceDynamoDBStreamParameters `json:"dynamoDBStreamParameters,omitempty"`
	// The collection of event patterns used to filter events.
	//
	// To remove a filter, specify a FilterCriteria object with an empty array of
	// Filter objects.
	//
	// For more information, see Events and Event Patterns (https://docs.aws.amazon.com/eventbridge/latest/userguide/eventbridge-and-event-patterns.html)
	// in the Amazon EventBridge User Guide.
	FilterCriteria *FilterCriteria `json:"filterCriteria,omitempty"`
	// The parameters for using a Kinesis stream as a source.
	KinesisStreamParameters *PipeSourceKinesisStreamParameters `json:"kinesisStreamParameters,omitempty"`
	// The parameters for using an MSK stream as a source.
	ManagedStreamingKafkaParameters *PipeSourceManagedStreamingKafkaParameters `json:"managedStreamingKafkaParameters,omitempty"`
	// The parameters for using a Rabbit MQ broker as a source.
	RabbitMQBrokerParameters *PipeSourceRabbitMQBrokerParameters `json:"rabbitMQBrokerParameters,omitempty"`
	// The parameters for using a self-managed Apache Kafka stream as a source.
	//
	// A self managed cluster refers to any Apache Kafka cluster not hosted by Amazon
	// Web Services. This includes both clusters you manage yourself, as well as
	// those hosted by a third-party provider, such as Confluent Cloud (https://www.confluent.io/),
	// CloudKarafka (https://www.cloudkarafka.com/), or Redpanda (https://redpanda.com/).
	// For more information, see Apache Kafka streams as a source (https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes-kafka.html)
	// in the Amazon EventBridge User Guide.
	SelfManagedKafkaParameters *PipeSourceSelfManagedKafkaParameters `json:"selfManagedKafkaParameters,omitempty"`
	// The parameters for using a Amazon SQS stream as a source.
	SQSQueueParameters *PipeSourceSQSQueueParameters `json:"sqsQueueParameters,omitempty"`
}

The parameters required to set up a source for your pipe.

func (*PipeSourceParameters) DeepCopy 

func (in *PipeSourceParameters) DeepCopy() *PipeSourceParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PipeSourceParameters.

func (*PipeSourceParameters) DeepCopyInto 

func (in *PipeSourceParameters) DeepCopyInto(out *PipeSourceParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PipeSourceRabbitMQBrokerParameters 

type PipeSourceRabbitMQBrokerParameters struct {
	BatchSize *int64 `json:"batchSize,omitempty"`
	// The Secrets Manager secret that stores your broker credentials.
	Credentials                    *MQBrokerAccessCredentials `json:"credentials,omitempty"`
	MaximumBatchingWindowInSeconds *int64                     `json:"maximumBatchingWindowInSeconds,omitempty"`
	QueueName                      *string                    `json:"queueName,omitempty"`
	VirtualHost                    *string                    `json:"virtualHost,omitempty"`
}

The parameters for using a Rabbit MQ broker as a source.

func (*PipeSourceRabbitMQBrokerParameters) DeepCopy 

func (in *PipeSourceRabbitMQBrokerParameters) DeepCopy() *PipeSourceRabbitMQBrokerParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PipeSourceRabbitMQBrokerParameters.

func (*PipeSourceRabbitMQBrokerParameters) DeepCopyInto 

func (in *PipeSourceRabbitMQBrokerParameters) DeepCopyInto(out *PipeSourceRabbitMQBrokerParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PipeSourceSQSQueueParameters 

type PipeSourceSQSQueueParameters struct {
	BatchSize                      *int64 `json:"batchSize,omitempty"`
	MaximumBatchingWindowInSeconds *int64 `json:"maximumBatchingWindowInSeconds,omitempty"`
}

The parameters for using a Amazon SQS stream as a source.

func (*PipeSourceSQSQueueParameters) DeepCopy 

func (in *PipeSourceSQSQueueParameters) DeepCopy() *PipeSourceSQSQueueParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PipeSourceSQSQueueParameters.

func (*PipeSourceSQSQueueParameters) DeepCopyInto 

func (in *PipeSourceSQSQueueParameters) DeepCopyInto(out *PipeSourceSQSQueueParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PipeSourceSelfManagedKafkaParameters 

type PipeSourceSelfManagedKafkaParameters struct {
	AdditionalBootstrapServers []*string `json:"additionalBootstrapServers,omitempty"`
	BatchSize                  *int64    `json:"batchSize,omitempty"`
	ConsumerGroupID            *string   `json:"consumerGroupID,omitempty"`
	// The Secrets Manager secret that stores your stream credentials.
	Credentials                    *SelfManagedKafkaAccessConfigurationCredentials `json:"credentials,omitempty"`
	MaximumBatchingWindowInSeconds *int64                                          `json:"maximumBatchingWindowInSeconds,omitempty"`
	// // Optional SecretManager ARN which stores the database credentials
	ServerRootCaCertificate *string `json:"serverRootCaCertificate,omitempty"`
	StartingPosition        *string `json:"startingPosition,omitempty"`
	TopicName               *string `json:"topicName,omitempty"`
	// This structure specifies the VPC subnets and security groups for the stream,
	// and whether a public IP address is to be used.
	VPC *SelfManagedKafkaAccessConfigurationVPC `json:"vpc,omitempty"`
}

The parameters for using a self-managed Apache Kafka stream as a source.

A self managed cluster refers to any Apache Kafka cluster not hosted by Amazon Web Services. This includes both clusters you manage yourself, as well as those hosted by a third-party provider, such as Confluent Cloud (https://www.confluent.io/), CloudKarafka (https://www.cloudkarafka.com/), or Redpanda (https://redpanda.com/). For more information, see Apache Kafka streams as a source (https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes-kafka.html) in the Amazon EventBridge User Guide.

func (*PipeSourceSelfManagedKafkaParameters) DeepCopy 

func (in *PipeSourceSelfManagedKafkaParameters) DeepCopy() *PipeSourceSelfManagedKafkaParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PipeSourceSelfManagedKafkaParameters.

func (*PipeSourceSelfManagedKafkaParameters) DeepCopyInto 

func (in *PipeSourceSelfManagedKafkaParameters) DeepCopyInto(out *PipeSourceSelfManagedKafkaParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PipeSpec 

type PipeSpec struct {

	// A description of the pipe.
	Description *string `json:"description,omitempty"`
	// The state the pipe should be in.
	DesiredState *string `json:"desiredState,omitempty"`
	// The ARN of the enrichment resource.
	Enrichment *string `json:"enrichment,omitempty"`
	// The parameters required to set up enrichment on your pipe.
	EnrichmentParameters *PipeEnrichmentParameters `json:"enrichmentParameters,omitempty"`
	// The name of the pipe.
	// +kubebuilder:validation:Required
	Name *string `json:"name"`
	// The ARN of the role that allows the pipe to send data to the target.
	// +kubebuilder:validation:Required
	RoleARN *string `json:"roleARN"`
	// The ARN of the source resource.
	// +kubebuilder:validation:Required
	Source *string `json:"source"`
	// The parameters required to set up a source for your pipe.
	SourceParameters *PipeSourceParameters `json:"sourceParameters,omitempty"`
	// The list of key-value pairs to associate with the pipe.
	Tags map[string]*string `json:"tags,omitempty"`
	// The ARN of the target resource.
	// +kubebuilder:validation:Required
	Target *string `json:"target"`
	// The parameters required to set up a target for your pipe.
	//
	// For more information about pipe target parameters, including how to use dynamic
	// path parameters, see Target parameters (https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes-event-target.html)
	// in the Amazon EventBridge User Guide.
	TargetParameters *PipeTargetParameters `json:"targetParameters,omitempty"`
}

PipeSpec defines the desired state of Pipe.

An object that represents a pipe. Amazon EventBridgePipes connect event sources to targets and reduces the need for specialized knowledge and integration code.

func (*PipeSpec) DeepCopy 

func (in *PipeSpec) DeepCopy() *PipeSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PipeSpec.

func (*PipeSpec) DeepCopyInto 

func (in *PipeSpec) DeepCopyInto(out *PipeSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PipeState 

type PipeState string
const (
	PipeState_RUNNING                PipeState = "RUNNING"
	PipeState_STOPPED                PipeState = "STOPPED"
	PipeState_CREATING               PipeState = "CREATING"
	PipeState_UPDATING               PipeState = "UPDATING"
	PipeState_DELETING               PipeState = "DELETING"
	PipeState_STARTING               PipeState = "STARTING"
	PipeState_STOPPING               PipeState = "STOPPING"
	PipeState_CREATE_FAILED          PipeState = "CREATE_FAILED"
	PipeState_UPDATE_FAILED          PipeState = "UPDATE_FAILED"
	PipeState_START_FAILED           PipeState = "START_FAILED"
	PipeState_STOP_FAILED            PipeState = "STOP_FAILED"
	PipeState_DELETE_FAILED          PipeState = "DELETE_FAILED"
	PipeState_CREATE_ROLLBACK_FAILED PipeState = "CREATE_ROLLBACK_FAILED"
	PipeState_DELETE_ROLLBACK_FAILED PipeState = "DELETE_ROLLBACK_FAILED"
	PipeState_UPDATE_ROLLBACK_FAILED PipeState = "UPDATE_ROLLBACK_FAILED"
)

type PipeStatus 

type PipeStatus struct {
	// All CRs managed by ACK have a common `Status.ACKResourceMetadata` member
	// that is used to contain resource sync state, account ownership,
	// constructed ARN for the resource
	// +kubebuilder:validation:Optional
	ACKResourceMetadata *ackv1alpha1.ResourceMetadata `json:"ackResourceMetadata"`
	// All CRs managed by ACK have a common `Status.Conditions` member that
	// contains a collection of `ackv1alpha1.Condition` objects that describe
	// the various terminal states of the CR and its backend AWS service API
	// resource
	// +kubebuilder:validation:Optional
	Conditions []*ackv1alpha1.Condition `json:"conditions"`
	// The time the pipe was created.
	// +kubebuilder:validation:Optional
	CreationTime *metav1.Time `json:"creationTime,omitempty"`
	// The state the pipe is in.
	// +kubebuilder:validation:Optional
	CurrentState *string `json:"currentState,omitempty"`
	// When the pipe was last updated, in ISO-8601 format (https://www.w3.org/TR/NOTE-datetime)
	// (YYYY-MM-DDThh:mm:ss.sTZD).
	// +kubebuilder:validation:Optional
	LastModifiedTime *metav1.Time `json:"lastModifiedTime,omitempty"`
	// The reason the pipe is in its current state.
	// +kubebuilder:validation:Optional
	StateReason *string `json:"stateReason,omitempty"`
}

PipeStatus defines the observed state of Pipe

func (*PipeStatus) DeepCopy 

func (in *PipeStatus) DeepCopy() *PipeStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PipeStatus.

func (*PipeStatus) DeepCopyInto 

func (in *PipeStatus) DeepCopyInto(out *PipeStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PipeTargetBatchJobParameters 

type PipeTargetBatchJobParameters struct {
	// The array properties for the submitted job, such as the size of the array.
	// The array size can be between 2 and 10,000. If you specify array properties
	// for a job, it becomes an array job. This parameter is used only if the target
	// is an Batch job.
	ArrayProperties *BatchArrayProperties `json:"arrayProperties,omitempty"`
	// The overrides that are sent to a container.
	ContainerOverrides *BatchContainerOverrides `json:"containerOverrides,omitempty"`
	DependsOn          []*BatchJobDependency    `json:"dependsOn,omitempty"`
	JobDefinition      *string                  `json:"jobDefinition,omitempty"`
	JobName            *string                  `json:"jobName,omitempty"`
	Parameters         map[string]*string       `json:"parameters,omitempty"`
	// The retry strategy that's associated with a job. For more information, see
	// Automated job retries (https://docs.aws.amazon.com/batch/latest/userguide/job_retries.html)
	// in the Batch User Guide.
	RetryStrategy *BatchRetryStrategy `json:"retryStrategy,omitempty"`
}

The parameters for using an Batch job as a target.

func (*PipeTargetBatchJobParameters) DeepCopy 

func (in *PipeTargetBatchJobParameters) DeepCopy() *PipeTargetBatchJobParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PipeTargetBatchJobParameters.

func (*PipeTargetBatchJobParameters) DeepCopyInto 

func (in *PipeTargetBatchJobParameters) DeepCopyInto(out *PipeTargetBatchJobParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PipeTargetCloudWatchLogsParameters 

type PipeTargetCloudWatchLogsParameters struct {
	LogStreamName *string `json:"logStreamName,omitempty"`
	Timestamp     *string `json:"timestamp,omitempty"`
}

The parameters for using an CloudWatch Logs log stream as a target.

func (*PipeTargetCloudWatchLogsParameters) DeepCopy 

func (in *PipeTargetCloudWatchLogsParameters) DeepCopy() *PipeTargetCloudWatchLogsParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PipeTargetCloudWatchLogsParameters.

func (*PipeTargetCloudWatchLogsParameters) DeepCopyInto 

func (in *PipeTargetCloudWatchLogsParameters) DeepCopyInto(out *PipeTargetCloudWatchLogsParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PipeTargetECSTaskParameters 

type PipeTargetECSTaskParameters struct {
	CapacityProviderStrategy []*CapacityProviderStrategyItem `json:"capacityProviderStrategy,omitempty"`
	EnableECSManagedTags     *bool                           `json:"enableECSManagedTags,omitempty"`
	EnableExecuteCommand     *bool                           `json:"enableExecuteCommand,omitempty"`
	Group                    *string                         `json:"group,omitempty"`
	LaunchType               *string                         `json:"launchType,omitempty"`
	// This structure specifies the network configuration for an Amazon ECS task.
	NetworkConfiguration *NetworkConfiguration `json:"networkConfiguration,omitempty"`
	// The overrides that are associated with a task.
	Overrides            *ECSTaskOverride       `json:"overrides,omitempty"`
	PlacementConstraints []*PlacementConstraint `json:"placementConstraints,omitempty"`
	PlacementStrategy    []*PlacementStrategy   `json:"placementStrategy,omitempty"`
	PlatformVersion      *string                `json:"platformVersion,omitempty"`
	PropagateTags        *string                `json:"propagateTags,omitempty"`
	ReferenceID          *string                `json:"referenceID,omitempty"`
	Tags                 []*Tag                 `json:"tags,omitempty"`
	TaskCount            *int64                 `json:"taskCount,omitempty"`
	TaskDefinitionARN    *string                `json:"taskDefinitionARN,omitempty"`
}

The parameters for using an Amazon ECS task as a target.

func (*PipeTargetECSTaskParameters) DeepCopy 

func (in *PipeTargetECSTaskParameters) DeepCopy() *PipeTargetECSTaskParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PipeTargetECSTaskParameters.

func (*PipeTargetECSTaskParameters) DeepCopyInto 

func (in *PipeTargetECSTaskParameters) DeepCopyInto(out *PipeTargetECSTaskParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PipeTargetEventBridgeEventBusParameters 

type PipeTargetEventBridgeEventBusParameters struct {
	DetailType *string   `json:"detailType,omitempty"`
	EndpointID *string   `json:"endpointID,omitempty"`
	Resources  []*string `json:"resources,omitempty"`
	Source     *string   `json:"source,omitempty"`
	Time       *string   `json:"time,omitempty"`
}

The parameters for using an EventBridge event bus as a target.

func (*PipeTargetEventBridgeEventBusParameters) DeepCopy 

func (in *PipeTargetEventBridgeEventBusParameters) DeepCopy() *PipeTargetEventBridgeEventBusParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PipeTargetEventBridgeEventBusParameters.

func (*PipeTargetEventBridgeEventBusParameters) DeepCopyInto 

func (in *PipeTargetEventBridgeEventBusParameters) DeepCopyInto(out *PipeTargetEventBridgeEventBusParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PipeTargetHTTPParameters 

type PipeTargetHTTPParameters struct {
	HeaderParameters      map[string]*string `json:"headerParameters,omitempty"`
	PathParameterValues   []*string          `json:"pathParameterValues,omitempty"`
	QueryStringParameters map[string]*string `json:"queryStringParameters,omitempty"`
}

These are custom parameter to be used when the target is an API Gateway REST APIs or EventBridge ApiDestinations.

func (*PipeTargetHTTPParameters) DeepCopy 

func (in *PipeTargetHTTPParameters) DeepCopy() *PipeTargetHTTPParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PipeTargetHTTPParameters.

func (*PipeTargetHTTPParameters) DeepCopyInto 

func (in *PipeTargetHTTPParameters) DeepCopyInto(out *PipeTargetHTTPParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PipeTargetInvocationType 

type PipeTargetInvocationType string
const (
	PipeTargetInvocationType_REQUEST_RESPONSE PipeTargetInvocationType = "REQUEST_RESPONSE"
	PipeTargetInvocationType_FIRE_AND_FORGET  PipeTargetInvocationType = "FIRE_AND_FORGET"
)

type PipeTargetKinesisStreamParameters 

type PipeTargetKinesisStreamParameters struct {
	PartitionKey *string `json:"partitionKey,omitempty"`
}

The parameters for using a Kinesis stream as a target.

func (*PipeTargetKinesisStreamParameters) DeepCopy 

func (in *PipeTargetKinesisStreamParameters) DeepCopy() *PipeTargetKinesisStreamParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PipeTargetKinesisStreamParameters.

func (*PipeTargetKinesisStreamParameters) DeepCopyInto 

func (in *PipeTargetKinesisStreamParameters) DeepCopyInto(out *PipeTargetKinesisStreamParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PipeTargetLambdaFunctionParameters 

type PipeTargetLambdaFunctionParameters struct {
	InvocationType *string `json:"invocationType,omitempty"`
}

The parameters for using a Lambda function as a target.

func (*PipeTargetLambdaFunctionParameters) DeepCopy 

func (in *PipeTargetLambdaFunctionParameters) DeepCopy() *PipeTargetLambdaFunctionParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PipeTargetLambdaFunctionParameters.

func (*PipeTargetLambdaFunctionParameters) DeepCopyInto 

func (in *PipeTargetLambdaFunctionParameters) DeepCopyInto(out *PipeTargetLambdaFunctionParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PipeTargetParameters 

type PipeTargetParameters struct {
	// The parameters for using an Batch job as a target.
	BatchJobParameters *PipeTargetBatchJobParameters `json:"batchJobParameters,omitempty"`
	// The parameters for using an CloudWatch Logs log stream as a target.
	CloudWatchLogsParameters *PipeTargetCloudWatchLogsParameters `json:"cloudWatchLogsParameters,omitempty"`
	// The parameters for using an Amazon ECS task as a target.
	ECSTaskParameters *PipeTargetECSTaskParameters `json:"ecsTaskParameters,omitempty"`
	// The parameters for using an EventBridge event bus as a target.
	EventBridgeEventBusParameters *PipeTargetEventBridgeEventBusParameters `json:"eventBridgeEventBusParameters,omitempty"`
	// These are custom parameter to be used when the target is an API Gateway REST
	// APIs or EventBridge ApiDestinations.
	HTTPParameters *PipeTargetHTTPParameters `json:"httpParameters,omitempty"`
	InputTemplate  *string                   `json:"inputTemplate,omitempty"`
	// The parameters for using a Kinesis stream as a target.
	KinesisStreamParameters *PipeTargetKinesisStreamParameters `json:"kinesisStreamParameters,omitempty"`
	// The parameters for using a Lambda function as a target.
	LambdaFunctionParameters *PipeTargetLambdaFunctionParameters `json:"lambdaFunctionParameters,omitempty"`
	// These are custom parameters to be used when the target is a Amazon Redshift
	// cluster to invoke the Amazon Redshift Data API BatchExecuteStatement.
	RedshiftDataParameters *PipeTargetRedshiftDataParameters `json:"redshiftDataParameters,omitempty"`
	// The parameters for using a SageMaker pipeline as a target.
	SageMakerPipelineParameters *PipeTargetSageMakerPipelineParameters `json:"sageMakerPipelineParameters,omitempty"`
	// The parameters for using a Amazon SQS stream as a target.
	SQSQueueParameters *PipeTargetSQSQueueParameters `json:"sqsQueueParameters,omitempty"`
	// The parameters for using a Step Functions state machine as a target.
	StepFunctionStateMachineParameters *PipeTargetStateMachineParameters `json:"stepFunctionStateMachineParameters,omitempty"`
}

The parameters required to set up a target for your pipe.

For more information about pipe target parameters, including how to use dynamic path parameters, see Target parameters (https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes-event-target.html) in the Amazon EventBridge User Guide.

func (*PipeTargetParameters) DeepCopy 

func (in *PipeTargetParameters) DeepCopy() *PipeTargetParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PipeTargetParameters.

func (*PipeTargetParameters) DeepCopyInto 

func (in *PipeTargetParameters) DeepCopyInto(out *PipeTargetParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PipeTargetRedshiftDataParameters 

type PipeTargetRedshiftDataParameters struct {
	// // Redshift Database
	Database *string `json:"database,omitempty"`
	// // Database user name
	DBUser *string `json:"dbUser,omitempty"`
	// // For targets, can either specify an ARN or a jsonpath pointing to the ARN.
	SecretManagerARN *string `json:"secretManagerARN,omitempty"`
	// // A list of SQLs.
	SQLs []*string `json:"sqls,omitempty"`
	// // A name for Redshift DataAPI statement which can be used as filter of//
	// ListStatement.
	StatementName *string `json:"statementName,omitempty"`
	WithEvent     *bool   `json:"withEvent,omitempty"`
}

These are custom parameters to be used when the target is a Amazon Redshift cluster to invoke the Amazon Redshift Data API BatchExecuteStatement.

func (*PipeTargetRedshiftDataParameters) DeepCopy 

func (in *PipeTargetRedshiftDataParameters) DeepCopy() *PipeTargetRedshiftDataParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PipeTargetRedshiftDataParameters.

func (*PipeTargetRedshiftDataParameters) DeepCopyInto 

func (in *PipeTargetRedshiftDataParameters) DeepCopyInto(out *PipeTargetRedshiftDataParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PipeTargetSQSQueueParameters 

type PipeTargetSQSQueueParameters struct {
	MessageDeduplicationID *string `json:"messageDeduplicationID,omitempty"`
	MessageGroupID         *string `json:"messageGroupID,omitempty"`
}

The parameters for using a Amazon SQS stream as a target.

func (*PipeTargetSQSQueueParameters) DeepCopy 

func (in *PipeTargetSQSQueueParameters) DeepCopy() *PipeTargetSQSQueueParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PipeTargetSQSQueueParameters.

func (*PipeTargetSQSQueueParameters) DeepCopyInto 

func (in *PipeTargetSQSQueueParameters) DeepCopyInto(out *PipeTargetSQSQueueParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PipeTargetSageMakerPipelineParameters 

type PipeTargetSageMakerPipelineParameters struct {
	PipelineParameterList []*SageMakerPipelineParameter `json:"pipelineParameterList,omitempty"`
}

The parameters for using a SageMaker pipeline as a target.

func (*PipeTargetSageMakerPipelineParameters) DeepCopy 

func (in *PipeTargetSageMakerPipelineParameters) DeepCopy() *PipeTargetSageMakerPipelineParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PipeTargetSageMakerPipelineParameters.

func (*PipeTargetSageMakerPipelineParameters) DeepCopyInto 

func (in *PipeTargetSageMakerPipelineParameters) DeepCopyInto(out *PipeTargetSageMakerPipelineParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PipeTargetStateMachineParameters 

type PipeTargetStateMachineParameters struct {
	InvocationType *string `json:"invocationType,omitempty"`
}

The parameters for using a Step Functions state machine as a target.

func (*PipeTargetStateMachineParameters) DeepCopy 

func (in *PipeTargetStateMachineParameters) DeepCopy() *PipeTargetStateMachineParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PipeTargetStateMachineParameters.

func (*PipeTargetStateMachineParameters) DeepCopyInto 

func (in *PipeTargetStateMachineParameters) DeepCopyInto(out *PipeTargetStateMachineParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Pipe_SDK 

type Pipe_SDK struct {
	ARN              *string      `json:"arn,omitempty"`
	CreationTime     *metav1.Time `json:"creationTime,omitempty"`
	CurrentState     *string      `json:"currentState,omitempty"`
	DesiredState     *string      `json:"desiredState,omitempty"`
	Enrichment       *string      `json:"enrichment,omitempty"`
	LastModifiedTime *metav1.Time `json:"lastModifiedTime,omitempty"`
	Name             *string      `json:"name,omitempty"`
	Source           *string      `json:"source,omitempty"`
	StateReason      *string      `json:"stateReason,omitempty"`
	Target           *string      `json:"target,omitempty"`
}

An object that represents a pipe. Amazon EventBridgePipes connect event sources to targets and reduces the need for specialized knowledge and integration code.

func (*Pipe_SDK) DeepCopy 

func (in *Pipe_SDK) DeepCopy() *Pipe_SDK

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Pipe_SDK.

func (*Pipe_SDK) DeepCopyInto 

func (in *Pipe_SDK) DeepCopyInto(out *Pipe_SDK)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PlacementConstraint 

type PlacementConstraint struct {
	Expression *string `json:"expression,omitempty"`
	Type       *string `json:"type_,omitempty"`
}

An object representing a constraint on task placement. To learn more, see Task Placement Constraints (https://docs.aws.amazon.com/AmazonECS/latest/developerguide/task-placement-constraints.html) in the Amazon Elastic Container Service Developer Guide.

func (*PlacementConstraint) DeepCopy 

func (in *PlacementConstraint) DeepCopy() *PlacementConstraint

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PlacementConstraint.

func (*PlacementConstraint) DeepCopyInto 

func (in *PlacementConstraint) DeepCopyInto(out *PlacementConstraint)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PlacementConstraintType 

type PlacementConstraintType string
const (
	PlacementConstraintType_distinctInstance PlacementConstraintType = "distinctInstance"
	PlacementConstraintType_memberOf         PlacementConstraintType = "memberOf"
)

type PlacementStrategy 

type PlacementStrategy struct {
	Field *string `json:"field,omitempty"`
	Type  *string `json:"type_,omitempty"`
}

The task placement strategy for a task or service. To learn more, see Task Placement Strategies (https://docs.aws.amazon.com/AmazonECS/latest/developerguide/task-placement-strategies.html) in the Amazon Elastic Container Service Service Developer Guide.

func (*PlacementStrategy) DeepCopy 

func (in *PlacementStrategy) DeepCopy() *PlacementStrategy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PlacementStrategy.

func (*PlacementStrategy) DeepCopyInto 

func (in *PlacementStrategy) DeepCopyInto(out *PlacementStrategy)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PlacementStrategyType 

type PlacementStrategyType string
const (
	PlacementStrategyType_random  PlacementStrategyType = "random"
	PlacementStrategyType_spread  PlacementStrategyType = "spread"
	PlacementStrategyType_binpack PlacementStrategyType = "binpack"
)

type PropagateTags 

type PropagateTags string
const (
	PropagateTags_TASK_DEFINITION PropagateTags = "TASK_DEFINITION"
)

type RequestedPipeState 

type RequestedPipeState string
const (
	RequestedPipeState_RUNNING RequestedPipeState = "RUNNING"
	RequestedPipeState_STOPPED RequestedPipeState = "STOPPED"
)

type RequestedPipeStateDescribeResponse 

type RequestedPipeStateDescribeResponse string
const (
	RequestedPipeStateDescribeResponse_RUNNING RequestedPipeStateDescribeResponse = "RUNNING"
	RequestedPipeStateDescribeResponse_STOPPED RequestedPipeStateDescribeResponse = "STOPPED"
	RequestedPipeStateDescribeResponse_DELETED RequestedPipeStateDescribeResponse = "DELETED"
)

type S3LogDestination added in v1.0.15 

type S3LogDestination struct {
	BucketName   *string `json:"bucketName,omitempty"`
	BucketOwner  *string `json:"bucketOwner,omitempty"`
	OutputFormat *string `json:"outputFormat,omitempty"`
	Prefix       *string `json:"prefix,omitempty"`
}

The Amazon S3 logging configuration settings for the pipe.

func (*S3LogDestination) DeepCopy added in v1.0.15 

func (in *S3LogDestination) DeepCopy() *S3LogDestination

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new S3LogDestination.

func (*S3LogDestination) DeepCopyInto added in v1.0.15 

func (in *S3LogDestination) DeepCopyInto(out *S3LogDestination)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type S3LogDestinationParameters added in v1.0.15 

type S3LogDestinationParameters struct {
	BucketName   *string `json:"bucketName,omitempty"`
	BucketOwner  *string `json:"bucketOwner,omitempty"`
	OutputFormat *string `json:"outputFormat,omitempty"`
	Prefix       *string `json:"prefix,omitempty"`
}

The Amazon S3 logging configuration settings for the pipe.

func (*S3LogDestinationParameters) DeepCopy added in v1.0.15 

func (in *S3LogDestinationParameters) DeepCopy() *S3LogDestinationParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new S3LogDestinationParameters.

func (*S3LogDestinationParameters) DeepCopyInto added in v1.0.15 

func (in *S3LogDestinationParameters) DeepCopyInto(out *S3LogDestinationParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type S3OutputFormat added in v1.0.15 

type S3OutputFormat string
const (
	S3OutputFormat_json  S3OutputFormat = "json"
	S3OutputFormat_plain S3OutputFormat = "plain"
	S3OutputFormat_w3c   S3OutputFormat = "w3c"
)

type SageMakerPipelineParameter 

type SageMakerPipelineParameter struct {
	Name  *string `json:"name,omitempty"`
	Value *string `json:"value,omitempty"`
}

Name/Value pair of a parameter to start execution of a SageMaker Model Building Pipeline.

func (*SageMakerPipelineParameter) DeepCopy 

func (in *SageMakerPipelineParameter) DeepCopy() *SageMakerPipelineParameter

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SageMakerPipelineParameter.

func (*SageMakerPipelineParameter) DeepCopyInto 

func (in *SageMakerPipelineParameter) DeepCopyInto(out *SageMakerPipelineParameter)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SelfManagedKafkaAccessConfigurationCredentials 

type SelfManagedKafkaAccessConfigurationCredentials struct {
	// // Optional SecretManager ARN which stores the database credentials
	BasicAuth *string `json:"basicAuth,omitempty"`
	// // Optional SecretManager ARN which stores the database credentials
	ClientCertificateTLSAuth *string `json:"clientCertificateTLSAuth,omitempty"`
	// // Optional SecretManager ARN which stores the database credentials
	SASLSCRAM256Auth *string `json:"saslSCRAM256Auth,omitempty"`
	// // Optional SecretManager ARN which stores the database credentials
	SASLSCRAM512Auth *string `json:"saslSCRAM512Auth,omitempty"`
}

The Secrets Manager secret that stores your stream credentials.

func (*SelfManagedKafkaAccessConfigurationCredentials) DeepCopy 

func (in *SelfManagedKafkaAccessConfigurationCredentials) DeepCopy() *SelfManagedKafkaAccessConfigurationCredentials

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SelfManagedKafkaAccessConfigurationCredentials.

func (*SelfManagedKafkaAccessConfigurationCredentials) DeepCopyInto 

func (in *SelfManagedKafkaAccessConfigurationCredentials) DeepCopyInto(out *SelfManagedKafkaAccessConfigurationCredentials)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SelfManagedKafkaAccessConfigurationVPC 

type SelfManagedKafkaAccessConfigurationVPC struct {
	// List of SecurityGroupId.
	SecurityGroup []*string `json:"securityGroup,omitempty"`
	// List of SubnetId.
	Subnets []*string `json:"subnets,omitempty"`
}

This structure specifies the VPC subnets and security groups for the stream, and whether a public IP address is to be used.

func (*SelfManagedKafkaAccessConfigurationVPC) DeepCopy 

func (in *SelfManagedKafkaAccessConfigurationVPC) DeepCopy() *SelfManagedKafkaAccessConfigurationVPC

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SelfManagedKafkaAccessConfigurationVPC.

func (*SelfManagedKafkaAccessConfigurationVPC) DeepCopyInto 

func (in *SelfManagedKafkaAccessConfigurationVPC) DeepCopyInto(out *SelfManagedKafkaAccessConfigurationVPC)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SelfManagedKafkaStartPosition 

type SelfManagedKafkaStartPosition string
const (
	SelfManagedKafkaStartPosition_TRIM_HORIZON SelfManagedKafkaStartPosition = "TRIM_HORIZON"
	SelfManagedKafkaStartPosition_LATEST       SelfManagedKafkaStartPosition = "LATEST"
)

type Tag 

type Tag struct {
	Key   *string `json:"key,omitempty"`
	Value *string `json:"value,omitempty"`
}

A key-value pair associated with an Amazon Web Services resource. In EventBridge, rules and event buses support tagging.

func (*Tag) DeepCopy 

func (in *Tag) DeepCopy() *Tag

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Tag.

func (*Tag) DeepCopyInto 

func (in *Tag) DeepCopyInto(out *Tag)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type TimeFieldType added in v1.0.15 

type TimeFieldType string
const (
	TimeFieldType_EPOCH            TimeFieldType = "EPOCH"
	TimeFieldType_TIMESTAMP_FORMAT TimeFieldType = "TIMESTAMP_FORMAT"
)

type UpdatePipeSourceActiveMQBrokerParameters 

type UpdatePipeSourceActiveMQBrokerParameters struct {
	BatchSize *int64 `json:"batchSize,omitempty"`
	// The Secrets Manager secret that stores your broker credentials.
	Credentials                    *MQBrokerAccessCredentials `json:"credentials,omitempty"`
	MaximumBatchingWindowInSeconds *int64                     `json:"maximumBatchingWindowInSeconds,omitempty"`
}

The parameters for using an Active MQ broker as a source.

func (*UpdatePipeSourceActiveMQBrokerParameters) DeepCopy 

func (in *UpdatePipeSourceActiveMQBrokerParameters) DeepCopy() *UpdatePipeSourceActiveMQBrokerParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UpdatePipeSourceActiveMQBrokerParameters.

func (*UpdatePipeSourceActiveMQBrokerParameters) DeepCopyInto 

func (in *UpdatePipeSourceActiveMQBrokerParameters) DeepCopyInto(out *UpdatePipeSourceActiveMQBrokerParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type UpdatePipeSourceDynamoDBStreamParameters 

type UpdatePipeSourceDynamoDBStreamParameters struct {
	BatchSize *int64 `json:"batchSize,omitempty"`
	// A DeadLetterConfig object that contains information about a dead-letter queue
	// configuration.
	DeadLetterConfig               *DeadLetterConfig `json:"deadLetterConfig,omitempty"`
	MaximumBatchingWindowInSeconds *int64            `json:"maximumBatchingWindowInSeconds,omitempty"`
	MaximumRecordAgeInSeconds      *int64            `json:"maximumRecordAgeInSeconds,omitempty"`
	MaximumRetryAttempts           *int64            `json:"maximumRetryAttempts,omitempty"`
	OnPartialBatchItemFailure      *string           `json:"onPartialBatchItemFailure,omitempty"`
	ParallelizationFactor          *int64            `json:"parallelizationFactor,omitempty"`
}

The parameters for using a DynamoDB stream as a source.

func (*UpdatePipeSourceDynamoDBStreamParameters) DeepCopy 

func (in *UpdatePipeSourceDynamoDBStreamParameters) DeepCopy() *UpdatePipeSourceDynamoDBStreamParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UpdatePipeSourceDynamoDBStreamParameters.

func (*UpdatePipeSourceDynamoDBStreamParameters) DeepCopyInto 

func (in *UpdatePipeSourceDynamoDBStreamParameters) DeepCopyInto(out *UpdatePipeSourceDynamoDBStreamParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type UpdatePipeSourceKinesisStreamParameters 

type UpdatePipeSourceKinesisStreamParameters struct {
	BatchSize *int64 `json:"batchSize,omitempty"`
	// A DeadLetterConfig object that contains information about a dead-letter queue
	// configuration.
	DeadLetterConfig               *DeadLetterConfig `json:"deadLetterConfig,omitempty"`
	MaximumBatchingWindowInSeconds *int64            `json:"maximumBatchingWindowInSeconds,omitempty"`
	MaximumRecordAgeInSeconds      *int64            `json:"maximumRecordAgeInSeconds,omitempty"`
	MaximumRetryAttempts           *int64            `json:"maximumRetryAttempts,omitempty"`
	OnPartialBatchItemFailure      *string           `json:"onPartialBatchItemFailure,omitempty"`
	ParallelizationFactor          *int64            `json:"parallelizationFactor,omitempty"`
}

The parameters for using a Kinesis stream as a source.

func (*UpdatePipeSourceKinesisStreamParameters) DeepCopy 

func (in *UpdatePipeSourceKinesisStreamParameters) DeepCopy() *UpdatePipeSourceKinesisStreamParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UpdatePipeSourceKinesisStreamParameters.

func (*UpdatePipeSourceKinesisStreamParameters) DeepCopyInto 

func (in *UpdatePipeSourceKinesisStreamParameters) DeepCopyInto(out *UpdatePipeSourceKinesisStreamParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type UpdatePipeSourceManagedStreamingKafkaParameters 

type UpdatePipeSourceManagedStreamingKafkaParameters struct {
	BatchSize *int64 `json:"batchSize,omitempty"`
	// The Secrets Manager secret that stores your stream credentials.
	Credentials                    *MSKAccessCredentials `json:"credentials,omitempty"`
	MaximumBatchingWindowInSeconds *int64                `json:"maximumBatchingWindowInSeconds,omitempty"`
}

The parameters for using an MSK stream as a source.

func (*UpdatePipeSourceManagedStreamingKafkaParameters) DeepCopy 

func (in *UpdatePipeSourceManagedStreamingKafkaParameters) DeepCopy() *UpdatePipeSourceManagedStreamingKafkaParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UpdatePipeSourceManagedStreamingKafkaParameters.

func (*UpdatePipeSourceManagedStreamingKafkaParameters) DeepCopyInto 

func (in *UpdatePipeSourceManagedStreamingKafkaParameters) DeepCopyInto(out *UpdatePipeSourceManagedStreamingKafkaParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type UpdatePipeSourceParameters 

type UpdatePipeSourceParameters struct {
	// The parameters for using an Active MQ broker as a source.
	ActiveMQBrokerParameters *UpdatePipeSourceActiveMQBrokerParameters `json:"activeMQBrokerParameters,omitempty"`
	// The parameters for using a DynamoDB stream as a source.
	DynamoDBStreamParameters *UpdatePipeSourceDynamoDBStreamParameters `json:"dynamoDBStreamParameters,omitempty"`
	// The collection of event patterns used to filter events.
	//
	// To remove a filter, specify a FilterCriteria object with an empty array of
	// Filter objects.
	//
	// For more information, see Events and Event Patterns (https://docs.aws.amazon.com/eventbridge/latest/userguide/eventbridge-and-event-patterns.html)
	// in the Amazon EventBridge User Guide.
	FilterCriteria *FilterCriteria `json:"filterCriteria,omitempty"`
	// The parameters for using a Kinesis stream as a source.
	KinesisStreamParameters *UpdatePipeSourceKinesisStreamParameters `json:"kinesisStreamParameters,omitempty"`
	// The parameters for using an MSK stream as a source.
	ManagedStreamingKafkaParameters *UpdatePipeSourceManagedStreamingKafkaParameters `json:"managedStreamingKafkaParameters,omitempty"`
	// The parameters for using a Rabbit MQ broker as a source.
	RabbitMQBrokerParameters *UpdatePipeSourceRabbitMQBrokerParameters `json:"rabbitMQBrokerParameters,omitempty"`
	// The parameters for using a self-managed Apache Kafka stream as a source.
	//
	// A self managed cluster refers to any Apache Kafka cluster not hosted by Amazon
	// Web Services. This includes both clusters you manage yourself, as well as
	// those hosted by a third-party provider, such as Confluent Cloud (https://www.confluent.io/),
	// CloudKarafka (https://www.cloudkarafka.com/), or Redpanda (https://redpanda.com/).
	// For more information, see Apache Kafka streams as a source (https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes-kafka.html)
	// in the Amazon EventBridge User Guide.
	SelfManagedKafkaParameters *UpdatePipeSourceSelfManagedKafkaParameters `json:"selfManagedKafkaParameters,omitempty"`
	// The parameters for using a Amazon SQS stream as a source.
	SQSQueueParameters *UpdatePipeSourceSQSQueueParameters `json:"sqsQueueParameters,omitempty"`
}

The parameters required to set up a source for your pipe.

func (*UpdatePipeSourceParameters) DeepCopy 

func (in *UpdatePipeSourceParameters) DeepCopy() *UpdatePipeSourceParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UpdatePipeSourceParameters.

func (*UpdatePipeSourceParameters) DeepCopyInto 

func (in *UpdatePipeSourceParameters) DeepCopyInto(out *UpdatePipeSourceParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type UpdatePipeSourceRabbitMQBrokerParameters 

type UpdatePipeSourceRabbitMQBrokerParameters struct {
	BatchSize *int64 `json:"batchSize,omitempty"`
	// The Secrets Manager secret that stores your broker credentials.
	Credentials                    *MQBrokerAccessCredentials `json:"credentials,omitempty"`
	MaximumBatchingWindowInSeconds *int64                     `json:"maximumBatchingWindowInSeconds,omitempty"`
}

The parameters for using a Rabbit MQ broker as a source.

func (*UpdatePipeSourceRabbitMQBrokerParameters) DeepCopy 

func (in *UpdatePipeSourceRabbitMQBrokerParameters) DeepCopy() *UpdatePipeSourceRabbitMQBrokerParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UpdatePipeSourceRabbitMQBrokerParameters.

func (*UpdatePipeSourceRabbitMQBrokerParameters) DeepCopyInto 

func (in *UpdatePipeSourceRabbitMQBrokerParameters) DeepCopyInto(out *UpdatePipeSourceRabbitMQBrokerParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type UpdatePipeSourceSQSQueueParameters 

type UpdatePipeSourceSQSQueueParameters struct {
	BatchSize                      *int64 `json:"batchSize,omitempty"`
	MaximumBatchingWindowInSeconds *int64 `json:"maximumBatchingWindowInSeconds,omitempty"`
}

The parameters for using a Amazon SQS stream as a source.

func (*UpdatePipeSourceSQSQueueParameters) DeepCopy 

func (in *UpdatePipeSourceSQSQueueParameters) DeepCopy() *UpdatePipeSourceSQSQueueParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UpdatePipeSourceSQSQueueParameters.

func (*UpdatePipeSourceSQSQueueParameters) DeepCopyInto 

func (in *UpdatePipeSourceSQSQueueParameters) DeepCopyInto(out *UpdatePipeSourceSQSQueueParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type UpdatePipeSourceSelfManagedKafkaParameters 

type UpdatePipeSourceSelfManagedKafkaParameters struct {
	BatchSize *int64 `json:"batchSize,omitempty"`
	// The Secrets Manager secret that stores your stream credentials.
	Credentials                    *SelfManagedKafkaAccessConfigurationCredentials `json:"credentials,omitempty"`
	MaximumBatchingWindowInSeconds *int64                                          `json:"maximumBatchingWindowInSeconds,omitempty"`
	// // Optional SecretManager ARN which stores the database credentials
	ServerRootCaCertificate *string `json:"serverRootCaCertificate,omitempty"`
	// This structure specifies the VPC subnets and security groups for the stream,
	// and whether a public IP address is to be used.
	VPC *SelfManagedKafkaAccessConfigurationVPC `json:"vpc,omitempty"`
}

The parameters for using a self-managed Apache Kafka stream as a source.

A self managed cluster refers to any Apache Kafka cluster not hosted by Amazon Web Services. This includes both clusters you manage yourself, as well as those hosted by a third-party provider, such as Confluent Cloud (https://www.confluent.io/), CloudKarafka (https://www.cloudkarafka.com/), or Redpanda (https://redpanda.com/). For more information, see Apache Kafka streams as a source (https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes-kafka.html) in the Amazon EventBridge User Guide.

func (*UpdatePipeSourceSelfManagedKafkaParameters) DeepCopy 

func (in *UpdatePipeSourceSelfManagedKafkaParameters) DeepCopy() *UpdatePipeSourceSelfManagedKafkaParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UpdatePipeSourceSelfManagedKafkaParameters.

func (*UpdatePipeSourceSelfManagedKafkaParameters) DeepCopyInto 

func (in *UpdatePipeSourceSelfManagedKafkaParameters) DeepCopyInto(out *UpdatePipeSourceSelfManagedKafkaParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ValidationExceptionField 

type ValidationExceptionField struct {
	Name *string `json:"name,omitempty"`
}

Indicates that an error has occurred while performing a validate operation.

func (*ValidationExceptionField) DeepCopy 

func (in *ValidationExceptionField) DeepCopy() *ValidationExceptionField

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ValidationExceptionField.

func (*ValidationExceptionField) DeepCopyInto 

func (in *ValidationExceptionField) DeepCopyInto(out *ValidationExceptionField)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

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.