Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddClientSub_Image_Safe ¶
func RunClientSub ¶
func RunClientSub(clientSubject string)
func RunClientSub_IDL ¶
func RunClientSub_IDL(hostId string)
Types ¶
type JobService ¶
func (*JobService) SetJobDeactiveStatus ¶
func (this *JobService) SetJobDeactiveStatus() models.Result
type NatsPubService ¶
func (*NatsPubService) PublishData ¶
func (this *NatsPubService) PublishData(data []byte) error
func (*NatsPubService) RuleDefinePub ¶
func (this *NatsPubService) RuleDefinePub()
func (*NatsPubService) SendToManyHost ¶
func (this *NatsPubService) SendToManyHost() []string
type NatsSubService ¶
type NatsSubService struct { Message []byte Conn stan.Conn ClientSubject string DelTask *models.Task }
func (*NatsSubService) DeleteTask ¶
func (this *NatsSubService) DeleteTask() error
func (*NatsSubService) ReceiveData ¶
func (this *NatsSubService) ReceiveData(result models.NatsData)
func (*NatsSubService) Save ¶
func (this *NatsSubService) Save() error
Click to show internal directories.
Click to hide internal directories.