2542
ctx context.Context,
2543
req *matchingservice.ForceUnloadTaskQueuePartitionRequest,
2544
>
) (*matchingservice.ForceUnloadTaskQueuePartitionResponse, error) {
matching_engine.go
2545
>
partition := tqid.PartitionFromPartitionProto(req.GetTaskQueuePartition(), req.GetNamespaceId())
2546
>
2547
>
wasLoaded := e.unloadTaskQueuePartitionByKey(partition, nil, unloadCauseForce)
2548
>
return &matchingservice.ForceUnloadTaskQueuePartitionResponse{WasLoaded: wasLoaded}, nil
2549
>
}
2550
2551
func (e *matchingEngineImpl) UpdateTaskQueueUserData(ctx context.Context, request *matchingservice.UpdateTaskQueueUserDataRequest) (*matchingservice.UpdateTaskQueueUserDataResponse, error) {