Versions in this module Expand all Collapse all v0 v0.3.0 Jan 25, 2023 v0.2.0 Jan 25, 2023 v0.1.0 Jan 25, 2023 Changes in this version + var EndpointMap map[string]string + var EndpointType = "regional" + func GetEndpointMap() map[string]string + func GetEndpointType() string + func SetClientProperty(client *Client, propertyName string, propertyValue interface{}) + func SetEndpointDataToClient(client *Client) + type Client struct + func NewClient() (client *Client, err error) + func NewClientWithAccessKey(regionId, accessKeyId, accessKeySecret string) (client *Client, err error) + func NewClientWithEcsRamRole(regionId string, roleName string) (client *Client, err error) + func NewClientWithOptions(regionId string, config *sdk.Config, credential auth.Credential) (client *Client, err error) + func NewClientWithProvider(regionId string, providers ...provider.Provider) (client *Client, err error) + func NewClientWithRamRoleArn(regionId string, accessKeyId, accessKeySecret, roleArn, roleSessionName string) (client *Client, err error) + func NewClientWithRamRoleArnAndPolicy(regionId string, ...) (client *Client, err error) + func NewClientWithRsaKeyPair(regionId string, publicKeyId, privateKey string, sessionExpiration int) (client *Client, err error) + func NewClientWithStsToken(regionId, stsAccessKeyId, stsAccessKeySecret, stsToken string) (client *Client, err error) + func (client *Client) ListTagResources(request *ListTagResourcesRequest) (response *ListTagResourcesResponse, err error) + func (client *Client) ListTagResourcesWithCallback(request *ListTagResourcesRequest, ...) <-chan int + func (client *Client) ListTagResourcesWithChan(request *ListTagResourcesRequest) (<-chan *ListTagResourcesResponse, <-chan error) + func (client *Client) OnsConsumerAccumulate(request *OnsConsumerAccumulateRequest) (response *OnsConsumerAccumulateResponse, err error) + func (client *Client) OnsConsumerAccumulateWithCallback(request *OnsConsumerAccumulateRequest, ...) <-chan int + func (client *Client) OnsConsumerAccumulateWithChan(request *OnsConsumerAccumulateRequest) (<-chan *OnsConsumerAccumulateResponse, <-chan error) + func (client *Client) OnsConsumerGetConnection(request *OnsConsumerGetConnectionRequest) (response *OnsConsumerGetConnectionResponse, err error) + func (client *Client) OnsConsumerGetConnectionWithCallback(request *OnsConsumerGetConnectionRequest, ...) <-chan int + func (client *Client) OnsConsumerGetConnectionWithChan(request *OnsConsumerGetConnectionRequest) (<-chan *OnsConsumerGetConnectionResponse, <-chan error) + func (client *Client) OnsConsumerResetOffset(request *OnsConsumerResetOffsetRequest) (response *OnsConsumerResetOffsetResponse, err error) + func (client *Client) OnsConsumerResetOffsetWithCallback(request *OnsConsumerResetOffsetRequest, ...) <-chan int + func (client *Client) OnsConsumerResetOffsetWithChan(request *OnsConsumerResetOffsetRequest) (<-chan *OnsConsumerResetOffsetResponse, <-chan error) + func (client *Client) OnsConsumerStatus(request *OnsConsumerStatusRequest) (response *OnsConsumerStatusResponse, err error) + func (client *Client) OnsConsumerStatusWithCallback(request *OnsConsumerStatusRequest, ...) <-chan int + func (client *Client) OnsConsumerStatusWithChan(request *OnsConsumerStatusRequest) (<-chan *OnsConsumerStatusResponse, <-chan error) + func (client *Client) OnsConsumerTimeSpan(request *OnsConsumerTimeSpanRequest) (response *OnsConsumerTimeSpanResponse, err error) + func (client *Client) OnsConsumerTimeSpanWithCallback(request *OnsConsumerTimeSpanRequest, ...) <-chan int + func (client *Client) OnsConsumerTimeSpanWithChan(request *OnsConsumerTimeSpanRequest) (<-chan *OnsConsumerTimeSpanResponse, <-chan error) + func (client *Client) OnsDLQMessageGetById(request *OnsDLQMessageGetByIdRequest) (response *OnsDLQMessageGetByIdResponse, err error) + func (client *Client) OnsDLQMessageGetByIdWithCallback(request *OnsDLQMessageGetByIdRequest, ...) <-chan int + func (client *Client) OnsDLQMessageGetByIdWithChan(request *OnsDLQMessageGetByIdRequest) (<-chan *OnsDLQMessageGetByIdResponse, <-chan error) + func (client *Client) OnsDLQMessagePageQueryByGroupId(request *OnsDLQMessagePageQueryByGroupIdRequest) (response *OnsDLQMessagePageQueryByGroupIdResponse, err error) + func (client *Client) OnsDLQMessagePageQueryByGroupIdWithCallback(request *OnsDLQMessagePageQueryByGroupIdRequest, ...) <-chan int + func (client *Client) OnsDLQMessagePageQueryByGroupIdWithChan(request *OnsDLQMessagePageQueryByGroupIdRequest) (<-chan *OnsDLQMessagePageQueryByGroupIdResponse, <-chan error) + func (client *Client) OnsDLQMessageResendById(request *OnsDLQMessageResendByIdRequest) (response *OnsDLQMessageResendByIdResponse, err error) + func (client *Client) OnsDLQMessageResendByIdWithCallback(request *OnsDLQMessageResendByIdRequest, ...) <-chan int + func (client *Client) OnsDLQMessageResendByIdWithChan(request *OnsDLQMessageResendByIdRequest) (<-chan *OnsDLQMessageResendByIdResponse, <-chan error) + func (client *Client) OnsGroupConsumerUpdate(request *OnsGroupConsumerUpdateRequest) (response *OnsGroupConsumerUpdateResponse, err error) + func (client *Client) OnsGroupConsumerUpdateWithCallback(request *OnsGroupConsumerUpdateRequest, ...) <-chan int + func (client *Client) OnsGroupConsumerUpdateWithChan(request *OnsGroupConsumerUpdateRequest) (<-chan *OnsGroupConsumerUpdateResponse, <-chan error) + func (client *Client) OnsGroupCreate(request *OnsGroupCreateRequest) (response *OnsGroupCreateResponse, err error) + func (client *Client) OnsGroupCreateWithCallback(request *OnsGroupCreateRequest, ...) <-chan int + func (client *Client) OnsGroupCreateWithChan(request *OnsGroupCreateRequest) (<-chan *OnsGroupCreateResponse, <-chan error) + func (client *Client) OnsGroupDelete(request *OnsGroupDeleteRequest) (response *OnsGroupDeleteResponse, err error) + func (client *Client) OnsGroupDeleteWithCallback(request *OnsGroupDeleteRequest, ...) <-chan int + func (client *Client) OnsGroupDeleteWithChan(request *OnsGroupDeleteRequest) (<-chan *OnsGroupDeleteResponse, <-chan error) + func (client *Client) OnsGroupList(request *OnsGroupListRequest) (response *OnsGroupListResponse, err error) + func (client *Client) OnsGroupListWithCallback(request *OnsGroupListRequest, ...) <-chan int + func (client *Client) OnsGroupListWithChan(request *OnsGroupListRequest) (<-chan *OnsGroupListResponse, <-chan error) + func (client *Client) OnsGroupSubDetail(request *OnsGroupSubDetailRequest) (response *OnsGroupSubDetailResponse, err error) + func (client *Client) OnsGroupSubDetailWithCallback(request *OnsGroupSubDetailRequest, ...) <-chan int + func (client *Client) OnsGroupSubDetailWithChan(request *OnsGroupSubDetailRequest) (<-chan *OnsGroupSubDetailResponse, <-chan error) + func (client *Client) OnsInstanceBaseInfo(request *OnsInstanceBaseInfoRequest) (response *OnsInstanceBaseInfoResponse, err error) + func (client *Client) OnsInstanceBaseInfoWithCallback(request *OnsInstanceBaseInfoRequest, ...) <-chan int + func (client *Client) OnsInstanceBaseInfoWithChan(request *OnsInstanceBaseInfoRequest) (<-chan *OnsInstanceBaseInfoResponse, <-chan error) + func (client *Client) OnsInstanceCreate(request *OnsInstanceCreateRequest) (response *OnsInstanceCreateResponse, err error) + func (client *Client) OnsInstanceCreateWithCallback(request *OnsInstanceCreateRequest, ...) <-chan int + func (client *Client) OnsInstanceCreateWithChan(request *OnsInstanceCreateRequest) (<-chan *OnsInstanceCreateResponse, <-chan error) + func (client *Client) OnsInstanceDelete(request *OnsInstanceDeleteRequest) (response *OnsInstanceDeleteResponse, err error) + func (client *Client) OnsInstanceDeleteWithCallback(request *OnsInstanceDeleteRequest, ...) <-chan int + func (client *Client) OnsInstanceDeleteWithChan(request *OnsInstanceDeleteRequest) (<-chan *OnsInstanceDeleteResponse, <-chan error) + func (client *Client) OnsInstanceInServiceList(request *OnsInstanceInServiceListRequest) (response *OnsInstanceInServiceListResponse, err error) + func (client *Client) OnsInstanceInServiceListWithCallback(request *OnsInstanceInServiceListRequest, ...) <-chan int + func (client *Client) OnsInstanceInServiceListWithChan(request *OnsInstanceInServiceListRequest) (<-chan *OnsInstanceInServiceListResponse, <-chan error) + func (client *Client) OnsInstanceUpdate(request *OnsInstanceUpdateRequest) (response *OnsInstanceUpdateResponse, err error) + func (client *Client) OnsInstanceUpdateWithCallback(request *OnsInstanceUpdateRequest, ...) <-chan int + func (client *Client) OnsInstanceUpdateWithChan(request *OnsInstanceUpdateRequest) (<-chan *OnsInstanceUpdateResponse, <-chan error) + func (client *Client) OnsMessageDetail(request *OnsMessageDetailRequest) (response *OnsMessageDetailResponse, err error) + func (client *Client) OnsMessageDetailWithCallback(request *OnsMessageDetailRequest, ...) <-chan int + func (client *Client) OnsMessageDetailWithChan(request *OnsMessageDetailRequest) (<-chan *OnsMessageDetailResponse, <-chan error) + func (client *Client) OnsMessageGetByKey(request *OnsMessageGetByKeyRequest) (response *OnsMessageGetByKeyResponse, err error) + func (client *Client) OnsMessageGetByKeyWithCallback(request *OnsMessageGetByKeyRequest, ...) <-chan int + func (client *Client) OnsMessageGetByKeyWithChan(request *OnsMessageGetByKeyRequest) (<-chan *OnsMessageGetByKeyResponse, <-chan error) + func (client *Client) OnsMessageGetByMsgId(request *OnsMessageGetByMsgIdRequest) (response *OnsMessageGetByMsgIdResponse, err error) + func (client *Client) OnsMessageGetByMsgIdWithCallback(request *OnsMessageGetByMsgIdRequest, ...) <-chan int + func (client *Client) OnsMessageGetByMsgIdWithChan(request *OnsMessageGetByMsgIdRequest) (<-chan *OnsMessageGetByMsgIdResponse, <-chan error) + func (client *Client) OnsMessagePageQueryByTopic(request *OnsMessagePageQueryByTopicRequest) (response *OnsMessagePageQueryByTopicResponse, err error) + func (client *Client) OnsMessagePageQueryByTopicWithCallback(request *OnsMessagePageQueryByTopicRequest, ...) <-chan int + func (client *Client) OnsMessagePageQueryByTopicWithChan(request *OnsMessagePageQueryByTopicRequest) (<-chan *OnsMessagePageQueryByTopicResponse, <-chan error) + func (client *Client) OnsMessagePush(request *OnsMessagePushRequest) (response *OnsMessagePushResponse, err error) + func (client *Client) OnsMessagePushWithCallback(request *OnsMessagePushRequest, ...) <-chan int + func (client *Client) OnsMessagePushWithChan(request *OnsMessagePushRequest) (<-chan *OnsMessagePushResponse, <-chan error) + func (client *Client) OnsMessageTrace(request *OnsMessageTraceRequest) (response *OnsMessageTraceResponse, err error) + func (client *Client) OnsMessageTraceWithCallback(request *OnsMessageTraceRequest, ...) <-chan int + func (client *Client) OnsMessageTraceWithChan(request *OnsMessageTraceRequest) (<-chan *OnsMessageTraceResponse, <-chan error) + func (client *Client) OnsRegionList(request *OnsRegionListRequest) (response *OnsRegionListResponse, err error) + func (client *Client) OnsRegionListWithCallback(request *OnsRegionListRequest, ...) <-chan int + func (client *Client) OnsRegionListWithChan(request *OnsRegionListRequest) (<-chan *OnsRegionListResponse, <-chan error) + func (client *Client) OnsTopicCreate(request *OnsTopicCreateRequest) (response *OnsTopicCreateResponse, err error) + func (client *Client) OnsTopicCreateWithCallback(request *OnsTopicCreateRequest, ...) <-chan int + func (client *Client) OnsTopicCreateWithChan(request *OnsTopicCreateRequest) (<-chan *OnsTopicCreateResponse, <-chan error) + func (client *Client) OnsTopicDelete(request *OnsTopicDeleteRequest) (response *OnsTopicDeleteResponse, err error) + func (client *Client) OnsTopicDeleteWithCallback(request *OnsTopicDeleteRequest, ...) <-chan int + func (client *Client) OnsTopicDeleteWithChan(request *OnsTopicDeleteRequest) (<-chan *OnsTopicDeleteResponse, <-chan error) + func (client *Client) OnsTopicList(request *OnsTopicListRequest) (response *OnsTopicListResponse, err error) + func (client *Client) OnsTopicListWithCallback(request *OnsTopicListRequest, ...) <-chan int + func (client *Client) OnsTopicListWithChan(request *OnsTopicListRequest) (<-chan *OnsTopicListResponse, <-chan error) + func (client *Client) OnsTopicStatus(request *OnsTopicStatusRequest) (response *OnsTopicStatusResponse, err error) + func (client *Client) OnsTopicStatusWithCallback(request *OnsTopicStatusRequest, ...) <-chan int + func (client *Client) OnsTopicStatusWithChan(request *OnsTopicStatusRequest) (<-chan *OnsTopicStatusResponse, <-chan error) + func (client *Client) OnsTopicSubDetail(request *OnsTopicSubDetailRequest) (response *OnsTopicSubDetailResponse, err error) + func (client *Client) OnsTopicSubDetailWithCallback(request *OnsTopicSubDetailRequest, ...) <-chan int + func (client *Client) OnsTopicSubDetailWithChan(request *OnsTopicSubDetailRequest) (<-chan *OnsTopicSubDetailResponse, <-chan error) + func (client *Client) OnsTopicUpdate(request *OnsTopicUpdateRequest) (response *OnsTopicUpdateResponse, err error) + func (client *Client) OnsTopicUpdateWithCallback(request *OnsTopicUpdateRequest, ...) <-chan int + func (client *Client) OnsTopicUpdateWithChan(request *OnsTopicUpdateRequest) (<-chan *OnsTopicUpdateResponse, <-chan error) + func (client *Client) OnsTraceGetResult(request *OnsTraceGetResultRequest) (response *OnsTraceGetResultResponse, err error) + func (client *Client) OnsTraceGetResultWithCallback(request *OnsTraceGetResultRequest, ...) <-chan int + func (client *Client) OnsTraceGetResultWithChan(request *OnsTraceGetResultRequest) (<-chan *OnsTraceGetResultResponse, <-chan error) + func (client *Client) OnsTraceQueryByMsgId(request *OnsTraceQueryByMsgIdRequest) (response *OnsTraceQueryByMsgIdResponse, err error) + func (client *Client) OnsTraceQueryByMsgIdWithCallback(request *OnsTraceQueryByMsgIdRequest, ...) <-chan int + func (client *Client) OnsTraceQueryByMsgIdWithChan(request *OnsTraceQueryByMsgIdRequest) (<-chan *OnsTraceQueryByMsgIdResponse, <-chan error) + func (client *Client) OnsTraceQueryByMsgKey(request *OnsTraceQueryByMsgKeyRequest) (response *OnsTraceQueryByMsgKeyResponse, err error) + func (client *Client) OnsTraceQueryByMsgKeyWithCallback(request *OnsTraceQueryByMsgKeyRequest, ...) <-chan int + func (client *Client) OnsTraceQueryByMsgKeyWithChan(request *OnsTraceQueryByMsgKeyRequest) (<-chan *OnsTraceQueryByMsgKeyResponse, <-chan error) + func (client *Client) OnsTrendGroupOutputTps(request *OnsTrendGroupOutputTpsRequest) (response *OnsTrendGroupOutputTpsResponse, err error) + func (client *Client) OnsTrendGroupOutputTpsWithCallback(request *OnsTrendGroupOutputTpsRequest, ...) <-chan int + func (client *Client) OnsTrendGroupOutputTpsWithChan(request *OnsTrendGroupOutputTpsRequest) (<-chan *OnsTrendGroupOutputTpsResponse, <-chan error) + func (client *Client) OnsTrendTopicInputTps(request *OnsTrendTopicInputTpsRequest) (response *OnsTrendTopicInputTpsResponse, err error) + func (client *Client) OnsTrendTopicInputTpsWithCallback(request *OnsTrendTopicInputTpsRequest, ...) <-chan int + func (client *Client) OnsTrendTopicInputTpsWithChan(request *OnsTrendTopicInputTpsRequest) (<-chan *OnsTrendTopicInputTpsResponse, <-chan error) + func (client *Client) OpenOnsService(request *OpenOnsServiceRequest) (response *OpenOnsServiceResponse, err error) + func (client *Client) OpenOnsServiceWithCallback(request *OpenOnsServiceRequest, ...) <-chan int + func (client *Client) OpenOnsServiceWithChan(request *OpenOnsServiceRequest) (<-chan *OpenOnsServiceResponse, <-chan error) + func (client *Client) TagResources(request *TagResourcesRequest) (response *TagResourcesResponse, err error) + func (client *Client) TagResourcesWithCallback(request *TagResourcesRequest, ...) <-chan int + func (client *Client) TagResourcesWithChan(request *TagResourcesRequest) (<-chan *TagResourcesResponse, <-chan error) + func (client *Client) UntagResources(request *UntagResourcesRequest) (response *UntagResourcesResponse, err error) + func (client *Client) UntagResourcesWithCallback(request *UntagResourcesRequest, ...) <-chan int + func (client *Client) UntagResourcesWithChan(request *UntagResourcesRequest) (<-chan *UntagResourcesResponse, <-chan error) + type ClientList struct + SubClientInfoDo []SubClientInfoDo + type ConnectionDo struct + ClientAddr string + ClientId string + Language string + RemoteIP string + Version string + type ConnectionList struct + ConnectionDo []ConnectionDo + type ConnectionSet struct + ConnectionDo []ConnectionDo + type ConsumerConnectionInfoDo struct + ClientId string + Connection string + ConsumeModel string + ConsumeType string + Jstack Jstack + Language string + LastTimeStamp int64 + RunningDataList RunningDataList + StartTimeStamp int64 + SubscriptionSet SubscriptionSet + ThreadCount int + Version string + type ConsumerConnectionInfoList struct + ConsumerConnectionInfoDo []ConsumerConnectionInfoDo + type ConsumerRunningDataDo struct + FailedCountPerHour int64 + FailedTps float64 + GroupId string + OkTps float64 + Rt float64 + Topic string + type Data struct + Body string + BodyCRC int + BornHost string + BornTimestamp int64 + ConnectionList ConnectionList + ConnectionSet ConnectionSet + ConsumeModel string + ConsumeTimeStamp int64 + ConsumeTps float64 + ConsumerConnectionInfoList ConsumerConnectionInfoList + DelayTime int64 + DetailInTopicList DetailInTopicListInOnsConsumerAccumulate + Flag int + GroupId string + InstanceId string + InstanceType int + LastTimeStamp int64 + LastTimestamp int64 + MaxTimeStamp int64 + MessageModel string + MinTimeStamp int64 + MsgId string + OffsetId string + Online bool + Perm int + PropertyList PropertyListInOnsDLQMessageGetById + RebalanceOK bool + ReconsumeTimes int + Records RecordsInOnsTrendGroupOutputTps + StoreHost string + StoreSize int + StoreTimestamp int64 + SubscriptionDataList SubscriptionDataListInOnsTopicSubDetail + SubscriptionSame bool + Title string + Topic string + TotalCount int64 + TotalDiff int64 + XUnit string + YUnit string + type DataInOnsDLQMessageResendById struct + MsgId []string + type DataInOnsGroupList struct + SubscribeInfoDo []SubscribeInfoDo + type DataInOnsInstanceInServiceList struct + InstanceVO []InstanceVO + type DataInOnsMessageDetail struct + Body string + BodyCRC int + BornHost string + BornTimestamp int64 + Flag int + InstanceId string + MsgId string + OffsetId string + PropertyList []MessageProperty + ReconsumeTimes int + StoreHost string + StoreSize int + StoreTimestamp int64 + Topic string + type DataInOnsMessageGetByKey struct + OnsRestMessageDo []OnsRestMessageDo + type DataInOnsMessageTrace struct + MessageTrack []MessageTrack + type DataInOnsRegionList struct + RegionDo []RegionDo + type DataInOnsTopicList struct + PublishInfoDo []PublishInfoDo + type DetailInTopicDo struct + DelayTime int64 + LastTimestamp int64 + Topic string + TotalDiff int64 + type DetailInTopicListInOnsConsumerAccumulate struct + DetailInTopicDo []DetailInTopicDo + type DetailInTopicListInOnsConsumerStatus struct + DetailInTopicDo []DetailInTopicDo + type Endpoints struct + HttpInternalEndpoint string + HttpInternetEndpoint string + HttpInternetSecureEndpoint string + TcpEndpoint string + TcpInternetEndpoint string + type InstanceBaseInfo struct + CreateTime string + Endpoints Endpoints + IndependentNaming bool + InstanceId string + InstanceName string + InstanceStatus int + InstanceType int + MaxTps int64 + ReleaseTime int64 + Remark string + SpInstanceId string + SpInstanceType int + TopicCapacity int + type InstanceVO struct + CreateTime int64 + IndependentNaming bool + InstanceId string + InstanceName string + InstanceStatus int + InstanceType int + ReleaseTime int64 + Tags TagsInOnsInstanceInServiceList + type Jstack struct + ThreadTrackDo []ThreadTrackDo + type ListTagResourcesRequest struct + InstanceId string + NextToken string + ResourceId *[]string + ResourceType string + Tag *[]ListTagResourcesTag + func CreateListTagResourcesRequest() (request *ListTagResourcesRequest) + type ListTagResourcesResponse struct + NextToken string + RequestId string + TagResources []TagResource + func CreateListTagResourcesResponse() (response *ListTagResourcesResponse) + type ListTagResourcesTag struct + Key string + Value string + type MessageProperty struct + Name string + Value string + type MessageTrack struct + ConsumerGroup string + ExceptionDesc string + InstanceId string + TrackType string + type MsgFoundDo struct + CurrentPage int64 + MaxPageCount int64 + MsgFoundList MsgFoundListInOnsDLQMessagePageQueryByGroupId + TaskId string + type MsgFoundListInOnsDLQMessagePageQueryByGroupId struct + OnsRestMessageDo []OnsRestMessageDo + type MsgFoundListInOnsMessagePageQueryByTopic struct + OnsRestMessageDo []OnsRestMessageDo + type OnsConsumerAccumulateRequest struct + Detail requests.Boolean + GroupId string + InstanceId string + func CreateOnsConsumerAccumulateRequest() (request *OnsConsumerAccumulateRequest) + type OnsConsumerAccumulateResponse struct + Data Data + HelpUrl string + RequestId string + func CreateOnsConsumerAccumulateResponse() (response *OnsConsumerAccumulateResponse) + type OnsConsumerGetConnectionRequest struct + GroupId string + InstanceId string + func CreateOnsConsumerGetConnectionRequest() (request *OnsConsumerGetConnectionRequest) + type OnsConsumerGetConnectionResponse struct + Data Data + HelpUrl string + RequestId string + func CreateOnsConsumerGetConnectionResponse() (response *OnsConsumerGetConnectionResponse) + type OnsConsumerResetOffsetRequest struct + GroupId string + InstanceId string + ResetTimestamp requests.Integer + Topic string + Type requests.Integer + func CreateOnsConsumerResetOffsetRequest() (request *OnsConsumerResetOffsetRequest) + type OnsConsumerResetOffsetResponse struct + HelpUrl string + RequestId string + func CreateOnsConsumerResetOffsetResponse() (response *OnsConsumerResetOffsetResponse) + type OnsConsumerStatusRequest struct + Detail requests.Boolean + GroupId string + InstanceId string + NeedJstack requests.Boolean + func CreateOnsConsumerStatusRequest() (request *OnsConsumerStatusRequest) + type OnsConsumerStatusResponse struct + Data Data + HelpUrl string + RequestId string + func CreateOnsConsumerStatusResponse() (response *OnsConsumerStatusResponse) + type OnsConsumerTimeSpanRequest struct + GroupId string + InstanceId string + Topic string + func CreateOnsConsumerTimeSpanRequest() (request *OnsConsumerTimeSpanRequest) + type OnsConsumerTimeSpanResponse struct + Data Data + HelpUrl string + RequestId string + func CreateOnsConsumerTimeSpanResponse() (response *OnsConsumerTimeSpanResponse) + type OnsDLQMessageGetByIdRequest struct + GroupId string + InstanceId string + MsgId string + func CreateOnsDLQMessageGetByIdRequest() (request *OnsDLQMessageGetByIdRequest) + type OnsDLQMessageGetByIdResponse struct + Data Data + HelpUrl string + RequestId string + func CreateOnsDLQMessageGetByIdResponse() (response *OnsDLQMessageGetByIdResponse) + type OnsDLQMessagePageQueryByGroupIdRequest struct + BeginTime requests.Integer + CurrentPage requests.Integer + EndTime requests.Integer + GroupId string + InstanceId string + PageSize requests.Integer + TaskId string + func CreateOnsDLQMessagePageQueryByGroupIdRequest() (request *OnsDLQMessagePageQueryByGroupIdRequest) + type OnsDLQMessagePageQueryByGroupIdResponse struct + HelpUrl string + MsgFoundDo MsgFoundDo + RequestId string + func CreateOnsDLQMessagePageQueryByGroupIdResponse() (response *OnsDLQMessagePageQueryByGroupIdResponse) + type OnsDLQMessageResendByIdRequest struct + GroupId string + InstanceId string + MsgId string + func CreateOnsDLQMessageResendByIdRequest() (request *OnsDLQMessageResendByIdRequest) + type OnsDLQMessageResendByIdResponse struct + Data DataInOnsDLQMessageResendById + HelpUrl string + RequestId string + func CreateOnsDLQMessageResendByIdResponse() (response *OnsDLQMessageResendByIdResponse) + type OnsGroupConsumerUpdateRequest struct + GroupId string + InstanceId string + ReadEnable requests.Boolean + func CreateOnsGroupConsumerUpdateRequest() (request *OnsGroupConsumerUpdateRequest) + type OnsGroupConsumerUpdateResponse struct + HelpUrl string + RequestId string + func CreateOnsGroupConsumerUpdateResponse() (response *OnsGroupConsumerUpdateResponse) + type OnsGroupCreateRequest struct + GroupId string + GroupType string + InstanceId string + Remark string + UserId string + func CreateOnsGroupCreateRequest() (request *OnsGroupCreateRequest) + type OnsGroupCreateResponse struct + HelpUrl string + RequestId string + func CreateOnsGroupCreateResponse() (response *OnsGroupCreateResponse) + type OnsGroupDeleteRequest struct + GroupId string + InstanceId string + func CreateOnsGroupDeleteRequest() (request *OnsGroupDeleteRequest) + type OnsGroupDeleteResponse struct + HelpUrl string + RequestId string + func CreateOnsGroupDeleteResponse() (response *OnsGroupDeleteResponse) + type OnsGroupListRequest struct + GroupId string + GroupType string + InstanceId string + Tag *[]OnsGroupListTag + UserId string + func CreateOnsGroupListRequest() (request *OnsGroupListRequest) + type OnsGroupListResponse struct + Data DataInOnsGroupList + HelpUrl string + RequestId string + func CreateOnsGroupListResponse() (response *OnsGroupListResponse) + type OnsGroupListTag struct + Key string + Value string + type OnsGroupSubDetailRequest struct + GroupId string + InstanceId string + func CreateOnsGroupSubDetailRequest() (request *OnsGroupSubDetailRequest) + type OnsGroupSubDetailResponse struct + Data Data + RequestId string + func CreateOnsGroupSubDetailResponse() (response *OnsGroupSubDetailResponse) + type OnsInstanceBaseInfoRequest struct + InstanceId string + UserId string + func CreateOnsInstanceBaseInfoRequest() (request *OnsInstanceBaseInfoRequest) + type OnsInstanceBaseInfoResponse struct + HelpUrl string + InstanceBaseInfo InstanceBaseInfo + RequestId string + func CreateOnsInstanceBaseInfoResponse() (response *OnsInstanceBaseInfoResponse) + type OnsInstanceCreateRequest struct + InstanceName string + Remark string + func CreateOnsInstanceCreateRequest() (request *OnsInstanceCreateRequest) + type OnsInstanceCreateResponse struct + Data Data + HelpUrl string + RequestId string + func CreateOnsInstanceCreateResponse() (response *OnsInstanceCreateResponse) + type OnsInstanceDeleteRequest struct + InstanceId string + func CreateOnsInstanceDeleteRequest() (request *OnsInstanceDeleteRequest) + type OnsInstanceDeleteResponse struct + HelpUrl string + RequestId string + func CreateOnsInstanceDeleteResponse() (response *OnsInstanceDeleteResponse) + type OnsInstanceInServiceListRequest struct + Tag *[]OnsInstanceInServiceListTag + UserId string + func CreateOnsInstanceInServiceListRequest() (request *OnsInstanceInServiceListRequest) + type OnsInstanceInServiceListResponse struct + Data DataInOnsInstanceInServiceList + HelpUrl string + RequestId string + func CreateOnsInstanceInServiceListResponse() (response *OnsInstanceInServiceListResponse) + type OnsInstanceInServiceListTag struct + Key string + Value string + type OnsInstanceUpdateRequest struct + InstanceId string + InstanceName string + Remark string + func CreateOnsInstanceUpdateRequest() (request *OnsInstanceUpdateRequest) + type OnsInstanceUpdateResponse struct + HelpUrl string + RequestId string + func CreateOnsInstanceUpdateResponse() (response *OnsInstanceUpdateResponse) + type OnsMessageDetailRequest struct + InstanceId string + MsgId string + Topic string + func CreateOnsMessageDetailRequest() (request *OnsMessageDetailRequest) + type OnsMessageDetailResponse struct + Data DataInOnsMessageDetail + HelpUrl string + RequestId string + func CreateOnsMessageDetailResponse() (response *OnsMessageDetailResponse) + type OnsMessageGetByKeyRequest struct + InstanceId string + Key string + Topic string + func CreateOnsMessageGetByKeyRequest() (request *OnsMessageGetByKeyRequest) + type OnsMessageGetByKeyResponse struct + Data DataInOnsMessageGetByKey + HelpUrl string + RequestId string + func CreateOnsMessageGetByKeyResponse() (response *OnsMessageGetByKeyResponse) + type OnsMessageGetByMsgIdRequest struct + InstanceId string + MsgId string + Topic string + func CreateOnsMessageGetByMsgIdRequest() (request *OnsMessageGetByMsgIdRequest) + type OnsMessageGetByMsgIdResponse struct + Data Data + HelpUrl string + RequestId string + func CreateOnsMessageGetByMsgIdResponse() (response *OnsMessageGetByMsgIdResponse) + type OnsMessagePageQueryByTopicRequest struct + BeginTime requests.Integer + CurrentPage requests.Integer + EndTime requests.Integer + InstanceId string + PageSize requests.Integer + TaskId string + Topic string + func CreateOnsMessagePageQueryByTopicRequest() (request *OnsMessagePageQueryByTopicRequest) + type OnsMessagePageQueryByTopicResponse struct + HelpUrl string + MsgFoundDo MsgFoundDo + RequestId string + func CreateOnsMessagePageQueryByTopicResponse() (response *OnsMessagePageQueryByTopicResponse) + type OnsMessagePushRequest struct + ClientId string + GroupId string + InstanceId string + MsgId string + Topic string + func CreateOnsMessagePushRequest() (request *OnsMessagePushRequest) + type OnsMessagePushResponse struct + HelpUrl string + RequestId string + func CreateOnsMessagePushResponse() (response *OnsMessagePushResponse) + type OnsMessageTraceRequest struct + InstanceId string + MsgId string + Topic string + func CreateOnsMessageTraceRequest() (request *OnsMessageTraceRequest) + type OnsMessageTraceResponse struct + Data DataInOnsMessageTrace + HelpUrl string + RequestId string + func CreateOnsMessageTraceResponse() (response *OnsMessageTraceResponse) + type OnsRegionListRequest struct + func CreateOnsRegionListRequest() (request *OnsRegionListRequest) + type OnsRegionListResponse struct + Data DataInOnsRegionList + HelpUrl string + RequestId string + func CreateOnsRegionListResponse() (response *OnsRegionListResponse) + type OnsRestMessageDo struct + Body string + BodyCRC int + BornHost string + BornTimestamp int64 + Flag int + InstanceId string + MsgId string + OffsetId string + PropertyList PropertyListInOnsDLQMessagePageQueryByGroupId + ReconsumeTimes int + StoreHost string + StoreSize int + StoreTimestamp int64 + Topic string + type OnsTopicCreateRequest struct + InstanceId string + MessageType requests.Integer + Remark string + Topic string + UserId string + func CreateOnsTopicCreateRequest() (request *OnsTopicCreateRequest) + type OnsTopicCreateResponse struct + HelpUrl string + RequestId string + func CreateOnsTopicCreateResponse() (response *OnsTopicCreateResponse) + type OnsTopicDeleteRequest struct + InstanceId string + Topic string + func CreateOnsTopicDeleteRequest() (request *OnsTopicDeleteRequest) + type OnsTopicDeleteResponse struct + HelpUrl string + RequestId string + func CreateOnsTopicDeleteResponse() (response *OnsTopicDeleteResponse) + type OnsTopicListRequest struct + InstanceId string + Tag *[]OnsTopicListTag + Topic string + UserId string + func CreateOnsTopicListRequest() (request *OnsTopicListRequest) + type OnsTopicListResponse struct + Data DataInOnsTopicList + HelpUrl string + RequestId string + func CreateOnsTopicListResponse() (response *OnsTopicListResponse) + type OnsTopicListTag struct + Key string + Value string + type OnsTopicStatusRequest struct + InstanceId string + Topic string + func CreateOnsTopicStatusRequest() (request *OnsTopicStatusRequest) + type OnsTopicStatusResponse struct + Data Data + HelpUrl string + RequestId string + func CreateOnsTopicStatusResponse() (response *OnsTopicStatusResponse) + type OnsTopicSubDetailRequest struct + InstanceId string + Topic string + func CreateOnsTopicSubDetailRequest() (request *OnsTopicSubDetailRequest) + type OnsTopicSubDetailResponse struct + Data Data + RequestId string + func CreateOnsTopicSubDetailResponse() (response *OnsTopicSubDetailResponse) + type OnsTopicUpdateRequest struct + InstanceId string + Perm requests.Integer + Topic string + func CreateOnsTopicUpdateRequest() (request *OnsTopicUpdateRequest) + type OnsTopicUpdateResponse struct + HelpUrl string + RequestId string + func CreateOnsTopicUpdateResponse() (response *OnsTopicUpdateResponse) + type OnsTraceGetResultRequest struct + QueryId string + func CreateOnsTraceGetResultRequest() (request *OnsTraceGetResultRequest) + type OnsTraceGetResultResponse struct + HelpUrl string + RequestId string + TraceData TraceData + func CreateOnsTraceGetResultResponse() (response *OnsTraceGetResultResponse) + type OnsTraceQueryByMsgIdRequest struct + BeginTime requests.Integer + EndTime requests.Integer + InstanceId string + MsgId string + Topic string + func CreateOnsTraceQueryByMsgIdRequest() (request *OnsTraceQueryByMsgIdRequest) + type OnsTraceQueryByMsgIdResponse struct + HelpUrl string + QueryId string + RequestId string + func CreateOnsTraceQueryByMsgIdResponse() (response *OnsTraceQueryByMsgIdResponse) + type OnsTraceQueryByMsgKeyRequest struct + BeginTime requests.Integer + EndTime requests.Integer + InstanceId string + MsgKey string + Topic string + func CreateOnsTraceQueryByMsgKeyRequest() (request *OnsTraceQueryByMsgKeyRequest) + type OnsTraceQueryByMsgKeyResponse struct + HelpUrl string + QueryId string + RequestId string + func CreateOnsTraceQueryByMsgKeyResponse() (response *OnsTraceQueryByMsgKeyResponse) + type OnsTrendGroupOutputTpsRequest struct + BeginTime requests.Integer + EndTime requests.Integer + GroupId string + InstanceId string + Period requests.Integer + Topic string + Type requests.Integer + func CreateOnsTrendGroupOutputTpsRequest() (request *OnsTrendGroupOutputTpsRequest) + type OnsTrendGroupOutputTpsResponse struct + Data Data + HelpUrl string + RequestId string + func CreateOnsTrendGroupOutputTpsResponse() (response *OnsTrendGroupOutputTpsResponse) + type OnsTrendTopicInputTpsRequest struct + BeginTime requests.Integer + EndTime requests.Integer + InstanceId string + Period requests.Integer + Topic string + Type requests.Integer + func CreateOnsTrendTopicInputTpsRequest() (request *OnsTrendTopicInputTpsRequest) + type OnsTrendTopicInputTpsResponse struct + Data Data + HelpUrl string + RequestId string + func CreateOnsTrendTopicInputTpsResponse() (response *OnsTrendTopicInputTpsResponse) + type OpenOnsServiceRequest struct + func CreateOpenOnsServiceRequest() (request *OpenOnsServiceRequest) + type OpenOnsServiceResponse struct + OrderId string + RequestId string + func CreateOpenOnsServiceResponse() (response *OpenOnsServiceResponse) + type PropertyListInOnsDLQMessageGetById struct + MessageProperty []MessageProperty + type PropertyListInOnsDLQMessagePageQueryByGroupId struct + MessageProperty []MessageProperty + type PropertyListInOnsMessageDetail struct + MessageProperty []MessageProperty + type PropertyListInOnsMessageGetByKey struct + MessageProperty []MessageProperty + type PropertyListInOnsMessageGetByMsgId struct + MessageProperty []MessageProperty + type PropertyListInOnsMessagePageQueryByTopic struct + MessageProperty []MessageProperty + type PublishInfoDo struct + CreateTime int64 + IndependentNaming bool + InstanceId string + MessageType int + Owner string + Relation int + RelationName string + Remark string + ServiceStatus int + Tags TagsInOnsTopicList + Topic string + type RecordsInOnsTrendGroupOutputTps struct + StatsDataDo []StatsDataDo + type RecordsInOnsTrendTopicInputTps struct + StatsDataDo []StatsDataDo + type RegionDo struct + ChannelId int + ChannelName string + CreateTime int64 + Id int64 + OnsRegionId string + RegionName string + UpdateTime int64 + type RunningDataList struct + ConsumerRunningDataDo []ConsumerRunningDataDo + type StatsDataDo struct + X int64 + Y float64 + type SubClientInfoDo struct + ClientHost string + CostTime int + ReconsumeTimes int + Status string + SubGroupName string + SubTime int64 + type SubList struct + SubMapDo []SubMapDo + type SubMapDo struct + ClientList ClientList + FailCount int + SubGroupName string + SuccessCount int + type SubscribeInfoDo struct + CreateTime int64 + GroupId string + GroupType string + IndependentNaming bool + InstanceId string + Owner string + Remark string + Tags TagsInOnsGroupList + UpdateTime int64 + type SubscriptionData struct + SubString string + SubVersion int64 + TagsSet TagsSet + Topic string + type SubscriptionDataListInOnsGroupSubDetail struct + SubscriptionDataListItem []SubscriptionDataListItem + type SubscriptionDataListInOnsTopicSubDetail struct + SubscriptionDataListItem []SubscriptionDataListItem + type SubscriptionDataListItem struct + GroupId string + MessageModel string + SubString string + Topic string + type SubscriptionSet struct + SubscriptionData []SubscriptionData + type Tag struct + Key string + Value string + type TagResource struct + InstanceId string + ResourceId string + ResourceType string + TagKey string + TagValue string + type TagResources struct + TagResource []TagResource + type TagResourcesRequest struct + InstanceId string + ResourceId *[]string + ResourceType string + Tag *[]TagResourcesTag + func CreateTagResourcesRequest() (request *TagResourcesRequest) + type TagResourcesResponse struct + RequestId string + func CreateTagResourcesResponse() (response *TagResourcesResponse) + type TagResourcesTag struct + Key string + Value string + type TagsInOnsGroupList struct + Tag []Tag + type TagsInOnsInstanceInServiceList struct + Tag []Tag + type TagsInOnsTopicList struct + Tag []Tag + type TagsSet struct + Tag []string + type ThreadTrackDo struct + Thread string + TrackList TrackList + type TraceData struct + CreateTime int64 + InstanceId string + MsgId string + MsgKey string + QueryId string + Status string + Topic string + TraceList TraceList + UpdateTime int64 + UserId string + type TraceList struct + TraceMapDo []TraceMapDo + type TraceMapDo struct + BornHost string + CostTime int + MsgId string + MsgKey string + PubGroupName string + PubTime int64 + Status string + SubList SubList + Tag string + Topic string + type TrackList struct + Track []string + type UntagResourcesRequest struct + All requests.Boolean + InstanceId string + ResourceId *[]string + ResourceType string + TagKey *[]string + func CreateUntagResourcesRequest() (request *UntagResourcesRequest) + type UntagResourcesResponse struct + RequestId string + func CreateUntagResourcesResponse() (response *UntagResourcesResponse)