eventbridge

package

Go to main page

Versions in this module

v1

v1.3.0

Aug 3, 2026

v1.2.0

Aug 3, 2026

Changes in this version

+ var ErrManagedRule = errors.New("ManagedRuleException")

type EventBus

+ LastModifiedTime time.Time

+ Policy string

type EventEntry

+ func (e *EventEntry) UnmarshalJSON(data []byte) error

type InMemoryBackend

+ func (b *InMemoryBackend) NotifyParameterPolicyAction(ctx context.Context, parameterName, policyType string) error

type Replay

+ Description string

+ Destination *ReplayDestination

type ReplayDestination

+ FilterArns []string

type StartReplayInput

+ func (in *StartReplayInput) UnmarshalJSON(data []byte) error

v1.1.4

Jul 20, 2026

v1.1.3

Jul 20, 2026

v1.1.2

Jul 20, 2026

v1.1.1

Jul 20, 2026

v1.1.0

Jul 19, 2026

Changes in this version

+ var ErrAlreadyExists = errors.New("ResourceAlreadyExistsException")

+ var ErrCannotDeleteDefaultBus = errors.New("IllegalArgumentException")

+ var ErrEventBusAlreadyExists = errors.New("ResourceAlreadyExistsException")

+ var ErrEventBusNotFound = errors.New("ResourceNotFoundException")

+ var ErrForbiddenOperation = errors.New("ForbiddenException")

+ var ErrInvalidCronExpression = errors.New("invalid cron expression")

+ var ErrInvalidParameter = errors.New("InvalidParameterException")

+ var ErrInvalidRateExpression = errors.New("invalid rate expression")

+ var ErrInvalidRateValue = errors.New("invalid rate value")

+ var ErrInvalidState = errors.New("InvalidStateException")

+ var ErrNilAppContext = errors.New("nil AppContext passed to EventBridge provider Init")

+ var ErrNotFound = errors.New("ResourceNotFoundException")

+ var ErrResourceLimitExceeded = errors.New("ResourceLimitExceededException")

+ var ErrRuleNotFound = errors.New("ResourceNotFoundException")

+ var ErrUnsupportedRateUnit = errors.New("unsupported rate unit")

+ var ErrUnsupportedScheduleExpression = errors.New("unsupported schedule expression")

+ type APIDestination struct

+ APIDestinationArn string

+ APIDestinationState string

+ ConnectionArn string

+ CreationTime time.Time

+ Description string

+ HTTPMethod string

+ InvocationEndpoint string

+ InvocationRateLimitPerSecond int

+ LastModifiedTime time.Time

+ Name string

+ type APIDestinationResolver interface

+ ResolveAPIDestination func(destARN string) (*ResolvedAPIDestination, bool)

+ WaitAPIDestinationRateLimit func(ctx context.Context, destARN string, ratePerSecond int)

+ type AppSyncParameters struct

+ GraphQLOperation string

+ type Archive struct

+ ArchiveArn string

+ ArchiveName string

+ CreationTime time.Time

+ Description string

+ EventCount int64

+ EventPattern string

+ EventSourceArn string

+ RetentionDays int

+ SizeBytes int64

+ State string

+ StateReason string

+ type ArchiveJanitor struct

+ Backend *InMemoryBackend

+ Interval time.Duration

+ func NewArchiveJanitor(backend *InMemoryBackend, interval time.Duration) *ArchiveJanitor

+ func (j *ArchiveJanitor) Run(ctx context.Context)

+ func (j *ArchiveJanitor) SweepOnce(ctx context.Context)

+ type AwsVpcConfiguration struct

+ AssignPublicIP string

+ SecurityGroups []string

+ Subnets []string

+ type BatchArrayProperties struct

+ Size int

+ type BatchParameters struct

+ ArrayProperties *BatchArrayProperties

+ JobDefinition string

+ JobName string

+ type CapacityProviderStrategyItem struct

+ Base int32

+ CapacityProvider string

+ Weight int32

+ type CloudWatchLogsPublisher interface

+ PutLogEvents func(ctx context.Context, logGroupName, logStreamName string, logEvents []any) error

+ type CodeBinding struct

+ CreationDate time.Time

+ Language string

+ LastModified time.Time

+ SchemaVersion string

+ Status string

+ type Connection struct

+ AuthParameters *ConnectionAuthParameters

+ AuthorizationType string

+ ConnectionArn string

+ ConnectionState string

+ CreationTime time.Time

+ Description string

+ LastAuthorizedTime time.Time

+ LastModifiedTime time.Time

+ Name string

+ SecretArn string

+ StateReason string

+ type ConnectionAPIKeyAuthParameters struct

+ APIKeyName string

+ APIKeyValue string

+ type ConnectionAuthParameters struct

+ APIKeyAuthParameters *ConnectionAPIKeyAuthParameters

