notifiers

package
v0.7.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 9, 2023 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ExchangeDailyJobResult

type ExchangeDailyJobResult struct {
	Exchange string `json:"exchange"`
	Date     int64  `json:"date"`
	Success  bool   `json:"success"`
}

ExchangeDailyJobResult daily result

type Notifier

type Notifier interface {
	Notify(*ExchangeDailyJobResult)
	Close()
}

Notifier notify exchange daily job result

func NewNsq

func NewNsq(broker, tlsCert, tlsKey, topic string) Notifier

NewNsq create new nsq notifier

type Nsq

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

Nsq notify by nsq

func (Nsq) Close

func (s Nsq) Close()

Close close producer

func (Nsq) Notify

func (s Nsq) Notify(result *ExchangeDailyJobResult)

Notify notify exchange daily job result

Jump to

Keyboard shortcuts

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