kafkian

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)

Variables

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