handler

package

v0.1.1 Latest Latest Go to latest Published: Jul 10, 2021 License: Apache-2.0 Imports: 17 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/persistenceOne/persistenceBridge

Links

Open Source Insights

Documentation ¶

Index ¶

func ConvertKafkaMsgsToEthMsg(kafkaMsgs []sarama.ConsumerMessage) ([]ethereum.EthTxMsg, error)
func ConvertKafkaMsgsToSDKMsg(kafkaMsgs []sarama.ConsumerMessage, protoCodec *codec.ProtoCodec) ([]sdk.Msg, error)
func SendBatchToEth(kafkaMsgs []sarama.ConsumerMessage, handler MsgHandler) error
func SendBatchToTendermint(kafkaMsgs []sarama.ConsumerMessage, handler MsgHandler) error
type MsgHandler

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func ConvertKafkaMsgsToEthMsg ¶

func ConvertKafkaMsgsToEthMsg(kafkaMsgs []sarama.ConsumerMessage) ([]ethereum.EthTxMsg, error)

func ConvertKafkaMsgsToSDKMsg ¶

func ConvertKafkaMsgsToSDKMsg(kafkaMsgs []sarama.ConsumerMessage, protoCodec *codec.ProtoCodec) ([]sdk.Msg, error)

func SendBatchToEth ¶

func SendBatchToEth(kafkaMsgs []sarama.ConsumerMessage, handler MsgHandler) error

SendBatchToEth : Handling of msgSend

func SendBatchToTendermint ¶

func SendBatchToTendermint(kafkaMsgs []sarama.ConsumerMessage, handler MsgHandler) error

SendBatchToTendermint :

Types ¶

type MsgHandler ¶

type MsgHandler struct {
	PstakeConfig configuration.Config
	ProtoCodec   *codec.ProtoCodec
	Chain        *relayer.Chain
	EthClient    *ethclient.Client
	Count        int
}

func (MsgHandler) Cleanup ¶

func (m MsgHandler) Cleanup(_ sarama.ConsumerGroupSession) error

func (MsgHandler) ConsumeClaim ¶

func (m MsgHandler) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

func (MsgHandler) HandleEthUnbond ¶

func (m MsgHandler) HandleEthUnbond(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

func (MsgHandler) HandleMsgDelegate ¶

func (m MsgHandler) HandleMsgDelegate(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

func (MsgHandler) HandleMsgSend ¶

func (m MsgHandler) HandleMsgSend(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

func (MsgHandler) HandleMsgUnbond ¶

func (m MsgHandler) HandleMsgUnbond(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

func (MsgHandler) HandleToEth ¶ added in v0.1.1

func (m MsgHandler) HandleToEth(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

func (MsgHandler) HandleToTendermint ¶ added in v0.1.1

func (m MsgHandler) HandleToTendermint(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

func (MsgHandler) Setup ¶

func (m MsgHandler) Setup(_ sarama.ConsumerGroupSession) error

Source Files ¶

View all Source files

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