kafka

Documentation

Index

• Variables
• type KafkaConn
  • func NewKafkaConn() *KafkaConn
  • func (k *KafkaConn) Produce(ctx context.Context) error
• type Log

Variables

var TestLog = Log{
	Type:             "log",
	LogIndex:         275,
	TransactionHash:  "0xca814e907b31eb8619cb0fb15b9682ea89e28bfd66342a933c834d7e4f9710c2",
	TransactionIndex: 111,
	Address:          "0x551b31a8097a60d7fa4e78c4541679b79cdf8b72",
	Data:             "0x00000000000000000000000000000000000000000000000000077ca233dd9708",
	Topics: []string{
		"0xddf252ad1be2c89b69c2b068fc378daa952ba7f163c4a11628f55a4df523b3ef",
		"0x00000000000000000000000036bf7ec470420ad6bae720af98ba73a8359bbc57",
		"0x000000000000000000000000b9b404d66c206bf1a290f83d9426efc0de34b5b1",
	},
	BlockNumber:    17725560,
	BlockTimestamp: 1689749387,
	BlockHash:      "0xae29a3e338de4797150dbdfcbbe77c63cacfe9ca6ec9bbe7c5ead363b5c43507",
	ItemId:         "log_0xca814e907b31eb8619cb0fb15b9682ea89e28bfd66342a933c834d7e4f9710c2_275",
	ItemTimestamp:  time.Now(),
}

Types

type KafkaConn

type KafkaConn struct {
	// contains filtered or unexported fields
}

func NewKafkaConn

func NewKafkaConn() *KafkaConn

func (*KafkaConn) Produce

func (k *KafkaConn) Produce(ctx context.Context) error

type Log

type Log struct {
	Type             string    `json:"type"`
	LogIndex         int       `json:"log_index"`
	TransactionHash  string    `json:"transaction_hash"`
	TransactionIndex int       `json:"transaction_index"`
	Address          string    `json:"address"`
	Data             string    `json:"data"`
	Topics           []string  `json:"topics"`
	BlockNumber      int       `json:"block_number"`
	BlockTimestamp   int       `json:"block_timestamp"`
	BlockHash        string    `json:"block_hash"`
	ItemId           string    `json:"item_id"`
	ItemTimestamp    time.Time `json:"item_timestamp"`
}