pendingtx

Documentation

Index

• type KafkaClient
  • func NewKafkaClient(addrs []string, topic string) *KafkaClient
  • func (kc *KafkaClient) Send(hash []byte, tx *watcher.Transaction) error
• type KafkaMsg
  • func (j *KafkaMsg) MarshalJSON() ([]byte, error)
  • func (j *KafkaMsg) MarshalJSONBuf(buf fflib.EncodingBuffer) error
  • func (j *KafkaMsg) UnmarshalJSON(input []byte) error
  • func (j *KafkaMsg) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
• 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"`
}

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