+ BasicAuthParameters *ConnectionBasicAuthParameters

+ InvocationHTTPParameters *ConnectionHTTPParameters

+ OAuthParameters *ConnectionOAuthParameters

+ type ConnectionBasicAuthParameters struct

+ Password string

+ Username string

+ type ConnectionBodyParameter struct

+ IsValueSecret bool

+ Key string

+ Value string

+ type ConnectionHTTPParameters struct

+ BodyParameters []ConnectionBodyParameter

+ HeaderParameters []ConnectionHeaderParameter

+ QueryStringParameters []ConnectionQueryStringParameter

+ type ConnectionHeaderParameter struct

+ IsValueSecret bool

+ Key string

+ Value string

+ type ConnectionOAuthClientParameters struct

+ ClientID string

+ ClientSecret string

+ type ConnectionOAuthParameters struct

+ AuthorizationEndpoint string

+ ClientParameters *ConnectionOAuthClientParameters

+ HTTPMethod string

+ OAuthHTTPParameters *ConnectionHTTPParameters

+ type ConnectionQueryStringParameter struct

+ IsValueSecret bool

+ Key string

+ Value string

+ type CreateAPIDestinationInput struct

+ ConnectionArn string

+ Description string

+ HTTPMethod string

+ InvocationEndpoint string

+ InvocationRateLimitPerSecond int

+ Name string

+ type CreateArchiveInput struct

+ ArchiveName string

+ Description string

+ EventPattern string

+ EventSourceArn string

+ RetentionDays int

+ type CreateConnectionInput struct

+ AuthParameters *ConnectionAuthParameters

+ AuthorizationType string

+ Description string

+ Name string

+ type CreateEndpointInput struct

+ Description string

+ EventBuses []EndpointEventBus

+ Name string

+ ReplicationConfig *ReplicationConfig

+ RoleArn string

+ RoutingConfig *RoutingConfig

+ type CreatePipeInput struct

+ Description string

+ DesiredState string

+ EnrichmentArn string

+ Name string

+ RoleArn string

+ SourceArn string

+ TargetArn string

+ type CreateRegistryInput struct

+ Description string

+ RegistryName string

+ Tags map[string]string

+ type CreateSchemaInput struct

+ Content string

+ Description string

+ RegistryName string

+ SchemaName string

+ Tags map[string]string

+ Type string

+ type DeadLetterConfig struct

+ Arn string

+ type DeliveryTargets struct

+ APIDestinations APIDestinationResolver

+ CloudWatchLogs CloudWatchLogsPublisher

+ ECS ECSTaskRunner

+ KinesisFirehose KinesisFirehosePublisher

+ KinesisStream KinesisStreamPublisher

+ Lambda LambdaInvoker

+ SNS SNSPublisher

+ SQS SQSSender

+ StepFunctions StepFunctionsExecutor

+ type DescribeCodeBindingInput struct

+ Language string

+ RegistryName string

+ SchemaName string

+ SchemaVersion string

+ type ECSTaskRunner interface

+ RunTask func(ctx context.Context, clusterARN string, payload []byte) error

+ type EcsParameters struct

+ CapacityProviderStrategy []CapacityProviderStrategyItem

+ EnableECSManagedTags bool

+ EnableExecuteCommand bool

+ Group string

+ LaunchType string

+ NetworkConfiguration *NetworkConfiguration

+ PlacementConstraints []PlacementConstraint

+ PlacementStrategy []PlacementStrategy

+ PlatformVersion string

+ PropagateTags string

+ ReferenceID string

+ Tags []EcsTag

+ TaskDefinitionArn string

+ type EcsTag struct

+ Key string

+ Value string

+ type Endpoint struct

+ Arn string

+ CreationTime time.Time

+ Description string

+ EndpointID string

+ EndpointURL string

+ EventBuses []EndpointEventBus

+ LastModifiedTime time.Time

+ Name string

+ ReplicationConfig *ReplicationConfig

+ RoleArn string

+ RoutingConfig *RoutingConfig

+ State string

+ StateReason string

+ type EndpointEventBus struct

+ EventBusArn string

+ type EventBus struct

+ Arn string

+ CreatedTime time.Time

+ Description string

+ Name string

+ type EventBusPolicy struct

+ Statements map[string]*EventBusPolicyStatement

+ type EventBusPolicyStatement struct

+ Action string

+ Effect string

+ Principal any

+ Sid string

+ type EventEntry struct

+ Detail string

+ DetailType string

+ EventBusName string

+ Resources []string

+ Source string

+ Time *time.Time

+ type EventLogEntry struct

+ Detail string

+ DetailType string

+ EventBusName string

+ ID string

+ Source string

+ Time time.Time

+ type EventResultEntry struct

+ ErrorCode string

+ ErrorMessage string

+ EventID string

+ type EventSource struct

+ Arn string

+ CreatedBy string

