(name string)
| 528 | } |
| 529 | |
| 530 | func validateConsumerName(name string) error { |
| 531 | if name == "" { |
| 532 | return fmt.Errorf("%w: name is required", ErrInvalidConsumerName) |
| 533 | } |
| 534 | if strings.ContainsAny(name, ">*. /\\\t\r\n") { |
| 535 | return fmt.Errorf("%w: %q", ErrInvalidConsumerName, name) |
| 536 | } |
| 537 | return nil |
| 538 | } |
| 539 | |
| 540 | func unpinConsumer(ctx context.Context, js *jetStream, stream, consumer, group string) error { |
| 541 | ctx, cancel := js.wrapContextWithoutDeadline(ctx) |