Documentation
¶
Index ¶
- type Acks
- type ApiDestinations
- type ApiDestinationsItem
- type ApiKeyAuthParameters
- type ApiParametersInGetApiDestination
- type ApiParametersInListApiDestinations
- type ApiParametersItem
- type AuthParameters
- type BasicAuthParameters
- type BatchWindow
- type Body
- type BodyParametersInGetConnection
- type BodyParametersInListConnections
- type BodyParametersItem
- type Client
- func NewClient() (client *Client, err error)
- func NewClientWithAccessKey(regionId, accessKeyId, accessKeySecret string) (client *Client, err error)
- func NewClientWithEcsRamRole(regionId string, roleName string) (client *Client, err error)
- func NewClientWithOptions(regionId string, config *sdk.Config, credential auth.Credential) (client *Client, err error)
- func NewClientWithProvider(regionId string, providers ...provider.Provider) (client *Client, err error)
- func NewClientWithRamRoleArn(regionId string, accessKeyId, accessKeySecret, roleArn, roleSessionName string) (client *Client, err error)
- func NewClientWithRamRoleArnAndPolicy(regionId string, ...) (client *Client, err error)
- func NewClientWithRsaKeyPair(regionId string, publicKeyId, privateKey string, sessionExpiration int) (client *Client, err error)
- func NewClientWithStsToken(regionId, stsAccessKeyId, stsAccessKeySecret, stsToken string) (client *Client, err error)
- func (client *Client) CreateApiDestination(request *CreateApiDestinationRequest) (response *CreateApiDestinationResponse, err error)
- func (client *Client) CreateApiDestinationWithCallback(request *CreateApiDestinationRequest, ...) <-chan int
- func (client *Client) CreateApiDestinationWithChan(request *CreateApiDestinationRequest) (<-chan *CreateApiDestinationResponse, <-chan error)
- func (client *Client) CreateConnection(request *CreateConnectionRequest) (response *CreateConnectionResponse, err error)
- func (client *Client) CreateConnectionWithCallback(request *CreateConnectionRequest, ...) <-chan int
- func (client *Client) CreateConnectionWithChan(request *CreateConnectionRequest) (<-chan *CreateConnectionResponse, <-chan error)
- func (client *Client) CreateEventBus(request *CreateEventBusRequest) (response *CreateEventBusResponse, err error)
- func (client *Client) CreateEventBusWithCallback(request *CreateEventBusRequest, ...) <-chan int
- func (client *Client) CreateEventBusWithChan(request *CreateEventBusRequest) (<-chan *CreateEventBusResponse, <-chan error)
- func (client *Client) CreateEventSource(request *CreateEventSourceRequest) (response *CreateEventSourceResponse, err error)
- func (client *Client) CreateEventSourceWithCallback(request *CreateEventSourceRequest, ...) <-chan int
- func (client *Client) CreateEventSourceWithChan(request *CreateEventSourceRequest) (<-chan *CreateEventSourceResponse, <-chan error)
- func (client *Client) CreateEventStreaming(request *CreateEventStreamingRequest) (response *CreateEventStreamingResponse, err error)
- func (client *Client) CreateEventStreamingWithCallback(request *CreateEventStreamingRequest, ...) <-chan int
- func (client *Client) CreateEventStreamingWithChan(request *CreateEventStreamingRequest) (<-chan *CreateEventStreamingResponse, <-chan error)
- func (client *Client) CreateRule(request *CreateRuleRequest) (response *CreateRuleResponse, err error)
- func (client *Client) CreateRuleWithCallback(request *CreateRuleRequest, ...) <-chan int
- func (client *Client) CreateRuleWithChan(request *CreateRuleRequest) (<-chan *CreateRuleResponse, <-chan error)
- func (client *Client) CreateServiceLinkedRoleForProduct(request *CreateServiceLinkedRoleForProductRequest) (response *CreateServiceLinkedRoleForProductResponse, err error)
- func (client *Client) CreateServiceLinkedRoleForProductWithCallback(request *CreateServiceLinkedRoleForProductRequest, ...) <-chan int
- func (client *Client) CreateServiceLinkedRoleForProductWithChan(request *CreateServiceLinkedRoleForProductRequest) (<-chan *CreateServiceLinkedRoleForProductResponse, <-chan error)
- func (client *Client) DeleteApiDestination(request *DeleteApiDestinationRequest) (response *DeleteApiDestinationResponse, err error)
- func (client *Client) DeleteApiDestinationWithCallback(request *DeleteApiDestinationRequest, ...) <-chan int
- func (client *Client) DeleteApiDestinationWithChan(request *DeleteApiDestinationRequest) (<-chan *DeleteApiDestinationResponse, <-chan error)
- func (client *Client) DeleteConnection(request *DeleteConnectionRequest) (response *DeleteConnectionResponse, err error)
- func (client *Client) DeleteConnectionWithCallback(request *DeleteConnectionRequest, ...) <-chan int
- func (client *Client) DeleteConnectionWithChan(request *DeleteConnectionRequest) (<-chan *DeleteConnectionResponse, <-chan error)
- func (client *Client) DeleteEventBus(request *DeleteEventBusRequest) (response *DeleteEventBusResponse, err error)
- func (client *Client) DeleteEventBusWithCallback(request *DeleteEventBusRequest, ...) <-chan int
- func (client *Client) DeleteEventBusWithChan(request *DeleteEventBusRequest) (<-chan *DeleteEventBusResponse, <-chan error)
- func (client *Client) DeleteEventSource(request *DeleteEventSourceRequest) (response *DeleteEventSourceResponse, err error)
- func (client *Client) DeleteEventSourceWithCallback(request *DeleteEventSourceRequest, ...) <-chan int
- func (client *Client) DeleteEventSourceWithChan(request *DeleteEventSourceRequest) (<-chan *DeleteEventSourceResponse, <-chan error)
- func (client *Client) DeleteEventStreaming(request *DeleteEventStreamingRequest) (response *DeleteEventStreamingResponse, err error)
- func (client *Client) DeleteEventStreamingWithCallback(request *DeleteEventStreamingRequest, ...) <-chan int
- func (client *Client) DeleteEventStreamingWithChan(request *DeleteEventStreamingRequest) (<-chan *DeleteEventStreamingResponse, <-chan error)
- func (client *Client) DeleteRule(request *DeleteRuleRequest) (response *DeleteRuleResponse, err error)
- func (client *Client) DeleteRuleWithCallback(request *DeleteRuleRequest, ...) <-chan int
- func (client *Client) DeleteRuleWithChan(request *DeleteRuleRequest) (<-chan *DeleteRuleResponse, <-chan error)
- func (client *Client) DeleteTargets(request *DeleteTargetsRequest) (response *DeleteTargetsResponse, err error)
- func (client *Client) DeleteTargetsWithCallback(request *DeleteTargetsRequest, ...) <-chan int
- func (client *Client) DeleteTargetsWithChan(request *DeleteTargetsRequest) (<-chan *DeleteTargetsResponse, <-chan error)
- func (client *Client) DisableRule(request *DisableRuleRequest) (response *DisableRuleResponse, err error)
- func (client *Client) DisableRuleWithCallback(request *DisableRuleRequest, ...) <-chan int
- func (client *Client) DisableRuleWithChan(request *DisableRuleRequest) (<-chan *DisableRuleResponse, <-chan error)
- func (client *Client) EnableRule(request *EnableRuleRequest) (response *EnableRuleResponse, err error)
- func (client *Client) EnableRuleWithCallback(request *EnableRuleRequest, ...) <-chan int
- func (client *Client) EnableRuleWithChan(request *EnableRuleRequest) (<-chan *EnableRuleResponse, <-chan error)
- func (client *Client) GetApiDestination(request *GetApiDestinationRequest) (response *GetApiDestinationResponse, err error)
- func (client *Client) GetApiDestinationWithCallback(request *GetApiDestinationRequest, ...) <-chan int
- func (client *Client) GetApiDestinationWithChan(request *GetApiDestinationRequest) (<-chan *GetApiDestinationResponse, <-chan error)
- func (client *Client) GetConnection(request *GetConnectionRequest) (response *GetConnectionResponse, err error)
- func (client *Client) GetConnectionWithCallback(request *GetConnectionRequest, ...) <-chan int
- func (client *Client) GetConnectionWithChan(request *GetConnectionRequest) (<-chan *GetConnectionResponse, <-chan error)
- func (client *Client) GetEventBus(request *GetEventBusRequest) (response *GetEventBusResponse, err error)
- func (client *Client) GetEventBusWithCallback(request *GetEventBusRequest, ...) <-chan int
- func (client *Client) GetEventBusWithChan(request *GetEventBusRequest) (<-chan *GetEventBusResponse, <-chan error)
- func (client *Client) GetEventStreaming(request *GetEventStreamingRequest) (response *GetEventStreamingResponse, err error)
- func (client *Client) GetEventStreamingWithCallback(request *GetEventStreamingRequest, ...) <-chan int
- func (client *Client) GetEventStreamingWithChan(request *GetEventStreamingRequest) (<-chan *GetEventStreamingResponse, <-chan error)
- func (client *Client) GetRule(request *GetRuleRequest) (response *GetRuleResponse, err error)
- func (client *Client) GetRuleWithCallback(request *GetRuleRequest, callback func(response *GetRuleResponse, err error)) <-chan int
- func (client *Client) GetRuleWithChan(request *GetRuleRequest) (<-chan *GetRuleResponse, <-chan error)
- func (client *Client) ListAliyunOfficialEventSources(request *ListAliyunOfficialEventSourcesRequest) (response *ListAliyunOfficialEventSourcesResponse, err error)
- func (client *Client) ListAliyunOfficialEventSourcesWithCallback(request *ListAliyunOfficialEventSourcesRequest, ...) <-chan int
- func (client *Client) ListAliyunOfficialEventSourcesWithChan(request *ListAliyunOfficialEventSourcesRequest) (<-chan *ListAliyunOfficialEventSourcesResponse, <-chan error)
- func (client *Client) ListApiDestinations(request *ListApiDestinationsRequest) (response *ListApiDestinationsResponse, err error)
- func (client *Client) ListApiDestinationsWithCallback(request *ListApiDestinationsRequest, ...) <-chan int
- func (client *Client) ListApiDestinationsWithChan(request *ListApiDestinationsRequest) (<-chan *ListApiDestinationsResponse, <-chan error)
- func (client *Client) ListConnections(request *ListConnectionsRequest) (response *ListConnectionsResponse, err error)
- func (client *Client) ListConnectionsWithCallback(request *ListConnectionsRequest, ...) <-chan int
- func (client *Client) ListConnectionsWithChan(request *ListConnectionsRequest) (<-chan *ListConnectionsResponse, <-chan error)
- func (client *Client) ListEventBuses(request *ListEventBusesRequest) (response *ListEventBusesResponse, err error)
- func (client *Client) ListEventBusesWithCallback(request *ListEventBusesRequest, ...) <-chan int
- func (client *Client) ListEventBusesWithChan(request *ListEventBusesRequest) (<-chan *ListEventBusesResponse, <-chan error)
- func (client *Client) ListEventStreamings(request *ListEventStreamingsRequest) (response *ListEventStreamingsResponse, err error)
- func (client *Client) ListEventStreamingsWithCallback(request *ListEventStreamingsRequest, ...) <-chan int
- func (client *Client) ListEventStreamingsWithChan(request *ListEventStreamingsRequest) (<-chan *ListEventStreamingsResponse, <-chan error)
- func (client *Client) ListRules(request *ListRulesRequest) (response *ListRulesResponse, err error)
- func (client *Client) ListRulesWithCallback(request *ListRulesRequest, ...) <-chan int
- func (client *Client) ListRulesWithChan(request *ListRulesRequest) (<-chan *ListRulesResponse, <-chan error)
- func (client *Client) ListTargets(request *ListTargetsRequest) (response *ListTargetsResponse, err error)
- func (client *Client) ListTargetsWithCallback(request *ListTargetsRequest, ...) <-chan int
- func (client *Client) ListTargetsWithChan(request *ListTargetsRequest) (<-chan *ListTargetsResponse, <-chan error)
- func (client *Client) ListUserDefinedEventSources(request *ListUserDefinedEventSourcesRequest) (response *ListUserDefinedEventSourcesResponse, err error)
- func (client *Client) ListUserDefinedEventSourcesWithCallback(request *ListUserDefinedEventSourcesRequest, ...) <-chan int
- func (client *Client) ListUserDefinedEventSourcesWithChan(request *ListUserDefinedEventSourcesRequest) (<-chan *ListUserDefinedEventSourcesResponse, <-chan error)
- func (client *Client) PauseEventStreaming(request *PauseEventStreamingRequest) (response *PauseEventStreamingResponse, err error)
- func (client *Client) PauseEventStreamingWithCallback(request *PauseEventStreamingRequest, ...) <-chan int
- func (client *Client) PauseEventStreamingWithChan(request *PauseEventStreamingRequest) (<-chan *PauseEventStreamingResponse, <-chan error)
- func (client *Client) PutTargets(request *PutTargetsRequest) (response *PutTargetsResponse, err error)
- func (client *Client) PutTargetsWithCallback(request *PutTargetsRequest, ...) <-chan int
- func (client *Client) PutTargetsWithChan(request *PutTargetsRequest) (<-chan *PutTargetsResponse, <-chan error)
- func (client *Client) QueryEvent(request *QueryEventRequest) (response *QueryEventResponse, err error)
- func (client *Client) QueryEventTraces(request *QueryEventTracesRequest) (response *QueryEventTracesResponse, err error)
- func (client *Client) QueryEventTracesWithCallback(request *QueryEventTracesRequest, ...) <-chan int
- func (client *Client) QueryEventTracesWithChan(request *QueryEventTracesRequest) (<-chan *QueryEventTracesResponse, <-chan error)
- func (client *Client) QueryEventWithCallback(request *QueryEventRequest, ...) <-chan int
- func (client *Client) QueryEventWithChan(request *QueryEventRequest) (<-chan *QueryEventResponse, <-chan error)
- func (client *Client) QueryTracedEventByEventId(request *QueryTracedEventByEventIdRequest) (response *QueryTracedEventByEventIdResponse, err error)
- func (client *Client) QueryTracedEventByEventIdWithCallback(request *QueryTracedEventByEventIdRequest, ...) <-chan int
- func (client *Client) QueryTracedEventByEventIdWithChan(request *QueryTracedEventByEventIdRequest) (<-chan *QueryTracedEventByEventIdResponse, <-chan error)
- func (client *Client) QueryTracedEvents(request *QueryTracedEventsRequest) (response *QueryTracedEventsResponse, err error)
- func (client *Client) QueryTracedEventsWithCallback(request *QueryTracedEventsRequest, ...) <-chan int
- func (client *Client) QueryTracedEventsWithChan(request *QueryTracedEventsRequest) (<-chan *QueryTracedEventsResponse, <-chan error)
- func (client *Client) StartEventStreaming(request *StartEventStreamingRequest) (response *StartEventStreamingResponse, err error)
- func (client *Client) StartEventStreamingWithCallback(request *StartEventStreamingRequest, ...) <-chan int
- func (client *Client) StartEventStreamingWithChan(request *StartEventStreamingRequest) (<-chan *StartEventStreamingResponse, <-chan error)
- func (client *Client) TestEventPattern(request *TestEventPatternRequest) (response *TestEventPatternResponse, err error)
- func (client *Client) TestEventPatternWithCallback(request *TestEventPatternRequest, ...) <-chan int
- func (client *Client) TestEventPatternWithChan(request *TestEventPatternRequest) (<-chan *TestEventPatternResponse, <-chan error)
- func (client *Client) UpdateApiDestination(request *UpdateApiDestinationRequest) (response *UpdateApiDestinationResponse, err error)
- func (client *Client) UpdateApiDestinationWithCallback(request *UpdateApiDestinationRequest, ...) <-chan int
- func (client *Client) UpdateApiDestinationWithChan(request *UpdateApiDestinationRequest) (<-chan *UpdateApiDestinationResponse, <-chan error)
- func (client *Client) UpdateConnection(request *UpdateConnectionRequest) (response *UpdateConnectionResponse, err error)
- func (client *Client) UpdateConnectionWithCallback(request *UpdateConnectionRequest, ...) <-chan int
- func (client *Client) UpdateConnectionWithChan(request *UpdateConnectionRequest) (<-chan *UpdateConnectionResponse, <-chan error)
- func (client *Client) UpdateEventBus(request *UpdateEventBusRequest) (response *UpdateEventBusResponse, err error)
- func (client *Client) UpdateEventBusWithCallback(request *UpdateEventBusRequest, ...) <-chan int
- func (client *Client) UpdateEventBusWithChan(request *UpdateEventBusRequest) (<-chan *UpdateEventBusResponse, <-chan error)
- func (client *Client) UpdateEventSource(request *UpdateEventSourceRequest) (response *UpdateEventSourceResponse, err error)
- func (client *Client) UpdateEventSourceWithCallback(request *UpdateEventSourceRequest, ...) <-chan int
- func (client *Client) UpdateEventSourceWithChan(request *UpdateEventSourceRequest) (<-chan *UpdateEventSourceResponse, <-chan error)
- func (client *Client) UpdateEventStreaming(request *UpdateEventStreamingRequest) (response *UpdateEventStreamingResponse, err error)
- func (client *Client) UpdateEventStreamingWithCallback(request *UpdateEventStreamingRequest, ...) <-chan int
- func (client *Client) UpdateEventStreamingWithChan(request *UpdateEventStreamingRequest) (<-chan *UpdateEventStreamingResponse, <-chan error)
- func (client *Client) UpdateRule(request *UpdateRuleRequest) (response *UpdateRuleResponse, err error)
- func (client *Client) UpdateRuleWithCallback(request *UpdateRuleRequest, ...) <-chan int
- func (client *Client) UpdateRuleWithChan(request *UpdateRuleRequest) (<-chan *UpdateRuleResponse, <-chan error)
- type ClientParameters
- type Concurrency
- type ConnectionsInGetConnection
- type ConnectionsInListConnections
- type ConnectionsItem
- type CreateApiDestinationHttpApiParameters
- type CreateApiDestinationHttpApiParametersApiParametersItem
- type CreateApiDestinationRequest
- type CreateApiDestinationResponse
- type CreateConnectionAuthParameters
- type CreateConnectionAuthParametersApiKeyAuthParameters
- type CreateConnectionAuthParametersBasicAuthParameters
- type CreateConnectionAuthParametersInvocationHttpParameters
- type CreateConnectionAuthParametersInvocationHttpParametersBodyParametersItem
- type CreateConnectionAuthParametersInvocationHttpParametersHeaderParametersItem
- type CreateConnectionAuthParametersInvocationHttpParametersQueryStringParametersItem
- type CreateConnectionAuthParametersOAuthParameters
- type CreateConnectionAuthParametersOAuthParametersClientParameters
- type CreateConnectionAuthParametersOAuthParametersOAuthHttpParameters
- type CreateConnectionAuthParametersOAuthParametersOAuthHttpParametersBodyParametersItem
- type CreateConnectionAuthParametersOAuthParametersOAuthHttpParametersHeaderParametersItem
- type CreateConnectionAuthParametersOAuthParametersOAuthHttpParametersQueryStringParametersItem
- type CreateConnectionNetworkParameters
- type CreateConnectionRequest
- type CreateConnectionResponse
- type CreateEventBusRequest
- type CreateEventBusResponse
- type CreateEventSourceRequest
- type CreateEventSourceResponse
- type CreateEventSourceSourceHttpEventParameters
- type CreateEventSourceSourceKafkaParameters
- type CreateEventSourceSourceMNSParameters
- type CreateEventSourceSourceRabbitMQParameters
- type CreateEventSourceSourceRocketMQParameters
- type CreateEventSourceSourceSLSParameters
- type CreateEventSourceSourceScheduledEventParameters
- type CreateEventStreamingRequest
- type CreateEventStreamingResponse
- type CreateEventStreamingRunOptions
- type CreateEventStreamingRunOptionsBatchWindow
- type CreateEventStreamingRunOptionsDeadLetterQueue
- type CreateEventStreamingRunOptionsRetryStrategy
- type CreateEventStreamingSink
- type CreateEventStreamingSinkSinkDataHubParameters
- type CreateEventStreamingSinkSinkDataHubParametersBody
- type CreateEventStreamingSinkSinkDataHubParametersProject
- type CreateEventStreamingSinkSinkDataHubParametersRoleName
- type CreateEventStreamingSinkSinkDataHubParametersTopic
- type CreateEventStreamingSinkSinkDataHubParametersTopicSchema
- type CreateEventStreamingSinkSinkDataHubParametersTopicType
- type CreateEventStreamingSinkSinkFcParameters
- type CreateEventStreamingSinkSinkFcParametersBody
- type CreateEventStreamingSinkSinkFcParametersConcurrency
- type CreateEventStreamingSinkSinkFcParametersFunctionName
- type CreateEventStreamingSinkSinkFcParametersInvocationType
- type CreateEventStreamingSinkSinkFcParametersQualifier
- type CreateEventStreamingSinkSinkFcParametersServiceName
- type CreateEventStreamingSinkSinkKafkaParameters
- type CreateEventStreamingSinkSinkKafkaParametersAcks
- type CreateEventStreamingSinkSinkKafkaParametersInstanceId
- type CreateEventStreamingSinkSinkKafkaParametersKey
- type CreateEventStreamingSinkSinkKafkaParametersSaslUser
- type CreateEventStreamingSinkSinkKafkaParametersTopic
- type CreateEventStreamingSinkSinkKafkaParametersValue
- type CreateEventStreamingSinkSinkMNSParameters
- type CreateEventStreamingSinkSinkMNSParametersBody
- type CreateEventStreamingSinkSinkMNSParametersIsBase64Encode
- type CreateEventStreamingSinkSinkMNSParametersQueueName
- type CreateEventStreamingSinkSinkRabbitMQParameters
- type CreateEventStreamingSinkSinkRabbitMQParametersBody
- type CreateEventStreamingSinkSinkRabbitMQParametersExchange
- type CreateEventStreamingSinkSinkRabbitMQParametersInstanceId
- type CreateEventStreamingSinkSinkRabbitMQParametersMessageId
- type CreateEventStreamingSinkSinkRabbitMQParametersProperties
- type CreateEventStreamingSinkSinkRabbitMQParametersQueueName
- type CreateEventStreamingSinkSinkRabbitMQParametersRoutingKey
- type CreateEventStreamingSinkSinkRabbitMQParametersTargetType
- type CreateEventStreamingSinkSinkRabbitMQParametersVirtualHostName
- type CreateEventStreamingSinkSinkRocketMQParameters
- type CreateEventStreamingSinkSinkRocketMQParametersBody
- type CreateEventStreamingSinkSinkRocketMQParametersInstanceEndpoint
- type CreateEventStreamingSinkSinkRocketMQParametersInstanceId
- type CreateEventStreamingSinkSinkRocketMQParametersInstancePassword
- type CreateEventStreamingSinkSinkRocketMQParametersInstanceType
- type CreateEventStreamingSinkSinkRocketMQParametersInstanceUsername
- type CreateEventStreamingSinkSinkRocketMQParametersKeys
- type CreateEventStreamingSinkSinkRocketMQParametersNetwork
- type CreateEventStreamingSinkSinkRocketMQParametersProperties
- type CreateEventStreamingSinkSinkRocketMQParametersSecurityGroupId
- type CreateEventStreamingSinkSinkRocketMQParametersTags
- type CreateEventStreamingSinkSinkRocketMQParametersTopic
- type CreateEventStreamingSinkSinkRocketMQParametersVSwitchIds
- type CreateEventStreamingSinkSinkRocketMQParametersVpcId
- type CreateEventStreamingSinkSinkSLSParameters
- type CreateEventStreamingSinkSinkSLSParametersBody
- type CreateEventStreamingSinkSinkSLSParametersLogStore
- type CreateEventStreamingSinkSinkSLSParametersProject
- type CreateEventStreamingSinkSinkSLSParametersRoleName
- type CreateEventStreamingSinkSinkSLSParametersTopic
- type CreateEventStreamingSource
- type CreateEventStreamingSourceSourceDTSParameters
- type CreateEventStreamingSourceSourceKafkaParameters
- type CreateEventStreamingSourceSourceMNSParameters
- type CreateEventStreamingSourceSourceMQTTParameters
- type CreateEventStreamingSourceSourceRabbitMQParameters
- type CreateEventStreamingSourceSourceRocketMQParameters
- type CreateEventStreamingSourceSourceSLSParameters
- type CreateRuleEventTargets
- type CreateRuleEventTargetsDeadLetterQueue
- type CreateRuleEventTargetsParamListItem
- type CreateRuleRequest
- type CreateRuleResponse
- type CreateServiceLinkedRoleForProductRequest
- type CreateServiceLinkedRoleForProductResponse
- type Data
- type DataInListEventBuses
- type DataInListEventStreamings
- type DataInListRules
- type DataInListTargets
- type DataInQueryEventTraces
- type DataInQueryTracedEventByEventId
- type DataInQueryTracedEvents
- type DataItem
- type Date
- type DeadLetterQueue
- type DeleteApiDestinationRequest
- type DeleteApiDestinationResponse
- type DeleteConnectionRequest
- type DeleteConnectionResponse
- type DeleteEventBusRequest
- type DeleteEventBusResponse
- type DeleteEventSourceRequest
- type DeleteEventSourceResponse
- type DeleteEventStreamingRequest
- type DeleteEventStreamingResponse
- type DeleteRuleRequest
- type DeleteRuleResponse
- type DeleteTargetsRequest
- type DeleteTargetsResponse
- type DisableRuleRequest
- type DisableRuleResponse
- type EnableRuleRequest
- type EnableRuleResponse
- type ErrorEntriesInDeleteTargets
- type ErrorEntriesInPutTargets
- type ErrorEntriesItem
- type EventBuses
- type EventBusesItem
- type EventSourceListInListAliyunOfficialEventSources
- type EventSourceListInListUserDefinedEventSources
- type EventSourceListItem
- type EventStreamings
- type EventStreamingsItem
- type EventTypes
- type EventTypesItem
- type EventsInQueryTracedEventByEventId
- type EventsInQueryTracedEvents
- type EventsItem
- type Exchange
- type FunctionName
- type GetApiDestinationRequest
- type GetApiDestinationResponse
- type GetConnectionRequest
- type GetConnectionResponse
- type GetEventBusRequest
- type GetEventBusResponse
- type GetEventStreamingRequest
- type GetEventStreamingResponse
- type GetRuleRequest
- type GetRuleResponse
- type HeaderParametersInGetConnection
- type HeaderParametersInListConnections
- type HeaderParametersItem
- type HttpApiParameters
- type InstanceId
- type InvocationHttpParameters
- type InvocationType
- type Ip
- type IsBase64Encode
- type Key
- type Keys
- type ListAliyunOfficialEventSourcesRequest
- type ListAliyunOfficialEventSourcesResponse
- type ListApiDestinationsRequest
- type ListApiDestinationsResponse
- type ListConnectionsRequest
- type ListConnectionsResponse
- type ListEventBusesRequest
- type ListEventBusesResponse
- type ListEventStreamingsRequest
- type ListEventStreamingsResponse
- type ListRulesRequest
- type ListRulesResponse
- type ListTargetsRequest
- type ListTargetsResponse
- type ListUserDefinedEventSourcesRequest
- type ListUserDefinedEventSourcesResponse
- type LogStore
- type MessageId
- type Method
- type NetworkParameters
- type OAuthHttpParameters
- type OAuthParameters
- type ParamListInGetRule
- type ParamListInListTargets
- type ParamListItem
- type PauseEventStreamingRequest
- type PauseEventStreamingResponse
- type Project
- type Properties
- type PutTargetsRequest
- type PutTargetsResponse
- type PutTargetsTargets
- type PutTargetsTargetsDeadLetterQueue
- type PutTargetsTargetsParamListItem
- type Qualifier
- type QueryEventRequest
- type QueryEventResponse
- type QueryEventTracesRequest
- type QueryEventTracesResponse
- type QueryStringParametersInGetConnection
- type QueryStringParametersInListConnections
- type QueryStringParametersItem
- type QueryTracedEventByEventIdRequest
- type QueryTracedEventByEventIdResponse
- type QueryTracedEventsRequest
- type QueryTracedEventsResponse
- type QueueName
- type Referer
- type RetryStrategy
- type RoleName
- type RoutingKey
- type Rules
- type RulesItem
- type RunOptions
- type SaslUser
- type ServiceName
- type Sink
- type SinkFcParameters
- type SinkKafkaParameters
- type SinkMNSParameters
- type SinkRabbitMQParameters
- type SinkRocketMQParameters
- type SinkSLSParameters
- type Source
- type SourceDTSParameters
- type SourceHttpEventParameters
- type SourceKafkaParameters
- type SourceMNSParameters
- type SourceMQTTParameters
- type SourceRabbitMQParameters
- type SourceRocketMQParameters
- type SourceRocketMQParametersInListUserDefinedEventSources
- type SourceSLSParameters
- type StartEventStreamingRequest
- type StartEventStreamingResponse
- type Tags
- type TargetType
- type TargetsInGetRule
- type TargetsInListRules
- type TargetsInListTargets
- type TargetsItem
- type TestEventPatternRequest
- type TestEventPatternResponse
- type Topic
- type UpdateApiDestinationHttpApiParameters
- type UpdateApiDestinationHttpApiParametersApiParametersItem
- type UpdateApiDestinationRequest
- type UpdateApiDestinationResponse
- type UpdateConnectionAuthParameters
- type UpdateConnectionAuthParametersApiKeyAuthParameters
- type UpdateConnectionAuthParametersBasicAuthParameters
- type UpdateConnectionAuthParametersInvocationHttpParameters
- type UpdateConnectionAuthParametersInvocationHttpParametersBodyParametersItem
- type UpdateConnectionAuthParametersInvocationHttpParametersHeaderParametersItem
- type UpdateConnectionAuthParametersInvocationHttpParametersQueryStringParametersItem
- type UpdateConnectionAuthParametersOAuthParameters
- type UpdateConnectionAuthParametersOAuthParametersClientParameters
- type UpdateConnectionAuthParametersOAuthParametersOAuthHttpParameters
- type UpdateConnectionAuthParametersOAuthParametersOAuthHttpParametersBodyParametersItem
- type UpdateConnectionAuthParametersOAuthParametersOAuthHttpParametersHeaderParametersItem
- type UpdateConnectionAuthParametersOAuthParametersOAuthHttpParametersQueryStringParametersItem
- type UpdateConnectionNetworkParameters
- type UpdateConnectionRequest
- type UpdateConnectionResponse
- type UpdateEventBusRequest
- type UpdateEventBusResponse
- type UpdateEventSourceRequest
- type UpdateEventSourceResponse
- type UpdateEventSourceSourceHttpEventParameters
- type UpdateEventSourceSourceKafkaParameters
- type UpdateEventSourceSourceMNSParameters
- type UpdateEventSourceSourceRabbitMQParameters
- type UpdateEventSourceSourceRocketMQParameters
- type UpdateEventSourceSourceSLSParameters
- type UpdateEventSourceSourceScheduledEventParameters
- type UpdateEventStreamingRequest
- type UpdateEventStreamingResponse
- type UpdateEventStreamingRunOptions
- type UpdateEventStreamingRunOptionsBatchWindow
- type UpdateEventStreamingRunOptionsDeadLetterQueue
- type UpdateEventStreamingRunOptionsRetryStrategy
- type UpdateEventStreamingSink
- type UpdateEventStreamingSinkSinkFcParameters
- type UpdateEventStreamingSinkSinkFcParametersBody
- type UpdateEventStreamingSinkSinkFcParametersConcurrency
- type UpdateEventStreamingSinkSinkFcParametersFunctionName
- type UpdateEventStreamingSinkSinkFcParametersInvocationType
- type UpdateEventStreamingSinkSinkFcParametersQualifier
- type UpdateEventStreamingSinkSinkFcParametersServiceName
- type UpdateEventStreamingSinkSinkKafkaParameters
- type UpdateEventStreamingSinkSinkKafkaParametersAcks
- type UpdateEventStreamingSinkSinkKafkaParametersInstanceId
- type UpdateEventStreamingSinkSinkKafkaParametersKey
- type UpdateEventStreamingSinkSinkKafkaParametersSaslUser
- type UpdateEventStreamingSinkSinkKafkaParametersTopic
- type UpdateEventStreamingSinkSinkKafkaParametersValue
- type UpdateEventStreamingSinkSinkMNSParameters
- type UpdateEventStreamingSinkSinkMNSParametersBody
- type UpdateEventStreamingSinkSinkMNSParametersIsBase64Encode
- type UpdateEventStreamingSinkSinkMNSParametersQueueName
- type UpdateEventStreamingSinkSinkRabbitMQParameters
- type UpdateEventStreamingSinkSinkRabbitMQParametersBody
- type UpdateEventStreamingSinkSinkRabbitMQParametersExchange
- type UpdateEventStreamingSinkSinkRabbitMQParametersInstanceId
- type UpdateEventStreamingSinkSinkRabbitMQParametersMessageId
- type UpdateEventStreamingSinkSinkRabbitMQParametersProperties
- type UpdateEventStreamingSinkSinkRabbitMQParametersQueueName
- type UpdateEventStreamingSinkSinkRabbitMQParametersRoutingKey
- type UpdateEventStreamingSinkSinkRabbitMQParametersTargetType
- type UpdateEventStreamingSinkSinkRabbitMQParametersVirtualHostName
- type UpdateEventStreamingSinkSinkRocketMQParameters
- type UpdateEventStreamingSinkSinkRocketMQParametersBody
- type UpdateEventStreamingSinkSinkRocketMQParametersInstanceId
- type UpdateEventStreamingSinkSinkRocketMQParametersKeys
- type UpdateEventStreamingSinkSinkRocketMQParametersProperties
- type UpdateEventStreamingSinkSinkRocketMQParametersTags
- type UpdateEventStreamingSinkSinkRocketMQParametersTopic
- type UpdateEventStreamingSinkSinkSLSParameters
- type UpdateEventStreamingSinkSinkSLSParametersBody
- type UpdateEventStreamingSinkSinkSLSParametersLogStore
- type UpdateEventStreamingSinkSinkSLSParametersProject
- type UpdateEventStreamingSinkSinkSLSParametersRoleName
- type UpdateEventStreamingSinkSinkSLSParametersTopic
- type UpdateEventStreamingSource
- type UpdateEventStreamingSourceSourceDTSParameters
- type UpdateEventStreamingSourceSourceKafkaParameters
- type UpdateEventStreamingSourceSourceMNSParameters
- type UpdateEventStreamingSourceSourceMQTTParameters
- type UpdateEventStreamingSourceSourceRabbitMQParameters
- type UpdateEventStreamingSourceSourceRocketMQParameters
- type UpdateEventStreamingSourceSourceSLSParameters
- type UpdateRuleRequest
- type UpdateRuleResponse
- type Value
- type VirtualHostName
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Acks ¶
type Acks struct {
Value string `json:"Value" xml:"Value"`
Template string `json:"Template" xml:"Template"`
Form string `json:"Form" xml:"Form"`
}
Acks is a nested struct in eventbridge response
type ApiDestinations ¶
type ApiDestinations struct {
ApiDestinationsItem []ApiDestinationsItem `json:"apiDestinations" xml:"apiDestinations"`
}
ApiDestinations is a nested struct in eventbridge response
type ApiDestinationsItem ¶
type ApiDestinationsItem struct {
ApiDestinationName string `json:"ApiDestinationName" xml:"ApiDestinationName"`
ConnectionName string `json:"ConnectionName" xml:"ConnectionName"`
Description string `json:"Description" xml:"Description"`
GmtCreate int64 `json:"GmtCreate" xml:"GmtCreate"`
InvocationRateLimitPerSecond int64 `json:"InvocationRateLimitPerSecond" xml:"InvocationRateLimitPerSecond"`
HttpApiParameters HttpApiParameters `json:"HttpApiParameters" xml:"HttpApiParameters"`
}
ApiDestinationsItem is a nested struct in eventbridge response
type ApiKeyAuthParameters ¶
type ApiKeyAuthParameters struct {
ApiKeyValue string `json:"ApiKeyValue" xml:"ApiKeyValue"`
ApiKeyName string `json:"ApiKeyName" xml:"ApiKeyName"`
}
ApiKeyAuthParameters is a nested struct in eventbridge response
type ApiParametersInGetApiDestination ¶
type ApiParametersInGetApiDestination struct {
ApiParametersItem []ApiParametersItem `json:"apiParameters" xml:"apiParameters"`
}
ApiParametersInGetApiDestination is a nested struct in eventbridge response
type ApiParametersInListApiDestinations ¶
type ApiParametersInListApiDestinations struct {
ApiParametersItem []ApiParametersItem `json:"apiParameters" xml:"apiParameters"`
}
ApiParametersInListApiDestinations is a nested struct in eventbridge response
type ApiParametersItem ¶
type ApiParametersItem struct {
Name string `json:"Name" xml:"Name"`
In string `json:"In" xml:"In"`
DefaultValue string `json:"DefaultValue" xml:"DefaultValue"`
Description string `json:"Description" xml:"Description"`
Type string `json:"Type" xml:"Type"`
}
ApiParametersItem is a nested struct in eventbridge response
type AuthParameters ¶
type AuthParameters struct {
AuthorizationType string `json:"AuthorizationType" xml:"AuthorizationType"`
OAuthParameters OAuthParameters `json:"OAuthParameters" xml:"OAuthParameters"`
ApiKeyAuthParameters ApiKeyAuthParameters `json:"ApiKeyAuthParameters" xml:"ApiKeyAuthParameters"`
InvocationHttpParameters InvocationHttpParameters `json:"InvocationHttpParameters" xml:"InvocationHttpParameters"`
BasicAuthParameters BasicAuthParameters `json:"BasicAuthParameters" xml:"BasicAuthParameters"`
}
AuthParameters is a nested struct in eventbridge response
type BasicAuthParameters ¶
type BasicAuthParameters struct {
Password string `json:"Password" xml:"Password"`
Username string `json:"Username" xml:"Username"`
}
BasicAuthParameters is a nested struct in eventbridge response
type BatchWindow ¶
type BatchWindow struct {
CountBasedWindow int `json:"CountBasedWindow" xml:"CountBasedWindow"`
TimeBasedWindow int `json:"TimeBasedWindow" xml:"TimeBasedWindow"`
}
BatchWindow is a nested struct in eventbridge response
type Body ¶
type Body struct {
Value string `json:"Value" xml:"Value"`
Template string `json:"Template" xml:"Template"`
Form string `json:"Form" xml:"Form"`
}
Body is a nested struct in eventbridge response
type BodyParametersInGetConnection ¶
type BodyParametersInGetConnection struct {
BodyParametersItem []BodyParametersItem `json:"bodyParameters" xml:"bodyParameters"`
}
BodyParametersInGetConnection is a nested struct in eventbridge response
type BodyParametersInListConnections ¶
type BodyParametersInListConnections struct {
BodyParametersItem []BodyParametersItem `json:"bodyParameters" xml:"bodyParameters"`
}
BodyParametersInListConnections is a nested struct in eventbridge response
type BodyParametersItem ¶
type BodyParametersItem struct {
Key string `json:"Key" xml:"Key"`
Value string `json:"Value" xml:"Value"`
IsValueSecret string `json:"IsValueSecret" xml:"IsValueSecret"`
ValuValuee string `json:"ValuValuee" xml:"ValuValuee"`
}
BodyParametersItem is a nested struct in eventbridge response
type Client ¶
Client is the sdk client struct, each func corresponds to an OpenAPI
func NewClientWithAccessKey ¶
func NewClientWithAccessKey(regionId, accessKeyId, accessKeySecret string) (client *Client, err error)
NewClientWithAccessKey is a shortcut to create sdk client with accesskey usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md
func NewClientWithEcsRamRole ¶
NewClientWithEcsRamRole is a shortcut to create sdk client with ecs ram role usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md
func NewClientWithOptions ¶
func NewClientWithOptions(regionId string, config *sdk.Config, credential auth.Credential) (client *Client, err error)
NewClientWithOptions creates a sdk client with regionId/sdkConfig/credential this is the common api to create a sdk client
func NewClientWithProvider ¶
func NewClientWithProvider(regionId string, providers ...provider.Provider) (client *Client, err error)
NewClientWithProvider creates a sdk client with providers usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md
func NewClientWithRamRoleArn ¶
func NewClientWithRamRoleArn(regionId string, accessKeyId, accessKeySecret, roleArn, roleSessionName string) (client *Client, err error)
NewClientWithRamRoleArn is a shortcut to create sdk client with ram roleArn usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md
func NewClientWithRamRoleArnAndPolicy ¶
func NewClientWithRamRoleArnAndPolicy(regionId string, accessKeyId, accessKeySecret, roleArn, roleSessionName, policy string) (client *Client, err error)
NewClientWithRamRoleArn is a shortcut to create sdk client with ram roleArn and policy usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md
func NewClientWithRsaKeyPair ¶
func NewClientWithRsaKeyPair(regionId string, publicKeyId, privateKey string, sessionExpiration int) (client *Client, err error)
NewClientWithRsaKeyPair is a shortcut to create sdk client with rsa key pair usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md
func NewClientWithStsToken ¶
func NewClientWithStsToken(regionId, stsAccessKeyId, stsAccessKeySecret, stsToken string) (client *Client, err error)
NewClientWithStsToken is a shortcut to create sdk client with sts token usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md
func (*Client) CreateApiDestination ¶
func (client *Client) CreateApiDestination(request *CreateApiDestinationRequest) (response *CreateApiDestinationResponse, err error)
CreateApiDestination invokes the eventbridge.CreateApiDestination API synchronously
func (*Client) CreateApiDestinationWithCallback ¶
func (client *Client) CreateApiDestinationWithCallback(request *CreateApiDestinationRequest, callback func(response *CreateApiDestinationResponse, err error)) <-chan int
CreateApiDestinationWithCallback invokes the eventbridge.CreateApiDestination API asynchronously
func (*Client) CreateApiDestinationWithChan ¶
func (client *Client) CreateApiDestinationWithChan(request *CreateApiDestinationRequest) (<-chan *CreateApiDestinationResponse, <-chan error)
CreateApiDestinationWithChan invokes the eventbridge.CreateApiDestination API asynchronously
func (*Client) CreateConnection ¶
func (client *Client) CreateConnection(request *CreateConnectionRequest) (response *CreateConnectionResponse, err error)
CreateConnection invokes the eventbridge.CreateConnection API synchronously
func (*Client) CreateConnectionWithCallback ¶
func (client *Client) CreateConnectionWithCallback(request *CreateConnectionRequest, callback func(response *CreateConnectionResponse, err error)) <-chan int
CreateConnectionWithCallback invokes the eventbridge.CreateConnection API asynchronously
func (*Client) CreateConnectionWithChan ¶
func (client *Client) CreateConnectionWithChan(request *CreateConnectionRequest) (<-chan *CreateConnectionResponse, <-chan error)
CreateConnectionWithChan invokes the eventbridge.CreateConnection API asynchronously
func (*Client) CreateEventBus ¶
func (client *Client) CreateEventBus(request *CreateEventBusRequest) (response *CreateEventBusResponse, err error)
CreateEventBus invokes the eventbridge.CreateEventBus API synchronously
func (*Client) CreateEventBusWithCallback ¶
func (client *Client) CreateEventBusWithCallback(request *CreateEventBusRequest, callback func(response *CreateEventBusResponse, err error)) <-chan int
CreateEventBusWithCallback invokes the eventbridge.CreateEventBus API asynchronously
func (*Client) CreateEventBusWithChan ¶
func (client *Client) CreateEventBusWithChan(request *CreateEventBusRequest) (<-chan *CreateEventBusResponse, <-chan error)
CreateEventBusWithChan invokes the eventbridge.CreateEventBus API asynchronously
func (*Client) CreateEventSource ¶
func (client *Client) CreateEventSource(request *CreateEventSourceRequest) (response *CreateEventSourceResponse, err error)
CreateEventSource invokes the eventbridge.CreateEventSource API synchronously
func (*Client) CreateEventSourceWithCallback ¶
func (client *Client) CreateEventSourceWithCallback(request *CreateEventSourceRequest, callback func(response *CreateEventSourceResponse, err error)) <-chan int
CreateEventSourceWithCallback invokes the eventbridge.CreateEventSource API asynchronously
func (*Client) CreateEventSourceWithChan ¶
func (client *Client) CreateEventSourceWithChan(request *CreateEventSourceRequest) (<-chan *CreateEventSourceResponse, <-chan error)
CreateEventSourceWithChan invokes the eventbridge.CreateEventSource API asynchronously
func (*Client) CreateEventStreaming ¶
func (client *Client) CreateEventStreaming(request *CreateEventStreamingRequest) (response *CreateEventStreamingResponse, err error)
CreateEventStreaming invokes the eventbridge.CreateEventStreaming API synchronously
func (*Client) CreateEventStreamingWithCallback ¶
func (client *Client) CreateEventStreamingWithCallback(request *CreateEventStreamingRequest, callback func(response *CreateEventStreamingResponse, err error)) <-chan int
CreateEventStreamingWithCallback invokes the eventbridge.CreateEventStreaming API asynchronously
func (*Client) CreateEventStreamingWithChan ¶
func (client *Client) CreateEventStreamingWithChan(request *CreateEventStreamingRequest) (<-chan *CreateEventStreamingResponse, <-chan error)
CreateEventStreamingWithChan invokes the eventbridge.CreateEventStreaming API asynchronously
func (*Client) CreateRule ¶
func (client *Client) CreateRule(request *CreateRuleRequest) (response *CreateRuleResponse, err error)
CreateRule invokes the eventbridge.CreateRule API synchronously
func (*Client) CreateRuleWithCallback ¶
func (client *Client) CreateRuleWithCallback(request *CreateRuleRequest, callback func(response *CreateRuleResponse, err error)) <-chan int
CreateRuleWithCallback invokes the eventbridge.CreateRule API asynchronously
func (*Client) CreateRuleWithChan ¶
func (client *Client) CreateRuleWithChan(request *CreateRuleRequest) (<-chan *CreateRuleResponse, <-chan error)
CreateRuleWithChan invokes the eventbridge.CreateRule API asynchronously
func (*Client) CreateServiceLinkedRoleForProduct ¶
func (client *Client) CreateServiceLinkedRoleForProduct(request *CreateServiceLinkedRoleForProductRequest) (response *CreateServiceLinkedRoleForProductResponse, err error)
CreateServiceLinkedRoleForProduct invokes the eventbridge.CreateServiceLinkedRoleForProduct API synchronously
func (*Client) CreateServiceLinkedRoleForProductWithCallback ¶
func (client *Client) CreateServiceLinkedRoleForProductWithCallback(request *CreateServiceLinkedRoleForProductRequest, callback func(response *CreateServiceLinkedRoleForProductResponse, err error)) <-chan int
CreateServiceLinkedRoleForProductWithCallback invokes the eventbridge.CreateServiceLinkedRoleForProduct API asynchronously
func (*Client) CreateServiceLinkedRoleForProductWithChan ¶
func (client *Client) CreateServiceLinkedRoleForProductWithChan(request *CreateServiceLinkedRoleForProductRequest) (<-chan *CreateServiceLinkedRoleForProductResponse, <-chan error)
CreateServiceLinkedRoleForProductWithChan invokes the eventbridge.CreateServiceLinkedRoleForProduct API asynchronously
func (*Client) DeleteApiDestination ¶
func (client *Client) DeleteApiDestination(request *DeleteApiDestinationRequest) (response *DeleteApiDestinationResponse, err error)
DeleteApiDestination invokes the eventbridge.DeleteApiDestination API synchronously
func (*Client) DeleteApiDestinationWithCallback ¶
func (client *Client) DeleteApiDestinationWithCallback(request *DeleteApiDestinationRequest, callback func(response *DeleteApiDestinationResponse, err error)) <-chan int
DeleteApiDestinationWithCallback invokes the eventbridge.DeleteApiDestination API asynchronously
func (*Client) DeleteApiDestinationWithChan ¶
func (client *Client) DeleteApiDestinationWithChan(request *DeleteApiDestinationRequest) (<-chan *DeleteApiDestinationResponse, <-chan error)
DeleteApiDestinationWithChan invokes the eventbridge.DeleteApiDestination API asynchronously
func (*Client) DeleteConnection ¶
func (client *Client) DeleteConnection(request *DeleteConnectionRequest) (response *DeleteConnectionResponse, err error)
DeleteConnection invokes the eventbridge.DeleteConnection API synchronously
func (*Client) DeleteConnectionWithCallback ¶
func (client *Client) DeleteConnectionWithCallback(request *DeleteConnectionRequest, callback func(response *DeleteConnectionResponse, err error)) <-chan int
DeleteConnectionWithCallback invokes the eventbridge.DeleteConnection API asynchronously
func (*Client) DeleteConnectionWithChan ¶
func (client *Client) DeleteConnectionWithChan(request *DeleteConnectionRequest) (<-chan *DeleteConnectionResponse, <-chan error)
DeleteConnectionWithChan invokes the eventbridge.DeleteConnection API asynchronously
func (*Client) DeleteEventBus ¶
func (client *Client) DeleteEventBus(request *DeleteEventBusRequest) (response *DeleteEventBusResponse, err error)
DeleteEventBus invokes the eventbridge.DeleteEventBus API synchronously
func (*Client) DeleteEventBusWithCallback ¶
func (client *Client) DeleteEventBusWithCallback(request *DeleteEventBusRequest, callback func(response *DeleteEventBusResponse, err error)) <-chan int
DeleteEventBusWithCallback invokes the eventbridge.DeleteEventBus API asynchronously
func (*Client) DeleteEventBusWithChan ¶
func (client *Client) DeleteEventBusWithChan(request *DeleteEventBusRequest) (<-chan *DeleteEventBusResponse, <-chan error)
DeleteEventBusWithChan invokes the eventbridge.DeleteEventBus API asynchronously
func (*Client) DeleteEventSource ¶
func (client *Client) DeleteEventSource(request *DeleteEventSourceRequest) (response *DeleteEventSourceResponse, err error)
DeleteEventSource invokes the eventbridge.DeleteEventSource API synchronously
func (*Client) DeleteEventSourceWithCallback ¶
func (client *Client) DeleteEventSourceWithCallback(request *DeleteEventSourceRequest, callback func(response *DeleteEventSourceResponse, err error)) <-chan int
DeleteEventSourceWithCallback invokes the eventbridge.DeleteEventSource API asynchronously
func (*Client) DeleteEventSourceWithChan ¶
func (client *Client) DeleteEventSourceWithChan(request *DeleteEventSourceRequest) (<-chan *DeleteEventSourceResponse, <-chan error)
DeleteEventSourceWithChan invokes the eventbridge.DeleteEventSource API asynchronously
func (*Client) DeleteEventStreaming ¶
func (client *Client) DeleteEventStreaming(request *DeleteEventStreamingRequest) (response *DeleteEventStreamingResponse, err error)
DeleteEventStreaming invokes the eventbridge.DeleteEventStreaming API synchronously
func (*Client) DeleteEventStreamingWithCallback ¶
func (client *Client) DeleteEventStreamingWithCallback(request *DeleteEventStreamingRequest, callback func(response *DeleteEventStreamingResponse, err error)) <-chan int
DeleteEventStreamingWithCallback invokes the eventbridge.DeleteEventStreaming API asynchronously
func (*Client) DeleteEventStreamingWithChan ¶
func (client *Client) DeleteEventStreamingWithChan(request *DeleteEventStreamingRequest) (<-chan *DeleteEventStreamingResponse, <-chan error)
DeleteEventStreamingWithChan invokes the eventbridge.DeleteEventStreaming API asynchronously
func (*Client) DeleteRule ¶
func (client *Client) DeleteRule(request *DeleteRuleRequest) (response *DeleteRuleResponse, err error)
DeleteRule invokes the eventbridge.DeleteRule API synchronously
func (*Client) DeleteRuleWithCallback ¶
func (client *Client) DeleteRuleWithCallback(request *DeleteRuleRequest, callback func(response *DeleteRuleResponse, err error)) <-chan int
DeleteRuleWithCallback invokes the eventbridge.DeleteRule API asynchronously
func (*Client) DeleteRuleWithChan ¶
func (client *Client) DeleteRuleWithChan(request *DeleteRuleRequest) (<-chan *DeleteRuleResponse, <-chan error)
DeleteRuleWithChan invokes the eventbridge.DeleteRule API asynchronously
func (*Client) DeleteTargets ¶
func (client *Client) DeleteTargets(request *DeleteTargetsRequest) (response *DeleteTargetsResponse, err error)
DeleteTargets invokes the eventbridge.DeleteTargets API synchronously
func (*Client) DeleteTargetsWithCallback ¶
func (client *Client) DeleteTargetsWithCallback(request *DeleteTargetsRequest, callback func(response *DeleteTargetsResponse, err error)) <-chan int
DeleteTargetsWithCallback invokes the eventbridge.DeleteTargets API asynchronously
func (*Client) DeleteTargetsWithChan ¶
func (client *Client) DeleteTargetsWithChan(request *DeleteTargetsRequest) (<-chan *DeleteTargetsResponse, <-chan error)
DeleteTargetsWithChan invokes the eventbridge.DeleteTargets API asynchronously
func (*Client) DisableRule ¶
func (client *Client) DisableRule(request *DisableRuleRequest) (response *DisableRuleResponse, err error)
DisableRule invokes the eventbridge.DisableRule API synchronously
func (*Client) DisableRuleWithCallback ¶
func (client *Client) DisableRuleWithCallback(request *DisableRuleRequest, callback func(response *DisableRuleResponse, err error)) <-chan int
DisableRuleWithCallback invokes the eventbridge.DisableRule API asynchronously
func (*Client) DisableRuleWithChan ¶
func (client *Client) DisableRuleWithChan(request *DisableRuleRequest) (<-chan *DisableRuleResponse, <-chan error)
DisableRuleWithChan invokes the eventbridge.DisableRule API asynchronously
func (*Client) EnableRule ¶
func (client *Client) EnableRule(request *EnableRuleRequest) (response *EnableRuleResponse, err error)
EnableRule invokes the eventbridge.EnableRule API synchronously
func (*Client) EnableRuleWithCallback ¶
func (client *Client) EnableRuleWithCallback(request *EnableRuleRequest, callback func(response *EnableRuleResponse, err error)) <-chan int
EnableRuleWithCallback invokes the eventbridge.EnableRule API asynchronously
func (*Client) EnableRuleWithChan ¶
func (client *Client) EnableRuleWithChan(request *EnableRuleRequest) (<-chan *EnableRuleResponse, <-chan error)
EnableRuleWithChan invokes the eventbridge.EnableRule API asynchronously
func (*Client) GetApiDestination ¶
func (client *Client) GetApiDestination(request *GetApiDestinationRequest) (response *GetApiDestinationResponse, err error)
GetApiDestination invokes the eventbridge.GetApiDestination API synchronously
func (*Client) GetApiDestinationWithCallback ¶
func (client *Client) GetApiDestinationWithCallback(request *GetApiDestinationRequest, callback func(response *GetApiDestinationResponse, err error)) <-chan int
GetApiDestinationWithCallback invokes the eventbridge.GetApiDestination API asynchronously
func (*Client) GetApiDestinationWithChan ¶
func (client *Client) GetApiDestinationWithChan(request *GetApiDestinationRequest) (<-chan *GetApiDestinationResponse, <-chan error)
GetApiDestinationWithChan invokes the eventbridge.GetApiDestination API asynchronously
func (*Client) GetConnection ¶
func (client *Client) GetConnection(request *GetConnectionRequest) (response *GetConnectionResponse, err error)
GetConnection invokes the eventbridge.GetConnection API synchronously
func (*Client) GetConnectionWithCallback ¶
func (client *Client) GetConnectionWithCallback(request *GetConnectionRequest, callback func(response *GetConnectionResponse, err error)) <-chan int
GetConnectionWithCallback invokes the eventbridge.GetConnection API asynchronously
func (*Client) GetConnectionWithChan ¶
func (client *Client) GetConnectionWithChan(request *GetConnectionRequest) (<-chan *GetConnectionResponse, <-chan error)
GetConnectionWithChan invokes the eventbridge.GetConnection API asynchronously
func (*Client) GetEventBus ¶
func (client *Client) GetEventBus(request *GetEventBusRequest) (response *GetEventBusResponse, err error)
GetEventBus invokes the eventbridge.GetEventBus API synchronously
func (*Client) GetEventBusWithCallback ¶
func (client *Client) GetEventBusWithCallback(request *GetEventBusRequest, callback func(response *GetEventBusResponse, err error)) <-chan int
GetEventBusWithCallback invokes the eventbridge.GetEventBus API asynchronously
func (*Client) GetEventBusWithChan ¶
func (client *Client) GetEventBusWithChan(request *GetEventBusRequest) (<-chan *GetEventBusResponse, <-chan error)
GetEventBusWithChan invokes the eventbridge.GetEventBus API asynchronously
func (*Client) GetEventStreaming ¶
func (client *Client) GetEventStreaming(request *GetEventStreamingRequest) (response *GetEventStreamingResponse, err error)
GetEventStreaming invokes the eventbridge.GetEventStreaming API synchronously
func (*Client) GetEventStreamingWithCallback ¶
func (client *Client) GetEventStreamingWithCallback(request *GetEventStreamingRequest, callback func(response *GetEventStreamingResponse, err error)) <-chan int
GetEventStreamingWithCallback invokes the eventbridge.GetEventStreaming API asynchronously
func (*Client) GetEventStreamingWithChan ¶
func (client *Client) GetEventStreamingWithChan(request *GetEventStreamingRequest) (<-chan *GetEventStreamingResponse, <-chan error)
GetEventStreamingWithChan invokes the eventbridge.GetEventStreaming API asynchronously
func (*Client) GetRule ¶
func (client *Client) GetRule(request *GetRuleRequest) (response *GetRuleResponse, err error)
GetRule invokes the eventbridge.GetRule API synchronously
func (*Client) GetRuleWithCallback ¶
func (client *Client) GetRuleWithCallback(request *GetRuleRequest, callback func(response *GetRuleResponse, err error)) <-chan int
GetRuleWithCallback invokes the eventbridge.GetRule API asynchronously
func (*Client) GetRuleWithChan ¶
func (client *Client) GetRuleWithChan(request *GetRuleRequest) (<-chan *GetRuleResponse, <-chan error)
GetRuleWithChan invokes the eventbridge.GetRule API asynchronously
func (*Client) ListAliyunOfficialEventSources ¶
func (client *Client) ListAliyunOfficialEventSources(request *ListAliyunOfficialEventSourcesRequest) (response *ListAliyunOfficialEventSourcesResponse, err error)
ListAliyunOfficialEventSources invokes the eventbridge.ListAliyunOfficialEventSources API synchronously
func (*Client) ListAliyunOfficialEventSourcesWithCallback ¶
func (client *Client) ListAliyunOfficialEventSourcesWithCallback(request *ListAliyunOfficialEventSourcesRequest, callback func(response *ListAliyunOfficialEventSourcesResponse, err error)) <-chan int
ListAliyunOfficialEventSourcesWithCallback invokes the eventbridge.ListAliyunOfficialEventSources API asynchronously
func (*Client) ListAliyunOfficialEventSourcesWithChan ¶
func (client *Client) ListAliyunOfficialEventSourcesWithChan(request *ListAliyunOfficialEventSourcesRequest) (<-chan *ListAliyunOfficialEventSourcesResponse, <-chan error)
ListAliyunOfficialEventSourcesWithChan invokes the eventbridge.ListAliyunOfficialEventSources API asynchronously
func (*Client) ListApiDestinations ¶
func (client *Client) ListApiDestinations(request *ListApiDestinationsRequest) (response *ListApiDestinationsResponse, err error)
ListApiDestinations invokes the eventbridge.ListApiDestinations API synchronously
func (*Client) ListApiDestinationsWithCallback ¶
func (client *Client) ListApiDestinationsWithCallback(request *ListApiDestinationsRequest, callback func(response *ListApiDestinationsResponse, err error)) <-chan int
ListApiDestinationsWithCallback invokes the eventbridge.ListApiDestinations API asynchronously
func (*Client) ListApiDestinationsWithChan ¶
func (client *Client) ListApiDestinationsWithChan(request *ListApiDestinationsRequest) (<-chan *ListApiDestinationsResponse, <-chan error)
ListApiDestinationsWithChan invokes the eventbridge.ListApiDestinations API asynchronously
func (*Client) ListConnections ¶
func (client *Client) ListConnections(request *ListConnectionsRequest) (response *ListConnectionsResponse, err error)
ListConnections invokes the eventbridge.ListConnections API synchronously
func (*Client) ListConnectionsWithCallback ¶
func (client *Client) ListConnectionsWithCallback(request *ListConnectionsRequest, callback func(response *ListConnectionsResponse, err error)) <-chan int
ListConnectionsWithCallback invokes the eventbridge.ListConnections API asynchronously
func (*Client) ListConnectionsWithChan ¶
func (client *Client) ListConnectionsWithChan(request *ListConnectionsRequest) (<-chan *ListConnectionsResponse, <-chan error)
ListConnectionsWithChan invokes the eventbridge.ListConnections API asynchronously
func (*Client) ListEventBuses ¶
func (client *Client) ListEventBuses(request *ListEventBusesRequest) (response *ListEventBusesResponse, err error)
ListEventBuses invokes the eventbridge.ListEventBuses API synchronously
func (*Client) ListEventBusesWithCallback ¶
func (client *Client) ListEventBusesWithCallback(request *ListEventBusesRequest, callback func(response *ListEventBusesResponse, err error)) <-chan int
ListEventBusesWithCallback invokes the eventbridge.ListEventBuses API asynchronously
func (*Client) ListEventBusesWithChan ¶
func (client *Client) ListEventBusesWithChan(request *ListEventBusesRequest) (<-chan *ListEventBusesResponse, <-chan error)
ListEventBusesWithChan invokes the eventbridge.ListEventBuses API asynchronously
func (*Client) ListEventStreamings ¶
func (client *Client) ListEventStreamings(request *ListEventStreamingsRequest) (response *ListEventStreamingsResponse, err error)
ListEventStreamings invokes the eventbridge.ListEventStreamings API synchronously
func (*Client) ListEventStreamingsWithCallback ¶
func (client *Client) ListEventStreamingsWithCallback(request *ListEventStreamingsRequest, callback func(response *ListEventStreamingsResponse, err error)) <-chan int
ListEventStreamingsWithCallback invokes the eventbridge.ListEventStreamings API asynchronously
func (*Client) ListEventStreamingsWithChan ¶
func (client *Client) ListEventStreamingsWithChan(request *ListEventStreamingsRequest) (<-chan *ListEventStreamingsResponse, <-chan error)
ListEventStreamingsWithChan invokes the eventbridge.ListEventStreamings API asynchronously
func (*Client) ListRules ¶
func (client *Client) ListRules(request *ListRulesRequest) (response *ListRulesResponse, err error)
ListRules invokes the eventbridge.ListRules API synchronously
func (*Client) ListRulesWithCallback ¶
func (client *Client) ListRulesWithCallback(request *ListRulesRequest, callback func(response *ListRulesResponse, err error)) <-chan int
ListRulesWithCallback invokes the eventbridge.ListRules API asynchronously
func (*Client) ListRulesWithChan ¶
func (client *Client) ListRulesWithChan(request *ListRulesRequest) (<-chan *ListRulesResponse, <-chan error)
ListRulesWithChan invokes the eventbridge.ListRules API asynchronously
func (*Client) ListTargets ¶ added in v1.62.366
func (client *Client) ListTargets(request *ListTargetsRequest) (response *ListTargetsResponse, err error)
ListTargets invokes the eventbridge.ListTargets API synchronously
func (*Client) ListTargetsWithCallback ¶ added in v1.62.366
func (client *Client) ListTargetsWithCallback(request *ListTargetsRequest, callback func(response *ListTargetsResponse, err error)) <-chan int
ListTargetsWithCallback invokes the eventbridge.ListTargets API asynchronously
func (*Client) ListTargetsWithChan ¶ added in v1.62.366
func (client *Client) ListTargetsWithChan(request *ListTargetsRequest) (<-chan *ListTargetsResponse, <-chan error)
ListTargetsWithChan invokes the eventbridge.ListTargets API asynchronously
func (*Client) ListUserDefinedEventSources ¶
func (client *Client) ListUserDefinedEventSources(request *ListUserDefinedEventSourcesRequest) (response *ListUserDefinedEventSourcesResponse, err error)
ListUserDefinedEventSources invokes the eventbridge.ListUserDefinedEventSources API synchronously
func (*Client) ListUserDefinedEventSourcesWithCallback ¶
func (client *Client) ListUserDefinedEventSourcesWithCallback(request *ListUserDefinedEventSourcesRequest, callback func(response *ListUserDefinedEventSourcesResponse, err error)) <-chan int
ListUserDefinedEventSourcesWithCallback invokes the eventbridge.ListUserDefinedEventSources API asynchronously
func (*Client) ListUserDefinedEventSourcesWithChan ¶
func (client *Client) ListUserDefinedEventSourcesWithChan(request *ListUserDefinedEventSourcesRequest) (<-chan *ListUserDefinedEventSourcesResponse, <-chan error)
ListUserDefinedEventSourcesWithChan invokes the eventbridge.ListUserDefinedEventSources API asynchronously
func (*Client) PauseEventStreaming ¶
func (client *Client) PauseEventStreaming(request *PauseEventStreamingRequest) (response *PauseEventStreamingResponse, err error)
PauseEventStreaming invokes the eventbridge.PauseEventStreaming API synchronously
func (*Client) PauseEventStreamingWithCallback ¶
func (client *Client) PauseEventStreamingWithCallback(request *PauseEventStreamingRequest, callback func(response *PauseEventStreamingResponse, err error)) <-chan int
PauseEventStreamingWithCallback invokes the eventbridge.PauseEventStreaming API asynchronously
func (*Client) PauseEventStreamingWithChan ¶
func (client *Client) PauseEventStreamingWithChan(request *PauseEventStreamingRequest) (<-chan *PauseEventStreamingResponse, <-chan error)
PauseEventStreamingWithChan invokes the eventbridge.PauseEventStreaming API asynchronously
func (*Client) PutTargets ¶ added in v1.62.248
func (client *Client) PutTargets(request *PutTargetsRequest) (response *PutTargetsResponse, err error)
PutTargets invokes the eventbridge.PutTargets API synchronously
func (*Client) PutTargetsWithCallback ¶ added in v1.62.248
func (client *Client) PutTargetsWithCallback(request *PutTargetsRequest, callback func(response *PutTargetsResponse, err error)) <-chan int
PutTargetsWithCallback invokes the eventbridge.PutTargets API asynchronously
func (*Client) PutTargetsWithChan ¶ added in v1.62.248
func (client *Client) PutTargetsWithChan(request *PutTargetsRequest) (<-chan *PutTargetsResponse, <-chan error)
PutTargetsWithChan invokes the eventbridge.PutTargets API asynchronously
func (*Client) QueryEvent ¶ added in v1.62.193
func (client *Client) QueryEvent(request *QueryEventRequest) (response *QueryEventResponse, err error)
QueryEvent invokes the eventbridge.QueryEvent API synchronously
func (*Client) QueryEventTraces ¶ added in v1.62.193
func (client *Client) QueryEventTraces(request *QueryEventTracesRequest) (response *QueryEventTracesResponse, err error)
QueryEventTraces invokes the eventbridge.QueryEventTraces API synchronously
func (*Client) QueryEventTracesWithCallback ¶ added in v1.62.193
func (client *Client) QueryEventTracesWithCallback(request *QueryEventTracesRequest, callback func(response *QueryEventTracesResponse, err error)) <-chan int
QueryEventTracesWithCallback invokes the eventbridge.QueryEventTraces API asynchronously
func (*Client) QueryEventTracesWithChan ¶ added in v1.62.193
func (client *Client) QueryEventTracesWithChan(request *QueryEventTracesRequest) (<-chan *QueryEventTracesResponse, <-chan error)
QueryEventTracesWithChan invokes the eventbridge.QueryEventTraces API asynchronously
func (*Client) QueryEventWithCallback ¶ added in v1.62.193
func (client *Client) QueryEventWithCallback(request *QueryEventRequest, callback func(response *QueryEventResponse, err error)) <-chan int
QueryEventWithCallback invokes the eventbridge.QueryEvent API asynchronously
func (*Client) QueryEventWithChan ¶ added in v1.62.193
func (client *Client) QueryEventWithChan(request *QueryEventRequest) (<-chan *QueryEventResponse, <-chan error)
QueryEventWithChan invokes the eventbridge.QueryEvent API asynchronously
func (*Client) QueryTracedEventByEventId ¶ added in v1.62.193
func (client *Client) QueryTracedEventByEventId(request *QueryTracedEventByEventIdRequest) (response *QueryTracedEventByEventIdResponse, err error)
QueryTracedEventByEventId invokes the eventbridge.QueryTracedEventByEventId API synchronously
func (*Client) QueryTracedEventByEventIdWithCallback ¶ added in v1.62.193
func (client *Client) QueryTracedEventByEventIdWithCallback(request *QueryTracedEventByEventIdRequest, callback func(response *QueryTracedEventByEventIdResponse, err error)) <-chan int
QueryTracedEventByEventIdWithCallback invokes the eventbridge.QueryTracedEventByEventId API asynchronously
func (*Client) QueryTracedEventByEventIdWithChan ¶ added in v1.62.193
func (client *Client) QueryTracedEventByEventIdWithChan(request *QueryTracedEventByEventIdRequest) (<-chan *QueryTracedEventByEventIdResponse, <-chan error)
QueryTracedEventByEventIdWithChan invokes the eventbridge.QueryTracedEventByEventId API asynchronously
func (*Client) QueryTracedEvents ¶ added in v1.62.193
func (client *Client) QueryTracedEvents(request *QueryTracedEventsRequest) (response *QueryTracedEventsResponse, err error)
QueryTracedEvents invokes the eventbridge.QueryTracedEvents API synchronously
func (*Client) QueryTracedEventsWithCallback ¶ added in v1.62.193
func (client *Client) QueryTracedEventsWithCallback(request *QueryTracedEventsRequest, callback func(response *QueryTracedEventsResponse, err error)) <-chan int
QueryTracedEventsWithCallback invokes the eventbridge.QueryTracedEvents API asynchronously
func (*Client) QueryTracedEventsWithChan ¶ added in v1.62.193
func (client *Client) QueryTracedEventsWithChan(request *QueryTracedEventsRequest) (<-chan *QueryTracedEventsResponse, <-chan error)
QueryTracedEventsWithChan invokes the eventbridge.QueryTracedEvents API asynchronously
func (*Client) StartEventStreaming ¶
func (client *Client) StartEventStreaming(request *StartEventStreamingRequest) (response *StartEventStreamingResponse, err error)
StartEventStreaming invokes the eventbridge.StartEventStreaming API synchronously
func (*Client) StartEventStreamingWithCallback ¶
func (client *Client) StartEventStreamingWithCallback(request *StartEventStreamingRequest, callback func(response *StartEventStreamingResponse, err error)) <-chan int
StartEventStreamingWithCallback invokes the eventbridge.StartEventStreaming API asynchronously
func (*Client) StartEventStreamingWithChan ¶
func (client *Client) StartEventStreamingWithChan(request *StartEventStreamingRequest) (<-chan *StartEventStreamingResponse, <-chan error)
StartEventStreamingWithChan invokes the eventbridge.StartEventStreaming API asynchronously
func (*Client) TestEventPattern ¶ added in v1.62.281
func (client *Client) TestEventPattern(request *TestEventPatternRequest) (response *TestEventPatternResponse, err error)
TestEventPattern invokes the eventbridge.TestEventPattern API synchronously
func (*Client) TestEventPatternWithCallback ¶ added in v1.62.281
func (client *Client) TestEventPatternWithCallback(request *TestEventPatternRequest, callback func(response *TestEventPatternResponse, err error)) <-chan int
TestEventPatternWithCallback invokes the eventbridge.TestEventPattern API asynchronously
func (*Client) TestEventPatternWithChan ¶ added in v1.62.281
func (client *Client) TestEventPatternWithChan(request *TestEventPatternRequest) (<-chan *TestEventPatternResponse, <-chan error)
TestEventPatternWithChan invokes the eventbridge.TestEventPattern API asynchronously
func (*Client) UpdateApiDestination ¶
func (client *Client) UpdateApiDestination(request *UpdateApiDestinationRequest) (response *UpdateApiDestinationResponse, err error)
UpdateApiDestination invokes the eventbridge.UpdateApiDestination API synchronously
func (*Client) UpdateApiDestinationWithCallback ¶
func (client *Client) UpdateApiDestinationWithCallback(request *UpdateApiDestinationRequest, callback func(response *UpdateApiDestinationResponse, err error)) <-chan int
UpdateApiDestinationWithCallback invokes the eventbridge.UpdateApiDestination API asynchronously
func (*Client) UpdateApiDestinationWithChan ¶
func (client *Client) UpdateApiDestinationWithChan(request *UpdateApiDestinationRequest) (<-chan *UpdateApiDestinationResponse, <-chan error)
UpdateApiDestinationWithChan invokes the eventbridge.UpdateApiDestination API asynchronously
func (*Client) UpdateConnection ¶
func (client *Client) UpdateConnection(request *UpdateConnectionRequest) (response *UpdateConnectionResponse, err error)
UpdateConnection invokes the eventbridge.UpdateConnection API synchronously
func (*Client) UpdateConnectionWithCallback ¶
func (client *Client) UpdateConnectionWithCallback(request *UpdateConnectionRequest, callback func(response *UpdateConnectionResponse, err error)) <-chan int
UpdateConnectionWithCallback invokes the eventbridge.UpdateConnection API asynchronously
func (*Client) UpdateConnectionWithChan ¶
func (client *Client) UpdateConnectionWithChan(request *UpdateConnectionRequest) (<-chan *UpdateConnectionResponse, <-chan error)
UpdateConnectionWithChan invokes the eventbridge.UpdateConnection API asynchronously
func (*Client) UpdateEventBus ¶
func (client *Client) UpdateEventBus(request *UpdateEventBusRequest) (response *UpdateEventBusResponse, err error)
UpdateEventBus invokes the eventbridge.UpdateEventBus API synchronously
func (*Client) UpdateEventBusWithCallback ¶
func (client *Client) UpdateEventBusWithCallback(request *UpdateEventBusRequest, callback func(response *UpdateEventBusResponse, err error)) <-chan int
UpdateEventBusWithCallback invokes the eventbridge.UpdateEventBus API asynchronously
func (*Client) UpdateEventBusWithChan ¶
func (client *Client) UpdateEventBusWithChan(request *UpdateEventBusRequest) (<-chan *UpdateEventBusResponse, <-chan error)
UpdateEventBusWithChan invokes the eventbridge.UpdateEventBus API asynchronously
func (*Client) UpdateEventSource ¶
func (client *Client) UpdateEventSource(request *UpdateEventSourceRequest) (response *UpdateEventSourceResponse, err error)
UpdateEventSource invokes the eventbridge.UpdateEventSource API synchronously
func (*Client) UpdateEventSourceWithCallback ¶
func (client *Client) UpdateEventSourceWithCallback(request *UpdateEventSourceRequest, callback func(response *UpdateEventSourceResponse, err error)) <-chan int
UpdateEventSourceWithCallback invokes the eventbridge.UpdateEventSource API asynchronously
func (*Client) UpdateEventSourceWithChan ¶
func (client *Client) UpdateEventSourceWithChan(request *UpdateEventSourceRequest) (<-chan *UpdateEventSourceResponse, <-chan error)
UpdateEventSourceWithChan invokes the eventbridge.UpdateEventSource API asynchronously
func (*Client) UpdateEventStreaming ¶
func (client *Client) UpdateEventStreaming(request *UpdateEventStreamingRequest) (response *UpdateEventStreamingResponse, err error)
UpdateEventStreaming invokes the eventbridge.UpdateEventStreaming API synchronously
func (*Client) UpdateEventStreamingWithCallback ¶
func (client *Client) UpdateEventStreamingWithCallback(request *UpdateEventStreamingRequest, callback func(response *UpdateEventStreamingResponse, err error)) <-chan int
UpdateEventStreamingWithCallback invokes the eventbridge.UpdateEventStreaming API asynchronously
func (*Client) UpdateEventStreamingWithChan ¶
func (client *Client) UpdateEventStreamingWithChan(request *UpdateEventStreamingRequest) (<-chan *UpdateEventStreamingResponse, <-chan error)
UpdateEventStreamingWithChan invokes the eventbridge.UpdateEventStreaming API asynchronously
func (*Client) UpdateRule ¶
func (client *Client) UpdateRule(request *UpdateRuleRequest) (response *UpdateRuleResponse, err error)
UpdateRule invokes the eventbridge.UpdateRule API synchronously
func (*Client) UpdateRuleWithCallback ¶
func (client *Client) UpdateRuleWithCallback(request *UpdateRuleRequest, callback func(response *UpdateRuleResponse, err error)) <-chan int
UpdateRuleWithCallback invokes the eventbridge.UpdateRule API asynchronously
func (*Client) UpdateRuleWithChan ¶
func (client *Client) UpdateRuleWithChan(request *UpdateRuleRequest) (<-chan *UpdateRuleResponse, <-chan error)
UpdateRuleWithChan invokes the eventbridge.UpdateRule API asynchronously
type ClientParameters ¶
type ClientParameters struct {
ClientID string `json:"ClientID" xml:"ClientID"`
ClientSecret string `json:"ClientSecret" xml:"ClientSecret"`
}
ClientParameters is a nested struct in eventbridge response
type Concurrency ¶ added in v1.62.286
type Concurrency struct {
Value string `json:"Value" xml:"Value"`
Template string `json:"Template" xml:"Template"`
Form string `json:"Form" xml:"Form"`
}
Concurrency is a nested struct in eventbridge response
type ConnectionsInGetConnection ¶
type ConnectionsInGetConnection struct {
ConnectionsItem []ConnectionsItem `json:"connections" xml:"connections"`
}
ConnectionsInGetConnection is a nested struct in eventbridge response
type ConnectionsInListConnections ¶
type ConnectionsInListConnections struct {
ConnectionsItem []ConnectionsItem `json:"connections" xml:"connections"`
}
ConnectionsInListConnections is a nested struct in eventbridge response
type ConnectionsItem ¶
type ConnectionsItem struct {
GmtCreate int64 `json:"GmtCreate" xml:"GmtCreate"`
ConnectionName string `json:"ConnectionName" xml:"ConnectionName"`
Id int64 `json:"Id" xml:"Id"`
Description string `json:"Description" xml:"Description"`
NetworkParameters NetworkParameters `json:"NetworkParameters" xml:"NetworkParameters"`
AuthParameters AuthParameters `json:"AuthParameters" xml:"AuthParameters"`
}
ConnectionsItem is a nested struct in eventbridge response
type CreateApiDestinationHttpApiParameters ¶
type CreateApiDestinationHttpApiParameters struct {
Endpoint string `name:"Endpoint"`
Method string `name:"Method"`
ApiParameters *[]CreateApiDestinationHttpApiParametersApiParametersItem `name:"ApiParameters" type:"Repeated"`
}
CreateApiDestinationHttpApiParameters is a repeated param struct in CreateApiDestinationRequest
type CreateApiDestinationHttpApiParametersApiParametersItem ¶
type CreateApiDestinationHttpApiParametersApiParametersItem struct {
In string `name:"In"`
Name string `name:"Name"`
Description string `name:"Description"`
DefaultValue string `name:"DefaultValue"`
Type string `name:"Type"`
}
CreateApiDestinationHttpApiParametersApiParametersItem is a repeated param struct in CreateApiDestinationRequest
type CreateApiDestinationRequest ¶
type CreateApiDestinationRequest struct {
*requests.RpcRequest
ConnectionName string `position:"Query" name:"ConnectionName"`
Description string `position:"Query" name:"Description"`
HttpApiParameters CreateApiDestinationHttpApiParameters `position:"Query" name:"HttpApiParameters" type:"Struct"`
ApiDestinationName string `position:"Query" name:"ApiDestinationName"`
InvocationRateLimitPerSecond requests.Integer `position:"Query" name:"InvocationRateLimitPerSecond"`
}
CreateApiDestinationRequest is the request struct for api CreateApiDestination
func CreateCreateApiDestinationRequest ¶
func CreateCreateApiDestinationRequest() (request *CreateApiDestinationRequest)
CreateCreateApiDestinationRequest creates a request to invoke CreateApiDestination API
type CreateApiDestinationResponse ¶
type CreateApiDestinationResponse struct {
*responses.BaseResponse
RequestId string `json:"RequestId" xml:"RequestId"`
Message string `json:"Message" xml:"Message"`
Code string `json:"Code" xml:"Code"`
Date Date `json:"Date" xml:"Date"`
}
CreateApiDestinationResponse is the response struct for api CreateApiDestination
func CreateCreateApiDestinationResponse ¶
func CreateCreateApiDestinationResponse() (response *CreateApiDestinationResponse)
CreateCreateApiDestinationResponse creates a response to parse from CreateApiDestination response
type CreateConnectionAuthParameters ¶
type CreateConnectionAuthParameters struct {
BasicAuthParameters CreateConnectionAuthParametersBasicAuthParameters `name:"BasicAuthParameters" type:"Struct"`
ApiKeyAuthParameters CreateConnectionAuthParametersApiKeyAuthParameters `name:"ApiKeyAuthParameters" type:"Struct"`
AuthorizationType string `name:"AuthorizationType"`
InvocationHttpParameters CreateConnectionAuthParametersInvocationHttpParameters `name:"InvocationHttpParameters" type:"Struct"`
OAuthParameters CreateConnectionAuthParametersOAuthParameters `name:"OAuthParameters" type:"Struct"`
}
CreateConnectionAuthParameters is a repeated param struct in CreateConnectionRequest
type CreateConnectionAuthParametersApiKeyAuthParameters ¶
type CreateConnectionAuthParametersApiKeyAuthParameters struct {
ApiKeyName string `name:"ApiKeyName"`
ApiKeyValue string `name:"ApiKeyValue"`
}
CreateConnectionAuthParametersApiKeyAuthParameters is a repeated param struct in CreateConnectionRequest
type CreateConnectionAuthParametersBasicAuthParameters ¶
type CreateConnectionAuthParametersBasicAuthParameters struct {
Password string `name:"Password"`
Username string `name:"Username"`
}
CreateConnectionAuthParametersBasicAuthParameters is a repeated param struct in CreateConnectionRequest
type CreateConnectionAuthParametersInvocationHttpParameters ¶
type CreateConnectionAuthParametersInvocationHttpParameters struct {
BodyParameters *[]CreateConnectionAuthParametersInvocationHttpParametersBodyParametersItem `name:"BodyParameters" type:"Repeated"`
HeaderParameters *[]CreateConnectionAuthParametersInvocationHttpParametersHeaderParametersItem `name:"HeaderParameters" type:"Repeated"`
QueryStringParameters *[]CreateConnectionAuthParametersInvocationHttpParametersQueryStringParametersItem `name:"QueryStringParameters" type:"Repeated"`
}
CreateConnectionAuthParametersInvocationHttpParameters is a repeated param struct in CreateConnectionRequest
type CreateConnectionAuthParametersInvocationHttpParametersBodyParametersItem ¶
type CreateConnectionAuthParametersInvocationHttpParametersBodyParametersItem struct {
IsValueSecret string `name:"IsValueSecret"`
Value string `name:"Value"`
Key string `name:"Key"`
}
CreateConnectionAuthParametersInvocationHttpParametersBodyParametersItem is a repeated param struct in CreateConnectionRequest
type CreateConnectionAuthParametersInvocationHttpParametersHeaderParametersItem ¶
type CreateConnectionAuthParametersInvocationHttpParametersHeaderParametersItem struct {
IsValueSecret string `name:"IsValueSecret"`
Value string `name:"Value"`
Key string `name:"Key"`
}
CreateConnectionAuthParametersInvocationHttpParametersHeaderParametersItem is a repeated param struct in CreateConnectionRequest
type CreateConnectionAuthParametersInvocationHttpParametersQueryStringParametersItem ¶
type CreateConnectionAuthParametersInvocationHttpParametersQueryStringParametersItem struct {
IsValueSecret string `name:"IsValueSecret"`
Value string `name:"Value"`
Key string `name:"Key"`
}
CreateConnectionAuthParametersInvocationHttpParametersQueryStringParametersItem is a repeated param struct in CreateConnectionRequest
type CreateConnectionAuthParametersOAuthParameters ¶
type CreateConnectionAuthParametersOAuthParameters struct {
ClientParameters CreateConnectionAuthParametersOAuthParametersClientParameters `name:"ClientParameters" type:"Struct"`
AuthorizationEndpoint string `name:"AuthorizationEndpoint"`
HttpMethod string `name:"HttpMethod"`
OAuthHttpParameters CreateConnectionAuthParametersOAuthParametersOAuthHttpParameters `name:"OAuthHttpParameters" type:"Struct"`
}
CreateConnectionAuthParametersOAuthParameters is a repeated param struct in CreateConnectionRequest
type CreateConnectionAuthParametersOAuthParametersClientParameters ¶
type CreateConnectionAuthParametersOAuthParametersClientParameters struct {
ClientID string `name:"ClientID"`
ClientSecret string `name:"ClientSecret"`
}
CreateConnectionAuthParametersOAuthParametersClientParameters is a repeated param struct in CreateConnectionRequest
type CreateConnectionAuthParametersOAuthParametersOAuthHttpParameters ¶
type CreateConnectionAuthParametersOAuthParametersOAuthHttpParameters struct {
BodyParameters *[]CreateConnectionAuthParametersOAuthParametersOAuthHttpParametersBodyParametersItem `name:"BodyParameters" type:"Repeated"`
HeaderParameters *[]CreateConnectionAuthParametersOAuthParametersOAuthHttpParametersHeaderParametersItem `name:"HeaderParameters" type:"Repeated"`
QueryStringParameters *[]CreateConnectionAuthParametersOAuthParametersOAuthHttpParametersQueryStringParametersItem `name:"QueryStringParameters" type:"Repeated"`
}
CreateConnectionAuthParametersOAuthParametersOAuthHttpParameters is a repeated param struct in CreateConnectionRequest
type CreateConnectionAuthParametersOAuthParametersOAuthHttpParametersBodyParametersItem ¶
type CreateConnectionAuthParametersOAuthParametersOAuthHttpParametersBodyParametersItem struct {
IsValueSecret string `name:"IsValueSecret"`
Value string `name:"Value"`
Key string `name:"Key"`
}
CreateConnectionAuthParametersOAuthParametersOAuthHttpParametersBodyParametersItem is a repeated param struct in CreateConnectionRequest
type CreateConnectionAuthParametersOAuthParametersOAuthHttpParametersHeaderParametersItem ¶
type CreateConnectionAuthParametersOAuthParametersOAuthHttpParametersHeaderParametersItem struct {
IsValueSecret string `name:"IsValueSecret"`
Value string `name:"Value"`
Key string `name:"Key"`
}
CreateConnectionAuthParametersOAuthParametersOAuthHttpParametersHeaderParametersItem is a repeated param struct in CreateConnectionRequest
type CreateConnectionAuthParametersOAuthParametersOAuthHttpParametersQueryStringParametersItem ¶
type CreateConnectionAuthParametersOAuthParametersOAuthHttpParametersQueryStringParametersItem struct {
IsValueSecret string `name:"IsValueSecret"`
Value string `name:"Value"`
Key string `name:"Key"`
}
CreateConnectionAuthParametersOAuthParametersOAuthHttpParametersQueryStringParametersItem is a repeated param struct in CreateConnectionRequest
type CreateConnectionNetworkParameters ¶
type CreateConnectionNetworkParameters struct {
VpcId string `name:"VpcId"`
SecurityGroupId string `name:"SecurityGroupId"`
NetworkType string `name:"NetworkType"`
VswitcheId string `name:"VswitcheId"`
}
CreateConnectionNetworkParameters is a repeated param struct in CreateConnectionRequest
type CreateConnectionRequest ¶
type CreateConnectionRequest struct {
*requests.RpcRequest
ConnectionName string `position:"Query" name:"ConnectionName"`
Description string `position:"Query" name:"Description"`
NetworkParameters CreateConnectionNetworkParameters `position:"Query" name:"NetworkParameters" type:"Struct"`
AuthParameters CreateConnectionAuthParameters `position:"Query" name:"AuthParameters" type:"Struct"`
}
CreateConnectionRequest is the request struct for api CreateConnection
func CreateCreateConnectionRequest ¶
func CreateCreateConnectionRequest() (request *CreateConnectionRequest)
CreateCreateConnectionRequest creates a request to invoke CreateConnection API
type CreateConnectionResponse ¶
type CreateConnectionResponse struct {
*responses.BaseResponse
RequestId string `json:"RequestId" xml:"RequestId"`
Message string `json:"Message" xml:"Message"`
Code string `json:"Code" xml:"Code"`
Data Data `json:"Data" xml:"Data"`
}
CreateConnectionResponse is the response struct for api CreateConnection
func CreateCreateConnectionResponse ¶
func CreateCreateConnectionResponse() (response *CreateConnectionResponse)
CreateCreateConnectionResponse creates a response to parse from CreateConnection response
type CreateEventBusRequest ¶
type CreateEventBusRequest struct {
*requests.RpcRequest
ClientToken string `position:"Query" name:"ClientToken"`
Description string `position:"Query" name:"Description"`
EventBusName string `position:"Query" name:"EventBusName"`
}
CreateEventBusRequest is the request struct for api CreateEventBus
func CreateCreateEventBusRequest ¶
func CreateCreateEventBusRequest() (request *CreateEventBusRequest)
CreateCreateEventBusRequest creates a request to invoke CreateEventBus API
type CreateEventBusResponse ¶
type CreateEventBusResponse struct {
*responses.BaseResponse
Message string `json:"Message" xml:"Message"`
RequestId string `json:"RequestId" xml:"RequestId"`
Code string `json:"Code" xml:"Code"`
Success bool `json:"Success" xml:"Success"`
Data Data `json:"Data" xml:"Data"`
}
CreateEventBusResponse is the response struct for api CreateEventBus
func CreateCreateEventBusResponse ¶
func CreateCreateEventBusResponse() (response *CreateEventBusResponse)
CreateCreateEventBusResponse creates a response to parse from CreateEventBus response
type CreateEventSourceRequest ¶
type CreateEventSourceRequest struct {
*requests.RpcRequest
Description string `position:"Body" name:"Description"`
EventBusName string `position:"Body" name:"EventBusName"`
SourceMNSParameters CreateEventSourceSourceMNSParameters `position:"Body" name:"SourceMNSParameters" type:"Struct"`
LinkedExternalSource requests.Boolean `position:"Body" name:"LinkedExternalSource"`
ExternalSourceType string `position:"Body" name:"ExternalSourceType"`
ExternalSourceConfig string `position:"Body" name:"ExternalSourceConfig"`
SourceRabbitMQParameters CreateEventSourceSourceRabbitMQParameters `position:"Body" name:"SourceRabbitMQParameters" type:"Struct"`
SourceRocketMQParameters CreateEventSourceSourceRocketMQParameters `position:"Body" name:"SourceRocketMQParameters" type:"Struct"`
SourceSLSParameters CreateEventSourceSourceSLSParameters `position:"Body" name:"SourceSLSParameters" type:"Struct"`
SourceScheduledEventParameters CreateEventSourceSourceScheduledEventParameters `position:"Body" name:"SourceScheduledEventParameters" type:"Struct"`
SourceKafkaParameters CreateEventSourceSourceKafkaParameters `position:"Body" name:"SourceKafkaParameters" type:"Struct"`
SourceHttpEventParameters CreateEventSourceSourceHttpEventParameters `position:"Body" name:"SourceHttpEventParameters" type:"Struct"`
EventSourceName string `position:"Body" name:"EventSourceName"`
}
CreateEventSourceRequest is the request struct for api CreateEventSource
func CreateCreateEventSourceRequest ¶
func CreateCreateEventSourceRequest() (request *CreateEventSourceRequest)
CreateCreateEventSourceRequest creates a request to invoke CreateEventSource API
type CreateEventSourceResponse ¶
type CreateEventSourceResponse struct {
*responses.BaseResponse
Message string `json:"Message" xml:"Message"`
RequestId string `json:"RequestId" xml:"RequestId"`
Code string `json:"Code" xml:"Code"`
Success bool `json:"Success" xml:"Success"`
Data Data `json:"Data" xml:"Data"`
}
CreateEventSourceResponse is the response struct for api CreateEventSource
func CreateCreateEventSourceResponse ¶
func CreateCreateEventSourceResponse() (response *CreateEventSourceResponse)
CreateCreateEventSourceResponse creates a response to parse from CreateEventSource response
type CreateEventSourceSourceHttpEventParameters ¶
type CreateEventSourceSourceHttpEventParameters struct {
Referer *[]string `name:"Referer" type:"Repeated"`
Method *[]string `name:"Method" type:"Repeated"`
Ip *[]string `name:"Ip" type:"Repeated"`
SecurityConfig string `name:"SecurityConfig"`
Type string `name:"Type"`
}
CreateEventSourceSourceHttpEventParameters is a repeated param struct in CreateEventSourceRequest
type CreateEventSourceSourceKafkaParameters ¶ added in v1.62.286
type CreateEventSourceSourceKafkaParameters struct {
InstanceId string `name:"InstanceId"`
ConsumerGroup string `name:"ConsumerGroup"`
RegionId string `name:"RegionId"`
VSwitchIds string `name:"VSwitchIds"`
VpcId string `name:"VpcId"`
SecurityGroupId string `name:"SecurityGroupId"`
Topic string `name:"Topic"`
OffsetReset string `name:"OffsetReset"`
MaximumTasks string `name:"MaximumTasks"`
Network string `name:"Network"`
}
CreateEventSourceSourceKafkaParameters is a repeated param struct in CreateEventSourceRequest
type CreateEventSourceSourceMNSParameters ¶
type CreateEventSourceSourceMNSParameters struct {
QueueName string `name:"QueueName"`
RegionId string `name:"RegionId"`
IsBase64Decode string `name:"IsBase64Decode"`
}
CreateEventSourceSourceMNSParameters is a repeated param struct in CreateEventSourceRequest
type CreateEventSourceSourceRabbitMQParameters ¶
type CreateEventSourceSourceRabbitMQParameters struct {
QueueName string `name:"QueueName"`
VirtualHostName string `name:"VirtualHostName"`
InstanceId string `name:"InstanceId"`
RegionId string `name:"RegionId"`
}
CreateEventSourceSourceRabbitMQParameters is a repeated param struct in CreateEventSourceRequest
type CreateEventSourceSourceRocketMQParameters ¶
type CreateEventSourceSourceRocketMQParameters struct {
InstanceNetwork string `name:"InstanceNetwork"`
InstanceVSwitchIds string `name:"InstanceVSwitchIds"`
InstanceSecurityGroupId string `name:"InstanceSecurityGroupId"`
InstanceId string `name:"InstanceId"`
Offset string `name:"Offset"`
InstanceVpcId string `name:"InstanceVpcId"`
RegionId string `name:"RegionId"`
GroupID string `name:"GroupID"`
Topic string `name:"Topic"`
InstanceType string `name:"InstanceType"`
Tag string `name:"Tag"`
Timestamp string `name:"Timestamp"`
}
CreateEventSourceSourceRocketMQParameters is a repeated param struct in CreateEventSourceRequest
type CreateEventSourceSourceSLSParameters ¶
type CreateEventSourceSourceSLSParameters struct {
RoleName string `name:"RoleName"`
Project string `name:"Project"`
LogStore string `name:"LogStore"`
ConsumePosition string `name:"ConsumePosition"`
}
CreateEventSourceSourceSLSParameters is a repeated param struct in CreateEventSourceRequest
type CreateEventSourceSourceScheduledEventParameters ¶ added in v1.62.286
type CreateEventSourceSourceScheduledEventParameters struct {
Schedule string `name:"Schedule"`
TimeZone string `name:"TimeZone"`
}
CreateEventSourceSourceScheduledEventParameters is a repeated param struct in CreateEventSourceRequest
type CreateEventStreamingRequest ¶
type CreateEventStreamingRequest struct {
*requests.RpcRequest
Sink CreateEventStreamingSink `position:"Body" name:"Sink" type:"Struct"`
Description string `position:"Body" name:"Description"`
FilterPattern string `position:"Body" name:"FilterPattern"`
Source CreateEventStreamingSource `position:"Body" name:"Source" type:"Struct"`
RunOptions CreateEventStreamingRunOptions `position:"Body" name:"RunOptions" type:"Struct"`
EventStreamingName string `position:"Body" name:"EventStreamingName"`
Tag string `position:"Body" name:"Tag"`
}
CreateEventStreamingRequest is the request struct for api CreateEventStreaming
func CreateCreateEventStreamingRequest ¶
func CreateCreateEventStreamingRequest() (request *CreateEventStreamingRequest)
CreateCreateEventStreamingRequest creates a request to invoke CreateEventStreaming API
type CreateEventStreamingResponse ¶
type CreateEventStreamingResponse struct {
*responses.BaseResponse
Message string `json:"Message" xml:"Message"`
RequestId string `json:"RequestId" xml:"RequestId"`
Code string `json:"Code" xml:"Code"`
Success bool `json:"Success" xml:"Success"`
Data Data `json:"Data" xml:"Data"`
}
CreateEventStreamingResponse is the response struct for api CreateEventStreaming
func CreateCreateEventStreamingResponse ¶
func CreateCreateEventStreamingResponse() (response *CreateEventStreamingResponse)
CreateCreateEventStreamingResponse creates a response to parse from CreateEventStreaming response
type CreateEventStreamingRunOptions ¶
type CreateEventStreamingRunOptions struct {
BatchWindow CreateEventStreamingRunOptionsBatchWindow `name:"BatchWindow" type:"Struct"`
RetryStrategy CreateEventStreamingRunOptionsRetryStrategy `name:"RetryStrategy" type:"Struct"`
DeadLetterQueue CreateEventStreamingRunOptionsDeadLetterQueue `name:"DeadLetterQueue" type:"Struct"`
MaximumTasks string `name:"MaximumTasks"`
ErrorsTolerance string `name:"ErrorsTolerance"`
}
CreateEventStreamingRunOptions is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingRunOptionsBatchWindow ¶
type CreateEventStreamingRunOptionsBatchWindow struct {
CountBasedWindow string `name:"CountBasedWindow"`
TimeBasedWindow string `name:"TimeBasedWindow"`
}
CreateEventStreamingRunOptionsBatchWindow is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingRunOptionsDeadLetterQueue ¶
type CreateEventStreamingRunOptionsDeadLetterQueue struct {
Arn string `name:"Arn"`
}
CreateEventStreamingRunOptionsDeadLetterQueue is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingRunOptionsRetryStrategy ¶
type CreateEventStreamingRunOptionsRetryStrategy struct {
PushRetryStrategy string `name:"PushRetryStrategy"`
MaximumRetryAttempts string `name:"MaximumRetryAttempts"`
MaximumEventAgeInSeconds string `name:"MaximumEventAgeInSeconds"`
}
CreateEventStreamingRunOptionsRetryStrategy is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSink ¶
type CreateEventStreamingSink struct {
SinkRabbitMQParameters CreateEventStreamingSinkSinkRabbitMQParameters `name:"SinkRabbitMQParameters" type:"Struct"`
SinkMNSParameters CreateEventStreamingSinkSinkMNSParameters `name:"SinkMNSParameters" type:"Struct"`
SinkDataHubParameters CreateEventStreamingSinkSinkDataHubParameters `name:"SinkDataHubParameters" type:"Struct"`
SinkKafkaParameters CreateEventStreamingSinkSinkKafkaParameters `name:"SinkKafkaParameters" type:"Struct"`
SinkFcParameters CreateEventStreamingSinkSinkFcParameters `name:"SinkFcParameters" type:"Struct"`
SinkSLSParameters CreateEventStreamingSinkSinkSLSParameters `name:"SinkSLSParameters" type:"Struct"`
SinkRocketMQParameters CreateEventStreamingSinkSinkRocketMQParameters `name:"SinkRocketMQParameters" type:"Struct"`
}
CreateEventStreamingSink is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkDataHubParameters ¶
type CreateEventStreamingSinkSinkDataHubParameters struct {
RoleName CreateEventStreamingSinkSinkDataHubParametersRoleName `name:"RoleName" type:"Struct"`
Project CreateEventStreamingSinkSinkDataHubParametersProject `name:"Project" type:"Struct"`
Topic CreateEventStreamingSinkSinkDataHubParametersTopic `name:"Topic" type:"Struct"`
TopicType CreateEventStreamingSinkSinkDataHubParametersTopicType `name:"TopicType" type:"Struct"`
Body CreateEventStreamingSinkSinkDataHubParametersBody `name:"Body" type:"Struct"`
TopicSchema CreateEventStreamingSinkSinkDataHubParametersTopicSchema `name:"TopicSchema" type:"Struct"`
}
CreateEventStreamingSinkSinkDataHubParameters is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkDataHubParametersBody ¶
type CreateEventStreamingSinkSinkDataHubParametersBody struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkDataHubParametersBody is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkDataHubParametersProject ¶
type CreateEventStreamingSinkSinkDataHubParametersProject struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkDataHubParametersProject is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkDataHubParametersRoleName ¶
type CreateEventStreamingSinkSinkDataHubParametersRoleName struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkDataHubParametersRoleName is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkDataHubParametersTopic ¶
type CreateEventStreamingSinkSinkDataHubParametersTopic struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkDataHubParametersTopic is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkDataHubParametersTopicSchema ¶
type CreateEventStreamingSinkSinkDataHubParametersTopicSchema struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkDataHubParametersTopicSchema is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkDataHubParametersTopicType ¶
type CreateEventStreamingSinkSinkDataHubParametersTopicType struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkDataHubParametersTopicType is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkFcParameters ¶
type CreateEventStreamingSinkSinkFcParameters struct {
InvocationType CreateEventStreamingSinkSinkFcParametersInvocationType `name:"InvocationType" type:"Struct"`
FunctionName CreateEventStreamingSinkSinkFcParametersFunctionName `name:"FunctionName" type:"Struct"`
Qualifier CreateEventStreamingSinkSinkFcParametersQualifier `name:"Qualifier" type:"Struct"`
ServiceName CreateEventStreamingSinkSinkFcParametersServiceName `name:"ServiceName" type:"Struct"`
Body CreateEventStreamingSinkSinkFcParametersBody `name:"Body" type:"Struct"`
Concurrency CreateEventStreamingSinkSinkFcParametersConcurrency `name:"Concurrency" type:"Struct"`
}
CreateEventStreamingSinkSinkFcParameters is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkFcParametersBody ¶
type CreateEventStreamingSinkSinkFcParametersBody struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkFcParametersBody is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkFcParametersConcurrency ¶ added in v1.62.286
type CreateEventStreamingSinkSinkFcParametersConcurrency struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkFcParametersConcurrency is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkFcParametersFunctionName ¶
type CreateEventStreamingSinkSinkFcParametersFunctionName struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkFcParametersFunctionName is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkFcParametersInvocationType ¶
type CreateEventStreamingSinkSinkFcParametersInvocationType struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkFcParametersInvocationType is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkFcParametersQualifier ¶
type CreateEventStreamingSinkSinkFcParametersQualifier struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkFcParametersQualifier is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkFcParametersServiceName ¶
type CreateEventStreamingSinkSinkFcParametersServiceName struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkFcParametersServiceName is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkKafkaParameters ¶
type CreateEventStreamingSinkSinkKafkaParameters struct {
InstanceId CreateEventStreamingSinkSinkKafkaParametersInstanceId `name:"InstanceId" type:"Struct"`
Acks CreateEventStreamingSinkSinkKafkaParametersAcks `name:"Acks" type:"Struct"`
Topic CreateEventStreamingSinkSinkKafkaParametersTopic `name:"Topic" type:"Struct"`
SaslUser CreateEventStreamingSinkSinkKafkaParametersSaslUser `name:"SaslUser" type:"Struct"`
Value CreateEventStreamingSinkSinkKafkaParametersValue `name:"Value" type:"Struct"`
Key CreateEventStreamingSinkSinkKafkaParametersKey `name:"Key" type:"Struct"`
}
CreateEventStreamingSinkSinkKafkaParameters is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkKafkaParametersAcks ¶
type CreateEventStreamingSinkSinkKafkaParametersAcks struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkKafkaParametersAcks is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkKafkaParametersInstanceId ¶
type CreateEventStreamingSinkSinkKafkaParametersInstanceId struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkKafkaParametersInstanceId is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkKafkaParametersKey ¶
type CreateEventStreamingSinkSinkKafkaParametersKey struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkKafkaParametersKey is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkKafkaParametersSaslUser ¶
type CreateEventStreamingSinkSinkKafkaParametersSaslUser struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkKafkaParametersSaslUser is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkKafkaParametersTopic ¶
type CreateEventStreamingSinkSinkKafkaParametersTopic struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkKafkaParametersTopic is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkKafkaParametersValue ¶
type CreateEventStreamingSinkSinkKafkaParametersValue struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkKafkaParametersValue is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkMNSParameters ¶
type CreateEventStreamingSinkSinkMNSParameters struct {
QueueName CreateEventStreamingSinkSinkMNSParametersQueueName `name:"QueueName" type:"Struct"`
IsBase64Encode CreateEventStreamingSinkSinkMNSParametersIsBase64Encode `name:"IsBase64Encode" type:"Struct"`
Body CreateEventStreamingSinkSinkMNSParametersBody `name:"Body" type:"Struct"`
}
CreateEventStreamingSinkSinkMNSParameters is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkMNSParametersBody ¶
type CreateEventStreamingSinkSinkMNSParametersBody struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkMNSParametersBody is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkMNSParametersIsBase64Encode ¶
type CreateEventStreamingSinkSinkMNSParametersIsBase64Encode struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkMNSParametersIsBase64Encode is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkMNSParametersQueueName ¶
type CreateEventStreamingSinkSinkMNSParametersQueueName struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkMNSParametersQueueName is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkRabbitMQParameters ¶
type CreateEventStreamingSinkSinkRabbitMQParameters struct {
RoutingKey CreateEventStreamingSinkSinkRabbitMQParametersRoutingKey `name:"RoutingKey" type:"Struct"`
QueueName CreateEventStreamingSinkSinkRabbitMQParametersQueueName `name:"QueueName" type:"Struct"`
VirtualHostName CreateEventStreamingSinkSinkRabbitMQParametersVirtualHostName `name:"VirtualHostName" type:"Struct"`
InstanceId CreateEventStreamingSinkSinkRabbitMQParametersInstanceId `name:"InstanceId" type:"Struct"`
TargetType CreateEventStreamingSinkSinkRabbitMQParametersTargetType `name:"TargetType" type:"Struct"`
MessageId CreateEventStreamingSinkSinkRabbitMQParametersMessageId `name:"MessageId" type:"Struct"`
Exchange CreateEventStreamingSinkSinkRabbitMQParametersExchange `name:"Exchange" type:"Struct"`
Body CreateEventStreamingSinkSinkRabbitMQParametersBody `name:"Body" type:"Struct"`
Properties CreateEventStreamingSinkSinkRabbitMQParametersProperties `name:"Properties" type:"Struct"`
}
CreateEventStreamingSinkSinkRabbitMQParameters is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkRabbitMQParametersBody ¶
type CreateEventStreamingSinkSinkRabbitMQParametersBody struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkRabbitMQParametersBody is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkRabbitMQParametersExchange ¶
type CreateEventStreamingSinkSinkRabbitMQParametersExchange struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkRabbitMQParametersExchange is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkRabbitMQParametersInstanceId ¶
type CreateEventStreamingSinkSinkRabbitMQParametersInstanceId struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkRabbitMQParametersInstanceId is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkRabbitMQParametersMessageId ¶
type CreateEventStreamingSinkSinkRabbitMQParametersMessageId struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkRabbitMQParametersMessageId is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkRabbitMQParametersProperties ¶
type CreateEventStreamingSinkSinkRabbitMQParametersProperties struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkRabbitMQParametersProperties is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkRabbitMQParametersQueueName ¶
type CreateEventStreamingSinkSinkRabbitMQParametersQueueName struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkRabbitMQParametersQueueName is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkRabbitMQParametersRoutingKey ¶
type CreateEventStreamingSinkSinkRabbitMQParametersRoutingKey struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkRabbitMQParametersRoutingKey is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkRabbitMQParametersTargetType ¶
type CreateEventStreamingSinkSinkRabbitMQParametersTargetType struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkRabbitMQParametersTargetType is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkRabbitMQParametersVirtualHostName ¶
type CreateEventStreamingSinkSinkRabbitMQParametersVirtualHostName struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkRabbitMQParametersVirtualHostName is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkRocketMQParameters ¶
type CreateEventStreamingSinkSinkRocketMQParameters struct {
Keys CreateEventStreamingSinkSinkRocketMQParametersKeys `name:"Keys" type:"Struct"`
VSwitchIds CreateEventStreamingSinkSinkRocketMQParametersVSwitchIds `name:"VSwitchIds" type:"Struct"`
SecurityGroupId CreateEventStreamingSinkSinkRocketMQParametersSecurityGroupId `name:"SecurityGroupId" type:"Struct"`
InstanceUsername CreateEventStreamingSinkSinkRocketMQParametersInstanceUsername `name:"InstanceUsername" type:"Struct"`
Body CreateEventStreamingSinkSinkRocketMQParametersBody `name:"Body" type:"Struct"`
Tags CreateEventStreamingSinkSinkRocketMQParametersTags `name:"Tags" type:"Struct"`
Network CreateEventStreamingSinkSinkRocketMQParametersNetwork `name:"Network" type:"Struct"`
InstancePassword CreateEventStreamingSinkSinkRocketMQParametersInstancePassword `name:"InstancePassword" type:"Struct"`
InstanceId CreateEventStreamingSinkSinkRocketMQParametersInstanceId `name:"InstanceId" type:"Struct"`
InstanceEndpoint CreateEventStreamingSinkSinkRocketMQParametersInstanceEndpoint `name:"InstanceEndpoint" type:"Struct"`
VpcId CreateEventStreamingSinkSinkRocketMQParametersVpcId `name:"VpcId" type:"Struct"`
Topic CreateEventStreamingSinkSinkRocketMQParametersTopic `name:"Topic" type:"Struct"`
InstanceType CreateEventStreamingSinkSinkRocketMQParametersInstanceType `name:"InstanceType" type:"Struct"`
Properties CreateEventStreamingSinkSinkRocketMQParametersProperties `name:"Properties" type:"Struct"`
}
CreateEventStreamingSinkSinkRocketMQParameters is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkRocketMQParametersBody ¶
type CreateEventStreamingSinkSinkRocketMQParametersBody struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkRocketMQParametersBody is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkRocketMQParametersInstanceEndpoint ¶
type CreateEventStreamingSinkSinkRocketMQParametersInstanceEndpoint struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkRocketMQParametersInstanceEndpoint is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkRocketMQParametersInstanceId ¶
type CreateEventStreamingSinkSinkRocketMQParametersInstanceId struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkRocketMQParametersInstanceId is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkRocketMQParametersInstancePassword ¶
type CreateEventStreamingSinkSinkRocketMQParametersInstancePassword struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkRocketMQParametersInstancePassword is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkRocketMQParametersInstanceType ¶
type CreateEventStreamingSinkSinkRocketMQParametersInstanceType struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkRocketMQParametersInstanceType is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkRocketMQParametersInstanceUsername ¶
type CreateEventStreamingSinkSinkRocketMQParametersInstanceUsername struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkRocketMQParametersInstanceUsername is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkRocketMQParametersKeys ¶
type CreateEventStreamingSinkSinkRocketMQParametersKeys struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkRocketMQParametersKeys is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkRocketMQParametersNetwork ¶
type CreateEventStreamingSinkSinkRocketMQParametersNetwork struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkRocketMQParametersNetwork is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkRocketMQParametersProperties ¶
type CreateEventStreamingSinkSinkRocketMQParametersProperties struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkRocketMQParametersProperties is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkRocketMQParametersSecurityGroupId ¶
type CreateEventStreamingSinkSinkRocketMQParametersSecurityGroupId struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkRocketMQParametersSecurityGroupId is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkRocketMQParametersTags ¶
type CreateEventStreamingSinkSinkRocketMQParametersTags struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkRocketMQParametersTags is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkRocketMQParametersTopic ¶
type CreateEventStreamingSinkSinkRocketMQParametersTopic struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkRocketMQParametersTopic is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkRocketMQParametersVSwitchIds ¶
type CreateEventStreamingSinkSinkRocketMQParametersVSwitchIds struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkRocketMQParametersVSwitchIds is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkRocketMQParametersVpcId ¶
type CreateEventStreamingSinkSinkRocketMQParametersVpcId struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkRocketMQParametersVpcId is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkSLSParameters ¶
type CreateEventStreamingSinkSinkSLSParameters struct {
RoleName CreateEventStreamingSinkSinkSLSParametersRoleName `name:"RoleName" type:"Struct"`
Project CreateEventStreamingSinkSinkSLSParametersProject `name:"Project" type:"Struct"`
Topic CreateEventStreamingSinkSinkSLSParametersTopic `name:"Topic" type:"Struct"`
Body CreateEventStreamingSinkSinkSLSParametersBody `name:"Body" type:"Struct"`
LogStore CreateEventStreamingSinkSinkSLSParametersLogStore `name:"LogStore" type:"Struct"`
}
CreateEventStreamingSinkSinkSLSParameters is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkSLSParametersBody ¶
type CreateEventStreamingSinkSinkSLSParametersBody struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkSLSParametersBody is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkSLSParametersLogStore ¶
type CreateEventStreamingSinkSinkSLSParametersLogStore struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkSLSParametersLogStore is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkSLSParametersProject ¶
type CreateEventStreamingSinkSinkSLSParametersProject struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkSLSParametersProject is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkSLSParametersRoleName ¶
type CreateEventStreamingSinkSinkSLSParametersRoleName struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkSLSParametersRoleName is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSinkSinkSLSParametersTopic ¶
type CreateEventStreamingSinkSinkSLSParametersTopic struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateEventStreamingSinkSinkSLSParametersTopic is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSource ¶
type CreateEventStreamingSource struct {
SourceMQTTParameters CreateEventStreamingSourceSourceMQTTParameters `name:"SourceMQTTParameters" type:"Struct"`
SourceRocketMQParameters CreateEventStreamingSourceSourceRocketMQParameters `name:"SourceRocketMQParameters" type:"Struct"`
SourceSLSParameters CreateEventStreamingSourceSourceSLSParameters `name:"SourceSLSParameters" type:"Struct"`
SourceDTSParameters CreateEventStreamingSourceSourceDTSParameters `name:"SourceDTSParameters" type:"Struct"`
SourceKafkaParameters CreateEventStreamingSourceSourceKafkaParameters `name:"SourceKafkaParameters" type:"Struct"`
SourceMNSParameters CreateEventStreamingSourceSourceMNSParameters `name:"SourceMNSParameters" type:"Struct"`
SourceRabbitMQParameters CreateEventStreamingSourceSourceRabbitMQParameters `name:"SourceRabbitMQParameters" type:"Struct"`
}
CreateEventStreamingSource is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSourceSourceDTSParameters ¶
type CreateEventStreamingSourceSourceDTSParameters struct {
BrokerUrl string `name:"BrokerUrl"`
Password string `name:"Password"`
InitCheckPoint string `name:"InitCheckPoint"`
Topic string `name:"Topic"`
TaskId string `name:"TaskId"`
Sid string `name:"Sid"`
Username string `name:"Username"`
}
CreateEventStreamingSourceSourceDTSParameters is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSourceSourceKafkaParameters ¶
type CreateEventStreamingSourceSourceKafkaParameters struct {
InstanceId string `name:"InstanceId"`
ConsumerGroup string `name:"ConsumerGroup"`
RegionId string `name:"RegionId"`
VSwitchIds string `name:"VSwitchIds"`
VpcId string `name:"VpcId"`
SecurityGroupId string `name:"SecurityGroupId"`
Topic string `name:"Topic"`
OffsetReset string `name:"OffsetReset"`
Network string `name:"Network"`
}
CreateEventStreamingSourceSourceKafkaParameters is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSourceSourceMNSParameters ¶
type CreateEventStreamingSourceSourceMNSParameters struct {
QueueName string `name:"QueueName"`
RegionId string `name:"RegionId"`
IsBase64Decode string `name:"IsBase64Decode"`
}
CreateEventStreamingSourceSourceMNSParameters is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSourceSourceMQTTParameters ¶
type CreateEventStreamingSourceSourceMQTTParameters struct {
InstanceId string `name:"InstanceId"`
RegionId string `name:"RegionId"`
Topic string `name:"Topic"`
}
CreateEventStreamingSourceSourceMQTTParameters is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSourceSourceRabbitMQParameters ¶
type CreateEventStreamingSourceSourceRabbitMQParameters struct {
QueueName string `name:"QueueName"`
VirtualHostName string `name:"VirtualHostName"`
InstanceId string `name:"InstanceId"`
RegionId string `name:"RegionId"`
}
CreateEventStreamingSourceSourceRabbitMQParameters is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSourceSourceRocketMQParameters ¶
type CreateEventStreamingSourceSourceRocketMQParameters struct {
FilterSql string `name:"FilterSql"`
InstanceSecurityGroupId string `name:"InstanceSecurityGroupId"`
Offset string `name:"Offset"`
VSwitchIds string `name:"VSwitchIds"`
GroupID string `name:"GroupID"`
SecurityGroupId string `name:"SecurityGroupId"`
InstanceUsername string `name:"InstanceUsername"`
FilterType string `name:"FilterType"`
Network string `name:"Network"`
AuthType string `name:"AuthType"`
InstancePassword string `name:"InstancePassword"`
InstanceVSwitchIds string `name:"InstanceVSwitchIds"`
InstanceNetwork string `name:"InstanceNetwork"`
InstanceId string `name:"InstanceId"`
InstanceEndpoint string `name:"InstanceEndpoint"`
InstanceVpcId string `name:"InstanceVpcId"`
RegionId string `name:"RegionId"`
VpcId string `name:"VpcId"`
Topic string `name:"Topic"`
InstanceType string `name:"InstanceType"`
Tag string `name:"Tag"`
Timestamp string `name:"Timestamp"`
}
CreateEventStreamingSourceSourceRocketMQParameters is a repeated param struct in CreateEventStreamingRequest
type CreateEventStreamingSourceSourceSLSParameters ¶
type CreateEventStreamingSourceSourceSLSParameters struct {
RoleName string `name:"RoleName"`
Project string `name:"Project"`
LogStore string `name:"LogStore"`
ConsumePosition string `name:"ConsumePosition"`
}
CreateEventStreamingSourceSourceSLSParameters is a repeated param struct in CreateEventStreamingRequest
type CreateRuleEventTargets ¶
type CreateRuleEventTargets struct {
Endpoint string `name:"Endpoint"`
PushRetryStrategy string `name:"PushRetryStrategy"`
ParamList *[]CreateRuleEventTargetsParamListItem `name:"ParamList" type:"Repeated"`
Id string `name:"Id"`
DeadLetterQueue CreateRuleEventTargetsDeadLetterQueue `name:"DeadLetterQueue" type:"Struct"`
Type string `name:"Type"`
ErrorsTolerance string `name:"ErrorsTolerance"`
}
CreateRuleEventTargets is a repeated param struct in CreateRuleRequest
type CreateRuleEventTargetsDeadLetterQueue ¶
type CreateRuleEventTargetsDeadLetterQueue struct {
Arn string `name:"Arn"`
}
CreateRuleEventTargetsDeadLetterQueue is a repeated param struct in CreateRuleRequest
type CreateRuleEventTargetsParamListItem ¶
type CreateRuleEventTargetsParamListItem struct {
Template string `name:"Template"`
ResourceKey string `name:"ResourceKey"`
Form string `name:"Form"`
Value string `name:"Value"`
}
CreateRuleEventTargetsParamListItem is a repeated param struct in CreateRuleRequest
type CreateRuleRequest ¶
type CreateRuleRequest struct {
*requests.RpcRequest
ClientToken string `position:"Query" name:"ClientToken"`
Description string `position:"Query" name:"Description"`
RuleName string `position:"Query" name:"RuleName"`
EventBusName string `position:"Query" name:"EventBusName"`
Targets string `position:"Query" name:"Targets"`
EventTargets *[]CreateRuleEventTargets `position:"Query" name:"EventTargets" type:"Json"`
FilterPattern string `position:"Query" name:"FilterPattern"`
Status string `position:"Query" name:"Status"`
}
CreateRuleRequest is the request struct for api CreateRule
func CreateCreateRuleRequest ¶
func CreateCreateRuleRequest() (request *CreateRuleRequest)
CreateCreateRuleRequest creates a request to invoke CreateRule API
type CreateRuleResponse ¶
type CreateRuleResponse struct {
*responses.BaseResponse
Message string `json:"Message" xml:"Message"`
RequestId string `json:"RequestId" xml:"RequestId"`
Code string `json:"Code" xml:"Code"`
Success bool `json:"Success" xml:"Success"`
Data Data `json:"Data" xml:"Data"`
}
CreateRuleResponse is the response struct for api CreateRule
func CreateCreateRuleResponse ¶
func CreateCreateRuleResponse() (response *CreateRuleResponse)
CreateCreateRuleResponse creates a response to parse from CreateRule response
type CreateServiceLinkedRoleForProductRequest ¶
type CreateServiceLinkedRoleForProductRequest struct {
*requests.RpcRequest
ProductName string `position:"Query" name:"ProductName"`
}
CreateServiceLinkedRoleForProductRequest is the request struct for api CreateServiceLinkedRoleForProduct
func CreateCreateServiceLinkedRoleForProductRequest ¶
func CreateCreateServiceLinkedRoleForProductRequest() (request *CreateServiceLinkedRoleForProductRequest)
CreateCreateServiceLinkedRoleForProductRequest creates a request to invoke CreateServiceLinkedRoleForProduct API
type CreateServiceLinkedRoleForProductResponse ¶
type CreateServiceLinkedRoleForProductResponse struct {
*responses.BaseResponse
Message string `json:"Message" xml:"Message"`
RequestId string `json:"RequestId" xml:"RequestId"`
Code string `json:"Code" xml:"Code"`
Success bool `json:"Success" xml:"Success"`
}
CreateServiceLinkedRoleForProductResponse is the response struct for api CreateServiceLinkedRoleForProduct
func CreateCreateServiceLinkedRoleForProductResponse ¶
func CreateCreateServiceLinkedRoleForProductResponse() (response *CreateServiceLinkedRoleForProductResponse)
CreateCreateServiceLinkedRoleForProductResponse creates a response to parse from CreateServiceLinkedRoleForProduct response
type Data ¶
type Data struct {
EventSourceARN string `json:"EventSourceARN" xml:"EventSourceARN"`
RuleName string `json:"RuleName" xml:"RuleName"`
CreateTimestamp int64 `json:"CreateTimestamp" xml:"CreateTimestamp"`
ConnectionName string `json:"ConnectionName" xml:"ConnectionName"`
EventBusName string `json:"EventBusName" xml:"EventBusName"`
ApiDestinationName string `json:"ApiDestinationName" xml:"ApiDestinationName"`
FilterPattern string `json:"FilterPattern" xml:"FilterPattern"`
Tag string `json:"Tag" xml:"Tag"`
CreatedTimestamp int64 `json:"CreatedTimestamp" xml:"CreatedTimestamp"`
EventBusARN string `json:"EventBusARN" xml:"EventBusARN"`
Description string `json:"Description" xml:"Description"`
InvocationRateLimitPerSecond int64 `json:"InvocationRateLimitPerSecond" xml:"InvocationRateLimitPerSecond"`
EventStreamingARN string `json:"EventStreamingARN" xml:"EventStreamingARN"`
MaxResults float64 `json:"MaxResults" xml:"MaxResults"`
RuleARN string `json:"RuleARN" xml:"RuleARN"`
Result bool `json:"Result" xml:"Result"`
EventStreamingName string `json:"EventStreamingName" xml:"EventStreamingName"`
GmtCreate int64 `json:"GmtCreate" xml:"GmtCreate"`
NextToken string `json:"NextToken" xml:"NextToken"`
Total float64 `json:"Total" xml:"Total"`
Status string `json:"Status" xml:"Status"`
ErrorEntriesCount int `json:"ErrorEntriesCount" xml:"ErrorEntriesCount"`
Source Source `json:"Source" xml:"Source"`
RunOptions RunOptions `json:"RunOptions" xml:"RunOptions"`
HttpApiParameters HttpApiParameters `json:"HttpApiParameters" xml:"HttpApiParameters"`
Sink Sink `json:"Sink" xml:"Sink"`
Connections []ConnectionsItem `json:"Connections" xml:"Connections"`
EventSourceList []EventSourceListItem `json:"EventSourceList" xml:"EventSourceList"`
ApiDestinations []ApiDestinationsItem `json:"ApiDestinations" xml:"ApiDestinations"`
Targets []TargetsItem `json:"Targets" xml:"Targets"`
ErrorEntries []ErrorEntriesItem `json:"ErrorEntries" xml:"ErrorEntries"`
}
Data is a nested struct in eventbridge response
type DataInListEventBuses ¶
type DataInListEventBuses struct {
NextToken string `json:"NextToken" xml:"NextToken"`
Total int `json:"Total" xml:"Total"`
EventBuses []EventBusesItem `json:"EventBuses" xml:"EventBuses"`
}
DataInListEventBuses is a nested struct in eventbridge response
type DataInListEventStreamings ¶
type DataInListEventStreamings struct {
NextToken string `json:"NextToken" xml:"NextToken"`
Total int `json:"Total" xml:"Total"`
EventStreamings []EventStreamingsItem `json:"EventStreamings" xml:"EventStreamings"`
}
DataInListEventStreamings is a nested struct in eventbridge response
type DataInListRules ¶
type DataInListRules struct {
NextToken string `json:"NextToken" xml:"NextToken"`
Total int `json:"Total" xml:"Total"`
Rules []RulesItem `json:"Rules" xml:"Rules"`
}
DataInListRules is a nested struct in eventbridge response
type DataInListTargets ¶ added in v1.62.366
type DataInListTargets struct {
NextToken string `json:"NextToken" xml:"NextToken"`
Total int `json:"Total" xml:"Total"`
Targets []TargetsItem `json:"Targets" xml:"Targets"`
}
DataInListTargets is a nested struct in eventbridge response
type DataInQueryEventTraces ¶ added in v1.62.193
type DataInQueryEventTraces struct {
DataItem []DataItem `json:"Data" xml:"Data"`
}
DataInQueryEventTraces is a nested struct in eventbridge response
type DataInQueryTracedEventByEventId ¶ added in v1.62.193
type DataInQueryTracedEventByEventId struct {
DataItem []DataItem `json:"Data" xml:"Data"`
}
DataInQueryTracedEventByEventId is a nested struct in eventbridge response
type DataInQueryTracedEvents ¶ added in v1.62.193
type DataInQueryTracedEvents struct {
NextToken string `json:"NextToken" xml:"NextToken"`
Total int `json:"Total" xml:"Total"`
Events []EventsItem `json:"Events" xml:"Events"`
}
DataInQueryTracedEvents is a nested struct in eventbridge response
type DataItem ¶ added in v1.62.193
type DataItem struct {
NotifyStatus string `json:"NotifyStatus" xml:"NotifyStatus"`
RuleName string `json:"RuleName" xml:"RuleName"`
Action string `json:"Action" xml:"Action"`
RuleMatchingTime string `json:"RuleMatchingTime" xml:"RuleMatchingTime"`
NotifyTime int64 `json:"NotifyTime" xml:"NotifyTime"`
ReceivedTime int64 `json:"ReceivedTime" xml:"ReceivedTime"`
EventBusName string `json:"EventBusName" xml:"EventBusName"`
Endpoint string `json:"Endpoint" xml:"Endpoint"`
EventSource string `json:"EventSource" xml:"EventSource"`
ActionTime int64 `json:"ActionTime" xml:"ActionTime"`
Total int `json:"Total" xml:"Total"`
NextToken string `json:"NextToken" xml:"NextToken"`
EventId string `json:"EventId" xml:"EventId"`
NotifyLatency string `json:"NotifyLatency" xml:"NotifyLatency"`
Events []EventsItem `json:"Events" xml:"Events"`
}
DataItem is a nested struct in eventbridge response
type Date ¶
type Date struct {
ApiDestinationName string `json:"ApiDestinationName" xml:"ApiDestinationName"`
}
Date is a nested struct in eventbridge response
type DeadLetterQueue ¶
type DeadLetterQueue struct {
Arn string `json:"Arn" xml:"Arn"`
}
DeadLetterQueue is a nested struct in eventbridge response
type DeleteApiDestinationRequest ¶
type DeleteApiDestinationRequest struct {
*requests.RpcRequest
ClientToken string `position:"Query" name:"ClientToken"`
ApiDestinationName string `position:"Query" name:"ApiDestinationName"`
}
DeleteApiDestinationRequest is the request struct for api DeleteApiDestination
func CreateDeleteApiDestinationRequest ¶
func CreateDeleteApiDestinationRequest() (request *DeleteApiDestinationRequest)
CreateDeleteApiDestinationRequest creates a request to invoke DeleteApiDestination API
type DeleteApiDestinationResponse ¶
type DeleteApiDestinationResponse struct {
*responses.BaseResponse
RequestId string `json:"RequestId" xml:"RequestId"`
Message string `json:"Message" xml:"Message"`
Code string `json:"Code" xml:"Code"`
}
DeleteApiDestinationResponse is the response struct for api DeleteApiDestination
func CreateDeleteApiDestinationResponse ¶
func CreateDeleteApiDestinationResponse() (response *DeleteApiDestinationResponse)
CreateDeleteApiDestinationResponse creates a response to parse from DeleteApiDestination response
type DeleteConnectionRequest ¶
type DeleteConnectionRequest struct {
*requests.RpcRequest
ConnectionName string `position:"Query" name:"ConnectionName"`
}
DeleteConnectionRequest is the request struct for api DeleteConnection
func CreateDeleteConnectionRequest ¶
func CreateDeleteConnectionRequest() (request *DeleteConnectionRequest)
CreateDeleteConnectionRequest creates a request to invoke DeleteConnection API
type DeleteConnectionResponse ¶
type DeleteConnectionResponse struct {
*responses.BaseResponse
RequestId string `json:"RequestId" xml:"RequestId"`
Message string `json:"Message" xml:"Message"`
Code string `json:"Code" xml:"Code"`
}
DeleteConnectionResponse is the response struct for api DeleteConnection
func CreateDeleteConnectionResponse ¶
func CreateDeleteConnectionResponse() (response *DeleteConnectionResponse)
CreateDeleteConnectionResponse creates a response to parse from DeleteConnection response
type DeleteEventBusRequest ¶
type DeleteEventBusRequest struct {
*requests.RpcRequest
ClientToken string `position:"Query" name:"ClientToken"`
EventBusName string `position:"Query" name:"EventBusName"`
}
DeleteEventBusRequest is the request struct for api DeleteEventBus
func CreateDeleteEventBusRequest ¶
func CreateDeleteEventBusRequest() (request *DeleteEventBusRequest)
CreateDeleteEventBusRequest creates a request to invoke DeleteEventBus API
type DeleteEventBusResponse ¶
type DeleteEventBusResponse struct {
*responses.BaseResponse
Message string `json:"Message" xml:"Message"`
RequestId string `json:"RequestId" xml:"RequestId"`
Data bool `json:"Data" xml:"Data"`
Code string `json:"Code" xml:"Code"`
Success bool `json:"Success" xml:"Success"`
}
DeleteEventBusResponse is the response struct for api DeleteEventBus
func CreateDeleteEventBusResponse ¶
func CreateDeleteEventBusResponse() (response *DeleteEventBusResponse)
CreateDeleteEventBusResponse creates a response to parse from DeleteEventBus response
type DeleteEventSourceRequest ¶
type DeleteEventSourceRequest struct {
*requests.RpcRequest
EventSourceName string `position:"Body" name:"EventSourceName"`
}
DeleteEventSourceRequest is the request struct for api DeleteEventSource
func CreateDeleteEventSourceRequest ¶
func CreateDeleteEventSourceRequest() (request *DeleteEventSourceRequest)
CreateDeleteEventSourceRequest creates a request to invoke DeleteEventSource API
type DeleteEventSourceResponse ¶
type DeleteEventSourceResponse struct {
*responses.BaseResponse
Message string `json:"Message" xml:"Message"`
RequestId string `json:"RequestId" xml:"RequestId"`
Data bool `json:"Data" xml:"Data"`
Code string `json:"Code" xml:"Code"`
Success bool `json:"Success" xml:"Success"`
}
DeleteEventSourceResponse is the response struct for api DeleteEventSource
func CreateDeleteEventSourceResponse ¶
func CreateDeleteEventSourceResponse() (response *DeleteEventSourceResponse)
CreateDeleteEventSourceResponse creates a response to parse from DeleteEventSource response
type DeleteEventStreamingRequest ¶
type DeleteEventStreamingRequest struct {
*requests.RpcRequest
EventStreamingName string `position:"Body" name:"EventStreamingName"`
}
DeleteEventStreamingRequest is the request struct for api DeleteEventStreaming
func CreateDeleteEventStreamingRequest ¶
func CreateDeleteEventStreamingRequest() (request *DeleteEventStreamingRequest)
CreateDeleteEventStreamingRequest creates a request to invoke DeleteEventStreaming API
type DeleteEventStreamingResponse ¶
type DeleteEventStreamingResponse struct {
*responses.BaseResponse
Message string `json:"Message" xml:"Message"`
RequestId string `json:"RequestId" xml:"RequestId"`
Data bool `json:"Data" xml:"Data"`
Code bool `json:"Code" xml:"Code"`
Success bool `json:"Success" xml:"Success"`
}
DeleteEventStreamingResponse is the response struct for api DeleteEventStreaming
func CreateDeleteEventStreamingResponse ¶
func CreateDeleteEventStreamingResponse() (response *DeleteEventStreamingResponse)
CreateDeleteEventStreamingResponse creates a response to parse from DeleteEventStreaming response
type DeleteRuleRequest ¶
type DeleteRuleRequest struct {
*requests.RpcRequest
RuleName string `position:"Query" name:"RuleName"`
EventBusName string `position:"Query" name:"EventBusName"`
}
DeleteRuleRequest is the request struct for api DeleteRule
func CreateDeleteRuleRequest ¶
func CreateDeleteRuleRequest() (request *DeleteRuleRequest)
CreateDeleteRuleRequest creates a request to invoke DeleteRule API
type DeleteRuleResponse ¶
type DeleteRuleResponse struct {
*responses.BaseResponse
Message string `json:"Message" xml:"Message"`
RequestId string `json:"RequestId" xml:"RequestId"`
Data bool `json:"Data" xml:"Data"`
Code string `json:"Code" xml:"Code"`
Success bool `json:"Success" xml:"Success"`
}
DeleteRuleResponse is the response struct for api DeleteRule
func CreateDeleteRuleResponse ¶
func CreateDeleteRuleResponse() (response *DeleteRuleResponse)
CreateDeleteRuleResponse creates a response to parse from DeleteRule response
type DeleteTargetsRequest ¶
type DeleteTargetsRequest struct {
*requests.RpcRequest
TargetIds *[]string `position:"Query" name:"TargetIds" type:"Json"`
RuleName string `position:"Query" name:"RuleName"`
EventBusName string `position:"Query" name:"EventBusName"`
}
DeleteTargetsRequest is the request struct for api DeleteTargets
func CreateDeleteTargetsRequest ¶
func CreateDeleteTargetsRequest() (request *DeleteTargetsRequest)
CreateDeleteTargetsRequest creates a request to invoke DeleteTargets API
type DeleteTargetsResponse ¶
type DeleteTargetsResponse struct {
*responses.BaseResponse
Message string `json:"Message" xml:"Message"`
RequestId string `json:"RequestId" xml:"RequestId"`
Code string `json:"Code" xml:"Code"`
Success bool `json:"Success" xml:"Success"`
Data Data `json:"Data" xml:"Data"`
}
DeleteTargetsResponse is the response struct for api DeleteTargets
func CreateDeleteTargetsResponse ¶
func CreateDeleteTargetsResponse() (response *DeleteTargetsResponse)
CreateDeleteTargetsResponse creates a response to parse from DeleteTargets response
type DisableRuleRequest ¶
type DisableRuleRequest struct {
*requests.RpcRequest
RuleName string `position:"Query" name:"RuleName"`
EventBusName string `position:"Query" name:"EventBusName"`
}
DisableRuleRequest is the request struct for api DisableRule
func CreateDisableRuleRequest ¶
func CreateDisableRuleRequest() (request *DisableRuleRequest)
CreateDisableRuleRequest creates a request to invoke DisableRule API
type DisableRuleResponse ¶
type DisableRuleResponse struct {
*responses.BaseResponse
Message string `json:"Message" xml:"Message"`
RequestId string `json:"RequestId" xml:"RequestId"`
Data bool `json:"Data" xml:"Data"`
Code string `json:"Code" xml:"Code"`
Success bool `json:"Success" xml:"Success"`
}
DisableRuleResponse is the response struct for api DisableRule
func CreateDisableRuleResponse ¶
func CreateDisableRuleResponse() (response *DisableRuleResponse)
CreateDisableRuleResponse creates a response to parse from DisableRule response
type EnableRuleRequest ¶
type EnableRuleRequest struct {
*requests.RpcRequest
RuleName string `position:"Query" name:"RuleName"`
EventBusName string `position:"Query" name:"EventBusName"`
}
EnableRuleRequest is the request struct for api EnableRule
func CreateEnableRuleRequest ¶
func CreateEnableRuleRequest() (request *EnableRuleRequest)
CreateEnableRuleRequest creates a request to invoke EnableRule API
type EnableRuleResponse ¶
type EnableRuleResponse struct {
*responses.BaseResponse
Message string `json:"Message" xml:"Message"`
RequestId string `json:"RequestId" xml:"RequestId"`
Data bool `json:"Data" xml:"Data"`
Code string `json:"Code" xml:"Code"`
Success bool `json:"Success" xml:"Success"`
}
EnableRuleResponse is the response struct for api EnableRule
func CreateEnableRuleResponse ¶
func CreateEnableRuleResponse() (response *EnableRuleResponse)
CreateEnableRuleResponse creates a response to parse from EnableRule response
type ErrorEntriesInDeleteTargets ¶
type ErrorEntriesInDeleteTargets struct {
ErrorEntriesItem []ErrorEntriesItem `json:"ErrorEntries" xml:"ErrorEntries"`
}
ErrorEntriesInDeleteTargets is a nested struct in eventbridge response
type ErrorEntriesInPutTargets ¶ added in v1.62.248
type ErrorEntriesInPutTargets struct {
ErrorEntriesItem []ErrorEntriesItem `json:"ErrorEntries" xml:"ErrorEntries"`
}
ErrorEntriesInPutTargets is a nested struct in eventbridge response
type ErrorEntriesItem ¶
type ErrorEntriesItem struct {
ErrorMessage string `json:"ErrorMessage" xml:"ErrorMessage"`
EntryId string `json:"EntryId" xml:"EntryId"`
ErrorCode string `json:"ErrorCode" xml:"ErrorCode"`
}
ErrorEntriesItem is a nested struct in eventbridge response
type EventBuses ¶
type EventBuses struct {
EventBusesItem []EventBusesItem `json:"EventBuses" xml:"EventBuses"`
}
EventBuses is a nested struct in eventbridge response
type EventBusesItem ¶
type EventBusesItem struct {
EventBusARN string `json:"EventBusARN" xml:"EventBusARN"`
EventBusName string `json:"EventBusName" xml:"EventBusName"`
Description string `json:"Description" xml:"Description"`
CreateTimestamp int64 `json:"CreateTimestamp" xml:"CreateTimestamp"`
}
EventBusesItem is a nested struct in eventbridge response
type EventSourceListInListAliyunOfficialEventSources ¶
type EventSourceListInListAliyunOfficialEventSources struct {
EventSourceListItem []EventSourceListItem `json:"eventSourceList" xml:"eventSourceList"`
}
EventSourceListInListAliyunOfficialEventSources is a nested struct in eventbridge response
type EventSourceListInListUserDefinedEventSources ¶
type EventSourceListInListUserDefinedEventSources struct {
EventSourceListItem []EventSourceListItem `json:"eventSourceList" xml:"eventSourceList"`
}
EventSourceListInListUserDefinedEventSources is a nested struct in eventbridge response
type EventSourceListItem ¶
type EventSourceListItem struct {
Name string `json:"Name" xml:"Name"`
Ctime float64 `json:"Ctime" xml:"Ctime"`
ExternalSourceConfig map[string]interface{} `json:"ExternalSourceConfig" xml:"ExternalSourceConfig"`
FullName string `json:"FullName" xml:"FullName"`
EventBusName string `json:"EventBusName" xml:"EventBusName"`
ExternalSourceType string `json:"ExternalSourceType" xml:"ExternalSourceType"`
Arn string `json:"Arn" xml:"Arn"`
Status string `json:"Status" xml:"Status"`
Description string `json:"Description" xml:"Description"`
Type string `json:"Type" xml:"Type"`
SourceHttpEventParameters SourceHttpEventParameters `json:"SourceHttpEventParameters" xml:"SourceHttpEventParameters"`
SourceRabbitMQParameters SourceRabbitMQParameters `json:"SourceRabbitMQParameters" xml:"SourceRabbitMQParameters"`
SourceMNSParameters SourceMNSParameters `json:"SourceMNSParameters" xml:"SourceMNSParameters"`
SourceRocketMQParameters SourceRocketMQParametersInListUserDefinedEventSources `json:"SourceRocketMQParameters" xml:"SourceRocketMQParameters"`
SourceSLSParameters SourceSLSParameters `json:"SourceSLSParameters" xml:"SourceSLSParameters"`
EventTypes []EventTypesItem `json:"EventTypes" xml:"EventTypes"`
}
EventSourceListItem is a nested struct in eventbridge response
type EventStreamings ¶
type EventStreamings struct {
EventStreamingsItem []EventStreamingsItem `json:"EventStreamings" xml:"EventStreamings"`
}
EventStreamings is a nested struct in eventbridge response
type EventStreamingsItem ¶
type EventStreamingsItem struct {
EventStreamingName string `json:"EventStreamingName" xml:"EventStreamingName"`
Description string `json:"Description" xml:"Description"`
FilterPattern string `json:"FilterPattern" xml:"FilterPattern"`
Tag string `json:"Tag" xml:"Tag"`
Status string `json:"Status" xml:"Status"`
Source Source `json:"Source" xml:"Source"`
Sink Sink `json:"Sink" xml:"Sink"`
RunOptions RunOptions `json:"RunOptions" xml:"RunOptions"`
}
EventStreamingsItem is a nested struct in eventbridge response
type EventTypes ¶
type EventTypes struct {
EventTypesItem []EventTypesItem `json:"eventTypes" xml:"eventTypes"`
}
EventTypes is a nested struct in eventbridge response
type EventTypesItem ¶
type EventTypesItem struct {
Name string `json:"Name" xml:"Name"`
ShortName string `json:"ShortName" xml:"ShortName"`
GroupName string `json:"GroupName" xml:"GroupName"`
Description string `json:"Description" xml:"Description"`
EventSourceName string `json:"EventSourceName" xml:"EventSourceName"`
}
EventTypesItem is a nested struct in eventbridge response
type EventsInQueryTracedEventByEventId ¶ added in v1.62.193
type EventsInQueryTracedEventByEventId struct {
EventsItem []EventsItem `json:"Events" xml:"Events"`
}
EventsInQueryTracedEventByEventId is a nested struct in eventbridge response
type EventsInQueryTracedEvents ¶ added in v1.62.193
type EventsInQueryTracedEvents struct {
EventsItem []EventsItem `json:"Events" xml:"Events"`
}
EventsInQueryTracedEvents is a nested struct in eventbridge response
type EventsItem ¶ added in v1.62.193
type EventsItem struct {
EventBusName string `json:"EventBusName" xml:"EventBusName"`
EventSource string `json:"EventSource" xml:"EventSource"`
EventReceivedTime int64 `json:"EventReceivedTime" xml:"EventReceivedTime"`
EventType string `json:"EventType" xml:"EventType"`
EventId string `json:"EventId" xml:"EventId"`
}
EventsItem is a nested struct in eventbridge response
type Exchange ¶
type Exchange struct {
Value string `json:"Value" xml:"Value"`
Template string `json:"Template" xml:"Template"`
Form string `json:"Form" xml:"Form"`
}
Exchange is a nested struct in eventbridge response
type FunctionName ¶
type FunctionName struct {
Value string `json:"Value" xml:"Value"`
Template string `json:"Template" xml:"Template"`
Form string `json:"Form" xml:"Form"`
}
FunctionName is a nested struct in eventbridge response
type GetApiDestinationRequest ¶
type GetApiDestinationRequest struct {
*requests.RpcRequest
ClientToken string `position:"Query" name:"ClientToken"`
ApiDestinationName string `position:"Query" name:"ApiDestinationName"`
}
GetApiDestinationRequest is the request struct for api GetApiDestination
func CreateGetApiDestinationRequest ¶
func CreateGetApiDestinationRequest() (request *GetApiDestinationRequest)
CreateGetApiDestinationRequest creates a request to invoke GetApiDestination API
type GetApiDestinationResponse ¶
type GetApiDestinationResponse struct {
*responses.BaseResponse
RequestId string `json:"RequestId" xml:"RequestId"`
Message string `json:"Message" xml:"Message"`
Code string `json:"Code" xml:"Code"`
Data Data `json:"Data" xml:"Data"`
}
GetApiDestinationResponse is the response struct for api GetApiDestination
func CreateGetApiDestinationResponse ¶
func CreateGetApiDestinationResponse() (response *GetApiDestinationResponse)
CreateGetApiDestinationResponse creates a response to parse from GetApiDestination response
type GetConnectionRequest ¶
type GetConnectionRequest struct {
*requests.RpcRequest
ConnectionName string `position:"Query" name:"ConnectionName"`
}
GetConnectionRequest is the request struct for api GetConnection
func CreateGetConnectionRequest ¶
func CreateGetConnectionRequest() (request *GetConnectionRequest)
CreateGetConnectionRequest creates a request to invoke GetConnection API
type GetConnectionResponse ¶
type GetConnectionResponse struct {
*responses.BaseResponse
RequestId string `json:"RequestId" xml:"RequestId"`
Message string `json:"Message" xml:"Message"`
Code string `json:"Code" xml:"Code"`
Data Data `json:"Data" xml:"Data"`
}
GetConnectionResponse is the response struct for api GetConnection
func CreateGetConnectionResponse ¶
func CreateGetConnectionResponse() (response *GetConnectionResponse)
CreateGetConnectionResponse creates a response to parse from GetConnection response
type GetEventBusRequest ¶
type GetEventBusRequest struct {
*requests.RpcRequest
EventBusName string `position:"Query" name:"EventBusName"`
}
GetEventBusRequest is the request struct for api GetEventBus
func CreateGetEventBusRequest ¶
func CreateGetEventBusRequest() (request *GetEventBusRequest)
CreateGetEventBusRequest creates a request to invoke GetEventBus API
type GetEventBusResponse ¶
type GetEventBusResponse struct {
*responses.BaseResponse
Message string `json:"Message" xml:"Message"`
RequestId string `json:"RequestId" xml:"RequestId"`
Code string `json:"Code" xml:"Code"`
Success bool `json:"Success" xml:"Success"`
Data Data `json:"Data" xml:"Data"`
}
GetEventBusResponse is the response struct for api GetEventBus
func CreateGetEventBusResponse ¶
func CreateGetEventBusResponse() (response *GetEventBusResponse)
CreateGetEventBusResponse creates a response to parse from GetEventBus response
type GetEventStreamingRequest ¶
type GetEventStreamingRequest struct {
*requests.RpcRequest
EventStreamingName string `position:"Body" name:"EventStreamingName"`
}
GetEventStreamingRequest is the request struct for api GetEventStreaming
func CreateGetEventStreamingRequest ¶
func CreateGetEventStreamingRequest() (request *GetEventStreamingRequest)
CreateGetEventStreamingRequest creates a request to invoke GetEventStreaming API
type GetEventStreamingResponse ¶
type GetEventStreamingResponse struct {
*responses.BaseResponse
Message string `json:"Message" xml:"Message"`
RequestId string `json:"RequestId" xml:"RequestId"`
Code string `json:"Code" xml:"Code"`
Success bool `json:"Success" xml:"Success"`
Data Data `json:"Data" xml:"Data"`
}
GetEventStreamingResponse is the response struct for api GetEventStreaming
func CreateGetEventStreamingResponse ¶
func CreateGetEventStreamingResponse() (response *GetEventStreamingResponse)
CreateGetEventStreamingResponse creates a response to parse from GetEventStreaming response
type GetRuleRequest ¶
type GetRuleRequest struct {
*requests.RpcRequest
RuleName string `position:"Query" name:"RuleName"`
EventBusName string `position:"Query" name:"EventBusName"`
}
GetRuleRequest is the request struct for api GetRule
func CreateGetRuleRequest ¶
func CreateGetRuleRequest() (request *GetRuleRequest)
CreateGetRuleRequest creates a request to invoke GetRule API
type GetRuleResponse ¶
type GetRuleResponse struct {
*responses.BaseResponse
Message string `json:"Message" xml:"Message"`
RequestId string `json:"RequestId" xml:"RequestId"`
Code string `json:"Code" xml:"Code"`
Success bool `json:"Success" xml:"Success"`
Data Data `json:"Data" xml:"Data"`
}
GetRuleResponse is the response struct for api GetRule
func CreateGetRuleResponse ¶
func CreateGetRuleResponse() (response *GetRuleResponse)
CreateGetRuleResponse creates a response to parse from GetRule response
type HeaderParametersInGetConnection ¶
type HeaderParametersInGetConnection struct {
HeaderParametersItem []HeaderParametersItem `json:"headerParameters" xml:"headerParameters"`
}
HeaderParametersInGetConnection is a nested struct in eventbridge response
type HeaderParametersInListConnections ¶
type HeaderParametersInListConnections struct {
HeaderParametersItem []HeaderParametersItem `json:"headerParameters" xml:"headerParameters"`
}
HeaderParametersInListConnections is a nested struct in eventbridge response
type HeaderParametersItem ¶
type HeaderParametersItem struct {
Key string `json:"Key" xml:"Key"`
Value string `json:"Value" xml:"Value"`
IsValueSecret string `json:"IsValueSecret" xml:"IsValueSecret"`
}
HeaderParametersItem is a nested struct in eventbridge response
type HttpApiParameters ¶
type HttpApiParameters struct {
Endpoint string `json:"Endpoint" xml:"Endpoint"`
Method string `json:"Method" xml:"Method"`
ApiParameters []ApiParametersItem `json:"ApiParameters" xml:"ApiParameters"`
}
HttpApiParameters is a nested struct in eventbridge response
type InstanceId ¶
type InstanceId struct {
Value string `json:"Value" xml:"Value"`
Template string `json:"Template" xml:"Template"`
Form string `json:"Form" xml:"Form"`
}
InstanceId is a nested struct in eventbridge response
type InvocationHttpParameters ¶
type InvocationHttpParameters struct {
BodyParameters []BodyParametersItem `json:"BodyParameters" xml:"BodyParameters"`
HeaderParameters []HeaderParametersItem `json:"HeaderParameters" xml:"HeaderParameters"`
QueryStringParameters []QueryStringParametersItem `json:"QueryStringParameters" xml:"QueryStringParameters"`
}
InvocationHttpParameters is a nested struct in eventbridge response
type InvocationType ¶
type InvocationType struct {
Value string `json:"Value" xml:"Value"`
Template string `json:"Template" xml:"Template"`
Form string `json:"Form" xml:"Form"`
}
InvocationType is a nested struct in eventbridge response
type Ip ¶
type Ip struct {
Ip []string `json:"ip" xml:"ip"`
}
Ip is a nested struct in eventbridge response
type IsBase64Encode ¶
type IsBase64Encode struct {
Value string `json:"Value" xml:"Value"`
Template string `json:"Template" xml:"Template"`
Form string `json:"Form" xml:"Form"`
}
IsBase64Encode is a nested struct in eventbridge response
type Key ¶
type Key struct {
Value string `json:"Value" xml:"Value"`
Template string `json:"Template" xml:"Template"`
Form string `json:"Form" xml:"Form"`
}
Key is a nested struct in eventbridge response
type Keys ¶
type Keys struct {
Value string `json:"Value" xml:"Value"`
Template string `json:"Template" xml:"Template"`
Form string `json:"Form" xml:"Form"`
}
Keys is a nested struct in eventbridge response
type ListAliyunOfficialEventSourcesRequest ¶
type ListAliyunOfficialEventSourcesRequest struct {
*requests.RpcRequest
Type string `position:"Query" name:"Type"`
NextToken string `position:"Query" name:"NextToken"`
Limit requests.Integer `position:"Query" name:"Limit"`
NamePrefix string `position:"Query" name:"NamePrefix"`
}
ListAliyunOfficialEventSourcesRequest is the request struct for api ListAliyunOfficialEventSources
func CreateListAliyunOfficialEventSourcesRequest ¶
func CreateListAliyunOfficialEventSourcesRequest() (request *ListAliyunOfficialEventSourcesRequest)
CreateListAliyunOfficialEventSourcesRequest creates a request to invoke ListAliyunOfficialEventSources API
type ListAliyunOfficialEventSourcesResponse ¶
type ListAliyunOfficialEventSourcesResponse struct {
*responses.BaseResponse
Message string `json:"Message" xml:"Message"`
RequestId string `json:"RequestId" xml:"RequestId"`
Code string `json:"Code" xml:"Code"`
Success bool `json:"Success" xml:"Success"`
Data Data `json:"Data" xml:"Data"`
}
ListAliyunOfficialEventSourcesResponse is the response struct for api ListAliyunOfficialEventSources
func CreateListAliyunOfficialEventSourcesResponse ¶
func CreateListAliyunOfficialEventSourcesResponse() (response *ListAliyunOfficialEventSourcesResponse)
CreateListAliyunOfficialEventSourcesResponse creates a response to parse from ListAliyunOfficialEventSources response
type ListApiDestinationsRequest ¶
type ListApiDestinationsRequest struct {
*requests.RpcRequest
ClientToken string `position:"Query" name:"ClientToken"`
Description string `position:"Query" name:"Description"`
NextToken string `position:"Query" name:"NextToken"`
ConnectionName string `position:"Query" name:"ConnectionName"`
MaxResults requests.Integer `position:"Query" name:"MaxResults"`
ApiDestinationNamePrefix string `position:"Query" name:"ApiDestinationNamePrefix"`
}
ListApiDestinationsRequest is the request struct for api ListApiDestinations
func CreateListApiDestinationsRequest ¶
func CreateListApiDestinationsRequest() (request *ListApiDestinationsRequest)
CreateListApiDestinationsRequest creates a request to invoke ListApiDestinations API
type ListApiDestinationsResponse ¶
type ListApiDestinationsResponse struct {
*responses.BaseResponse
RequestId string `json:"RequestId" xml:"RequestId"`
Message string `json:"Message" xml:"Message"`
Code string `json:"Code" xml:"Code"`
Data Data `json:"Data" xml:"Data"`
}
ListApiDestinationsResponse is the response struct for api ListApiDestinations
func CreateListApiDestinationsResponse ¶
func CreateListApiDestinationsResponse() (response *ListApiDestinationsResponse)
CreateListApiDestinationsResponse creates a response to parse from ListApiDestinations response
type ListConnectionsRequest ¶
type ListConnectionsRequest struct {
*requests.RpcRequest
ConnectionNamePrefix string `position:"Body" name:"ConnectionNamePrefix"`
NextToken string `position:"Body" name:"NextToken"`
MaxResults requests.Integer `position:"Body" name:"MaxResults"`
}
ListConnectionsRequest is the request struct for api ListConnections
func CreateListConnectionsRequest ¶
func CreateListConnectionsRequest() (request *ListConnectionsRequest)
CreateListConnectionsRequest creates a request to invoke ListConnections API
type ListConnectionsResponse ¶
type ListConnectionsResponse struct {
*responses.BaseResponse
RequestId string `json:"RequestId" xml:"RequestId"`
Message string `json:"Message" xml:"Message"`
Code string `json:"Code" xml:"Code"`
Data Data `json:"Data" xml:"Data"`
}
ListConnectionsResponse is the response struct for api ListConnections
func CreateListConnectionsResponse ¶
func CreateListConnectionsResponse() (response *ListConnectionsResponse)
CreateListConnectionsResponse creates a response to parse from ListConnections response
type ListEventBusesRequest ¶
type ListEventBusesRequest struct {
*requests.RpcRequest
NextToken string `position:"Query" name:"NextToken"`
Limit requests.Integer `position:"Query" name:"Limit"`
NamePrefix string `position:"Query" name:"NamePrefix"`
EventBusType string `position:"Query" name:"EventBusType"`
}
ListEventBusesRequest is the request struct for api ListEventBuses
func CreateListEventBusesRequest ¶
func CreateListEventBusesRequest() (request *ListEventBusesRequest)
CreateListEventBusesRequest creates a request to invoke ListEventBuses API
type ListEventBusesResponse ¶
type ListEventBusesResponse struct {
*responses.BaseResponse
Message string `json:"Message" xml:"Message"`
RequestId string `json:"RequestId" xml:"RequestId"`
Code string `json:"Code" xml:"Code"`
Success bool `json:"Success" xml:"Success"`
Data DataInListEventBuses `json:"Data" xml:"Data"`
}
ListEventBusesResponse is the response struct for api ListEventBuses
func CreateListEventBusesResponse ¶
func CreateListEventBusesResponse() (response *ListEventBusesResponse)
CreateListEventBusesResponse creates a response to parse from ListEventBuses response
type ListEventStreamingsRequest ¶
type ListEventStreamingsRequest struct {
*requests.RpcRequest
SourceArn string `position:"Body" name:"SourceArn"`
SinkType string `position:"Body" name:"SinkType"`
SinkArn string `position:"Body" name:"SinkArn"`
NextToken string `position:"Body" name:"NextToken"`
Limit requests.Integer `position:"Body" name:"Limit"`
SourceType string `position:"Body" name:"SourceType"`
NamePrefix string `position:"Body" name:"NamePrefix"`
Tag string `position:"Body" name:"Tag"`
}
ListEventStreamingsRequest is the request struct for api ListEventStreamings
func CreateListEventStreamingsRequest ¶
func CreateListEventStreamingsRequest() (request *ListEventStreamingsRequest)
CreateListEventStreamingsRequest creates a request to invoke ListEventStreamings API
type ListEventStreamingsResponse ¶
type ListEventStreamingsResponse struct {
*responses.BaseResponse
Message string `json:"Message" xml:"Message"`
RequestId string `json:"RequestId" xml:"RequestId"`
Code string `json:"Code" xml:"Code"`
Success bool `json:"Success" xml:"Success"`
Data DataInListEventStreamings `json:"Data" xml:"Data"`
}
ListEventStreamingsResponse is the response struct for api ListEventStreamings
func CreateListEventStreamingsResponse ¶
func CreateListEventStreamingsResponse() (response *ListEventStreamingsResponse)
CreateListEventStreamingsResponse creates a response to parse from ListEventStreamings response
type ListRulesRequest ¶
type ListRulesRequest struct {
*requests.RpcRequest
RuleNamePrefix string `position:"Query" name:"RuleNamePrefix"`
EventBusName string `position:"Query" name:"EventBusName"`
NextToken string `position:"Query" name:"NextToken"`
Limit requests.Integer `position:"Query" name:"Limit"`
}
ListRulesRequest is the request struct for api ListRules
func CreateListRulesRequest ¶
func CreateListRulesRequest() (request *ListRulesRequest)
CreateListRulesRequest creates a request to invoke ListRules API
type ListRulesResponse ¶
type ListRulesResponse struct {
*responses.BaseResponse
Message string `json:"Message" xml:"Message"`
RequestId string `json:"RequestId" xml:"RequestId"`
Code string `json:"Code" xml:"Code"`
Success bool `json:"Success" xml:"Success"`
Data DataInListRules `json:"Data" xml:"Data"`
}
ListRulesResponse is the response struct for api ListRules
func CreateListRulesResponse ¶
func CreateListRulesResponse() (response *ListRulesResponse)
CreateListRulesResponse creates a response to parse from ListRules response
type ListTargetsRequest ¶ added in v1.62.366
type ListTargetsRequest struct {
*requests.RpcRequest
RuleName string `position:"Query" name:"RuleName"`
EventBusName string `position:"Query" name:"EventBusName"`
NextToken string `position:"Query" name:"NextToken"`
Limit requests.Integer `position:"Query" name:"Limit"`
Arn string `position:"Query" name:"Arn"`
}
ListTargetsRequest is the request struct for api ListTargets
func CreateListTargetsRequest ¶ added in v1.62.366
func CreateListTargetsRequest() (request *ListTargetsRequest)
CreateListTargetsRequest creates a request to invoke ListTargets API
type ListTargetsResponse ¶ added in v1.62.366
type ListTargetsResponse struct {
*responses.BaseResponse
Message string `json:"Message" xml:"Message"`
RequestId string `json:"RequestId" xml:"RequestId"`
Code string `json:"Code" xml:"Code"`
Success bool `json:"Success" xml:"Success"`
Data DataInListTargets `json:"Data" xml:"Data"`
}
ListTargetsResponse is the response struct for api ListTargets
func CreateListTargetsResponse ¶ added in v1.62.366
func CreateListTargetsResponse() (response *ListTargetsResponse)
CreateListTargetsResponse creates a response to parse from ListTargets response
type ListUserDefinedEventSourcesRequest ¶
type ListUserDefinedEventSourcesRequest struct {
*requests.RpcRequest
Type string `position:"Query" name:"Type"`
NextToken string `position:"Query" name:"NextToken"`
Limit requests.Integer `position:"Query" name:"Limit"`
NamePrefix string `position:"Query" name:"NamePrefix"`
}
ListUserDefinedEventSourcesRequest is the request struct for api ListUserDefinedEventSources
func CreateListUserDefinedEventSourcesRequest ¶
func CreateListUserDefinedEventSourcesRequest() (request *ListUserDefinedEventSourcesRequest)
CreateListUserDefinedEventSourcesRequest creates a request to invoke ListUserDefinedEventSources API
type ListUserDefinedEventSourcesResponse ¶
type ListUserDefinedEventSourcesResponse struct {
*responses.BaseResponse
Message string `json:"Message" xml:"Message"`
RequestId string `json:"RequestId" xml:"RequestId"`
Code string `json:"Code" xml:"Code"`
Success bool `json:"Success" xml:"Success"`
Data Data `json:"Data" xml:"Data"`
}
ListUserDefinedEventSourcesResponse is the response struct for api ListUserDefinedEventSources
func CreateListUserDefinedEventSourcesResponse ¶
func CreateListUserDefinedEventSourcesResponse() (response *ListUserDefinedEventSourcesResponse)
CreateListUserDefinedEventSourcesResponse creates a response to parse from ListUserDefinedEventSources response
type LogStore ¶
type LogStore struct {
Value string `json:"Value" xml:"Value"`
Template string `json:"Template" xml:"Template"`
Form string `json:"Form" xml:"Form"`
}
LogStore is a nested struct in eventbridge response
type MessageId ¶
type MessageId struct {
Value string `json:"Value" xml:"Value"`
Template string `json:"Template" xml:"Template"`
Form string `json:"Form" xml:"Form"`
}
MessageId is a nested struct in eventbridge response
type Method ¶
type Method struct {
Method []string `json:"method" xml:"method"`
}
Method is a nested struct in eventbridge response
type NetworkParameters ¶
type NetworkParameters struct {
SecurityGroupId string `json:"SecurityGroupId" xml:"SecurityGroupId"`
VswitcheId string `json:"VswitcheId" xml:"VswitcheId"`
NetworkType string `json:"NetworkType" xml:"NetworkType"`
VpcId string `json:"VpcId" xml:"VpcId"`
}
NetworkParameters is a nested struct in eventbridge response
type OAuthHttpParameters ¶
type OAuthHttpParameters struct {
BodyParameters []BodyParametersItem `json:"BodyParameters" xml:"BodyParameters"`
HeaderParameters []HeaderParametersItem `json:"HeaderParameters" xml:"HeaderParameters"`
QueryStringParameters []QueryStringParametersItem `json:"QueryStringParameters" xml:"QueryStringParameters"`
}
OAuthHttpParameters is a nested struct in eventbridge response
type OAuthParameters ¶
type OAuthParameters struct {
HttpMethod string `json:"HttpMethod" xml:"HttpMethod"`
AuthorizationEndpoint string `json:"AuthorizationEndpoint" xml:"AuthorizationEndpoint"`
OAuthHttpParameters OAuthHttpParameters `json:"OAuthHttpParameters" xml:"OAuthHttpParameters"`
ClientParameters ClientParameters `json:"ClientParameters" xml:"ClientParameters"`
}
OAuthParameters is a nested struct in eventbridge response
type ParamListInGetRule ¶ added in v1.62.366
type ParamListInGetRule struct {
ParamListItem []ParamListItem `json:"ParamList" xml:"ParamList"`
}
ParamListInGetRule is a nested struct in eventbridge response
type ParamListInListTargets ¶ added in v1.62.366
type ParamListInListTargets struct {
ParamListItem []ParamListItem `json:"ParamList" xml:"ParamList"`
}
ParamListInListTargets is a nested struct in eventbridge response
type ParamListItem ¶
type ParamListItem struct {
Value string `json:"Value" xml:"Value"`
Template string `json:"Template" xml:"Template"`
Form string `json:"Form" xml:"Form"`
ResourceKey string `json:"ResourceKey" xml:"ResourceKey"`
}
ParamListItem is a nested struct in eventbridge response
type PauseEventStreamingRequest ¶
type PauseEventStreamingRequest struct {
*requests.RpcRequest
EventStreamingName string `position:"Body" name:"EventStreamingName"`
}
PauseEventStreamingRequest is the request struct for api PauseEventStreaming
func CreatePauseEventStreamingRequest ¶
func CreatePauseEventStreamingRequest() (request *PauseEventStreamingRequest)
CreatePauseEventStreamingRequest creates a request to invoke PauseEventStreaming API
type PauseEventStreamingResponse ¶
type PauseEventStreamingResponse struct {
*responses.BaseResponse
Message string `json:"Message" xml:"Message"`
RequestId string `json:"RequestId" xml:"RequestId"`
Data bool `json:"Data" xml:"Data"`
Code bool `json:"Code" xml:"Code"`
Success bool `json:"Success" xml:"Success"`
}
PauseEventStreamingResponse is the response struct for api PauseEventStreaming
func CreatePauseEventStreamingResponse ¶
func CreatePauseEventStreamingResponse() (response *PauseEventStreamingResponse)
CreatePauseEventStreamingResponse creates a response to parse from PauseEventStreaming response
type Project ¶
type Project struct {
Value string `json:"Value" xml:"Value"`
Template string `json:"Template" xml:"Template"`
Form string `json:"Form" xml:"Form"`
}
Project is a nested struct in eventbridge response
type Properties ¶
type Properties struct {
Value string `json:"Value" xml:"Value"`
Template string `json:"Template" xml:"Template"`
Form string `json:"Form" xml:"Form"`
}
Properties is a nested struct in eventbridge response
type PutTargetsRequest ¶ added in v1.62.248
type PutTargetsRequest struct {
*requests.RpcRequest
ClientToken string `position:"Query" name:"ClientToken"`
RuleName string `position:"Query" name:"RuleName"`
EventBusName string `position:"Query" name:"EventBusName"`
Targets *[]PutTargetsTargets `position:"Query" name:"Targets" type:"Json"`
}
PutTargetsRequest is the request struct for api PutTargets
func CreatePutTargetsRequest ¶ added in v1.62.248
func CreatePutTargetsRequest() (request *PutTargetsRequest)
CreatePutTargetsRequest creates a request to invoke PutTargets API
type PutTargetsResponse ¶ added in v1.62.248
type PutTargetsResponse struct {
*responses.BaseResponse
Message string `json:"Message" xml:"Message"`
RequestId string `json:"RequestId" xml:"RequestId"`
Code string `json:"Code" xml:"Code"`
Success bool `json:"Success" xml:"Success"`
Data Data `json:"Data" xml:"Data"`
}
PutTargetsResponse is the response struct for api PutTargets
func CreatePutTargetsResponse ¶ added in v1.62.248
func CreatePutTargetsResponse() (response *PutTargetsResponse)
CreatePutTargetsResponse creates a response to parse from PutTargets response
type PutTargetsTargets ¶ added in v1.62.248
type PutTargetsTargets struct {
Endpoint string `name:"Endpoint"`
PushRetryStrategy string `name:"PushRetryStrategy"`
ParamList *[]PutTargetsTargetsParamListItem `name:"ParamList" type:"Repeated"`
Id string `name:"Id"`
DeadLetterQueue PutTargetsTargetsDeadLetterQueue `name:"DeadLetterQueue" type:"Struct"`
Type string `name:"Type"`
ErrorsTolerance string `name:"ErrorsTolerance"`
}
PutTargetsTargets is a repeated param struct in PutTargetsRequest
type PutTargetsTargetsDeadLetterQueue ¶ added in v1.62.248
type PutTargetsTargetsDeadLetterQueue struct {
Arn string `name:"Arn"`
}
PutTargetsTargetsDeadLetterQueue is a repeated param struct in PutTargetsRequest
type PutTargetsTargetsParamListItem ¶ added in v1.62.248
type PutTargetsTargetsParamListItem struct {
Template string `name:"Template"`
ResourceKey string `name:"ResourceKey"`
Form string `name:"Form"`
Value string `name:"Value"`
}
PutTargetsTargetsParamListItem is a repeated param struct in PutTargetsRequest
type Qualifier ¶
type Qualifier struct {
Value string `json:"Value" xml:"Value"`
Template string `json:"Template" xml:"Template"`
Form string `json:"Form" xml:"Form"`
}
Qualifier is a nested struct in eventbridge response
type QueryEventRequest ¶ added in v1.62.193
type QueryEventRequest struct {
*requests.RpcRequest
EventId string `position:"Query" name:"EventId"`
EventBusName string `position:"Query" name:"EventBusName"`
EventSource string `position:"Query" name:"EventSource"`
}
QueryEventRequest is the request struct for api QueryEvent
func CreateQueryEventRequest ¶ added in v1.62.193
func CreateQueryEventRequest() (request *QueryEventRequest)
CreateQueryEventRequest creates a request to invoke QueryEvent API
type QueryEventResponse ¶ added in v1.62.193
type QueryEventResponse struct {
*responses.BaseResponse
Message string `json:"Message" xml:"Message"`
RequestId string `json:"RequestId" xml:"RequestId"`
Data map[string]interface{} `json:"Data" xml:"Data"`
Code string `json:"Code" xml:"Code"`
Success bool `json:"Success" xml:"Success"`
}
QueryEventResponse is the response struct for api QueryEvent
func CreateQueryEventResponse ¶ added in v1.62.193
func CreateQueryEventResponse() (response *QueryEventResponse)
CreateQueryEventResponse creates a response to parse from QueryEvent response
type QueryEventTracesRequest ¶ added in v1.62.193
type QueryEventTracesRequest struct {
*requests.RpcRequest
EventId string `position:"Query" name:"EventId"`
EventBusName string `position:"Query" name:"EventBusName"`
}
QueryEventTracesRequest is the request struct for api QueryEventTraces
func CreateQueryEventTracesRequest ¶ added in v1.62.193
func CreateQueryEventTracesRequest() (request *QueryEventTracesRequest)
CreateQueryEventTracesRequest creates a request to invoke QueryEventTraces API
type QueryEventTracesResponse ¶ added in v1.62.193
type QueryEventTracesResponse struct {
*responses.BaseResponse
Message string `json:"Message" xml:"Message"`
RequestId string `json:"RequestId" xml:"RequestId"`
Code string `json:"Code" xml:"Code"`
Success bool `json:"Success" xml:"Success"`
Data []DataItem `json:"Data" xml:"Data"`
}
QueryEventTracesResponse is the response struct for api QueryEventTraces
func CreateQueryEventTracesResponse ¶ added in v1.62.193
func CreateQueryEventTracesResponse() (response *QueryEventTracesResponse)
CreateQueryEventTracesResponse creates a response to parse from QueryEventTraces response
type QueryStringParametersInGetConnection ¶
type QueryStringParametersInGetConnection struct {
QueryStringParametersItem []QueryStringParametersItem `json:"queryStringParameters" xml:"queryStringParameters"`
}
QueryStringParametersInGetConnection is a nested struct in eventbridge response
type QueryStringParametersInListConnections ¶
type QueryStringParametersInListConnections struct {
QueryStringParametersItem []QueryStringParametersItem `json:"queryStringParameters" xml:"queryStringParameters"`
}
QueryStringParametersInListConnections is a nested struct in eventbridge response
type QueryStringParametersItem ¶
type QueryStringParametersItem struct {
Key string `json:"Key" xml:"Key"`
Value string `json:"Value" xml:"Value"`
IsValueSecret string `json:"IsValueSecret" xml:"IsValueSecret"`
}
QueryStringParametersItem is a nested struct in eventbridge response
type QueryTracedEventByEventIdRequest ¶ added in v1.62.193
type QueryTracedEventByEventIdRequest struct {
*requests.RpcRequest
EventId string `position:"Query" name:"EventId"`
EventBusName string `position:"Query" name:"EventBusName"`
EventSource string `position:"Query" name:"EventSource"`
}
QueryTracedEventByEventIdRequest is the request struct for api QueryTracedEventByEventId
func CreateQueryTracedEventByEventIdRequest ¶ added in v1.62.193
func CreateQueryTracedEventByEventIdRequest() (request *QueryTracedEventByEventIdRequest)
CreateQueryTracedEventByEventIdRequest creates a request to invoke QueryTracedEventByEventId API
type QueryTracedEventByEventIdResponse ¶ added in v1.62.193
type QueryTracedEventByEventIdResponse struct {
*responses.BaseResponse
Message string `json:"Message" xml:"Message"`
RequestId string `json:"RequestId" xml:"RequestId"`
Code string `json:"Code" xml:"Code"`
Success bool `json:"Success" xml:"Success"`
Data []DataItem `json:"Data" xml:"Data"`
}
QueryTracedEventByEventIdResponse is the response struct for api QueryTracedEventByEventId
func CreateQueryTracedEventByEventIdResponse ¶ added in v1.62.193
func CreateQueryTracedEventByEventIdResponse() (response *QueryTracedEventByEventIdResponse)
CreateQueryTracedEventByEventIdResponse creates a response to parse from QueryTracedEventByEventId response
type QueryTracedEventsRequest ¶ added in v1.62.193
type QueryTracedEventsRequest struct {
*requests.RpcRequest
MatchedRule string `position:"Query" name:"MatchedRule"`
StartTime requests.Integer `position:"Query" name:"StartTime"`
EventBusName string `position:"Query" name:"EventBusName"`
EventSource string `position:"Query" name:"EventSource"`
NextToken string `position:"Query" name:"NextToken"`
Limit requests.Integer `position:"Query" name:"Limit"`
EndTime requests.Integer `position:"Query" name:"EndTime"`
EventType string `position:"Query" name:"EventType"`
}
QueryTracedEventsRequest is the request struct for api QueryTracedEvents
func CreateQueryTracedEventsRequest ¶ added in v1.62.193
func CreateQueryTracedEventsRequest() (request *QueryTracedEventsRequest)
CreateQueryTracedEventsRequest creates a request to invoke QueryTracedEvents API
type QueryTracedEventsResponse ¶ added in v1.62.193
type QueryTracedEventsResponse struct {
*responses.BaseResponse
Message string `json:"Message" xml:"Message"`
RequestId string `json:"RequestId" xml:"RequestId"`
Code string `json:"Code" xml:"Code"`
Success bool `json:"Success" xml:"Success"`
Data DataInQueryTracedEvents `json:"Data" xml:"Data"`
}
QueryTracedEventsResponse is the response struct for api QueryTracedEvents
func CreateQueryTracedEventsResponse ¶ added in v1.62.193
func CreateQueryTracedEventsResponse() (response *QueryTracedEventsResponse)
CreateQueryTracedEventsResponse creates a response to parse from QueryTracedEvents response
type QueueName ¶
type QueueName struct {
Value string `json:"Value" xml:"Value"`
Template string `json:"Template" xml:"Template"`
Form string `json:"Form" xml:"Form"`
}
QueueName is a nested struct in eventbridge response
type Referer ¶
type Referer struct {
Referer []string `json:"referer" xml:"referer"`
}
Referer is a nested struct in eventbridge response
type RetryStrategy ¶
type RetryStrategy struct {
MaximumRetryAttempts float64 `json:"MaximumRetryAttempts" xml:"MaximumRetryAttempts"`
MaximumEventAgeInSeconds float64 `json:"MaximumEventAgeInSeconds" xml:"MaximumEventAgeInSeconds"`
PushRetryStrategy string `json:"PushRetryStrategy" xml:"PushRetryStrategy"`
}
RetryStrategy is a nested struct in eventbridge response
type RoleName ¶
type RoleName struct {
Value string `json:"Value" xml:"Value"`
Template string `json:"Template" xml:"Template"`
Form string `json:"Form" xml:"Form"`
}
RoleName is a nested struct in eventbridge response
type RoutingKey ¶
type RoutingKey struct {
Value string `json:"Value" xml:"Value"`
Template string `json:"Template" xml:"Template"`
Form string `json:"Form" xml:"Form"`
}
RoutingKey is a nested struct in eventbridge response
type Rules ¶
type Rules struct {
RulesItem []RulesItem `json:"Rules" xml:"Rules"`
}
Rules is a nested struct in eventbridge response
type RulesItem ¶
type RulesItem struct {
DetailMap map[string]interface{} `json:"DetailMap" xml:"DetailMap"`
Status string `json:"Status" xml:"Status"`
EventBusName string `json:"EventBusName" xml:"EventBusName"`
RuleARN string `json:"RuleARN" xml:"RuleARN"`
Description string `json:"Description" xml:"Description"`
FilterPattern string `json:"FilterPattern" xml:"FilterPattern"`
CreatedTimestamp int64 `json:"CreatedTimestamp" xml:"CreatedTimestamp"`
RuleName string `json:"RuleName" xml:"RuleName"`
Targets []TargetsItem `json:"Targets" xml:"Targets"`
}
RulesItem is a nested struct in eventbridge response
type RunOptions ¶
type RunOptions struct {
ErrorsTolerance string `json:"ErrorsTolerance" xml:"ErrorsTolerance"`
MaximumTasks int `json:"MaximumTasks" xml:"MaximumTasks"`
BatchWindow BatchWindow `json:"BatchWindow" xml:"BatchWindow"`
RetryStrategy RetryStrategy `json:"RetryStrategy" xml:"RetryStrategy"`
DeadLetterQueue DeadLetterQueue `json:"DeadLetterQueue" xml:"DeadLetterQueue"`
}
RunOptions is a nested struct in eventbridge response
type SaslUser ¶
type SaslUser struct {
Value string `json:"Value" xml:"Value"`
Template string `json:"Template" xml:"Template"`
Form string `json:"Form" xml:"Form"`
}
SaslUser is a nested struct in eventbridge response
type ServiceName ¶
type ServiceName struct {
Value string `json:"Value" xml:"Value"`
Template string `json:"Template" xml:"Template"`
Form string `json:"Form" xml:"Form"`
}
ServiceName is a nested struct in eventbridge response
type Sink ¶
type Sink struct {
SinkSLSParameters SinkSLSParameters `json:"SinkSLSParameters" xml:"SinkSLSParameters"`
SinkFcParameters SinkFcParameters `json:"SinkFcParameters" xml:"SinkFcParameters"`
SinkRabbitMQParameters SinkRabbitMQParameters `json:"SinkRabbitMQParameters" xml:"SinkRabbitMQParameters"`
SinkRocketMQParameters SinkRocketMQParameters `json:"SinkRocketMQParameters" xml:"SinkRocketMQParameters"`
SinkKafkaParameters SinkKafkaParameters `json:"SinkKafkaParameters" xml:"SinkKafkaParameters"`
SinkMNSParameters SinkMNSParameters `json:"SinkMNSParameters" xml:"SinkMNSParameters"`
}
Sink is a nested struct in eventbridge response
type SinkFcParameters ¶
type SinkFcParameters struct {
FunctionName FunctionName `json:"FunctionName" xml:"FunctionName"`
ServiceName ServiceName `json:"ServiceName" xml:"ServiceName"`
InvocationType InvocationType `json:"InvocationType" xml:"InvocationType"`
Concurrency Concurrency `json:"Concurrency" xml:"Concurrency"`
Body Body `json:"Body" xml:"Body"`
Qualifier Qualifier `json:"Qualifier" xml:"Qualifier"`
}
SinkFcParameters is a nested struct in eventbridge response
type SinkKafkaParameters ¶
type SinkKafkaParameters struct {
Value Value `json:"Value" xml:"Value"`
Key Key `json:"Key" xml:"Key"`
InstanceId InstanceId `json:"InstanceId" xml:"InstanceId"`
Topic Topic `json:"Topic" xml:"Topic"`
Acks Acks `json:"Acks" xml:"Acks"`
SaslUser SaslUser `json:"SaslUser" xml:"SaslUser"`
}
SinkKafkaParameters is a nested struct in eventbridge response
type SinkMNSParameters ¶
type SinkMNSParameters struct {
IsBase64Encode IsBase64Encode `json:"IsBase64Encode" xml:"IsBase64Encode"`
Body Body `json:"Body" xml:"Body"`
QueueName QueueName `json:"QueueName" xml:"QueueName"`
}
SinkMNSParameters is a nested struct in eventbridge response
type SinkRabbitMQParameters ¶
type SinkRabbitMQParameters struct {
RoutingKey RoutingKey `json:"RoutingKey" xml:"RoutingKey"`
TargetType TargetType `json:"TargetType" xml:"TargetType"`
InstanceId InstanceId `json:"InstanceId" xml:"InstanceId"`
Exchange Exchange `json:"Exchange" xml:"Exchange"`
Properties Properties `json:"Properties" xml:"Properties"`
VirtualHostName VirtualHostName `json:"VirtualHostName" xml:"VirtualHostName"`
Body Body `json:"Body" xml:"Body"`
MessageId MessageId `json:"MessageId" xml:"MessageId"`
QueueName QueueName `json:"QueueName" xml:"QueueName"`
}
SinkRabbitMQParameters is a nested struct in eventbridge response
type SinkRocketMQParameters ¶
type SinkRocketMQParameters struct {
Keys Keys `json:"Keys" xml:"Keys"`
InstanceId InstanceId `json:"InstanceId" xml:"InstanceId"`
Tags Tags `json:"Tags" xml:"Tags"`
Topic Topic `json:"Topic" xml:"Topic"`
Properties Properties `json:"Properties" xml:"Properties"`
Body Body `json:"Body" xml:"Body"`
}
SinkRocketMQParameters is a nested struct in eventbridge response
type SinkSLSParameters ¶
type SinkSLSParameters struct {
Project Project `json:"Project" xml:"Project"`
RoleName RoleName `json:"RoleName" xml:"RoleName"`
Topic Topic `json:"Topic" xml:"Topic"`
LogStore LogStore `json:"LogStore" xml:"LogStore"`
Body Body `json:"Body" xml:"Body"`
}
SinkSLSParameters is a nested struct in eventbridge response
type Source ¶
type Source struct {
SourceRocketMQParameters SourceRocketMQParameters `json:"SourceRocketMQParameters" xml:"SourceRocketMQParameters"`
SourceKafkaParameters SourceKafkaParameters `json:"SourceKafkaParameters" xml:"SourceKafkaParameters"`
SourceSLSParameters SourceSLSParameters `json:"SourceSLSParameters" xml:"SourceSLSParameters"`
SourceMQTTParameters SourceMQTTParameters `json:"SourceMQTTParameters" xml:"SourceMQTTParameters"`
SourceRabbitMQParameters SourceRabbitMQParameters `json:"SourceRabbitMQParameters" xml:"SourceRabbitMQParameters"`
SourceDTSParameters SourceDTSParameters `json:"SourceDTSParameters" xml:"SourceDTSParameters"`
SourceMNSParameters SourceMNSParameters `json:"SourceMNSParameters" xml:"SourceMNSParameters"`
}
Source is a nested struct in eventbridge response
type SourceDTSParameters ¶
type SourceDTSParameters struct {
Password string `json:"Password" xml:"Password"`
TaskId string `json:"TaskId" xml:"TaskId"`
Username string `json:"Username" xml:"Username"`
BrokerUrl string `json:"BrokerUrl" xml:"BrokerUrl"`
Sid string `json:"Sid" xml:"Sid"`
InitCheckPoint string `json:"InitCheckPoint" xml:"InitCheckPoint"`
Topic string `json:"Topic" xml:"Topic"`
}
SourceDTSParameters is a nested struct in eventbridge response
type SourceHttpEventParameters ¶
type SourceHttpEventParameters struct {
Type string `json:"Type" xml:"Type"`
SecurityConfig string `json:"SecurityConfig" xml:"SecurityConfig"`
Method []string `json:"Method" xml:"Method"`
Ip []string `json:"Ip" xml:"Ip"`
Referer []string `json:"Referer" xml:"Referer"`
}
SourceHttpEventParameters is a nested struct in eventbridge response
type SourceKafkaParameters ¶
type SourceKafkaParameters struct {
RegionId string `json:"RegionId" xml:"RegionId"`
SecurityGroupId string `json:"SecurityGroupId" xml:"SecurityGroupId"`
ConsumerGroup string `json:"ConsumerGroup" xml:"ConsumerGroup"`
OffsetReset string `json:"OffsetReset" xml:"OffsetReset"`
InstanceId string `json:"InstanceId" xml:"InstanceId"`
Network string `json:"Network" xml:"Network"`
VpcId string `json:"VpcId" xml:"VpcId"`
Topic string `json:"Topic" xml:"Topic"`
VSwitchIds string `json:"VSwitchIds" xml:"VSwitchIds"`
}
SourceKafkaParameters is a nested struct in eventbridge response
type SourceMNSParameters ¶
type SourceMNSParameters struct {
QueueName string `json:"QueueName" xml:"QueueName"`
IsBase64Decode bool `json:"IsBase64Decode" xml:"IsBase64Decode"`
RegionId string `json:"RegionId" xml:"RegionId"`
}
SourceMNSParameters is a nested struct in eventbridge response
type SourceMQTTParameters ¶
type SourceMQTTParameters struct {
RegionId string `json:"RegionId" xml:"RegionId"`
InstanceId string `json:"InstanceId" xml:"InstanceId"`
Topic string `json:"Topic" xml:"Topic"`
}
SourceMQTTParameters is a nested struct in eventbridge response
type SourceRabbitMQParameters ¶
type SourceRabbitMQParameters struct {
QueueName string `json:"QueueName" xml:"QueueName"`
RegionId string `json:"RegionId" xml:"RegionId"`
InstanceId string `json:"InstanceId" xml:"InstanceId"`
VirtualHostName string `json:"VirtualHostName" xml:"VirtualHostName"`
}
SourceRabbitMQParameters is a nested struct in eventbridge response
type SourceRocketMQParameters ¶
type SourceRocketMQParameters struct {
RegionId string `json:"RegionId" xml:"RegionId"`
Tag string `json:"Tag" xml:"Tag"`
Timestamp int64 `json:"Timestamp" xml:"Timestamp"`
InstanceId string `json:"InstanceId" xml:"InstanceId"`
GroupID string `json:"GroupID" xml:"GroupID"`
Offset string `json:"Offset" xml:"Offset"`
Topic string `json:"Topic" xml:"Topic"`
}
SourceRocketMQParameters is a nested struct in eventbridge response
type SourceRocketMQParametersInListUserDefinedEventSources ¶
type SourceRocketMQParametersInListUserDefinedEventSources struct {
RegionId string `json:"RegionId" xml:"RegionId"`
InstanceId string `json:"InstanceId" xml:"InstanceId"`
Topic string `json:"Topic" xml:"Topic"`
Tag string `json:"Tag" xml:"Tag"`
Offset string `json:"Offset" xml:"Offset"`
Timestamp float64 `json:"Timestamp" xml:"Timestamp"`
GroupId string `json:"GroupId" xml:"GroupId"`
}
SourceRocketMQParametersInListUserDefinedEventSources is a nested struct in eventbridge response
type SourceSLSParameters ¶
type SourceSLSParameters struct {
LogStore string `json:"LogStore" xml:"LogStore"`
Project string `json:"Project" xml:"Project"`
ConsumerGroup string `json:"ConsumerGroup" xml:"ConsumerGroup"`
ConsumePosition string `json:"ConsumePosition" xml:"ConsumePosition"`
RoleName string `json:"RoleName" xml:"RoleName"`
}
SourceSLSParameters is a nested struct in eventbridge response
type StartEventStreamingRequest ¶
type StartEventStreamingRequest struct {
*requests.RpcRequest
EventStreamingName string `position:"Body" name:"EventStreamingName"`
}
StartEventStreamingRequest is the request struct for api StartEventStreaming
func CreateStartEventStreamingRequest ¶
func CreateStartEventStreamingRequest() (request *StartEventStreamingRequest)
CreateStartEventStreamingRequest creates a request to invoke StartEventStreaming API
type StartEventStreamingResponse ¶
type StartEventStreamingResponse struct {
*responses.BaseResponse
Message string `json:"Message" xml:"Message"`
RequestId string `json:"RequestId" xml:"RequestId"`
Data bool `json:"Data" xml:"Data"`
Code bool `json:"Code" xml:"Code"`
Success bool `json:"Success" xml:"Success"`
}
StartEventStreamingResponse is the response struct for api StartEventStreaming
func CreateStartEventStreamingResponse ¶
func CreateStartEventStreamingResponse() (response *StartEventStreamingResponse)
CreateStartEventStreamingResponse creates a response to parse from StartEventStreaming response
type Tags ¶
type Tags struct {
Value string `json:"Value" xml:"Value"`
Template string `json:"Template" xml:"Template"`
Form string `json:"Form" xml:"Form"`
}
Tags is a nested struct in eventbridge response
type TargetType ¶
type TargetType struct {
Value string `json:"Value" xml:"Value"`
Template string `json:"Template" xml:"Template"`
Form string `json:"Form" xml:"Form"`
}
TargetType is a nested struct in eventbridge response
type TargetsInGetRule ¶
type TargetsInGetRule struct {
TargetsItem []TargetsItem `json:"Targets" xml:"Targets"`
}
TargetsInGetRule is a nested struct in eventbridge response
type TargetsInListRules ¶
type TargetsInListRules struct {
TargetsItem []TargetsItem `json:"Targets" xml:"Targets"`
}
TargetsInListRules is a nested struct in eventbridge response
type TargetsInListTargets ¶ added in v1.62.366
type TargetsInListTargets struct {
TargetsItem []TargetsItem `json:"Targets" xml:"Targets"`
}
TargetsInListTargets is a nested struct in eventbridge response
type TargetsItem ¶
type TargetsItem struct {
Endpoint string `json:"Endpoint" xml:"Endpoint"`
EventBusName string `json:"EventBusName" xml:"EventBusName"`
PushSelector string `json:"PushSelector" xml:"PushSelector"`
RuleName string `json:"RuleName" xml:"RuleName"`
DetailMap map[string]interface{} `json:"DetailMap" xml:"DetailMap"`
Id string `json:"Id" xml:"Id"`
PushRetryStrategy string `json:"PushRetryStrategy" xml:"PushRetryStrategy"`
Type string `json:"Type" xml:"Type"`
DeadLetterQueue DeadLetterQueue `json:"DeadLetterQueue" xml:"DeadLetterQueue"`
ParamList []ParamListItem `json:"ParamList" xml:"ParamList"`
}
TargetsItem is a nested struct in eventbridge response
type TestEventPatternRequest ¶ added in v1.62.281
type TestEventPatternRequest struct {
*requests.RpcRequest
EventPattern string `position:"Body" name:"EventPattern"`
Event string `position:"Body" name:"Event"`
}
TestEventPatternRequest is the request struct for api TestEventPattern
func CreateTestEventPatternRequest ¶ added in v1.62.281
func CreateTestEventPatternRequest() (request *TestEventPatternRequest)
CreateTestEventPatternRequest creates a request to invoke TestEventPattern API
type TestEventPatternResponse ¶ added in v1.62.281
type TestEventPatternResponse struct {
*responses.BaseResponse
RequestId string `json:"RequestId" xml:"RequestId"`
Message string `json:"Message" xml:"Message"`
Code string `json:"Code" xml:"Code"`
Success bool `json:"Success" xml:"Success"`
Data Data `json:"Data" xml:"Data"`
}
TestEventPatternResponse is the response struct for api TestEventPattern
func CreateTestEventPatternResponse ¶ added in v1.62.281
func CreateTestEventPatternResponse() (response *TestEventPatternResponse)
CreateTestEventPatternResponse creates a response to parse from TestEventPattern response
type Topic ¶
type Topic struct {
Value string `json:"Value" xml:"Value"`
Template string `json:"Template" xml:"Template"`
Form string `json:"Form" xml:"Form"`
}
Topic is a nested struct in eventbridge response
type UpdateApiDestinationHttpApiParameters ¶
type UpdateApiDestinationHttpApiParameters struct {
Endpoint string `name:"Endpoint"`
Method string `name:"Method"`
ApiParameters *[]UpdateApiDestinationHttpApiParametersApiParametersItem `name:"ApiParameters" type:"Repeated"`
}
UpdateApiDestinationHttpApiParameters is a repeated param struct in UpdateApiDestinationRequest
type UpdateApiDestinationHttpApiParametersApiParametersItem ¶
type UpdateApiDestinationHttpApiParametersApiParametersItem struct {
In string `name:"In"`
Name string `name:"Name"`
Description string `name:"Description"`
DefaultValue string `name:"DefaultValue"`
Type string `name:"Type"`
}
UpdateApiDestinationHttpApiParametersApiParametersItem is a repeated param struct in UpdateApiDestinationRequest
type UpdateApiDestinationRequest ¶
type UpdateApiDestinationRequest struct {
*requests.RpcRequest
ClientToken string `position:"Query" name:"ClientToken"`
Description string `position:"Query" name:"Description"`
ApiDestinationName string `position:"Query" name:"ApiDestinationName"`
ConnectionName string `position:"Query" name:"ConnectionName"`
HttpApiParameters UpdateApiDestinationHttpApiParameters `position:"Query" name:"HttpApiParameters" type:"Struct"`
InvocationRateLimitPerSecond requests.Integer `position:"Query" name:"InvocationRateLimitPerSecond"`
}
UpdateApiDestinationRequest is the request struct for api UpdateApiDestination
func CreateUpdateApiDestinationRequest ¶
func CreateUpdateApiDestinationRequest() (request *UpdateApiDestinationRequest)
CreateUpdateApiDestinationRequest creates a request to invoke UpdateApiDestination API
type UpdateApiDestinationResponse ¶
type UpdateApiDestinationResponse struct {
*responses.BaseResponse
RequestId string `json:"RequestId" xml:"RequestId"`
Message string `json:"Message" xml:"Message"`
Code string `json:"Code" xml:"Code"`
ApiDestinationName string `json:"ApiDestinationName" xml:"ApiDestinationName"`
}
UpdateApiDestinationResponse is the response struct for api UpdateApiDestination
func CreateUpdateApiDestinationResponse ¶
func CreateUpdateApiDestinationResponse() (response *UpdateApiDestinationResponse)
CreateUpdateApiDestinationResponse creates a response to parse from UpdateApiDestination response
type UpdateConnectionAuthParameters ¶
type UpdateConnectionAuthParameters struct {
BasicAuthParameters UpdateConnectionAuthParametersBasicAuthParameters `name:"BasicAuthParameters" type:"Struct"`
ApiKeyAuthParameters UpdateConnectionAuthParametersApiKeyAuthParameters `name:"ApiKeyAuthParameters" type:"Struct"`
AuthorizationType string `name:"AuthorizationType"`
InvocationHttpParameters UpdateConnectionAuthParametersInvocationHttpParameters `name:"InvocationHttpParameters" type:"Struct"`
OAuthParameters UpdateConnectionAuthParametersOAuthParameters `name:"OAuthParameters" type:"Struct"`
}
UpdateConnectionAuthParameters is a repeated param struct in UpdateConnectionRequest
type UpdateConnectionAuthParametersApiKeyAuthParameters ¶
type UpdateConnectionAuthParametersApiKeyAuthParameters struct {
ApiKeyName string `name:"ApiKeyName"`
ApiKeyValue string `name:"ApiKeyValue"`
}
UpdateConnectionAuthParametersApiKeyAuthParameters is a repeated param struct in UpdateConnectionRequest
type UpdateConnectionAuthParametersBasicAuthParameters ¶
type UpdateConnectionAuthParametersBasicAuthParameters struct {
Password string `name:"Password"`
Username string `name:"Username"`
}
UpdateConnectionAuthParametersBasicAuthParameters is a repeated param struct in UpdateConnectionRequest
type UpdateConnectionAuthParametersInvocationHttpParameters ¶
type UpdateConnectionAuthParametersInvocationHttpParameters struct {
BodyParameters *[]UpdateConnectionAuthParametersInvocationHttpParametersBodyParametersItem `name:"BodyParameters" type:"Repeated"`
HeaderParameters *[]UpdateConnectionAuthParametersInvocationHttpParametersHeaderParametersItem `name:"HeaderParameters" type:"Repeated"`
QueryStringParameters *[]UpdateConnectionAuthParametersInvocationHttpParametersQueryStringParametersItem `name:"QueryStringParameters" type:"Repeated"`
}
UpdateConnectionAuthParametersInvocationHttpParameters is a repeated param struct in UpdateConnectionRequest
type UpdateConnectionAuthParametersInvocationHttpParametersBodyParametersItem ¶
type UpdateConnectionAuthParametersInvocationHttpParametersBodyParametersItem struct {
IsValueSecret string `name:"IsValueSecret"`
Value string `name:"Value"`
Key string `name:"Key"`
}
UpdateConnectionAuthParametersInvocationHttpParametersBodyParametersItem is a repeated param struct in UpdateConnectionRequest
type UpdateConnectionAuthParametersInvocationHttpParametersHeaderParametersItem ¶
type UpdateConnectionAuthParametersInvocationHttpParametersHeaderParametersItem struct {
IsValueSecret string `name:"IsValueSecret"`
Value string `name:"Value"`
Key string `name:"Key"`
}
UpdateConnectionAuthParametersInvocationHttpParametersHeaderParametersItem is a repeated param struct in UpdateConnectionRequest
type UpdateConnectionAuthParametersInvocationHttpParametersQueryStringParametersItem ¶
type UpdateConnectionAuthParametersInvocationHttpParametersQueryStringParametersItem struct {
IsValueSecret string `name:"IsValueSecret"`
Value string `name:"Value"`
Key string `name:"Key"`
}
UpdateConnectionAuthParametersInvocationHttpParametersQueryStringParametersItem is a repeated param struct in UpdateConnectionRequest
type UpdateConnectionAuthParametersOAuthParameters ¶
type UpdateConnectionAuthParametersOAuthParameters struct {
ClientParameters UpdateConnectionAuthParametersOAuthParametersClientParameters `name:"ClientParameters" type:"Struct"`
AuthorizationEndpoint string `name:"AuthorizationEndpoint"`
HttpMethod string `name:"HttpMethod"`
OAuthHttpParameters UpdateConnectionAuthParametersOAuthParametersOAuthHttpParameters `name:"OAuthHttpParameters" type:"Struct"`
}
UpdateConnectionAuthParametersOAuthParameters is a repeated param struct in UpdateConnectionRequest
type UpdateConnectionAuthParametersOAuthParametersClientParameters ¶
type UpdateConnectionAuthParametersOAuthParametersClientParameters struct {
ClientID string `name:"ClientID"`
ClientSecret string `name:"ClientSecret"`
}
UpdateConnectionAuthParametersOAuthParametersClientParameters is a repeated param struct in UpdateConnectionRequest
type UpdateConnectionAuthParametersOAuthParametersOAuthHttpParameters ¶
type UpdateConnectionAuthParametersOAuthParametersOAuthHttpParameters struct {
BodyParameters *[]UpdateConnectionAuthParametersOAuthParametersOAuthHttpParametersBodyParametersItem `name:"BodyParameters" type:"Repeated"`
HeaderParameters *[]UpdateConnectionAuthParametersOAuthParametersOAuthHttpParametersHeaderParametersItem `name:"HeaderParameters" type:"Repeated"`
QueryStringParameters *[]UpdateConnectionAuthParametersOAuthParametersOAuthHttpParametersQueryStringParametersItem `name:"QueryStringParameters" type:"Repeated"`
}
UpdateConnectionAuthParametersOAuthParametersOAuthHttpParameters is a repeated param struct in UpdateConnectionRequest
type UpdateConnectionAuthParametersOAuthParametersOAuthHttpParametersBodyParametersItem ¶
type UpdateConnectionAuthParametersOAuthParametersOAuthHttpParametersBodyParametersItem struct {
IsValueSecret string `name:"IsValueSecret"`
Value string `name:"Value"`
Key string `name:"Key"`
}
UpdateConnectionAuthParametersOAuthParametersOAuthHttpParametersBodyParametersItem is a repeated param struct in UpdateConnectionRequest
type UpdateConnectionAuthParametersOAuthParametersOAuthHttpParametersHeaderParametersItem ¶
type UpdateConnectionAuthParametersOAuthParametersOAuthHttpParametersHeaderParametersItem struct {
IsValueSecret string `name:"IsValueSecret"`
Value string `name:"Value"`
Key string `name:"Key"`
}
UpdateConnectionAuthParametersOAuthParametersOAuthHttpParametersHeaderParametersItem is a repeated param struct in UpdateConnectionRequest
type UpdateConnectionAuthParametersOAuthParametersOAuthHttpParametersQueryStringParametersItem ¶
type UpdateConnectionAuthParametersOAuthParametersOAuthHttpParametersQueryStringParametersItem struct {
IsValueSecret string `name:"IsValueSecret"`
Value string `name:"Value"`
Key string `name:"Key"`
}
UpdateConnectionAuthParametersOAuthParametersOAuthHttpParametersQueryStringParametersItem is a repeated param struct in UpdateConnectionRequest
type UpdateConnectionNetworkParameters ¶
type UpdateConnectionNetworkParameters struct {
VpcId string `name:"VpcId"`
SecurityGroupId string `name:"SecurityGroupId"`
NetworkType string `name:"NetworkType"`
VswitcheId string `name:"VswitcheId"`
}
UpdateConnectionNetworkParameters is a repeated param struct in UpdateConnectionRequest
type UpdateConnectionRequest ¶
type UpdateConnectionRequest struct {
*requests.RpcRequest
ConnectionName string `position:"Query" name:"ConnectionName"`
Description string `position:"Query" name:"Description"`
NetworkParameters UpdateConnectionNetworkParameters `position:"Query" name:"NetworkParameters" type:"Struct"`
AuthParameters UpdateConnectionAuthParameters `position:"Query" name:"AuthParameters" type:"Struct"`
}
UpdateConnectionRequest is the request struct for api UpdateConnection
func CreateUpdateConnectionRequest ¶
func CreateUpdateConnectionRequest() (request *UpdateConnectionRequest)
CreateUpdateConnectionRequest creates a request to invoke UpdateConnection API
type UpdateConnectionResponse ¶
type UpdateConnectionResponse struct {
*responses.BaseResponse
RequestId string `json:"RequestId" xml:"RequestId"`
Message string `json:"Message" xml:"Message"`
Code string `json:"Code" xml:"Code"`
}
UpdateConnectionResponse is the response struct for api UpdateConnection
func CreateUpdateConnectionResponse ¶
func CreateUpdateConnectionResponse() (response *UpdateConnectionResponse)
CreateUpdateConnectionResponse creates a response to parse from UpdateConnection response
type UpdateEventBusRequest ¶
type UpdateEventBusRequest struct {
*requests.RpcRequest
Description string `position:"Query" name:"Description"`
EventBusName string `position:"Query" name:"EventBusName"`
}
UpdateEventBusRequest is the request struct for api UpdateEventBus
func CreateUpdateEventBusRequest ¶
func CreateUpdateEventBusRequest() (request *UpdateEventBusRequest)
CreateUpdateEventBusRequest creates a request to invoke UpdateEventBus API
type UpdateEventBusResponse ¶
type UpdateEventBusResponse struct {
*responses.BaseResponse
Message string `json:"Message" xml:"Message"`
RequestId string `json:"RequestId" xml:"RequestId"`
Data bool `json:"Data" xml:"Data"`
Code string `json:"Code" xml:"Code"`
Success bool `json:"Success" xml:"Success"`
}
UpdateEventBusResponse is the response struct for api UpdateEventBus
func CreateUpdateEventBusResponse ¶
func CreateUpdateEventBusResponse() (response *UpdateEventBusResponse)
CreateUpdateEventBusResponse creates a response to parse from UpdateEventBus response
type UpdateEventSourceRequest ¶
type UpdateEventSourceRequest struct {
*requests.RpcRequest
Description string `position:"Body" name:"Description"`
EventBusName string `position:"Body" name:"EventBusName"`
SourceMNSParameters UpdateEventSourceSourceMNSParameters `position:"Body" name:"SourceMNSParameters" type:"Struct"`
LinkedExternalSource requests.Boolean `position:"Body" name:"LinkedExternalSource"`
ExternalSourceType string `position:"Body" name:"ExternalSourceType"`
ExternalSourceConfig map[string]string `position:"Body" name:"ExternalSourceConfig" type:"Map"`
SourceRabbitMQParameters UpdateEventSourceSourceRabbitMQParameters `position:"Body" name:"SourceRabbitMQParameters" type:"Struct"`
SourceRocketMQParameters UpdateEventSourceSourceRocketMQParameters `position:"Body" name:"SourceRocketMQParameters" type:"Struct"`
SourceSLSParameters UpdateEventSourceSourceSLSParameters `position:"Body" name:"SourceSLSParameters" type:"Struct"`
SourceScheduledEventParameters UpdateEventSourceSourceScheduledEventParameters `position:"Body" name:"SourceScheduledEventParameters" type:"Struct"`
SourceKafkaParameters UpdateEventSourceSourceKafkaParameters `position:"Body" name:"SourceKafkaParameters" type:"Struct"`
SourceHttpEventParameters UpdateEventSourceSourceHttpEventParameters `position:"Body" name:"SourceHttpEventParameters" type:"Struct"`
EventSourceName string `position:"Body" name:"EventSourceName"`
}
UpdateEventSourceRequest is the request struct for api UpdateEventSource
func CreateUpdateEventSourceRequest ¶
func CreateUpdateEventSourceRequest() (request *UpdateEventSourceRequest)
CreateUpdateEventSourceRequest creates a request to invoke UpdateEventSource API
type UpdateEventSourceResponse ¶
type UpdateEventSourceResponse struct {
*responses.BaseResponse
Message string `json:"Message" xml:"Message"`
RequestId string `json:"RequestId" xml:"RequestId"`
Data bool `json:"Data" xml:"Data"`
Code string `json:"Code" xml:"Code"`
Success bool `json:"Success" xml:"Success"`
}
UpdateEventSourceResponse is the response struct for api UpdateEventSource
func CreateUpdateEventSourceResponse ¶
func CreateUpdateEventSourceResponse() (response *UpdateEventSourceResponse)
CreateUpdateEventSourceResponse creates a response to parse from UpdateEventSource response
type UpdateEventSourceSourceHttpEventParameters ¶
type UpdateEventSourceSourceHttpEventParameters struct {
Referer *[]string `name:"Referer" type:"Repeated"`
Method *[]string `name:"Method" type:"Repeated"`
Ip *[]string `name:"Ip" type:"Repeated"`
SecurityConfig string `name:"SecurityConfig"`
Type string `name:"Type"`
}
UpdateEventSourceSourceHttpEventParameters is a repeated param struct in UpdateEventSourceRequest
type UpdateEventSourceSourceKafkaParameters ¶ added in v1.62.286
type UpdateEventSourceSourceKafkaParameters struct {
InstanceId string `name:"InstanceId"`
ConsumerGroup string `name:"ConsumerGroup"`
RegionId string `name:"RegionId"`
VSwitchIds string `name:"VSwitchIds"`
VpcId string `name:"VpcId"`
SecurityGroupId string `name:"SecurityGroupId"`
Topic string `name:"Topic"`
OffsetReset string `name:"OffsetReset"`
MaximumTasks string `name:"MaximumTasks"`
Network string `name:"Network"`
}
UpdateEventSourceSourceKafkaParameters is a repeated param struct in UpdateEventSourceRequest
type UpdateEventSourceSourceMNSParameters ¶
type UpdateEventSourceSourceMNSParameters struct {
QueueName string `name:"QueueName"`
RegionId string `name:"RegionId"`
IsBase64Decode string `name:"IsBase64Decode"`
}
UpdateEventSourceSourceMNSParameters is a repeated param struct in UpdateEventSourceRequest
type UpdateEventSourceSourceRabbitMQParameters ¶
type UpdateEventSourceSourceRabbitMQParameters struct {
QueueName string `name:"QueueName"`
VirtualHostName string `name:"VirtualHostName"`
InstanceId string `name:"InstanceId"`
RegionId string `name:"RegionId"`
}
UpdateEventSourceSourceRabbitMQParameters is a repeated param struct in UpdateEventSourceRequest
type UpdateEventSourceSourceRocketMQParameters ¶
type UpdateEventSourceSourceRocketMQParameters struct {
InstanceNetwork string `name:"InstanceNetwork"`
InstanceVSwitchIds string `name:"InstanceVSwitchIds"`
InstanceSecurityGroupId string `name:"InstanceSecurityGroupId"`
InstanceId string `name:"InstanceId"`
Offset string `name:"Offset"`
InstanceVpcId string `name:"InstanceVpcId"`
RegionId string `name:"RegionId"`
GroupID string `name:"GroupID"`
Topic string `name:"Topic"`
InstanceType string `name:"InstanceType"`
Tag string `name:"Tag"`
Timestamp string `name:"Timestamp"`
}
UpdateEventSourceSourceRocketMQParameters is a repeated param struct in UpdateEventSourceRequest
type UpdateEventSourceSourceSLSParameters ¶
type UpdateEventSourceSourceSLSParameters struct {
RoleName string `name:"RoleName"`
Project string `name:"Project"`
LogStore string `name:"LogStore"`
ConsumePosition string `name:"ConsumePosition"`
}
UpdateEventSourceSourceSLSParameters is a repeated param struct in UpdateEventSourceRequest
type UpdateEventSourceSourceScheduledEventParameters ¶ added in v1.62.286
type UpdateEventSourceSourceScheduledEventParameters struct {
Schedule string `name:"Schedule"`
TimeZone string `name:"TimeZone"`
}
UpdateEventSourceSourceScheduledEventParameters is a repeated param struct in UpdateEventSourceRequest
type UpdateEventStreamingRequest ¶
type UpdateEventStreamingRequest struct {
*requests.RpcRequest
Sink UpdateEventStreamingSink `position:"Body" name:"Sink" type:"Struct"`
Description string `position:"Body" name:"Description"`
FilterPattern string `position:"Body" name:"FilterPattern"`
Source UpdateEventStreamingSource `position:"Body" name:"Source" type:"Struct"`
RunOptions UpdateEventStreamingRunOptions `position:"Body" name:"RunOptions" type:"Struct"`
EventStreamingName string `position:"Body" name:"EventStreamingName"`
Tag string `position:"Body" name:"Tag"`
}
UpdateEventStreamingRequest is the request struct for api UpdateEventStreaming
func CreateUpdateEventStreamingRequest ¶
func CreateUpdateEventStreamingRequest() (request *UpdateEventStreamingRequest)
CreateUpdateEventStreamingRequest creates a request to invoke UpdateEventStreaming API
type UpdateEventStreamingResponse ¶
type UpdateEventStreamingResponse struct {
*responses.BaseResponse
Message string `json:"Message" xml:"Message"`
RequestId string `json:"RequestId" xml:"RequestId"`
Data bool `json:"Data" xml:"Data"`
Code string `json:"Code" xml:"Code"`
Success bool `json:"Success" xml:"Success"`
}
UpdateEventStreamingResponse is the response struct for api UpdateEventStreaming
func CreateUpdateEventStreamingResponse ¶
func CreateUpdateEventStreamingResponse() (response *UpdateEventStreamingResponse)
CreateUpdateEventStreamingResponse creates a response to parse from UpdateEventStreaming response
type UpdateEventStreamingRunOptions ¶
type UpdateEventStreamingRunOptions struct {
BatchWindow UpdateEventStreamingRunOptionsBatchWindow `name:"BatchWindow" type:"Struct"`
RetryStrategy UpdateEventStreamingRunOptionsRetryStrategy `name:"RetryStrategy" type:"Struct"`
DeadLetterQueue UpdateEventStreamingRunOptionsDeadLetterQueue `name:"DeadLetterQueue" type:"Struct"`
MaximumTasks string `name:"MaximumTasks"`
ErrorsTolerance string `name:"ErrorsTolerance"`
}
UpdateEventStreamingRunOptions is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingRunOptionsBatchWindow ¶
type UpdateEventStreamingRunOptionsBatchWindow struct {
CountBasedWindow string `name:"CountBasedWindow"`
TimeBasedWindow string `name:"TimeBasedWindow"`
}
UpdateEventStreamingRunOptionsBatchWindow is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingRunOptionsDeadLetterQueue ¶
type UpdateEventStreamingRunOptionsDeadLetterQueue struct {
Arn string `name:"Arn"`
}
UpdateEventStreamingRunOptionsDeadLetterQueue is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingRunOptionsRetryStrategy ¶
type UpdateEventStreamingRunOptionsRetryStrategy struct {
PushRetryStrategy string `name:"PushRetryStrategy"`
MaximumRetryAttempts string `name:"MaximumRetryAttempts"`
MaximumEventAgeInSeconds string `name:"MaximumEventAgeInSeconds"`
}
UpdateEventStreamingRunOptionsRetryStrategy is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSink ¶
type UpdateEventStreamingSink struct {
SinkRabbitMQParameters UpdateEventStreamingSinkSinkRabbitMQParameters `name:"SinkRabbitMQParameters" type:"Struct"`
SinkMNSParameters UpdateEventStreamingSinkSinkMNSParameters `name:"SinkMNSParameters" type:"Struct"`
SinkKafkaParameters UpdateEventStreamingSinkSinkKafkaParameters `name:"SinkKafkaParameters" type:"Struct"`
SinkFcParameters UpdateEventStreamingSinkSinkFcParameters `name:"SinkFcParameters" type:"Struct"`
SinkSLSParameters UpdateEventStreamingSinkSinkSLSParameters `name:"SinkSLSParameters" type:"Struct"`
SinkRocketMQParameters UpdateEventStreamingSinkSinkRocketMQParameters `name:"SinkRocketMQParameters" type:"Struct"`
}
UpdateEventStreamingSink is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkFcParameters ¶
type UpdateEventStreamingSinkSinkFcParameters struct {
InvocationType UpdateEventStreamingSinkSinkFcParametersInvocationType `name:"InvocationType" type:"Struct"`
FunctionName UpdateEventStreamingSinkSinkFcParametersFunctionName `name:"FunctionName" type:"Struct"`
Qualifier UpdateEventStreamingSinkSinkFcParametersQualifier `name:"Qualifier" type:"Struct"`
ServiceName UpdateEventStreamingSinkSinkFcParametersServiceName `name:"ServiceName" type:"Struct"`
Body UpdateEventStreamingSinkSinkFcParametersBody `name:"Body" type:"Struct"`
Concurrency UpdateEventStreamingSinkSinkFcParametersConcurrency `name:"Concurrency" type:"Struct"`
}
UpdateEventStreamingSinkSinkFcParameters is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkFcParametersBody ¶
type UpdateEventStreamingSinkSinkFcParametersBody struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
UpdateEventStreamingSinkSinkFcParametersBody is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkFcParametersConcurrency ¶ added in v1.62.286
type UpdateEventStreamingSinkSinkFcParametersConcurrency struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
UpdateEventStreamingSinkSinkFcParametersConcurrency is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkFcParametersFunctionName ¶
type UpdateEventStreamingSinkSinkFcParametersFunctionName struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
UpdateEventStreamingSinkSinkFcParametersFunctionName is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkFcParametersInvocationType ¶
type UpdateEventStreamingSinkSinkFcParametersInvocationType struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
UpdateEventStreamingSinkSinkFcParametersInvocationType is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkFcParametersQualifier ¶
type UpdateEventStreamingSinkSinkFcParametersQualifier struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
UpdateEventStreamingSinkSinkFcParametersQualifier is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkFcParametersServiceName ¶
type UpdateEventStreamingSinkSinkFcParametersServiceName struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
UpdateEventStreamingSinkSinkFcParametersServiceName is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkKafkaParameters ¶
type UpdateEventStreamingSinkSinkKafkaParameters struct {
InstanceId UpdateEventStreamingSinkSinkKafkaParametersInstanceId `name:"InstanceId" type:"Struct"`
Acks UpdateEventStreamingSinkSinkKafkaParametersAcks `name:"Acks" type:"Struct"`
Topic UpdateEventStreamingSinkSinkKafkaParametersTopic `name:"Topic" type:"Struct"`
SaslUser UpdateEventStreamingSinkSinkKafkaParametersSaslUser `name:"SaslUser" type:"Struct"`
Value UpdateEventStreamingSinkSinkKafkaParametersValue `name:"Value" type:"Struct"`
Key UpdateEventStreamingSinkSinkKafkaParametersKey `name:"Key" type:"Struct"`
}
UpdateEventStreamingSinkSinkKafkaParameters is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkKafkaParametersAcks ¶
type UpdateEventStreamingSinkSinkKafkaParametersAcks struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
UpdateEventStreamingSinkSinkKafkaParametersAcks is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkKafkaParametersInstanceId ¶
type UpdateEventStreamingSinkSinkKafkaParametersInstanceId struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
UpdateEventStreamingSinkSinkKafkaParametersInstanceId is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkKafkaParametersKey ¶
type UpdateEventStreamingSinkSinkKafkaParametersKey struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
UpdateEventStreamingSinkSinkKafkaParametersKey is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkKafkaParametersSaslUser ¶
type UpdateEventStreamingSinkSinkKafkaParametersSaslUser struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
UpdateEventStreamingSinkSinkKafkaParametersSaslUser is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkKafkaParametersTopic ¶
type UpdateEventStreamingSinkSinkKafkaParametersTopic struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
UpdateEventStreamingSinkSinkKafkaParametersTopic is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkKafkaParametersValue ¶
type UpdateEventStreamingSinkSinkKafkaParametersValue struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
UpdateEventStreamingSinkSinkKafkaParametersValue is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkMNSParameters ¶
type UpdateEventStreamingSinkSinkMNSParameters struct {
QueueName UpdateEventStreamingSinkSinkMNSParametersQueueName `name:"QueueName" type:"Struct"`
IsBase64Encode UpdateEventStreamingSinkSinkMNSParametersIsBase64Encode `name:"IsBase64Encode" type:"Struct"`
Body UpdateEventStreamingSinkSinkMNSParametersBody `name:"Body" type:"Struct"`
}
UpdateEventStreamingSinkSinkMNSParameters is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkMNSParametersBody ¶
type UpdateEventStreamingSinkSinkMNSParametersBody struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
UpdateEventStreamingSinkSinkMNSParametersBody is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkMNSParametersIsBase64Encode ¶
type UpdateEventStreamingSinkSinkMNSParametersIsBase64Encode struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
UpdateEventStreamingSinkSinkMNSParametersIsBase64Encode is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkMNSParametersQueueName ¶
type UpdateEventStreamingSinkSinkMNSParametersQueueName struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
UpdateEventStreamingSinkSinkMNSParametersQueueName is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkRabbitMQParameters ¶
type UpdateEventStreamingSinkSinkRabbitMQParameters struct {
RoutingKey UpdateEventStreamingSinkSinkRabbitMQParametersRoutingKey `name:"RoutingKey" type:"Struct"`
QueueName UpdateEventStreamingSinkSinkRabbitMQParametersQueueName `name:"QueueName" type:"Struct"`
VirtualHostName UpdateEventStreamingSinkSinkRabbitMQParametersVirtualHostName `name:"VirtualHostName" type:"Struct"`
InstanceId UpdateEventStreamingSinkSinkRabbitMQParametersInstanceId `name:"InstanceId" type:"Struct"`
TargetType UpdateEventStreamingSinkSinkRabbitMQParametersTargetType `name:"TargetType" type:"Struct"`
MessageId UpdateEventStreamingSinkSinkRabbitMQParametersMessageId `name:"MessageId" type:"Struct"`
Exchange UpdateEventStreamingSinkSinkRabbitMQParametersExchange `name:"Exchange" type:"Struct"`
Body UpdateEventStreamingSinkSinkRabbitMQParametersBody `name:"Body" type:"Struct"`
Properties UpdateEventStreamingSinkSinkRabbitMQParametersProperties `name:"Properties" type:"Struct"`
}
UpdateEventStreamingSinkSinkRabbitMQParameters is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkRabbitMQParametersBody ¶
type UpdateEventStreamingSinkSinkRabbitMQParametersBody struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
UpdateEventStreamingSinkSinkRabbitMQParametersBody is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkRabbitMQParametersExchange ¶
type UpdateEventStreamingSinkSinkRabbitMQParametersExchange struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
UpdateEventStreamingSinkSinkRabbitMQParametersExchange is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkRabbitMQParametersInstanceId ¶
type UpdateEventStreamingSinkSinkRabbitMQParametersInstanceId struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
UpdateEventStreamingSinkSinkRabbitMQParametersInstanceId is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkRabbitMQParametersMessageId ¶
type UpdateEventStreamingSinkSinkRabbitMQParametersMessageId struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
UpdateEventStreamingSinkSinkRabbitMQParametersMessageId is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkRabbitMQParametersProperties ¶
type UpdateEventStreamingSinkSinkRabbitMQParametersProperties struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
UpdateEventStreamingSinkSinkRabbitMQParametersProperties is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkRabbitMQParametersQueueName ¶
type UpdateEventStreamingSinkSinkRabbitMQParametersQueueName struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
UpdateEventStreamingSinkSinkRabbitMQParametersQueueName is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkRabbitMQParametersRoutingKey ¶
type UpdateEventStreamingSinkSinkRabbitMQParametersRoutingKey struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
UpdateEventStreamingSinkSinkRabbitMQParametersRoutingKey is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkRabbitMQParametersTargetType ¶
type UpdateEventStreamingSinkSinkRabbitMQParametersTargetType struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
UpdateEventStreamingSinkSinkRabbitMQParametersTargetType is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkRabbitMQParametersVirtualHostName ¶
type UpdateEventStreamingSinkSinkRabbitMQParametersVirtualHostName struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
UpdateEventStreamingSinkSinkRabbitMQParametersVirtualHostName is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkRocketMQParameters ¶
type UpdateEventStreamingSinkSinkRocketMQParameters struct {
InstanceId UpdateEventStreamingSinkSinkRocketMQParametersInstanceId `name:"InstanceId" type:"Struct"`
Keys UpdateEventStreamingSinkSinkRocketMQParametersKeys `name:"Keys" type:"Struct"`
Topic UpdateEventStreamingSinkSinkRocketMQParametersTopic `name:"Topic" type:"Struct"`
Body UpdateEventStreamingSinkSinkRocketMQParametersBody `name:"Body" type:"Struct"`
Properties UpdateEventStreamingSinkSinkRocketMQParametersProperties `name:"Properties" type:"Struct"`
Tags UpdateEventStreamingSinkSinkRocketMQParametersTags `name:"Tags" type:"Struct"`
}
UpdateEventStreamingSinkSinkRocketMQParameters is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkRocketMQParametersBody ¶
type UpdateEventStreamingSinkSinkRocketMQParametersBody struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
UpdateEventStreamingSinkSinkRocketMQParametersBody is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkRocketMQParametersInstanceId ¶
type UpdateEventStreamingSinkSinkRocketMQParametersInstanceId struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
UpdateEventStreamingSinkSinkRocketMQParametersInstanceId is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkRocketMQParametersKeys ¶
type UpdateEventStreamingSinkSinkRocketMQParametersKeys struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
UpdateEventStreamingSinkSinkRocketMQParametersKeys is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkRocketMQParametersProperties ¶
type UpdateEventStreamingSinkSinkRocketMQParametersProperties struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
UpdateEventStreamingSinkSinkRocketMQParametersProperties is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkRocketMQParametersTags ¶
type UpdateEventStreamingSinkSinkRocketMQParametersTags struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
UpdateEventStreamingSinkSinkRocketMQParametersTags is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkRocketMQParametersTopic ¶
type UpdateEventStreamingSinkSinkRocketMQParametersTopic struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
UpdateEventStreamingSinkSinkRocketMQParametersTopic is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkSLSParameters ¶
type UpdateEventStreamingSinkSinkSLSParameters struct {
RoleName UpdateEventStreamingSinkSinkSLSParametersRoleName `name:"RoleName" type:"Struct"`
Project UpdateEventStreamingSinkSinkSLSParametersProject `name:"Project" type:"Struct"`
Topic UpdateEventStreamingSinkSinkSLSParametersTopic `name:"Topic" type:"Struct"`
Body UpdateEventStreamingSinkSinkSLSParametersBody `name:"Body" type:"Struct"`
LogStore UpdateEventStreamingSinkSinkSLSParametersLogStore `name:"LogStore" type:"Struct"`
}
UpdateEventStreamingSinkSinkSLSParameters is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkSLSParametersBody ¶
type UpdateEventStreamingSinkSinkSLSParametersBody struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
UpdateEventStreamingSinkSinkSLSParametersBody is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkSLSParametersLogStore ¶
type UpdateEventStreamingSinkSinkSLSParametersLogStore struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
UpdateEventStreamingSinkSinkSLSParametersLogStore is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkSLSParametersProject ¶
type UpdateEventStreamingSinkSinkSLSParametersProject struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
UpdateEventStreamingSinkSinkSLSParametersProject is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkSLSParametersRoleName ¶
type UpdateEventStreamingSinkSinkSLSParametersRoleName struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
UpdateEventStreamingSinkSinkSLSParametersRoleName is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSinkSinkSLSParametersTopic ¶
type UpdateEventStreamingSinkSinkSLSParametersTopic struct {
Template string `name:"Template"`
Form string `name:"Form"`
Value string `name:"Value"`
}
UpdateEventStreamingSinkSinkSLSParametersTopic is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSource ¶
type UpdateEventStreamingSource struct {
SourceMQTTParameters UpdateEventStreamingSourceSourceMQTTParameters `name:"SourceMQTTParameters" type:"Struct"`
SourceRocketMQParameters UpdateEventStreamingSourceSourceRocketMQParameters `name:"SourceRocketMQParameters" type:"Struct"`
SourceSLSParameters UpdateEventStreamingSourceSourceSLSParameters `name:"SourceSLSParameters" type:"Struct"`
SourceDTSParameters UpdateEventStreamingSourceSourceDTSParameters `name:"SourceDTSParameters" type:"Struct"`
SourceKafkaParameters UpdateEventStreamingSourceSourceKafkaParameters `name:"SourceKafkaParameters" type:"Struct"`
SourceMNSParameters UpdateEventStreamingSourceSourceMNSParameters `name:"SourceMNSParameters" type:"Struct"`
SourceRabbitMQParameters UpdateEventStreamingSourceSourceRabbitMQParameters `name:"SourceRabbitMQParameters" type:"Struct"`
}
UpdateEventStreamingSource is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSourceSourceDTSParameters ¶
type UpdateEventStreamingSourceSourceDTSParameters struct {
BrokerUrl string `name:"BrokerUrl"`
Password string `name:"Password"`
InitCheckPoint string `name:"InitCheckPoint"`
Topic string `name:"Topic"`
TaskId string `name:"TaskId"`
Sid string `name:"Sid"`
Username string `name:"Username"`
}
UpdateEventStreamingSourceSourceDTSParameters is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSourceSourceKafkaParameters ¶
type UpdateEventStreamingSourceSourceKafkaParameters struct {
InstanceId string `name:"InstanceId"`
ConsumerGroup string `name:"ConsumerGroup"`
RegionId string `name:"RegionId"`
VSwitchIds string `name:"VSwitchIds"`
VpcId string `name:"VpcId"`
SecurityGroupId string `name:"SecurityGroupId"`
Topic string `name:"Topic"`
OffsetReset string `name:"OffsetReset"`
Network string `name:"Network"`
}
UpdateEventStreamingSourceSourceKafkaParameters is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSourceSourceMNSParameters ¶
type UpdateEventStreamingSourceSourceMNSParameters struct {
QueueName string `name:"QueueName"`
RegionId string `name:"RegionId"`
IsBase64Decode string `name:"IsBase64Decode"`
}
UpdateEventStreamingSourceSourceMNSParameters is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSourceSourceMQTTParameters ¶
type UpdateEventStreamingSourceSourceMQTTParameters struct {
InstanceId string `name:"InstanceId"`
RegionId string `name:"RegionId"`
Topic string `name:"Topic"`
}
UpdateEventStreamingSourceSourceMQTTParameters is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSourceSourceRabbitMQParameters ¶
type UpdateEventStreamingSourceSourceRabbitMQParameters struct {
QueueName string `name:"QueueName"`
VirtualHostName string `name:"VirtualHostName"`
InstanceId string `name:"InstanceId"`
RegionId string `name:"RegionId"`
}
UpdateEventStreamingSourceSourceRabbitMQParameters is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSourceSourceRocketMQParameters ¶
type UpdateEventStreamingSourceSourceRocketMQParameters struct {
InstanceId string `name:"InstanceId"`
Offset string `name:"Offset"`
RegionId string `name:"RegionId"`
GroupID string `name:"GroupID"`
Topic string `name:"Topic"`
Tag string `name:"Tag"`
Timestamp string `name:"Timestamp"`
}
UpdateEventStreamingSourceSourceRocketMQParameters is a repeated param struct in UpdateEventStreamingRequest
type UpdateEventStreamingSourceSourceSLSParameters ¶
type UpdateEventStreamingSourceSourceSLSParameters struct {
RoleName string `name:"RoleName"`
}
UpdateEventStreamingSourceSourceSLSParameters is a repeated param struct in UpdateEventStreamingRequest
type UpdateRuleRequest ¶
type UpdateRuleRequest struct {
*requests.RpcRequest
ClientToken string `position:"Query" name:"ClientToken"`
Description string `position:"Query" name:"Description"`
RuleName string `position:"Query" name:"RuleName"`
EventBusName string `position:"Query" name:"EventBusName"`
FilterPattern string `position:"Query" name:"FilterPattern"`
Status string `position:"Query" name:"Status"`
}
UpdateRuleRequest is the request struct for api UpdateRule
func CreateUpdateRuleRequest ¶
func CreateUpdateRuleRequest() (request *UpdateRuleRequest)
CreateUpdateRuleRequest creates a request to invoke UpdateRule API
type UpdateRuleResponse ¶
type UpdateRuleResponse struct {
*responses.BaseResponse
Message string `json:"Message" xml:"Message"`
RequestId string `json:"RequestId" xml:"RequestId"`
Data bool `json:"Data" xml:"Data"`
Code string `json:"Code" xml:"Code"`
Success bool `json:"Success" xml:"Success"`
}
UpdateRuleResponse is the response struct for api UpdateRule
func CreateUpdateRuleResponse ¶
func CreateUpdateRuleResponse() (response *UpdateRuleResponse)
CreateUpdateRuleResponse creates a response to parse from UpdateRule response
type Value ¶
type Value struct {
Value string `json:"Value" xml:"Value"`
Template string `json:"Template" xml:"Template"`
Form string `json:"Form" xml:"Form"`
}
Value is a nested struct in eventbridge response
type VirtualHostName ¶
type VirtualHostName struct {
Value string `json:"Value" xml:"Value"`
Template string `json:"Template" xml:"Template"`
Form string `json:"Form" xml:"Form"`
}
VirtualHostName is a nested struct in eventbridge response
Source Files
¶
- client.go
- create_api_destination.go
- create_connection.go
- create_event_bus.go
- create_event_source.go
- create_event_streaming.go
- create_rule.go
- create_service_linked_role_for_product.go
- delete_api_destination.go
- delete_connection.go
- delete_event_bus.go
- delete_event_source.go
- delete_event_streaming.go
- delete_rule.go
- delete_targets.go
- disable_rule.go
- enable_rule.go
- get_api_destination.go
- get_connection.go
- get_event_bus.go
- get_event_streaming.go
- get_rule.go
- list_aliyun_official_event_sources.go
- list_api_destinations.go
- list_connections.go
- list_event_buses.go
- list_event_streamings.go
- list_rules.go
- list_targets.go
- list_user_defined_event_sources.go
- pause_event_streaming.go
- put_targets.go
- query_event.go
- query_event_traces.go
- query_traced_event_by_event_id.go
- query_traced_events.go
- start_event_streaming.go
- struct_acks.go
- struct_api_destinations.go
- struct_api_destinations_item.go
- struct_api_key_auth_parameters.go
- struct_api_parameters_in_get_api_destination.go
- struct_api_parameters_in_list_api_destinations.go
- struct_api_parameters_item.go
- struct_auth_parameters.go
- struct_basic_auth_parameters.go
- struct_batch_window.go
- struct_body.go
- struct_body_parameters_in_get_connection.go
- struct_body_parameters_in_list_connections.go
- struct_body_parameters_item.go
- struct_client_parameters.go
- struct_concurrency.go
- struct_connections_in_get_connection.go
- struct_connections_in_list_connections.go
- struct_connections_item.go
- struct_data.go
- struct_data_in_list_event_buses.go
- struct_data_in_list_event_streamings.go
- struct_data_in_list_rules.go
- struct_data_in_list_targets.go
- struct_data_in_query_event_traces.go
- struct_data_in_query_traced_event_by_event_id.go
- struct_data_in_query_traced_events.go
- struct_data_item.go
- struct_date.go
- struct_dead_letter_queue.go
- struct_error_entries_in_delete_targets.go
- struct_error_entries_in_put_targets.go
- struct_error_entries_item.go
- struct_event_buses.go
- struct_event_buses_item.go
- struct_event_source_list_in_list_aliyun_official_event_sources.go
- struct_event_source_list_in_list_user_defined_event_sources.go
- struct_event_source_list_item.go
- struct_event_streamings.go
- struct_event_streamings_item.go
- struct_event_types.go
- struct_event_types_item.go
- struct_events_in_query_traced_event_by_event_id.go
- struct_events_in_query_traced_events.go
- struct_events_item.go
- struct_exchange.go
- struct_function_name.go
- struct_header_parameters_in_get_connection.go
- struct_header_parameters_in_list_connections.go
- struct_header_parameters_item.go
- struct_http_api_parameters.go
- struct_instance_id.go
- struct_invocation_http_parameters.go
- struct_invocation_type.go
- struct_ip.go
- struct_is_base64_encode.go
- struct_key.go
- struct_keys.go
- struct_log_store.go
- struct_message_id.go
- struct_method.go
- struct_network_parameters.go
- struct_o_auth_http_parameters.go
- struct_o_auth_parameters.go
- struct_param_list_in_get_rule.go
- struct_param_list_in_list_targets.go
- struct_param_list_item.go
- struct_project.go
- struct_properties.go
- struct_qualifier.go
- struct_query_string_parameters_in_get_connection.go
- struct_query_string_parameters_in_list_connections.go
- struct_query_string_parameters_item.go
- struct_queue_name.go
- struct_referer.go
- struct_retry_strategy.go
- struct_role_name.go
- struct_routing_key.go
- struct_rules.go
- struct_rules_item.go
- struct_run_options.go
- struct_sasl_user.go
- struct_service_name.go
- struct_sink.go
- struct_sink_fc_parameters.go
- struct_sink_kafka_parameters.go
- struct_sink_mns_parameters.go
- struct_sink_rabbit_mq_parameters.go
- struct_sink_rocket_mq_parameters.go
- struct_sink_sls_parameters.go
- struct_source.go
- struct_source_dts_parameters.go
- struct_source_http_event_parameters.go
- struct_source_kafka_parameters.go
- struct_source_mns_parameters.go
- struct_source_mqtt_parameters.go
- struct_source_rabbit_mq_parameters.go
- struct_source_rocket_mq_parameters.go
- struct_source_rocket_mq_parameters_in_list_user_defined_event_sources.go
- struct_source_sls_parameters.go
- struct_tags.go
- struct_target_type.go
- struct_targets_in_get_rule.go
- struct_targets_in_list_rules.go
- struct_targets_in_list_targets.go
- struct_targets_item.go
- struct_topic.go
- struct_value.go
- struct_virtual_host_name.go
- test_event_pattern.go
- update_api_destination.go
- update_connection.go
- update_event_bus.go
- update_event_source.go
- update_event_streaming.go
- update_rule.go