+ CreationTime time.Time

+ ExpirationTime time.Time

+ Name string

+ State string

+ type FailedEntry struct

+ ErrorCode string

+ ErrorMessage string

+ TargetID string

+ type FailoverConfig struct

+ Primary *Primary

+ Secondary *Secondary

+ type GetDiscoveredSchemaInput struct

+ Events []string

+ Type string

+ type GetEventBusPolicyInput struct

+ EventBusName string

+ type HTTPParameters struct

+ HeaderParameters map[string]string

+ PathParameterValues []string

+ QueryStringParameters map[string]string

+ type Handler struct

+ Backend StorageBackend

+ DefaultRegion string

+ func NewHandler(backend StorageBackend) *Handler

+ func (h *Handler) ChaosOperations() []string

+ func (h *Handler) ChaosRegions() []string

+ func (h *Handler) ChaosServiceName() string

+ func (h *Handler) ExtractOperation(c *echo.Context) string

+ func (h *Handler) ExtractResource(c *echo.Context) string

+ func (h *Handler) GetSupportedOperations() []string

+ func (h *Handler) Handler() echo.HandlerFunc

+ func (h *Handler) MatchPriority() int

+ func (h *Handler) Name() string

+ func (h *Handler) Reset()

+ func (h *Handler) Restore(ctx context.Context, data []byte) error

+ func (h *Handler) RouteMatcher() service.Matcher

+ func (h *Handler) SetArchiveJanitor(j *ArchiveJanitor)

+ func (h *Handler) SetScheduler(s *Scheduler)

+ func (h *Handler) Shutdown(ctx context.Context)

+ func (h *Handler) Snapshot(ctx context.Context) []byte

+ func (h *Handler) StartWorker(ctx context.Context) error

+ type InMemoryBackend struct

+ func NewInMemoryBackend() *InMemoryBackend

+ func NewInMemoryBackendWithConfig(accountID, region string) *InMemoryBackend

+ func NewInMemoryBackendWithContext(svcCtx context.Context, accountID, region string) *InMemoryBackend

+ func (b *InMemoryBackend) ActivateEventSource(ctx context.Context, name string) error

+ func (b *InMemoryBackend) AddAPIDestinationInternal(dst *APIDestination)

+ func (b *InMemoryBackend) AddArchiveInternal(archive *Archive)

+ func (b *InMemoryBackend) AddConnectionInternal(conn *Connection)

+ func (b *InMemoryBackend) AddEndpointInternal(ep *Endpoint)

+ func (b *InMemoryBackend) AddEventSourceInternal(src *EventSource)

+ func (b *InMemoryBackend) AddPartnerSourceInternal(src *PartnerEventSource)

+ func (b *InMemoryBackend) AddReplayInternal(replay *Replay)

+ func (b *InMemoryBackend) CancelReplay(ctx context.Context, replayName string) (*Replay, error)

+ func (b *InMemoryBackend) Close()

+ func (b *InMemoryBackend) CreateAPIDestination(ctx context.Context, input CreateAPIDestinationInput) (*APIDestination, error)

+ func (b *InMemoryBackend) CreateArchive(ctx context.Context, input CreateArchiveInput) (*Archive, error)

+ func (b *InMemoryBackend) CreateConnection(ctx context.Context, input CreateConnectionInput) (*Connection, error)

+ func (b *InMemoryBackend) CreateEndpoint(ctx context.Context, input CreateEndpointInput) (*Endpoint, error)

+ func (b *InMemoryBackend) CreateEventBus(ctx context.Context, name, description string) (*EventBus, error)

+ func (b *InMemoryBackend) CreatePartnerEventSource(ctx context.Context, name, account string) (*PartnerEventSource, error)

+ func (b *InMemoryBackend) CreatePipe(ctx context.Context, input CreatePipeInput) (*Pipe, error)

+ func (b *InMemoryBackend) CreateRegistry(ctx context.Context, input CreateRegistryInput) (*SchemaRegistry, error)

+ func (b *InMemoryBackend) CreateSchema(ctx context.Context, input CreateSchemaInput) (*Schema, error)

+ func (b *InMemoryBackend) DeactivateEventSource(ctx context.Context, name string) error

+ func (b *InMemoryBackend) DeauthorizeConnection(ctx context.Context, name string) (*Connection, error)

+ func (b *InMemoryBackend) DeleteAPIDestination(ctx context.Context, name string) error

+ func (b *InMemoryBackend) DeleteArchive(ctx context.Context, name string) error

+ func (b *InMemoryBackend) DeleteConnection(ctx context.Context, name string) error

+ func (b *InMemoryBackend) DeleteEndpoint(ctx context.Context, name string) error

+ func (b *InMemoryBackend) DeleteEventBus(ctx context.Context, name string) error

+ func (b *InMemoryBackend) DeletePartnerEventSource(ctx context.Context, name string) error

