mapping_voucher

Documentation

Index

• type Signal
• type Worker
  • func NewWorker(nc nats.JetStreamContext, topic string, userVoucherRepo biz.UserVoucherRepo, ...) *Worker
  • func (w *Worker) Run()

Types

type Signal

type Signal struct {
	SignalId     int     `json:"signal_id"`
	Indicator    string  `json:"indicator"`
	Source       string  `json:"source"`
	SignalStatus string  `json:"signal_status"`
	IsUpdate     bool    `json:"is_update"`
	Symbol       string  `json:"symbol"`
	TimeFrame    string  `json:"time_frame"`
	Signal       string  `json:"signal"`
	CloseTime    int64   `json:"close_time"`
	ClosePrice   float32 `json:"close_price"`
	Type         string  `json:"type"` // close / realtime
	SourceDown   string  `json:"source_down"`
	IsTest       bool    `json:"isTest"`
}

type Worker

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

func NewWorker

func NewWorker(nc nats.JetStreamContext, topic string, userVoucherRepo biz.UserVoucherRepo, campaignRepo biz.CampaignRepo, voucherCampaignRepo biz.VoucherCampaignRepo) *Worker

func (*Worker) Run

func (w *Worker) Run()