client

Documentation

Index

• type JcqClient
  • func NewJcqClient(credential *core.Credential) *JcqClient
  • func (c *JcqClient) AddPermission(request *jcq.AddPermissionRequest) (*jcq.AddPermissionResponse, error)
  • func (c *JcqClient) CleanMessages(request *jcq.CleanMessagesRequest) (*jcq.CleanMessagesResponse, error)
  • func (c *JcqClient) CreateSubscription(request *jcq.CreateSubscriptionRequest) (*jcq.CreateSubscriptionResponse, error)
  • func (c *JcqClient) CreateTopic(request *jcq.CreateTopicRequest) (*jcq.CreateTopicResponse, error)
  • func (c *JcqClient) DeleteDeadLetters(request *jcq.DeleteDeadLettersRequest) (*jcq.DeleteDeadLettersResponse, error)
  • func (c *JcqClient) DeleteSubscription(request *jcq.DeleteSubscriptionRequest) (*jcq.DeleteSubscriptionResponse, error)
  • func (c *JcqClient) DeleteTopic(request *jcq.DeleteTopicRequest) (*jcq.DeleteTopicResponse, error)
  • func (c *JcqClient) DescribeAccessPoint(request *jcq.DescribeAccessPointRequest) (*jcq.DescribeAccessPointResponse, error)
  • func (c *JcqClient) DescribeConsumerGroupIds(request *jcq.DescribeConsumerGroupIdsRequest) (*jcq.DescribeConsumerGroupIdsResponse, error)
  • func (c *JcqClient) DescribeDeadLetterNumbers(request *jcq.DescribeDeadLetterNumbersRequest) (*jcq.DescribeDeadLetterNumbersResponse, error)
  • func (c *JcqClient) DescribeDeadLetterNumbersWithTopic(request *jcq.DescribeDeadLetterNumbersWithTopicRequest) (*jcq.DescribeDeadLetterNumbersWithTopicResponse, error)
  • func (c *JcqClient) DescribeMessage(request *jcq.DescribeMessageRequest) (*jcq.DescribeMessageResponse, error)
  • func (c *JcqClient) DescribeMessageTrace(request *jcq.DescribeMessageTraceRequest) (*jcq.DescribeMessageTraceResponse, error)
  • func (c *JcqClient) DescribeMessages(request *jcq.DescribeMessagesRequest) (*jcq.DescribeMessagesResponse, error)
  • func (c *JcqClient) DescribeMessagesByBusinessId(request *jcq.DescribeMessagesByBusinessIdRequest) (*jcq.DescribeMessagesByBusinessIdResponse, error)
  • func (c *JcqClient) DescribePermission(request *jcq.DescribePermissionRequest) (*jcq.DescribePermissionResponse, error)
  • func (c *JcqClient) DescribeSubscription(request *jcq.DescribeSubscriptionRequest) (*jcq.DescribeSubscriptionResponse, error)
  • func (c *JcqClient) DescribeSubscriptions(request *jcq.DescribeSubscriptionsRequest) (*jcq.DescribeSubscriptionsResponse, error)
  • func (c *JcqClient) DescribeTopic(request *jcq.DescribeTopicRequest) (*jcq.DescribeTopicResponse, error)
  • func (c *JcqClient) DescribeTopics(request *jcq.DescribeTopicsRequest) (*jcq.DescribeTopicsResponse, error)
  • func (c *JcqClient) DisableLogger()
  • func (c *JcqClient) ListDeadLetters(request *jcq.ListDeadLettersRequest) (*jcq.ListDeadLettersResponse, error)
  • func (c *JcqClient) ModifySubscriptionAttribute(request *jcq.ModifySubscriptionAttributeRequest) (*jcq.ModifySubscriptionAttributeResponse, error)
  • func (c *JcqClient) RemovePermission(request *jcq.RemovePermissionRequest) (*jcq.RemovePermissionResponse, error)
  • func (c *JcqClient) ResendDeadLetters(request *jcq.ResendDeadLettersRequest) (*jcq.ResendDeadLettersResponse, error)
  • func (c *JcqClient) ResetConsumeOffset(request *jcq.ResetConsumeOffsetRequest) (*jcq.ResetConsumeOffsetResponse, error)
  • func (c *JcqClient) SetConfig(config *core.Config)
  • func (c *JcqClient) SetLogger(logger core.Logger)

Types

type JcqClient

type JcqClient struct {
	core.JDCloudClient
}

func NewJcqClient

func NewJcqClient(credential *core.Credential) *JcqClient

func (*JcqClient) AddPermission

func (c *JcqClient) AddPermission(request *jcq.AddPermissionRequest) (*jcq.AddPermissionResponse, error)

对当前topic授予目标用户特定权限

func (*JcqClient) CleanMessages

func (c *JcqClient) CleanMessages(request *jcq.CleanMessagesRequest) (*jcq.CleanMessagesResponse, error)

清除消息

func (*JcqClient) CreateSubscription

func (c *JcqClient) CreateSubscription(request *jcq.CreateSubscriptionRequest) (*jcq.CreateSubscriptionResponse, error)

创建订阅

func (*JcqClient) CreateTopic

func (c *JcqClient) CreateTopic(request *jcq.CreateTopicRequest) (*jcq.CreateTopicResponse, error)

