status

Documentation

Index

• type ConfirmedMsg
• type FailedMsg
• type Log
• type MinedMsg
• type Producer
  • func NewKafka(ctx context.Context, topic string, client sarama.Client, ...) (Producer, error)
• type SubmittedMsg

Types

type ConfirmedMsg

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

type FailedMsg

type FailedMsg struct {
	ID   string
	Data []byte
}

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)
	Failed(msg *FailedMsg)
}

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"`
}