(ctx context.Context, channel string, message interface{})
| 28 | } |
| 29 | |
| 30 | func (c cmdable) SPublish(ctx context.Context, channel string, message interface{}) *IntCmd { |
| 31 | cmd := NewIntCmd(ctx, "spublish", channel, message) |
| 32 | _ = c(ctx, cmd) |
| 33 | // Record PubSub message sent (if command succeeded) |
| 34 | if cmd.Err() == nil { |
| 35 | otel.RecordPubSubMessage(ctx, nil, "sent", channel, true) |
| 36 | } |
| 37 | return cmd |
| 38 | } |
| 39 | |
| 40 | func (c cmdable) PubSubChannels(ctx context.Context, pattern string) *StringSliceCmd { |
| 41 | args := []interface{}{"pubsub", "channels"} |
nothing calls this directly
no test coverage detected