model

package

Go to main page

Versions in this module

v0

v0.1.124

Nov 28, 2024

v0.1.123

Nov 21, 2024

v0.1.122

Nov 14, 2024

v0.1.121

Nov 7, 2024

v0.1.120

Oct 31, 2024

v0.1.119

Oct 24, 2024

v0.1.118

Oct 17, 2024

v0.1.117

Oct 10, 2024

v0.1.116

Sep 26, 2024

v0.1.115

Sep 23, 2024

v0.1.114

Sep 12, 2024

v0.1.113

Sep 5, 2024

v0.1.112

Aug 29, 2024

v0.1.111

Aug 22, 2024

v0.1.110

Aug 15, 2024

v0.1.109

Aug 8, 2024

v0.1.108

Aug 1, 2024

v0.1.107

Jul 25, 2024

v0.1.106

Jul 18, 2024

v0.1.105

Jul 11, 2024

v0.1.104

Jul 4, 2024

v0.1.103

Jun 27, 2024

v0.1.102

Jun 20, 2024

v0.1.101

Jun 14, 2024

v0.1.100

Jun 13, 2024

v0.1.99

Jun 6, 2024

v0.1.98

May 30, 2024

v0.1.97

May 23, 2024

v0.1.96

May 16, 2024

v0.1.95

May 9, 2024

v0.1.94

Apr 30, 2024

v0.1.93

Apr 25, 2024

v0.1.92

Apr 18, 2024

v0.1.92-patch

Apr 23, 2024

v0.1.91

Apr 11, 2024

v0.1.90

Apr 3, 2024

v0.1.89

Apr 1, 2024

v0.1.88

Mar 28, 2024

v0.1.87

Mar 21, 2024

v0.1.86

Mar 14, 2024

v0.1.85

Mar 7, 2024

v0.1.84

Feb 29, 2024

v0.1.83

Feb 22, 2024

v0.1.82

Feb 20, 2024

v0.1.81

Feb 7, 2024

v0.1.80

Feb 1, 2024

v0.1.79

Jan 25, 2024

v0.1.78

Jan 18, 2024

v0.1.77

Jan 11, 2024

Changes in this version

type EventStreamingDetail

+ Id *string

type ShowEventStreamingResponse

+ Id *string

v0.1.76

Jan 4, 2024

Changes in this version

type ListEventStreamingResponse

+ Items *[]EventStreamingDetail

+ Size *int32

+ Total *int32

type SourceKafkaMqParameters

+ Addr *string

v0.1.75

Dec 27, 2023

v0.1.74

Dec 22, 2023

v0.1.73

Dec 21, 2023

v0.1.72

Dec 14, 2023

v0.1.71

Dec 7, 2023

Changes in this version

type ChannelCreateReq

+ CrossAccount *bool

+ EpsId *string

+ Policy map[string]ChannelCreateReqPolicy

+ type ChannelCreateReqPolicy struct

+ Action *string

+ Effect *string

+ Principal map[string]ChannelCreateReqPrincipal

+ Resource *string

+ Sid *string

+ func (o ChannelCreateReqPolicy) String() string

+ type ChannelCreateReqPrincipal struct

+ Iam *[]string

+ func (o ChannelCreateReqPrincipal) String() string

type ChannelInfo

+ EpsId *string

type ChannelUpdateReq

+ CrossAccount *bool

+ EpsId *string

+ Policy map[string]ChannelCreateReqPolicy

type CreateChannelRequest

+ EnterpriseProjectId *string

type CreateChannelResponse

+ EpsId *string

type DeleteChannelRequest

+ EnterpriseProjectId *string

+ type EgTargetDetail struct

+ AgencyName string

+ CrossAccount *bool

+ CrossRegion *bool

+ TargetChannelId string

+ TargetProjectId string

+ TargetRegion string

+ func (o EgTargetDetail) String() string

type EventStreamingSink

+ SinkKafka *SinkKafkaParameters

type EventStreamingSinkNameEnum

+ HC_FUNCTION_GRAPH EventStreamingSinkName

+ HC_KAFKA EventStreamingSinkName

type EventStreamingSource

+ SourceMobileRocketmq *SourceMobileMqParameters

type KafkaConnectionDetail

+ SecurityProtocol *string

type ListChannelsRequest

+ EpsId *string

type ListEventStreamingRequest

+ FuzzyName *string

+ Name *string

type ShowDetailOfChannelRequest

+ EnterpriseProjectId *string

type ShowDetailOfChannelResponse

+ EpsId *string

type ShowDetailOfEventRequest

+ ChannelId *string

+ type SinkKafkaParameters struct

+ ConnectionId string

+ KeyTransform *[]TransForm

+ Topic string

+ func (o SinkKafkaParameters) String() string

type SourceKafkaMqParameters

+ SecurityProtocol *string

+ type SourceMobileMqParameters struct

+ AccessKey *string

+ Addr string

+ AddrType SourceMobileMqParametersAddrType

+ AuthenticationRequired *bool

+ ConsumeTimeout int32

+ ConsumerBatchMaxSize *int32

+ ConsumerMaxWait *int32

+ ConsumerThreadNums *int32

+ GroupId string

+ InstanceId string

+ MaxReconsumerTimes *int32

+ MessageModel SourceMobileMqParametersMessageModel

+ MessageType SourceMobileMqParametersMessageType

+ MsgTraceSwitch *bool

+ SdkUrl string

+ SecretKey *string

+ SubnetId *string

+ SuspendTime *int32

+ Tag *string

+ Topic string

+ VpcId *string

+ func (o SourceMobileMqParameters) String() string

+ type SourceMobileMqParametersAddrType struct

+ func (c *SourceMobileMqParametersAddrType) UnmarshalJSON(b []byte) error

+ func (c SourceMobileMqParametersAddrType) MarshalJSON() ([]byte, error)

+ func (c SourceMobileMqParametersAddrType) Value() string

+ type SourceMobileMqParametersAddrTypeEnum struct

+ PRIVATE SourceMobileMqParametersAddrType

+ PUBLIC SourceMobileMqParametersAddrType

+ func GetSourceMobileMqParametersAddrTypeEnum() SourceMobileMqParametersAddrTypeEnum

+ type SourceMobileMqParametersMessageModel struct

+ func (c *SourceMobileMqParametersMessageModel) UnmarshalJSON(b []byte) error

+ func (c SourceMobileMqParametersMessageModel) MarshalJSON() ([]byte, error)

+ func (c SourceMobileMqParametersMessageModel) Value() string

+ type SourceMobileMqParametersMessageModelEnum struct

+ BROADCASTING SourceMobileMqParametersMessageModel

+ CLUSTERING SourceMobileMqParametersMessageModel

+ func GetSourceMobileMqParametersMessageModelEnum() SourceMobileMqParametersMessageModelEnum

+ type SourceMobileMqParametersMessageType struct

+ func (c *SourceMobileMqParametersMessageType) UnmarshalJSON(b []byte) error

+ func (c SourceMobileMqParametersMessageType) MarshalJSON() ([]byte, error)

+ func (c SourceMobileMqParametersMessageType) Value() string

+ type SourceMobileMqParametersMessageTypeEnum struct

+ NORMAL SourceMobileMqParametersMessageType

+ func GetSourceMobileMqParametersMessageTypeEnum() SourceMobileMqParametersMessageTypeEnum

type SubscriptionTarget

+ EgDetail *EgTargetDetail

type UpdateChannelRequest

+ EnterpriseProjectId *string

type UpdateChannelResponse

+ EpsId *string

v0.1.70

Nov 30, 2023

v0.1.69

Nov 23, 2023

v0.1.68

Nov 23, 2023

v0.1.67

Nov 16, 2023

v0.1.66

Nov 13, 2023

v0.1.65

Nov 9, 2023

v0.1.64

Nov 2, 2023

v0.1.63

Oct 26, 2023

v0.1.62

Oct 19, 2023

v0.1.61

Oct 12, 2023

v0.1.60

Sep 19, 2023

v0.1.59

Sep 14, 2023

v0.1.58

Sep 7, 2023

v0.1.57

Aug 31, 2023

v0.1.56

Aug 24, 2023

Changes in this version

+ type Detail struct

+ AgencyName *string

+ InvocationHttpParameters *InvocationHttpParameters

+ Url *string

+ func (o Detail) String() string

+ type HeaderParameter struct

+ IsValueSecret *bool

+ Key *string

+ Value *string

+ func (o HeaderParameter) String() string

+ type InvocationHttpParameters struct

+ HeaderParameters *[]HeaderParameter

+ func (o InvocationHttpParameters) String() string

v0.1.55

Aug 21, 2023

v0.1.54

Aug 17, 2023

v0.1.53

Aug 10, 2023

v0.1.52

Aug 3, 2023

Changes in this version

type ConnectionInfo

+ ErrorInfo *ErrorInfo

type CreateConnectionResponse

+ ErrorInfo *ErrorInfo

type CreateEndpointResponse

+ ErrorInfo *ErrorInfo

type CreateEventSourceResponse

+ ErrorInfo *ErrorInfo

type CreateSubscriptionTargetResponse

+ DeadLetterQueue *DeadLetterQueue

type CustomizeSourceInfo

+ ErrorInfo *ErrorInfo

+ type DeadLetterQueue struct

+ ConnectionId string

+ InstanceId string

+ Topic string

+ Type DeadLetterQueueType

+ func (o DeadLetterQueue) String() string

+ type DeadLetterQueueType struct

+ func (c *DeadLetterQueueType) UnmarshalJSON(b []byte) error

+ func (c DeadLetterQueueType) MarshalJSON() ([]byte, error)

+ func (c DeadLetterQueueType) Value() string

+ type DeadLetterQueueTypeEnum struct

+ KAFKA DeadLetterQueueType

+ func GetDeadLetterQueueTypeEnum() DeadLetterQueueTypeEnum

type EndpointInfo

+ ErrorInfo *ErrorInfo

+ type ErrorInfo struct

+ ErrorCode *string

+ ErrorDetail *string

+ ErrorMsg *string

+ func (o ErrorInfo) String() string

type ListConnectionsRequest

+ InstanceId *string

type ListEndpointsRequest

+ SubnetId *string

type ShowDetailOfConnectionResponse

+ ErrorInfo *ErrorInfo

type ShowDetailOfEventSourceResponse

+ ErrorInfo *ErrorInfo

type ShowDetailOfSubscriptionTargetResponse

+ DeadLetterQueue *DeadLetterQueue

+ type SmnTargetDetail struct

+ AgencyName string

+ SubjectTransform *SmnTargetDetailSubjectTransform

+ Urn string

+ func (o SmnTargetDetail) String() string

+ type SmnTargetDetailSubjectTransform struct

+ Template *string

+ Type SmnTargetDetailSubjectTransformType

+ Value string

+ func (o SmnTargetDetailSubjectTransform) String() string

+ type SmnTargetDetailSubjectTransformType struct

+ func (c *SmnTargetDetailSubjectTransformType) UnmarshalJSON(b []byte) error

+ func (c SmnTargetDetailSubjectTransformType) MarshalJSON() ([]byte, error)

+ func (c SmnTargetDetailSubjectTransformType) Value() string

+ type SmnTargetDetailSubjectTransformTypeEnum struct

+ CONSTANT SmnTargetDetailSubjectTransformType

+ VARIABLE SmnTargetDetailSubjectTransformType

+ func GetSmnTargetDetailSubjectTransformTypeEnum() SmnTargetDetailSubjectTransformTypeEnum

+ type SourceKafkaMqParametersSaslMechanism struct

+ func (c *SourceKafkaMqParametersSaslMechanism) UnmarshalJSON(b []byte) error

+ func (c SourceKafkaMqParametersSaslMechanism) MarshalJSON() ([]byte, error)

+ func (c SourceKafkaMqParametersSaslMechanism) Value() string

+ type SourceKafkaMqParametersSaslMechanismEnum struct

+ PLAIN SourceKafkaMqParametersSaslMechanism

+ SCRAM_SHA_512 SourceKafkaMqParametersSaslMechanism

+ func GetSourceKafkaMqParametersSaslMechanismEnum() SourceKafkaMqParametersSaslMechanismEnum

+ type SourceKafkaMqParametersSeekTo struct

+ func (c *SourceKafkaMqParametersSeekTo) UnmarshalJSON(b []byte) error

+ func (c SourceKafkaMqParametersSeekTo) MarshalJSON() ([]byte, error)

+ func (c SourceKafkaMqParametersSeekTo) Value() string

+ type SourceKafkaMqParametersSeekToEnum struct

+ EARLIEST SourceKafkaMqParametersSeekTo

+ LATEST SourceKafkaMqParametersSeekTo

+ func GetSourceKafkaMqParametersSeekToEnum() SourceKafkaMqParametersSeekToEnum

type SubscriptionTarget

+ DeadLetterQueue *DeadLetterQueue

+ SmnDetail *SmnTargetDetail

type SubscriptionTargetInfo

+ DeadLetterQueue *DeadLetterQueue

type UpdateConnectionResponse

+ ErrorInfo *ErrorInfo

type UpdateEndpointResponse

+ ErrorInfo *ErrorInfo

type UpdateEventSourceResponse

+ ErrorInfo *ErrorInfo

type UpdateSubscriptionTargetResponse

+ DeadLetterQueue *DeadLetterQueue

v0.1.51

Jul 31, 2023

v0.1.50

Jul 27, 2023

v0.1.49

Jul 20, 2023

v0.1.48

Jul 13, 2023

v0.1.47

Jul 6, 2023

v0.1.46

Jun 29, 2023

v0.1.45

Jun 21, 2023

v0.1.44

Jun 15, 2023

v0.1.43

Jun 8, 2023

v0.1.42

Jun 1, 2023

Changes in this version

+ type BatchWindow struct

