seaweedfs/weed/mq/broker/brokder_grpc_pub.go

17 lines
379 B
Go
Raw Normal View History

2022-07-31 20:23:44 +00:00
package broker
import (
"github.com/seaweedfs/seaweedfs/weed/pb/mq_pb"
)
/*
The messages is buffered in memory, and saved to filer under
/topics/<topic>/<date>/<hour>/<segment>/*.msg
/topics/<topic>/<date>/<hour>/segment
/topics/<topic>/info/segment_<id>.meta
*/
func (broker *MessageQueueBroker) Publish(stream mq_pb.SeaweedMessaging_PublishServer) error {
return nil
}