Documentation ¶
Index ¶
- Variables
- func InitializeKafka(nodeList []string, context client.Context)
- func NewKafkaMsgFromRest(msg sdk.Msg, ticketID TicketID, baseRequest rest.BaseReq, ...) kafkaMsg
- func NewKafkaState(nodeList []string) *kafkaState
- func RegisterRoutes(context client.Context, router *mux.Router)
- func SendToKafka(kafkaMsg kafkaMsg, legacyAmino *codec.LegacyAmino) []byte
- type TicketID
Constants ¶
This section is empty.
Variables ¶
View Source
var KafkaState kafkaState
Functions ¶
func InitializeKafka ¶
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 SendToKafka ¶
func SendToKafka(kafkaMsg kafkaMsg, legacyAmino *codec.LegacyAmino) []byte
SendToKafka : handles sending message to kafka
Types ¶
Click to show internal directories.
Click to hide internal directories.