+ func (b *InMemoryBackend) DeletePipe(ctx context.Context, name string) error

+ func (b *InMemoryBackend) DeleteRegistry(ctx context.Context, registryName string) error

+ func (b *InMemoryBackend) DeleteRule(ctx context.Context, name, eventBusName string) error

+ func (b *InMemoryBackend) DeleteSchema(ctx context.Context, registryName, schemaName string) error

+ func (b *InMemoryBackend) DeleteSchemaVersion(ctx context.Context, registryName, schemaName, schemaVersion string) error

+ func (b *InMemoryBackend) DescribeAPIDestination(ctx context.Context, name string) (*APIDestination, error)

+ func (b *InMemoryBackend) DescribeArchive(ctx context.Context, name string) (*Archive, error)

+ func (b *InMemoryBackend) DescribeCodeBinding(ctx context.Context, input DescribeCodeBindingInput) (*CodeBinding, error)

+ func (b *InMemoryBackend) DescribeConnection(ctx context.Context, name string) (*Connection, error)

+ func (b *InMemoryBackend) DescribeEndpoint(ctx context.Context, name string) (*Endpoint, error)

+ func (b *InMemoryBackend) DescribeEventBus(ctx context.Context, name string) (*EventBus, error)

+ func (b *InMemoryBackend) DescribeEventSource(ctx context.Context, name string) (*EventSource, error)

+ func (b *InMemoryBackend) DescribePartnerEventSource(ctx context.Context, name string) (*PartnerEventSource, error)

+ func (b *InMemoryBackend) DescribePipe(ctx context.Context, name string) (*Pipe, error)

+ func (b *InMemoryBackend) DescribeRegistry(ctx context.Context, registryName string) (*SchemaRegistry, error)

+ func (b *InMemoryBackend) DescribeReplay(ctx context.Context, name string) (*Replay, error)

+ func (b *InMemoryBackend) DescribeRule(ctx context.Context, name, eventBusName string) (*Rule, error)

+ func (b *InMemoryBackend) DescribeSchema(ctx context.Context, registryName, schemaName, schemaVersion string) (*Schema, error)

+ func (b *InMemoryBackend) DescribeSchemaVersion(ctx context.Context, registryName, schemaName, schemaVersion string) (*SchemaVersion, error)

+ func (b *InMemoryBackend) DisableRule(ctx context.Context, name, eventBusName string) error

+ func (b *InMemoryBackend) EnableRule(ctx context.Context, name, eventBusName string) error

+ func (b *InMemoryBackend) GetCodeBindingSource(ctx context.Context, registryName, schemaName, language, schemaVersion string) (string, error)

+ func (b *InMemoryBackend) GetDiscoveredSchema(ctx context.Context, input GetDiscoveredSchemaInput) (string, error)

+ func (b *InMemoryBackend) GetEventBusPolicy(ctx context.Context, eventBusName string) (string, error)

+ func (b *InMemoryBackend) GetEventLog(ctx context.Context) []EventLogEntry

+ func (b *InMemoryBackend) ListAPIDestinations(ctx context.Context, namePrefix, nextToken string) ([]APIDestination, string, error)

+ func (b *InMemoryBackend) ListArchives(ctx context.Context, namePrefix, nextToken string) ([]Archive, string, error)

+ func (b *InMemoryBackend) ListCodeBindings(ctx context.Context, input ListCodeBindingsInput) ([]CodeBinding, string, error)

+ func (b *InMemoryBackend) ListConnections(ctx context.Context, namePrefix, nextToken string) ([]Connection, string, error)

+ func (b *InMemoryBackend) ListEndpoints(ctx context.Context, namePrefix, nextToken string) ([]Endpoint, string, error)

+ func (b *InMemoryBackend) ListEventBuses(ctx context.Context, namePrefix, nextToken string, limit int) ([]EventBus, string, error)

+ func (b *InMemoryBackend) ListEventSources(ctx context.Context, namePrefix, nextToken string) ([]EventSource, string, error)

+ func (b *InMemoryBackend) ListPartnerEventSources(ctx context.Context, namePrefix, nextToken string) ([]PartnerEventSource, string, error)

+ func (b *InMemoryBackend) ListPipes(ctx context.Context, namePrefix, nextToken string) ([]Pipe, string, error)

+ func (b *InMemoryBackend) ListRegistries(ctx context.Context, namePrefix, nextToken string) ([]SchemaRegistry, string, error)

+ func (b *InMemoryBackend) ListReplays(ctx context.Context, namePrefix, nextToken string) ([]Replay, string, error)

+ func (b *InMemoryBackend) ListRuleNamesByTarget(ctx context.Context, targetARN, eventBusName, nextToken string) ([]string, string, error)

+ func (b *InMemoryBackend) ListRules(ctx context.Context, eventBusName, namePrefix, nextToken string, limit int) ([]Rule, string, error)

