Documentation
¶
Index ¶
- Variables
- func AssignConsumer(env base.Environment, topic string) (err error)
- func GetReplayTypesList() []string
- func HandleWS(w http.ResponseWriter, r *http.Request)
- func LookupTopic(env base.Environment, topic, params string) (err error)
- func ProduceMessage(env base.Environment, msg *kafka.Message) (err error)
- func SubscribeConsumer(env base.Environment, topic string) (err error)
Constants ¶
This section is empty.
Variables ¶
View Source
var WS *websocket.Conn
WS web socket connection.
Functions ¶
func AssignConsumer ¶
func AssignConsumer(env base.Environment, topic string) (err error)
AssignConsumer creates a consumer for the given environment topic.
func GetReplayTypesList ¶
func GetReplayTypesList() []string
GetReplayTypesList returns the supported replay types.
func HandleWS ¶
func HandleWS(w http.ResponseWriter, r *http.Request)
HandleWS handles web socket messages.
func LookupTopic ¶
func LookupTopic(env base.Environment, topic, params string) (err error)
LookupTopic searchs in topic messages, according to the given replay params.
func ProduceMessage ¶
func ProduceMessage(env base.Environment, msg *kafka.Message) (err error)
ProduceMessage produces the given message, using the given environment configuration.
func SubscribeConsumer ¶
func SubscribeConsumer(env base.Environment, topic string) (err error)
SubscribeConsumer creates a consumer for the given environment topics.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.