v20210416

package
v3.0.404+incompatible Latest Latest
Warning

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

 Go to latest Published: Mar 22, 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"

	// 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"

	//
	FAILEDOPERATION_ERRORFILTER = "FailedOperation.ErrorFilter"

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

	// 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"

	// 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_SYSTEM = "InternalError.System"

	// Incorrect parameter.
	INVALIDPARAMETER = "InvalidParameter"

	// `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 `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 `ConnectionName` value does not conform to the specification. Please fix it and try again.
	INVALIDPARAMETERVALUE_CONNECTIONNAME = "InvalidParameterValue.ConnectionName"

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

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

	// The `EventBusName` value does not conform to the specification. Please fix it 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 `Filters` value does not conform to the specification. Please fix it and try again.
	INVALIDPARAMETERVALUE_FILTERS = "InvalidParameterValue.Filters"

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

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

	// 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"

	// 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 `Type` value does not conform to the specification. Please fix it and try again.
	INVALIDPARAMETERVALUE_TYPE = "InvalidParameterValue.Type"

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

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

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

	// The `RouteOverLimit` quantity has reached the upper limit. You can 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"

	//
	OPERATIONDENIED_DEFAULTCLSRESOURCEUNSUPPORTED = "OperationDenied.DefaultCLSResourceUnsupported"

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

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

	// There are rules or connectors under the event bus, so it cannot be deleted. Please delete all rules and connectors and try again.
	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"

	// 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"

	// 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, as the current resource was 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, as the current backend service type was 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 CheckRuleResponse 