+ func (b *InMemoryBackend) ListSchemaVersions(ctx context.Context, registryName, schemaName, nextToken string) ([]SchemaVersion, string, error)

+ func (b *InMemoryBackend) ListSchemas(ctx context.Context, registryName, namePrefix, nextToken string) ([]Schema, string, error)

+ func (b *InMemoryBackend) ListTargetsByRule(ctx context.Context, ruleName, eventBusName, nextToken string, limit int) ([]Target, string, error)

+ func (b *InMemoryBackend) PutCodeBinding(ctx context.Context, input PutCodeBindingInput) (*CodeBinding, error)

+ func (b *InMemoryBackend) PutEventBusPolicy(ctx context.Context, input PutEventBusPolicyInput) error

+ func (b *InMemoryBackend) PutEvents(ctx context.Context, entries []EventEntry) ([]EventResultEntry, error)

+ func (b *InMemoryBackend) PutPartnerEvents(ctx context.Context, entries []EventEntry) ([]EventResultEntry, error)

+ func (b *InMemoryBackend) PutPermission(ctx context.Context, input PutPermissionInput) error

+ func (b *InMemoryBackend) PutRule(ctx context.Context, input PutRuleInput) (*Rule, error)

+ func (b *InMemoryBackend) PutTargets(ctx context.Context, ruleName, eventBusName string, targets []Target) ([]FailedEntry, error)

+ func (b *InMemoryBackend) RemovePermission(ctx context.Context, input RemovePermissionInput) error

+ func (b *InMemoryBackend) RemoveTargets(ctx context.Context, ruleName, eventBusName string, ids []string) ([]FailedEntry, error)

+ func (b *InMemoryBackend) Reset()

+ func (b *InMemoryBackend) ResolveAPIDestination(destARN string) (*ResolvedAPIDestination, bool)

+ func (b *InMemoryBackend) Restore(ctx context.Context, data []byte) error

+ func (b *InMemoryBackend) SFNPutEvents(ctx context.Context, entries []map[string]any) (int, error)

+ func (b *InMemoryBackend) SearchSchemas(ctx context.Context, registryName, keywords, nextToken string) ([]Schema, string, error)

+ func (b *InMemoryBackend) SetDeliveryTargets(dt *DeliveryTargets)

+ func (b *InMemoryBackend) SetDeliveryTimeout(d time.Duration)

+ func (b *InMemoryBackend) SetShutdownTimeout(d time.Duration)

+ func (b *InMemoryBackend) Snapshot(ctx context.Context) []byte

+ func (b *InMemoryBackend) StartReplay(ctx context.Context, input StartReplayInput) (*Replay, error)

+ func (b *InMemoryBackend) TestEventPattern(ctx context.Context, pattern, event string) (bool, error)

+ func (b *InMemoryBackend) UpdateAPIDestination(ctx context.Context, input UpdateAPIDestinationInput) (*APIDestination, error)

+ func (b *InMemoryBackend) UpdateArchive(ctx context.Context, input UpdateArchiveInput) (*Archive, error)

+ func (b *InMemoryBackend) UpdateConnection(ctx context.Context, input UpdateConnectionInput) (*Connection, error)

+ func (b *InMemoryBackend) UpdateEndpoint(ctx context.Context, input UpdateEndpointInput) (*Endpoint, error)

+ func (b *InMemoryBackend) UpdateEventBus(ctx context.Context, input UpdateEventBusInput) (*EventBus, error)

+ func (b *InMemoryBackend) UpdatePipe(ctx context.Context, input UpdatePipeInput) (*Pipe, error)

+ func (b *InMemoryBackend) UpdateRegistry(ctx context.Context, input UpdateRegistryInput) (*SchemaRegistry, error)

+ func (b *InMemoryBackend) UpdateSchema(ctx context.Context, input UpdateSchemaInput) (*Schema, error)

+ func (b *InMemoryBackend) WaitAPIDestinationRateLimit(ctx context.Context, destARN string, ratePerSecond int)

+ type InputTransformer struct

+ InputPathsMap map[string]string

+ InputTemplate string

+ type KinesisFirehosePublisher interface

+ PutRecord func(ctx context.Context, deliveryStreamARN, data string) error

+ type KinesisParameters struct

+ PartitionKeyPath string

+ type KinesisStreamPublisher interface

+ PutRecord func(ctx context.Context, streamARN, partitionKey, data string) error

+ type LambdaInvoker interface

+ InvokeFunction func(ctx context.Context, name string, invocationType string, payload []byte) ([]byte, int, error)

+ type ListCodeBindingsInput struct

+ NextToken string

+ RegistryName string

+ SchemaName string

+ SchemaVersion string

+ type NetworkConfiguration struct

+ AwsvpcConfiguration *AwsVpcConfiguration