+ Count *int32

+ Interval *int32

+ Time *int32

+ func (o BatchWindow) String() string

type ChannelInfoProviderTypeEnum

+ PARTNER ChannelInfoProviderType

type ConnectionCreateReq

+ KafkaDetail *KafkaConnectionDetail

+ Type *ConnectionType

type ConnectionInfo

+ KafkaDetail *KafkaConnectionDetail

+ Type *ConnectionType

+ type ConnectionType struct

+ func (c *ConnectionType) UnmarshalJSON(b []byte) error

+ func (c ConnectionType) MarshalJSON() ([]byte, error)

+ func (c ConnectionType) Value() string

+ type ConnectionTypeEnum struct

+ KAFKA ConnectionType

+ WEBHOOK ConnectionType

+ func GetConnectionTypeEnum() ConnectionTypeEnum

type CreateChannelResponseProviderTypeEnum

+ PARTNER CreateChannelResponseProviderType

type CreateConnectionResponse

+ KafkaDetail *KafkaConnectionDetail

+ Type *ConnectionType

type CreateEventSourceResponseProviderTypeEnum

+ PARTNER CreateEventSourceResponseProviderType

+ type CreateEventStreamingRequest struct

+ Body *EventStreamingCreateReq

+ func (o CreateEventStreamingRequest) String() string

+ type CreateEventStreamingResponse struct

+ EventStreamingID *string

+ HttpStatusCode int

+ XRequestId *string

+ func (o CreateEventStreamingResponse) String() string

type CustomizeSourceInfoProviderTypeEnum

+ PARTNER CustomizeSourceInfoProviderType

+ type DeleteEventStreamingRequest struct

+ EventstreamingId string

+ func (o DeleteEventStreamingRequest) String() string

+ type DeleteEventStreamingResponse struct

+ EventStreamingID *string

+ HttpStatusCode int

+ XRequestId *string

+ func (o DeleteEventStreamingResponse) String() string

+ type DeliverDetail struct

+ DeliverConsuming *string

+ DeliverRspCode *string

+ DeliverStatus *string

+ DeliverTime *string

+ func (o DeliverDetail) String() string

+ type DeliverItem struct

+ AllDeliverTimes *int32

+ DeliverTargetList *[]DeliverTarget

+ FailCounts *int32

+ SubscriptionId *string

+ SubscriptionName *string

+ SuccessCounts *int32

+ func (o DeliverItem) String() string

+ type DeliverTarget struct

+ DeliverDetailList *[]DeliverDetail

+ DeliverStatus *string

+ DeliverTargetId *string

+ DeliverTargetName *string

+ func (o DeliverTarget) String() string

+ type EventStreamingCreateReq struct

+ Description *string

+ Name string

+ Option *RunOption

+ RuleConfig *EventStreamingCreateReqRuleConfig

+ Sink *EventStreamingSink

+ Source *EventStreamingSource

+ func (o EventStreamingCreateReq) String() string

+ type EventStreamingCreateReqRuleConfig struct

+ Filter *string

+ Transform *TransForm

+ func (o EventStreamingCreateReqRuleConfig) String() string

+ type EventStreamingDetail struct

+ CreatedTime *string

+ Description *string

+ Name string

+ Option *RunOption

+ RuleConfig *EventStreamingCreateReqRuleConfig

+ Sink *EventStreamingSink

+ Source *EventStreamingSource

+ Status *EventStreamingDetailStatus

+ StreamingId *string

+ UpdatedTime *string

+ func (o EventStreamingDetail) String() string

+ type EventStreamingDetailStatus struct

+ func (c *EventStreamingDetailStatus) UnmarshalJSON(b []byte) error

+ func (c EventStreamingDetailStatus) MarshalJSON() ([]byte, error)

+ func (c EventStreamingDetailStatus) Value() string

+ type EventStreamingDetailStatusEnum struct

+ CREATED EventStreamingDetailStatus

+ ERROR EventStreamingDetailStatus

+ RUNNING EventStreamingDetailStatus

+ STOPPED EventStreamingDetailStatus

+ func GetEventStreamingDetailStatusEnum() EventStreamingDetailStatusEnum

+ type EventStreamingOperateReq struct

+ Operation *EventStreamingOperateReqOperation

+ func (o EventStreamingOperateReq) String() string

+ type EventStreamingOperateReqOperation struct

+ func (c *EventStreamingOperateReqOperation) UnmarshalJSON(b []byte) error

+ func (c EventStreamingOperateReqOperation) MarshalJSON() ([]byte, error)

+ func (c EventStreamingOperateReqOperation) Value() string

+ type EventStreamingOperateReqOperationEnum struct

+ PAUSE EventStreamingOperateReqOperation

+ START EventStreamingOperateReqOperation

+ func GetEventStreamingOperateReqOperationEnum() EventStreamingOperateReqOperationEnum

+ type EventStreamingSink struct

+ Name *EventStreamingSinkName

+ SinkFg *SinkFgParameters

+ func (o EventStreamingSink) String() string

+ type EventStreamingSinkName struct

+ func (c *EventStreamingSinkName) UnmarshalJSON(b []byte) error

+ func (c EventStreamingSinkName) MarshalJSON() ([]byte, error)

+ func (c EventStreamingSinkName) Value() string

+ type EventStreamingSinkNameEnum struct

+ HC_FG EventStreamingSinkName

+ func GetEventStreamingSinkNameEnum() EventStreamingSinkNameEnum

+ type EventStreamingSource struct

+ Name *EventStreamingSourceName

+ SourceKafka *SourceKafkaMqParameters

+ func (o EventStreamingSource) String() string

+ type EventStreamingSourceName struct

+ func (c *EventStreamingSourceName) UnmarshalJSON(b []byte) error

+ func (c EventStreamingSourceName) MarshalJSON() ([]byte, error)

+ func (c EventStreamingSourceName) Value() string

+ type EventStreamingSourceNameEnum struct

+ HC_DMS EventStreamingSourceName

+ func GetEventStreamingSourceNameEnum() EventStreamingSourceNameEnum

+ type EventStreamingUpdateReq struct

+ Description *string

+ Name string

+ Option *RunOption

+ RuleConfig *EventStreamingCreateReqRuleConfig

+ Sink *EventStreamingSink

+ Source *EventStreamingSource

+ func (o EventStreamingUpdateReq) String() string

+ type KafkaConnectionDetail struct

+ Acks *KafkaConnectionDetailAcks

+ Addr string

+ InstanceId string

+ Password *string

+ SaslSsl bool

+ Username *string

+ func (o KafkaConnectionDetail) String() string

+ type KafkaConnectionDetailAcks struct

+ func (c *KafkaConnectionDetailAcks) UnmarshalJSON(b []byte) error

+ func (c KafkaConnectionDetailAcks) MarshalJSON() ([]byte, error)

+ func (c KafkaConnectionDetailAcks) Value() string

+ type KafkaConnectionDetailAcksEnum struct

+ ALL KafkaConnectionDetailAcks

+ E_0 KafkaConnectionDetailAcks

+ E_1 KafkaConnectionDetailAcks

+ func GetKafkaConnectionDetailAcksEnum() KafkaConnectionDetailAcksEnum

+ type KafkaTargetDetail struct

+ KeyTransform *KafkaTargetDetailKeyTransform

+ Topic string

+ func (o KafkaTargetDetail) String() string

+ type KafkaTargetDetailKeyTransform struct

+ Template *string

+ Type *KafkaTargetDetailKeyTransformType

+ Value *string

+ func (o KafkaTargetDetailKeyTransform) String() string

+ type KafkaTargetDetailKeyTransformType struct

+ func (c *KafkaTargetDetailKeyTransformType) UnmarshalJSON(b []byte) error

+ func (c KafkaTargetDetailKeyTransformType) MarshalJSON() ([]byte, error)

+ func (c KafkaTargetDetailKeyTransformType) Value() string

+ type KafkaTargetDetailKeyTransformTypeEnum struct

+ CONSTANT KafkaTargetDetailKeyTransformType

+ NONE KafkaTargetDetailKeyTransformType

+ VARIABLE KafkaTargetDetailKeyTransformType

+ func GetKafkaTargetDetailKeyTransformTypeEnum() KafkaTargetDetailKeyTransformTypeEnum

type ListChannelsRequestProviderTypeEnum

+ PARTNER ListChannelsRequestProviderType

type ListEventSourcesRequestProviderTypeEnum

+ PARTNER ListEventSourcesRequestProviderType

+ type ListEventStreamingRequest struct

+ Limit *int32

+ Offset *int32

+ func (o ListEventStreamingRequest) String() string

+ type ListEventStreamingResponse struct

+ Body *[]EventStreamingDetail

+ HttpStatusCode int

+ XRequestId *string

+ func (o ListEventStreamingResponse) String() string

type ListEventTargetRequest

+ SupportTypes *[]ListEventTargetRequestSupportTypes

+ type ListEventTargetRequestSupportTypes struct

+ func (c *ListEventTargetRequestSupportTypes) UnmarshalJSON(b []byte) error

+ func (c ListEventTargetRequestSupportTypes) MarshalJSON() ([]byte, error)

+ func (c ListEventTargetRequestSupportTypes) Value() string

+ type ListEventTargetRequestSupportTypesEnum struct

+ FLOW ListEventTargetRequestSupportTypes

+ SUBSCRIPTION ListEventTargetRequestSupportTypes

+ func GetListEventTargetRequestSupportTypesEnum() ListEventTargetRequestSupportTypesEnum

type ListSubscriptionsRequest

+ ConnectionId *string

+ type ListTracedEventsRequest struct

+ ChannelId string

+ EndTime int64

+ EventId *string

+ EventType *string

+ Limit *string

+ Offset *int32

+ SourceName *string

+ StartTime int64

+ SubscriptionName *string

+ func (o ListTracedEventsRequest) String() string

+ type ListTracedEventsRespResult struct

+ EventId *string

+ EventReceivedTime *int32

+ EventType *string

+ SourceName *string

+ SourceProvider *string

+ SubscriptionName *string

+ func (o ListTracedEventsRespResult) String() string

+ type ListTracedEventsResponse struct

+ HttpStatusCode int

+ Result *[]ListTracedEventsRespResult

+ Size *int32

+ Total *int32

+ XRequestId *string

+ func (o ListTracedEventsResponse) String() string

+ type PutOfficialEventsRequest struct

+ Body *PutEventsReq

+ SourceName string

+ func (o PutOfficialEventsRequest) String() string

+ type PutOfficialEventsResponse struct

+ Events *[]PutEventsRespEvents

+ FailedCount *int32

+ HttpStatusCode int

+ XRequestId *string

+ func (o PutOfficialEventsResponse) String() string

+ type ResumeEventStreamingRequest struct

+ Body *EventStreamingOperateReq

+ EventstreamingId string

+ func (o ResumeEventStreamingRequest) String() string

+ type ResumeEventStreamingResponse struct

+ EventStreamingID *string

+ HttpStatusCode int

+ XRequestId *string

+ func (o ResumeEventStreamingResponse) String() string

+ type RunOption struct

+ BatchWindow *BatchWindow

+ ThreadNum *int32

+ func (o RunOption) String() string

type ShowDetailOfChannelResponseProviderTypeEnum

+ PARTNER ShowDetailOfChannelResponseProviderType

type ShowDetailOfConnectionResponse

+ KafkaDetail *KafkaConnectionDetail

+ Type *ConnectionType

+ type ShowDetailOfEventRequest struct

+ TraceId string

+ func (o ShowDetailOfEventRequest) String() string

+ type ShowDetailOfEventResponse struct

+ Body *string

+ HttpStatusCode int

+ func (o ShowDetailOfEventResponse) String() string

type ShowDetailOfEventSourceResponseProviderTypeEnum

+ PARTNER ShowDetailOfEventSourceResponseProviderType

+ type ShowDetailOfEventTraceRequest struct

+ ChannelId string

+ TraceId string

+ func (o ShowDetailOfEventTraceRequest) String() string

+ type ShowDetailOfEventTraceResponse struct

+ ChannelId *string

+ ChannelName *string

+ DeliverList *[]DeliverItem

+ EventId *string

+ EventSource *string

+ EventType *string

+ HttpStatusCode int

+ ReceiveTime *string

+ func (o ShowDetailOfEventTraceResponse) String() string

+ type ShowEventStreamingRequest struct

+ EventstreamingId string

+ func (o ShowEventStreamingRequest) String() string

+ type ShowEventStreamingResponse struct

+ CreatedTime *string

+ Description *string

+ HttpStatusCode int

+ Name string

+ Option *RunOption

+ RuleConfig *EventStreamingCreateReqRuleConfig

+ Sink *EventStreamingSink

+ Source *EventStreamingSource

+ Status *ShowEventStreamingResponseStatus

+ StreamingId *string

+ UpdatedTime *string

+ XRequestId *string

+ func (o ShowEventStreamingResponse) String() string

+ type ShowEventStreamingResponseStatus struct

+ func (c *ShowEventStreamingResponseStatus) UnmarshalJSON(b []byte) error

+ func (c ShowEventStreamingResponseStatus) MarshalJSON() ([]byte, error)

+ func (c ShowEventStreamingResponseStatus) Value() string

+ type ShowEventStreamingResponseStatusEnum struct

+ CREATED ShowEventStreamingResponseStatus

+ ERROR ShowEventStreamingResponseStatus

+ RUNNING ShowEventStreamingResponseStatus

+ STOPPED ShowEventStreamingResponseStatus

+ func GetShowEventStreamingResponseStatusEnum() ShowEventStreamingResponseStatusEnum

+ type SinkFgParameters struct

+ Agency *string

+ InvokeType *SinkFgParametersInvokeType

+ Urn *string

+ func (o SinkFgParameters) String() string

+ type SinkFgParametersInvokeType struct

