Method Publish

pubsub_commands.go:20–28

Publish posts the message to the channel.

(ctx context.Context, channel string, message interface{})

// Publish posts the message to the channel.
func (c cmdable) Publish(ctx context.Context, channel string, message interface{}) *IntCmd {
	cmd := NewIntCmd(ctx, "publish", channel, message)
	_ = c(ctx, cmd)
	// Record PubSub message sent (if command succeeded)
	if cmd.Err() == nil {
		otel.RecordPubSubMessage(ctx, nil, "sent", channel, false)
	}
	return cmd
}

func (c cmdable) SPublish(ctx context.Context, channel string, message interface{}) *IntCmd {
	cmd := NewIntCmd(ctx, "spublish", channel, message)