-v1.0.0

add queue support
kubemq-io · Jul 17, 2019 · 6b31561 · 6b31561
1 parent b7e172f
commit 6b31561
Show file tree

Hide file tree

Showing 14 changed files with 958 additions and 352 deletions.
diff --git a/README.md b/README.md
@@ -19,11 +19,13 @@ Available Commands:
   help        Help about any command
   metrics     Call kubemq metrics endpoint
   mon         monitor messages/requests channels
-  send        send event / event_store / command / query
-  subscribe   subscribe to events / events_store / commands / queries
+  pubsub      send and receive pub/sub real-time and persistent events
+  queue       send and receive queue messages
+  rpc         send and receive rpc commands and queries
   test        test your kubemq installation
   version     print kubemq version
 
+
 Flags:
   -h, --help   help for kubetools
 
@@ -51,6 +53,7 @@ Available Commands:
   events       monitor events channels
   events_store monitor events store channels
   queries      monitor query channels
+  queue        monitor queue channels
 
 Flags:
   -h, --help   help for mon
@@ -70,115 +73,316 @@ Run `kubetools mon commands <ChannelName>` or `kubetools m c <ChannelName>` will
 #### Monitor Query Channel
 Run `kubetools mon queries <ChannelName>` or `kubetools m q <ChannelName>` will monitor and show all traffic in <ChannelName> Queries channel.
 
-### Send
-Run `kubetools send` or `kubetools s` for sending messages to any channel.
+#### Monitor Queue Channel
+Run `kubetools mon queue <ChannelName>` or `kubetools m qu <ChannelName>` will monitor and show all traffic in <ChannelName> Queue channel.
 
-Available sub commands:
+
+### PubSub
+Run `kubetools pubsub` or `kubetools p` for publish and subscribe real-time and persistent events.
+
+Available PubSub commands:
+
+```
+Usage:
+  kubetools pubsub [command]
+
+Aliases:
+  pubsub, p, ps
+
+Available Commands:
+  receive     receive pub/sub real-time and persistent events
+  send        send pub/sub real-time and persistent events
+
+Flags:
+  -h, --help                     help for pubsub
+  -t, --pubsubTransport string   set transport type, grpc or rest (default "grpc")
+
+Use "kubetools pubsub [command] --help" for more information about a command.
+```
+
+
+### PubSub Send
+Run `kubetools pubsub send` or `kubetools p s` for publish real-time and persistent events.
 
 ```
 Usage:
-  kubetools send [command]
+  kubetools pubsub send [command]
 
 Aliases:
   send, s
 
 Available Commands:
-  command     send command to a channel
-  event       send event to a channel
-  event_store send event_store to a channel
-  query       send query to a channel
+  events       send real-time event to a channel
+  events_store send persistent event to a channel
+
+Flags:
+  -h, --help   help for send
+
+Global Flags:
+  -t, --pubsubTransport string   set transport type, grpc or rest (default "grpc")
+
+Use "kubetools pubsub send [command] --help" for more information about a command.
+```
+
+##### Send Message to an Events Channel
+Run `kubetools pubsub send event <ChannelName> <YourMessage>` or `kubetools p s e <ChannelName> <YourMessage>` for sending <YourMessage> to Events channel <ChannelName>
+
+##### Send Message to an Events Store Channel
+Run `kubetools pubsub send events_store <ChannelName> <YourMessage>` or `kubetools p s es <ChannelName> <YourMessage>` for sending <YourMessage> to Events Store channel <ChannelName>
+
+
+### PubSub Receive
+Run `kubetools pubsub receive` or `kubetools p r` for for receiving real-time and persistent events.
+
+```
+Usage:
+  kubetools pubsub receive [command]
+
+Aliases:
+  receive, rec, r
+
+Available Commands:
+  events       subscribe to receive real-time events from a channel
+  events_store subscribe to receive persistent events from channel
 
 Flags:
-  -h, --help                   help for send
-  -t, --sendTransport string   set transport type, grpc or rest (default "grpc")
+  -h, --help   help for receive
 
-Use "kubetools send [command] --help" for more information about a command.
+Global Flags:
+  -t, --pubsubTransport string   set transport type, grpc or rest (default "grpc")
 
+Use "kubetools pubsub receive [command] --help" for more information about a command.
 ```
 
-#### Send Message to an Events Channel
-Run `kubetools send event <ChannelName> <YourMessage>` or `kubetools s e <ChannelName> <YourMessage>` for sending <YourMessage> to Events channel <ChannelName>
+##### Receive PubSub Events From Channel
+Run `Kubetools pubsub receive event <ChannelName>` or `Kubetools p r e <ChannelName>` for receiving messages in Events channel <ChannelName>.
+
+##### Receive PubSub Events Store From Channel
+Run `Kubetools pubsub receive events_store <ChannelName>` or `Kubetools p r es <ChannelName>` for receiving messages in Events Store channel <ChannelName>.
 
