pubsub

Documentation

Index

• func PublishCommand(c *cmds.Context)
• func SubscribeAllCommand(c *cmds.Context)
• func SubscribeCommand(c *cmds.Context)
• type KeyValue

Functions

func PublishCommand

func PublishCommand(c *cmds.Context)

PublishCommand - PUBLISH <stream> <version> <event-payload>

func SubscribeAllCommand

func SubscribeAllCommand(c *cmds.Context)

SubscribeAllCommand - SUBSCRIBEALL [<index>]

func SubscribeCommand

func SubscribeCommand(c *cmds.Context)

SubscribeCommand - SUBSCRIBE <stream> [<offset>]

Types

type KeyValue

type KeyValue struct {
	Key   store.Key
	Value string
}

KeyValue - key and value