type CheckRuleResponse struct {
	*tchttp.BaseResponse
	Response *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"`
	} `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 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 CheckTransformationResponse 

type CheckTransformationResponse struct {
	*tchttp.BaseResponse
	Response *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"`
	} `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 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"

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"

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"

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"

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_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"
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_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"
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: 

INTERNALERROR = "InternalError"
INVALIDPARAMETERVALUE_DESCRIPTION = "InvalidParameterValue.Description"
INVALIDPARAMETERVALUE_EVENTBUSNAME = "InvalidParameterValue.EventBusName"
INVALIDPARAMETERVALUE_TYPE = "InvalidParameterValue.Type"
LIMITEXCEEDED_EVENTBUS = "LimitExceeded.EventBus"
RESOURCEINUSE_DEFAULTEVENTBUS = "ResourceInUse.DefaultEventBus"
RESOURCEINUSE_EVENTBUS = "ResourceInUse.EventBus"

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: 

INTERNALERROR = "InternalError"
INVALIDPARAMETERVALUE_DESCRIPTION = "InvalidParameterValue.Description"
INVALIDPARAMETERVALUE_EVENTBUSNAME = "InvalidParameterValue.EventBusName"
INVALIDPARAMETERVALUE_TYPE = "InvalidParameterValue.Type"
LIMITEXCEEDED_EVENTBUS = "LimitExceeded.EventBus"
RESOURCEINUSE_DEFAULTEVENTBUS = "ResourceInUse.DefaultEventBus"
RESOURCEINUSE_EVENTBUS = "ResourceInUse.EventBus"

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_DESCRIPTION = "InvalidParameterValue.Description"
INVALIDPARAMETERVALUE_EVENTPATTERN = "InvalidParameterValue.EventPattern"
INVALIDPARAMETERVALUE_RULENAME = "InvalidParameterValue.RuleName"
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_DESCRIPTION = "InvalidParameterValue.Description"
INVALIDPARAMETERVALUE_EVENTPATTERN = "InvalidParameterValue.EventPattern"
INVALIDPARAMETERVALUE_RULENAME = "InvalidParameterValue.RuleName"
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_CREATETRIGGER = "FailedOperation.CreateTrigger"
INVALIDPARAMETERVALUE_AMPPARAMS = "InvalidParameterValue.AMPParams"
INVALIDPARAMETERVALUE_BATCHEVENTCOUNT = "InvalidParameterValue.BatchEventCount"
INVALIDPARAMETERVALUE_BATCHTIMEOUT = "InvalidParameterValue.BatchTimeout"
INVALIDPARAMETERVALUE_CALLBACKTYPE = "InvalidParameterValue.CallbackType"
INVALIDPARAMETERVALUE_CALLBACKWECOMURL = "InvalidParameterValue.CallbackWeComURL"
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"
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_CREATETRIGGER = "FailedOperation.CreateTrigger"
INVALIDPARAMETERVALUE_AMPPARAMS = "InvalidParameterValue.AMPParams"
INVALIDPARAMETERVALUE_BATCHEVENTCOUNT = "InvalidParameterValue.BatchEventCount"
INVALIDPARAMETERVALUE_BATCHTIMEOUT = "InvalidParameterValue.BatchTimeout"
INVALIDPARAMETERVALUE_CALLBACKTYPE = "InvalidParameterValue.CallbackType"
INVALIDPARAMETERVALUE_CALLBACKWECOMURL = "InvalidParameterValue.CallbackWeComURL"
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"
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: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_CREATETRIGGER = "FailedOperation.CreateTrigger"
INVALIDPARAMETERVALUE_AMPPARAMS = "InvalidParameterValue.AMPParams"
INVALIDPARAMETERVALUE_BATCHEVENTCOUNT = "InvalidParameterValue.BatchEventCount"
INVALIDPARAMETERVALUE_BATCHTIMEOUT = "InvalidParameterValue.BatchTimeout"
INVALIDPARAMETERVALUE_CALLBACKTYPE = "InvalidParameterValue.CallbackType"
INVALIDPARAMETERVALUE_CALLBACKWECOMURL = "InvalidParameterValue.CallbackWeComURL"
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"
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) 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: 

FAILEDOPERATION = "FailedOperation"
FAILEDOPERATION_CREATETRIGGER = "FailedOperation.CreateTrigger"
INVALIDPARAMETERVALUE_AMPPARAMS = "InvalidParameterValue.AMPParams"
INVALIDPARAMETERVALUE_BATCHEVENTCOUNT = "InvalidParameterValue.BatchEventCount"
INVALIDPARAMETERVALUE_BATCHTIMEOUT = "InvalidParameterValue.BatchTimeout"
INVALIDPARAMETERVALUE_CALLBACKTYPE = "InvalidParameterValue.CallbackType"
INVALIDPARAMETERVALUE_CALLBACKWECOMURL = "InvalidParameterValue.CallbackWeComURL"
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"
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) 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: 

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: 

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: 

INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"
INVALIDPARAMETERVALUE_TARGETID = "InvalidParameterValue.TargetId"
INVALIDPARAMETERVALUE_TYPE = "InvalidParameterValue.Type"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
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: 

INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"
INVALIDPARAMETERVALUE_TARGETID = "InvalidParameterValue.TargetId"
INVALIDPARAMETERVALUE_TYPE = "InvalidParameterValue.Type"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
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_RULEID = "InvalidParameterValue.RuleId"
INVALIDPARAMETERVALUE_TARGETID = "InvalidParameterValue.TargetId"
INVALIDPARAMETERVALUE_TYPE = "InvalidParameterValue.Type"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
RESOURCENOTFOUND_ROLE = "ResourceNotFound.Role"
RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule"
RESOURCENOTFOUND_TARGET = "ResourceNotFound.Target"

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_RULEID = "InvalidParameterValue.RuleId"
INVALIDPARAMETERVALUE_TARGETID = "InvalidParameterValue.TargetId"
INVALIDPARAMETERVALUE_TYPE = "InvalidParameterValue.Type"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
RESOURCENOTFOUND_ROLE = "ResourceNotFound.Role"
RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule"
RESOURCENOTFOUND_TARGET = "ResourceNotFound.Target"

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_RULEID = "InvalidParameterValue.RuleId"

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_RULEID = "InvalidParameterValue.RuleId"

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_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_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: 

INVALIDPARAMETERVALUE_CONNECTIONID = "InvalidParameterValue.ConnectionId"
INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
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: 

INVALIDPARAMETERVALUE_CONNECTIONID = "InvalidParameterValue.ConnectionId"
INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
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: 

INVALIDPARAMETERVALUE_DESCRIPTION = "InvalidParameterValue.Description"
INVALIDPARAMETERVALUE_EVENTBUSNAME = "InvalidParameterValue.EventBusName"
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: 

INVALIDPARAMETERVALUE_DESCRIPTION = "InvalidParameterValue.Description"
INVALIDPARAMETERVALUE_EVENTBUSNAME = "InvalidParameterValue.EventBusName"
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: 

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"

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: 

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"

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_NOTICERECEIVERUSERIDS = "InvalidParameterValue.NoticeReceiverUserIds"
INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"
INVALIDPARAMETERVALUE_TARGETID = "InvalidParameterValue.TargetId"
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_NOTICERECEIVERUSERIDS = "InvalidParameterValue.NoticeReceiverUserIds"
INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"
INVALIDPARAMETERVALUE_TARGETID = "InvalidParameterValue.TargetId"
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: 

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

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: 

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

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"`

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

	// Type
	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 CreateConnectionResponse 

