diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-05-17 22:44:20 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-05-17 22:44:20 -0700 |
| commit | 2bfd810912b5c0967f30abf6ebacd8f8afa314aa (patch) | |
| tree | 870bd08f50c83b14ead1db19f4acd7b2316ffef6 /weed/command/msg_broker.go | |
| parent | 85aeead3d2c154fd09f274ada83b836d65b1ebf5 (diff) | |
| download | seaweedfs-2bfd810912b5c0967f30abf6ebacd8f8afa314aa.tar.xz seaweedfs-2bfd810912b5c0967f30abf6ebacd8f8afa314aa.zip | |
combine msgBroker into weed server command
Diffstat (limited to 'weed/command/msg_broker.go')
| -rw-r--r-- | weed/command/msg_broker.go | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/weed/command/msg_broker.go b/weed/command/msg_broker.go index bab1083ab..b4b5855ff 100644 --- a/weed/command/msg_broker.go +++ b/weed/command/msg_broker.go @@ -20,10 +20,10 @@ import ( ) var ( - messageBrokerStandaloneOptions QueueOptions + messageBrokerStandaloneOptions MessageBrokerOptions ) -type QueueOptions struct { +type MessageBrokerOptions struct { filer *string ip *string port *int @@ -41,8 +41,8 @@ func init() { } var cmdMsgBroker = &Command{ - UsageLine: "msg.broker [-port=17777] [-filer=<ip:port>]", - Short: "<WIP> start a message queue broker", + UsageLine: "msgBroker [-port=17777] [-filer=<ip:port>]", + Short: "start a message queue broker", Long: `start a message queue broker The broker can accept gRPC calls to write or read messages. The messages are stored via filer. @@ -59,7 +59,7 @@ func runMsgBroker(cmd *Command, args []string) bool { } -func (msgBrokerOpt *QueueOptions) startQueueServer() bool { +func (msgBrokerOpt *MessageBrokerOptions) startQueueServer() bool { grace.SetupProfiling(*messageBrokerStandaloneOptions.cpuprofile, *messageBrokerStandaloneOptions.memprofile) |
