v20210416

package
v3.0.542+incompatible Latest Latest
Warning

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

 Go to latest Published: Sep 23, 2022 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source 
const (

	// CAM signature/authentication error.
	AUTHFAILURE = "AuthFailure"

	// Operation failed.
	FAILEDOPERATION = "FailedOperation"

	//
	FAILEDOPERATION_AUTHENTICATEUSERFAILED = "FailedOperation.AuthenticateUserFailed"

	// Failed to create the delivery target. Please check the function status.
	FAILEDOPERATION_CREATETRIGGER = "FailedOperation.CreateTrigger"

	// Failed to delete the connector. Please check the resource status.
	FAILEDOPERATION_DELETECONNECTION = "FailedOperation.DeleteConnection"

	// Failed to delete the rule. Please make sure the resource exists, and the status is normal.
	FAILEDOPERATION_DELETERULE = "FailedOperation.DeleteRule"

	//
	FAILEDOPERATION_ESREQUESTFAILED = "FailedOperation.ESRequestFailed"

	// The rule does not match with the event. Please modify and try again.
	FAILEDOPERATION_ERRORFILTER = "FailedOperation.ErrorFilter"

	// Failed to register the CLS service.
	FAILEDOPERATION_REGISTERCLSSERVICE = "FailedOperation.RegisterCLSService"

	// ServiceError: operation failed. Please check the resource information.
	FAILEDOPERATION_SERVICEERROR = "FailedOperation.ServiceError"

	// Failed to update the connector. Please make sure the resource exists, and the status is normal.
	FAILEDOPERATION_UPDATECONNECTION = "FailedOperation.UpdateConnection"

	// Failed to update the rule. Please make sure the resource exists, and the status is normal.
	FAILEDOPERATION_UPDATERULE = "FailedOperation.UpdateRule"

	// Internal error.
	INTERNALERROR = "InternalError"

	// An error occurred while processing the service. Please try again later. If the problem persists, please contact the smart customer service or submit a ticket.
	INTERNALERROR_OSSEXCEPTION = "InternalError.OssException"

	// Service error. Please try again. If the problem persists, please submit a ticket.
	INTERNALERROR_SYSTEM = "InternalError.System"

	// Parameter error.
	INVALIDPARAMETER = "InvalidParameter"

	// APIGateway cannot be enabled or disabled. Please check and try again.
	INVALIDPARAMETER_ENABLEAPIGATEWAY = "InvalidParameter.EnableAPIGateway"

	// `Payload` does not conform to the specification. Please fix it and try again.
	INVALIDPARAMETER_PAYLOAD = "InvalidParameter.Payload"

	// The `AMPParams` value does not conform to the specification. Please fix it and try again.
	INVALIDPARAMETERVALUE_AMPPARAMS = "InvalidParameterValue.AMPParams"

	// The `BatchEventCount` value does not conform to the specification. Please fix it and try again.
	INVALIDPARAMETERVALUE_BATCHEVENTCOUNT = "InvalidParameterValue.BatchEventCount"

	// The `BatchTimeout` value does not conform to the specification. Please fix it and try again.
	INVALIDPARAMETERVALUE_BATCHTIMEOUT = "InvalidParameterValue.BatchTimeout"

	// The CKafka parameter is invalid. Please check and try again.
	INVALIDPARAMETERVALUE_CKAFKATARGETPARAMS = "InvalidParameterValue.CKafkaTargetParams"

	// The `CallbackType` value does not conform to the specification. Please fix it and try again.
	INVALIDPARAMETERVALUE_CALLBACKTYPE = "InvalidParameterValue.CallbackType"

	// The `CallbackWeComURL` value does not conform to the specification. Please fix it and try again.
	INVALIDPARAMETERVALUE_CALLBACKWECOMURL = "InvalidParameterValue.CallbackWeComURL"

	// The `ConnectionDescription` value does not conform to the specification. Please fix it and try again.
	INVALIDPARAMETERVALUE_CONNECTIONDESCRIPTION = "InvalidParameterValue.ConnectionDescription"

	// The `ConnectionId` value does not conform to the specification. Please fix it and try again.
	INVALIDPARAMETERVALUE_CONNECTIONID = "InvalidParameterValue.ConnectionId"

	// The value of `ConnectionName` is invalid. Please check and try again.
	INVALIDPARAMETERVALUE_CONNECTIONNAME = "InvalidParameterValue.ConnectionName"

	// The value of `AMPParams` is invalid. Please check and try again.
	INVALIDPARAMETERVALUE_DTSPARAMS = "InvalidParameterValue.DTSParams"

	// The dead letter queue parameter is invalid. Please check and try again.
	INVALIDPARAMETERVALUE_DEADLETTERCONFIG = "InvalidParameterValue.DeadLetterConfig"

	// The `Description` value does not conform to the specification. Please fix it and try again.
	INVALIDPARAMETERVALUE_DESCRIPTION = "InvalidParameterValue.Description"

	//
	INVALIDPARAMETERVALUE_ELASTICSEARCHTARGETPARAMS = "InvalidParameterValue.ElasticSearchTargetParams"

	// The `EventBusId` value does not conform to the specification. Please fix it and try again.
	INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"

	// The value of `EventBusName` is invalid. Please check and try again.
	INVALIDPARAMETERVALUE_EVENTBUSNAME = "InvalidParameterValue.EventBusName"

	// The `EventPattern` value does not conform to the specification. Please fix it and try again.
	INVALIDPARAMETERVALUE_EVENTPATTERN = "InvalidParameterValue.EventPattern"

	// The linkage tracing parameter is invalid. Please check and try again.
	INVALIDPARAMETERVALUE_EVENTTRACECONFIG = "InvalidParameterValue.EventTraceConfig"

	// The `Filters` value does not conform to the specification. Please fix it and try again.
	INVALIDPARAMETERVALUE_FILTERS = "InvalidParameterValue.Filters"

	// The value of `InvalidApiRequestConfig` is invalid. Please check and try again.
	INVALIDPARAMETERVALUE_INVALIDAPIREQUESTCONFIG = "InvalidParameterValue.InvalidApiRequestConfig"

	// Invalid event mode format. Please check and try again.
	INVALIDPARAMETERVALUE_INVALIDFILTERRULE = "InvalidParameterValue.InvalidFilterRule"

	// Invalid matching rules. Please check and try again.
	INVALIDPARAMETERVALUE_INVALIDPATTERN = "InvalidParameterValue.InvalidPattern"

	// The `Limit` value does not conform to the specification. Please fix it and try again.
	INVALIDPARAMETERVALUE_LIMIT = "InvalidParameterValue.Limit"

	// The value of `LinkMode` is invalid. Please check and try again.
	INVALIDPARAMETERVALUE_LINKMODE = "InvalidParameterValue.LinkMode"

	// The `NoticeReceiverChannel` value does not conform to the specification. Please fix it and try again.
	INVALIDPARAMETERVALUE_NOTICERECEIVERCHANNEL = "InvalidParameterValue.NoticeReceiverChannel"

	// The `NoticeReceiverTimeWindow` value does not conform to the specification. Please fix it and try again.
	INVALIDPARAMETERVALUE_NOTICERECEIVERTIMEWINDOW = "InvalidParameterValue.NoticeReceiverTimeWindow"

	// The `NoticeReceiverUserIds` value does not conform to the specification. Please fix it and try again.
	INVALIDPARAMETERVALUE_NOTICERECEIVERUSERIDS = "InvalidParameterValue.NoticeReceiverUserIds"

	// The `NoticeReceiverUserType` value does not conform to the specification. Please fix it and try again.
	INVALIDPARAMETERVALUE_NOTICERECEIVERUSERTYPE = "InvalidParameterValue.NoticeReceiverUserType"

	// The `Offset` value does not conform to the specification. Please fix it and try again.
	INVALIDPARAMETERVALUE_OFFSET = "InvalidParameterValue.Offset"

	// The `Order` value does not conform to the specification. Please fix it and try again.
	INVALIDPARAMETERVALUE_ORDER = "InvalidParameterValue.Order"

	// The `OrderBy` value does not conform to the specification. Please fix it and try again.
	INVALIDPARAMETERVALUE_ORDERBY = "InvalidParameterValue.OrderBy"

	// The `Qualifier` value does not conform to the specification. Please fix it and try again.
	INVALIDPARAMETERVALUE_QUALIFIER = "InvalidParameterValue.Qualifier"

	// The `RuleId` value does not conform to the specification. Please fix it and try again.
	INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"

	// The `RuleName` value does not conform to the specification. Please fix it and try again.
	INVALIDPARAMETERVALUE_RULENAME = "InvalidParameterValue.RuleName"

	//
	INVALIDPARAMETERVALUE_TAGS = "InvalidParameterValue.Tags"

	// The `TargetDescription` value does not conform to the specification. Please fix it and try again.
	INVALIDPARAMETERVALUE_TARGETDESCRIPTION = "InvalidParameterValue.TargetDescription"

	// The `TargetId` value does not conform to the specification. Please fix it and try again.
	INVALIDPARAMETERVALUE_TARGETID = "InvalidParameterValue.TargetId"

	// The data transformation parameter is invalid. Please check and try again.
	INVALIDPARAMETERVALUE_TRANSFORMATIONID = "InvalidParameterValue.TransformationID"

	// Failed to create the data transformation task: The parameter is invalid. Please check and try again.
	INVALIDPARAMETERVALUE_TRANSFORMATIONS = "InvalidParameterValue.Transformations"

	// The `Type` value does not conform to the specification. Please fix it and try again.
	INVALIDPARAMETERVALUE_TYPE = "InvalidParameterValue.Type"

	// The number of `Connection` reaches the upper limit. You can submit a ticket to increase it.
	LIMITEXCEEDED_CONNECTION = "LimitExceeded.Connection"

	// The number of `EventBus` reaches the upper limit. You can submit a ticket to increase it.
	LIMITEXCEEDED_EVENTBUS = "LimitExceeded.EventBus"

	// Failed to create the resource: Insufficient balance. Please check and try again.
	LIMITEXCEEDED_INSUFFICIENTBALANCE = "LimitExceeded.InsufficientBalance"

	// The `Logset` quantity has reached the upper limit. You can submit a ticket to increase it.
	LIMITEXCEEDED_LOGSET = "LimitExceeded.Logset"

	// The number of `RouteOverLimit` reaches the upper limit. Submit a ticket to increase it.
	LIMITEXCEEDED_ROUTEOVERLIMIT = "LimitExceeded.RouteOverLimit"

	// The `Rule` quantity has reached the upper limit. You can submit a ticket to increase it.
	LIMITEXCEEDED_RULE = "LimitExceeded.Rule"

	// The `Target` quantity has reached the upper limit. You can submit a ticket to increase it.
	LIMITEXCEEDED_TARGET = "LimitExceeded.Target"

	// Failed to create the delivery target, as the number of function triggers has reached the limit. You can submit a ticket to increase it.
	LIMITEXCEEDED_TRIGGER = "LimitExceeded.Trigger"

	// Failed to create the delivery target, as it was detected that the current account did not exist. Please check your account status.
	OPERATIONDENIED_ACCOUNTNOTEXISTS = "OperationDenied.AccountNotExists"

	// You cannot create a CLS event target based on the default EventBridge logset in the custom event bus.
	OPERATIONDENIED_DEFAULTCLSRESOURCEUNSUPPORTED = "OperationDenied.DefaultCLSResourceUnsupported"

	// The operation failed, as the resource could not be modified or deleted.
	OPERATIONDENIED_RESOURCEIMMUTABLE = "OperationDenied.ResourceImmutable"

	// The current user account type does not support this operation. Please submit a ticket.
	OPERATIONDENIED_UNSUPPORTEDOPERATION = "OperationDenied.UnsupportedOperation"

	// The default Tencent Cloud service event bus cannot be created repeatedly in the same region.
	RESOURCEINUSE_DEFAULTEVENTBUS = "ResourceInUse.DefaultEventBus"

	// Failed to delete the event bus. Please first delete all rules, connectors and archives of it.
	RESOURCEINUSE_EVENTBUS = "ResourceInUse.EventBus"

	// There are targets under the rule, so it cannot be deleted. Please delete all targets and try again.
	RESOURCEINUSE_RULE = "ResourceInUse.Rule"

	// The resource does not exist.
	RESOURCENOTFOUND = "ResourceNotFound"

	// The specified `Connection` was not found. Please create it and try again.
	RESOURCENOTFOUND_CONNECTION = "ResourceNotFound.Connection"

	// The specified event bus was not found. Please create it and try again.
	RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"

	// The specified `Function` was not found. Please create it and try again.
	RESOURCENOTFOUND_FUNCTION = "ResourceNotFound.Function"

	// Failed to delete the connector, as the specified API was not found.
	RESOURCENOTFOUND_INVALIDAPI = "ResourceNotFound.InvalidApi"

	// The connector operation failed, as the specified API Gateway service was not found.
	RESOURCENOTFOUND_INVALIDSERVICE = "ResourceNotFound.InvalidService"

	// Failed to create the delivery target, as the specified namespace was not found. Please create it and try again.
	RESOURCENOTFOUND_NAMESPACE = "ResourceNotFound.Namespace"

	//
	RESOURCENOTFOUND_PRIVATELINKRESOURCE = "ResourceNotFound.PrivateLinkResource"

	// The specified service role was not found. Please create it and try again.
	RESOURCENOTFOUND_ROLE = "ResourceNotFound.Role"

	// The specified `Rule` was not found. Please create it and try again.
	RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule"

	// The specified `Target` was not found. Please create it and try again.
	RESOURCENOTFOUND_TARGET = "ResourceNotFound.Target"

	// The specified task is not found. Please check and try again.
	RESOURCENOTFOUND_TRANSFORMATION = "ResourceNotFound.Transformation"

	// Failed to create the delivery target, as the specified service version was not found. Please create it and try again.
	RESOURCENOTFOUND_VERSION = "ResourceNotFound.Version"

	// Failed to create the connector: The current resource is unavailable.
	RESOURCEUNAVAILABLE_CONNECTION = "ResourceUnavailable.Connection"

	// Failed to create the delivery target, as the current resource was unavailable.
	RESOURCEUNAVAILABLE_TARGET = "ResourceUnavailable.Target"

	// The current account does not have permissions to use EB. Please log in to the CAM console for authorization.
	UNAUTHORIZEDOPERATION_CAM = "UnauthorizedOperation.CAM"

	// Unsupported operation
	UNSUPPORTEDOPERATION = "UnsupportedOperation"

	// The connector operation failed, as the API did not support the current operation.
	UNSUPPORTEDOPERATION_INVALIDACTION = "UnsupportedOperation.InvalidAction"

	// Failed to create the connector: The current backend service type is not supported.
	UNSUPPORTEDOPERATION_INVALIDENDPOINTTYPE = "UnsupportedOperation.InvalidEndpointType"
)
View Source 
const APIVersion = "2021-04-16"

