Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
Click to show internal directories.
Click to hide internal directories.