status

package

v0.4.8 Latest Latest Go to latest Published: Feb 7, 2025 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

This section is empty.

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

type FailedMsg struct {
	ID   string
	Data []byte
}

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

type MinedMsg struct {
	ID   string
	Hash common.Hash
}

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

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

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