+ func (c *SinkFgParametersInvokeType) UnmarshalJSON(b []byte) error

+ func (c SinkFgParametersInvokeType) MarshalJSON() ([]byte, error)

+ func (c SinkFgParametersInvokeType) Value() string

+ type SinkFgParametersInvokeTypeEnum struct

+ SYNCASYNC SinkFgParametersInvokeType

+ func GetSinkFgParametersInvokeTypeEnum() SinkFgParametersInvokeTypeEnum

+ type SourceKafkaMqParameters struct

+ EnableSaslSsl *bool

+ Group string

+ InstanceId *string

+ InstanceName *string

+ Password *string

+ SaslMechanism *string

+ SeekTo *string

+ SslCertificatePwd *string

+ SslCertificateUrl *string

+ Topic string

+ UserName *string

+ func (o SourceKafkaMqParameters) String() string

type SubscriptionSourceProviderTypeEnum

+ PARTNER SubscriptionSourceProviderType

type SubscriptionTarget

+ KafkaDetail *KafkaTargetDetail

type UpdateChannelResponseProviderTypeEnum

+ PARTNER UpdateChannelResponseProviderType

type UpdateConnectionResponse

+ KafkaDetail *KafkaConnectionDetail

+ Type *ConnectionType

type UpdateEventSourceResponseProviderTypeEnum

+ PARTNER UpdateEventSourceResponseProviderType

+ type UpdateEventStreamingRequest struct

+ Body *EventStreamingUpdateReq

+ EventstreamingId string

+ func (o UpdateEventStreamingRequest) String() string

+ type UpdateEventStreamingResponse struct

+ EventStreamingID *string

+ HttpStatusCode int

+ XRequestId *string

+ func (o UpdateEventStreamingResponse) String() string

v0.1.41

May 25, 2023

v0.1.40

May 18, 2023

v0.1.39

May 11, 2023

v0.1.38

Apr 27, 2023

v0.1.37

Apr 20, 2023

v0.1.36

Apr 13, 2023

v0.1.35

Apr 6, 2023

v0.1.34

Mar 30, 2023

v0.1.33

Mar 23, 2023

v0.1.32

Mar 16, 2023

v0.1.31

Mar 14, 2023

v0.1.30

Mar 9, 2023

v0.1.29

Mar 7, 2023

v0.1.28

Mar 2, 2023

Changes in this version

type AgencyCreateReqTypeEnum

+ EG_RESTORE_AGENCY AgencyCreateReqType

+ type CheckPutEventsReq struct

+ Sources *[]CheckPutEventsReqSources

+ func (o CheckPutEventsReq) String() string

+ type CheckPutEventsReqSources struct

+ ChannelId *string

+ SourceName *string

+ func (o CheckPutEventsReqSources) String() string

+ type CheckPutEventsRequest struct

+ Body *CheckPutEventsReq

+ func (o CheckPutEventsRequest) String() string

+ type CheckPutEventsResponse struct

+ FailedCount *int32

+ HttpStatusCode int

+ Sources *[]CheckPutEventsResult

+ XRequestId *string

+ func (o CheckPutEventsResponse) String() string

+ type CheckPutEventsResult struct

+ ChannelId *string

+ CheckDetail *string

+ CheckResult *bool

+ SourceName *string

+ func (o CheckPutEventsResult) String() string

type CreateSubscriptionResponse

+ Used *[]SubscriptionUsedInfo

type CustomizeSourceCreateReqTypeEnum

+ ROCKETMQ CustomizeSourceCreateReqType

+ type EventPubMetricsItem struct

+ EventSize *int64

+ InvokeTime *int64

+ Num *int64

+ ProcessTime *int64

+ SuccessNum *int64

+ Timestamp *int64

+ func (o EventPubMetricsItem) String() string

+ type EventSubMetricsItem struct

+ FailNum *int64

+ InvokeTime *int64

+ Num *int64

+ ProcessTime *int64

+ RetryFailNum *int64

+ RetrySuccessNum *int64

+ RetryTimes *int32

+ SuccessNum *int64

+ Timestamp *int64

+ func (o EventSubMetricsItem) String() string

type ListAgenciesRequestTypeEnum

+ EG_RESTORE_AGENCY ListAgenciesRequestType

+ type ListObsBucketsRequest struct

+ Limit *int32

+ Offset *int32

+ Sort *string

+ func (o ListObsBucketsRequest) String() string

+ type ListObsBucketsResponse struct

+ HttpStatusCode int

+ Items *[]ObsBucketInfo

+ Size *int32

+ Total *int32

+ func (o ListObsBucketsResponse) String() string

+ type ListPubMetricsRequest struct

+ ChannelId string

+ EndTime *int64

+ Filter *ListPubMetricsRequestFilter

+ Period *int32

+ ProviderType *ListPubMetricsRequestProviderType

+ SourceName *string

+ StartTime int64

+ func (o ListPubMetricsRequest) String() string

+ type ListPubMetricsRequestFilter struct

+ func (c *ListPubMetricsRequestFilter) UnmarshalJSON(b []byte) error

+ func (c ListPubMetricsRequestFilter) MarshalJSON() ([]byte, error)

+ func (c ListPubMetricsRequestFilter) Value() string

+ type ListPubMetricsRequestFilterEnum struct

+ AVG ListPubMetricsRequestFilter

+ MAX ListPubMetricsRequestFilter

+ MIN ListPubMetricsRequestFilter

+ func GetListPubMetricsRequestFilterEnum() ListPubMetricsRequestFilterEnum

+ type ListPubMetricsRequestProviderType struct

+ func (c *ListPubMetricsRequestProviderType) UnmarshalJSON(b []byte) error

+ func (c ListPubMetricsRequestProviderType) MarshalJSON() ([]byte, error)

+ func (c ListPubMetricsRequestProviderType) Value() string

+ type ListPubMetricsRequestProviderTypeEnum struct

+ CUSTOM ListPubMetricsRequestProviderType

+ OFFICIAL ListPubMetricsRequestProviderType

+ func GetListPubMetricsRequestProviderTypeEnum() ListPubMetricsRequestProviderTypeEnum

+ type ListPubMetricsResponse struct

+ HttpStatusCode int

+ Result *[]EventPubMetricsItem

+ Total *int32

+ func (o ListPubMetricsResponse) String() string

type ListQuotasRequestTypeEnum

+ SOURCE_ROCKETMQ ListQuotasRequestType

+ type ListSubMetricsRequest struct

+ EndTime *int64

+ Filter *ListSubMetricsRequestFilter

+ Period *int32

+ ProviderType *ListSubMetricsRequestProviderType

+ StartTime int64

+ SubscriptionId string

+ TargetId *string

+ func (o ListSubMetricsRequest) String() string

+ type ListSubMetricsRequestFilter struct

+ func (c *ListSubMetricsRequestFilter) UnmarshalJSON(b []byte) error

+ func (c ListSubMetricsRequestFilter) MarshalJSON() ([]byte, error)

+ func (c ListSubMetricsRequestFilter) Value() string

+ type ListSubMetricsRequestFilterEnum struct

+ AVG ListSubMetricsRequestFilter

+ MAX ListSubMetricsRequestFilter

+ MIN ListSubMetricsRequestFilter

+ func GetListSubMetricsRequestFilterEnum() ListSubMetricsRequestFilterEnum

+ type ListSubMetricsRequestProviderType struct

+ func (c *ListSubMetricsRequestProviderType) UnmarshalJSON(b []byte) error

+ func (c ListSubMetricsRequestProviderType) MarshalJSON() ([]byte, error)

+ func (c ListSubMetricsRequestProviderType) Value() string

+ type ListSubMetricsRequestProviderTypeEnum struct

+ CUSTOM ListSubMetricsRequestProviderType

+ OFFICIAL ListSubMetricsRequestProviderType

+ func GetListSubMetricsRequestProviderTypeEnum() ListSubMetricsRequestProviderTypeEnum

+ type ListSubMetricsResponse struct

+ HttpStatusCode int

+ Result *[]EventSubMetricsItem

+ Total *int32

+ func (o ListSubMetricsResponse) String() string

+ type ListWorkflowTriggersRequest struct

+ Limit *int32

+ Offset *int32

+ Sort *string

+ WorkflowId string

+ func (o ListWorkflowTriggersRequest) String() string

+ type ListWorkflowTriggersResponse struct

+ HttpStatusCode int

+ Items *[]SubscriptionInfo

+ Size *int32

+ Total *int32

+ func (o ListWorkflowTriggersResponse) String() string

+ type ObsBucketInfo struct

+ Acl *interface{}

+ BucketName *string

+ BucketStorageClass *interface{}

+ BucketType *string

+ CreationDate *string

+ Location *string

+ Metadata *interface{}

+ OriginalHeaders *interface{}

+ Owner *ObsBucketInfoOwner

+ RequestId *string

+ ResponseHeaders *interface{}

+ StatusCode *int32

+ StorageClass *interface{}

+ func (o ObsBucketInfo) String() string

+ type ObsBucketInfoOwner struct

+ DisplayName *string

+ Id *string

+ func (o ObsBucketInfoOwner) String() string

type QuotaItemInfoTypeEnum

+ SOURCE_ROCKETMQ QuotaItemInfoType

type ShowDetailOfSubscriptionResponse

+ Used *[]SubscriptionUsedInfo

type SubscriptionInfo

+ Used *[]SubscriptionUsedInfo

+ type SubscriptionUsedInfo struct

+ Description *string

+ Owner *string

+ ResourceId *string

+ func (o SubscriptionUsedInfo) String() string

+ type TransForm struct

+ Template *string

+ Type TransFormType

+ Value *string

+ func (o TransForm) String() string

+ type TransFormType struct

+ func (c *TransFormType) UnmarshalJSON(b []byte) error

+ func (c TransFormType) MarshalJSON() ([]byte, error)

+ func (c TransFormType) Value() string

+ type TransFormTypeEnum struct

+ CONSTANT TransFormType

+ ORIGINAL TransFormType

+ VARIABLE TransFormType

+ func GetTransFormTypeEnum() TransFormTypeEnum

type UpdateSubscriptionResponse

+ Used *[]SubscriptionUsedInfo

v0.1.27

Feb 23, 2023

v0.1.26

Feb 16, 2023

v0.1.25

Feb 9, 2023

v0.1.24

Feb 2, 2023

v0.1.23

Jan 19, 2023

v0.1.22

Jan 12, 2023

v0.1.21

Jan 5, 2023

v0.1.20

Dec 29, 2022

v0.1.19

Dec 26, 2022

v0.1.18

Dec 22, 2022

v0.1.17

Dec 19, 2022

v0.1.16

Dec 15, 2022

v0.1.15

Dec 8, 2022

v0.1.14

Dec 1, 2022

v0.1.13

Nov 30, 2022

v0.1.12

Nov 24, 2022

v0.1.11

Nov 17, 2022

v0.1.10

Nov 14, 2022

v0.1.9

Nov 8, 2022

v0.1.8

Nov 3, 2022

v0.1.7

Nov 2, 2022

v0.1.6

Oct 27, 2022

v0.1.5

Sep 28, 2022

v0.1.4

Sep 26, 2022

v0.1.3

Sep 22, 2022

Changes in this version

+ type AgencyCreateReq struct

+ Type AgencyCreateReqType

+ func (o AgencyCreateReq) String() string

+ type AgencyCreateReqType struct

+ func (c *AgencyCreateReqType) UnmarshalJSON(b []byte) error

+ func (c AgencyCreateReqType) MarshalJSON() ([]byte, error)

+ func (c AgencyCreateReqType) Value() string

+ type AgencyCreateReqTypeEnum struct

+ CUSTOM_SOURCE_RABBITMQ AgencyCreateReqType

+ TARGET_CONNECTION AgencyCreateReqType

+ func GetAgencyCreateReqTypeEnum() AgencyCreateReqTypeEnum

+ type ApiVersionsLinks struct

+ Href *string

+ Rel *string

+ func (o ApiVersionsLinks) String() string

+ type ApiVersionsVersions struct

+ Id *string

+ Links *[]ApiVersionsLinks

+ MinVersion *string

+ Status *ApiVersionsVersionsStatus

+ Updated *string

+ Version *string

+ func (o ApiVersionsVersions) String() string

+ type ApiVersionsVersionsStatus struct

+ func (c *ApiVersionsVersionsStatus) UnmarshalJSON(b []byte) error

+ func (c ApiVersionsVersionsStatus) MarshalJSON() ([]byte, error)

+ func (c ApiVersionsVersionsStatus) Value() string

+ type ApiVersionsVersionsStatusEnum struct

+ CURRENT ApiVersionsVersionsStatus

+ DEPRECATED ApiVersionsVersionsStatus

+ SUPPORTED ApiVersionsVersionsStatus

+ func GetApiVersionsVersionsStatusEnum() ApiVersionsVersionsStatusEnum

+ type ConnectionCreateReq struct

+ Description *string

+ Name string

+ SubnetId *string

+ VpcId *string

+ func (o ConnectionCreateReq) String() string

+ type ConnectionInfo struct

+ Agency *string

+ CreatedTime *string

+ Description *string

+ Flavor *ConnectionInfoFlavor

+ Id *string

+ Name *string

+ Status *ConnectionInfoStatus

+ SubnetId *string

+ UpdatedTime *string

+ VpcId *string

+ func (o ConnectionInfo) String() string

+ type ConnectionInfoFlavor struct

+ BandwidthType *ConnectionInfoFlavorBandwidthType

+ Concurrency *int32

+ ConcurrencyType *ConnectionInfoFlavorConcurrencyType

+ Name *string

+ func (o ConnectionInfoFlavor) String() string

+ type ConnectionInfoFlavorBandwidthType struct

+ func (c *ConnectionInfoFlavorBandwidthType) UnmarshalJSON(b []byte) error

