func (wh *WorkflowHandler) DescribeTaskList(
	ctx context.Context,
	request *types.DescribeTaskListRequest,
) (resp *types.DescribeTaskListResponse, retError error) {
	defer log.CapturePanic(wh.GetLogger(), &retError)

	scope, sw := wh.startRequestProfileWithDomain(ctx, metrics.FrontendDescribeTaskListScope, request)
	defer sw.Stop()

	if wh.isShuttingDown() {
		return nil, errShuttingDown
	}

	if err := wh.versionChecker.ClientSupported(ctx, wh.config.EnableClientVersionCheck()); err != nil {
		return nil, wh.error(err, scope)
	}

	if request == nil {
		return nil, wh.error(errRequestNotSet, scope)
	}

	if request.GetDomain() == "" {
		return nil, wh.error(errDomainNotSet, scope)
	}

	if ok := wh.allow(true, request); !ok {
		return nil, wh.error(createServiceBusyError(), scope)
	}

	domainID, err := wh.GetDomainCache().GetDomainID(request.GetDomain())
	if err != nil {
		return nil, wh.error(err, scope)
	}

	if err := wh.validateTaskList(request.TaskList, scope, request.GetDomain()); err != nil {
		return nil, wh.error(err, scope)
	}

	if request.TaskListType == nil {
		return nil, wh.error(errTaskListTypeNotSet, scope)
	}

	response, err := wh.GetMatchingClient().DescribeTaskList(ctx, &types.MatchingDescribeTaskListRequest{
		DomainUUID:  domainID,
		DescRequest: request,
	})
	if err != nil {
		return nil, wh.error(err, scope)
	}

	return response, nil
}
// DescribeTaskList returns information about the target tasklist, right now this API returns the
// pollers which polled this tasklist in last few minutes. If includeTaskListStatus field is true,
// it will also return status of tasklist's ackManager (readLevel, ackLevel, backlogCountHint and taskIDBlock).
DescribeTaskList returns information about the target tasklist, right now this API returns the
pollers which polled this tasklist in last few minutes. If includeTaskListStatus field is true,
it will also return status of tasklist's ackManager (readLevel, ackLevel, backlogCountHint and taskIDBlock).
// DescribeTaskList returns information about the target tasklist right now this API returns the // pollers which polled this tasklist in last few minutes . If includeTaskListStatus field is true // it will also return status of tasklist ' s ackManager ( readLevel ackLevel backlogCountHint and taskIDBlock ) .
func (wh *WorkflowHandler) DescribeTaskList(
	ctx context.Context,
	request *types.DescribeTaskListRequest,
) (resp *types.DescribeTaskListResponse, retError error) {
	defer log.CapturePanic(wh.GetLogger(), &retError)
	scope, sw := wh.startRequestProfileWithDomain(ctx, metrics.FrontendDescribeTaskListScope, request)
	defer sw.Stop()
	if wh.isShuttingDown() {
		return nil, errShuttingDown
	}
	if err := wh.versionChecker.ClientSupported(ctx, wh.config.EnableClientVersionCheck()); err != nil {
		return nil, wh.error(err, scope)
	}
	if request == nil {
		return nil, wh.error(errRequestNotSet, scope)
	}
	if request.GetDomain() == "" {
		return nil, wh.error(errDomainNotSet, scope)
	}
	if ok := wh.allow(true, request); !ok {
		return nil, wh.error(createServiceBusyError(), scope)
	}
	domainID, err := wh.GetDomainCache().GetDomainID(request.GetDomain())
	if err != nil {
		return nil, wh.error(err, scope)
	}
	if err := wh.validateTaskList(request.TaskList, scope, request.GetDomain()); err != nil {
		return nil, wh.error(err, scope)
	}
	if request.TaskListType == nil {
		return nil, wh.error(errTaskListTypeNotSet, scope)
	}
	response, err := wh.GetMatchingClient().DescribeTaskList(ctx, &types.MatchingDescribeTaskListRequest{
		DomainUUID:  domainID,
		DescRequest: request,
	})
	if err != nil {
		return nil, wh.error(err, scope)
	}
	return response, nil
}
func ( wh * WorkflowHandler ) DescribeTaskList ( ctx context . Context , request * types . DescribeTaskListRequest , ) ( resp * types . DescribeTaskListResponse , retError error ) { defer log . CapturePanic ( wh . GetLogger ( ) , & retError ) scope , sw := wh . startRequestProfileWithDomain ( ctx , metrics . FrontendDescribeTaskListScope , request ) defer sw . Stop ( ) if wh . isShuttingDown ( ) { return nil , errShuttingDown } if err := wh . versionChecker . ClientSupported ( ctx , wh . config . EnableClientVersionCheck ( ) ) ; err != nil { return nil , wh . error ( err , scope ) } if request == nil { return nil , wh . error ( errRequestNotSet , scope ) } if request . GetDomain ( ) == " " { return nil , wh . error ( errDomainNotSet , scope ) } if ok := wh . allow ( true , request ) ; ! ok { return nil , wh . error ( createServiceBusyError ( ) , scope ) } domainID , err := wh . GetDomainCache ( ) . GetDomainID ( request . GetDomain ( ) ) if err != nil { return nil , wh . error ( err , scope ) } if err := wh . validateTaskList ( request . TaskList , scope , request . GetDomain ( ) ) ; err != nil { return nil , wh . error ( err , scope ) } if request . TaskListType == nil { return nil , wh . error ( errTaskListTypeNotSet , scope ) } response , err := wh . GetMatchingClient ( ) . DescribeTaskList ( ctx , & types . MatchingDescribeTaskListRequest { DomainUUID : domainID , DescRequest : request , } ) if err != nil { return nil , wh . error ( err , scope ) } return response , nil }
DescribeTaskList returns information about the target tasklist, right now this API returns the
pollers which polled this tasklist in last few minutes.
DescribeTaskList returns information about the target tasklist right now this API returns the pollers which polled this tasklist in last few minutes .