utils

package

v0.5.3 Latest Latest Go to latest Published: Dec 17, 2021 License: Apache-2.0 Imports: 11 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 ¶

Constants
Variables
func AddResponseToDB(ticket Ticket, response []byte, kafkaDB *dbm.GoLevelDB, cdc *codec.LegacyAmino)
func GetResponseFromDB(ticket Ticket, kafkaDB *dbm.GoLevelDB, cdc *codec.LegacyAmino) []byte
func KafkaAdmin(kafkaPorts []string, config *sarama.Config) sarama.ClusterAdmin
func NewConsumerGroup(kafkaPorts []string, groupID string, config *sarama.Config) sarama.ConsumerGroup
func NewProducer(kafkaPorts []string, config *sarama.Config) sarama.SyncProducer
func ProducerDeliverMessage(msgBytes []byte, topic string, producer sarama.SyncProducer) error
func ProducerDeliverMessages(msgBytes [][]byte, topic string, producer sarama.SyncProducer) error
func QueryDB(cdc *codec.LegacyAmino, kafkaDB *dbm.GoLevelDB) http.HandlerFunc
func SaramaConfig() *sarama.Config
func SetTicketIDtoDB(ticket Ticket, kafkaDB *dbm.GoLevelDB, cdc *codec.LegacyAmino, msg []byte)
func TopicsInit(admin sarama.ClusterAdmin, topic string, topicDetail sarama.TopicDetail)
type KafkaState
- func NewKafkaState(kafkaPorts []string, homeDir string, topicDetail sarama.TopicDetail) KafkaState
type Ticket
- func TicketIDGenerator(prefix string) Ticket
type TicketIDResponse

Constants ¶

View Source

const EthUnbond = "ethereum-unbond" //flushes every 3 days

View Source

const GroupEthUnbond = "group-ethereum-unbond"

View Source

const GroupMsgDelegate = "group-msg-delegate"

View Source

const GroupMsgSend = "group-msg-send"

View Source

const GroupMsgUnbond = "group-msg-unbond"

View Source

const GroupRedelegate = "group-redelegate"

View Source

const GroupRetryTendermint = "group-retry-tendermint"

View Source

const GroupToEth = "group-to-ethereum"

View Source

const GroupToTendermint = "group-to-tendermint"

View Source

const MsgDelegate = "msg-delegate" //priority2

View Source

const MsgSend = "msg-send" //priority3

View Source

const MsgUnbond = "msg-unbond" //priority1

View Source

const Redelegate = "redelegate"

View Source

const RetryTendermint = "retry-tendermint"

View Source

const ToEth = "to-ethereum"

View Source

const ToTendermint = "to-tendermint"

Variables ¶

View Source

var Groups = []string{GroupEthUnbond,
	GroupMsgSend, GroupMsgDelegate, GroupRedelegate, GroupMsgUnbond,
	GroupToEth, GroupRetryTendermint, GroupToTendermint,
}

View Source

var TicketIDAtomicCounter int64

TicketIDAtomicCounter is a counter that adds when each time a function is called

View Source

var Topics = []string{
	EthUnbond, MsgSend, MsgDelegate, Redelegate, MsgUnbond,
	ToEth, RetryTendermint, ToTendermint,
}

Topics : is list of topics

Functions ¶

func AddResponseToDB ¶

func AddResponseToDB(ticket Ticket, response []byte, kafkaDB *dbm.GoLevelDB, cdc *codec.LegacyAmino)

AddResponseToDB : Updates response to DB

func GetResponseFromDB ¶

func GetResponseFromDB(ticket Ticket, kafkaDB *dbm.GoLevelDB, cdc *codec.LegacyAmino) []byte

GetResponseFromDB : gives the response from DB

func KafkaAdmin ¶

func KafkaAdmin(kafkaPorts []string, config *sarama.Config) sarama.ClusterAdmin

KafkaAdmin : is admin to create topics

func NewConsumerGroup ¶

func NewConsumerGroup(kafkaPorts []string, groupID string, config *sarama.Config) sarama.ConsumerGroup

func NewProducer ¶

func NewProducer(kafkaPorts []string, config *sarama.Config) sarama.SyncProducer

NewProducer is a producer to send messages to kafka

func ProducerDeliverMessage ¶

func ProducerDeliverMessage(msgBytes []byte, topic string, producer sarama.SyncProducer) error

ProducerDeliverMessage : delivers messages to kafka

func ProducerDeliverMessages ¶

func ProducerDeliverMessages(msgBytes [][]byte, topic string, producer sarama.SyncProducer) error

func QueryDB ¶

func QueryDB(cdc *codec.LegacyAmino, kafkaDB *dbm.GoLevelDB) http.HandlerFunc

QueryDB : REST outputs info from DB

func SaramaConfig ¶

func SaramaConfig() *sarama.Config

func SetTicketIDtoDB ¶

func SetTicketIDtoDB(ticket Ticket, kafkaDB *dbm.GoLevelDB, cdc *codec.LegacyAmino, msg []byte)

SetTicketIDtoDB : initiates ticketID in Database

func TopicsInit ¶

func TopicsInit(admin sarama.ClusterAdmin, topic string, topicDetail sarama.TopicDetail)

TopicsInit : is needed to initialise topics

Types ¶

type KafkaState ¶

type KafkaState struct {
	HomeDir       string
	Admin         sarama.ClusterAdmin
	ConsumerGroup map[string]sarama.ConsumerGroup
	Producer      sarama.SyncProducer
	Topics        []string
}

KafkaState : is a struct showing the state of kafka

func NewKafkaState ¶

func NewKafkaState(kafkaPorts []string, homeDir string, topicDetail sarama.TopicDetail) KafkaState

NewKafkaState : returns a kafka state

type Ticket ¶

type Ticket string

Ticket : is a type that implements string

func TicketIDGenerator ¶

func TicketIDGenerator(prefix string) Ticket

TicketIDGenerator is a random unique ticket ID generator, output is a string

type TicketIDResponse ¶

type TicketIDResponse struct {
	TicketID Ticket `json:"ticketID" valid:"required~ticketID is mandatory,length(20)~ticketID length should be 20" `
}

TicketIDResponse : is a json structure to send TicketID to user

Source Files ¶

View all Source files

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