lsm/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2025-10-15 20:06:19 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

move go client out

Browse Source
This commit is contained in:
Chris Lu
2020-04-18 12:11:50 -07:00
parent 5af49c7aa5
commit ef1274edc9
3 changed files with 0 additions and 39 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
weed/messaging/client/client.go
View File

@@ -1,11 +0,0 @@
package client
type MessagingClient struct {
bootstrapBrokers []string
}
func NewMessagingClient(bootstrapBrokers []string) *MessagingClient {
return &MessagingClient{
bootstrapBrokers: bootstrapBrokers,
}
}

14
weed/messaging/client/publisher.go
View File

@@ -1,14 +0,0 @@
package client
import "github.com/chrislusf/seaweedfs/weed/pb/messaging_pb"
type Publisher struct {
}
func (c *MessagingClient) NewPublisher(namespace, topic string) *Publisher {
return &Publisher{}
}
func (p *Publisher) Publish(m *messaging_pb.RawData) error{
return nil
}

14
weed/messaging/client/subscriber.go
View File

@@ -1,14 +0,0 @@
package client
import "github.com/chrislusf/seaweedfs/weed/pb/messaging_pb"
type Subscriber struct {
}
func (c *MessagingClient) NewSubscriber(namespace, topic string) *Subscriber {
return &Subscriber{}
}
func (p *Subscriber) Subscribe(processFn func(m *messaging_pb.Message)) error{
return nil
}