Variables

This section is empty.

Functions

This section is empty.

Types

type APIGWParams 

type APIGWParams struct {
	// HTTPS
	Protocol *string `json:"Protocol,omitempty" name:"Protocol"`

	// POST
	Method *string `json:"Method,omitempty" name:"Method"`
}

type CheckRuleRequest 

type CheckRuleRequest struct {
	*tchttp.BaseRequest
}

func NewCheckRuleRequest 

func NewCheckRuleRequest() (request *CheckRuleRequest)

func (*CheckRuleRequest) FromJsonString 

func (r *CheckRuleRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CheckRuleRequest) ToJsonString 

func (r *CheckRuleRequest) ToJsonString() string

type CheckRuleRequestParams 

type CheckRuleRequestParams struct {
}

Predefined struct for user

type CheckRuleResponse 

type CheckRuleResponse struct {
	*tchttp.BaseResponse
	Response *CheckRuleResponseParams `json:"Response"`
}

func NewCheckRuleResponse 

func NewCheckRuleResponse() (response *CheckRuleResponse)

func (*CheckRuleResponse) FromJsonString 

func (r *CheckRuleResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CheckRuleResponse) ToJsonString 

func (r *CheckRuleResponse) ToJsonString() string

type CheckRuleResponseParams 

type CheckRuleResponseParams struct {
	// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type CheckTransformationRequest 

type CheckTransformationRequest struct {
	*tchttp.BaseRequest

	// JSON string to be processed
	Input *string `json:"Input,omitempty" name:"Input"`

	// Transformation rule list
	Transformations []*Transformation `json:"Transformations,omitempty" name:"Transformations"`
}

func NewCheckTransformationRequest 

func NewCheckTransformationRequest() (request *CheckTransformationRequest)

func (*CheckTransformationRequest) FromJsonString 

func (r *CheckTransformationRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CheckTransformationRequest) ToJsonString 

func (r *CheckTransformationRequest) ToJsonString() string

type CheckTransformationRequestParams 

type CheckTransformationRequestParams struct {
	// JSON string to be processed
	Input *string `json:"Input,omitempty" name:"Input"`

	// Transformation rule list
	Transformations []*Transformation `json:"Transformations,omitempty" name:"Transformations"`
}

Predefined struct for user

type CheckTransformationResponse 

type CheckTransformationResponse struct {
	*tchttp.BaseResponse
	Response *CheckTransformationResponseParams `json:"Response"`
}

func NewCheckTransformationResponse 

func NewCheckTransformationResponse() (response *CheckTransformationResponse)

func (*CheckTransformationResponse) FromJsonString 

func (r *CheckTransformationResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CheckTransformationResponse) ToJsonString 

func (r *CheckTransformationResponse) ToJsonString() string

type CheckTransformationResponseParams 

type CheckTransformationResponseParams struct {
	// Data processed by `Transformations`
	Output *string `json:"Output,omitempty" name:"Output"`

	// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type CkafkaDeliveryParams 

type CkafkaDeliveryParams struct {
	// ckafka topic name
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`

	// Six-Segment QCS description of CKafka resource
	ResourceDescription *string `json:"ResourceDescription,omitempty" name:"ResourceDescription"`
}

type CkafkaParams 

type CkafkaParams struct {
	// kafka offset
	Offset *string `json:"Offset,omitempty" name:"Offset"`

	// ckafka  topic
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`
}

type CkafkaTargetParams 

type CkafkaTargetParams struct {
	// CKafka topic to be delivered to
	TopicName *string `json:"TopicName,omitempty" name:"TopicName"`

	// Retry policy
	RetryPolicy *RetryPolicy `json:"RetryPolicy,omitempty" name:"RetryPolicy"`
}

type Client 

type Client struct {
	common.Client
}

func NewClient 

func NewClient(credential common.CredentialIface, region string, clientProfile *profile.ClientProfile) (client *Client, err error)

func NewClientWithSecretId 

func NewClientWithSecretId(secretId, secretKey, region string) (client *Client, err error)

Deprecated

func (*Client) CheckRule 

func (c *Client) CheckRule(request *CheckRuleRequest) (response *CheckRuleResponse, err error)

CheckRule This API is used to check a rule.

error code that may be returned: 

FAILEDOPERATION_ERRORFILTER = "FailedOperation.ErrorFilter"
INTERNALERROR = "InternalError"
INTERNALERROR_SYSTEM = "InternalError.System"
INVALIDPARAMETER = "InvalidParameter"
INVALIDPARAMETERVALUE_INVALIDFILTERRULE = "InvalidParameterValue.InvalidFilterRule"
INVALIDPARAMETERVALUE_INVALIDPATTERN = "InvalidParameterValue.InvalidPattern"

func (*Client) CheckRuleWithContext 

func (c *Client) CheckRuleWithContext(ctx context.Context, request *CheckRuleRequest) (response *CheckRuleResponse, err error)

CheckRule This API is used to check a rule.

error code that may be returned: 

FAILEDOPERATION_ERRORFILTER = "FailedOperation.ErrorFilter"
INTERNALERROR = "InternalError"
INTERNALERROR_SYSTEM = "InternalError.System"
INVALIDPARAMETER = "InvalidParameter"
INVALIDPARAMETERVALUE_INVALIDFILTERRULE = "InvalidParameterValue.InvalidFilterRule"
INVALIDPARAMETERVALUE_INVALIDPATTERN = "InvalidParameterValue.InvalidPattern"

func (*Client) CheckTransformation 

func (c *Client) CheckTransformation(request *CheckTransformationRequest) (response *CheckTransformationResponse, err error)

CheckTransformation This API is used to test rules and data on the ETL configuration page.

error code that may be returned: 

FAILEDOPERATION_ERRORFILTER = "FailedOperation.ErrorFilter"
INTERNALERROR = "InternalError"
INTERNALERROR_SYSTEM = "InternalError.System"
INVALIDPARAMETER = "InvalidParameter"
INVALIDPARAMETERVALUE_INVALIDFILTERRULE = "InvalidParameterValue.InvalidFilterRule"
INVALIDPARAMETERVALUE_INVALIDPATTERN = "InvalidParameterValue.InvalidPattern"

func (*Client) CheckTransformationWithContext 

func (c *Client) CheckTransformationWithContext(ctx context.Context, request *CheckTransformationRequest) (response *CheckTransformationResponse, err error)

CheckTransformation This API is used to test rules and data on the ETL configuration page.

error code that may be returned: 

FAILEDOPERATION_ERRORFILTER = "FailedOperation.ErrorFilter"
INTERNALERROR = "InternalError"
INTERNALERROR_SYSTEM = "InternalError.System"
INVALIDPARAMETER = "InvalidParameter"
INVALIDPARAMETERVALUE_INVALIDFILTERRULE = "InvalidParameterValue.InvalidFilterRule"
INVALIDPARAMETERVALUE_INVALIDPATTERN = "InvalidParameterValue.InvalidPattern"

func (*Client) CreateConnection 

func (c *Client) CreateConnection(request *CreateConnectionRequest) (response *CreateConnectionResponse, err error)

CreateConnection This API is used to create an event connector.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_SERVICEERROR = "FailedOperation.ServiceError"
INTERNALERROR_OSSEXCEPTION = "InternalError.OssException"
INVALIDPARAMETERVALUE_CONNECTIONDESCRIPTION = "InvalidParameterValue.ConnectionDescription"
INVALIDPARAMETERVALUE_CONNECTIONNAME = "InvalidParameterValue.ConnectionName"
INVALIDPARAMETERVALUE_DTSPARAMS = "InvalidParameterValue.DTSParams"
INVALIDPARAMETERVALUE_DESCRIPTION = "InvalidParameterValue.Description"
INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
INVALIDPARAMETERVALUE_EVENTBUSNAME = "InvalidParameterValue.EventBusName"
INVALIDPARAMETERVALUE_INVALIDAPIREQUESTCONFIG = "InvalidParameterValue.InvalidApiRequestConfig"
INVALIDPARAMETERVALUE_TYPE = "InvalidParameterValue.Type"
LIMITEXCEEDED_CONNECTION = "LimitExceeded.Connection"
LIMITEXCEEDED_ROUTEOVERLIMIT = "LimitExceeded.RouteOverLimit"
OPERATIONDENIED_RESOURCEIMMUTABLE = "OperationDenied.ResourceImmutable"
OPERATIONDENIED_UNSUPPORTEDOPERATION = "OperationDenied.UnsupportedOperation"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
RESOURCENOTFOUND_INVALIDSERVICE = "ResourceNotFound.InvalidService"
RESOURCENOTFOUND_ROLE = "ResourceNotFound.Role"
RESOURCENOTFOUND_TARGET = "ResourceNotFound.Target"
RESOURCEUNAVAILABLE_CONNECTION = "ResourceUnavailable.Connection"
UNSUPPORTEDOPERATION = "UnsupportedOperation"
UNSUPPORTEDOPERATION_INVALIDACTION = "UnsupportedOperation.InvalidAction"
UNSUPPORTEDOPERATION_INVALIDENDPOINTTYPE = "UnsupportedOperation.InvalidEndpointType"

func (*Client) CreateConnectionWithContext 

func (c *Client) CreateConnectionWithContext(ctx context.Context, request *CreateConnectionRequest) (response *CreateConnectionResponse, err error)

CreateConnection This API is used to create an event connector.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_SERVICEERROR = "FailedOperation.ServiceError"
INTERNALERROR_OSSEXCEPTION = "InternalError.OssException"
INVALIDPARAMETERVALUE_CONNECTIONDESCRIPTION = "InvalidParameterValue.ConnectionDescription"
INVALIDPARAMETERVALUE_CONNECTIONNAME = "InvalidParameterValue.ConnectionName"
INVALIDPARAMETERVALUE_DTSPARAMS = "InvalidParameterValue.DTSParams"
INVALIDPARAMETERVALUE_DESCRIPTION = "InvalidParameterValue.Description"
INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
INVALIDPARAMETERVALUE_EVENTBUSNAME = "InvalidParameterValue.EventBusName"
INVALIDPARAMETERVALUE_INVALIDAPIREQUESTCONFIG = "InvalidParameterValue.InvalidApiRequestConfig"
INVALIDPARAMETERVALUE_TYPE = "InvalidParameterValue.Type"
LIMITEXCEEDED_CONNECTION = "LimitExceeded.Connection"
LIMITEXCEEDED_ROUTEOVERLIMIT = "LimitExceeded.RouteOverLimit"
OPERATIONDENIED_RESOURCEIMMUTABLE = "OperationDenied.ResourceImmutable"
OPERATIONDENIED_UNSUPPORTEDOPERATION = "OperationDenied.UnsupportedOperation"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
RESOURCENOTFOUND_INVALIDSERVICE = "ResourceNotFound.InvalidService"
RESOURCENOTFOUND_ROLE = "ResourceNotFound.Role"
RESOURCENOTFOUND_TARGET = "ResourceNotFound.Target"
RESOURCEUNAVAILABLE_CONNECTION = "ResourceUnavailable.Connection"
UNSUPPORTEDOPERATION = "UnsupportedOperation"
UNSUPPORTEDOPERATION_INVALIDACTION = "UnsupportedOperation.InvalidAction"
UNSUPPORTEDOPERATION_INVALIDENDPOINTTYPE = "UnsupportedOperation.InvalidEndpointType"

func (*Client) CreateEventBus 

func (c *Client) CreateEventBus(request *CreateEventBusRequest) (response *CreateEventBusResponse, err error)

CreateEventBus This API is used to create an event bus.

error code that may be returned: 

FAILEDOPERATION_REGISTERCLSSERVICE = "FailedOperation.RegisterCLSService"
INTERNALERROR = "InternalError"
INVALIDPARAMETERVALUE_DESCRIPTION = "InvalidParameterValue.Description"
INVALIDPARAMETERVALUE_EVENTBUSNAME = "InvalidParameterValue.EventBusName"
INVALIDPARAMETERVALUE_EVENTTRACECONFIG = "InvalidParameterValue.EventTraceConfig"
INVALIDPARAMETERVALUE_LINKMODE = "InvalidParameterValue.LinkMode"
INVALIDPARAMETERVALUE_TAGS = "InvalidParameterValue.Tags"
INVALIDPARAMETERVALUE_TYPE = "InvalidParameterValue.Type"
LIMITEXCEEDED_EVENTBUS = "LimitExceeded.EventBus"
LIMITEXCEEDED_INSUFFICIENTBALANCE = "LimitExceeded.InsufficientBalance"
RESOURCEINUSE_DEFAULTEVENTBUS = "ResourceInUse.DefaultEventBus"
RESOURCEINUSE_EVENTBUS = "ResourceInUse.EventBus"
RESOURCENOTFOUND_ROLE = "ResourceNotFound.Role"

func (*Client) CreateEventBusWithContext 

func (c *Client) CreateEventBusWithContext(ctx context.Context, request *CreateEventBusRequest) (response *CreateEventBusResponse, err error)

CreateEventBus This API is used to create an event bus.

error code that may be returned: 

FAILEDOPERATION_REGISTERCLSSERVICE = "FailedOperation.RegisterCLSService"
INTERNALERROR = "InternalError"
INVALIDPARAMETERVALUE_DESCRIPTION = "InvalidParameterValue.Description"
INVALIDPARAMETERVALUE_EVENTBUSNAME = "InvalidParameterValue.EventBusName"
INVALIDPARAMETERVALUE_EVENTTRACECONFIG = "InvalidParameterValue.EventTraceConfig"
INVALIDPARAMETERVALUE_LINKMODE = "InvalidParameterValue.LinkMode"
INVALIDPARAMETERVALUE_TAGS = "InvalidParameterValue.Tags"
INVALIDPARAMETERVALUE_TYPE = "InvalidParameterValue.Type"
LIMITEXCEEDED_EVENTBUS = "LimitExceeded.EventBus"
LIMITEXCEEDED_INSUFFICIENTBALANCE = "LimitExceeded.InsufficientBalance"
RESOURCEINUSE_DEFAULTEVENTBUS = "ResourceInUse.DefaultEventBus"
RESOURCEINUSE_EVENTBUS = "ResourceInUse.EventBus"
RESOURCENOTFOUND_ROLE = "ResourceNotFound.Role"

func (*Client) CreateRule 

func (c *Client) CreateRule(request *CreateRuleRequest) (response *CreateRuleResponse, err error)

CreateRule This API is used to create an event rule.

error code that may be returned: 

INVALIDPARAMETERVALUE_DEADLETTERCONFIG = "InvalidParameterValue.DeadLetterConfig"
INVALIDPARAMETERVALUE_DESCRIPTION = "InvalidParameterValue.Description"
INVALIDPARAMETERVALUE_EVENTPATTERN = "InvalidParameterValue.EventPattern"
INVALIDPARAMETERVALUE_RULENAME = "InvalidParameterValue.RuleName"
INVALIDPARAMETERVALUE_TAGS = "InvalidParameterValue.Tags"
INVALIDPARAMETERVALUE_TYPE = "InvalidParameterValue.Type"
LIMITEXCEEDED_RULE = "LimitExceeded.Rule"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"

func (*Client) CreateRuleWithContext 

func (c *Client) CreateRuleWithContext(ctx context.Context, request *CreateRuleRequest) (response *CreateRuleResponse, err error)

CreateRule This API is used to create an event rule.

error code that may be returned: 

INVALIDPARAMETERVALUE_DEADLETTERCONFIG = "InvalidParameterValue.DeadLetterConfig"
INVALIDPARAMETERVALUE_DESCRIPTION = "InvalidParameterValue.Description"
INVALIDPARAMETERVALUE_EVENTPATTERN = "InvalidParameterValue.EventPattern"
INVALIDPARAMETERVALUE_RULENAME = "InvalidParameterValue.RuleName"
INVALIDPARAMETERVALUE_TAGS = "InvalidParameterValue.Tags"
INVALIDPARAMETERVALUE_TYPE = "InvalidParameterValue.Type"
LIMITEXCEEDED_RULE = "LimitExceeded.Rule"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"

func (*Client) CreateTarget 

func (c *Client) CreateTarget(request *CreateTargetRequest) (response *CreateTargetResponse, err error)

CreateTarget This API is used to create a delivery target.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_AUTHENTICATEUSERFAILED = "FailedOperation.AuthenticateUserFailed"
FAILEDOPERATION_CREATETRIGGER = "FailedOperation.CreateTrigger"
FAILEDOPERATION_ESREQUESTFAILED = "FailedOperation.ESRequestFailed"
INVALIDPARAMETERVALUE_AMPPARAMS = "InvalidParameterValue.AMPParams"
INVALIDPARAMETERVALUE_BATCHEVENTCOUNT = "InvalidParameterValue.BatchEventCount"
INVALIDPARAMETERVALUE_BATCHTIMEOUT = "InvalidParameterValue.BatchTimeout"
INVALIDPARAMETERVALUE_CKAFKATARGETPARAMS = "InvalidParameterValue.CKafkaTargetParams"
INVALIDPARAMETERVALUE_CALLBACKTYPE = "InvalidParameterValue.CallbackType"
INVALIDPARAMETERVALUE_CALLBACKWECOMURL = "InvalidParameterValue.CallbackWeComURL"
INVALIDPARAMETERVALUE_ELASTICSEARCHTARGETPARAMS = "InvalidParameterValue.ElasticSearchTargetParams"
INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
INVALIDPARAMETERVALUE_NOTICERECEIVERCHANNEL = "InvalidParameterValue.NoticeReceiverChannel"
INVALIDPARAMETERVALUE_NOTICERECEIVERTIMEWINDOW = "InvalidParameterValue.NoticeReceiverTimeWindow"
INVALIDPARAMETERVALUE_NOTICERECEIVERUSERIDS = "InvalidParameterValue.NoticeReceiverUserIds"
INVALIDPARAMETERVALUE_NOTICERECEIVERUSERTYPE = "InvalidParameterValue.NoticeReceiverUserType"
INVALIDPARAMETERVALUE_QUALIFIER = "InvalidParameterValue.Qualifier"
INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"
INVALIDPARAMETERVALUE_TARGETDESCRIPTION = "InvalidParameterValue.TargetDescription"
INVALIDPARAMETERVALUE_TYPE = "InvalidParameterValue.Type"
LIMITEXCEEDED_LOGSET = "LimitExceeded.Logset"
LIMITEXCEEDED_TARGET = "LimitExceeded.Target"
LIMITEXCEEDED_TRIGGER = "LimitExceeded.Trigger"
OPERATIONDENIED_ACCOUNTNOTEXISTS = "OperationDenied.AccountNotExists"
OPERATIONDENIED_DEFAULTCLSRESOURCEUNSUPPORTED = "OperationDenied.DefaultCLSResourceUnsupported"
OPERATIONDENIED_UNSUPPORTEDOPERATION = "OperationDenied.UnsupportedOperation"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
RESOURCENOTFOUND_FUNCTION = "ResourceNotFound.Function"
RESOURCENOTFOUND_NAMESPACE = "ResourceNotFound.Namespace"
RESOURCENOTFOUND_ROLE = "ResourceNotFound.Role"
RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule"
RESOURCENOTFOUND_TARGET = "ResourceNotFound.Target"
RESOURCENOTFOUND_VERSION = "ResourceNotFound.Version"
RESOURCEUNAVAILABLE_TARGET = "ResourceUnavailable.Target"

func (*Client) CreateTargetWithContext 

func (c *Client) CreateTargetWithContext(ctx context.Context, request *CreateTargetRequest) (response *CreateTargetResponse, err error)

CreateTarget This API is used to create a delivery target.

error code that may be returned: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_AUTHENTICATEUSERFAILED = "FailedOperation.AuthenticateUserFailed"
FAILEDOPERATION_CREATETRIGGER = "FailedOperation.CreateTrigger"
FAILEDOPERATION_ESREQUESTFAILED = "FailedOperation.ESRequestFailed"
INVALIDPARAMETERVALUE_AMPPARAMS = "InvalidParameterValue.AMPParams"
INVALIDPARAMETERVALUE_BATCHEVENTCOUNT = "InvalidParameterValue.BatchEventCount"
INVALIDPARAMETERVALUE_BATCHTIMEOUT = "InvalidParameterValue.BatchTimeout"
INVALIDPARAMETERVALUE_CKAFKATARGETPARAMS = "InvalidParameterValue.CKafkaTargetParams"
INVALIDPARAMETERVALUE_CALLBACKTYPE = "InvalidParameterValue.CallbackType"
INVALIDPARAMETERVALUE_CALLBACKWECOMURL = "InvalidParameterValue.CallbackWeComURL"
INVALIDPARAMETERVALUE_ELASTICSEARCHTARGETPARAMS = "InvalidParameterValue.ElasticSearchTargetParams"
INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
INVALIDPARAMETERVALUE_NOTICERECEIVERCHANNEL = "InvalidParameterValue.NoticeReceiverChannel"
INVALIDPARAMETERVALUE_NOTICERECEIVERTIMEWINDOW = "InvalidParameterValue.NoticeReceiverTimeWindow"
INVALIDPARAMETERVALUE_NOTICERECEIVERUSERIDS = "InvalidParameterValue.NoticeReceiverUserIds"
INVALIDPARAMETERVALUE_NOTICERECEIVERUSERTYPE = "InvalidParameterValue.NoticeReceiverUserType"
INVALIDPARAMETERVALUE_QUALIFIER = "InvalidParameterValue.Qualifier"
INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"
INVALIDPARAMETERVALUE_TARGETDESCRIPTION = "InvalidParameterValue.TargetDescription"
INVALIDPARAMETERVALUE_TYPE = "InvalidParameterValue.Type"
LIMITEXCEEDED_LOGSET = "LimitExceeded.Logset"
LIMITEXCEEDED_TARGET = "LimitExceeded.Target"
LIMITEXCEEDED_TRIGGER = "LimitExceeded.Trigger"
OPERATIONDENIED_ACCOUNTNOTEXISTS = "OperationDenied.AccountNotExists"
OPERATIONDENIED_DEFAULTCLSRESOURCEUNSUPPORTED = "OperationDenied.DefaultCLSResourceUnsupported"
OPERATIONDENIED_UNSUPPORTEDOPERATION = "OperationDenied.UnsupportedOperation"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
RESOURCENOTFOUND_FUNCTION = "ResourceNotFound.Function"
RESOURCENOTFOUND_NAMESPACE = "ResourceNotFound.Namespace"
RESOURCENOTFOUND_ROLE = "ResourceNotFound.Role"
RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule"
RESOURCENOTFOUND_TARGET = "ResourceNotFound.Target"
RESOURCENOTFOUND_VERSION = "ResourceNotFound.Version"
RESOURCEUNAVAILABLE_TARGET = "ResourceUnavailable.Target"

func (*Client) CreateTransformation 

func (c *Client) CreateTransformation(request *CreateTransformationRequest) (response *CreateTransformationResponse, err error)

CreateTransformation This API is used to create a transformer.

error code that may be returned: 

INVALIDPARAMETERVALUE_TRANSFORMATIONS = "InvalidParameterValue.Transformations"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule"

func (*Client) CreateTransformationWithContext 

func (c *Client) CreateTransformationWithContext(ctx context.Context, request *CreateTransformationRequest) (response *CreateTransformationResponse, err error)

CreateTransformation This API is used to create a transformer.

error code that may be returned: 

INVALIDPARAMETERVALUE_TRANSFORMATIONS = "InvalidParameterValue.Transformations"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule"

func (*Client) DeleteConnection 

func (c *Client) DeleteConnection(request *DeleteConnectionRequest) (response *DeleteConnectionResponse, err error)

DeleteConnection This API is used to delete an event connector.

error code that may be returned: 

FAILEDOPERATION_DELETECONNECTION = "FailedOperation.DeleteConnection"
FAILEDOPERATION_SERVICEERROR = "FailedOperation.ServiceError"
INTERNALERROR_OSSEXCEPTION = "InternalError.OssException"
INVALIDPARAMETERVALUE_CONNECTIONDESCRIPTION = "InvalidParameterValue.ConnectionDescription"
INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
RESOURCENOTFOUND_CONNECTION = "ResourceNotFound.Connection"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
RESOURCENOTFOUND_INVALIDAPI = "ResourceNotFound.InvalidApi"
RESOURCENOTFOUND_INVALIDSERVICE = "ResourceNotFound.InvalidService"
UNSUPPORTEDOPERATION_INVALIDACTION = "UnsupportedOperation.InvalidAction"

func (*Client) DeleteConnectionWithContext 

func (c *Client) DeleteConnectionWithContext(ctx context.Context, request *DeleteConnectionRequest) (response *DeleteConnectionResponse, err error)

DeleteConnection This API is used to delete an event connector.

error code that may be returned: 

FAILEDOPERATION_DELETECONNECTION = "FailedOperation.DeleteConnection"
FAILEDOPERATION_SERVICEERROR = "FailedOperation.ServiceError"
INTERNALERROR_OSSEXCEPTION = "InternalError.OssException"
INVALIDPARAMETERVALUE_CONNECTIONDESCRIPTION = "InvalidParameterValue.ConnectionDescription"
INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
RESOURCENOTFOUND_CONNECTION = "ResourceNotFound.Connection"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
RESOURCENOTFOUND_INVALIDAPI = "ResourceNotFound.InvalidApi"
RESOURCENOTFOUND_INVALIDSERVICE = "ResourceNotFound.InvalidService"
UNSUPPORTEDOPERATION_INVALIDACTION = "UnsupportedOperation.InvalidAction"

func (*Client) DeleteEventBus 

func (c *Client) DeleteEventBus(request *DeleteEventBusRequest) (response *DeleteEventBusResponse, err error)

DeleteEventBus This API is used to delete an event bus.

error code that may be returned: 

INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
OPERATIONDENIED_RESOURCEIMMUTABLE = "OperationDenied.ResourceImmutable"
RESOURCEINUSE_EVENTBUS = "ResourceInUse.EventBus"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"

func (*Client) DeleteEventBusWithContext 

func (c *Client) DeleteEventBusWithContext(ctx context.Context, request *DeleteEventBusRequest) (response *DeleteEventBusResponse, err error)

DeleteEventBus This API is used to delete an event bus.

error code that may be returned: 

INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
OPERATIONDENIED_RESOURCEIMMUTABLE = "OperationDenied.ResourceImmutable"
RESOURCEINUSE_EVENTBUS = "ResourceInUse.EventBus"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"

func (*Client) DeleteRule 

func (c *Client) DeleteRule(request *DeleteRuleRequest) (response *DeleteRuleResponse, err error)

DeleteRule This API is used to delete an event rule.

error code that may be returned: 

FAILEDOPERATION_DELETERULE = "FailedOperation.DeleteRule"
INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"
RESOURCEINUSE_RULE = "ResourceInUse.Rule"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule"

func (*Client) DeleteRuleWithContext 

func (c *Client) DeleteRuleWithContext(ctx context.Context, request *DeleteRuleRequest) (response *DeleteRuleResponse, err error)

DeleteRule This API is used to delete an event rule.

error code that may be returned: 

FAILEDOPERATION_DELETERULE = "FailedOperation.DeleteRule"
INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"
RESOURCEINUSE_RULE = "ResourceInUse.Rule"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule"

func (*Client) DeleteTarget 

func (c *Client) DeleteTarget(request *DeleteTargetRequest) (response *DeleteTargetResponse, err error)

DeleteTarget This API is used to delete a delivery target.

error code that may be returned: 

FAILEDOPERATION_ESREQUESTFAILED = "FailedOperation.ESRequestFailed"
INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"
INVALIDPARAMETERVALUE_TARGETID = "InvalidParameterValue.TargetId"
INVALIDPARAMETERVALUE_TYPE = "InvalidParameterValue.Type"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
RESOURCENOTFOUND_PRIVATELINKRESOURCE = "ResourceNotFound.PrivateLinkResource"
RESOURCENOTFOUND_ROLE = "ResourceNotFound.Role"
RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule"
RESOURCENOTFOUND_TARGET = "ResourceNotFound.Target"

func (*Client) DeleteTargetWithContext 

func (c *Client) DeleteTargetWithContext(ctx context.Context, request *DeleteTargetRequest) (response *DeleteTargetResponse, err error)

DeleteTarget This API is used to delete a delivery target.

error code that may be returned: 

FAILEDOPERATION_ESREQUESTFAILED = "FailedOperation.ESRequestFailed"
INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"
INVALIDPARAMETERVALUE_TARGETID = "InvalidParameterValue.TargetId"
INVALIDPARAMETERVALUE_TYPE = "InvalidParameterValue.Type"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
RESOURCENOTFOUND_PRIVATELINKRESOURCE = "ResourceNotFound.PrivateLinkResource"
RESOURCENOTFOUND_ROLE = "ResourceNotFound.Role"
RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule"
RESOURCENOTFOUND_TARGET = "ResourceNotFound.Target"

func (*Client) DeleteTransformation 

func (c *Client) DeleteTransformation(request *DeleteTransformationRequest) (response *DeleteTransformationResponse, err error)

DeleteTransformation This API is used to delete a transformer.

error code that may be returned: 

INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
INVALIDPARAMETERVALUE_TRANSFORMATIONID = "InvalidParameterValue.TransformationID"
RESOURCENOTFOUND_TRANSFORMATION = "ResourceNotFound.Transformation"

func (*Client) DeleteTransformationWithContext 

func (c *Client) DeleteTransformationWithContext(ctx context.Context, request *DeleteTransformationRequest) (response *DeleteTransformationResponse, err error)

DeleteTransformation This API is used to delete a transformer.

error code that may be returned: 

INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
INVALIDPARAMETERVALUE_TRANSFORMATIONID = "InvalidParameterValue.TransformationID"
RESOURCENOTFOUND_TRANSFORMATION = "ResourceNotFound.Transformation"

func (*Client) GetEventBus 

func (c *Client) GetEventBus(request *GetEventBusRequest) (response *GetEventBusResponse, err error)

GetEventBus This API is used to get the details of an event bus.

error code that may be returned: 

INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"

func (*Client) GetEventBusWithContext 

func (c *Client) GetEventBusWithContext(ctx context.Context, request *GetEventBusRequest) (response *GetEventBusResponse, err error)

GetEventBus This API is used to get the details of an event bus.

error code that may be returned: 

INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"

func (*Client) GetRule 

func (c *Client) GetRule(request *GetRuleRequest) (response *GetRuleResponse, err error)

GetRule This API is used to get the details of an event rule.

error code that may be returned: 

INTERNALERROR = "InternalError"
INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule"

func (*Client) GetRuleWithContext 

func (c *Client) GetRuleWithContext(ctx context.Context, request *GetRuleRequest) (response *GetRuleResponse, err error)

GetRule This API is used to get the details of an event rule.

error code that may be returned: 

INTERNALERROR = "InternalError"
INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule"

func (*Client) GetTransformation 

func (c *Client) GetTransformation(request *GetTransformationRequest) (response *GetTransformationResponse, err error)

GetTransformation This API is used to get the details of a transformer.

error code that may be returned: 

INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"
INVALIDPARAMETERVALUE_TRANSFORMATIONID = "InvalidParameterValue.TransformationID"
RESOURCENOTFOUND_TRANSFORMATION = "ResourceNotFound.Transformation"

func (*Client) GetTransformationWithContext 

func (c *Client) GetTransformationWithContext(ctx context.Context, request *GetTransformationRequest) (response *GetTransformationResponse, err error)

GetTransformation This API is used to get the details of a transformer.

error code that may be returned: 

INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"
INVALIDPARAMETERVALUE_TRANSFORMATIONID = "InvalidParameterValue.TransformationID"
RESOURCENOTFOUND_TRANSFORMATION = "ResourceNotFound.Transformation"

func (*Client) ListConnections 

func (c *Client) ListConnections(request *ListConnectionsRequest) (response *ListConnectionsResponse, err error)

ListConnections This API is used to get the list of event connectors.

error code that may be returned: 

INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
INVALIDPARAMETERVALUE_LIMIT = "InvalidParameterValue.Limit"
INVALIDPARAMETERVALUE_OFFSET = "InvalidParameterValue.Offset"
INVALIDPARAMETERVALUE_ORDER = "InvalidParameterValue.Order"
INVALIDPARAMETERVALUE_ORDERBY = "InvalidParameterValue.OrderBy"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"

func (*Client) ListConnectionsWithContext 

func (c *Client) ListConnectionsWithContext(ctx context.Context, request *ListConnectionsRequest) (response *ListConnectionsResponse, err error)

ListConnections This API is used to get the list of event connectors.

error code that may be returned: 

INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
INVALIDPARAMETERVALUE_LIMIT = "InvalidParameterValue.Limit"
INVALIDPARAMETERVALUE_OFFSET = "InvalidParameterValue.Offset"
INVALIDPARAMETERVALUE_ORDER = "InvalidParameterValue.Order"
INVALIDPARAMETERVALUE_ORDERBY = "InvalidParameterValue.OrderBy"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"

func (*Client) ListEventBuses 

func (c *Client) ListEventBuses(request *ListEventBusesRequest) (response *ListEventBusesResponse, err error)

ListEventBuses This API is used to get the list of event buses.

error code that may be returned: 

INTERNALERROR = "InternalError"
INVALIDPARAMETERVALUE_FILTERS = "InvalidParameterValue.Filters"
INVALIDPARAMETERVALUE_LIMIT = "InvalidParameterValue.Limit"
INVALIDPARAMETERVALUE_OFFSET = "InvalidParameterValue.Offset"
INVALIDPARAMETERVALUE_ORDER = "InvalidParameterValue.Order"
INVALIDPARAMETERVALUE_ORDERBY = "InvalidParameterValue.OrderBy"
UNAUTHORIZEDOPERATION_CAM = "UnauthorizedOperation.CAM"

func (*Client) ListEventBusesWithContext 

func (c *Client) ListEventBusesWithContext(ctx context.Context, request *ListEventBusesRequest) (response *ListEventBusesResponse, err error)

ListEventBuses This API is used to get the list of event buses.

error code that may be returned: 

INTERNALERROR = "InternalError"
INVALIDPARAMETERVALUE_FILTERS = "InvalidParameterValue.Filters"
INVALIDPARAMETERVALUE_LIMIT = "InvalidParameterValue.Limit"
INVALIDPARAMETERVALUE_OFFSET = "InvalidParameterValue.Offset"
INVALIDPARAMETERVALUE_ORDER = "InvalidParameterValue.Order"
INVALIDPARAMETERVALUE_ORDERBY = "InvalidParameterValue.OrderBy"
UNAUTHORIZEDOPERATION_CAM = "UnauthorizedOperation.CAM"

func (*Client) ListRules 

func (c *Client) ListRules(request *ListRulesRequest) (response *ListRulesResponse, err error)

ListRules This API is used to get the list of event rules.

error code that may be returned: 

INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
INVALIDPARAMETERVALUE_FILTERS = "InvalidParameterValue.Filters"
INVALIDPARAMETERVALUE_LIMIT = "InvalidParameterValue.Limit"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"

func (*Client) ListRulesWithContext 

func (c *Client) ListRulesWithContext(ctx context.Context, request *ListRulesRequest) (response *ListRulesResponse, err error)

ListRules This API is used to get the list of event rules.

error code that may be returned: 

INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
INVALIDPARAMETERVALUE_FILTERS = "InvalidParameterValue.Filters"
INVALIDPARAMETERVALUE_LIMIT = "InvalidParameterValue.Limit"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"

func (*Client) ListTargets 

func (c *Client) ListTargets(request *ListTargetsRequest) (response *ListTargetsResponse, err error)

ListTargets This API is used to get the list delivery targets.

error code that may be returned: 

INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
INVALIDPARAMETERVALUE_LIMIT = "InvalidParameterValue.Limit"
INVALIDPARAMETERVALUE_OFFSET = "InvalidParameterValue.Offset"
INVALIDPARAMETERVALUE_ORDER = "InvalidParameterValue.Order"
INVALIDPARAMETERVALUE_ORDERBY = "InvalidParameterValue.OrderBy"
INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"
INVALIDPARAMETERVALUE_TARGETID = "InvalidParameterValue.TargetId"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule"

func (*Client) ListTargetsWithContext 

func (c *Client) ListTargetsWithContext(ctx context.Context, request *ListTargetsRequest) (response *ListTargetsResponse, err error)

ListTargets This API is used to get the list delivery targets.

error code that may be returned: 

INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
INVALIDPARAMETERVALUE_LIMIT = "InvalidParameterValue.Limit"
INVALIDPARAMETERVALUE_OFFSET = "InvalidParameterValue.Offset"
INVALIDPARAMETERVALUE_ORDER = "InvalidParameterValue.Order"
INVALIDPARAMETERVALUE_ORDERBY = "InvalidParameterValue.OrderBy"
INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"
INVALIDPARAMETERVALUE_TARGETID = "InvalidParameterValue.TargetId"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule"

func (*Client) UpdateConnection 

func (c *Client) UpdateConnection(request *UpdateConnectionRequest) (response *UpdateConnectionResponse, err error)

UpdateConnection This API is used to update an event connector.

error code that may be returned: 

FAILEDOPERATION_UPDATECONNECTION = "FailedOperation.UpdateConnection"
INVALIDPARAMETER_ENABLEAPIGATEWAY = "InvalidParameter.EnableAPIGateway"
INVALIDPARAMETERVALUE_CONNECTIONID = "InvalidParameterValue.ConnectionId"
INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
OPERATIONDENIED_RESOURCEIMMUTABLE = "OperationDenied.ResourceImmutable"
RESOURCENOTFOUND_CONNECTION = "ResourceNotFound.Connection"

func (*Client) UpdateConnectionWithContext 

func (c *Client) UpdateConnectionWithContext(ctx context.Context, request *UpdateConnectionRequest) (response *UpdateConnectionResponse, err error)

UpdateConnection This API is used to update an event connector.

error code that may be returned: 

FAILEDOPERATION_UPDATECONNECTION = "FailedOperation.UpdateConnection"
INVALIDPARAMETER_ENABLEAPIGATEWAY = "InvalidParameter.EnableAPIGateway"
INVALIDPARAMETERVALUE_CONNECTIONID = "InvalidParameterValue.ConnectionId"
INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
OPERATIONDENIED_RESOURCEIMMUTABLE = "OperationDenied.ResourceImmutable"
RESOURCENOTFOUND_CONNECTION = "ResourceNotFound.Connection"

func (*Client) UpdateEventBus 

func (c *Client) UpdateEventBus(request *UpdateEventBusRequest) (response *UpdateEventBusResponse, err error)

UpdateEventBus This API is used to update an event bus.

error code that may be returned: 

FAILEDOPERATION_REGISTERCLSSERVICE = "FailedOperation.RegisterCLSService"
INVALIDPARAMETERVALUE_DESCRIPTION = "InvalidParameterValue.Description"
INVALIDPARAMETERVALUE_EVENTBUSNAME = "InvalidParameterValue.EventBusName"
INVALIDPARAMETERVALUE_EVENTTRACECONFIG = "InvalidParameterValue.EventTraceConfig"
OPERATIONDENIED_DEFAULTCLSRESOURCEUNSUPPORTED = "OperationDenied.DefaultCLSResourceUnsupported"
OPERATIONDENIED_RESOURCEIMMUTABLE = "OperationDenied.ResourceImmutable"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"

func (*Client) UpdateEventBusWithContext 

func (c *Client) UpdateEventBusWithContext(ctx context.Context, request *UpdateEventBusRequest) (response *UpdateEventBusResponse, err error)

UpdateEventBus This API is used to update an event bus.

error code that may be returned: 

FAILEDOPERATION_REGISTERCLSSERVICE = "FailedOperation.RegisterCLSService"
INVALIDPARAMETERVALUE_DESCRIPTION = "InvalidParameterValue.Description"
INVALIDPARAMETERVALUE_EVENTBUSNAME = "InvalidParameterValue.EventBusName"
INVALIDPARAMETERVALUE_EVENTTRACECONFIG = "InvalidParameterValue.EventTraceConfig"
OPERATIONDENIED_DEFAULTCLSRESOURCEUNSUPPORTED = "OperationDenied.DefaultCLSResourceUnsupported"
OPERATIONDENIED_RESOURCEIMMUTABLE = "OperationDenied.ResourceImmutable"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"

func (*Client) UpdateRule 

func (c *Client) UpdateRule(request *UpdateRuleRequest) (response *UpdateRuleResponse, err error)

UpdateRule This API is used to update an event rule.

error code that may be returned: 

FAILEDOPERATION_UPDATERULE = "FailedOperation.UpdateRule"
INVALIDPARAMETER_PAYLOAD = "InvalidParameter.Payload"
INVALIDPARAMETERVALUE_DESCRIPTION = "InvalidParameterValue.Description"
INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
INVALIDPARAMETERVALUE_EVENTPATTERN = "InvalidParameterValue.EventPattern"
INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"
INVALIDPARAMETERVALUE_RULENAME = "InvalidParameterValue.RuleName"
INVALIDPARAMETERVALUE_TYPE = "InvalidParameterValue.Type"
OPERATIONDENIED_RESOURCEIMMUTABLE = "OperationDenied.ResourceImmutable"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"

func (*Client) UpdateRuleWithContext 

func (c *Client) UpdateRuleWithContext(ctx context.Context, request *UpdateRuleRequest) (response *UpdateRuleResponse, err error)

UpdateRule This API is used to update an event rule.

error code that may be returned: 

FAILEDOPERATION_UPDATERULE = "FailedOperation.UpdateRule"
INVALIDPARAMETER_PAYLOAD = "InvalidParameter.Payload"
INVALIDPARAMETERVALUE_DESCRIPTION = "InvalidParameterValue.Description"
INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
INVALIDPARAMETERVALUE_EVENTPATTERN = "InvalidParameterValue.EventPattern"
INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"
INVALIDPARAMETERVALUE_RULENAME = "InvalidParameterValue.RuleName"
INVALIDPARAMETERVALUE_TYPE = "InvalidParameterValue.Type"
OPERATIONDENIED_RESOURCEIMMUTABLE = "OperationDenied.ResourceImmutable"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"

func (*Client) UpdateTarget 

func (c *Client) UpdateTarget(request *UpdateTargetRequest) (response *UpdateTargetResponse, err error)

UpdateTarget This API is used to update a delivery target.

error code that may be returned: 

AUTHFAILURE = "AuthFailure"
INTERNALERROR = "InternalError"
INVALIDPARAMETERVALUE_BATCHTIMEOUT = "InvalidParameterValue.BatchTimeout"
INVALIDPARAMETERVALUE_CALLBACKWECOMURL = "InvalidParameterValue.CallbackWeComURL"
INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
INVALIDPARAMETERVALUE_NOTICERECEIVERCHANNEL = "InvalidParameterValue.NoticeReceiverChannel"
INVALIDPARAMETERVALUE_NOTICERECEIVERUSERIDS = "InvalidParameterValue.NoticeReceiverUserIds"
INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"
INVALIDPARAMETERVALUE_TARGETID = "InvalidParameterValue.TargetId"
OPERATIONDENIED_RESOURCEIMMUTABLE = "OperationDenied.ResourceImmutable"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule"
RESOURCENOTFOUND_TARGET = "ResourceNotFound.Target"

func (*Client) UpdateTargetWithContext 

func (c *Client) UpdateTargetWithContext(ctx context.Context, request *UpdateTargetRequest) (response *UpdateTargetResponse, err error)

UpdateTarget This API is used to update a delivery target.

error code that may be returned: 

AUTHFAILURE = "AuthFailure"
INTERNALERROR = "InternalError"
INVALIDPARAMETERVALUE_BATCHTIMEOUT = "InvalidParameterValue.BatchTimeout"
INVALIDPARAMETERVALUE_CALLBACKWECOMURL = "InvalidParameterValue.CallbackWeComURL"
INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
INVALIDPARAMETERVALUE_NOTICERECEIVERCHANNEL = "InvalidParameterValue.NoticeReceiverChannel"
INVALIDPARAMETERVALUE_NOTICERECEIVERUSERIDS = "InvalidParameterValue.NoticeReceiverUserIds"
INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"
INVALIDPARAMETERVALUE_TARGETID = "InvalidParameterValue.TargetId"
OPERATIONDENIED_RESOURCEIMMUTABLE = "OperationDenied.ResourceImmutable"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule"
RESOURCENOTFOUND_TARGET = "ResourceNotFound.Target"

func (*Client) UpdateTransformation 

func (c *Client) UpdateTransformation(request *UpdateTransformationRequest) (response *UpdateTransformationResponse, err error)

UpdateTransformation This API is used to update a transformer.

error code that may be returned: 

INVALIDPARAMETERVALUE_TRANSFORMATIONID = "InvalidParameterValue.TransformationID"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"

func (*Client) UpdateTransformationWithContext 

func (c *Client) UpdateTransformationWithContext(ctx context.Context, request *UpdateTransformationRequest) (response *UpdateTransformationResponse, err error)

UpdateTransformation This API is used to update a transformer.

error code that may be returned: 

INVALIDPARAMETERVALUE_TRANSFORMATIONID = "InvalidParameterValue.TransformationID"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"

type Connection 

type Connection struct {
	// Status
	Status *string `json:"Status,omitempty" name:"Status"`

	// Update time
	ModTime *string `json:"ModTime,omitempty" name:"ModTime"`

	// Switch
	Enable *bool `json:"Enable,omitempty" name:"Enable"`

	// Description
	Description *string `json:"Description,omitempty" name:"Description"`

	// Creation time
	AddTime *string `json:"AddTime,omitempty" name:"AddTime"`

	// Connector ID
	ConnectionId *string `json:"ConnectionId,omitempty" name:"ConnectionId"`

	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Connector description
	ConnectionDescription *ConnectionDescription `json:"ConnectionDescription,omitempty" name:"ConnectionDescription"`

	// Connector name
	ConnectionName *string `json:"ConnectionName,omitempty" name:"ConnectionName"`

	// Type
	Type *string `json:"Type,omitempty" name:"Type"`
}

type ConnectionDescription 

type ConnectionDescription struct {
	// Six-Segment QCS resource description. For more information, see [Resource Description Method](https://intl.cloud.tencent.com/document/product/598/10606?from_cn_redirect=1)
	ResourceDescription *string `json:"ResourceDescription,omitempty" name:"ResourceDescription"`

	// API Gateway parameters
	// Note: this field may return null, indicating that no valid values can be obtained.
	APIGWParams *APIGWParams `json:"APIGWParams,omitempty" name:"APIGWParams"`

	// CKafka parameters
	// Note: this field may return null, indicating that no valid values can be obtained.
	CkafkaParams *CkafkaParams `json:"CkafkaParams,omitempty" name:"CkafkaParams"`
}

type CreateConnectionRequest 

type CreateConnectionRequest struct {
	*tchttp.BaseRequest

	// Connector description
	ConnectionDescription *ConnectionDescription `json:"ConnectionDescription,omitempty" name:"ConnectionDescription"`

	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Connector name
	ConnectionName *string `json:"ConnectionName,omitempty" name:"ConnectionName"`

	// Description
	Description *string `json:"Description,omitempty" name:"Description"`

	// Whether to enable
	Enable *bool `json:"Enable,omitempty" name:"Enable"`

	// Type of the connector
	Type *string `json:"Type,omitempty" name:"Type"`
}

func NewCreateConnectionRequest 

func NewCreateConnectionRequest() (request *CreateConnectionRequest)

func (*CreateConnectionRequest) FromJsonString 

func (r *CreateConnectionRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateConnectionRequest) ToJsonString 

func (r *CreateConnectionRequest) ToJsonString() string

type CreateConnectionRequestParams 

type CreateConnectionRequestParams struct {
	// Connector description
	ConnectionDescription *ConnectionDescription `json:"ConnectionDescription,omitempty" name:"ConnectionDescription"`

	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Connector name
	ConnectionName *string `json:"ConnectionName,omitempty" name:"ConnectionName"`

	// Description
	Description *string `json:"Description,omitempty" name:"Description"`

	// Whether to enable
	Enable *bool `json:"Enable,omitempty" name:"Enable"`

	// Type of the connector
	Type *string `json:"Type,omitempty" name:"Type"`
}

Predefined struct for user

type CreateConnectionResponse 

type CreateConnectionResponse struct {
	*tchttp.BaseResponse
	Response *CreateConnectionResponseParams `json:"Response"`
}

func NewCreateConnectionResponse 

func NewCreateConnectionResponse() (response *CreateConnectionResponse)

func (*CreateConnectionResponse) FromJsonString 

func (r *CreateConnectionResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateConnectionResponse) ToJsonString 

func (r *CreateConnectionResponse) ToJsonString() string

type CreateConnectionResponseParams 

type CreateConnectionResponseParams struct {
	// Connector ID
	ConnectionId *string `json:"ConnectionId,omitempty" name:"ConnectionId"`

	// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type CreateEventBusRequest 

type CreateEventBusRequest struct {
	*tchttp.BaseRequest

	// Event bus name: it can contain 2-60 letters, digits, underscores, and hyphens and must start with a letter and end with a digit or letter.
	EventBusName *string `json:"EventBusName,omitempty" name:"EventBusName"`

	// Event bus description, which can contain up to 200 characters of any type.
	Description *string `json:"Description,omitempty" name:"Description"`
}

func NewCreateEventBusRequest 

func NewCreateEventBusRequest() (request *CreateEventBusRequest)

func (*CreateEventBusRequest) FromJsonString 

func (r *CreateEventBusRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateEventBusRequest) ToJsonString 

func (r *CreateEventBusRequest) ToJsonString() string

type CreateEventBusRequestParams 

type CreateEventBusRequestParams struct {
	// Event bus name: it can contain 2-60 letters, digits, underscores, and hyphens and must start with a letter and end with a digit or letter.
	EventBusName *string `json:"EventBusName,omitempty" name:"EventBusName"`

	// Event bus description, which can contain up to 200 characters of any type.
	Description *string `json:"Description,omitempty" name:"Description"`
}

Predefined struct for user

type CreateEventBusResponse 

type CreateEventBusResponse struct {
	*tchttp.BaseResponse
	Response *CreateEventBusResponseParams `json:"Response"`
}

func NewCreateEventBusResponse 

func NewCreateEventBusResponse() (response *CreateEventBusResponse)

func (*CreateEventBusResponse) FromJsonString 

func (r *CreateEventBusResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateEventBusResponse) ToJsonString 

func (r *CreateEventBusResponse) ToJsonString() string

type CreateEventBusResponseParams 

type CreateEventBusResponseParams struct {
	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type CreateRuleRequest 

type CreateRuleRequest struct {
	*tchttp.BaseRequest

	// See [Event Pattern](https://intl.cloud.tencent.com/document/product/1359/56084?from_cn_redirect=1)
	EventPattern *string `json:"EventPattern,omitempty" name:"EventPattern"`

	// Event bus ID.
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Event bus name, which can contain 2–60 letters, digits, underscores, and hyphens and must start with a letter and end with a digit or letter
	RuleName *string `json:"RuleName,omitempty" name:"RuleName"`

	// Switch.
	Enable *bool `json:"Enable,omitempty" name:"Enable"`

	// Event bus description, which can contain up to 200 characters of any type
	Description *string `json:"Description,omitempty" name:"Description"`
}

func NewCreateRuleRequest 

func NewCreateRuleRequest() (request *CreateRuleRequest)

func (*CreateRuleRequest) FromJsonString 

func (r *CreateRuleRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateRuleRequest) ToJsonString 

func (r *CreateRuleRequest) ToJsonString() string

type CreateRuleRequestParams 

type CreateRuleRequestParams struct {
	// See [Event Pattern](https://intl.cloud.tencent.com/document/product/1359/56084?from_cn_redirect=1)
	EventPattern *string `json:"EventPattern,omitempty" name:"EventPattern"`

	// Event bus ID.
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Event bus name, which can contain 2–60 letters, digits, underscores, and hyphens and must start with a letter and end with a digit or letter
	RuleName *string `json:"RuleName,omitempty" name:"RuleName"`

	// Switch.
	Enable *bool `json:"Enable,omitempty" name:"Enable"`

	// Event bus description, which can contain up to 200 characters of any type
	Description *string `json:"Description,omitempty" name:"Description"`
}

Predefined struct for user

type CreateRuleResponse 

type CreateRuleResponse struct {
	*tchttp.BaseResponse
	Response *CreateRuleResponseParams `json:"Response"`
}

func NewCreateRuleResponse 

func NewCreateRuleResponse() (response *CreateRuleResponse)

func (*CreateRuleResponse) FromJsonString 

func (r *CreateRuleResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateRuleResponse) ToJsonString 

func (r *CreateRuleResponse) ToJsonString() string

type CreateRuleResponseParams 

type CreateRuleResponseParams struct {
	// Event rule ID
	RuleId *string `json:"RuleId,omitempty" name:"RuleId"`

	// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type CreateTargetRequest 

type CreateTargetRequest struct {
	*tchttp.BaseRequest

	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Target type
	Type *string `json:"Type,omitempty" name:"Type"`

	// Target description
	TargetDescription *TargetDescription `json:"TargetDescription,omitempty" name:"TargetDescription"`

	// Event rule ID
	RuleId *string `json:"RuleId,omitempty" name:"RuleId"`
}

func NewCreateTargetRequest 

func NewCreateTargetRequest() (request *CreateTargetRequest)

func (*CreateTargetRequest) FromJsonString 

func (r *CreateTargetRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateTargetRequest) ToJsonString 

func (r *CreateTargetRequest) ToJsonString() string

type CreateTargetRequestParams 

type CreateTargetRequestParams struct {
	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Target type
	Type *string `json:"Type,omitempty" name:"Type"`

	// Target description
	TargetDescription *TargetDescription `json:"TargetDescription,omitempty" name:"TargetDescription"`

	// Event rule ID
	RuleId *string `json:"RuleId,omitempty" name:"RuleId"`
}

Predefined struct for user

type CreateTargetResponse 

type CreateTargetResponse struct {
	*tchttp.BaseResponse
	Response *CreateTargetResponseParams `json:"Response"`
}

func NewCreateTargetResponse 

func NewCreateTargetResponse() (response *CreateTargetResponse)

func (*CreateTargetResponse) FromJsonString 

func (r *CreateTargetResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateTargetResponse) ToJsonString 

func (r *CreateTargetResponse) ToJsonString() string

type CreateTargetResponseParams 

type CreateTargetResponseParams struct {
	// Target ID
	TargetId *string `json:"TargetId,omitempty" name:"TargetId"`

	// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type CreateTransformationRequest 

type CreateTransformationRequest struct {
	*tchttp.BaseRequest

	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Rule ID
	RuleId *string `json:"RuleId,omitempty" name:"RuleId"`

	// Transformation rule list (currently, only one is supported)
	Transformations []*Transformation `json:"Transformations,omitempty" name:"Transformations"`
}

func NewCreateTransformationRequest 

func NewCreateTransformationRequest() (request *CreateTransformationRequest)

func (*CreateTransformationRequest) FromJsonString 

func (r *CreateTransformationRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateTransformationRequest) ToJsonString 

func (r *CreateTransformationRequest) ToJsonString() string

type CreateTransformationRequestParams 

type CreateTransformationRequestParams struct {
	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Rule ID
	RuleId *string `json:"RuleId,omitempty" name:"RuleId"`

	// Transformation rule list (currently, only one is supported)
	Transformations []*Transformation `json:"Transformations,omitempty" name:"Transformations"`
}

Predefined struct for user

type CreateTransformationResponse 

type CreateTransformationResponse struct {
	*tchttp.BaseResponse
	Response *CreateTransformationResponseParams `json:"Response"`
}

func NewCreateTransformationResponse 

func NewCreateTransformationResponse() (response *CreateTransformationResponse)

func (*CreateTransformationResponse) FromJsonString 

func (r *CreateTransformationResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateTransformationResponse) ToJsonString 

func (r *CreateTransformationResponse) ToJsonString() string

type CreateTransformationResponseParams 

type CreateTransformationResponseParams struct {
	// Generated transformer ID
	TransformationId *string `json:"TransformationId,omitempty" name:"TransformationId"`

	// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type DeadLetterConfig 

type DeadLetterConfig struct {
	// Three modes are supported: DLQ, drop, and ignore error, which correspond to `DLQ`, `DROP`, and `IGNORE_ERROR` respectively
	DisposeMethod *string `json:"DisposeMethod,omitempty" name:"DisposeMethod"`

	// If the DLQ mode is set, this option is required. Error messages will be delivered to the corresponding Kafka topic
	// Note: this field may return null, indicating that no valid values can be obtained.
	CkafkaDeliveryParams *CkafkaDeliveryParams `json:"CkafkaDeliveryParams,omitempty" name:"CkafkaDeliveryParams"`
}

type DeleteConnectionRequest 

type DeleteConnectionRequest struct {
	*tchttp.BaseRequest

	// Connector ID
	ConnectionId *string `json:"ConnectionId,omitempty" name:"ConnectionId"`

	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`
}

func NewDeleteConnectionRequest 

func NewDeleteConnectionRequest() (request *DeleteConnectionRequest)

func (*DeleteConnectionRequest) FromJsonString 

func (r *DeleteConnectionRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteConnectionRequest) ToJsonString 

func (r *DeleteConnectionRequest) ToJsonString() string

type DeleteConnectionRequestParams 

type DeleteConnectionRequestParams struct {
	// Connector ID
	ConnectionId *string `json:"ConnectionId,omitempty" name:"ConnectionId"`

	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`
}

Predefined struct for user

type DeleteConnectionResponse 

type DeleteConnectionResponse struct {
	*tchttp.BaseResponse
	Response *DeleteConnectionResponseParams `json:"Response"`
}

func NewDeleteConnectionResponse 

func NewDeleteConnectionResponse() (response *DeleteConnectionResponse)

func (*DeleteConnectionResponse) FromJsonString 

func (r *DeleteConnectionResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteConnectionResponse) ToJsonString 

func (r *DeleteConnectionResponse) ToJsonString() string

type DeleteConnectionResponseParams 

type DeleteConnectionResponseParams struct {
	// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type DeleteEventBusRequest 

type DeleteEventBusRequest struct {
	*tchttp.BaseRequest

	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`
}

func NewDeleteEventBusRequest 

func NewDeleteEventBusRequest() (request *DeleteEventBusRequest)

func (*DeleteEventBusRequest) FromJsonString 

func (r *DeleteEventBusRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteEventBusRequest) ToJsonString 

func (r *DeleteEventBusRequest) ToJsonString() string

type DeleteEventBusRequestParams 

type DeleteEventBusRequestParams struct {
	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`
}

Predefined struct for user

type DeleteEventBusResponse 

type DeleteEventBusResponse struct {
	*tchttp.BaseResponse
	Response *DeleteEventBusResponseParams `json:"Response"`
}

func NewDeleteEventBusResponse 

func NewDeleteEventBusResponse() (response *DeleteEventBusResponse)

func (*DeleteEventBusResponse) FromJsonString 

func (r *DeleteEventBusResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteEventBusResponse) ToJsonString 

func (r *DeleteEventBusResponse) ToJsonString() string

type DeleteEventBusResponseParams 

type DeleteEventBusResponseParams struct {
	// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type DeleteRuleRequest 

type DeleteRuleRequest struct {
	*tchttp.BaseRequest

	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Event rule ID
	RuleId *string `json:"RuleId,omitempty" name:"RuleId"`
}

func NewDeleteRuleRequest 

func NewDeleteRuleRequest() (request *DeleteRuleRequest)

func (*DeleteRuleRequest) FromJsonString 

func (r *DeleteRuleRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteRuleRequest) ToJsonString 

func (r *DeleteRuleRequest) ToJsonString() string

type DeleteRuleRequestParams 

type DeleteRuleRequestParams struct {
	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Event rule ID
	RuleId *string `json:"RuleId,omitempty" name:"RuleId"`
}

Predefined struct for user

type DeleteRuleResponse 

type DeleteRuleResponse struct {
	*tchttp.BaseResponse
	Response *DeleteRuleResponseParams `json:"Response"`
}

func NewDeleteRuleResponse 

func NewDeleteRuleResponse() (response *DeleteRuleResponse)

func (*DeleteRuleResponse) FromJsonString 

func (r *DeleteRuleResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteRuleResponse) ToJsonString 

func (r *DeleteRuleResponse) ToJsonString() string

type DeleteRuleResponseParams 

type DeleteRuleResponseParams struct {
	// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type DeleteTargetRequest 

type DeleteTargetRequest struct {
	*tchttp.BaseRequest

	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Delivery target ID
	TargetId *string `json:"TargetId,omitempty" name:"TargetId"`

	// Event rule ID
	RuleId *string `json:"RuleId,omitempty" name:"RuleId"`
}

func NewDeleteTargetRequest 

func NewDeleteTargetRequest() (request *DeleteTargetRequest)

func (*DeleteTargetRequest) FromJsonString 

func (r *DeleteTargetRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteTargetRequest) ToJsonString 

func (r *DeleteTargetRequest) ToJsonString() string

type DeleteTargetRequestParams 

type DeleteTargetRequestParams struct {
	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Delivery target ID
	TargetId *string `json:"TargetId,omitempty" name:"TargetId"`

	// Event rule ID
	RuleId *string `json:"RuleId,omitempty" name:"RuleId"`
}

Predefined struct for user

type DeleteTargetResponse 

type DeleteTargetResponse struct {
	*tchttp.BaseResponse
	Response *DeleteTargetResponseParams `json:"Response"`
}

func NewDeleteTargetResponse 

func NewDeleteTargetResponse() (response *DeleteTargetResponse)

func (*DeleteTargetResponse) FromJsonString 

func (r *DeleteTargetResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteTargetResponse) ToJsonString 

func (r *DeleteTargetResponse) ToJsonString() string

type DeleteTargetResponseParams 

type DeleteTargetResponseParams struct {
	// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type DeleteTransformationRequest 

type DeleteTransformationRequest struct {
	*tchttp.BaseRequest

	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Rule ID
	RuleId *string `json:"RuleId,omitempty" name:"RuleId"`

	// Transformer ID
	TransformationId *string `json:"TransformationId,omitempty" name:"TransformationId"`
}

func NewDeleteTransformationRequest 

func NewDeleteTransformationRequest() (request *DeleteTransformationRequest)

func (*DeleteTransformationRequest) FromJsonString 

func (r *DeleteTransformationRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteTransformationRequest) ToJsonString 

func (r *DeleteTransformationRequest) ToJsonString() string

type DeleteTransformationRequestParams 

type DeleteTransformationRequestParams struct {
	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Rule ID
	RuleId *string `json:"RuleId,omitempty" name:"RuleId"`

	// Transformer ID
	TransformationId *string `json:"TransformationId,omitempty" name:"TransformationId"`
}

Predefined struct for user

type DeleteTransformationResponse 

type DeleteTransformationResponse struct {
	*tchttp.BaseResponse
	Response *DeleteTransformationResponseParams `json:"Response"`
}

func NewDeleteTransformationResponse 

func NewDeleteTransformationResponse() (response *DeleteTransformationResponse)

func (*DeleteTransformationResponse) FromJsonString 

func (r *DeleteTransformationResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteTransformationResponse) ToJsonString 

func (r *DeleteTransformationResponse) ToJsonString() string

type DeleteTransformationResponseParams 

type DeleteTransformationResponseParams struct {
	// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type ESTargetParams 

type ESTargetParams struct {
	// Network connection type
	NetMode *string `json:"NetMode,omitempty" name:"NetMode"`

	// Index prefix
	IndexPrefix *string `json:"IndexPrefix,omitempty" name:"IndexPrefix"`

	// ES log rotation interval
	RotationInterval *string `json:"RotationInterval,omitempty" name:"RotationInterval"`

	// DTS event configuration
	OutputMode *string `json:"OutputMode,omitempty" name:"OutputMode"`

	// DTS indexing configuration
	IndexSuffixMode *string `json:"IndexSuffixMode,omitempty" name:"IndexSuffixMode"`

	// ES template type
	IndexTemplateType *string `json:"IndexTemplateType,omitempty" name:"IndexTemplateType"`
}

type EtlFilter 

type EtlFilter struct {
	// The syntax is the same as that of `Rule`
	Filter *string `json:"Filter,omitempty" name:"Filter"`
}

type EventBus 

type EventBus struct {
	// Update time
	ModTime *string `json:"ModTime,omitempty" name:"ModTime"`

	// Event bus description, which can contain up to 200 characters of any type
	Description *string `json:"Description,omitempty" name:"Description"`

	// Creation time
	AddTime *string `json:"AddTime,omitempty" name:"AddTime"`

	// Event bus name, which can contain 2–60 letters, digits, underscores, and hyphens and must start with a letter and end with a digit or letter
	EventBusName *string `json:"EventBusName,omitempty" name:"EventBusName"`

	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Event bus type
	Type *string `json:"Type,omitempty" name:"Type"`
}

type Extraction 

type Extraction struct {
	// JsonPath, which will be `$.` by default if not specified
	ExtractionInputPath *string `json:"ExtractionInputPath,omitempty" name:"ExtractionInputPath"`

	// Valid values: TEXT/JSON
	Format *string `json:"Format,omitempty" name:"Format"`

	// Only required for `Text`
	// Note: this field may return null, indicating that no valid values can be obtained.
	TextParams *TextParams `json:"TextParams,omitempty" name:"TextParams"`
}

type Filter 

type Filter struct {
	// One or more filter values.
	Values []*string `json:"Values,omitempty" name:"Values"`

	// Filter name.
	Name *string `json:"Name,omitempty" name:"Name"`
}

type GetEventBusRequest 

type GetEventBusRequest struct {
	*tchttp.BaseRequest

	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`
}

func NewGetEventBusRequest 

func NewGetEventBusRequest() (request *GetEventBusRequest)

func (*GetEventBusRequest) FromJsonString 

func (r *GetEventBusRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*GetEventBusRequest) ToJsonString 

func (r *GetEventBusRequest) ToJsonString() string

type GetEventBusRequestParams 

type GetEventBusRequestParams struct {
	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`
}

Predefined struct for user

type GetEventBusResponse 

type GetEventBusResponse struct {
	*tchttp.BaseResponse
	Response *GetEventBusResponseParams `json:"Response"`
}

func NewGetEventBusResponse 

func NewGetEventBusResponse() (response *GetEventBusResponse)

func (*GetEventBusResponse) FromJsonString 

func (r *GetEventBusResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*GetEventBusResponse) ToJsonString 

func (r *GetEventBusResponse) ToJsonString() string

type GetEventBusResponseParams 

type GetEventBusResponseParams struct {
	// Update time
	ModTime *string `json:"ModTime,omitempty" name:"ModTime"`

	// Event bus description
	Description *string `json:"Description,omitempty" name:"Description"`

	// Log topic ID
	ClsTopicId *string `json:"ClsTopicId,omitempty" name:"ClsTopicId"`

	// Creation time.
	AddTime *string `json:"AddTime,omitempty" name:"AddTime"`

	// Logset ID
	ClsLogsetId *string `json:"ClsLogsetId,omitempty" name:"ClsLogsetId"`

	// Event bus name
	EventBusName *string `json:"EventBusName,omitempty" name:"EventBusName"`

	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// (Disused) Event bus type
	Type *string `json:"Type,omitempty" name:"Type"`

	// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type GetRuleRequest 

type GetRuleRequest struct {
	*tchttp.BaseRequest

	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Event rule ID
	RuleId *string `json:"RuleId,omitempty" name:"RuleId"`
}

func NewGetRuleRequest 

func NewGetRuleRequest() (request *GetRuleRequest)

func (*GetRuleRequest) FromJsonString 

func (r *GetRuleRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*GetRuleRequest) ToJsonString 

func (r *GetRuleRequest) ToJsonString() string

type GetRuleRequestParams 

type GetRuleRequestParams struct {
	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Event rule ID
	RuleId *string `json:"RuleId,omitempty" name:"RuleId"`
}

Predefined struct for user

type GetRuleResponse 

type GetRuleResponse struct {
	*tchttp.BaseResponse
	Response *GetRuleResponseParams `json:"Response"`
}

func NewGetRuleResponse 

func NewGetRuleResponse() (response *GetRuleResponse)

func (*GetRuleResponse) FromJsonString 

func (r *GetRuleResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*GetRuleResponse) ToJsonString 

func (r *GetRuleResponse) ToJsonString() string

type GetRuleResponseParams 

type GetRuleResponseParams struct {
	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Event rule ID
	RuleId *string `json:"RuleId,omitempty" name:"RuleId"`

	// Event rule name
	RuleName *string `json:"RuleName,omitempty" name:"RuleName"`

	// Event rule status
	Status *string `json:"Status,omitempty" name:"Status"`

	// Switch
	Enable *bool `json:"Enable,omitempty" name:"Enable"`

	// Event rule description
	Description *string `json:"Description,omitempty" name:"Description"`

	// Event pattern
	EventPattern *string `json:"EventPattern,omitempty" name:"EventPattern"`

	// Creation time
	AddTime *string `json:"AddTime,omitempty" name:"AddTime"`

	// Update time
	ModTime *string `json:"ModTime,omitempty" name:"ModTime"`

	// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type GetTransformationRequest 

type GetTransformationRequest struct {
	*tchttp.BaseRequest

	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Rule ID
	RuleId *string `json:"RuleId,omitempty" name:"RuleId"`

	// Transformer ID
	TransformationId *string `json:"TransformationId,omitempty" name:"TransformationId"`
}

func NewGetTransformationRequest 

func NewGetTransformationRequest() (request *GetTransformationRequest)

func (*GetTransformationRequest) FromJsonString 

func (r *GetTransformationRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*GetTransformationRequest) ToJsonString 

func (r *GetTransformationRequest) ToJsonString() string

type GetTransformationRequestParams 

type GetTransformationRequestParams struct {
	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Rule ID
	RuleId *string `json:"RuleId,omitempty" name:"RuleId"`

	// Transformer ID
	TransformationId *string `json:"TransformationId,omitempty" name:"TransformationId"`
}

Predefined struct for user

type GetTransformationResponse 

type GetTransformationResponse struct {
	*tchttp.BaseResponse
	Response *GetTransformationResponseParams `json:"Response"`
}

func NewGetTransformationResponse 

func NewGetTransformationResponse() (response *GetTransformationResponse)

func (*GetTransformationResponse) FromJsonString 

func (r *GetTransformationResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*GetTransformationResponse) ToJsonString 

func (r *GetTransformationResponse) ToJsonString() string

type GetTransformationResponseParams 

type GetTransformationResponseParams struct {
	// Transformation rule list
	Transformations []*Transformation `json:"Transformations,omitempty" name:"Transformations"`

	// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type ListConnectionsRequest 

type ListConnectionsRequest struct {
	*tchttp.BaseRequest

	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Indicates by which field to sort the returned results. Valid values: AddTime, ModTime
	OrderBy *string `json:"OrderBy,omitempty" name:"OrderBy"`

	// Number of returned results. Default value: 20. Maximum value: 100.
	Limit *int64 `json:"Limit,omitempty" name:"Limit"`

	// Indicates whether the returned results are sorted in ascending or descending order. Valid values: ASC, DESC
	Order *string `json:"Order,omitempty" name:"Order"`

	// Offset. Default value: 0.
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`
}

func NewListConnectionsRequest 

func NewListConnectionsRequest() (request *ListConnectionsRequest)

func (*ListConnectionsRequest) FromJsonString 

func (r *ListConnectionsRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ListConnectionsRequest) ToJsonString 

func (r *ListConnectionsRequest) ToJsonString() string

type ListConnectionsRequestParams 

type ListConnectionsRequestParams struct {
	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Indicates by which field to sort the returned results. Valid values: AddTime, ModTime
	OrderBy *string `json:"OrderBy,omitempty" name:"OrderBy"`

	// Number of returned results. Default value: 20. Maximum value: 100.
	Limit *int64 `json:"Limit,omitempty" name:"Limit"`

	// Indicates whether the returned results are sorted in ascending or descending order. Valid values: ASC, DESC
	Order *string `json:"Order,omitempty" name:"Order"`

	// Offset. Default value: 0.
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`
}

Predefined struct for user

type ListConnectionsResponse 

type ListConnectionsResponse struct {
	*tchttp.BaseResponse
	Response *ListConnectionsResponseParams `json:"Response"`
}

func NewListConnectionsResponse 

func NewListConnectionsResponse() (response *ListConnectionsResponse)

func (*ListConnectionsResponse) FromJsonString 

func (r *ListConnectionsResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ListConnectionsResponse) ToJsonString 

func (r *ListConnectionsResponse) ToJsonString() string

type ListConnectionsResponseParams 

type ListConnectionsResponseParams struct {
	// Connector information
	Connections []*Connection `json:"Connections,omitempty" name:"Connections"`

	// Total number of connectors
	TotalCount *int64 `json:"TotalCount,omitempty" name:"TotalCount"`

	// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type ListEventBusesRequest 

type ListEventBusesRequest struct {
	*tchttp.BaseRequest

	// Indicates by which field to sort the returned results. Valid values: AddTime (creation time), ModTime (modification time)
	OrderBy *string `json:"OrderBy,omitempty" name:"OrderBy"`

	// Number of returned results. Default value: 20. Maximum value: 100.
	Limit *int64 `json:"Limit,omitempty" name:"Limit"`

	// Indicates whether the returned results are sorted in ascending or descending order. Valid values: ASC (ascending order), DESC (descending order)
	Order *string `json:"Order,omitempty" name:"Order"`

	// Filter. For more information, see the Instance Filter Table below. Each request can contain up to 10 `Filters` and 5 `Filter.Values`.
	Filters []*Filter `json:"Filters,omitempty" name:"Filters"`

	// Pagination offset. Default value: 0.
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`
}

func NewListEventBusesRequest 

func NewListEventBusesRequest() (request *ListEventBusesRequest)

func (*ListEventBusesRequest) FromJsonString 

func (r *ListEventBusesRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ListEventBusesRequest) ToJsonString 

func (r *ListEventBusesRequest) ToJsonString() string

type ListEventBusesRequestParams 

type ListEventBusesRequestParams struct {
	// Indicates by which field to sort the returned results. Valid values: AddTime (creation time), ModTime (modification time)
	OrderBy *string `json:"OrderBy,omitempty" name:"OrderBy"`

	// Number of returned results. Default value: 20. Maximum value: 100.
	Limit *int64 `json:"Limit,omitempty" name:"Limit"`

	// Indicates whether the returned results are sorted in ascending or descending order. Valid values: ASC (ascending order), DESC (descending order)
	Order *string `json:"Order,omitempty" name:"Order"`

	// Filter. For more information, see the Instance Filter Table below. Each request can contain up to 10 `Filters` and 5 `Filter.Values`.
	Filters []*Filter `json:"Filters,omitempty" name:"Filters"`

	// Pagination offset. Default value: 0.
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`
}

Predefined struct for user

type ListEventBusesResponse 

type ListEventBusesResponse struct {
	*tchttp.BaseResponse
	Response *ListEventBusesResponseParams `json:"Response"`
}

func NewListEventBusesResponse 

func NewListEventBusesResponse() (response *ListEventBusesResponse)

func (*ListEventBusesResponse) FromJsonString 

func (r *ListEventBusesResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ListEventBusesResponse) ToJsonString 

func (r *ListEventBusesResponse) ToJsonString() string

type ListEventBusesResponseParams 

type ListEventBusesResponseParams struct {
	// Event bus information
	EventBuses []*EventBus `json:"EventBuses,omitempty" name:"EventBuses"`

	// Total number of event buses
	TotalCount *int64 `json:"TotalCount,omitempty" name:"TotalCount"`

	// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type ListRulesRequest 

type ListRulesRequest struct {
	*tchttp.BaseRequest

	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Indicates by which field to sort the returned results. Valid values: AddTime (creation time), ModTime (modification time)
	OrderBy *string `json:"OrderBy,omitempty" name:"OrderBy"`

	// Number of returned results. Default value: 20. Maximum value: 100.
	Limit *int64 `json:"Limit,omitempty" name:"Limit"`

	// Pagination offset. Default value: 0.
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`

	// Indicates whether the returned results are sorted in ascending or descending order. Valid values: ASC (ascending order), DESC (descending order)
	Order *string `json:"Order,omitempty" name:"Order"`
}

func NewListRulesRequest 

func NewListRulesRequest() (request *ListRulesRequest)

func (*ListRulesRequest) FromJsonString 

func (r *ListRulesRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ListRulesRequest) ToJsonString 

func (r *ListRulesRequest) ToJsonString() string

type ListRulesRequestParams 

type ListRulesRequestParams struct {
	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Indicates by which field to sort the returned results. Valid values: AddTime (creation time), ModTime (modification time)
	OrderBy *string `json:"OrderBy,omitempty" name:"OrderBy"`

	// Number of returned results. Default value: 20. Maximum value: 100.
	Limit *int64 `json:"Limit,omitempty" name:"Limit"`

	// Pagination offset. Default value: 0.
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`

	// Indicates whether the returned results are sorted in ascending or descending order. Valid values: ASC (ascending order), DESC (descending order)
	Order *string `json:"Order,omitempty" name:"Order"`
}

Predefined struct for user

type ListRulesResponse 

type ListRulesResponse struct {
	*tchttp.BaseResponse
	Response *ListRulesResponseParams `json:"Response"`
}

func NewListRulesResponse 

func NewListRulesResponse() (response *ListRulesResponse)

func (*ListRulesResponse) FromJsonString 

func (r *ListRulesResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ListRulesResponse) ToJsonString 

func (r *ListRulesResponse) ToJsonString() string

type ListRulesResponseParams 

type ListRulesResponseParams struct {
	// Event rule information
	Rules []*Rule `json:"Rules,omitempty" name:"Rules"`

	// Total number of event rules
	TotalCount *int64 `json:"TotalCount,omitempty" name:"TotalCount"`

	// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type ListTargetsRequest 

type ListTargetsRequest struct {
	*tchttp.BaseRequest

	// Event rule ID
	RuleId *string `json:"RuleId,omitempty" name:"RuleId"`

	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Indicates by which field to sort the returned results. Valid values: AddTime (creation time), ModTime (modification time)
	OrderBy *string `json:"OrderBy,omitempty" name:"OrderBy"`

	// Number of returned results. Default value: 20. Maximum value: 100.
	Limit *int64 `json:"Limit,omitempty" name:"Limit"`

	// Pagination offset. Default value: 0.
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`

	// Indicates whether the returned results are sorted in ascending or descending order. Valid values: ASC (ascending order), DESC (descending order)
	Order *string `json:"Order,omitempty" name:"Order"`
}

func NewListTargetsRequest 

func NewListTargetsRequest() (request *ListTargetsRequest)

func (*ListTargetsRequest) FromJsonString 

func (r *ListTargetsRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ListTargetsRequest) ToJsonString 

func (r *ListTargetsRequest) ToJsonString() string

type ListTargetsRequestParams 

type ListTargetsRequestParams struct {
	// Event rule ID
	RuleId *string `json:"RuleId,omitempty" name:"RuleId"`

	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Indicates by which field to sort the returned results. Valid values: AddTime (creation time), ModTime (modification time)
	OrderBy *string `json:"OrderBy,omitempty" name:"OrderBy"`

	// Number of returned results. Default value: 20. Maximum value: 100.
	Limit *int64 `json:"Limit,omitempty" name:"Limit"`

	// Pagination offset. Default value: 0.
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`

	// Indicates whether the returned results are sorted in ascending or descending order. Valid values: ASC (ascending order), DESC (descending order)
	Order *string `json:"Order,omitempty" name:"Order"`
}

Predefined struct for user

type ListTargetsResponse 

type ListTargetsResponse struct {
	*tchttp.BaseResponse
	Response *ListTargetsResponseParams `json:"Response"`
}

func NewListTargetsResponse 

func NewListTargetsResponse() (response *ListTargetsResponse)

func (*ListTargetsResponse) FromJsonString 

func (r *ListTargetsResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ListTargetsResponse) ToJsonString 

func (r *ListTargetsResponse) ToJsonString() string

type ListTargetsResponseParams 

type ListTargetsResponseParams struct {
	// Total number of targets
	TotalCount *int64 `json:"TotalCount,omitempty" name:"TotalCount"`

	// Target information
	Targets []*Target `json:"Targets,omitempty" name:"Targets"`

	// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type OutputStructParam 

type OutputStructParam struct {
	// Key in the corresponding JSON output
	Key *string `json:"Key,omitempty" name:"Key"`

	// You can enter a JsonPath, constant, or built-in date type
	Value *string `json:"Value,omitempty" name:"Value"`

	// Data type of `Value`. Valid values: STRING, NUMBER, BOOLEAN, NULL, SYS_VARIABLE, JSONPATH
	ValueType *string `json:"ValueType,omitempty" name:"ValueType"`
}

type RetryPolicy 

type RetryPolicy struct {
	// Retry interval in seconds
	RetryInterval *uint64 `json:"RetryInterval,omitempty" name:"RetryInterval"`

	// Maximum number of retries
	MaxRetryAttempts *uint64 `json:"MaxRetryAttempts,omitempty" name:"MaxRetryAttempts"`
}

type Rule 

type Rule struct {
	// Status
	Status *string `json:"Status,omitempty" name:"Status"`

	// Modification time
	ModTime *string `json:"ModTime,omitempty" name:"ModTime"`

	// Switch
	Enable *bool `json:"Enable,omitempty" name:"Enable"`

	// Description
	Description *string `json:"Description,omitempty" name:"Description"`

	// Rule ID
	RuleId *string `json:"RuleId,omitempty" name:"RuleId"`

	// Creation time
	AddTime *string `json:"AddTime,omitempty" name:"AddTime"`

	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Rule name
	RuleName *string `json:"RuleName,omitempty" name:"RuleName"`

	// Target overview
	// Note: this field may return null, indicating that no valid values can be obtained.
	Targets []*TargetBrief `json:"Targets,omitempty" name:"Targets"`

	// DLQ rule set by the rule, which may be null
	// Note: this field may return null, indicating that no valid values can be obtained.
	DeadLetterConfig *DeadLetterConfig `json:"DeadLetterConfig,omitempty" name:"DeadLetterConfig"`
}

type SCFParams 

type SCFParams struct {
	// Maximum waiting time for batch delivery
	BatchTimeout *int64 `json:"BatchTimeout,omitempty" name:"BatchTimeout"`

	// Maximum number of events in batch delivery
	BatchEventCount *int64 `json:"BatchEventCount,omitempty" name:"BatchEventCount"`

	// Enables batch delivery
	EnableBatchDelivery *bool `json:"EnableBatchDelivery,omitempty" name:"EnableBatchDelivery"`
}

type Target 

type Target struct {
	// Target type
	Type *string `json:"Type,omitempty" name:"Type"`

	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Target ID
	TargetId *string `json:"TargetId,omitempty" name:"TargetId"`

	// Target description
	TargetDescription *TargetDescription `json:"TargetDescription,omitempty" name:"TargetDescription"`

	// Event rule ID
	RuleId *string `json:"RuleId,omitempty" name:"RuleId"`

	// Enables batch delivery
	// Note: this field may return null, indicating that no valid values can be obtained.
	EnableBatchDelivery *bool `json:"EnableBatchDelivery,omitempty" name:"EnableBatchDelivery"`

	// Maximum waiting time for batch delivery
	// Note: this field may return null, indicating that no valid values can be obtained.
	BatchTimeout *int64 `json:"BatchTimeout,omitempty" name:"BatchTimeout"`

	// Maximum number of events in batch delivery
	// Note: this field may return null, indicating that no valid values can be obtained.
	BatchEventCount *int64 `json:"BatchEventCount,omitempty" name:"BatchEventCount"`
}

type TargetBrief 

type TargetBrief struct {
	// Target ID
	TargetId *string `json:"TargetId,omitempty" name:"TargetId"`

	// Target type
	Type *string `json:"Type,omitempty" name:"Type"`
}

type TargetDescription 

type TargetDescription struct {
	// Six-Segment QCS resource description. For more information, see [Resource Description Method](https://intl.cloud.tencent.com/document/product/598/10606?from_cn_redirect=1)
	ResourceDescription *string `json:"ResourceDescription,omitempty" name:"ResourceDescription"`

	// SCF parameter
	SCFParams *SCFParams `json:"SCFParams,omitempty" name:"SCFParams"`

	// CKafka parameters
	CkafkaTargetParams *CkafkaTargetParams `json:"CkafkaTargetParams,omitempty" name:"CkafkaTargetParams"`

	// ElasticSearch parameters
	ESTargetParams *ESTargetParams `json:"ESTargetParams,omitempty" name:"ESTargetParams"`
}

type TextParams 

type TextParams struct {
	// Comma, | , tab, space, line break, %, or #, which can contain only 1 character.
	// Note: this field may return null, indicating that no valid values can be obtained.
	Separator *string `json:"Separator,omitempty" name:"Separator"`

	// Entered regex (128 characters)
	// Note: this field may return null, indicating that no valid values can be obtained.
	Regex *string `json:"Regex,omitempty" name:"Regex"`
}

type Transform 

type Transform struct {
	// Describes how to transform data
	OutputStructs []*OutputStructParam `json:"OutputStructs,omitempty" name:"OutputStructs"`
}

type Transformation 

type Transformation struct {
	// Describes how to extract data
	// Note: this field may return null, indicating that no valid values can be obtained.
	Extraction *Extraction `json:"Extraction,omitempty" name:"Extraction"`

	// Describes how to filter data
	// Note: this field may return null, indicating that no valid values can be obtained.
	EtlFilter *EtlFilter `json:"EtlFilter,omitempty" name:"EtlFilter"`

	// Describes how to transform data
	// Note: this field may return null, indicating that no valid values can be obtained.
	Transform *Transform `json:"Transform,omitempty" name:"Transform"`
}

type UpdateConnectionRequest 

type UpdateConnectionRequest struct {
	*tchttp.BaseRequest

	// Connector ID
	ConnectionId *string `json:"ConnectionId,omitempty" name:"ConnectionId"`

	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Switch
	Enable *bool `json:"Enable,omitempty" name:"Enable"`

	// Description
	Description *string `json:"Description,omitempty" name:"Description"`

	// Connector name
	ConnectionName *string `json:"ConnectionName,omitempty" name:"ConnectionName"`
}

func NewUpdateConnectionRequest 

func NewUpdateConnectionRequest() (request *UpdateConnectionRequest)

func (*UpdateConnectionRequest) FromJsonString 

func (r *UpdateConnectionRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*UpdateConnectionRequest) ToJsonString 

func (r *UpdateConnectionRequest) ToJsonString() string

type UpdateConnectionRequestParams 

type UpdateConnectionRequestParams struct {
	// Connector ID
	ConnectionId *string `json:"ConnectionId,omitempty" name:"ConnectionId"`

	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Switch
	Enable *bool `json:"Enable,omitempty" name:"Enable"`

	// Description
	Description *string `json:"Description,omitempty" name:"Description"`

	// Connector name
	ConnectionName *string `json:"ConnectionName,omitempty" name:"ConnectionName"`
}

Predefined struct for user

type UpdateConnectionResponse 

type UpdateConnectionResponse struct {
	*tchttp.BaseResponse
	Response *UpdateConnectionResponseParams `json:"Response"`
}

func NewUpdateConnectionResponse 

func NewUpdateConnectionResponse() (response *UpdateConnectionResponse)

func (*UpdateConnectionResponse) FromJsonString 

func (r *UpdateConnectionResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*UpdateConnectionResponse) ToJsonString 

func (r *UpdateConnectionResponse) ToJsonString() string

type UpdateConnectionResponseParams 

type UpdateConnectionResponseParams struct {
	// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type UpdateEventBusRequest 

type UpdateEventBusRequest struct {
	*tchttp.BaseRequest

	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Event bus description, which can contain up to 200 characters of any type.
	Description *string `json:"Description,omitempty" name:"Description"`

	// Event bus name: it can contain 2-60 letters, digits, underscores, and hyphens and must start with a letter and end with a digit or letter.
	EventBusName *string `json:"EventBusName,omitempty" name:"EventBusName"`
}

func NewUpdateEventBusRequest 

func NewUpdateEventBusRequest() (request *UpdateEventBusRequest)

func (*UpdateEventBusRequest) FromJsonString 

func (r *UpdateEventBusRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*UpdateEventBusRequest) ToJsonString 

func (r *UpdateEventBusRequest) ToJsonString() string

type UpdateEventBusRequestParams 

type UpdateEventBusRequestParams struct {
	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Event bus description, which can contain up to 200 characters of any type.
	Description *string `json:"Description,omitempty" name:"Description"`

	// Event bus name: it can contain 2-60 letters, digits, underscores, and hyphens and must start with a letter and end with a digit or letter.
	EventBusName *string `json:"EventBusName,omitempty" name:"EventBusName"`
}

Predefined struct for user

type UpdateEventBusResponse 

type UpdateEventBusResponse struct {
	*tchttp.BaseResponse
	Response *UpdateEventBusResponseParams `json:"Response"`
}

func NewUpdateEventBusResponse 

func NewUpdateEventBusResponse() (response *UpdateEventBusResponse)

func (*UpdateEventBusResponse) FromJsonString 

func (r *UpdateEventBusResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*UpdateEventBusResponse) ToJsonString 

func (r *UpdateEventBusResponse) ToJsonString() string

type UpdateEventBusResponseParams 

type UpdateEventBusResponseParams struct {
	// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type UpdateRuleRequest 

type UpdateRuleRequest struct {
	*tchttp.BaseRequest

	// Event rule ID
	RuleId *string `json:"RuleId,omitempty" name:"RuleId"`

	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Switch.
	Enable *bool `json:"Enable,omitempty" name:"Enable"`

	// Rule description, which can contain up to 200 characters of any type.
	Description *string `json:"Description,omitempty" name:"Description"`

	// Event rule name, which can contain 2–60 letters, digits, underscores, and hyphens and must start with a letter and end with a digit or letter
	RuleName *string `json:"RuleName,omitempty" name:"RuleName"`
}

func NewUpdateRuleRequest 

func NewUpdateRuleRequest() (request *UpdateRuleRequest)

func (*UpdateRuleRequest) FromJsonString 

func (r *UpdateRuleRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*UpdateRuleRequest) ToJsonString 

func (r *UpdateRuleRequest) ToJsonString() string

type UpdateRuleRequestParams 

type UpdateRuleRequestParams struct {
	// Event rule ID
	RuleId *string `json:"RuleId,omitempty" name:"RuleId"`

	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Switch.
	Enable *bool `json:"Enable,omitempty" name:"Enable"`

	// Rule description, which can contain up to 200 characters of any type.
	Description *string `json:"Description,omitempty" name:"Description"`

	// Event rule name, which can contain 2–60 letters, digits, underscores, and hyphens and must start with a letter and end with a digit or letter
	RuleName *string `json:"RuleName,omitempty" name:"RuleName"`
}

Predefined struct for user

type UpdateRuleResponse 

type UpdateRuleResponse struct {
	*tchttp.BaseResponse
	Response *UpdateRuleResponseParams `json:"Response"`
}

func NewUpdateRuleResponse 

func NewUpdateRuleResponse() (response *UpdateRuleResponse)

func (*UpdateRuleResponse) FromJsonString 

func (r *UpdateRuleResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*UpdateRuleResponse) ToJsonString 

func (r *UpdateRuleResponse) ToJsonString() string

type UpdateRuleResponseParams 

type UpdateRuleResponseParams struct {
	// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type UpdateTargetRequest 

type UpdateTargetRequest struct {
	*tchttp.BaseRequest

	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Event rule ID
	RuleId *string `json:"RuleId,omitempty" name:"RuleId"`

	// Delivery target ID
	TargetId *string `json:"TargetId,omitempty" name:"TargetId"`

	// Enables batch delivery
	EnableBatchDelivery *bool `json:"EnableBatchDelivery,omitempty" name:"EnableBatchDelivery"`

	// Maximum waiting time for batch delivery
	BatchTimeout *int64 `json:"BatchTimeout,omitempty" name:"BatchTimeout"`

	// Maximum number of events in batch delivery
	BatchEventCount *int64 `json:"BatchEventCount,omitempty" name:"BatchEventCount"`
}

func NewUpdateTargetRequest 

func NewUpdateTargetRequest() (request *UpdateTargetRequest)

func (*UpdateTargetRequest) FromJsonString 

func (r *UpdateTargetRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*UpdateTargetRequest) ToJsonString 

func (r *UpdateTargetRequest) ToJsonString() string

type UpdateTargetRequestParams 

type UpdateTargetRequestParams struct {
	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Event rule ID
	RuleId *string `json:"RuleId,omitempty" name:"RuleId"`

	// Delivery target ID
	TargetId *string `json:"TargetId,omitempty" name:"TargetId"`

	// Enables batch delivery
	EnableBatchDelivery *bool `json:"EnableBatchDelivery,omitempty" name:"EnableBatchDelivery"`

	// Maximum waiting time for batch delivery
	BatchTimeout *int64 `json:"BatchTimeout,omitempty" name:"BatchTimeout"`

	// Maximum number of events in batch delivery
	BatchEventCount *int64 `json:"BatchEventCount,omitempty" name:"BatchEventCount"`
}

Predefined struct for user

type UpdateTargetResponse 

type UpdateTargetResponse struct {
	*tchttp.BaseResponse
	Response *UpdateTargetResponseParams `json:"Response"`
}

func NewUpdateTargetResponse 

func NewUpdateTargetResponse() (response *UpdateTargetResponse)

func (*UpdateTargetResponse) FromJsonString 

func (r *UpdateTargetResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*UpdateTargetResponse) ToJsonString 

func (r *UpdateTargetResponse) ToJsonString() string

type UpdateTargetResponseParams 

type UpdateTargetResponseParams struct {
	// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type UpdateTransformationRequest 

type UpdateTransformationRequest struct {
	*tchttp.BaseRequest

	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Rule ID
	RuleId *string `json:"RuleId,omitempty" name:"RuleId"`

	// Transformer ID
	TransformationId *string `json:"TransformationId,omitempty" name:"TransformationId"`

	// Transformation rule list (currently, only one is supported)
	Transformations []*Transformation `json:"Transformations,omitempty" name:"Transformations"`
}

func NewUpdateTransformationRequest 

func NewUpdateTransformationRequest() (request *UpdateTransformationRequest)

func (*UpdateTransformationRequest) FromJsonString 

func (r *UpdateTransformationRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*UpdateTransformationRequest) ToJsonString 

func (r *UpdateTransformationRequest) ToJsonString() string

type UpdateTransformationRequestParams 

type UpdateTransformationRequestParams struct {
	// Event bus ID
	EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"`

	// Rule ID
	RuleId *string `json:"RuleId,omitempty" name:"RuleId"`

	// Transformer ID
	TransformationId *string `json:"TransformationId,omitempty" name:"TransformationId"`

	// Transformation rule list (currently, only one is supported)
	Transformations []*Transformation `json:"Transformations,omitempty" name:"Transformations"`
}

Predefined struct for user

type UpdateTransformationResponse 

type UpdateTransformationResponse struct {
	*tchttp.BaseResponse
	Response *UpdateTransformationResponseParams `json:"Response"`
}

func NewUpdateTransformationResponse 

func NewUpdateTransformationResponse() (response *UpdateTransformationResponse)

func (*UpdateTransformationResponse) FromJsonString 

func (r *UpdateTransformationResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*UpdateTransformationResponse) ToJsonString 

func (r *UpdateTransformationResponse) ToJsonString() string

type UpdateTransformationResponseParams 

type UpdateTransformationResponseParams struct {
	// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.