+ type PartnerEventSource struct

+ Account string

+ Arn string

+ Name string

+ type Pipe struct

+ Arn string

+ CreationTime time.Time

+ CurrentState string

+ Description string

+ DesiredState string

+ EnrichmentArn string

+ LastModifiedTime time.Time

+ Name string

+ RoleArn string

+ SourceArn string

+ StateReason string

+ TargetArn string

+ type PlacementConstraint struct

+ Expression string

+ Type string

+ type PlacementStrategy struct

+ Field string

+ Type string

+ type Primary struct

+ HealthCheck string

+ type Provider struct

+ func (p *Provider) Init(ctx *service.AppContext) (service.Registerable, error)

+ func (p *Provider) Name() string

+ type PutCodeBindingInput struct

+ Language string

+ RegistryName string

+ SchemaName string

+ SchemaVersion string

+ type PutEventBusPolicyInput struct

+ EventBusName string

+ Policy string

+ type PutPermissionInput struct

+ Action string

+ EventBusName string

+ Policy string

+ Principal string

+ StatementID string

+ type PutRuleInput struct

+ Description string

+ EventBusName string

+ EventPattern string

+ ManagedBy string

+ Name string

+ RoleArn string

+ ScheduleExpression string

+ State string

+ Tags map[string]string

+ type RedshiftDataParameters struct

+ DBUser string

+ Database string

+ SQL string

+ SecretManagerArn string

+ Sqls []string

+ StatementName string

+ WithEvent bool

+ type RemovePermissionInput struct

+ EventBusName string

+ RemoveAllPermissions bool

+ StatementID string

+ type Replay struct

+ EventEndTime time.Time

+ EventSourceArn string

+ EventStartTime time.Time

+ ReplayArn string

+ ReplayEndTime time.Time

+ ReplayName string

+ ReplayStartTime time.Time

+ State string

+ StateReason string

+ type ReplayDestination struct

+ Arn string

+ type ReplicationConfig struct

+ State string

+ type ResolvedAPIDestination struct

+ APIKeyName string

+ APIKeyValue string

+ AuthType string

+ BasicPassword string

+ BasicUsername string

+ BodyParameters []ConnectionBodyParameter

+ Endpoint string

+ HTTPMethod string

+ HeaderParameters []ConnectionHeaderParameter

+ OAuth *ResolvedOAuth

+ QueryStringParameters []ConnectionQueryStringParameter

+ RateLimitPerSecond int

+ type ResolvedOAuth struct

+ AuthorizationEndpoint string

+ BodyParameters []ConnectionBodyParameter

+ ClientID string

+ ClientSecret string

+ HTTPMethod string

+ HeaderParameters []ConnectionHeaderParameter

+ QueryStringParameters []ConnectionQueryStringParameter

+ type RetryPolicy struct

+ MaximumEventAgeInSeconds int

+ MaximumRetryAttempts int

+ type RoutingConfig struct

+ FailoverConfig *FailoverConfig

+ type Rule struct

+ Arn string

+ Description string

+ EventBusName string

+ EventPattern string

+ ManagedBy string

+ Name string

+ RoleArn string

+ ScheduleExpression string

+ State string

+ type RunCommandParameters struct

+ RunCommandTargets []RunCommandTarget

+ type RunCommandTarget struct

+ Key string

+ Values []string

+ type SNSPublisher interface

+ PublishToTopic func(ctx context.Context, topicARN, message string) error

+ type SQSSender interface

+ SendMessageToQueue func(ctx context.Context, queueARN, messageBody string) error

+ type SageMakerPipelineParameter struct

+ Name string

+ Value string

+ type SageMakerPipelineParameters struct

+ PipelineParameterList []SageMakerPipelineParameter

+ type Scheduler struct

+ func NewScheduler(backend *InMemoryBackend, tickInterval time.Duration) *Scheduler

+ func (s *Scheduler) Run(ctx context.Context)

+ type Schema struct

+ Content string

+ Description string

+ LastModified time.Time

+ RegistryName string

+ SchemaArn string

+ SchemaName string

+ SchemaVersion string

+ Tags map[string]string

+ Type string

+ VersionCreatedDate time.Time

+ type SchemaRegistry struct

+ Description string

+ RegistryArn string

+ RegistryName string

+ Tags map[string]string

+ type SchemaVersion struct

+ Content string

+ CreatedDate time.Time

+ RegistryName string

+ SchemaArn string

+ SchemaName string

+ SchemaVersion string

+ Type string

+ type Secondary struct

+ Route string

+ type SqsParameters struct

+ MessageGroupID string

+ type StartReplayInput struct

+ Description string

+ Destination *ReplayDestination

+ EventEndTime time.Time

+ EventSourceArn string

+ EventStartTime time.Time

+ ReplayName string

+ type StepFunctionsExecutor interface

