transactions

Documentation

Index

• type Message
• type Service
  • func Init(config *config.Config, ds *datastore.KafkaDatastore, pgDs *pg.PgDatastore) (*Service, error)
  • func (s *Service) Push(txData *tx.GetTxResponse)
• type TempMessage

Types

type Message

type Message struct {
	MsgType      string `json:"type"`
	Msg          string `json:"value"`
	Events       string `json:"events"`
	ExternalInfo string `json:"external_info"`
	Log          string `json:"log"`
}

type Service

type Service struct {
	// contains filtered or unexported fields
}

func Init

func Init(config *config.Config, ds *datastore.KafkaDatastore, pgDs *pg.PgDatastore) (*Service, error)

func (*Service) Push

func (s *Service) Push(txData *tx.GetTxResponse)

type TempMessage

type TempMessage struct {
	MsgType string                 `json:"type"`
	Msg     map[string]interface{} `json:"value"`
}