type CreateConnectionResponse struct {
	*tchttp.BaseResponse
	Response *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"`
	} `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 CreateEventBusRequest 

type CreateEventBusRequest struct {
	*tchttp.BaseRequest

	// 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 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 CreateEventBusResponse 

type CreateEventBusResponse struct {
	*tchttp.BaseResponse
	Response *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"`
	} `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 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 CreateRuleResponse 

type CreateRuleResponse struct {
	*tchttp.BaseResponse
	Response *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"`
	} `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 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 CreateTargetResponse 

type CreateTargetResponse struct {
	*tchttp.BaseResponse
	Response *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"`
	} `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 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 CreateTransformationResponse 

type CreateTransformationResponse struct {
	*tchttp.BaseResponse
	Response *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"`
	} `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 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 DeleteConnectionResponse 

type DeleteConnectionResponse struct {
	*tchttp.BaseResponse
	Response *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"`
	} `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 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 DeleteEventBusResponse 

type DeleteEventBusResponse struct {
	*tchttp.BaseResponse
	Response *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"`
	} `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 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 DeleteRuleResponse 

type DeleteRuleResponse struct {
	*tchttp.BaseResponse
	Response *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"`
	} `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 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 DeleteTargetResponse 

type DeleteTargetResponse struct {
	*tchttp.BaseResponse
	Response *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"`
	} `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 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 DeleteTransformationResponse 

type DeleteTransformationResponse struct {
	*tchttp.BaseResponse
	Response *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"`
	} `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 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 GetEventBusResponse 

type GetEventBusResponse struct {
	*tchttp.BaseResponse
	Response *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"`
	} `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 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 GetRuleResponse 

type GetRuleResponse struct {
	*tchttp.BaseResponse
	Response *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"`
	} `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 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 GetTransformationResponse 

type GetTransformationResponse struct {
	*tchttp.BaseResponse
	Response *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"`
	} `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 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 ListConnectionsResponse 

type ListConnectionsResponse struct {
	*tchttp.BaseResponse
	Response *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"`
	} `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 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 ListEventBusesResponse 

type ListEventBusesResponse struct {
	*tchttp.BaseResponse
	Response *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"`
	} `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 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 ListRulesResponse 

type ListRulesResponse struct {
	*tchttp.BaseResponse
	Response *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"`
	} `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 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 ListTargetsResponse 

type ListTargetsResponse struct {
	*tchttp.BaseResponse
	Response *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"`
	} `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 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"`
}

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 UpdateConnectionResponse 

type UpdateConnectionResponse struct {
	*tchttp.BaseResponse
	Response *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"`
	} `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 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, 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"`
}

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 UpdateEventBusResponse 

type UpdateEventBusResponse struct {
	*tchttp.BaseResponse
	Response *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"`
	} `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 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 UpdateRuleResponse 

type UpdateRuleResponse struct {
	*tchttp.BaseResponse
	Response *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"`
	} `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 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 UpdateTargetResponse 

type UpdateTargetResponse struct {
	*tchttp.BaseResponse
	Response *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"`
	} `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 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 UpdateTransformationResponse 

type UpdateTransformationResponse struct {
	*tchttp.BaseResponse
	Response *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"`
	} `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

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.