+ func (c ConnectionInfoFlavorBandwidthType) MarshalJSON() ([]byte, error)

+ func (c ConnectionInfoFlavorBandwidthType) Value() string

+ type ConnectionInfoFlavorBandwidthTypeEnum struct

+ EXCLUSIVE ConnectionInfoFlavorBandwidthType

+ SHARED ConnectionInfoFlavorBandwidthType

+ func GetConnectionInfoFlavorBandwidthTypeEnum() ConnectionInfoFlavorBandwidthTypeEnum

+ type ConnectionInfoFlavorConcurrencyType struct

+ func (c *ConnectionInfoFlavorConcurrencyType) UnmarshalJSON(b []byte) error

+ func (c ConnectionInfoFlavorConcurrencyType) MarshalJSON() ([]byte, error)

+ func (c ConnectionInfoFlavorConcurrencyType) Value() string

+ type ConnectionInfoFlavorConcurrencyTypeEnum struct

+ EXCLUSIVE ConnectionInfoFlavorConcurrencyType

+ SHARED ConnectionInfoFlavorConcurrencyType

+ func GetConnectionInfoFlavorConcurrencyTypeEnum() ConnectionInfoFlavorConcurrencyTypeEnum

+ type ConnectionInfoStatus struct

+ func (c *ConnectionInfoStatus) UnmarshalJSON(b []byte) error

+ func (c ConnectionInfoStatus) MarshalJSON() ([]byte, error)

+ func (c ConnectionInfoStatus) Value() string

+ type ConnectionInfoStatusEnum struct

+ CREATED ConnectionInfoStatus

+ CREATE_FAILED ConnectionInfoStatus

+ CREATING ConnectionInfoStatus

+ func GetConnectionInfoStatusEnum() ConnectionInfoStatusEnum

+ type ConnectionUpdateReq struct

+ Description *string

+ func (o ConnectionUpdateReq) String() string

+ type CreateAgenciesRequest struct

+ Body *AgencyCreateReq

+ func (o CreateAgenciesRequest) String() string

+ type CreateAgenciesResponse struct

+ Agencies *[]string

+ HttpStatusCode int

+ func (o CreateAgenciesResponse) String() string

type CreateChannelResponse

+ XRequestId *string

+ type CreateConnectionRequest struct

+ Body *ConnectionCreateReq

+ func (o CreateConnectionRequest) String() string

+ type CreateConnectionResponse struct

+ Agency *string

+ CreatedTime *string

+ Description *string

+ Flavor *ConnectionInfoFlavor

+ HttpStatusCode int

+ Id *string

+ Name *string

+ Status *CreateConnectionResponseStatus

+ SubnetId *string

+ UpdatedTime *string

+ VpcId *string

+ XRequestId *string

+ func (o CreateConnectionResponse) String() string

+ type CreateConnectionResponseStatus struct

+ func (c *CreateConnectionResponseStatus) UnmarshalJSON(b []byte) error

+ func (c CreateConnectionResponseStatus) MarshalJSON() ([]byte, error)

+ func (c CreateConnectionResponseStatus) Value() string

+ type CreateConnectionResponseStatusEnum struct

+ CREATED CreateConnectionResponseStatus

+ CREATE_FAILED CreateConnectionResponseStatus

+ CREATING CreateConnectionResponseStatus

+ func GetCreateConnectionResponseStatusEnum() CreateConnectionResponseStatusEnum

+ type CreateEndpointRequest struct

+ Body *EndpointCreateReq

+ func (o CreateEndpointRequest) String() string

+ type CreateEndpointResponse struct

+ CreatedTime *string

+ Description *string

+ Domain *string

+ Endpoints *[]EndpointConnection

+ HttpStatusCode int

+ Id *string

+ Name *string

+ Scalable *bool

+ Status *CreateEndpointResponseStatus

+ SubnetId *string

+ Type *CreateEndpointResponseType

+ UpdatedTime *string

+ VpcId *string

+ XRequestId *string

+ func (o CreateEndpointResponse) String() string

+ type CreateEndpointResponseStatus struct

+ func (c *CreateEndpointResponseStatus) UnmarshalJSON(b []byte) error

+ func (c CreateEndpointResponseStatus) MarshalJSON() ([]byte, error)

+ func (c CreateEndpointResponseStatus) Value() string

+ type CreateEndpointResponseStatusEnum struct

+ CREATED CreateEndpointResponseStatus

+ CREATE_FAILED CreateEndpointResponseStatus

+ CREATING CreateEndpointResponseStatus

+ DELETE_FAILED CreateEndpointResponseStatus

+ func GetCreateEndpointResponseStatusEnum() CreateEndpointResponseStatusEnum

+ type CreateEndpointResponseType struct

+ func (c *CreateEndpointResponseType) UnmarshalJSON(b []byte) error

+ func (c CreateEndpointResponseType) MarshalJSON() ([]byte, error)

+ func (c CreateEndpointResponseType) Value() string

+ type CreateEndpointResponseTypeEnum struct

+ PRIVATE CreateEndpointResponseType

+ PUBLIC CreateEndpointResponseType

+ func GetCreateEndpointResponseTypeEnum() CreateEndpointResponseTypeEnum

+ type CreateEventSchemaRequest struct

+ Body *CustomizeSchemaCreateReq

+ func (o CreateEventSchemaRequest) String() string

+ type CreateEventSchemaResponse struct

+ Compatibility *CreateEventSchemaResponseCompatibility

+ CreatedTime *string

+ DataSample *string

+ Definition *string

+ Description *string

+ Format *string

+ HttpStatusCode int

+ Id *string

+ Name *string

+ NumberOfVersions *int32

+ ProviderType *CreateEventSchemaResponseProviderType

+ UpdatedTime *string

+ Version *int32

+ XRequestId *string

+ func (o CreateEventSchemaResponse) String() string

+ type CreateEventSchemaResponseCompatibility struct

+ func (c *CreateEventSchemaResponseCompatibility) UnmarshalJSON(b []byte) error

+ func (c CreateEventSchemaResponseCompatibility) MarshalJSON() ([]byte, error)

+ func (c CreateEventSchemaResponseCompatibility) Value() string

+ type CreateEventSchemaResponseCompatibilityEnum struct

+ BACKWARD CreateEventSchemaResponseCompatibility

+ FORWARD CreateEventSchemaResponseCompatibility

+ FULL CreateEventSchemaResponseCompatibility

+ NONE CreateEventSchemaResponseCompatibility

+ func GetCreateEventSchemaResponseCompatibilityEnum() CreateEventSchemaResponseCompatibilityEnum

+ type CreateEventSchemaResponseProviderType struct

+ func (c *CreateEventSchemaResponseProviderType) UnmarshalJSON(b []byte) error

+ func (c CreateEventSchemaResponseProviderType) MarshalJSON() ([]byte, error)

+ func (c CreateEventSchemaResponseProviderType) Value() string

+ type CreateEventSchemaResponseProviderTypeEnum struct

+ CUSTOM CreateEventSchemaResponseProviderType

+ OFFICIAL CreateEventSchemaResponseProviderType

+ func GetCreateEventSchemaResponseProviderTypeEnum() CreateEventSchemaResponseProviderTypeEnum

+ type CreateEventSchemaVersionRequest struct

+ Body *CustomizeSchemaVersionCreateReq

+ SchemaId string

+ func (o CreateEventSchemaVersionRequest) String() string

+ type CreateEventSchemaVersionResponse struct

+ CreatedTime *string

+ DataSample *string

+ Definition *string

+ Format *string

+ HttpStatusCode int

+ Id *string

+ SchemaId *string

+ UpdatedTime *string

+ Version *int32

+ XRequestId *string

+ func (o CreateEventSchemaVersionResponse) String() string

type CreateEventSourceResponse

+ Detail *interface{}

+ EventTypes *[]CustomizeSourceInfoEventTypes

+ Status *CreateEventSourceResponseStatus

+ Type *string

+ XRequestId *string

+ type CreateEventSourceResponseStatus struct

+ func (c *CreateEventSourceResponseStatus) UnmarshalJSON(b []byte) error

+ func (c CreateEventSourceResponseStatus) MarshalJSON() ([]byte, error)

+ func (c CreateEventSourceResponseStatus) Value() string

+ type CreateEventSourceResponseStatusEnum struct

+ CREATE_FAILED CreateEventSourceResponseStatus

+ ERROR CreateEventSourceResponseStatus

+ RUNNING CreateEventSourceResponseStatus

+ func GetCreateEventSourceResponseStatusEnum() CreateEventSourceResponseStatusEnum

type CreateSubscriptionResponse

+ XRequestId *string

type CreateSubscriptionTargetResponse

+ ConnectionId *string

+ XRequestId *string

+ type CustomizeSchemaCreateReq struct

+ Compatibility CustomizeSchemaCreateReqCompatibility

+ DataSample *string

+ Definition string

+ Description *string

+ Format *CustomizeSchemaCreateReqFormat

+ Name string

+ func (o CustomizeSchemaCreateReq) String() string

+ type CustomizeSchemaCreateReqCompatibility struct

+ func (c *CustomizeSchemaCreateReqCompatibility) UnmarshalJSON(b []byte) error

+ func (c CustomizeSchemaCreateReqCompatibility) MarshalJSON() ([]byte, error)

+ func (c CustomizeSchemaCreateReqCompatibility) Value() string

+ type CustomizeSchemaCreateReqCompatibilityEnum struct

+ BACKWARD CustomizeSchemaCreateReqCompatibility

+ FORWARD CustomizeSchemaCreateReqCompatibility

+ FULL CustomizeSchemaCreateReqCompatibility

+ NONE CustomizeSchemaCreateReqCompatibility

+ func GetCustomizeSchemaCreateReqCompatibilityEnum() CustomizeSchemaCreateReqCompatibilityEnum

+ type CustomizeSchemaCreateReqFormat struct

+ func (c *CustomizeSchemaCreateReqFormat) UnmarshalJSON(b []byte) error

+ func (c CustomizeSchemaCreateReqFormat) MarshalJSON() ([]byte, error)

+ func (c CustomizeSchemaCreateReqFormat) Value() string

+ type CustomizeSchemaCreateReqFormatEnum struct

+ JSON_SCHEMA_DRAFT_6 CustomizeSchemaCreateReqFormat

+ func GetCustomizeSchemaCreateReqFormatEnum() CustomizeSchemaCreateReqFormatEnum

+ type CustomizeSchemaItemInfo struct

+ Compatibility *CustomizeSchemaItemInfoCompatibility

+ CreatedTime *string

+ Description *string

+ Format *string

+ Id *string

+ Name *string

+ NumberOfVersions *int32

+ ProviderType *CustomizeSchemaItemInfoProviderType

+ UpdatedTime *string

+ func (o CustomizeSchemaItemInfo) String() string

+ type CustomizeSchemaItemInfoCompatibility struct

+ func (c *CustomizeSchemaItemInfoCompatibility) UnmarshalJSON(b []byte) error

+ func (c CustomizeSchemaItemInfoCompatibility) MarshalJSON() ([]byte, error)

+ func (c CustomizeSchemaItemInfoCompatibility) Value() string

+ type CustomizeSchemaItemInfoCompatibilityEnum struct

+ BACKWARD CustomizeSchemaItemInfoCompatibility

+ FORWARD CustomizeSchemaItemInfoCompatibility

+ FULL CustomizeSchemaItemInfoCompatibility

+ NONE CustomizeSchemaItemInfoCompatibility

+ func GetCustomizeSchemaItemInfoCompatibilityEnum() CustomizeSchemaItemInfoCompatibilityEnum

+ type CustomizeSchemaItemInfoProviderType struct

+ func (c *CustomizeSchemaItemInfoProviderType) UnmarshalJSON(b []byte) error

+ func (c CustomizeSchemaItemInfoProviderType) MarshalJSON() ([]byte, error)

+ func (c CustomizeSchemaItemInfoProviderType) Value() string

+ type CustomizeSchemaItemInfoProviderTypeEnum struct

+ CUSTOM CustomizeSchemaItemInfoProviderType

+ OFFICIAL CustomizeSchemaItemInfoProviderType

+ func GetCustomizeSchemaItemInfoProviderTypeEnum() CustomizeSchemaItemInfoProviderTypeEnum

+ type CustomizeSchemaUpdateReq struct

+ Compatibility *CustomizeSchemaUpdateReqCompatibility

+ Description *string

+ func (o CustomizeSchemaUpdateReq) String() string

+ type CustomizeSchemaUpdateReqCompatibility struct

+ func (c *CustomizeSchemaUpdateReqCompatibility) UnmarshalJSON(b []byte) error

+ func (c CustomizeSchemaUpdateReqCompatibility) MarshalJSON() ([]byte, error)

+ func (c CustomizeSchemaUpdateReqCompatibility) Value() string

+ type CustomizeSchemaUpdateReqCompatibilityEnum struct

+ BACKWARD CustomizeSchemaUpdateReqCompatibility

+ FORWARD CustomizeSchemaUpdateReqCompatibility

+ FULL CustomizeSchemaUpdateReqCompatibility

+ NONE CustomizeSchemaUpdateReqCompatibility

+ func GetCustomizeSchemaUpdateReqCompatibilityEnum() CustomizeSchemaUpdateReqCompatibilityEnum

+ type CustomizeSchemaVersionCreateReq struct

+ DataSample *string

+ Definition *string

+ func (o CustomizeSchemaVersionCreateReq) String() string

+ type CustomizeSchemaVersionItemInfo struct

+ CreatedTime *string

+ Id *string

+ UpdatedTime *string

+ Version *int32

+ func (o CustomizeSchemaVersionItemInfo) String() string

type CustomizeSourceCreateReq

+ Detail *interface{}

+ Type *CustomizeSourceCreateReqType

