queuing

func InitializeKafka ¶

func InitializeKafka(nodeList []string, context client.Context)

func NewKafkaMsgFromRest ¶

func NewKafkaMsgFromRest(msg sdk.Msg, ticketID TicketID, baseRequest rest.BaseReq, context client.Context) kafkaMsg

NewKafkaMsgFromRest : makes a msg to send to kafka queue

func NewKafkaState ¶

func NewKafkaState(nodeList []string) *kafkaState

NewKafkaState : returns a kafka state

func RegisterRoutes ¶

func RegisterRoutes(context client.Context, router *mux.Router)

func SendToKafka ¶

func SendToKafka(kafkaMsg kafkaMsg, legacyAmino *codec.LegacyAmino) []byte

SendToKafka : handles sending message to kafka