创建一个指定名称的topic

func (*JcqClient) DeleteDeadLetters

func (c *JcqClient) DeleteDeadLetters(request *jcq.DeleteDeadLettersRequest) (*jcq.DeleteDeadLettersResponse, error)

删除死信消息

func (*JcqClient) DeleteSubscription

func (c *JcqClient) DeleteSubscription(request *jcq.DeleteSubscriptionRequest) (*jcq.DeleteSubscriptionResponse, error)

删除订阅

func (*JcqClient) DeleteTopic

func (c *JcqClient) DeleteTopic(request *jcq.DeleteTopicRequest) (*jcq.DeleteTopicResponse, error)

删除单个topic

func (*JcqClient) DescribeAccessPoint

func (c *JcqClient) DescribeAccessPoint(request *jcq.DescribeAccessPointRequest) (*jcq.DescribeAccessPointResponse, error)

查看接入点接口

func (*JcqClient) DescribeConsumerGroupIds

func (c *JcqClient) DescribeConsumerGroupIds(request *jcq.DescribeConsumerGroupIdsRequest) (*jcq.DescribeConsumerGroupIdsResponse, error)

consumerGroupId列表

func (*JcqClient) DescribeDeadLetterNumbers

func (c *JcqClient) DescribeDeadLetterNumbers(request *jcq.DescribeDeadLetterNumbersRequest) (*jcq.DescribeDeadLetterNumbersResponse, error)

死信消息数(按照用户或者consumerGroupId)

func (*JcqClient) DescribeDeadLetterNumbersWithTopic

func (c *JcqClient) DescribeDeadLetterNumbersWithTopic(request *jcq.DescribeDeadLetterNumbersWithTopicRequest) (*jcq.DescribeDeadLetterNumbersWithTopicResponse, error)

死信消息数

func (*JcqClient) DescribeMessage

func (c *JcqClient) DescribeMessage(request *jcq.DescribeMessageRequest) (*jcq.DescribeMessageResponse, error)

查询message详情

func (*JcqClient) DescribeMessageTrace

func (c *JcqClient) DescribeMessageTrace(request *jcq.DescribeMessageTraceRequest) (*jcq.DescribeMessageTraceResponse, error)

查询消息轨迹

func (*JcqClient) DescribeMessages

func (c *JcqClient) DescribeMessages(request *jcq.DescribeMessagesRequest) (*jcq.DescribeMessagesResponse, error)

消息列表

func (*JcqClient) DescribeMessagesByBusinessId

func (c *JcqClient) DescribeMessagesByBusinessId(request *jcq.DescribeMessagesByBusinessIdRequest) (*jcq.DescribeMessagesByBusinessIdResponse, error)

根据businessId查询消息

func (*JcqClient) DescribePermission

func (c *JcqClient) DescribePermission(request *jcq.DescribePermissionRequest) (*jcq.DescribePermissionResponse, error)

查看当前topic授予了哪些用户哪些权限

func (*JcqClient) DescribeSubscription

func (c *JcqClient) DescribeSubscription(request *jcq.DescribeSubscriptionRequest) (*jcq.DescribeSubscriptionResponse, error)

查询订阅详情

func (*JcqClient) DescribeSubscriptions

func (c *JcqClient) DescribeSubscriptions(request *jcq.DescribeSubscriptionsRequest) (*jcq.DescribeSubscriptionsResponse, error)

订阅列表

func (*JcqClient) DescribeTopic

func (c *JcqClient) DescribeTopic(request *jcq.DescribeTopicRequest) (*jcq.DescribeTopicResponse, error)

查询topic详情

func (*JcqClient) DescribeTopics

func (c *JcqClient) DescribeTopics(request *jcq.DescribeTopicsRequest) (*jcq.DescribeTopicsResponse, error)

查询topic列表

func (*JcqClient) DisableLogger

func (c *JcqClient) DisableLogger()

func (*JcqClient) ListDeadLetters

func (c *JcqClient) ListDeadLetters(request *jcq.ListDeadLettersRequest) (*jcq.ListDeadLettersResponse, error)

死信队列列表

func (*JcqClient) ModifySubscriptionAttribute

func (c *JcqClient) ModifySubscriptionAttribute(request *jcq.ModifySubscriptionAttributeRequest) (*jcq.ModifySubscriptionAttributeResponse, error)

修改订阅

func (*JcqClient) RemovePermission

func (c *JcqClient) RemovePermission(request *jcq.RemovePermissionRequest) (*jcq.RemovePermissionResponse, error)

删除当前topic对目标用户授权的权限

func (*JcqClient) ResendDeadLetters

func (c *JcqClient) ResendDeadLetters(request *jcq.ResendDeadLettersRequest) (*jcq.ResendDeadLettersResponse, error)

重发死信消息

func (*JcqClient) ResetConsumeOffset

func (c *JcqClient) ResetConsumeOffset(request *jcq.ResetConsumeOffsetRequest) (*jcq.ResetConsumeOffsetResponse, error)

重置消费位

func (*JcqClient) SetConfig

func (c *JcqClient) SetConfig(config *core.Config)

func (*JcqClient) SetLogger

func (c *JcqClient) SetLogger(logger core.Logger)