eventbridge

package

Go to main page

Versions in this module

v1

v1.5.0

Aug 24, 2026

v1.4.0

Aug 19, 2026

v1.3.5

Aug 19, 2026

v1.3.4

Aug 18, 2026

v1.3.3

Aug 17, 2026

v1.3.2

Aug 16, 2026

v1.3.1

Aug 16, 2026

Changes in this version

type Archive

+ KmsKeyIdentifier string

type BatchParameters

+ RetryStrategy *BatchRetryStrategy

+ type BatchRetryStrategy struct

+ Attempts int32

type CreateArchiveInput

+ KmsKeyIdentifier string

+ type CreateEventBusParams struct

+ DeadLetterConfig *DeadLetterConfig

+ Description string

+ KmsKeyIdentifier string

+ LogConfig *LogConfig

+ Name string

+ type ECSTaskRunnerWithParams interface

+ RunTaskWithParams func(ctx context.Context, clusterARN string, params *EcsParameters, payload []byte) error

type EcsParameters

+ TaskCount int32

type EventBus

+ DeadLetterConfig *DeadLetterConfig

+ KmsKeyIdentifier string

+ LogConfig *LogConfig

type InMemoryBackend

+ func (b *InMemoryBackend) ListPartnerEventSourceAccounts(ctx context.Context, eventSourceName string) ([]PartnerEventSourceAccountInfo, error)

+ type LogConfig struct

+ IncludeDetail string

+ Level string

+ type PartnerEventSourceAccountInfo struct

+ Account string

+ CreationTime time.Time

+ ExpirationTime time.Time

+ State string

type StorageBackend

+ ListPartnerEventSourceAccounts func(ctx context.Context, eventSourceName string) ([]PartnerEventSourceAccountInfo, error)

type UpdateArchiveInput

+ KmsKeyIdentifier string

type UpdateEventBusInput

+ DeadLetterConfig *DeadLetterConfig

+ KmsKeyIdentifier string

+ LogConfig *LogConfig

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