status

package
v0.3.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 27, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ConfirmedMsg

type ConfirmedMsg struct {
	ID         string
	Hash       common.Hash
	Logs       []*Log
	Successful bool
}

type Log

type Log struct {
	Address common.Address `json:"address"`
	Topics  []common.Hash  `json:"topics"`
	Data    hexutil.Bytes  `json:"data"`
}

type MinedMsg

type MinedMsg struct {
	ID   string
	Hash common.Hash
}

type Producer

type Producer interface {
	Submitted(msg *SubmittedMsg)
	Mined(msg *MinedMsg)
	Confirmed(msg *ConfirmedMsg)
}

func NewKafka

func NewKafka(ctx context.Context, topic string, client sarama.Client, logger *zerolog.Logger) (Producer, error)

type SubmittedMsg

type SubmittedMsg struct {
	ID   string      `json:"id"`
	Hash common.Hash `json:"hash"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL