pubsub

package

v0.0.0-...-56cb166 Latest Latest Go to latest Published: Feb 19, 2025 License: AGPL-3.0 Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

func NewPubSubHandler(abort <-chan struct{}, hub Hub) http.Handler

NewPubSubHandler returns a new http.Handler that handles pubsub messages.

type Hub interface {
	Publish(string, interface{}) (func(), error)
}

Hub defines the publish method that the handler uses to publish messages on the centralhub of the apiserver.