// PublishStream is called when a client sends a message to the stream.
PublishStream is called when a client sends a message to the stream.
// PublishStream is called when a client sends a message to the stream .
func (d *CouchbaseDatasource) PublishStream(_ context.Context, req *backend.PublishStreamRequest) (*backend.PublishStreamResponse, error) {
	log.DefaultLogger.Info("PublishStream called", "request", req)
	return &backend.PublishStreamResponse{
		Status: backend.PublishStreamStatusPermissionDenied,
	}, nil
}
func ( d * CouchbaseDatasource ) PublishStream ( _ context . Context , req * backend . PublishStreamRequest ) ( * backend . PublishStreamResponse , error ) { log . DefaultLogger . Info ( " " , " " , req ) return & backend . PublishStreamResponse { Status : backend . PublishStreamStatusPermissionDenied , } , nil }
PublishStream is called when a client sends a message to the stream.
PublishStream is called when a client sends a message to the stream .
// Do not allow publishing at all.