handler

package

v0.1.0 Latest Latest Go to latest Published: Jun 2, 2021 License: Apache-2.0 Imports: 16 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 BatchAndHandle(kafkaMsgs *[]sarama.ConsumerMessage, kafkaMsg sarama.ConsumerMessage, ...) (bool, error)
func ConvertKafkaMsgsToEthMsg(kafkaMsgs []sarama.ConsumerMessage) ([]ethereum2.EthTxMsg, error)
func ConvertKafkaMsgsToSDKMsg(kafkaMsgs []sarama.ConsumerMessage, protoCodec *codec.ProtoCodec) ([]sdk.Msg, error)
func SendBatchToEth(kafkaMsgs []sarama.ConsumerMessage, _ *codec.ProtoCodec, _ *relayer.Chain, ...) error
func SendBatchToTendermint(kafkaMsgs []sarama.ConsumerMessage, protoCodec *codec.ProtoCodec, ...) error
type MsgHandler

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func BatchAndHandle ¶

func BatchAndHandle(kafkaMsgs *[]sarama.ConsumerMessage, kafkaMsg sarama.ConsumerMessage,
	protoCodec *codec.ProtoCodec, chain *relayer.Chain, ethClient *ethclient.Client,
	handle func([]sarama.ConsumerMessage, *codec.ProtoCodec, *relayer.Chain, *ethclient.Client) error) (bool, error)

BatchAndHandle :

func ConvertKafkaMsgsToEthMsg ¶

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

func ConvertKafkaMsgsToSDKMsg ¶

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

func SendBatchToEth ¶

func SendBatchToEth(kafkaMsgs []sarama.ConsumerMessage, _ *codec.ProtoCodec, _ *relayer.Chain, ethClient *ethclient.Client) error

SendBatchToEth : Handling of msgSend

func SendBatchToTendermint ¶

func SendBatchToTendermint(kafkaMsgs []sarama.ConsumerMessage, protoCodec *codec.ProtoCodec, chain *relayer.Chain, _ *ethclient.Client) 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) HandleTopicMsgs ¶

func (m MsgHandler) HandleTopicMsgs(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim, batchSize int,
	handle func([]sarama.ConsumerMessage, *codec.ProtoCodec, *relayer.Chain, *ethclient.Client) error) error

HandleTopicMsgs Handlers of message types

func (MsgHandler) Setup ¶

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

Source Files ¶

View all Source files

type.go

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