()
| 355 | ) |
| 356 | |
| 357 | func generateConsName() string { |
| 358 | name := nuid.Next() |
| 359 | sha := sha256.New() |
| 360 | sha.Write([]byte(name)) |
| 361 | b := sha.Sum(nil) |
| 362 | for i := 0; i < 8; i++ { |
| 363 | b[i] = rdigits[int(b[i]%base)] |
| 364 | } |
| 365 | return string(b[:8]) |
| 366 | } |
| 367 | |
| 368 | func getConsumer(ctx context.Context, js *jetStream, stream, name string) (Consumer, error) { |
| 369 | info, err := fetchConsumerInfo(ctx, js, stream, name) |
no test coverage detected