Versions in this module Expand all Collapse all v0 v0.1.1 Nov 15, 2021 v0.1.0 Oct 18, 2020 Changes in this version + var DefaultCLIHome = os.ExpandEnv("$HOME/.kafka") + var ModuleCdc *codec.Codec + var SleepRoutine = time.Duration(2500000000) + var SleepTimer = time.Duration(1000000000) + var TicketIDAtomicCounter int64 + var Topics = []string + func AddResponseToDB(TicketID Ticket, response []byte, kafkaDB *dbm.GoLevelDB, cdc *codec.Codec) + func CliCtxFromKafkaMsg(kafkaMsg KafkaMsg, cliContext context.CLIContext) context.CLIContext + func GetResponseFromDB(TicketID Ticket, kafkaDB *dbm.GoLevelDB, cdc *codec.Codec) []byte + func KafkaAdmin(kafkaPorts []string) sarama.ClusterAdmin + func KafkaProducerDeliverMessage(msg KafkaMsg, topic string, producer sarama.SyncProducer, cdc *codec.Codec) error + func NewConsumer(kafkaPorts []string) sarama.Consumer + func NewProducer(kafkaPorts []string) sarama.SyncProducer + func PartitionConsumers(consumer sarama.Consumer, topic string) sarama.PartitionConsumer + func QueryDB(cdc *codec.Codec, kafkaDB *dbm.GoLevelDB) http.HandlerFunc + func RegisterCodec(cdc *codec.Codec) + func SendToKafka(msg KafkaMsg, kafkaState KafkaState, cdc *codec.Codec) []byte + func SetTicketIDtoDB(TicketID Ticket, kafkaDB *dbm.GoLevelDB, cdc *codec.Codec, msg []byte) + func TopicsInit(admin sarama.ClusterAdmin, topic string) + type KafkaCliCtx struct + BroadcastMode string + ChainID string + From string + FromAddress sdk.AccAddress + FromName string + GenerateOnly bool + Height int64 + HomeDir string + Indent bool + NodeURI string + Offline bool + OutputFormat string + Simulate bool + SkipConfirm bool + TrustNode bool + UseLedger bool + type KafkaMsg struct + BaseRequest rest.BaseReq + KafkaCli KafkaCliCtx + Msg sdk.Msg + TicketID Ticket + func KafkaTopicConsumer(topic string, consumers map[string]sarama.PartitionConsumer, cdc *codec.Codec) KafkaMsg + func NewKafkaMsgFromRest(msg sdk.Msg, ticketID Ticket, baseRequest rest.BaseReq, ...) KafkaMsg + type KafkaState struct + Admin sarama.ClusterAdmin + Consumer sarama.Consumer + Consumers map[string]sarama.PartitionConsumer + KafkaDB *dbm.GoLevelDB + Producer sarama.SyncProducer + Topics []string + func NewKafkaState(kafkaPorts []string) KafkaState + type Ticket string + func TicketIDGenerator(prefix string) Ticket + type TicketIDResponse struct + TicketID Ticket