+ type CustomizeSourceCreateReqType struct

+ func (c *CustomizeSourceCreateReqType) UnmarshalJSON(b []byte) error

+ func (c CustomizeSourceCreateReqType) MarshalJSON() ([]byte, error)

+ func (c CustomizeSourceCreateReqType) Value() string

+ type CustomizeSourceCreateReqTypeEnum struct

+ APPLICATION CustomizeSourceCreateReqType

+ RABBITMQ CustomizeSourceCreateReqType

+ func GetCustomizeSourceCreateReqTypeEnum() CustomizeSourceCreateReqTypeEnum

+ type CustomizeSourceInfo struct

+ ChannelId *string

+ ChannelName *string

+ CreatedTime *string

+ Description *string

+ Detail *interface{}

+ EventTypes *[]CustomizeSourceInfoEventTypes

+ Id *string

+ Label *string

+ Name *string

+ ProviderType *CustomizeSourceInfoProviderType

+ Status *CustomizeSourceInfoStatus

+ Type *string

+ UpdatedTime *string

+ func (o CustomizeSourceInfo) String() string

+ type CustomizeSourceInfoEventTypes struct

+ Description *string

+ Name *string

+ func (o CustomizeSourceInfoEventTypes) String() string

+ type CustomizeSourceInfoProviderType struct

+ func (c *CustomizeSourceInfoProviderType) UnmarshalJSON(b []byte) error

+ func (c CustomizeSourceInfoProviderType) MarshalJSON() ([]byte, error)

+ func (c CustomizeSourceInfoProviderType) Value() string

+ type CustomizeSourceInfoProviderTypeEnum struct

+ CUSTOM CustomizeSourceInfoProviderType

+ OFFICIAL CustomizeSourceInfoProviderType

+ func GetCustomizeSourceInfoProviderTypeEnum() CustomizeSourceInfoProviderTypeEnum

+ type CustomizeSourceInfoStatus struct

+ func (c *CustomizeSourceInfoStatus) UnmarshalJSON(b []byte) error

+ func (c CustomizeSourceInfoStatus) MarshalJSON() ([]byte, error)

+ func (c CustomizeSourceInfoStatus) Value() string

+ type CustomizeSourceInfoStatusEnum struct

+ CREATE_FAILED CustomizeSourceInfoStatus

+ ERROR CustomizeSourceInfoStatus

+ RUNNING CustomizeSourceInfoStatus

+ func GetCustomizeSourceInfoStatusEnum() CustomizeSourceInfoStatusEnum

type CustomizeSourceUpdateReq

+ Detail *interface{}

+ type DeleteConnectionRequest struct

+ ConnectionId string

+ func (o DeleteConnectionRequest) String() string

+ type DeleteConnectionResponse struct

+ HttpStatusCode int

+ func (o DeleteConnectionResponse) String() string

+ type DeleteEndpointRequest struct

+ EndpointId string

+ func (o DeleteEndpointRequest) String() string

+ type DeleteEndpointResponse struct

+ HttpStatusCode int

+ func (o DeleteEndpointResponse) String() string

+ type DeleteEventSchemaRequest struct

+ SchemaId string

+ func (o DeleteEventSchemaRequest) String() string

+ type DeleteEventSchemaResponse struct

+ HttpStatusCode int

+ func (o DeleteEventSchemaResponse) String() string

+ type DeleteEventSchemaVersionRequest struct

+ SchemaId string

+ Version int32

+ func (o DeleteEventSchemaVersionRequest) String() string

+ type DeleteEventSchemaVersionResponse struct

+ HttpStatusCode int

+ func (o DeleteEventSchemaVersionResponse) String() string

+ type DiscoverEventSchemaFromDataReq struct

+ Event string

+ Format *DiscoverEventSchemaFromDataReqFormat

+ func (o DiscoverEventSchemaFromDataReq) String() string

+ type DiscoverEventSchemaFromDataReqFormat struct

+ func (c *DiscoverEventSchemaFromDataReqFormat) UnmarshalJSON(b []byte) error

+ func (c DiscoverEventSchemaFromDataReqFormat) MarshalJSON() ([]byte, error)

+ func (c DiscoverEventSchemaFromDataReqFormat) Value() string

+ type DiscoverEventSchemaFromDataReqFormatEnum struct

+ JSON_SCHEMA_DRAFT_6 DiscoverEventSchemaFromDataReqFormat

+ func GetDiscoverEventSchemaFromDataReqFormatEnum() DiscoverEventSchemaFromDataReqFormatEnum

+ type DiscoverEventSchemaFromDataRequest struct

+ Body *DiscoverEventSchemaFromDataReq

+ func (o DiscoverEventSchemaFromDataRequest) String() string

+ type DiscoverEventSchemaFromDataResponse struct

+ Definition *string

+ HttpStatusCode int

+ XRequestId *string

+ func (o DiscoverEventSchemaFromDataResponse) String() string

+ type EndpointConnection struct

+ CreatedTime *string

+ EndpointServiceId *string

+ EndpointServiceName *string

+ Id *string

+ Ip *string

+ MarkerId *string

+ func (o EndpointConnection) String() string

+ type EndpointCreateReq struct

+ Description *string

+ Name string

+ SubnetId string

+ VpcId string

+ func (o EndpointCreateReq) String() string

+ type EndpointInfo struct

+ CreatedTime *string

+ Description *string

+ Domain *string

+ Endpoints *[]EndpointConnection

+ Id *string

+ Name *string

+ Scalable *bool

+ Status *EndpointInfoStatus

+ SubnetId *string

+ Type *EndpointInfoType

+ UpdatedTime *string

+ VpcId *string

+ func (o EndpointInfo) String() string

+ type EndpointInfoStatus struct

+ func (c *EndpointInfoStatus) UnmarshalJSON(b []byte) error

+ func (c EndpointInfoStatus) MarshalJSON() ([]byte, error)

+ func (c EndpointInfoStatus) Value() string

+ type EndpointInfoStatusEnum struct

+ CREATED EndpointInfoStatus

+ CREATE_FAILED EndpointInfoStatus

+ CREATING EndpointInfoStatus

+ DELETE_FAILED EndpointInfoStatus

+ func GetEndpointInfoStatusEnum() EndpointInfoStatusEnum

+ type EndpointInfoType struct

+ func (c *EndpointInfoType) UnmarshalJSON(b []byte) error

+ func (c EndpointInfoType) MarshalJSON() ([]byte, error)

+ func (c EndpointInfoType) Value() string

+ type EndpointInfoTypeEnum struct

+ PRIVATE EndpointInfoType

+ PUBLIC EndpointInfoType

+ func GetEndpointInfoTypeEnum() EndpointInfoTypeEnum

+ type EndpointUpdateReq struct

+ Description *string

+ func (o EndpointUpdateReq) String() string

+ type ListAgenciesRequest struct

+ Type ListAgenciesRequestType

+ func (o ListAgenciesRequest) String() string

+ type ListAgenciesRequestType struct

+ func (c *ListAgenciesRequestType) UnmarshalJSON(b []byte) error

+ func (c ListAgenciesRequestType) MarshalJSON() ([]byte, error)

+ func (c ListAgenciesRequestType) Value() string

+ type ListAgenciesRequestTypeEnum struct

+ CUSTOM_SOURCE_RABBITMQ ListAgenciesRequestType

+ TARGET_CONNECTION ListAgenciesRequestType

+ func GetListAgenciesRequestTypeEnum() ListAgenciesRequestTypeEnum

+ type ListAgenciesResponse struct

+ Agencies *[]string

+ HttpStatusCode int

+ func (o ListAgenciesResponse) String() string

+ type ListApiVersionsRequest struct

+ func (o ListApiVersionsRequest) String() string

+ type ListApiVersionsResponse struct

+ HttpStatusCode int

+ Versions *[]ApiVersionsVersions

+ func (o ListApiVersionsResponse) String() string

+ type ListConnectionsRequest struct

+ FuzzyName *string

+ Limit *int32

+ Name *string

+ Offset *int32

+ Sort *string

+ func (o ListConnectionsRequest) String() string

+ type ListConnectionsResponse struct

+ HttpStatusCode int

+ Items *[]ConnectionInfo

+ Size *int32

+ Total *int32

+ func (o ListConnectionsResponse) String() string

+ type ListEndpointsRequest struct

+ FuzzyName *string

+ Limit *int32

+ Name *string

+ Offset *int32

+ Sort *string

+ Type *ListEndpointsRequestType

+ VpcId *string

+ func (o ListEndpointsRequest) String() string

+ type ListEndpointsRequestType struct

+ func (c *ListEndpointsRequestType) UnmarshalJSON(b []byte) error

+ func (c ListEndpointsRequestType) MarshalJSON() ([]byte, error)

+ func (c ListEndpointsRequestType) Value() string

+ type ListEndpointsRequestTypeEnum struct

+ PRIVATE ListEndpointsRequestType

+ PUBLIC ListEndpointsRequestType

+ func GetListEndpointsRequestTypeEnum() ListEndpointsRequestTypeEnum

+ type ListEndpointsResponse struct

+ HttpStatusCode int

+ Items *[]EndpointInfo

+ Size *int32

+ Total *int32

+ XRequestId *string

+ func (o ListEndpointsResponse) String() string

+ type ListEventSchemaRequest struct

+ FuzzyName *string

+ Limit *int32

+ Name *string

+ Offset *int32

+ ProviderType *ListEventSchemaRequestProviderType

+ Sort *string

+ func (o ListEventSchemaRequest) String() string

+ type ListEventSchemaRequestProviderType struct

+ func (c *ListEventSchemaRequestProviderType) UnmarshalJSON(b []byte) error

+ func (c ListEventSchemaRequestProviderType) MarshalJSON() ([]byte, error)

+ func (c ListEventSchemaRequestProviderType) Value() string

+ type ListEventSchemaRequestProviderTypeEnum struct

+ CUSTOM ListEventSchemaRequestProviderType

+ OFFICIAL ListEventSchemaRequestProviderType

+ func GetListEventSchemaRequestProviderTypeEnum() ListEventSchemaRequestProviderTypeEnum

+ type ListEventSchemaResponse struct

+ HttpStatusCode int

+ Items *[]CustomizeSchemaItemInfo

+ Size *int32

+ Total *int32

+ func (o ListEventSchemaResponse) String() string

+ type ListEventSchemaVersionsRequest struct

+ Limit *int32

+ Offset *int32

+ SchemaId string

+ Sort *string

+ func (o ListEventSchemaVersionsRequest) String() string

+ type ListEventSchemaVersionsResponse struct

+ HttpStatusCode int

+ Items *[]CustomizeSchemaVersionItemInfo

+ Size *int32

+ Total *int32

+ func (o ListEventSchemaVersionsResponse) String() string

type ListQuotasRequestTypeEnum

+ CONNECTION ListQuotasRequestType

+ PRIVATE_ENDPOINT ListQuotasRequestType

+ SOURCE_RABBITMQ ListQuotasRequestType

+ type ListTriggersRequest struct

+ FuncUrn string

+ Limit *int32

+ Offset *int32

+ Sort *string

+ func (o ListTriggersRequest) String() string

+ type ListTriggersResponse struct

+ HttpStatusCode int

+ Items *[]SubscriptionInfo

+ Size *int32

+ Total *int32

+ func (o ListTriggersResponse) String() string

type OperateSubscriptionResponse

+ XRequestId *string

type PutEventsResponse

+ XRequestId *string

type QuotaItemInfoTypeEnum

+ CONNECTION QuotaItemInfoType

+ PRIVATE_ENDPOINT QuotaItemInfoType

+ SOURCE_RABBITMQ QuotaItemInfoType

+ type ShowDetailOfConnectionRequest struct

+ ConnectionId string

+ func (o ShowDetailOfConnectionRequest) String() string

+ type ShowDetailOfConnectionResponse struct

+ Agency *string

+ CreatedTime *string

+ Description *string

+ Flavor *ConnectionInfoFlavor

+ HttpStatusCode int

+ Id *string

+ Name *string

+ Status *ShowDetailOfConnectionResponseStatus

+ SubnetId *string

+ UpdatedTime *string

+ VpcId *string

+ func (o ShowDetailOfConnectionResponse) String() string

+ type ShowDetailOfConnectionResponseStatus struct

+ func (c *ShowDetailOfConnectionResponseStatus) UnmarshalJSON(b []byte) error

+ func (c ShowDetailOfConnectionResponseStatus) MarshalJSON() ([]byte, error)

+ func (c ShowDetailOfConnectionResponseStatus) Value() string

+ type ShowDetailOfConnectionResponseStatusEnum struct

+ CREATED ShowDetailOfConnectionResponseStatus

+ CREATE_FAILED ShowDetailOfConnectionResponseStatus

+ CREATING ShowDetailOfConnectionResponseStatus

+ func GetShowDetailOfConnectionResponseStatusEnum() ShowDetailOfConnectionResponseStatusEnum

+ type ShowDetailOfEventSchemaRequest struct

+ SchemaId string

+ func (o ShowDetailOfEventSchemaRequest) String() string

+ type ShowDetailOfEventSchemaResponse struct

+ Compatibility *ShowDetailOfEventSchemaResponseCompatibility

+ CreatedTime *string

+ DataSample *string

+ Definition *string

+ Description *string

+ Format *string

+ HttpStatusCode int

+ Id *string

+ Name *string

+ NumberOfVersions *int32

+ ProviderType *ShowDetailOfEventSchemaResponseProviderType

+ UpdatedTime *string

+ Version *int32

+ func (o ShowDetailOfEventSchemaResponse) String() string

+ type ShowDetailOfEventSchemaResponseCompatibility struct

+ func (c *ShowDetailOfEventSchemaResponseCompatibility) UnmarshalJSON(b []byte) error

