pubsub

package

v0.39.0 Latest Latest Go to latest Published: Mar 13, 2026 License: Apache-2.0 Imports: 2 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type PubSub struct {
	// contains filtered or unexported fields
}

func NewPubSub() *PubSub

func (ps *PubSub) Publish(topic string, message []byte)

func (ps *PubSub) Subscribe(topic string) (ch chan []byte, sub Sub)

func (ps *PubSub) Unsubscribe(sub Sub)

type Sub struct {
	Id    int64
	Topic string
}