pendingtx

package

v1.0.0 Latest Latest Go to latest Published: Jan 6, 2023 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/evoblockchain/evochain

Links

Open Source Insights

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()

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

type KafkaMsg ¶

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

func (*KafkaMsg) MarshalJSON ¶

func (j *KafkaMsg) MarshalJSON() ([]byte, error)

MarshalJSON marshal bytes to json - template

func (*KafkaMsg) MarshalJSONBuf ¶

func (j *KafkaMsg) MarshalJSONBuf(buf fflib.EncodingBuffer) error

MarshalJSONBuf marshal buff to json - template

func (*KafkaMsg) UnmarshalJSON ¶

func (j *KafkaMsg) UnmarshalJSON(input []byte) error

UnmarshalJSON umarshall json - template of ffjson

func (*KafkaMsg) UnmarshalJSONFFLexer ¶

func (j *KafkaMsg) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

UnmarshalJSONFFLexer fast json unmarshall - template ffjson

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()

Source Files ¶

View all Source files

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