pendingtx

package
v0.19.9 Latest Latest
Warning

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

Go to latest
Published: Oct 25, 2021 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 *rpctypes.Transaction) error

type KafkaMsg

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

type Sender

type Sender interface {
	Send(hash []byte, tx *rpctypes.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()

Jump to

Keyboard shortcuts

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