queuing

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

Variables

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

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

SendToKafka : handles sending message to kafka

Types

type TicketID

type TicketID string

TicketID : is a type that implements string