timeout time.Duration,
callerInfo headers.CallerInfo,
ctx := headers.SetCallerInfo(
context.Background(),
callerInfo,
)
ctx = headers.SetCallerName(ctx, namespaceName)
return context.WithTimeout(ctx, timeout)
}
func getReplicaitonCallerInfo(priority enumsspb.TaskPriority) headers.CallerInfo {