+ StartExecution func(stateMachineARN, name, input string) error

+ type StorageBackend interface

+ ActivateEventSource func(ctx context.Context, name string) error

+ CancelReplay func(ctx context.Context, replayName string) (*Replay, error)

+ CreateAPIDestination func(ctx context.Context, input CreateAPIDestinationInput) (*APIDestination, error)

+ CreateArchive func(ctx context.Context, input CreateArchiveInput) (*Archive, error)

+ CreateConnection func(ctx context.Context, input CreateConnectionInput) (*Connection, error)

+ CreateEndpoint func(ctx context.Context, input CreateEndpointInput) (*Endpoint, error)

+ CreateEventBus func(ctx context.Context, name, description string) (*EventBus, error)

+ CreatePartnerEventSource func(ctx context.Context, name, account string) (*PartnerEventSource, error)

+ CreatePipe func(ctx context.Context, input CreatePipeInput) (*Pipe, error)

+ CreateRegistry func(ctx context.Context, input CreateRegistryInput) (*SchemaRegistry, error)

+ CreateSchema func(ctx context.Context, input CreateSchemaInput) (*Schema, error)

+ DeactivateEventSource func(ctx context.Context, name string) error

+ DeauthorizeConnection func(ctx context.Context, name string) (*Connection, error)

+ DeleteAPIDestination func(ctx context.Context, name string) error

+ DeleteArchive func(ctx context.Context, name string) error

+ DeleteConnection func(ctx context.Context, name string) error

+ DeleteEndpoint func(ctx context.Context, name string) error

+ DeleteEventBus func(ctx context.Context, name string) error

+ DeletePartnerEventSource func(ctx context.Context, name string) error

+ DeletePipe func(ctx context.Context, name string) error

+ DeleteRegistry func(ctx context.Context, registryName string) error

+ DeleteRule func(ctx context.Context, name, eventBusName string) error

+ DeleteSchema func(ctx context.Context, registryName, schemaName string) error

+ DeleteSchemaVersion func(ctx context.Context, registryName, schemaName, schemaVersion string) error

+ DescribeAPIDestination func(ctx context.Context, name string) (*APIDestination, error)

+ DescribeArchive func(ctx context.Context, name string) (*Archive, error)

+ DescribeCodeBinding func(ctx context.Context, input DescribeCodeBindingInput) (*CodeBinding, error)

+ DescribeConnection func(ctx context.Context, name string) (*Connection, error)

+ DescribeEndpoint func(ctx context.Context, name string) (*Endpoint, error)

+ DescribeEventBus func(ctx context.Context, name string) (*EventBus, error)

+ DescribeEventSource func(ctx context.Context, name string) (*EventSource, error)

+ DescribePartnerEventSource func(ctx context.Context, name string) (*PartnerEventSource, error)

+ DescribePipe func(ctx context.Context, name string) (*Pipe, error)

+ DescribeRegistry func(ctx context.Context, registryName string) (*SchemaRegistry, error)

+ DescribeReplay func(ctx context.Context, name string) (*Replay, error)

+ DescribeRule func(ctx context.Context, name, eventBusName string) (*Rule, error)

+ DescribeSchema func(ctx context.Context, registryName, schemaName, schemaVersion string) (*Schema, error)

+ DescribeSchemaVersion func(ctx context.Context, registryName, schemaName, schemaVersion string) (*SchemaVersion, error)

+ DisableRule func(ctx context.Context, name, eventBusName string) error

+ EnableRule func(ctx context.Context, name, eventBusName string) error

+ GetCodeBindingSource func(ctx context.Context, registryName, schemaName, language, schemaVersion string) (string, error)

+ GetDiscoveredSchema func(ctx context.Context, input GetDiscoveredSchemaInput) (string, error)

+ GetEventBusPolicy func(ctx context.Context, eventBusName string) (string, error)

+ GetEventLog func(ctx context.Context) []EventLogEntry

+ ListAPIDestinations func(ctx context.Context, namePrefix, nextToken string) ([]APIDestination, string, error)

+ ListArchives func(ctx context.Context, namePrefix, nextToken string) ([]Archive, string, error)

+ ListCodeBindings func(ctx context.Context, input ListCodeBindingsInput) ([]CodeBinding, string, error)

+ ListConnections func(ctx context.Context, namePrefix, nextToken string) ([]Connection, string, error)

+ ListEndpoints func(ctx context.Context, namePrefix, nextToken string) ([]Endpoint, string, error)

+ ListEventBuses func(ctx context.Context, namePrefix, nextToken string, limit int) ([]EventBus, string, error)

+ ListEventSources func(ctx context.Context, namePrefix, nextToken string) ([]EventSource, string, error)

+ ListPartnerEventSources func(ctx context.Context, namePrefix, nextToken string) ([]PartnerEventSource, string, error)