-#### Send Message to an Events Store Channel
-Run `kubetools send events_store <ChannelName> <YourMessage>` or `kubetools s es <ChannelName> <YourMessage>` for sending <YourMessage> to Events Store channel <ChannelName>
 
-#### Send Message to a Commands Channel
-Run `kubetools send command <ChannelName> <YourMessage>` or `kubetools s c <ChannelName> <YourMessage>` for sending <YourMessage> to Commands channel <ChannelName>
+### RPC
+Run `kubetools rpc` or `kubetools r` for sending and receiving rpc calls of commands and queries.
+
+Available RPC commands:
+
+```
+Usage:
+  kubetools rpc [command]
+
+Aliases:
+  rpc, r
+
+Available Commands:
+  receive     receive commands or queries
+  send        send commands and queries
+
+Flags:
+  -h, --help                  help for rpc
+  -t, --rpcTransport string   set transport type, grpc or rest (default "grpc")
+
+Use "kubetools rpc [command] --help" for more information about a command.
+```
+
+
+### RPC Send
+Run `kubetools rpc send` or `kubetools r s` for sending command and query rpc calls.
+
+```
+Usage:
+  kubetools rpc send [command]
+
+Aliases:
+  send, s
+
+Available Commands:
+  command     send command to a channel
+  query       send query to a channel
+
+Flags:
+  -h, --help   help for send
+
+Global Flags:
+  -t, --rpcTransport string   set transport type, grpc or rest (default "grpc")
+
+Use "kubetools rpc send [command] --help" for more information about a command.
+```
+
+##### Send RPC Commands To Channel
+Run `kubetools rpc send command <ChannelName> <YourMessage>` or `kubetools r s c <ChannelName> <YourMessage>` for sending <YourMessage> to Commands channel <ChannelName>
 
 Additional configuration available:
 
 ```
 Usage:
-  kubetools send command [flags]
+  kubetools rpc send command [flags]
 
 Aliases:
   command, c
 
 Flags:
-  -h, --help             help for command
-  -o, --sendTimout int   set command timeout in MSec (default 10000)
+  -h, --help                help for command
+  -o, --rpcSendTimout int   set command timeout in msec (default 10000)
 
 Global Flags:
-  -t, --sendTransport string   set transport type, grpc or rest (default "grpc")
+  -t, --rpcTransport string   set transport type, grpc or rest (default "grpc")
 
 ```
 
-#### Send Message to a Query Channel
-Run `kubetools send query <ChannelName> <YourMessage>` or `kubetools s q <ChannelName> <YourMessage>` for sending <YourMessage> to Queries channel <ChannelName>
+##### Send RPC Query To Channel
+Run `kubetools rpc send query <ChannelName> <YourMessage>` or `kubetools r s q <ChannelName> <YourMessage>` for sending <YourMessage> to Queries channel <ChannelName>
 
 Additional configuration available:
 
 ```
 Usage:
-  kubetools send query [flags]
+  kubetools rpc send query [flags]
 
 Aliases:
   query, q
 
 Flags:
-  -h, --help             help for query
-  -o, --sendTimout int   set query timeout in MSec (default 10000)
+  -h, --help                help for query
+  -o, --rpcSendTimout int   set query timeout in msec (default 10000)
 
 Global Flags:
-  -t, --sendTransport string   set transport type, grpc or rest (default "grpc")
+  -t, --rpcTransport string   set transport type, grpc or rest (default "grpc")
 
 ```
 
-### Subscribe
-Run `kubetools send` or `kubetools s` for subscribing to any channel ,show messages received and echo messages back in Commands and Queries channels.
+
+#### RPC RECEIVE
+Run `kubetools rpc receive` or `kubetools r r` for receiving commands and queries calls.
 
 ```
 Usage:
-  kubetools subscribe [command]
+  kubetools rpc receive [command]
 
 Aliases:
-  subscribe, sub
+  receive, rec, r
 
 Available Commands:
-  command     subscribe to a command to a channel
-  event       subscribe to an events channel
-  event_store subscribe to an event_store channel
-  query       subscribe to a query channel
+  command     subscribe to receive commands from a channel
+  query       subscribe to receive queries from channel
 
 Flags:
-  -h, --help                        help for subscribe
-  -g, --subscribeGroup string       set optional group for a channel
-  -t, --subscribeTransport string   set transport type, grpc or rest (default "grpc")
+  -h, --help   help for receive
 
+Global Flags:
+  -t, --rpcTransport string   set transport type, grpc or rest (default "grpc")
+
+Use "kubetools rpc receive [command] --help" for more information about a command.
 
 ```
 