+ func (c ShowDetailOfEventSchemaResponseCompatibility) MarshalJSON() ([]byte, error)

+ func (c ShowDetailOfEventSchemaResponseCompatibility) Value() string

+ type ShowDetailOfEventSchemaResponseCompatibilityEnum struct

+ BACKWARD ShowDetailOfEventSchemaResponseCompatibility

+ FORWARD ShowDetailOfEventSchemaResponseCompatibility

+ FULL ShowDetailOfEventSchemaResponseCompatibility

+ NONE ShowDetailOfEventSchemaResponseCompatibility

+ func GetShowDetailOfEventSchemaResponseCompatibilityEnum() ShowDetailOfEventSchemaResponseCompatibilityEnum

+ type ShowDetailOfEventSchemaResponseProviderType struct

+ func (c *ShowDetailOfEventSchemaResponseProviderType) UnmarshalJSON(b []byte) error

+ func (c ShowDetailOfEventSchemaResponseProviderType) MarshalJSON() ([]byte, error)

+ func (c ShowDetailOfEventSchemaResponseProviderType) Value() string

+ type ShowDetailOfEventSchemaResponseProviderTypeEnum struct

+ CUSTOM ShowDetailOfEventSchemaResponseProviderType

+ OFFICIAL ShowDetailOfEventSchemaResponseProviderType

+ func GetShowDetailOfEventSchemaResponseProviderTypeEnum() ShowDetailOfEventSchemaResponseProviderTypeEnum

+ type ShowDetailOfEventSchemaVersionRequest struct

+ SchemaId string

+ Version int32

+ func (o ShowDetailOfEventSchemaVersionRequest) String() string

+ type ShowDetailOfEventSchemaVersionResponse struct

+ CreatedTime *string

+ DataSample *string

+ Definition *string

+ Format *string

+ HttpStatusCode int

+ Id *string

+ SchemaId *string

+ UpdatedTime *string

+ Version *int32

+ func (o ShowDetailOfEventSchemaVersionResponse) String() string

type ShowDetailOfEventSourceResponse

+ Detail *interface{}

+ EventTypes *[]CustomizeSourceInfoEventTypes

+ Status *ShowDetailOfEventSourceResponseStatus

+ Type *string

+ type ShowDetailOfEventSourceResponseStatus struct

+ func (c *ShowDetailOfEventSourceResponseStatus) UnmarshalJSON(b []byte) error

+ func (c ShowDetailOfEventSourceResponseStatus) MarshalJSON() ([]byte, error)

+ func (c ShowDetailOfEventSourceResponseStatus) Value() string

+ type ShowDetailOfEventSourceResponseStatusEnum struct

+ CREATE_FAILED ShowDetailOfEventSourceResponseStatus

+ ERROR ShowDetailOfEventSourceResponseStatus

+ RUNNING ShowDetailOfEventSourceResponseStatus

+ func GetShowDetailOfEventSourceResponseStatusEnum() ShowDetailOfEventSourceResponseStatusEnum

type ShowDetailOfSubscriptionTargetResponse

+ ConnectionId *string

type SubscriptionTarget

+ ConnectionId *string

type SubscriptionTargetInfo

+ ConnectionId *string

type UpdateChannelResponse

+ XRequestId *string

+ type UpdateConnectionRequest struct

+ Body *ConnectionUpdateReq

+ ConnectionId string

+ func (o UpdateConnectionRequest) String() string

+ type UpdateConnectionResponse struct

+ Agency *string

+ CreatedTime *string

+ Description *string

+ Flavor *ConnectionInfoFlavor

+ HttpStatusCode int

+ Id *string

+ Name *string

+ Status *UpdateConnectionResponseStatus

+ SubnetId *string

+ UpdatedTime *string

+ VpcId *string

+ XRequestId *string

+ func (o UpdateConnectionResponse) String() string

+ type UpdateConnectionResponseStatus struct

+ func (c *UpdateConnectionResponseStatus) UnmarshalJSON(b []byte) error

+ func (c UpdateConnectionResponseStatus) MarshalJSON() ([]byte, error)

+ func (c UpdateConnectionResponseStatus) Value() string

+ type UpdateConnectionResponseStatusEnum struct

+ CREATED UpdateConnectionResponseStatus

+ CREATE_FAILED UpdateConnectionResponseStatus

+ CREATING UpdateConnectionResponseStatus

+ func GetUpdateConnectionResponseStatusEnum() UpdateConnectionResponseStatusEnum

+ type UpdateEndpointRequest struct

+ Body *EndpointUpdateReq

+ EndpointId string

+ func (o UpdateEndpointRequest) String() string

+ type UpdateEndpointResponse struct

+ CreatedTime *string

+ Description *string

+ Domain *string

+ Endpoints *[]EndpointConnection

+ HttpStatusCode int

+ Id *string

+ Name *string

+ Scalable *bool

+ Status *UpdateEndpointResponseStatus

+ SubnetId *string

+ Type *UpdateEndpointResponseType

+ UpdatedTime *string

+ VpcId *string

+ func (o UpdateEndpointResponse) String() string

+ type UpdateEndpointResponseStatus struct

+ func (c *UpdateEndpointResponseStatus) UnmarshalJSON(b []byte) error

+ func (c UpdateEndpointResponseStatus) MarshalJSON() ([]byte, error)

+ func (c UpdateEndpointResponseStatus) Value() string

+ type UpdateEndpointResponseStatusEnum struct

+ CREATED UpdateEndpointResponseStatus

+ CREATE_FAILED UpdateEndpointResponseStatus

+ CREATING UpdateEndpointResponseStatus

+ DELETE_FAILED UpdateEndpointResponseStatus

+ func GetUpdateEndpointResponseStatusEnum() UpdateEndpointResponseStatusEnum

+ type UpdateEndpointResponseType struct

+ func (c *UpdateEndpointResponseType) UnmarshalJSON(b []byte) error

+ func (c UpdateEndpointResponseType) MarshalJSON() ([]byte, error)

+ func (c UpdateEndpointResponseType) Value() string

+ type UpdateEndpointResponseTypeEnum struct

+ PRIVATE UpdateEndpointResponseType

+ PUBLIC UpdateEndpointResponseType

+ func GetUpdateEndpointResponseTypeEnum() UpdateEndpointResponseTypeEnum

+ type UpdateEventSchemaRequest struct

+ Body *CustomizeSchemaUpdateReq

+ SchemaId string

+ func (o UpdateEventSchemaRequest) String() string

+ type UpdateEventSchemaResponse struct

+ Compatibility *UpdateEventSchemaResponseCompatibility

+ CreatedTime *string

+ DataSample *string

+ Definition *string

+ Description *string

+ Format *string

+ HttpStatusCode int

+ Id *string

+ Name *string

+ NumberOfVersions *int32

+ ProviderType *UpdateEventSchemaResponseProviderType

+ UpdatedTime *string

+ Version *int32

+ XRequestId *string

+ func (o UpdateEventSchemaResponse) String() string

+ type UpdateEventSchemaResponseCompatibility struct

+ func (c *UpdateEventSchemaResponseCompatibility) UnmarshalJSON(b []byte) error

+ func (c UpdateEventSchemaResponseCompatibility) MarshalJSON() ([]byte, error)

+ func (c UpdateEventSchemaResponseCompatibility) Value() string

+ type UpdateEventSchemaResponseCompatibilityEnum struct

+ BACKWARD UpdateEventSchemaResponseCompatibility

+ FORWARD UpdateEventSchemaResponseCompatibility

+ FULL UpdateEventSchemaResponseCompatibility

+ NONE UpdateEventSchemaResponseCompatibility

+ func GetUpdateEventSchemaResponseCompatibilityEnum() UpdateEventSchemaResponseCompatibilityEnum

+ type UpdateEventSchemaResponseProviderType struct

+ func (c *UpdateEventSchemaResponseProviderType) UnmarshalJSON(b []byte) error

+ func (c UpdateEventSchemaResponseProviderType) MarshalJSON() ([]byte, error)

+ func (c UpdateEventSchemaResponseProviderType) Value() string

+ type UpdateEventSchemaResponseProviderTypeEnum struct

+ CUSTOM UpdateEventSchemaResponseProviderType

+ OFFICIAL UpdateEventSchemaResponseProviderType

+ func GetUpdateEventSchemaResponseProviderTypeEnum() UpdateEventSchemaResponseProviderTypeEnum

type UpdateEventSourceResponse

+ Detail *interface{}

+ EventTypes *[]CustomizeSourceInfoEventTypes

+ Status *UpdateEventSourceResponseStatus

+ Type *string

+ XRequestId *string

+ type UpdateEventSourceResponseStatus struct

+ func (c *UpdateEventSourceResponseStatus) UnmarshalJSON(b []byte) error

+ func (c UpdateEventSourceResponseStatus) MarshalJSON() ([]byte, error)

+ func (c UpdateEventSourceResponseStatus) Value() string

+ type UpdateEventSourceResponseStatusEnum struct

+ CREATE_FAILED UpdateEventSourceResponseStatus

+ ERROR UpdateEventSourceResponseStatus

+ RUNNING UpdateEventSourceResponseStatus

+ func GetUpdateEventSourceResponseStatusEnum() UpdateEventSourceResponseStatusEnum

type UpdateSubscriptionResponse

+ XRequestId *string

type UpdateSubscriptionSourceResponse

+ XRequestId *string

type UpdateSubscriptionTargetResponse

+ ConnectionId *string

+ XRequestId *string

v0.1.2

Sep 15, 2022

v0.1.1

Sep 8, 2022

v0.0.108

Sep 1, 2022

v0.0.107

Aug 29, 2022

v0.0.106

Aug 25, 2022

v0.0.105

Aug 22, 2022

v0.0.104

Aug 18, 2022

Changes in this version

+ type CatalogTargetInfo struct

+ CreatedTime *string

+ Description *string

+ Id *string

+ Label *string

+ Name *string

+ Parameters *[]CatalogTargetParameters

+ ProviderType *CatalogTargetInfoProviderType

+ UpdatedTime *string

+ func (o CatalogTargetInfo) String() string

+ type CatalogTargetInfoProviderType struct

+ func (c *CatalogTargetInfoProviderType) UnmarshalJSON(b []byte) error

+ func (c CatalogTargetInfoProviderType) MarshalJSON() ([]byte, error)

+ func (c CatalogTargetInfoProviderType) Value() string

+ type CatalogTargetInfoProviderTypeEnum struct

+ CUSTOM CatalogTargetInfoProviderType

+ OFFICIAL CatalogTargetInfoProviderType

+ func GetCatalogTargetInfoProviderTypeEnum() CatalogTargetInfoProviderTypeEnum

+ type CatalogTargetParameters struct

+ Label *string

+ Metadata *interface{}

+ Name *string

+ func (o CatalogTargetParameters) String() string

+ type ChannelCreateReq struct

+ Description *string

+ Name *string

+ func (o ChannelCreateReq) String() string

+ type ChannelInfo struct

+ CreatedTime *string

+ Description *string

+ Id *string

+ Name *string

+ ProviderType *ChannelInfoProviderType

+ UpdatedTime *string

+ func (o ChannelInfo) String() string

+ type ChannelInfoProviderType struct

+ func (c *ChannelInfoProviderType) UnmarshalJSON(b []byte) error

+ func (c ChannelInfoProviderType) MarshalJSON() ([]byte, error)

+ func (c ChannelInfoProviderType) Value() string

+ type ChannelInfoProviderTypeEnum struct

+ CUSTOM ChannelInfoProviderType

+ OFFICIAL ChannelInfoProviderType

+ func GetChannelInfoProviderTypeEnum() ChannelInfoProviderTypeEnum

+ type ChannelUpdateReq struct

+ Description *string

+ func (o ChannelUpdateReq) String() string

+ type CloudEvents struct

+ Data *interface{}

+ Datacontenttype *string

+ Dataschema *string

+ Id string

+ Source string

+ Specversion string

+ Subject *string

+ Time *string

+ Type string

+ func (o CloudEvents) String() string

+ type CreateChannelRequest struct

+ Body *ChannelCreateReq

+ func (o CreateChannelRequest) String() string

+ type CreateChannelResponse struct

+ CreatedTime *string

+ Description *string

+ HttpStatusCode int

+ Id *string

+ Name *string

+ ProviderType *CreateChannelResponseProviderType

+ UpdatedTime *string

+ func (o CreateChannelResponse) String() string

+ type CreateChannelResponseProviderType struct

+ func (c *CreateChannelResponseProviderType) UnmarshalJSON(b []byte) error

+ func (c CreateChannelResponseProviderType) MarshalJSON() ([]byte, error)

+ func (c CreateChannelResponseProviderType) Value() string

+ type CreateChannelResponseProviderTypeEnum struct

+ CUSTOM CreateChannelResponseProviderType

+ OFFICIAL CreateChannelResponseProviderType

+ func GetCreateChannelResponseProviderTypeEnum() CreateChannelResponseProviderTypeEnum

+ type CreateEventSourceRequest struct

+ Body *CustomizeSourceCreateReq

+ func (o CreateEventSourceRequest) String() string

+ type CreateEventSourceResponse struct

+ ChannelId *string

+ ChannelName *string

+ CreatedTime *string

+ Description *string

+ HttpStatusCode int

+ Id *string

+ Label *string

+ Name *string

+ ProviderType *CreateEventSourceResponseProviderType

+ UpdatedTime *string

+ func (o CreateEventSourceResponse) String() string

+ type CreateEventSourceResponseProviderType struct

+ func (c *CreateEventSourceResponseProviderType) UnmarshalJSON(b []byte) error

+ func (c CreateEventSourceResponseProviderType) MarshalJSON() ([]byte, error)

+ func (c CreateEventSourceResponseProviderType) Value() string

