pendingtx

Documentation

Index

• type KafkaClient
  • func NewKafkaClient(addrs []string, topic string) *KafkaClient
  • func (kc *KafkaClient) Send(hash []byte, tx *watcher.Transaction) error
• type KafkaMsg
• type Sender
• type Watcher
  • func NewWatcher(clientCtx context.CLIContext, log log.Logger, sender Sender) *Watcher
  • func (w *Watcher) Start()

Types

type KafkaClient

type KafkaClient struct {
	Topic string
	*kafka.Writer
}

func NewKafkaClient

func NewKafkaClient(addrs []string, topic string) *KafkaClient

func (*KafkaClient) Send

func (kc *KafkaClient) Send(hash []byte, tx *watcher.Transaction) error

type KafkaMsg

type KafkaMsg struct {
	Topic  string               `json:"topic"`
	Source interface{}          `json:"source"`
	Data   *watcher.Transaction `json:"data"`
}

type Sender

type Sender interface {
	Send(hash []byte, tx *watcher.Transaction) error
}

type Watcher

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

func NewWatcher

func NewWatcher(clientCtx context.CLIContext, log log.Logger, sender Sender) *Watcher

func (*Watcher) Start

func (w *Watcher) Start()