-#### Subscribe to Events Channel
-Run `Kubetools subscribe event <ChannelName>` or `Kubetools sub e <ChannelName>` for receiving messages in Events channel <ChannelName>.
+##### Receive RPC Commands From Channel
+Run `Kubetools rpc receive command <ChannelName>` or `Kubetools r r c <ChannelName>` for receiving messages in Commands channel <ChannelName> and send acknowledge back to the sender.
+
+##### Receive RPC Queries From Channel
+Run `Kubetools rpc receive query <ChannelName>` or `Kubetools r r q <ChannelName>` for receiving messages in Queries channel <ChannelName> and echo back the same message to the sender.
+
+
+### Queue
+Run `kubetools queue` or `kubetools q` for sending and receiving queue messages.
+
+Available Queue commands:
+
+```
+Usage:
+  kubetools queue [command]
+
+Aliases:
+  queue, q
+
+Available Commands:
+  ack         acl all messages in a queue
+  peak        peak messages from a queue
+  receive     receive messages from a queue
+  send        send message to a queue
 
-#### Subscribe to Events Store Channel
-Run `Kubetools subscribe event_store <ChannelName>` or `Kubetools sub es <ChannelName>` for receiving messages in Events Store channel <ChannelName>.
+Flags:
+  -h, --help                    help for queue
+  -t, --queueTransport string   set transport type, grpc or rest (default "grpc")
+
+Use "kubetools queue [command] --help" for more information about a command.
+```
+
+
+#### Send To a Queue
+Run `kubetools queue send` or `kubetools q s` for sending queue messages.
+
+```
+Usage:
+  kubetools queue send [flags]
+
+Aliases:
+  send, s
+
+Flags:
+  -h, --help                 help for send
+  -d, --sendDelay int        set queue message send delay seconds
+  -e, --sendExpiration int   set queue message expiration seconds
+
+Global Flags:
+  -t, --queueTransport string   set transport type, grpc or rest (default "grpc")
+```
 
-#### Subscribe to Commands Channel
-Run `Kubetools subscribe command <ChannelName>` or `Kubetools sub c <ChannelName>` for receiving messages in Commands channel <ChannelName> and send acknowledge back to the sender.
+#### Receive From a Queue
+Run `kubetools queue receive` or `kubetools q r` for receiving queue messages.
 
-#### Subscribe to Queries Channel
-Run `Kubetools subscribe query <ChannelName>` or `Kubetools sub q <ChannelName>` for receiving messages in Queries channel <ChannelName> and echo back the same message to the sender.
+```
+Usage:
+  kubetools queue receive [flags]
+
+Aliases:
+  receive, r
+
+Flags:
+  -h, --help                  help for receive
+  -i, --receiveMessages int   set how many messages we want to get from queue (default 1)
+  -w, --receiveWait int       set how many seconds to wait for queue messages (default 2)
+
+Global Flags:
+  -t, --queueTransport string   set transport type, grpc or rest (default "grpc")
+
+```
+
+#### Peak into a Queue
+Run `kubetools queue peak` or `kubetools q p` for peaking queue messages.
+
+```
+Usage:
+  kubetools queue peak [flags]
+
+Aliases:
+  peak, p
+
+Flags:
+  -h, --help                  help for peak
+  -i, --receiveMessages int   set how many messages we peak to get from queue (default 1)
+  -w, --receiveWait int       set how many seconds to peak for queue messages (default 2)
+
+Global Flags:
+  -t, --queueTransport string   set transport type, grpc or rest (default "grpc")
+```
+
+#### Ack All Messages in a Queue
+Run `kubetools queue ack` or `kubetools q a` for ack all queue messages.
+
+```
+Usage:
+  kubetools queue ack [flags]
+
+Aliases:
+  ack, a
+
+Flags:
+  -h, --help              help for ack
+  -w, --receiveWait int   set how many seconds wait to ack all messages in queue (default 2)
+
+Global Flags:
+  -t, --queueTransport string   set transport type, grpc or rest (default "grpc")
+```
 
 ### Health
 Run `kubetools health` or `kubetools h`

diff --git a/Taskfile.yml b/Taskfile.yml
@@ -4,7 +4,7 @@ version: '2'
 
 vars:
   BINARY_NAME: kubetools
-  VERSION: v0.2.0
+  VERSION: v1.0.0
 
 tasks:
   default:

diff --git a/bin/linux32/kubetools b/bin/linux32/kubetools
diff --git a/bin/linux64/kubetools b/bin/linux64/kubetools
diff --git a/bin/macos/kubetools b/bin/macos/kubetools
diff --git a/bin/windows/kubetools.exe b/bin/windows/kubetools.exe