+ type CreateEventSourceResponseProviderTypeEnum struct

+ CUSTOM CreateEventSourceResponseProviderType

+ OFFICIAL CreateEventSourceResponseProviderType

+ func GetCreateEventSourceResponseProviderTypeEnum() CreateEventSourceResponseProviderTypeEnum

+ type CreateSubscriptionRequest struct

+ Body *SubscriptionCreateReq

+ func (o CreateSubscriptionRequest) String() string

+ type CreateSubscriptionResponse struct

+ ChannelId *string

+ ChannelName *string

+ CreatedTime *string

+ Description *string

+ HttpStatusCode int

+ Id *string

+ Name *string

+ Sources *[]SubscriptionSourceInfo

+ Status *CreateSubscriptionResponseStatus

+ Targets *[]SubscriptionTargetInfo

+ Type *CreateSubscriptionResponseType

+ UpdatedTime *string

+ func (o CreateSubscriptionResponse) String() string

+ type CreateSubscriptionResponseStatus struct

+ func (c *CreateSubscriptionResponseStatus) UnmarshalJSON(b []byte) error

+ func (c CreateSubscriptionResponseStatus) MarshalJSON() ([]byte, error)

+ func (c CreateSubscriptionResponseStatus) Value() string

+ type CreateSubscriptionResponseStatusEnum struct

+ CREATED CreateSubscriptionResponseStatus

+ DISABLED CreateSubscriptionResponseStatus

+ ENABLED CreateSubscriptionResponseStatus

+ ERROR CreateSubscriptionResponseStatus

+ FROZEN CreateSubscriptionResponseStatus

+ func GetCreateSubscriptionResponseStatusEnum() CreateSubscriptionResponseStatusEnum

+ type CreateSubscriptionResponseType struct

+ func (c *CreateSubscriptionResponseType) UnmarshalJSON(b []byte) error

+ func (c CreateSubscriptionResponseType) MarshalJSON() ([]byte, error)

+ func (c CreateSubscriptionResponseType) Value() string

+ type CreateSubscriptionResponseTypeEnum struct

+ EVENT CreateSubscriptionResponseType

+ SCHEDULED CreateSubscriptionResponseType

+ func GetCreateSubscriptionResponseTypeEnum() CreateSubscriptionResponseTypeEnum

+ type CreateSubscriptionTargetRequest struct

+ Body *SubscriptionTarget

+ SubscriptionId string

+ func (o CreateSubscriptionTargetRequest) String() string

+ type CreateSubscriptionTargetResponse struct

+ CreatedTime *string

+ Detail *interface{}

+ HttpStatusCode int

+ Id *string

+ Name *string

+ ProviderType *string

+ Transform *SubscriptionTargetInfoTransform

+ UpdatedTime *string

+ func (o CreateSubscriptionTargetResponse) String() string

+ type CustomizeSourceCreateReq struct

+ ChannelId string

+ Description *string

+ Name string

+ func (o CustomizeSourceCreateReq) String() string

+ type CustomizeSourceUpdateReq struct

+ Description *string

+ func (o CustomizeSourceUpdateReq) String() string

+ type DeleteChannelRequest struct

+ ChannelId string

+ func (o DeleteChannelRequest) String() string

+ type DeleteChannelResponse struct

+ HttpStatusCode int

+ func (o DeleteChannelResponse) String() string

+ type DeleteEventSourceRequest struct

+ SourceId string

+ func (o DeleteEventSourceRequest) String() string

+ type DeleteEventSourceResponse struct

+ HttpStatusCode int

+ func (o DeleteEventSourceResponse) String() string

+ type DeleteSubscriptionRequest struct

+ SubscriptionId string

+ func (o DeleteSubscriptionRequest) String() string

+ type DeleteSubscriptionResponse struct

+ HttpStatusCode int

+ func (o DeleteSubscriptionResponse) String() string

+ type DeleteSubscriptionTargetRequest struct

+ SubscriptionId string

+ TargetId string

+ func (o DeleteSubscriptionTargetRequest) String() string

+ type DeleteSubscriptionTargetResponse struct

+ HttpStatusCode int

+ func (o DeleteSubscriptionTargetResponse) String() string

+ type ListChannelsRequest struct

+ FuzzyName *string

+ Limit *int32

+ Name *string

+ Offset *int32

+ ProviderType *ListChannelsRequestProviderType

+ Sort *string

+ func (o ListChannelsRequest) String() string

+ type ListChannelsRequestProviderType struct

+ func (c *ListChannelsRequestProviderType) UnmarshalJSON(b []byte) error

+ func (c ListChannelsRequestProviderType) MarshalJSON() ([]byte, error)

+ func (c ListChannelsRequestProviderType) Value() string

+ type ListChannelsRequestProviderTypeEnum struct

+ CUSTOM ListChannelsRequestProviderType

+ OFFICIAL ListChannelsRequestProviderType

+ func GetListChannelsRequestProviderTypeEnum() ListChannelsRequestProviderTypeEnum

+ type ListChannelsResponse struct

+ HttpStatusCode int

+ Items *[]ChannelInfo

+ Size *int32

+ Total *int32

+ func (o ListChannelsResponse) String() string

+ type ListEventSourcesRequest struct

+ ChannelId *string

+ FuzzyLabel *string

+ FuzzyName *string

+ Limit *int32

+ Name *string

+ Offset *int32

+ ProviderType *ListEventSourcesRequestProviderType

+ Sort *string

+ func (o ListEventSourcesRequest) String() string

+ type ListEventSourcesRequestProviderType struct

+ func (c *ListEventSourcesRequestProviderType) UnmarshalJSON(b []byte) error

+ func (c ListEventSourcesRequestProviderType) MarshalJSON() ([]byte, error)

+ func (c ListEventSourcesRequestProviderType) Value() string

+ type ListEventSourcesRequestProviderTypeEnum struct

+ CUSTOM ListEventSourcesRequestProviderType

+ OFFICIAL ListEventSourcesRequestProviderType

+ func GetListEventSourcesRequestProviderTypeEnum() ListEventSourcesRequestProviderTypeEnum

+ type ListEventSourcesResponse struct

+ HttpStatusCode int

+ Items *[]SourceInfo

+ Size *int32

+ Total *int32

+ func (o ListEventSourcesResponse) String() string

+ type ListEventTargetRequest struct

+ FuzzyLabel *string

+ Limit *int32

+ Offset *int32

+ Sort *string

+ func (o ListEventTargetRequest) String() string

+ type ListEventTargetResponse struct

+ HttpStatusCode int

+ Items *[]CatalogTargetInfo

+ Size *int32

+ Total *int32

+ func (o ListEventTargetResponse) String() string

+ type ListQuotasRequest struct

+ Type *ListQuotasRequestType

+ func (o ListQuotasRequest) String() string

+ type ListQuotasRequestType struct

+ func (c *ListQuotasRequestType) UnmarshalJSON(b []byte) error

+ func (c ListQuotasRequestType) MarshalJSON() ([]byte, error)

+ func (c ListQuotasRequestType) Value() string

+ type ListQuotasRequestTypeEnum struct

+ CHANNEL ListQuotasRequestType

+ CHANNEL_SUBSCRIPTION ListQuotasRequestType

+ SCHEMA ListQuotasRequestType

+ SCHEMA_VERSION ListQuotasRequestType

+ SOURCE ListQuotasRequestType

+ SUBSCRIPTION ListQuotasRequestType

+ SUBSCRIPTION_TARGET ListQuotasRequestType

+ func GetListQuotasRequestTypeEnum() ListQuotasRequestTypeEnum

+ type ListQuotasResponse struct

+ HttpStatusCode int

+ Quotas *[]QuotaResourceResp

+ func (o ListQuotasResponse) String() string

+ type ListSubscriptionsRequest struct

+ ChannelId *string

+ FuzzyName *string

+ Limit *int32

+ Name *string

+ Offset *int32

+ Sort *string

+ func (o ListSubscriptionsRequest) String() string

+ type ListSubscriptionsResponse struct

+ HttpStatusCode int

+ Items *[]SubscriptionInfo

+ Size *int32

+ Total *int32

+ func (o ListSubscriptionsResponse) String() string

+ type OperateSubscriptionRequest struct

+ Body *SubscriptionOperateReq

+ func (o OperateSubscriptionRequest) String() string

+ type OperateSubscriptionResponse struct

+ Events *[]SubscriptionOperateRespEvents

+ FailedCount *int32

+ HttpStatusCode int

+ func (o OperateSubscriptionResponse) String() string

+ type PutEventsReq struct

+ Events *[]CloudEvents

+ func (o PutEventsReq) String() string

+ type PutEventsRequest struct

+ Body *PutEventsReq

+ ChannelId string

+ func (o PutEventsRequest) String() string

+ type PutEventsRespEvents struct

+ ErrorCode *string

+ ErrorMsg *string

+ EventId *string

+ func (o PutEventsRespEvents) String() string

+ type PutEventsResponse struct

+ Events *[]PutEventsRespEvents

+ FailedCount *int32

+ HttpStatusCode int

+ func (o PutEventsResponse) String() string

+ type QuotaItemInfo struct

+ Max *string

+ Min *string

+ Name *string

+ Quota *string

+ Type *QuotaItemInfoType

+ Used *string

+ func (o QuotaItemInfo) String() string

+ type QuotaItemInfoType struct

+ func (c *QuotaItemInfoType) UnmarshalJSON(b []byte) error

+ func (c QuotaItemInfoType) MarshalJSON() ([]byte, error)

+ func (c QuotaItemInfoType) Value() string

+ type QuotaItemInfoTypeEnum struct

+ CHANNEL QuotaItemInfoType

+ CHANNEL_SUBSCRIPTION QuotaItemInfoType

+ SCHEMA QuotaItemInfoType

+ SCHEMA_VERSION QuotaItemInfoType

+ SOURCE QuotaItemInfoType

+ SUBSCRIPTION QuotaItemInfoType

+ SUBSCRIPTION_TARGET QuotaItemInfoType

+ func GetQuotaItemInfoTypeEnum() QuotaItemInfoTypeEnum

+ type QuotaResourceResp struct

+ Resources *[]QuotaItemInfo

+ func (o QuotaResourceResp) String() string

+ type ShowDetailOfChannelRequest struct

+ ChannelId string

+ func (o ShowDetailOfChannelRequest) String() string

+ type ShowDetailOfChannelResponse struct

+ CreatedTime *string

+ Description *string

+ HttpStatusCode int

+ Id *string

+ Name *string

+ ProviderType *ShowDetailOfChannelResponseProviderType

+ UpdatedTime *string

+ func (o ShowDetailOfChannelResponse) String() string

+ type ShowDetailOfChannelResponseProviderType struct

+ func (c *ShowDetailOfChannelResponseProviderType) UnmarshalJSON(b []byte) error

+ func (c ShowDetailOfChannelResponseProviderType) MarshalJSON() ([]byte, error)

+ func (c ShowDetailOfChannelResponseProviderType) Value() string

+ type ShowDetailOfChannelResponseProviderTypeEnum struct

+ CUSTOM ShowDetailOfChannelResponseProviderType

+ OFFICIAL ShowDetailOfChannelResponseProviderType

+ func GetShowDetailOfChannelResponseProviderTypeEnum() ShowDetailOfChannelResponseProviderTypeEnum

+ type ShowDetailOfEventSourceRequest struct

+ SourceId string

+ func (o ShowDetailOfEventSourceRequest) String() string

+ type ShowDetailOfEventSourceResponse struct

+ ChannelId *string

+ ChannelName *string

+ CreatedTime *string

+ Description *string

+ HttpStatusCode int

+ Id *string

+ Label *string

+ Name *string

+ ProviderType *ShowDetailOfEventSourceResponseProviderType

+ UpdatedTime *string

+ func (o ShowDetailOfEventSourceResponse) String() string

+ type ShowDetailOfEventSourceResponseProviderType struct

+ func (c *ShowDetailOfEventSourceResponseProviderType) UnmarshalJSON(b []byte) error

+ func (c ShowDetailOfEventSourceResponseProviderType) MarshalJSON() ([]byte, error)

+ func (c ShowDetailOfEventSourceResponseProviderType) Value() string

+ type ShowDetailOfEventSourceResponseProviderTypeEnum struct

+ CUSTOM ShowDetailOfEventSourceResponseProviderType

+ OFFICIAL ShowDetailOfEventSourceResponseProviderType

+ func GetShowDetailOfEventSourceResponseProviderTypeEnum() ShowDetailOfEventSourceResponseProviderTypeEnum

+ type ShowDetailOfSubscriptionRequest struct

+ SubscriptionId string

+ func (o ShowDetailOfSubscriptionRequest) String() string

+ type ShowDetailOfSubscriptionResponse struct

+ ChannelId *string

+ ChannelName *string

+ CreatedTime *string

+ Description *string

+ HttpStatusCode int

+ Id *string

+ Name *string

+ Sources *[]SubscriptionSourceInfo

+ Status *ShowDetailOfSubscriptionResponseStatus

+ Targets *[]SubscriptionTargetInfo

+ Type *ShowDetailOfSubscriptionResponseType

+ UpdatedTime *string

+ func (o ShowDetailOfSubscriptionResponse) String() string

+ type ShowDetailOfSubscriptionResponseStatus struct

+ func (c *ShowDetailOfSubscriptionResponseStatus) UnmarshalJSON(b []byte) error

+ func (c ShowDetailOfSubscriptionResponseStatus) MarshalJSON() ([]byte, error)

+ func (c ShowDetailOfSubscriptionResponseStatus) Value() string

+ type ShowDetailOfSubscriptionResponseStatusEnum struct

+ CREATED ShowDetailOfSubscriptionResponseStatus

+ DISABLED ShowDetailOfSubscriptionResponseStatus

+ ENABLED ShowDetailOfSubscriptionResponseStatus