+ ListPipes func(ctx context.Context, namePrefix, nextToken string) ([]Pipe, string, error)

+ ListRegistries func(ctx context.Context, namePrefix, nextToken string) ([]SchemaRegistry, string, error)

+ ListReplays func(ctx context.Context, namePrefix, nextToken string) ([]Replay, string, error)

+ ListRuleNamesByTarget func(ctx context.Context, targetARN, eventBusName, nextToken string) ([]string, string, error)

+ ListRules func(ctx context.Context, eventBusName, namePrefix, nextToken string, limit int) ([]Rule, string, error)

+ ListSchemaVersions func(ctx context.Context, registryName, schemaName, nextToken string) ([]SchemaVersion, string, error)

+ ListSchemas func(ctx context.Context, registryName, namePrefix, nextToken string) ([]Schema, string, error)

+ ListTargetsByRule func(ctx context.Context, ruleName, eventBusName, nextToken string, limit int) ([]Target, string, error)

+ PutCodeBinding func(ctx context.Context, input PutCodeBindingInput) (*CodeBinding, error)

+ PutEventBusPolicy func(ctx context.Context, input PutEventBusPolicyInput) error

+ PutEvents func(ctx context.Context, entries []EventEntry) ([]EventResultEntry, error)

+ PutPartnerEvents func(ctx context.Context, entries []EventEntry) ([]EventResultEntry, error)

+ PutPermission func(ctx context.Context, input PutPermissionInput) error

+ PutRule func(ctx context.Context, input PutRuleInput) (*Rule, error)

+ PutTargets func(ctx context.Context, ruleName, eventBusName string, targets []Target) ([]FailedEntry, error)

+ RemovePermission func(ctx context.Context, input RemovePermissionInput) error

+ RemoveTargets func(ctx context.Context, ruleName, eventBusName string, ids []string) ([]FailedEntry, error)

+ SearchSchemas func(ctx context.Context, registryName, keywords, nextToken string) ([]Schema, string, error)

+ StartReplay func(ctx context.Context, input StartReplayInput) (*Replay, error)

+ TestEventPattern func(ctx context.Context, pattern, event string) (bool, error)

+ UpdateAPIDestination func(ctx context.Context, input UpdateAPIDestinationInput) (*APIDestination, error)

+ UpdateArchive func(ctx context.Context, input UpdateArchiveInput) (*Archive, error)

+ UpdateConnection func(ctx context.Context, input UpdateConnectionInput) (*Connection, error)

+ UpdateEndpoint func(ctx context.Context, input UpdateEndpointInput) (*Endpoint, error)

+ UpdateEventBus func(ctx context.Context, input UpdateEventBusInput) (*EventBus, error)

+ UpdatePipe func(ctx context.Context, input UpdatePipeInput) (*Pipe, error)

+ UpdateRegistry func(ctx context.Context, input UpdateRegistryInput) (*SchemaRegistry, error)

+ UpdateSchema func(ctx context.Context, input UpdateSchemaInput) (*Schema, error)

+ type Target struct

+ AppSyncParameters *AppSyncParameters

+ Arn string

+ BatchParameters *BatchParameters

+ DeadLetterConfig *DeadLetterConfig

+ EcsParameters *EcsParameters

+ HTTPParameters *HTTPParameters

+ ID string

+ Input string

+ InputPath string

+ InputTransformer *InputTransformer

+ KinesisParameters *KinesisParameters

+ RedshiftDataParameters *RedshiftDataParameters

+ RetryPolicy *RetryPolicy

+ RoleArn string

+ RunCommandParameters *RunCommandParameters

+ SageMakerPipelineParameters *SageMakerPipelineParameters

+ SqsParameters *SqsParameters

+ type UpdateAPIDestinationInput struct

+ ConnectionArn string

+ Description string

+ HTTPMethod string

+ InvocationEndpoint string

+ InvocationRateLimitPerSecond int

+ Name string

+ type UpdateArchiveInput struct

+ ArchiveName string

+ Description string

+ EventPattern string

+ RetentionDays int

+ type UpdateConnectionInput struct

+ AuthParameters *ConnectionAuthParameters

+ AuthorizationType string

+ Description string

+ Name string

+ type UpdateEndpointInput struct

+ Description string

+ EventBuses []EndpointEventBus

+ Name string

+ ReplicationConfig *ReplicationConfig

+ RoleArn string

+ RoutingConfig *RoutingConfig

+ type UpdateEventBusInput struct

+ Description string

+ Name string

+ type UpdatePipeInput struct

+ Description string

+ DesiredState string

+ EnrichmentArn string

+ Name string

+ RoleArn string

+ TargetArn string

+ type UpdateRegistryInput struct

+ Description string

+ RegistryName string

+ type UpdateSchemaInput struct

+ ClientTokenID string

+ Content string

+ Description string

+ RegistryName string

+ SchemaName string

+ Type string

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