18
}
19
21
>
return RoutingKeyExtractor{
22
>
serializer: *tasktoken.NewSerializer(),
23
>
}
24
>
}
25
26
// WorkflowServiceExtractor returns a RoutingKeyExtractorFunc that extracts the
27
// routing key from WorkflowService API requests using the provided
28
// RoutingKeyExtractor.
29
>
func WorkflowServiceExtractor(extractor RoutingKeyExtractor) RoutingKeyExtractorFunc {
routing_key_extractor.go
30
>
return func(_ context.Context, req any, fullMethod string) namespace.RoutingKey {
31
>
// Only process WorkflowService APIs
32
>
if !strings.HasPrefix(fullMethod, api.WorkflowServicePrefix) {
33
return namespace.RoutingKey{}
34
}