+ ERROR ShowDetailOfSubscriptionResponseStatus

+ FROZEN ShowDetailOfSubscriptionResponseStatus

+ func GetShowDetailOfSubscriptionResponseStatusEnum() ShowDetailOfSubscriptionResponseStatusEnum

+ type ShowDetailOfSubscriptionResponseType struct

+ func (c *ShowDetailOfSubscriptionResponseType) UnmarshalJSON(b []byte) error

+ func (c ShowDetailOfSubscriptionResponseType) MarshalJSON() ([]byte, error)

+ func (c ShowDetailOfSubscriptionResponseType) Value() string

+ type ShowDetailOfSubscriptionResponseTypeEnum struct

+ EVENT ShowDetailOfSubscriptionResponseType

+ SCHEDULED ShowDetailOfSubscriptionResponseType

+ func GetShowDetailOfSubscriptionResponseTypeEnum() ShowDetailOfSubscriptionResponseTypeEnum

+ type ShowDetailOfSubscriptionTargetRequest struct

+ SubscriptionId string

+ TargetId string

+ func (o ShowDetailOfSubscriptionTargetRequest) String() string

+ type ShowDetailOfSubscriptionTargetResponse struct

+ CreatedTime *string

+ Detail *interface{}

+ HttpStatusCode int

+ Id *string

+ Name *string

+ ProviderType *string

+ Transform *SubscriptionTargetInfoTransform

+ UpdatedTime *string

+ func (o ShowDetailOfSubscriptionTargetResponse) String() string

+ type SourceInfo struct

+ ChannelId *string

+ ChannelName *string

+ CreatedTime *string

+ Description *string

+ EventTypes *[]SourceInfoEventTypes

+ Id *string

+ Label *string

+ Name *string

+ ProviderType *SourceInfoProviderType

+ UpdatedTime *string

+ func (o SourceInfo) String() string

+ type SourceInfoEventTypes struct

+ Description *string

+ Name *string

+ func (o SourceInfoEventTypes) String() string

+ type SourceInfoProviderType struct

+ func (c *SourceInfoProviderType) UnmarshalJSON(b []byte) error

+ func (c SourceInfoProviderType) MarshalJSON() ([]byte, error)

+ func (c SourceInfoProviderType) Value() string

+ type SourceInfoProviderTypeEnum struct

+ CUSTOM SourceInfoProviderType

+ OFFICIAL SourceInfoProviderType

+ func GetSourceInfoProviderTypeEnum() SourceInfoProviderTypeEnum

+ type SubscriptionCreateReq struct

+ ChannelId string

+ Description *string

+ Name string

+ Sources []SubscriptionSource

+ Targets []SubscriptionTarget

+ func (o SubscriptionCreateReq) String() string

+ type SubscriptionInfo struct

+ ChannelId *string

+ ChannelName *string

+ CreatedTime *string

+ Description *string

+ Id *string

+ Name *string

+ Sources *[]SubscriptionSourceInfo

+ Status *SubscriptionInfoStatus

+ Targets *[]SubscriptionTargetInfo

+ Type *SubscriptionInfoType

+ UpdatedTime *string

+ func (o SubscriptionInfo) String() string

+ type SubscriptionInfoStatus struct

+ func (c *SubscriptionInfoStatus) UnmarshalJSON(b []byte) error

+ func (c SubscriptionInfoStatus) MarshalJSON() ([]byte, error)

+ func (c SubscriptionInfoStatus) Value() string

+ type SubscriptionInfoStatusEnum struct

+ CREATED SubscriptionInfoStatus

+ DISABLED SubscriptionInfoStatus

+ ENABLED SubscriptionInfoStatus

+ ERROR SubscriptionInfoStatus

+ FROZEN SubscriptionInfoStatus

+ func GetSubscriptionInfoStatusEnum() SubscriptionInfoStatusEnum

+ type SubscriptionInfoType struct

+ func (c *SubscriptionInfoType) UnmarshalJSON(b []byte) error

+ func (c SubscriptionInfoType) MarshalJSON() ([]byte, error)

+ func (c SubscriptionInfoType) Value() string

+ type SubscriptionInfoTypeEnum struct

+ EVENT SubscriptionInfoType

+ SCHEDULED SubscriptionInfoType

+ func GetSubscriptionInfoTypeEnum() SubscriptionInfoTypeEnum

+ type SubscriptionOperateReq struct

+ Operation *SubscriptionOperateReqOperation

+ SubscriptionIds *[]string

+ func (o SubscriptionOperateReq) String() string

+ type SubscriptionOperateReqOperation struct

+ func (c *SubscriptionOperateReqOperation) UnmarshalJSON(b []byte) error

+ func (c SubscriptionOperateReqOperation) MarshalJSON() ([]byte, error)

+ func (c SubscriptionOperateReqOperation) Value() string

+ type SubscriptionOperateReqOperationEnum struct

+ DISABLE SubscriptionOperateReqOperation

+ ENABLE SubscriptionOperateReqOperation

+ func GetSubscriptionOperateReqOperationEnum() SubscriptionOperateReqOperationEnum

+ type SubscriptionOperateRespEvents struct

+ ErrorCode *string

+ ErrorMsg *string

+ SubscriptionId *string

+ func (o SubscriptionOperateRespEvents) String() string

+ type SubscriptionSource struct

+ Detail *interface{}

+ Filter *interface{}

+ Id *string

+ Name string

+ ProviderType SubscriptionSourceProviderType

+ func (o SubscriptionSource) String() string

+ type SubscriptionSourceInfo struct

+ CreatedTime *string

+ Detail *interface{}

+ Filter *interface{}

+ Id *string

+ Name *string

+ ProviderType *string

+ UpdatedTime *string

+ func (o SubscriptionSourceInfo) String() string

+ type SubscriptionSourceProviderType struct

+ func (c *SubscriptionSourceProviderType) UnmarshalJSON(b []byte) error

+ func (c SubscriptionSourceProviderType) MarshalJSON() ([]byte, error)

+ func (c SubscriptionSourceProviderType) Value() string

+ type SubscriptionSourceProviderTypeEnum struct

+ CUSTOM SubscriptionSourceProviderType

+ OFFICIAL SubscriptionSourceProviderType

+ func GetSubscriptionSourceProviderTypeEnum() SubscriptionSourceProviderTypeEnum

+ type SubscriptionTarget struct

+ Detail *interface{}

+ Id *string

+ Name string

+ ProviderType SubscriptionTargetProviderType

+ Transform *SubscriptionTargetTransform

+ func (o SubscriptionTarget) String() string

+ type SubscriptionTargetInfo struct

+ CreatedTime *string

+ Detail *interface{}

+ Id *string

+ Name *string

+ ProviderType *string

+ Transform *SubscriptionTargetInfoTransform

+ UpdatedTime *string

+ func (o SubscriptionTargetInfo) String() string

+ type SubscriptionTargetInfoTransform struct

+ Template *string

+ Type *string

+ Value *string

+ func (o SubscriptionTargetInfoTransform) String() string

+ type SubscriptionTargetProviderType struct

+ func (c *SubscriptionTargetProviderType) UnmarshalJSON(b []byte) error

+ func (c SubscriptionTargetProviderType) MarshalJSON() ([]byte, error)

+ func (c SubscriptionTargetProviderType) Value() string

+ type SubscriptionTargetProviderTypeEnum struct

+ CUSTOM SubscriptionTargetProviderType

+ OFFICIAL SubscriptionTargetProviderType

+ func GetSubscriptionTargetProviderTypeEnum() SubscriptionTargetProviderTypeEnum

+ type SubscriptionTargetTransform struct

+ Template *string

+ Type SubscriptionTargetTransformType

+ Value *string

+ func (o SubscriptionTargetTransform) String() string

+ type SubscriptionTargetTransformType struct

+ func (c *SubscriptionTargetTransformType) UnmarshalJSON(b []byte) error

+ func (c SubscriptionTargetTransformType) MarshalJSON() ([]byte, error)

+ func (c SubscriptionTargetTransformType) Value() string

+ type SubscriptionTargetTransformTypeEnum struct

+ CONSTANT SubscriptionTargetTransformType

+ ORIGINAL SubscriptionTargetTransformType

+ VARIABLE SubscriptionTargetTransformType

+ func GetSubscriptionTargetTransformTypeEnum() SubscriptionTargetTransformTypeEnum

+ type SubscriptionUpdateReq struct

+ Description *string

+ Sources *[]SubscriptionSource

+ Targets *[]SubscriptionTarget

+ func (o SubscriptionUpdateReq) String() string

+ type UpdateChannelRequest struct

+ Body *ChannelUpdateReq

+ ChannelId string

+ func (o UpdateChannelRequest) String() string

+ type UpdateChannelResponse struct

+ CreatedTime *string

+ Description *string

+ HttpStatusCode int

+ Id *string

+ Name *string

+ ProviderType *UpdateChannelResponseProviderType

+ UpdatedTime *string

+ func (o UpdateChannelResponse) String() string

+ type UpdateChannelResponseProviderType struct

+ func (c *UpdateChannelResponseProviderType) UnmarshalJSON(b []byte) error

+ func (c UpdateChannelResponseProviderType) MarshalJSON() ([]byte, error)

+ func (c UpdateChannelResponseProviderType) Value() string

+ type UpdateChannelResponseProviderTypeEnum struct

+ CUSTOM UpdateChannelResponseProviderType

+ OFFICIAL UpdateChannelResponseProviderType

+ func GetUpdateChannelResponseProviderTypeEnum() UpdateChannelResponseProviderTypeEnum

+ type UpdateEventSourceRequest struct

+ Body *CustomizeSourceUpdateReq

+ SourceId string

+ func (o UpdateEventSourceRequest) String() string

+ type UpdateEventSourceResponse struct

+ ChannelId *string

+ ChannelName *string

+ CreatedTime *string

+ Description *string

+ HttpStatusCode int

+ Id *string

+ Label *string

+ Name *string

+ ProviderType *UpdateEventSourceResponseProviderType

+ UpdatedTime *string

+ func (o UpdateEventSourceResponse) String() string

+ type UpdateEventSourceResponseProviderType struct

+ func (c *UpdateEventSourceResponseProviderType) UnmarshalJSON(b []byte) error

+ func (c UpdateEventSourceResponseProviderType) MarshalJSON() ([]byte, error)

+ func (c UpdateEventSourceResponseProviderType) Value() string

+ type UpdateEventSourceResponseProviderTypeEnum struct

+ CUSTOM UpdateEventSourceResponseProviderType

+ OFFICIAL UpdateEventSourceResponseProviderType

+ func GetUpdateEventSourceResponseProviderTypeEnum() UpdateEventSourceResponseProviderTypeEnum

+ type UpdateSubscriptionRequest struct

+ Body *SubscriptionUpdateReq

+ SubscriptionId string

+ func (o UpdateSubscriptionRequest) String() string

+ type UpdateSubscriptionResponse struct

+ ChannelId *string

+ ChannelName *string

+ CreatedTime *string

+ Description *string

+ HttpStatusCode int

+ Id *string

+ Name *string

+ Sources *[]SubscriptionSourceInfo

+ Status *UpdateSubscriptionResponseStatus

+ Targets *[]SubscriptionTargetInfo

+ Type *UpdateSubscriptionResponseType

+ UpdatedTime *string

+ func (o UpdateSubscriptionResponse) String() string

+ type UpdateSubscriptionResponseStatus struct

+ func (c *UpdateSubscriptionResponseStatus) UnmarshalJSON(b []byte) error

+ func (c UpdateSubscriptionResponseStatus) MarshalJSON() ([]byte, error)

+ func (c UpdateSubscriptionResponseStatus) Value() string

+ type UpdateSubscriptionResponseStatusEnum struct

+ CREATED UpdateSubscriptionResponseStatus

+ DISABLED UpdateSubscriptionResponseStatus

+ ENABLED UpdateSubscriptionResponseStatus

+ ERROR UpdateSubscriptionResponseStatus

+ FROZEN UpdateSubscriptionResponseStatus

+ func GetUpdateSubscriptionResponseStatusEnum() UpdateSubscriptionResponseStatusEnum

+ type UpdateSubscriptionResponseType struct

+ func (c *UpdateSubscriptionResponseType) UnmarshalJSON(b []byte) error

+ func (c UpdateSubscriptionResponseType) MarshalJSON() ([]byte, error)

+ func (c UpdateSubscriptionResponseType) Value() string

+ type UpdateSubscriptionResponseTypeEnum struct

+ EVENT UpdateSubscriptionResponseType

+ SCHEDULED UpdateSubscriptionResponseType

+ func GetUpdateSubscriptionResponseTypeEnum() UpdateSubscriptionResponseTypeEnum

+ type UpdateSubscriptionSourceRequest struct

+ Body *SubscriptionSource

+ SourceId string

+ SubscriptionId string

+ func (o UpdateSubscriptionSourceRequest) String() string

+ type UpdateSubscriptionSourceResponse struct

+ CreatedTime *string

+ Detail *interface{}

+ Filter *interface{}

+ HttpStatusCode int

+ Id *string

+ Name *string

+ ProviderType *string

+ UpdatedTime *string

+ func (o UpdateSubscriptionSourceResponse) String() string

+ type UpdateSubscriptionTargetRequest struct

+ Body *SubscriptionTarget

+ SubscriptionId string

+ TargetId string

+ func (o UpdateSubscriptionTargetRequest) String() string

+ type UpdateSubscriptionTargetResponse struct

+ CreatedTime *string

+ Detail *interface{}

+ HttpStatusCode int

+ Id *string

+ Name *string

+ ProviderType *string

+ Transform *SubscriptionTargetInfoTransform

+ UpdatedTime *string

+ func (o UpdateSubscriptionTargetResponse) String() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL