Documentation
¶
Overview ¶
Package eventbridgev2 provides the API client, operations, and parameter types for Amazon EventBridgeV2.
Amazon EventBridge event bus API. An event bus receives events published by your applications and AWS services, stores them for a configurable retention period, and delivers them to subscribers. A subscriber filters events, optionally transforms them, and invokes a target such as Lambda, SQS, SNS, Kinesis, Step Functions, or an HTTP endpoint. The API manages event buses, subscribers, event sources, resource policies, and tags, and publishes events through PutEvents and PutRawEvents.
Index ¶
- Constants
- Variables
- func NewDefaultEndpointResolver() *internalendpoints.Resolver
- func WithAPIOptions(optFns ...func(*middleware.Stack) error) func(*Options)
- func WithEndpointResolver(v EndpointResolver) func(*Options)deprecated
- func WithEndpointResolverV2(v EndpointResolverV2) func(*Options)
- func WithSigV4SigningName(name string) func(*Options)
- func WithSigV4SigningRegion(region string) func(*Options)
- type AuthResolverParameters
- type AuthSchemeResolver
- type Client
- func (c *Client) CreateEventBus(ctx context.Context, params *CreateEventBusInput, optFns ...func(*Options)) (*CreateEventBusOutput, error)
- func (c *Client) CreateEventSource(ctx context.Context, params *CreateEventSourceInput, optFns ...func(*Options)) (*CreateEventSourceOutput, error)
- func (c *Client) CreateSubscriber(ctx context.Context, params *CreateSubscriberInput, optFns ...func(*Options)) (*CreateSubscriberOutput, error)
- func (c *Client) DeleteEventBus(ctx context.Context, params *DeleteEventBusInput, optFns ...func(*Options)) (*DeleteEventBusOutput, error)
- func (c *Client) DeleteEventSource(ctx context.Context, params *DeleteEventSourceInput, optFns ...func(*Options)) (*DeleteEventSourceOutput, error)
- func (c *Client) DeleteResourcePolicy(ctx context.Context, params *DeleteResourcePolicyInput, ...) (*DeleteResourcePolicyOutput, error)
- func (c *Client) DeleteSubscriber(ctx context.Context, params *DeleteSubscriberInput, optFns ...func(*Options)) (*DeleteSubscriberOutput, error)
- func (c *Client) DescribeEventBus(ctx context.Context, params *DescribeEventBusInput, optFns ...func(*Options)) (*DescribeEventBusOutput, error)
- func (c *Client) DescribeEventSource(ctx context.Context, params *DescribeEventSourceInput, ...) (*DescribeEventSourceOutput, error)
- func (c *Client) DescribeSubscriber(ctx context.Context, params *DescribeSubscriberInput, optFns ...func(*Options)) (*DescribeSubscriberOutput, error)
- func (c *Client) GetResourcePolicy(ctx context.Context, params *GetResourcePolicyInput, optFns ...func(*Options)) (*GetResourcePolicyOutput, error)
- func (c *Client) ListEventBuses(ctx context.Context, params *ListEventBusesInput, optFns ...func(*Options)) (*ListEventBusesOutput, error)
- func (c *Client) ListEventSources(ctx context.Context, params *ListEventSourcesInput, optFns ...func(*Options)) (*ListEventSourcesOutput, error)
- func (c *Client) ListResourcePolicies(ctx context.Context, params *ListResourcePoliciesInput, ...) (*ListResourcePoliciesOutput, error)
- func (c *Client) ListSubscribers(ctx context.Context, params *ListSubscribersInput, optFns ...func(*Options)) (*ListSubscribersOutput, error)
- func (c *Client) ListTagsForResource(ctx context.Context, params *ListTagsForResourceInput, ...) (*ListTagsForResourceOutput, error)
- func (c *Client) Options() Options
- func (c *Client) PutEvents(ctx context.Context, params *PutEventsInput, optFns ...func(*Options)) (*PutEventsOutput, error)
- func (c *Client) PutRawEvents(ctx context.Context, params *PutRawEventsInput, optFns ...func(*Options)) (*PutRawEventsOutput, error)
- func (c *Client) PutResourcePolicy(ctx context.Context, params *PutResourcePolicyInput, optFns ...func(*Options)) (*PutResourcePolicyOutput, error)
- func (c *Client) RevokeResource(ctx context.Context, params *RevokeResourceInput, optFns ...func(*Options)) (*RevokeResourceOutput, error)
- func (c *Client) TagResource(ctx context.Context, params *TagResourceInput, optFns ...func(*Options)) (*TagResourceOutput, error)
- func (c *Client) UntagResource(ctx context.Context, params *UntagResourceInput, optFns ...func(*Options)) (*UntagResourceOutput, error)
- func (c *Client) UpdateEventBus(ctx context.Context, params *UpdateEventBusInput, optFns ...func(*Options)) (*UpdateEventBusOutput, error)
- func (c *Client) UpdateEventSource(ctx context.Context, params *UpdateEventSourceInput, optFns ...func(*Options)) (*UpdateEventSourceOutput, error)
- func (c *Client) UpdateSubscriber(ctx context.Context, params *UpdateSubscriberInput, optFns ...func(*Options)) (*UpdateSubscriberOutput, error)
- type CreateEventBusInput
- type CreateEventBusOutput
- type CreateEventSourceInput
- type CreateEventSourceOutput
- type CreateSubscriberInput
- type CreateSubscriberOutput
- type DeleteEventBusInput
- type DeleteEventBusOutput
- type DeleteEventSourceInput
- type DeleteEventSourceOutput
- type DeleteResourcePolicyInput
- type DeleteResourcePolicyOutput
- type DeleteSubscriberInput
- type DeleteSubscriberOutput
- type DescribeEventBusAPIClient
- type DescribeEventBusInput
- type DescribeEventBusOutput
- type DescribeEventSourceInput
- type DescribeEventSourceOutput
- type DescribeSubscriberInput
- type DescribeSubscriberOutput
- type EndpointParameters
- type EndpointResolver
- type EndpointResolverFunc
- type EndpointResolverOptions
- type EndpointResolverV2
- type EventBusActiveWaiter
- type EventBusActiveWaiterOptions
- type EventBusDeletedWaiter
- type EventBusDeletedWaiterOptions
- type GetResourcePolicyInput
- type GetResourcePolicyOutput
- type HTTPClient
- type HTTPSignerV4
- type IdempotencyTokenProvider
- type ListEventBusesAPIClient
- type ListEventBusesInput
- type ListEventBusesOutput
- type ListEventBusesPaginator
- type ListEventBusesPaginatorOptions
- type ListEventSourcesAPIClient
- type ListEventSourcesInput
- type ListEventSourcesOutput
- type ListEventSourcesPaginator
- type ListEventSourcesPaginatorOptions
- type ListResourcePoliciesAPIClient
- type ListResourcePoliciesInput
- type ListResourcePoliciesOutput
- type ListResourcePoliciesPaginator
- type ListResourcePoliciesPaginatorOptions
- type ListSubscribersAPIClient
- type ListSubscribersInput
- type ListSubscribersOutput
- type ListSubscribersPaginator
- type ListSubscribersPaginatorOptions
- type ListTagsForResourceInput
- type ListTagsForResourceOutput
- type Options
- type PutEventsInput
- type PutEventsOutput
- type PutRawEventsInput
- type PutRawEventsOutput
- type PutResourcePolicyInput
- type PutResourcePolicyOutput
- type ResolveEndpoint
- type RevokeResourceInput
- type RevokeResourceOutput
- type TagResourceInput
- type TagResourceOutput
- type UntagResourceInput
- type UntagResourceOutput
- type UpdateEventBusInput
- type UpdateEventBusOutput
- type UpdateEventSourceInput
- type UpdateEventSourceOutput
- type UpdateSubscriberInput
- type UpdateSubscriberOutput
Constants ¶
const ServiceAPIVersion = "2025-05-15"
const ServiceID = "EventBridgeV2"
Variables ¶
var TypeRegistry = &smithy.TypeRegistry{ Entries: map[string]*smithy.TypeRegistryEntry{ "com.amazonaws.eventbridgev2#AccessDeniedException": { Schema: schemas.AccessDeniedException, New: func() any { return &types.AccessDeniedException{} }, }, "com.amazonaws.eventbridgev2#ConcurrentModificationException": { Schema: schemas.ConcurrentModificationException, New: func() any { return &types.ConcurrentModificationException{} }, }, "com.amazonaws.eventbridgev2#ConflictException": { Schema: schemas.ConflictException, New: func() any { return &types.ConflictException{} }, }, "com.amazonaws.eventbridgev2#IdempotentParameterMismatchException": { Schema: schemas.IdempotentParameterMismatchException, New: func() any { return &types.IdempotentParameterMismatchException{} }, }, "com.amazonaws.eventbridgev2#InternalException": { Schema: schemas.InternalException, New: func() any { return &types.InternalException{} }, }, "com.amazonaws.eventbridgev2#InvalidInputException": { Schema: schemas.InvalidInputException, New: func() any { return &types.InvalidInputException{} }, }, "com.amazonaws.eventbridgev2#InvalidStateException": { Schema: schemas.InvalidStateException, New: func() any { return &types.InvalidStateException{} }, }, "com.amazonaws.eventbridgev2#LimitExceededException": { Schema: schemas.LimitExceededException, New: func() any { return &types.LimitExceededException{} }, }, "com.amazonaws.eventbridgev2#PolicyLengthExceededException": { Schema: schemas.PolicyLengthExceededException, New: func() any { return &types.PolicyLengthExceededException{} }, }, "com.amazonaws.eventbridgev2#PublicPolicyException": { Schema: schemas.PublicPolicyException, New: func() any { return &types.PublicPolicyException{} }, }, "com.amazonaws.eventbridgev2#ResourceAlreadyExistsException": { Schema: schemas.ResourceAlreadyExistsException, New: func() any { return &types.ResourceAlreadyExistsException{} }, }, "com.amazonaws.eventbridgev2#ResourceInUseException": { Schema: schemas.ResourceInUseException, New: func() any { return &types.ResourceInUseException{} }, }, "com.amazonaws.eventbridgev2#ResourceNotFoundException": { Schema: schemas.ResourceNotFoundException, New: func() any { return &types.ResourceNotFoundException{} }, }, "com.amazonaws.eventbridgev2#SchemaRegistryUnavailableException": { Schema: schemas.SchemaRegistryUnavailableException, New: func() any { return &types.SchemaRegistryUnavailableException{} }, }, "com.amazonaws.eventbridgev2#ThrottlingException": { Schema: schemas.ThrottlingException, New: func() any { return &types.ThrottlingException{} }, }, }, }
TypeRegistry is the type registry for this service.
Functions ¶
func NewDefaultEndpointResolver ¶
func NewDefaultEndpointResolver() *internalendpoints.Resolver
NewDefaultEndpointResolver constructs a new service endpoint resolver
func WithAPIOptions ¶
func WithAPIOptions(optFns ...func(*middleware.Stack) error) func(*Options)
WithAPIOptions returns a functional option for setting the Client's APIOptions option.
func WithEndpointResolver
deprecated
func WithEndpointResolver(v EndpointResolver) func(*Options)
Deprecated: EndpointResolver and WithEndpointResolver. Providing a value for this field will likely prevent you from using any endpoint-related service features released after the introduction of EndpointResolverV2 and BaseEndpoint.
To migrate an EndpointResolver implementation that uses a custom endpoint, set the client option BaseEndpoint instead.
func WithEndpointResolverV2 ¶
func WithEndpointResolverV2(v EndpointResolverV2) func(*Options)
WithEndpointResolverV2 returns a functional option for setting the Client's EndpointResolverV2 option.
func WithSigV4SigningName ¶
WithSigV4SigningName applies an override to the authentication workflow to use the given signing name for SigV4-authenticated operations.
This is an advanced setting. The value here is FINAL, taking precedence over the resolved signing name from both auth scheme resolution and endpoint resolution.
func WithSigV4SigningRegion ¶
WithSigV4SigningRegion applies an override to the authentication workflow to use the given signing region for SigV4-authenticated operations.
This is an advanced setting. The value here is FINAL, taking precedence over the resolved signing region from both auth scheme resolution and endpoint resolution.
Types ¶
type AuthResolverParameters ¶
type AuthResolverParameters struct {
// The name of the operation being invoked.
Operation string
// The region in which the operation is being invoked.
Region string
}
AuthResolverParameters contains the set of inputs necessary for auth scheme resolution.
type AuthSchemeResolver ¶
type AuthSchemeResolver interface {
ResolveAuthSchemes(context.Context, *AuthResolverParameters) ([]*smithyauth.Option, error)
}
AuthSchemeResolver returns a set of possible authentication options for an operation.
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client provides the API client to make operations call for Amazon EventBridgeV2.
func New ¶
New returns an initialized Client based on the functional options. Provide additional functional options to further configure the behavior of the client, such as changing the client's endpoint or adding custom middleware behavior.
func NewFromConfig ¶
NewFromConfig returns a new client from the provided config.
func (*Client) CreateEventBus ¶
func (c *Client) CreateEventBus(ctx context.Context, params *CreateEventBusInput, optFns ...func(*Options)) (*CreateEventBusOutput, error)
Creates an event bus. Provisioning is asynchronous: the bus is returned in the CREATING state and transitions to ACTIVE when ready (see the EventBusActive waiter). Retries carrying the same ClientToken are idempotent.
func (*Client) CreateEventSource ¶
func (c *Client) CreateEventSource(ctx context.Context, params *CreateEventSourceInput, optFns ...func(*Options)) (*CreateEventSourceOutput, error)
Creates an EventSource, which forwards events from an origin (an AWS service or another account) onto an event bus. The bus must be ACTIVE. Retries carrying the same ClientToken are idempotent.
func (*Client) CreateSubscriber ¶
func (c *Client) CreateSubscriber(ctx context.Context, params *CreateSubscriberInput, optFns ...func(*Options)) (*CreateSubscriberOutput, error)
Creates a subscriber on an event bus, which delivers matching events to the configured target. The bus must be ACTIVE. Retries carrying the same ClientToken are idempotent.
func (*Client) DeleteEventBus ¶
func (c *Client) DeleteEventBus(ctx context.Context, params *DeleteEventBusInput, optFns ...func(*Options)) (*DeleteEventBusOutput, error)
Deletes an event bus. Deletion is asynchronous: the bus moves to DELETING and disappears when complete (see the EventBusDeleted waiter). A bus with subscribers or event sources cannot be deleted.
func (*Client) DeleteEventSource ¶
func (c *Client) DeleteEventSource(ctx context.Context, params *DeleteEventSourceInput, optFns ...func(*Options)) (*DeleteEventSourceOutput, error)
Deletes an EventSource. Forwarding from its origin stops.
func (*Client) DeleteResourcePolicy ¶
func (c *Client) DeleteResourcePolicy(ctx context.Context, params *DeleteResourcePolicyInput, optFns ...func(*Options)) (*DeleteResourcePolicyOutput, error)
Deletes the named resource policy attached to an event bus.
func (*Client) DeleteSubscriber ¶
func (c *Client) DeleteSubscriber(ctx context.Context, params *DeleteSubscriberInput, optFns ...func(*Options)) (*DeleteSubscriberOutput, error)
Deletes a subscriber. Events are no longer delivered to its target.
func (*Client) DescribeEventBus ¶
func (c *Client) DescribeEventBus(ctx context.Context, params *DescribeEventBusInput, optFns ...func(*Options)) (*DescribeEventBusOutput, error)
Returns the full configuration and lifecycle state of an event bus.
func (*Client) DescribeEventSource ¶
func (c *Client) DescribeEventSource(ctx context.Context, params *DescribeEventSourceInput, optFns ...func(*Options)) (*DescribeEventSourceOutput, error)
Returns the full configuration and lifecycle state of an EventSource.
func (*Client) DescribeSubscriber ¶
func (c *Client) DescribeSubscriber(ctx context.Context, params *DescribeSubscriberInput, optFns ...func(*Options)) (*DescribeSubscriberOutput, error)
Returns the full configuration and state of a subscriber.
func (*Client) GetResourcePolicy ¶
func (c *Client) GetResourcePolicy(ctx context.Context, params *GetResourcePolicyInput, optFns ...func(*Options)) (*GetResourcePolicyOutput, error)
Returns the named resource policy attached to an event bus. Fails with ResourceNotFoundException when the event bus or the named policy does not exist.
func (*Client) ListEventBuses ¶
func (c *Client) ListEventBuses(ctx context.Context, params *ListEventBusesInput, optFns ...func(*Options)) (*ListEventBusesOutput, error)
Lists the event buses visible to the caller: buses the account owns and buses shared with it through AWS RAM. Shared entries carry identity fields only (Name, EventBusArn, EventBusAccountId); owned entries carry every summary field. Set EventBusAccountId to scope the list to one owner account.
func (*Client) ListEventSources ¶
func (c *Client) ListEventSources(ctx context.Context, params *ListEventSourcesInput, optFns ...func(*Options)) (*ListEventSourcesOutput, error)
Lists EventSources as summaries. By default the list spans the EventSources the caller account owns; set EventBusArn to scope it to one bus. Use DescribeEventSource to retrieve full configuration.
func (*Client) ListResourcePolicies ¶
func (c *Client) ListResourcePolicies(ctx context.Context, params *ListResourcePoliciesInput, optFns ...func(*Options)) (*ListResourcePoliciesOutput, error)
Lists the resource policies attached to an event bus as summaries (policy name and revision ID). Use GetResourcePolicy to retrieve a policy document.
func (*Client) ListSubscribers ¶
func (c *Client) ListSubscribers(ctx context.Context, params *ListSubscribersInput, optFns ...func(*Options)) (*ListSubscribersOutput, error)
Lists subscribers as summaries. By default the list spans the subscribers the caller account owns across all buses; set EventBusArn to scope it to one bus. Use DescribeSubscriber to retrieve full configuration.
func (*Client) ListTagsForResource ¶
func (c *Client) ListTagsForResource(ctx context.Context, params *ListTagsForResourceInput, optFns ...func(*Options)) (*ListTagsForResourceOutput, error)
Lists the tags on an event bus, subscriber, or event source.
func (*Client) Options ¶
Options returns a copy of the client configuration.
Callers SHOULD NOT perform mutations on any inner structures within client config. Config overrides should instead be made on a per-operation basis through functional options.
func (*Client) PutEvents ¶
func (c *Client) PutEvents(ctx context.Context, params *PutEventsInput, optFns ...func(*Options)) (*PutEventsOutput, error)
Publishes events to an event bus.
func (*Client) PutRawEvents ¶
func (c *Client) PutRawEvents(ctx context.Context, params *PutRawEventsInput, optFns ...func(*Options)) (*PutRawEventsOutput, error)
Publishes pre-shaped events to an event bus.
func (*Client) PutResourcePolicy ¶
func (c *Client) PutResourcePolicy(ctx context.Context, params *PutResourcePolicyInput, optFns ...func(*Options)) (*PutResourcePolicyOutput, error)
Attaches a named resource policy to an event bus — the only resource type that supports policies; other resource ARNs are rejected. Each bus holds two named policies: "default" (customer-managed, full IAM policy language including Deny) and "AWS_RAM" (written exclusively by AWS Resource Access Manager to reflect resource shares). Both policies are evaluated on cross-account authorization; an explicit Deny in either overrides an Allow in the other. Operations that omit PolicyName target "default". A "default" policy that would grant public access is rejected with PublicPolicyException and is not attached; this check is always on and cannot be disabled.
func (*Client) RevokeResource ¶
func (c *Client) RevokeResource(ctx context.Context, params *RevokeResourceInput, optFns ...func(*Options)) (*RevokeResourceOutput, error)
Revokes a subscriber or an EventSource. The bus owner calls this to withdraw a misbehaving resource attached to their bus. Revocation is terminal: there is no operation that clears it. A revoked resource refuses mutating operations with InvalidStateException; delete stays available for cleanup.
func (*Client) TagResource ¶
func (c *Client) TagResource(ctx context.Context, params *TagResourceInput, optFns ...func(*Options)) (*TagResourceOutput, error)
Adds or replaces tags on an event bus, subscriber, or event source.
func (*Client) UntagResource ¶
func (c *Client) UntagResource(ctx context.Context, params *UntagResourceInput, optFns ...func(*Options)) (*UntagResourceOutput, error)
Removes tags from an event bus, subscriber, or event source.
func (*Client) UpdateEventBus ¶
func (c *Client) UpdateEventBus(ctx context.Context, params *UpdateEventBusInput, optFns ...func(*Options)) (*UpdateEventBusOutput, error)
Updates an event bus. The update is asynchronous: the bus moves to UPDATING and returns to ACTIVE when the change is applied. Fields omitted from the request are left unchanged.
func (*Client) UpdateEventSource ¶
func (c *Client) UpdateEventSource(ctx context.Context, params *UpdateEventSourceInput, optFns ...func(*Options)) (*UpdateEventSourceOutput, error)
Updates an EventSource. Fields omitted from the request are left unchanged.
func (*Client) UpdateSubscriber ¶
func (c *Client) UpdateSubscriber(ctx context.Context, params *UpdateSubscriberInput, optFns ...func(*Options)) (*UpdateSubscriberOutput, error)
Updates a subscriber. Fields omitted from the request are left unchanged.
type CreateEventBusInput ¶
type CreateEventBusInput struct {
// Name of an event bus. The first character must be alphanumeric; the remaining
// characters may also include '.', '-', and '_'. The grammar matches the name
// segment of EventBusArn (event-busv2//), so every valid name can be represented
// in the bus's ARN. The same type is used everywhere a bus name appears.
//
// This member is required.
Name *string
// Unique, case-sensitive identifier that ensures the idempotency of the request.
// The SDK generates one automatically when the field is omitted.
ClientToken *string
// Free-text description. Used by every resource type that has one: event buses,
// subscribers, and event sources.
Description *string
// Encryption configuration for an event bus.
EncryptionConfiguration *types.EncryptionConfiguration
// Event storage configuration for an event bus.
StorageConfiguration *types.StorageConfiguration
// Tags attached to a resource, as key-value pairs.
Tags map[string]string
// contains filtered or unexported fields
}
func (*CreateEventBusInput) Serialize ¶
func (v *CreateEventBusInput) Serialize(s smithy.ShapeSerializer)
func (*CreateEventBusInput) SerializeMembers ¶
func (v *CreateEventBusInput) SerializeMembers(s smithy.ShapeSerializer)
type CreateEventBusOutput ¶
type CreateEventBusOutput struct {
// The time the event bus was created.
CreationTime *time.Time
// Free-text description. Used by every resource type that has one: event buses,
// subscribers, and event sources.
Description *string
// Encryption configuration for an event bus.
EncryptionConfiguration *types.EncryptionConfiguration
// The Amazon Resource Name (ARN) that uniquely identifies an event bus.
EventBusArn *string
// Name of an event bus. The first character must be alphanumeric; the remaining
// characters may also include '.', '-', and '_'. The grammar matches the name
// segment of EventBusArn (event-busv2//), so every valid name can be represented
// in the bus's ARN. The same type is used everywhere a bus name appears.
Name *string
// Lifecycle state of an event bus.
//
// - CREATING: Bus creation is in progress.
// - CREATE_FAILED: Bus creation failed; see StateReason. The bus cannot be
// recovered or recreated in place: delete it with DeleteEventBus, then create a
// new bus.
// - ACTIVE: Bus is fully operational and can accept events.
// - UPDATING: Bus update is in progress.
// - UPDATE_FAILED: Bus update failed; the bus remains operational with its
// previous configuration.
// - DELETING: Bus deletion is actively in progress.
// - DELETE_FAILED: Bus deletion failed; see StateReason. Retry DeleteEventBus
// after removing subscribers and event sources.
State types.BusState
// Human-readable explanation of why an event bus is in its current State. Omitted
// when the bus is in a normal operational state (ACTIVE). It stands in for the
// error response an asynchronous failure cannot return, so it applies only to
// resources with an asynchronous lifecycle: event buses. EventSources and
// subscribers are provisioned synchronously and report failures directly on the
// request.
StateReason *string
// Event storage configuration of an event bus, as returned on reads.
StorageConfiguration *types.StorageConfigurationOutput
// Metadata pertaining to the operation's result.
ResultMetadata middleware.Metadata
// contains filtered or unexported fields
}
func (*CreateEventBusOutput) Deserialize ¶
func (v *CreateEventBusOutput) Deserialize(d smithy.ShapeDeserializer) error
func (*CreateEventBusOutput) Serialize ¶
func (v *CreateEventBusOutput) Serialize(s smithy.ShapeSerializer)
func (*CreateEventBusOutput) SerializeMembers ¶
func (v *CreateEventBusOutput) SerializeMembers(s smithy.ShapeSerializer)
type CreateEventSourceInput ¶
type CreateEventSourceInput struct {
// Discriminated EventSource configuration. Exactly one variant must be set.
//
// This member is required.
Configuration types.EventSourceConfiguration
// The Amazon Resource Name (ARN) that uniquely identifies an event bus.
//
// This member is required.
EventBusArn *string
// EventSource name. First character alphanumeric; the rest may add '.', '-', '_'.
// Names may not begin with the reserved "aws." prefix. The grammar matches the ARN
// local-name segment in EventSourceArn (event-sourcev2///), mirroring
// EventBusName, so a name the ARN cannot represent cannot be created.
//
// This member is required.
Name *string
// Unique, case-sensitive identifier that ensures the idempotency of the request.
// The SDK generates one automatically when the field is omitted.
ClientToken *string
// Free-text description. Used by every resource type that has one: event buses,
// subscribers, and event sources.
Description *string
// Tags attached to a resource, as key-value pairs.
Tags map[string]string
// contains filtered or unexported fields
}
func (*CreateEventSourceInput) Serialize ¶
func (v *CreateEventSourceInput) Serialize(s smithy.ShapeSerializer)
func (*CreateEventSourceInput) SerializeMembers ¶
func (v *CreateEventSourceInput) SerializeMembers(s smithy.ShapeSerializer)
type CreateEventSourceOutput ¶
type CreateEventSourceOutput struct {
// The time the EventSource was created.
CreationTime *time.Time
// The Amazon Resource Name (ARN) that uniquely identifies an event bus.
EventBusArn *string
// EventSource ARN: event-sourcev2///. The type segment is set by the service
// (aws.service for AWS service events, aws.partner for partner events) and is not
// part of the resource's name. The id segment is a 25-character identifier
// generated by the service.
EventSourceArn *string
// EventSource name. First character alphanumeric; the rest may add '.', '-', '_'.
// Names may not begin with the reserved "aws." prefix. The grammar matches the ARN
// local-name segment in EventSourceArn (event-sourcev2///), mirroring
// EventBusName, so a name the ARN cannot represent cannot be created.
Name *string
// Lifecycle state of an EventSource. Revocation is reported by the Revoked flag.
State types.EventSourceState
// Metadata pertaining to the operation's result.
ResultMetadata middleware.Metadata
// contains filtered or unexported fields
}
func (*CreateEventSourceOutput) Deserialize ¶
func (v *CreateEventSourceOutput) Deserialize(d smithy.ShapeDeserializer) error
func (*CreateEventSourceOutput) Serialize ¶
func (v *CreateEventSourceOutput) Serialize(s smithy.ShapeSerializer)
func (*CreateEventSourceOutput) SerializeMembers ¶
func (v *CreateEventSourceOutput) SerializeMembers(s smithy.ShapeSerializer)
type CreateSubscriberInput ¶
type CreateSubscriberInput struct {
// The Amazon Resource Name (ARN) that uniquely identifies an event bus.
//
// This member is required.
EventBusArn *string
// Configuration for how the subscriber invokes its target.
//
// This member is required.
InvokeConfiguration *types.InvokeConfiguration
// Name of a subscriber. The first character must be alphanumeric; the remaining
// characters may also include '.', '-', and '_'.
//
// This member is required.
Name *string
// Batching configuration for a subscriber.
BatchConfiguration *types.BatchConfiguration
// Unique, case-sensitive identifier that ensures the idempotency of the request.
// The SDK generates one automatically when the field is omitted.
ClientToken *string
// Free-text description. Used by every resource type that has one: event buses,
// subscribers, and event sources.
Description *string
// Configuration for filtering events delivered to a subscriber. On
// CreateSubscriber, Filters is required and must contain at least one Filter with
// a non-empty Pattern. On UpdateSubscriber, an empty FilterConfiguration:{}
// clears the existing filter. Any non-empty shape (including {Language:X} without
// Filters) must contain a valid Filters list — same contract as CreateSubscriber.
// A non-empty Filters list overwrites; an omitted FilterConfiguration preserves
// existing state. All Filters are implicitly ANDed — an event must match every
// Filter to be delivered.
FilterConfiguration *types.FilterConfiguration
// Log configuration for a subscriber.
LogConfiguration *types.LogConfiguration
// On-failure configuration: where a failed delivery is sent. Shared by the
// subscriber and the EventSource.
OnFailureConfiguration *types.OnFailureConfiguration
// Point-in-time configuration for a subscriber. Only applicable when
// StartingPosition is POINT_IN_TIME.
PointInTimeConfiguration *types.PointInTimeConfiguration
// Retry policy for a subscriber.
RetryPolicy *types.RetryPolicy
// Starting position for a subscriber.
StartingPosition types.StartingPosition
// Customer-controlled run state of a subscriber, set on create or update.
// Distinct from the bus lifecycle vocabulary, where ACTIVE means "provisioned and
// healthy". Delivery requires State RUNNING on a subscriber that is not revoked.
State types.SubscriberState
// Tags attached to a resource, as key-value pairs.
Tags map[string]string
// Not applicable to universal (aws-sdk) targets, whose input transformation is
// UniversalTargetParameters.Input; a Transformer on such a target is rejected.
Transformer *types.Transformer
// Delivery ordering mode of a subscriber: FIFO delivers events in order within an
// event group; UNORDERED delivers without an ordering guarantee.
Type types.OrderingType
// contains filtered or unexported fields
}
func (*CreateSubscriberInput) Serialize ¶
func (v *CreateSubscriberInput) Serialize(s smithy.ShapeSerializer)
func (*CreateSubscriberInput) SerializeMembers ¶
func (v *CreateSubscriberInput) SerializeMembers(s smithy.ShapeSerializer)
type CreateSubscriberOutput ¶
type CreateSubscriberOutput struct {
// The time the subscriber was created.
CreationTime *time.Time
// The Amazon Resource Name (ARN) that uniquely identifies an event bus.
EventBusArn *string
// Name of a subscriber. The first character must be alphanumeric; the remaining
// characters may also include '.', '-', and '_'.
Name *string
// Point-in-time configuration for a subscriber. Only applicable when
// StartingPosition is POINT_IN_TIME.
PointInTimeConfiguration *types.PointInTimeConfiguration
// Starting position for a subscriber.
StartingPosition types.StartingPosition
// Customer-controlled run state of a subscriber, set on create or update.
// Distinct from the bus lifecycle vocabulary, where ACTIVE means "provisioned and
// healthy". Delivery requires State RUNNING on a subscriber that is not revoked.
State types.SubscriberState
// The Amazon Resource Name (ARN) that uniquely identifies a subscriber.
SubscriberArn *string
// Delivery ordering mode of a subscriber: FIFO delivers events in order within an
// event group; UNORDERED delivers without an ordering guarantee.
Type types.OrderingType
// Metadata pertaining to the operation's result.
ResultMetadata middleware.Metadata
// contains filtered or unexported fields
}
func (*CreateSubscriberOutput) Deserialize ¶
func (v *CreateSubscriberOutput) Deserialize(d smithy.ShapeDeserializer) error
func (*CreateSubscriberOutput) Serialize ¶
func (v *CreateSubscriberOutput) Serialize(s smithy.ShapeSerializer)
func (*CreateSubscriberOutput) SerializeMembers ¶
func (v *CreateSubscriberOutput) SerializeMembers(s smithy.ShapeSerializer)
type DeleteEventBusInput ¶
type DeleteEventBusInput struct {
// The Amazon Resource Name (ARN) that uniquely identifies an event bus.
//
// This member is required.
EventBusArn *string
// contains filtered or unexported fields
}
func (*DeleteEventBusInput) Serialize ¶
func (v *DeleteEventBusInput) Serialize(s smithy.ShapeSerializer)
func (*DeleteEventBusInput) SerializeMembers ¶
func (v *DeleteEventBusInput) SerializeMembers(s smithy.ShapeSerializer)
type DeleteEventBusOutput ¶
type DeleteEventBusOutput struct {
// Metadata pertaining to the operation's result.
ResultMetadata middleware.Metadata
// contains filtered or unexported fields
}
func (*DeleteEventBusOutput) Deserialize ¶
func (v *DeleteEventBusOutput) Deserialize(d smithy.ShapeDeserializer) error
func (*DeleteEventBusOutput) Serialize ¶
func (v *DeleteEventBusOutput) Serialize(s smithy.ShapeSerializer)
func (*DeleteEventBusOutput) SerializeMembers ¶
func (v *DeleteEventBusOutput) SerializeMembers(s smithy.ShapeSerializer)
type DeleteEventSourceInput ¶
type DeleteEventSourceInput struct {
// EventSource ARN: event-sourcev2///. The type segment is set by the service
// (aws.service for AWS service events, aws.partner for partner events) and is not
// part of the resource's name. The id segment is a 25-character identifier
// generated by the service.
//
// This member is required.
EventSourceArn *string
// contains filtered or unexported fields
}
func (*DeleteEventSourceInput) Serialize ¶
func (v *DeleteEventSourceInput) Serialize(s smithy.ShapeSerializer)
func (*DeleteEventSourceInput) SerializeMembers ¶
func (v *DeleteEventSourceInput) SerializeMembers(s smithy.ShapeSerializer)
type DeleteEventSourceOutput ¶
type DeleteEventSourceOutput struct {
// Metadata pertaining to the operation's result.
ResultMetadata middleware.Metadata
// contains filtered or unexported fields
}
func (*DeleteEventSourceOutput) Deserialize ¶
func (v *DeleteEventSourceOutput) Deserialize(d smithy.ShapeDeserializer) error
func (*DeleteEventSourceOutput) Serialize ¶
func (v *DeleteEventSourceOutput) Serialize(s smithy.ShapeSerializer)
func (*DeleteEventSourceOutput) SerializeMembers ¶
func (v *DeleteEventSourceOutput) SerializeMembers(s smithy.ShapeSerializer)
type DeleteResourcePolicyInput ¶
type DeleteResourcePolicyInput struct {
// The Amazon Resource Name (ARN) that uniquely identifies an event bus.
//
// This member is required.
ResourceArn *string
// The delete succeeds only if the named policy's current revision ID matches this
// value; if it differs or the policy does not exist, the operation fails with
// ConflictException. The "NO_POLICY" sentinel is not valid here. When omitted,
// deleting an absent policy is an idempotent success. Supplying this value makes
// the delete non-idempotent: once it succeeds the expected revision no longer
// exists, so retrying an unanswered request fails with ConflictException even
// though the policy was deleted. To establish the outcome, read the policy back:
// ResourceNotFoundException means the delete took effect.
ExpectedRevisionId *string
// Which named policy to delete. Defaults to "default" when omitted (a delete AWS
// Resource Access Manager makes on the owner's behalf resolves to "AWS_RAM"
// instead). The two writers are exclusive in both directions — only Resource
// Access Manager can delete "AWS_RAM", and only the bus owner can delete "default"
// — so naming the other party's policy fails with AccessDeniedException. A
// well-formed name that is neither of the two fails with InvalidInputException.
PolicyName *string
// contains filtered or unexported fields
}
func (*DeleteResourcePolicyInput) Serialize ¶
func (v *DeleteResourcePolicyInput) Serialize(s smithy.ShapeSerializer)
func (*DeleteResourcePolicyInput) SerializeMembers ¶
func (v *DeleteResourcePolicyInput) SerializeMembers(s smithy.ShapeSerializer)
type DeleteResourcePolicyOutput ¶
type DeleteResourcePolicyOutput struct {
// Revision ID of the policy that was deleted. Absent when no policy was deleted.
RevisionId *string
// Metadata pertaining to the operation's result.
ResultMetadata middleware.Metadata
// contains filtered or unexported fields
}
func (*DeleteResourcePolicyOutput) Deserialize ¶
func (v *DeleteResourcePolicyOutput) Deserialize(d smithy.ShapeDeserializer) error
func (*DeleteResourcePolicyOutput) Serialize ¶
func (v *DeleteResourcePolicyOutput) Serialize(s smithy.ShapeSerializer)
func (*DeleteResourcePolicyOutput) SerializeMembers ¶
func (v *DeleteResourcePolicyOutput) SerializeMembers(s smithy.ShapeSerializer)
type DeleteSubscriberInput ¶
type DeleteSubscriberInput struct {
// The Amazon Resource Name (ARN) that uniquely identifies a subscriber.
//
// This member is required.
SubscriberArn *string
// contains filtered or unexported fields
}
func (*DeleteSubscriberInput) Serialize ¶
func (v *DeleteSubscriberInput) Serialize(s smithy.ShapeSerializer)
func (*DeleteSubscriberInput) SerializeMembers ¶
func (v *DeleteSubscriberInput) SerializeMembers(s smithy.ShapeSerializer)
type DeleteSubscriberOutput ¶
type DeleteSubscriberOutput struct {
// Metadata pertaining to the operation's result.
ResultMetadata middleware.Metadata
// contains filtered or unexported fields
}
func (*DeleteSubscriberOutput) Deserialize ¶
func (v *DeleteSubscriberOutput) Deserialize(d smithy.ShapeDeserializer) error
func (*DeleteSubscriberOutput) Serialize ¶
func (v *DeleteSubscriberOutput) Serialize(s smithy.ShapeSerializer)
func (*DeleteSubscriberOutput) SerializeMembers ¶
func (v *DeleteSubscriberOutput) SerializeMembers(s smithy.ShapeSerializer)
type DescribeEventBusAPIClient ¶
type DescribeEventBusAPIClient interface {
DescribeEventBus(context.Context, *DescribeEventBusInput, ...func(*Options)) (*DescribeEventBusOutput, error)
}
DescribeEventBusAPIClient is a client that implements the DescribeEventBus operation.
type DescribeEventBusInput ¶
type DescribeEventBusInput struct {
// The Amazon Resource Name (ARN) that uniquely identifies an event bus.
//
// This member is required.
EventBusArn *string
// contains filtered or unexported fields
}
func (*DescribeEventBusInput) Serialize ¶
func (v *DescribeEventBusInput) Serialize(s smithy.ShapeSerializer)
func (*DescribeEventBusInput) SerializeMembers ¶
func (v *DescribeEventBusInput) SerializeMembers(s smithy.ShapeSerializer)
type DescribeEventBusOutput ¶
type DescribeEventBusOutput struct {
// The time the event bus was created.
CreationTime *time.Time
// Free-text description. Used by every resource type that has one: event buses,
// subscribers, and event sources.
Description *string
// Encryption configuration for an event bus.
EncryptionConfiguration *types.EncryptionConfiguration
// The Amazon Resource Name (ARN) that uniquely identifies an event bus.
EventBusArn *string
// The time the event bus was last modified.
LastModifiedTime *time.Time
// Name of an event bus. The first character must be alphanumeric; the remaining
// characters may also include '.', '-', and '_'. The grammar matches the name
// segment of EventBusArn (event-busv2//), so every valid name can be represented
// in the bus's ARN. The same type is used everywhere a bus name appears.
Name *string
// Lifecycle state of an event bus.
//
// - CREATING: Bus creation is in progress.
// - CREATE_FAILED: Bus creation failed; see StateReason. The bus cannot be
// recovered or recreated in place: delete it with DeleteEventBus, then create a
// new bus.
// - ACTIVE: Bus is fully operational and can accept events.
// - UPDATING: Bus update is in progress.
// - UPDATE_FAILED: Bus update failed; the bus remains operational with its
// previous configuration.
// - DELETING: Bus deletion is actively in progress.
// - DELETE_FAILED: Bus deletion failed; see StateReason. Retry DeleteEventBus
// after removing subscribers and event sources.
State types.BusState
// Human-readable explanation of why an event bus is in its current State. Omitted
// when the bus is in a normal operational state (ACTIVE). It stands in for the
// error response an asynchronous failure cannot return, so it applies only to
// resources with an asynchronous lifecycle: event buses. EventSources and
// subscribers are provisioned synchronously and report failures directly on the
// request.
StateReason *string
// Event storage configuration of an event bus, as returned on reads.
StorageConfiguration *types.StorageConfigurationOutput
// Metadata pertaining to the operation's result.
ResultMetadata middleware.Metadata
// contains filtered or unexported fields
}
func (*DescribeEventBusOutput) Deserialize ¶
func (v *DescribeEventBusOutput) Deserialize(d smithy.ShapeDeserializer) error
func (*DescribeEventBusOutput) Serialize ¶
func (v *DescribeEventBusOutput) Serialize(s smithy.ShapeSerializer)
func (*DescribeEventBusOutput) SerializeMembers ¶
func (v *DescribeEventBusOutput) SerializeMembers(s smithy.ShapeSerializer)
type DescribeEventSourceInput ¶
type DescribeEventSourceInput struct {
// EventSource ARN: event-sourcev2///. The type segment is set by the service
// (aws.service for AWS service events, aws.partner for partner events) and is not
// part of the resource's name. The id segment is a 25-character identifier
// generated by the service.
//
// This member is required.
EventSourceArn *string
// contains filtered or unexported fields
}
func (*DescribeEventSourceInput) Serialize ¶
func (v *DescribeEventSourceInput) Serialize(s smithy.ShapeSerializer)
func (*DescribeEventSourceInput) SerializeMembers ¶
func (v *DescribeEventSourceInput) SerializeMembers(s smithy.ShapeSerializer)
type DescribeEventSourceOutput ¶
type DescribeEventSourceOutput struct {
// Discriminated EventSource configuration. Exactly one variant must be set.
Configuration types.EventSourceConfiguration
// The time the EventSource was created.
CreationTime *time.Time
// Free-text description. Used by every resource type that has one: event buses,
// subscribers, and event sources.
Description *string
// The Amazon Resource Name (ARN) that uniquely identifies an event bus.
EventBusArn *string
// EventSource ARN: event-sourcev2///. The type segment is set by the service
// (aws.service for AWS service events, aws.partner for partner events) and is not
// part of the resource's name. The id segment is a 25-character identifier
// generated by the service.
EventSourceArn *string
// The time the EventSource was last modified.
LastModifiedTime *time.Time
// EventSource name. First character alphanumeric; the rest may add '.', '-', '_'.
// Names may not begin with the reserved "aws." prefix. The grammar matches the ARN
// local-name segment in EventSourceArn (event-sourcev2///), mirroring
// EventBusName, so a name the ARN cannot represent cannot be created.
Name *string
// True when the bus owner has withdrawn this EventSource. Present only when true,
// so an absent member means the EventSource is not revoked. Revocation is
// terminal: it never returns to false. Mutating operations on a revoked
// EventSource fail with InvalidStateException, except DeleteEventSource, which
// stays available so a revoked EventSource can still be cleaned up.
Revoked *bool
// Lifecycle state of an EventSource. Revocation is reported by the Revoked flag.
State types.EventSourceState
// Metadata pertaining to the operation's result.
ResultMetadata middleware.Metadata
// contains filtered or unexported fields
}
func (*DescribeEventSourceOutput) Deserialize ¶
func (v *DescribeEventSourceOutput) Deserialize(d smithy.ShapeDeserializer) error
func (*DescribeEventSourceOutput) Serialize ¶
func (v *DescribeEventSourceOutput) Serialize(s smithy.ShapeSerializer)
func (*DescribeEventSourceOutput) SerializeMembers ¶
func (v *DescribeEventSourceOutput) SerializeMembers(s smithy.ShapeSerializer)
type DescribeSubscriberInput ¶
type DescribeSubscriberInput struct {
// The Amazon Resource Name (ARN) that uniquely identifies a subscriber.
//
// This member is required.
SubscriberArn *string
// contains filtered or unexported fields
}
func (*DescribeSubscriberInput) Serialize ¶
func (v *DescribeSubscriberInput) Serialize(s smithy.ShapeSerializer)
func (*DescribeSubscriberInput) SerializeMembers ¶
func (v *DescribeSubscriberInput) SerializeMembers(s smithy.ShapeSerializer)
type DescribeSubscriberOutput ¶
type DescribeSubscriberOutput struct {
// Batching configuration for a subscriber.
BatchConfiguration *types.BatchConfiguration
// The time the subscriber was created.
CreationTime *time.Time
// Free-text description. Used by every resource type that has one: event buses,
// subscribers, and event sources.
Description *string
// The Amazon Resource Name (ARN) that uniquely identifies an event bus.
EventBusArn *string
// Configuration for filtering events delivered to a subscriber. On
// CreateSubscriber, Filters is required and must contain at least one Filter with
// a non-empty Pattern. On UpdateSubscriber, an empty FilterConfiguration:{}
// clears the existing filter. Any non-empty shape (including {Language:X} without
// Filters) must contain a valid Filters list — same contract as CreateSubscriber.
// A non-empty Filters list overwrites; an omitted FilterConfiguration preserves
// existing state. All Filters are implicitly ANDed — an event must match every
// Filter to be delivered.
FilterConfiguration *types.FilterConfiguration
// Configuration for how the subscriber invokes its target.
InvokeConfiguration *types.InvokeConfiguration
// The time the subscriber was last modified.
LastModifiedTime *time.Time
// Log configuration for a subscriber.
LogConfiguration *types.LogConfiguration
// Name of a subscriber. The first character must be alphanumeric; the remaining
// characters may also include '.', '-', and '_'.
Name *string
// On-failure configuration: where a failed delivery is sent. Shared by the
// subscriber and the EventSource.
OnFailureConfiguration *types.OnFailureConfiguration
// Point-in-time configuration for a subscriber. Only applicable when
// StartingPosition is POINT_IN_TIME.
PointInTimeConfiguration *types.PointInTimeConfiguration
// Retry policy for a subscriber.
RetryPolicy *types.RetryPolicy
// True when the bus owner has revoked this subscriber. Present only when true, so
// an absent member means the subscriber is not revoked. Revocation is terminal: it
// never returns to false. Mutating operations on a revoked subscriber fail with
// InvalidStateException, except DeleteSubscriber, which stays available so a
// revoked subscriber can still be cleaned up.
Revoked *bool
// Starting position for a subscriber.
StartingPosition types.StartingPosition
// Customer-controlled run state of a subscriber, set on create or update.
// Distinct from the bus lifecycle vocabulary, where ACTIVE means "provisioned and
// healthy". Delivery requires State RUNNING on a subscriber that is not revoked.
State types.SubscriberState
// The Amazon Resource Name (ARN) that uniquely identifies a subscriber.
SubscriberArn *string
// Absent for universal (aws-sdk) targets, whose input transformation is
// UniversalTargetParameters.Input.
Transformer *types.Transformer
// Delivery ordering mode of a subscriber: FIFO delivers events in order within an
// event group; UNORDERED delivers without an ordering guarantee.
Type types.OrderingType
// Metadata pertaining to the operation's result.
ResultMetadata middleware.Metadata
// contains filtered or unexported fields
}
func (*DescribeSubscriberOutput) Deserialize ¶
func (v *DescribeSubscriberOutput) Deserialize(d smithy.ShapeDeserializer) error
func (*DescribeSubscriberOutput) Serialize ¶
func (v *DescribeSubscriberOutput) Serialize(s smithy.ShapeSerializer)
func (*DescribeSubscriberOutput) SerializeMembers ¶
func (v *DescribeSubscriberOutput) SerializeMembers(s smithy.ShapeSerializer)
type EndpointParameters ¶
type EndpointParameters struct {
// The AWS region used to dispatch the request.
//
// AWS::Region
Region *string
// Override the endpoint used to send this request.
//
// Parameter is
// required.
//
// SDK::Endpoint
Endpoint *string
// When true, send this request to the FIPS-compliant regional endpoint.
//
// Defaults
// to false if no value is provided.
//
// AWS::UseFIPS
UseFIPS *bool
// When true, use the dual-stack endpoint.
//
// Defaults to false if no value is
// provided.
//
// AWS::UseDualStack
UseDualStack *bool
// The AWS account ID used for the request, sourced from the caller's
// credentials.
//
// Parameter is required.
//
// AWS::Auth::AccountId
AccountId *string
// The bus ARN from the request, bound via @contextParam. Its account is the bus
// owner and takes precedence over the credentials-sourced account for cell routing
// (cross-account calls).
//
// Parameter is required.
EventBusArn *string
// The behavior for account ID based endpoint routing: preferred, disabled, or
// required.
//
// Parameter is required.
//
// AWS::Auth::AccountIdEndpointMode
AccountIdEndpointMode *string
}
EndpointParameters provides the parameters that influence how endpoints are resolved.
func (EndpointParameters) ValidateRequired ¶
func (p EndpointParameters) ValidateRequired() error
ValidateRequired validates required parameters are set.
func (EndpointParameters) WithDefaults ¶
func (p EndpointParameters) WithDefaults() EndpointParameters
WithDefaults returns a shallow copy of EndpointParameterswith default values applied to members where applicable.
type EndpointResolver ¶
type EndpointResolver interface {
ResolveEndpoint(region string, options EndpointResolverOptions) (aws.Endpoint, error)
}
EndpointResolver interface for resolving service endpoints.
func EndpointResolverFromURL ¶
func EndpointResolverFromURL(url string, optFns ...func(*aws.Endpoint)) EndpointResolver
EndpointResolverFromURL returns an EndpointResolver configured using the provided endpoint url. By default, the resolved endpoint resolver uses the client region as signing region, and the endpoint source is set to EndpointSourceCustom.You can provide functional options to configure endpoint values for the resolved endpoint.
type EndpointResolverFunc ¶
type EndpointResolverFunc func(region string, options EndpointResolverOptions) (aws.Endpoint, error)
EndpointResolverFunc is a helper utility that wraps a function so it satisfies the EndpointResolver interface. This is useful when you want to add additional endpoint resolving logic, or stub out specific endpoints with custom values.
func (EndpointResolverFunc) ResolveEndpoint ¶
func (fn EndpointResolverFunc) ResolveEndpoint(region string, options EndpointResolverOptions) (endpoint aws.Endpoint, err error)
type EndpointResolverOptions ¶
type EndpointResolverOptions = internalendpoints.Options
EndpointResolverOptions is the service endpoint resolver options
type EndpointResolverV2 ¶
type EndpointResolverV2 interface {
ResolveEndpoint(ctx context.Context, params EndpointParameters) (
smithyendpoints.Endpoint, error,
)
}
EndpointResolverV2 provides the interface for resolving service endpoints.
func NewDefaultEndpointResolverV2 ¶
func NewDefaultEndpointResolverV2() EndpointResolverV2
type EventBusActiveWaiter ¶
type EventBusActiveWaiter struct {
// contains filtered or unexported fields
}
EventBusActiveWaiter defines the waiters for EventBusActive
func NewEventBusActiveWaiter ¶
func NewEventBusActiveWaiter(client DescribeEventBusAPIClient, optFns ...func(*EventBusActiveWaiterOptions)) *EventBusActiveWaiter
NewEventBusActiveWaiter constructs a EventBusActiveWaiter.
func (*EventBusActiveWaiter) Wait ¶
func (w *EventBusActiveWaiter) Wait(ctx context.Context, params *DescribeEventBusInput, maxWaitDur time.Duration, optFns ...func(*EventBusActiveWaiterOptions)) error
Wait calls the waiter function for EventBusActive waiter. The maxWaitDur is the maximum wait duration the waiter will wait. The maxWaitDur is required and must be greater than zero.
func (*EventBusActiveWaiter) WaitForOutput ¶
func (w *EventBusActiveWaiter) WaitForOutput(ctx context.Context, params *DescribeEventBusInput, maxWaitDur time.Duration, optFns ...func(*EventBusActiveWaiterOptions)) (*DescribeEventBusOutput, error)
WaitForOutput calls the waiter function for EventBusActive waiter and returns the output of the successful operation. The maxWaitDur is the maximum wait duration the waiter will wait. The maxWaitDur is required and must be greater than zero.
type EventBusActiveWaiterOptions ¶
type EventBusActiveWaiterOptions struct {
// Set of options to modify how an operation is invoked. These apply to all
// operations invoked for this client. Use functional options on operation call to
// modify this list for per operation behavior.
//
// Passing options here is functionally equivalent to passing values to this
// config's ClientOptions field that extend the inner client's APIOptions directly.
APIOptions []func(*middleware.Stack) error
// Functional options to be passed to all operations invoked by this client.
//
// Function values that modify the inner APIOptions are applied after the waiter
// config's own APIOptions modifiers.
ClientOptions []func(*Options)
// MinDelay is the minimum amount of time to delay between retries. If unset,
// EventBusActiveWaiter will use default minimum delay of 2 seconds. Note that
// MinDelay must resolve to a value lesser than or equal to the MaxDelay.
MinDelay time.Duration
// MaxDelay is the maximum amount of time to delay between retries. If unset or
// set to zero, EventBusActiveWaiter will use default max delay of 120 seconds.
// Note that MaxDelay must resolve to value greater than or equal to the MinDelay.
MaxDelay time.Duration
// LogWaitAttempts is used to enable logging for waiter retry attempts
LogWaitAttempts bool
// Retryable is function that can be used to override the service defined
// waiter-behavior based on operation output, or returned error. This function is
// used by the waiter to decide if a state is retryable or a terminal state.
//
// By default service-modeled logic will populate this option. This option can
// thus be used to define a custom waiter state with fall-back to service-modeled
// waiter state mutators.The function returns an error in case of a failure state.
// In case of retry state, this function returns a bool value of true and nil
// error, while in case of success it returns a bool value of false and nil error.
Retryable func(context.Context, *DescribeEventBusInput, *DescribeEventBusOutput, error) (bool, error)
}
EventBusActiveWaiterOptions are waiter options for EventBusActiveWaiter
type EventBusDeletedWaiter ¶
type EventBusDeletedWaiter struct {
// contains filtered or unexported fields
}
EventBusDeletedWaiter defines the waiters for EventBusDeleted
func NewEventBusDeletedWaiter ¶
func NewEventBusDeletedWaiter(client DescribeEventBusAPIClient, optFns ...func(*EventBusDeletedWaiterOptions)) *EventBusDeletedWaiter
NewEventBusDeletedWaiter constructs a EventBusDeletedWaiter.
func (*EventBusDeletedWaiter) Wait ¶
func (w *EventBusDeletedWaiter) Wait(ctx context.Context, params *DescribeEventBusInput, maxWaitDur time.Duration, optFns ...func(*EventBusDeletedWaiterOptions)) error
Wait calls the waiter function for EventBusDeleted waiter. The maxWaitDur is the maximum wait duration the waiter will wait. The maxWaitDur is required and must be greater than zero.
func (*EventBusDeletedWaiter) WaitForOutput ¶
func (w *EventBusDeletedWaiter) WaitForOutput(ctx context.Context, params *DescribeEventBusInput, maxWaitDur time.Duration, optFns ...func(*EventBusDeletedWaiterOptions)) (*DescribeEventBusOutput, error)
WaitForOutput calls the waiter function for EventBusDeleted waiter and returns the output of the successful operation. The maxWaitDur is the maximum wait duration the waiter will wait. The maxWaitDur is required and must be greater than zero.
type EventBusDeletedWaiterOptions ¶
type EventBusDeletedWaiterOptions struct {
// Set of options to modify how an operation is invoked. These apply to all
// operations invoked for this client. Use functional options on operation call to
// modify this list for per operation behavior.
//
// Passing options here is functionally equivalent to passing values to this
// config's ClientOptions field that extend the inner client's APIOptions directly.
APIOptions []func(*middleware.Stack) error
// Functional options to be passed to all operations invoked by this client.
//
// Function values that modify the inner APIOptions are applied after the waiter
// config's own APIOptions modifiers.
ClientOptions []func(*Options)
// MinDelay is the minimum amount of time to delay between retries. If unset,
// EventBusDeletedWaiter will use default minimum delay of 2 seconds. Note that
// MinDelay must resolve to a value lesser than or equal to the MaxDelay.
MinDelay time.Duration
// MaxDelay is the maximum amount of time to delay between retries. If unset or
// set to zero, EventBusDeletedWaiter will use default max delay of 120 seconds.
// Note that MaxDelay must resolve to value greater than or equal to the MinDelay.
MaxDelay time.Duration
// LogWaitAttempts is used to enable logging for waiter retry attempts
LogWaitAttempts bool
// Retryable is function that can be used to override the service defined
// waiter-behavior based on operation output, or returned error. This function is
// used by the waiter to decide if a state is retryable or a terminal state.
//
// By default service-modeled logic will populate this option. This option can
// thus be used to define a custom waiter state with fall-back to service-modeled
// waiter state mutators.The function returns an error in case of a failure state.
// In case of retry state, this function returns a bool value of true and nil
// error, while in case of success it returns a bool value of false and nil error.
Retryable func(context.Context, *DescribeEventBusInput, *DescribeEventBusOutput, error) (bool, error)
}
EventBusDeletedWaiterOptions are waiter options for EventBusDeletedWaiter
type GetResourcePolicyInput ¶
type GetResourcePolicyInput struct {
// The Amazon Resource Name (ARN) that uniquely identifies an event bus.
//
// This member is required.
ResourceArn *string
// Which named policy to read. Defaults to "default" when omitted (a read AWS
// Resource Access Manager makes on the owner's behalf resolves to "AWS_RAM"
// instead). Unlike writing, neither name is reserved on a read: the bus owner can
// read both. There is no fallback between the two, so a bus shared only through
// Resource Access Manager fails with ResourceNotFoundException until "AWS_RAM" is
// named explicitly. A well-formed name that is neither of the two fails with
// InvalidInputException.
PolicyName *string
// contains filtered or unexported fields
}
func (*GetResourcePolicyInput) Serialize ¶
func (v *GetResourcePolicyInput) Serialize(s smithy.ShapeSerializer)
func (*GetResourcePolicyInput) SerializeMembers ¶
func (v *GetResourcePolicyInput) SerializeMembers(s smithy.ShapeSerializer)
type GetResourcePolicyOutput ¶
type GetResourcePolicyOutput struct {
// A resource policy document, as a JSON string. The "default" policy can be up to
// 20 KB (20,480 bytes of UTF-8) by default. This quota is adjustable in Service
// Quotas. A "default" policy that exceeds the quota is rejected with
// PolicyLengthExceededException. No policy document can exceed 389,120 bytes of
// UTF-8, regardless of the quota.
//
// This member is required.
PolicyDocument *string
// Name of a policy attached to a resource. Valid values: "default" (the
// customer-managed policy) and "AWS_RAM" (managed exclusively by AWS Resource
// Access Manager). Any other value is rejected.
//
// This member is required.
PolicyName *string
// The Amazon Resource Name (ARN) that uniquely identifies an event bus.
//
// This member is required.
ResourceArn *string
// Revision ID of a resource policy. A new revision ID is generated on every
// successful write.
//
// This member is required.
RevisionId *string
// Metadata pertaining to the operation's result.
ResultMetadata middleware.Metadata
// contains filtered or unexported fields
}
Returned only when the named policy exists. A missing event bus or a missing named policy fails with ResourceNotFoundException rather than returning an empty or null policy document. Every member is therefore always present on a successful response.
func (*GetResourcePolicyOutput) Deserialize ¶
func (v *GetResourcePolicyOutput) Deserialize(d smithy.ShapeDeserializer) error
func (*GetResourcePolicyOutput) Serialize ¶
func (v *GetResourcePolicyOutput) Serialize(s smithy.ShapeSerializer)
func (*GetResourcePolicyOutput) SerializeMembers ¶
func (v *GetResourcePolicyOutput) SerializeMembers(s smithy.ShapeSerializer)
type HTTPSignerV4 ¶
type IdempotencyTokenProvider ¶
IdempotencyTokenProvider interface for providing idempotency token
type ListEventBusesAPIClient ¶
type ListEventBusesAPIClient interface {
ListEventBuses(context.Context, *ListEventBusesInput, ...func(*Options)) (*ListEventBusesOutput, error)
}
ListEventBusesAPIClient is a client that implements the ListEventBuses operation.
type ListEventBusesInput ¶
type ListEventBusesInput struct {
// AWS Account Id.
EventBusAccountId *string
// Maximum number of results to return in one page of a List operation.
MaxResults *int32
// Name of an event bus. The first character must be alphanumeric; the remaining
// characters may also include '.', '-', and '_'. The grammar matches the name
// segment of EventBusArn (event-busv2//), so every valid name can be represented
// in the bus's ARN. The same type is used everywhere a bus name appears.
NamePrefix *string
// Opaque pagination token returned by a List operation. Pass it back in the next
// request to retrieve the next page of results.
NextToken *string
// contains filtered or unexported fields
}
func (*ListEventBusesInput) Serialize ¶
func (v *ListEventBusesInput) Serialize(s smithy.ShapeSerializer)
func (*ListEventBusesInput) SerializeMembers ¶
func (v *ListEventBusesInput) SerializeMembers(s smithy.ShapeSerializer)
type ListEventBusesOutput ¶
type ListEventBusesOutput struct {
// List of event bus summaries.
EventBuses []types.EventBusSummary
// Opaque pagination token returned by a List operation. Pass it back in the next
// request to retrieve the next page of results.
NextToken *string
// Metadata pertaining to the operation's result.
ResultMetadata middleware.Metadata
// contains filtered or unexported fields
}
func (*ListEventBusesOutput) Deserialize ¶
func (v *ListEventBusesOutput) Deserialize(d smithy.ShapeDeserializer) error
func (*ListEventBusesOutput) Serialize ¶
func (v *ListEventBusesOutput) Serialize(s smithy.ShapeSerializer)
func (*ListEventBusesOutput) SerializeMembers ¶
func (v *ListEventBusesOutput) SerializeMembers(s smithy.ShapeSerializer)
type ListEventBusesPaginator ¶
type ListEventBusesPaginator struct {
// contains filtered or unexported fields
}
ListEventBusesPaginator is a paginator for ListEventBuses
func NewListEventBusesPaginator ¶
func NewListEventBusesPaginator(client ListEventBusesAPIClient, params *ListEventBusesInput, optFns ...func(*ListEventBusesPaginatorOptions)) *ListEventBusesPaginator
NewListEventBusesPaginator returns a new ListEventBusesPaginator
func (*ListEventBusesPaginator) HasMorePages ¶
func (p *ListEventBusesPaginator) HasMorePages() bool
HasMorePages returns a boolean indicating whether more pages are available
func (*ListEventBusesPaginator) NextPage ¶
func (p *ListEventBusesPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*ListEventBusesOutput, error)
NextPage retrieves the next ListEventBuses page.
type ListEventBusesPaginatorOptions ¶
type ListEventBusesPaginatorOptions struct {
// Maximum number of results to return in one page of a List operation.
Limit int32
// Set to true if pagination should stop if the service returns a pagination token
// that matches the most recent token provided to the service.
StopOnDuplicateToken bool
}
ListEventBusesPaginatorOptions is the paginator options for ListEventBuses
type ListEventSourcesAPIClient ¶
type ListEventSourcesAPIClient interface {
ListEventSources(context.Context, *ListEventSourcesInput, ...func(*Options)) (*ListEventSourcesOutput, error)
}
ListEventSourcesAPIClient is a client that implements the ListEventSources operation.
type ListEventSourcesInput ¶
type ListEventSourcesInput struct {
// The Amazon Resource Name (ARN) that uniquely identifies an event bus.
EventBusArn *string
// Maximum number of results to return in one page of a List operation.
MaxResults *int32
// EventSource name. First character alphanumeric; the rest may add '.', '-', '_'.
// Names may not begin with the reserved "aws." prefix. The grammar matches the ARN
// local-name segment in EventSourceArn (event-sourcev2///), mirroring
// EventBusName, so a name the ARN cannot represent cannot be created.
NamePrefix *string
// Opaque pagination token returned by a List operation. Pass it back in the next
// request to retrieve the next page of results.
NextToken *string
// contains filtered or unexported fields
}
func (*ListEventSourcesInput) Serialize ¶
func (v *ListEventSourcesInput) Serialize(s smithy.ShapeSerializer)
func (*ListEventSourcesInput) SerializeMembers ¶
func (v *ListEventSourcesInput) SerializeMembers(s smithy.ShapeSerializer)
type ListEventSourcesOutput ¶
type ListEventSourcesOutput struct {
// List of EventSource summaries.
EventSources []types.EventSourceSummary
// Opaque pagination token returned by a List operation. Pass it back in the next
// request to retrieve the next page of results.
NextToken *string
// Metadata pertaining to the operation's result.
ResultMetadata middleware.Metadata
// contains filtered or unexported fields
}
func (*ListEventSourcesOutput) Deserialize ¶
func (v *ListEventSourcesOutput) Deserialize(d smithy.ShapeDeserializer) error
func (*ListEventSourcesOutput) Serialize ¶
func (v *ListEventSourcesOutput) Serialize(s smithy.ShapeSerializer)
func (*ListEventSourcesOutput) SerializeMembers ¶
func (v *ListEventSourcesOutput) SerializeMembers(s smithy.ShapeSerializer)
type ListEventSourcesPaginator ¶
type ListEventSourcesPaginator struct {
// contains filtered or unexported fields
}
ListEventSourcesPaginator is a paginator for ListEventSources
func NewListEventSourcesPaginator ¶
func NewListEventSourcesPaginator(client ListEventSourcesAPIClient, params *ListEventSourcesInput, optFns ...func(*ListEventSourcesPaginatorOptions)) *ListEventSourcesPaginator
NewListEventSourcesPaginator returns a new ListEventSourcesPaginator
func (*ListEventSourcesPaginator) HasMorePages ¶
func (p *ListEventSourcesPaginator) HasMorePages() bool
HasMorePages returns a boolean indicating whether more pages are available
func (*ListEventSourcesPaginator) NextPage ¶
func (p *ListEventSourcesPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*ListEventSourcesOutput, error)
NextPage retrieves the next ListEventSources page.
type ListEventSourcesPaginatorOptions ¶
type ListEventSourcesPaginatorOptions struct {
// Maximum number of results to return in one page of a List operation.
Limit int32
// Set to true if pagination should stop if the service returns a pagination token
// that matches the most recent token provided to the service.
StopOnDuplicateToken bool
}
ListEventSourcesPaginatorOptions is the paginator options for ListEventSources
type ListResourcePoliciesAPIClient ¶
type ListResourcePoliciesAPIClient interface {
ListResourcePolicies(context.Context, *ListResourcePoliciesInput, ...func(*Options)) (*ListResourcePoliciesOutput, error)
}
ListResourcePoliciesAPIClient is a client that implements the ListResourcePolicies operation.
type ListResourcePoliciesInput ¶
type ListResourcePoliciesInput struct {
// The Amazon Resource Name (ARN) that uniquely identifies an event bus.
//
// This member is required.
ResourceArn *string
// Maximum number of results to return in one page of a List operation.
MaxResults *int32
// Opaque pagination token returned by a List operation. Pass it back in the next
// request to retrieve the next page of results.
NextToken *string
// contains filtered or unexported fields
}
func (*ListResourcePoliciesInput) Serialize ¶
func (v *ListResourcePoliciesInput) Serialize(s smithy.ShapeSerializer)
func (*ListResourcePoliciesInput) SerializeMembers ¶
func (v *ListResourcePoliciesInput) SerializeMembers(s smithy.ShapeSerializer)
type ListResourcePoliciesOutput ¶
type ListResourcePoliciesOutput struct {
// Opaque pagination token returned by a List operation. Pass it back in the next
// request to retrieve the next page of results.
NextToken *string
// List of resource policy summaries.
PolicySummaries []types.ResourcePolicySummary
// Metadata pertaining to the operation's result.
ResultMetadata middleware.Metadata
// contains filtered or unexported fields
}
Summaries only (policy name and revision ID). Use GetResourcePolicy to retrieve a policy document.
func (*ListResourcePoliciesOutput) Deserialize ¶
func (v *ListResourcePoliciesOutput) Deserialize(d smithy.ShapeDeserializer) error
func (*ListResourcePoliciesOutput) Serialize ¶
func (v *ListResourcePoliciesOutput) Serialize(s smithy.ShapeSerializer)
func (*ListResourcePoliciesOutput) SerializeMembers ¶
func (v *ListResourcePoliciesOutput) SerializeMembers(s smithy.ShapeSerializer)
type ListResourcePoliciesPaginator ¶
type ListResourcePoliciesPaginator struct {
// contains filtered or unexported fields
}
ListResourcePoliciesPaginator is a paginator for ListResourcePolicies
func NewListResourcePoliciesPaginator ¶
func NewListResourcePoliciesPaginator(client ListResourcePoliciesAPIClient, params *ListResourcePoliciesInput, optFns ...func(*ListResourcePoliciesPaginatorOptions)) *ListResourcePoliciesPaginator
NewListResourcePoliciesPaginator returns a new ListResourcePoliciesPaginator
func (*ListResourcePoliciesPaginator) HasMorePages ¶
func (p *ListResourcePoliciesPaginator) HasMorePages() bool
HasMorePages returns a boolean indicating whether more pages are available
func (*ListResourcePoliciesPaginator) NextPage ¶
func (p *ListResourcePoliciesPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*ListResourcePoliciesOutput, error)
NextPage retrieves the next ListResourcePolicies page.
type ListResourcePoliciesPaginatorOptions ¶
type ListResourcePoliciesPaginatorOptions struct {
// Maximum number of results to return in one page of a List operation.
Limit int32
// Set to true if pagination should stop if the service returns a pagination token
// that matches the most recent token provided to the service.
StopOnDuplicateToken bool
}
ListResourcePoliciesPaginatorOptions is the paginator options for ListResourcePolicies
type ListSubscribersAPIClient ¶
type ListSubscribersAPIClient interface {
ListSubscribers(context.Context, *ListSubscribersInput, ...func(*Options)) (*ListSubscribersOutput, error)
}
ListSubscribersAPIClient is a client that implements the ListSubscribers operation.
type ListSubscribersInput ¶
type ListSubscribersInput struct {
// The Amazon Resource Name (ARN) that uniquely identifies an event bus.
EventBusArn *string
// Maximum number of results to return in one page of a List operation.
MaxResults *int32
// Name of a subscriber. The first character must be alphanumeric; the remaining
// characters may also include '.', '-', and '_'.
NamePrefix *string
// Opaque pagination token returned by a List operation. Pass it back in the next
// request to retrieve the next page of results.
NextToken *string
// contains filtered or unexported fields
}
func (*ListSubscribersInput) Serialize ¶
func (v *ListSubscribersInput) Serialize(s smithy.ShapeSerializer)
func (*ListSubscribersInput) SerializeMembers ¶
func (v *ListSubscribersInput) SerializeMembers(s smithy.ShapeSerializer)
type ListSubscribersOutput ¶
type ListSubscribersOutput struct {
// Opaque pagination token returned by a List operation. Pass it back in the next
// request to retrieve the next page of results.
NextToken *string
// List of subscriber summaries.
Subscribers []types.SubscriberSummary
// Metadata pertaining to the operation's result.
ResultMetadata middleware.Metadata
// contains filtered or unexported fields
}
func (*ListSubscribersOutput) Deserialize ¶
func (v *ListSubscribersOutput) Deserialize(d smithy.ShapeDeserializer) error
func (*ListSubscribersOutput) Serialize ¶
func (v *ListSubscribersOutput) Serialize(s smithy.ShapeSerializer)
func (*ListSubscribersOutput) SerializeMembers ¶
func (v *ListSubscribersOutput) SerializeMembers(s smithy.ShapeSerializer)
type ListSubscribersPaginator ¶
type ListSubscribersPaginator struct {
// contains filtered or unexported fields
}
ListSubscribersPaginator is a paginator for ListSubscribers
func NewListSubscribersPaginator ¶
func NewListSubscribersPaginator(client ListSubscribersAPIClient, params *ListSubscribersInput, optFns ...func(*ListSubscribersPaginatorOptions)) *ListSubscribersPaginator
NewListSubscribersPaginator returns a new ListSubscribersPaginator
func (*ListSubscribersPaginator) HasMorePages ¶
func (p *ListSubscribersPaginator) HasMorePages() bool
HasMorePages returns a boolean indicating whether more pages are available
func (*ListSubscribersPaginator) NextPage ¶
func (p *ListSubscribersPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*ListSubscribersOutput, error)
NextPage retrieves the next ListSubscribers page.
type ListSubscribersPaginatorOptions ¶
type ListSubscribersPaginatorOptions struct {
// Maximum number of results to return in one page of a List operation.
Limit int32
// Set to true if pagination should stop if the service returns a pagination token
// that matches the most recent token provided to the service.
StopOnDuplicateToken bool
}
ListSubscribersPaginatorOptions is the paginator options for ListSubscribers
type ListTagsForResourceInput ¶
type ListTagsForResourceInput struct {
// ARN for an EventBridge resource that supports tagging: event buses,
// subscribers, and event sources.
//
// This member is required.
ResourceArn *string
// contains filtered or unexported fields
}
func (*ListTagsForResourceInput) Serialize ¶
func (v *ListTagsForResourceInput) Serialize(s smithy.ShapeSerializer)
func (*ListTagsForResourceInput) SerializeMembers ¶
func (v *ListTagsForResourceInput) SerializeMembers(s smithy.ShapeSerializer)
type ListTagsForResourceOutput ¶
type ListTagsForResourceOutput struct {
// Tags attached to a resource, as key-value pairs.
Tags map[string]string
// Metadata pertaining to the operation's result.
ResultMetadata middleware.Metadata
// contains filtered or unexported fields
}
func (*ListTagsForResourceOutput) Deserialize ¶
func (v *ListTagsForResourceOutput) Deserialize(d smithy.ShapeDeserializer) error
func (*ListTagsForResourceOutput) Serialize ¶
func (v *ListTagsForResourceOutput) Serialize(s smithy.ShapeSerializer)
func (*ListTagsForResourceOutput) SerializeMembers ¶
func (v *ListTagsForResourceOutput) SerializeMembers(s smithy.ShapeSerializer)
type Options ¶
type Options struct {
// Set of options to modify how an operation is invoked. These apply to all
// operations invoked for this client. Use functional options on operation call to
// modify this list for per operation behavior.
APIOptions []func(*middleware.Stack) error
// Indicates how aws account ID is applied in endpoint2.0 routing
AccountIDEndpointMode aws.AccountIDEndpointMode
// The optional application specific identifier appended to the User-Agent header.
AppID string
// This endpoint will be given as input to an EndpointResolverV2. It is used for
// providing a custom base endpoint that is subject to modifications by the
// processing EndpointResolverV2.
BaseEndpoint *string
// Configures the events that will be sent to the configured logger.
ClientLogMode aws.ClientLogMode
// The credentials object to use when signing requests.
Credentials aws.CredentialsProvider
// The configuration DefaultsMode that the SDK should use when constructing the
// clients initial default settings.
DefaultsMode aws.DefaultsMode
// Disables SDK clock skew correction. When set, the SDK will not adjust request
// signing timestamps to compensate for clock drift between the client and the
// service.
DisableClockSkewCorrection bool
// The endpoint options to be used when attempting to resolve an endpoint.
EndpointOptions EndpointResolverOptions
// The service endpoint resolver.
//
// Deprecated: Deprecated: EndpointResolver and WithEndpointResolver. Providing a
// value for this field will likely prevent you from using any endpoint-related
// service features released after the introduction of EndpointResolverV2 and
// BaseEndpoint.
//
// To migrate an EndpointResolver implementation that uses a custom endpoint, set
// the client option BaseEndpoint instead.
EndpointResolver EndpointResolver
// Resolves the endpoint used for a particular service operation.
EndpointResolverV2 EndpointResolverV2
// Signature Version 4 (SigV4) Signer
HTTPSignerV4 HTTPSignerV4
// Provides idempotency tokens values that will be automatically populated into
// idempotent API operations.
IdempotencyTokenProvider IdempotencyTokenProvider
// The logger writer interface to write logging messages to.
Logger logging.Logger
// The client meter provider.
MeterProvider metrics.MeterProvider
// The region to send requests to. (Required)
Region string
// RetryMaxAttempts specifies the maximum number attempts an API client will call
// an operation that fails with a retryable error. A value of 0 is ignored, and
// will not be used to configure the API client created default retryer, or modify
// per operation call's retry max attempts.
//
// If specified in an operation call's functional options with a value that is
// different than the constructed client's Options, the Client's Retryer will be
// wrapped to use the operation's specific RetryMaxAttempts value.
RetryMaxAttempts int
// RetryMode specifies the retry mode the API client will be created with, if
// Retryer option is not also specified.
//
// When creating a new API Clients this member will only be used if the Retryer
// Options member is nil. This value will be ignored if Retryer is not nil.
//
// Currently does not support per operation call overrides, may in the future.
RetryMode aws.RetryMode
// Retryer guides how HTTP requests should be retried in case of recoverable
// failures. When nil the API client will use a default retryer. The kind of
// default retry created by the API client can be changed with the RetryMode
// option.
Retryer aws.Retryer
// The RuntimeEnvironment configuration, only populated if the DefaultsMode is set
// to DefaultsModeAuto and is initialized using config.LoadDefaultConfig . You
// should not populate this structure programmatically, or rely on the values here
// within your applications.
RuntimeEnvironment aws.RuntimeEnvironment
// The client tracer provider.
TracerProvider tracing.TracerProvider
Protocol smithyhttp.ClientProtocol
// The HTTP client to invoke API calls with. Defaults to client's default HTTP
// implementation if nil.
HTTPClient HTTPClient
// Client registry of operation interceptors.
Interceptors smithyhttp.InterceptorRegistry
// The auth scheme resolver which determines how to authenticate for each
// operation.
AuthSchemeResolver AuthSchemeResolver
// The list of auth schemes supported by the client.
AuthSchemes []smithyhttp.AuthScheme
// Priority list of preferred auth scheme names (e.g. sigv4a).
AuthSchemePreference []string
// contains filtered or unexported fields
}
func (Options) GetIdentityResolver ¶
func (o Options) GetIdentityResolver(schemeID string) smithyauth.IdentityResolver
type PutEventsInput ¶
type PutEventsInput struct {
// List of event entries to publish. Must contain at least one entry.
//
// This member is required.
Entries []types.PutEventsRequestEntry
// The Amazon Resource Name (ARN) that uniquely identifies an event bus.
//
// This member is required.
EventBusArn *string
// Request-level deduplication settings, applied to every entry in the batch.
DeduplicationConfiguration *types.DeduplicationConfiguration
// contains filtered or unexported fields
}
func (*PutEventsInput) Serialize ¶
func (v *PutEventsInput) Serialize(s smithy.ShapeSerializer)
func (*PutEventsInput) SerializeMembers ¶
func (v *PutEventsInput) SerializeMembers(s smithy.ShapeSerializer)
type PutEventsOutput ¶
type PutEventsOutput struct {
// List of per-entry publish results, in the same order as the request entries.
Entries []types.PutEventsResultEntry
// The number of entries in the batch that failed to be published.
FailedEntryCount int32
// Metadata pertaining to the operation's result.
ResultMetadata middleware.Metadata
// contains filtered or unexported fields
}
func (*PutEventsOutput) Deserialize ¶
func (v *PutEventsOutput) Deserialize(d smithy.ShapeDeserializer) error
func (*PutEventsOutput) Serialize ¶
func (v *PutEventsOutput) Serialize(s smithy.ShapeSerializer)
func (*PutEventsOutput) SerializeMembers ¶
func (v *PutEventsOutput) SerializeMembers(s smithy.ShapeSerializer)
type PutRawEventsInput ¶
type PutRawEventsInput struct {
// List of event entries to publish. Must contain at least one entry.
//
// This member is required.
Entries []types.PutRawEventsRequestEntry
// The Amazon Resource Name (ARN) that uniquely identifies an event bus.
//
// This member is required.
EventBusArn *string
// Request-level deduplication settings, applied to every entry in the batch.
DeduplicationConfiguration *types.DeduplicationConfiguration
// Schema-registry settings for encoding open-format (Avro/Protobuf) events.
// Required for open-format entries; ignored for JSON entries. The registry is read
// with the caller's credentials, so the caller needs read access to the registry
// it references.
SchemaRegistryConfiguration *types.SchemaRegistryConfiguration
// contains filtered or unexported fields
}
func (*PutRawEventsInput) Serialize ¶
func (v *PutRawEventsInput) Serialize(s smithy.ShapeSerializer)
func (*PutRawEventsInput) SerializeMembers ¶
func (v *PutRawEventsInput) SerializeMembers(s smithy.ShapeSerializer)
type PutRawEventsOutput ¶
type PutRawEventsOutput struct {
// List of per-entry publish results, in the same order as the request entries.
Entries []types.PutRawEventsResultEntry
// The number of entries in the batch that failed to be published.
FailedEntryCount int32
// Metadata pertaining to the operation's result.
ResultMetadata middleware.Metadata
// contains filtered or unexported fields
}
func (*PutRawEventsOutput) Deserialize ¶
func (v *PutRawEventsOutput) Deserialize(d smithy.ShapeDeserializer) error
func (*PutRawEventsOutput) Serialize ¶
func (v *PutRawEventsOutput) Serialize(s smithy.ShapeSerializer)
func (*PutRawEventsOutput) SerializeMembers ¶
func (v *PutRawEventsOutput) SerializeMembers(s smithy.ShapeSerializer)
type PutResourcePolicyInput ¶
type PutResourcePolicyInput struct {
// A resource policy document, as a JSON string. The "default" policy can be up to
// 20 KB (20,480 bytes of UTF-8) by default. This quota is adjustable in Service
// Quotas. A "default" policy that exceeds the quota is rejected with
// PolicyLengthExceededException. No policy document can exceed 389,120 bytes of
// UTF-8, regardless of the quota.
//
// This member is required.
PolicyDocument *string
// The Amazon Resource Name (ARN) that uniquely identifies an event bus.
//
// This member is required.
ResourceArn *string
// The write succeeds only if the named policy's current revision ID matches this
// value; a policy that does not exist yet matches only the sentinel "NO_POLICY"
// (create-only). On mismatch the operation fails with ConflictException. When
// omitted, the write is unconditional. Every attempt stores a newly generated
// revision ID, so retrying an unanswered request can conflict with the caller's
// own earlier attempt; read the policy back and compare it with the one you
// intended before treating a conflict as another writer's change.
ExpectedRevisionId *string
// Which named policy to write. Defaults to "default", the customer-managed
// policy, when omitted (a write AWS Resource Access Manager makes on the owner's
// behalf resolves to "AWS_RAM" instead). The two writers are exclusive in both
// directions — only Resource Access Manager can write "AWS_RAM", and only the bus
// owner can write "default" — so naming the other party's policy fails with
// AccessDeniedException. A well-formed name that is neither of the two fails with
// InvalidInputException.
PolicyName *string
// contains filtered or unexported fields
}
func (*PutResourcePolicyInput) Serialize ¶
func (v *PutResourcePolicyInput) Serialize(s smithy.ShapeSerializer)
func (*PutResourcePolicyInput) SerializeMembers ¶
func (v *PutResourcePolicyInput) SerializeMembers(s smithy.ShapeSerializer)
type PutResourcePolicyOutput ¶
type PutResourcePolicyOutput struct {
// Name of a policy attached to a resource. Valid values: "default" (the
// customer-managed policy) and "AWS_RAM" (managed exclusively by AWS Resource
// Access Manager). Any other value is rejected.
//
// This member is required.
PolicyName *string
// The Amazon Resource Name (ARN) that uniquely identifies an event bus.
//
// This member is required.
ResourceArn *string
// Absent when the write removed the policy; a removal produces no new revision.
RevisionId *string
// Metadata pertaining to the operation's result.
ResultMetadata middleware.Metadata
// contains filtered or unexported fields
}
func (*PutResourcePolicyOutput) Deserialize ¶
func (v *PutResourcePolicyOutput) Deserialize(d smithy.ShapeDeserializer) error
func (*PutResourcePolicyOutput) Serialize ¶
func (v *PutResourcePolicyOutput) Serialize(s smithy.ShapeSerializer)
func (*PutResourcePolicyOutput) SerializeMembers ¶
func (v *PutResourcePolicyOutput) SerializeMembers(s smithy.ShapeSerializer)
type ResolveEndpoint ¶
type ResolveEndpoint struct {
Resolver EndpointResolver
Options EndpointResolverOptions
}
func (*ResolveEndpoint) HandleSerialize ¶
func (m *ResolveEndpoint) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) ( out middleware.SerializeOutput, metadata middleware.Metadata, err error, )
func (*ResolveEndpoint) ID ¶
func (*ResolveEndpoint) ID() string
type RevokeResourceInput ¶
type RevokeResourceInput struct {
// ARN of a resource a bus owner can revoke: a subscriber or an EventSource. The
// pattern is the revocable subset of TaggableResourceArn; buses are not revocable.
//
// This member is required.
Arn *string
// contains filtered or unexported fields
}
func (*RevokeResourceInput) Serialize ¶
func (v *RevokeResourceInput) Serialize(s smithy.ShapeSerializer)
func (*RevokeResourceInput) SerializeMembers ¶
func (v *RevokeResourceInput) SerializeMembers(s smithy.ShapeSerializer)
type RevokeResourceOutput ¶
type RevokeResourceOutput struct {
// ARN of a resource a bus owner can revoke: a subscriber or an EventSource. The
// pattern is the revocable subset of TaggableResourceArn; buses are not revocable.
Arn *string
// Metadata pertaining to the operation's result.
ResultMetadata middleware.Metadata
// contains filtered or unexported fields
}
func (*RevokeResourceOutput) Deserialize ¶
func (v *RevokeResourceOutput) Deserialize(d smithy.ShapeDeserializer) error
func (*RevokeResourceOutput) Serialize ¶
func (v *RevokeResourceOutput) Serialize(s smithy.ShapeSerializer)
func (*RevokeResourceOutput) SerializeMembers ¶
func (v *RevokeResourceOutput) SerializeMembers(s smithy.ShapeSerializer)
type TagResourceInput ¶
type TagResourceInput struct {
// ARN for an EventBridge resource that supports tagging: event buses,
// subscribers, and event sources.
//
// This member is required.
ResourceArn *string
// Tags attached to a resource, as key-value pairs.
//
// This member is required.
Tags map[string]string
// contains filtered or unexported fields
}
func (*TagResourceInput) Serialize ¶
func (v *TagResourceInput) Serialize(s smithy.ShapeSerializer)
func (*TagResourceInput) SerializeMembers ¶
func (v *TagResourceInput) SerializeMembers(s smithy.ShapeSerializer)
type TagResourceOutput ¶
type TagResourceOutput struct {
// Metadata pertaining to the operation's result.
ResultMetadata middleware.Metadata
// contains filtered or unexported fields
}
func (*TagResourceOutput) Deserialize ¶
func (v *TagResourceOutput) Deserialize(d smithy.ShapeDeserializer) error
func (*TagResourceOutput) Serialize ¶
func (v *TagResourceOutput) Serialize(s smithy.ShapeSerializer)
func (*TagResourceOutput) SerializeMembers ¶
func (v *TagResourceOutput) SerializeMembers(s smithy.ShapeSerializer)
type UntagResourceInput ¶
type UntagResourceInput struct {
// ARN for an EventBridge resource that supports tagging: event buses,
// subscribers, and event sources.
//
// This member is required.
ResourceArn *string
// List of tag keys.
//
// This member is required.
TagKeys []string
// contains filtered or unexported fields
}
func (*UntagResourceInput) Serialize ¶
func (v *UntagResourceInput) Serialize(s smithy.ShapeSerializer)
func (*UntagResourceInput) SerializeMembers ¶
func (v *UntagResourceInput) SerializeMembers(s smithy.ShapeSerializer)
type UntagResourceOutput ¶
type UntagResourceOutput struct {
// Metadata pertaining to the operation's result.
ResultMetadata middleware.Metadata
// contains filtered or unexported fields
}
func (*UntagResourceOutput) Deserialize ¶
func (v *UntagResourceOutput) Deserialize(d smithy.ShapeDeserializer) error
func (*UntagResourceOutput) Serialize ¶
func (v *UntagResourceOutput) Serialize(s smithy.ShapeSerializer)
func (*UntagResourceOutput) SerializeMembers ¶
func (v *UntagResourceOutput) SerializeMembers(s smithy.ShapeSerializer)
type UpdateEventBusInput ¶
type UpdateEventBusInput struct {
// The Amazon Resource Name (ARN) that uniquely identifies an event bus.
//
// This member is required.
EventBusArn *string
// Free-text description. Used by every resource type that has one: event buses,
// subscribers, and event sources.
Description *string
// Encryption configuration for an event bus.
EncryptionConfiguration *types.EncryptionConfiguration
// Event storage configuration for an event bus.
StorageConfiguration *types.StorageConfiguration
// contains filtered or unexported fields
}
func (*UpdateEventBusInput) Serialize ¶
func (v *UpdateEventBusInput) Serialize(s smithy.ShapeSerializer)
func (*UpdateEventBusInput) SerializeMembers ¶
func (v *UpdateEventBusInput) SerializeMembers(s smithy.ShapeSerializer)
type UpdateEventBusOutput ¶
type UpdateEventBusOutput struct {
// Free-text description. Used by every resource type that has one: event buses,
// subscribers, and event sources.
Description *string
// Encryption configuration for an event bus.
EncryptionConfiguration *types.EncryptionConfiguration
// The Amazon Resource Name (ARN) that uniquely identifies an event bus.
EventBusArn *string
// The time the event bus was last modified.
LastModifiedTime *time.Time
// Name of an event bus. The first character must be alphanumeric; the remaining
// characters may also include '.', '-', and '_'. The grammar matches the name
// segment of EventBusArn (event-busv2//), so every valid name can be represented
// in the bus's ARN. The same type is used everywhere a bus name appears.
Name *string
// Lifecycle state of an event bus.
//
// - CREATING: Bus creation is in progress.
// - CREATE_FAILED: Bus creation failed; see StateReason. The bus cannot be
// recovered or recreated in place: delete it with DeleteEventBus, then create a
// new bus.
// - ACTIVE: Bus is fully operational and can accept events.
// - UPDATING: Bus update is in progress.
// - UPDATE_FAILED: Bus update failed; the bus remains operational with its
// previous configuration.
// - DELETING: Bus deletion is actively in progress.
// - DELETE_FAILED: Bus deletion failed; see StateReason. Retry DeleteEventBus
// after removing subscribers and event sources.
State types.BusState
// Human-readable explanation of why an event bus is in its current State. Omitted
// when the bus is in a normal operational state (ACTIVE). It stands in for the
// error response an asynchronous failure cannot return, so it applies only to
// resources with an asynchronous lifecycle: event buses. EventSources and
// subscribers are provisioned synchronously and report failures directly on the
// request.
StateReason *string
// Event storage configuration of an event bus, as returned on reads.
StorageConfiguration *types.StorageConfigurationOutput
// Metadata pertaining to the operation's result.
ResultMetadata middleware.Metadata
// contains filtered or unexported fields
}
func (*UpdateEventBusOutput) Deserialize ¶
func (v *UpdateEventBusOutput) Deserialize(d smithy.ShapeDeserializer) error
func (*UpdateEventBusOutput) Serialize ¶
func (v *UpdateEventBusOutput) Serialize(s smithy.ShapeSerializer)
func (*UpdateEventBusOutput) SerializeMembers ¶
func (v *UpdateEventBusOutput) SerializeMembers(s smithy.ShapeSerializer)
type UpdateEventSourceInput ¶
type UpdateEventSourceInput struct {
// EventSource ARN: event-sourcev2///. The type segment is set by the service
// (aws.service for AWS service events, aws.partner for partner events) and is not
// part of the resource's name. The id segment is a 25-character identifier
// generated by the service.
//
// This member is required.
EventSourceArn *string
// Discriminated EventSource configuration. Exactly one variant must be set.
Configuration types.EventSourceConfiguration
// Free-text description. Used by every resource type that has one: event buses,
// subscribers, and event sources.
Description *string
// contains filtered or unexported fields
}
func (*UpdateEventSourceInput) Serialize ¶
func (v *UpdateEventSourceInput) Serialize(s smithy.ShapeSerializer)
func (*UpdateEventSourceInput) SerializeMembers ¶
func (v *UpdateEventSourceInput) SerializeMembers(s smithy.ShapeSerializer)
type UpdateEventSourceOutput ¶
type UpdateEventSourceOutput struct {
// The Amazon Resource Name (ARN) that uniquely identifies an event bus.
EventBusArn *string
// EventSource ARN: event-sourcev2///. The type segment is set by the service
// (aws.service for AWS service events, aws.partner for partner events) and is not
// part of the resource's name. The id segment is a 25-character identifier
// generated by the service.
EventSourceArn *string
// The time the EventSource was last modified.
LastModifiedTime *time.Time
// EventSource name. First character alphanumeric; the rest may add '.', '-', '_'.
// Names may not begin with the reserved "aws." prefix. The grammar matches the ARN
// local-name segment in EventSourceArn (event-sourcev2///), mirroring
// EventBusName, so a name the ARN cannot represent cannot be created.
Name *string
// Lifecycle state of an EventSource. Revocation is reported by the Revoked flag.
State types.EventSourceState
// Metadata pertaining to the operation's result.
ResultMetadata middleware.Metadata
// contains filtered or unexported fields
}
func (*UpdateEventSourceOutput) Deserialize ¶
func (v *UpdateEventSourceOutput) Deserialize(d smithy.ShapeDeserializer) error
func (*UpdateEventSourceOutput) Serialize ¶
func (v *UpdateEventSourceOutput) Serialize(s smithy.ShapeSerializer)
func (*UpdateEventSourceOutput) SerializeMembers ¶
func (v *UpdateEventSourceOutput) SerializeMembers(s smithy.ShapeSerializer)
type UpdateSubscriberInput ¶
type UpdateSubscriberInput struct {
// The Amazon Resource Name (ARN) that uniquely identifies a subscriber.
//
// This member is required.
SubscriberArn *string
// Batching configuration for a subscriber.
BatchConfiguration *types.BatchConfiguration
// Free-text description. Used by every resource type that has one: event buses,
// subscribers, and event sources.
Description *string
// Configuration for filtering events delivered to a subscriber. On
// CreateSubscriber, Filters is required and must contain at least one Filter with
// a non-empty Pattern. On UpdateSubscriber, an empty FilterConfiguration:{}
// clears the existing filter. Any non-empty shape (including {Language:X} without
// Filters) must contain a valid Filters list — same contract as CreateSubscriber.
// A non-empty Filters list overwrites; an omitted FilterConfiguration preserves
// existing state. All Filters are implicitly ANDed — an event must match every
// Filter to be delivered.
FilterConfiguration *types.FilterConfiguration
// Update-able configuration for how the subscriber invokes its target.
InvokeConfiguration *types.UpdateInvokeConfiguration
// Log configuration for a subscriber.
LogConfiguration *types.LogConfiguration
// On-failure configuration: where a failed delivery is sent. Shared by the
// subscriber and the EventSource.
OnFailureConfiguration *types.OnFailureConfiguration
// Position from which delivery resumes when a subscriber is unpaused. Honored
// only on an UpdateSubscriber call that transitions State from STOPPED to RUNNING
// (unpause); ignored on any other call and not accepted on Create. Defaults to
// LAST_PROCESSED when omitted.
ResumePosition types.ResumePosition
// Retry policy for a subscriber.
RetryPolicy *types.RetryPolicy
// Customer-controlled run state of a subscriber, set on create or update.
// Distinct from the bus lifecycle vocabulary, where ACTIVE means "provisioned and
// healthy". Delivery requires State RUNNING on a subscriber that is not revoked.
State types.SubscriberState
// Not applicable to universal (aws-sdk) targets, whose input transformation is
// UniversalTargetParameters.Input; a Transformer on such a target is rejected.
Transformer *types.Transformer
// contains filtered or unexported fields
}
func (*UpdateSubscriberInput) Serialize ¶
func (v *UpdateSubscriberInput) Serialize(s smithy.ShapeSerializer)
func (*UpdateSubscriberInput) SerializeMembers ¶
func (v *UpdateSubscriberInput) SerializeMembers(s smithy.ShapeSerializer)
type UpdateSubscriberOutput ¶
type UpdateSubscriberOutput struct {
// The Amazon Resource Name (ARN) that uniquely identifies an event bus.
EventBusArn *string
// The time the subscriber was last modified.
LastModifiedTime *time.Time
// Name of a subscriber. The first character must be alphanumeric; the remaining
// characters may also include '.', '-', and '_'.
Name *string
// Point-in-time configuration for a subscriber. Only applicable when
// StartingPosition is POINT_IN_TIME.
PointInTimeConfiguration *types.PointInTimeConfiguration
// Starting position for a subscriber.
StartingPosition types.StartingPosition
// Customer-controlled run state of a subscriber, set on create or update.
// Distinct from the bus lifecycle vocabulary, where ACTIVE means "provisioned and
// healthy". Delivery requires State RUNNING on a subscriber that is not revoked.
State types.SubscriberState
// The Amazon Resource Name (ARN) that uniquely identifies a subscriber.
SubscriberArn *string
// Delivery ordering mode of a subscriber: FIFO delivers events in order within an
// event group; UNORDERED delivers without an ordering guarantee.
Type types.OrderingType
// Metadata pertaining to the operation's result.
ResultMetadata middleware.Metadata
// contains filtered or unexported fields
}
func (*UpdateSubscriberOutput) Deserialize ¶
func (v *UpdateSubscriberOutput) Deserialize(d smithy.ShapeDeserializer) error
func (*UpdateSubscriberOutput) Serialize ¶
func (v *UpdateSubscriberOutput) Serialize(s smithy.ShapeSerializer)
func (*UpdateSubscriberOutput) SerializeMembers ¶
func (v *UpdateSubscriberOutput) SerializeMembers(s smithy.ShapeSerializer)
Source Files
¶
- api_client.go
- api_op_CreateEventBus.go
- api_op_CreateEventSource.go
- api_op_CreateSubscriber.go
- api_op_DeleteEventBus.go
- api_op_DeleteEventSource.go
- api_op_DeleteResourcePolicy.go
- api_op_DeleteSubscriber.go
- api_op_DescribeEventBus.go
- api_op_DescribeEventSource.go
- api_op_DescribeSubscriber.go
- api_op_GetResourcePolicy.go
- api_op_ListEventBuses.go
- api_op_ListEventSources.go
- api_op_ListResourcePolicies.go
- api_op_ListSubscribers.go
- api_op_ListTagsForResource.go
- api_op_PutEvents.go
- api_op_PutRawEvents.go
- api_op_PutResourcePolicy.go
- api_op_RevokeResource.go
- api_op_TagResource.go
- api_op_UntagResource.go
- api_op_UpdateEventBus.go
- api_op_UpdateEventSource.go
- api_op_UpdateSubscriber.go
- auth.go
- common_serde.go
- doc.go
- endpoints.go
- go_module_metadata.go
- options.go
- type_registry.go
- validators.go