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