Method Publish

internal/updatepipe/pubsub/pubsub.go:8–8

(key, payload string)

	Subscribe(ctx context.Context, key string) error
	Unsubscribe(ctx context.Context, key string) error
	Publish(key, payload string) error
	Listener() chan Msg
	Close() error
}