service

package

v0.0.0-...-56366a6 Latest Latest Go to latest Published: Feb 3, 2021 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/skeyic/monitoring

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
type FutuCollector
- func NewFutuCollector(fileName string) *FutuCollector
- func (c *FutuCollector) AddFilter(f FutuMsgFilter)
- func (c *FutuCollector) Analysis()
- func (c *FutuCollector) ApplyFilter(msgsToAnalysis []*FutuMsg)
- func (c *FutuCollector) AutoSave()
- func (c *FutuCollector) GetMsgs(page, pageSize int) (msgs []*FutuMsg, err error)
- func (c *FutuCollector) InitMsgNum(initMsgNum int) *FutuCollector
- func (c *FutuCollector) Load() (err error)
- func (c *FutuCollector) LoadFromFile() (err error)
- func (c *FutuCollector) LookBack(lookBack bool) *FutuCollector
- func (c *FutuCollector) MergeMsgs(sourceMsgs, newMsgs []*FutuMsg) (lastMsgs []*FutuMsg)
- func (c *FutuCollector) Process() (err error)
- func (c *FutuCollector) SaveToFile() (err error)
- func (c *FutuCollector) Start() (err error)
- func (c *FutuCollector) Validation() (result bool)
type FutuMsg
- func (s *FutuMsg) AutoMigrate()
- func (s *FutuMsg) ID() int64
type FutuMsgFilter
type FutuMsgs
- func (s FutuMsgs) Len() int
- func (s FutuMsgs) Less(i, j int) bool
- func (s FutuMsgs) Swap(i, j int)
type RateFutuMsgFilter
- func NewRateFutuMsgFilter() RateFutuMsgFilter
- func (r RateFutuMsgFilter) Alert(msg *FutuMsg) error
- func (r RateFutuMsgFilter) Match(msg *FutuMsg) bool
type SinaFinanceCollector
- func (c *SinaFinanceCollector) GetMsgs(page, pageSize int) (msgs []*SinaFinanceMsg, err error)
- func (c *SinaFinanceCollector) Load(maxLength int64) (err error)
- func (c *SinaFinanceCollector) LoadFromFile() (err error)
- func (c *SinaFinanceCollector) MergeMsgs(sourceMsgs, newMsgs []*SinaFinanceMsg) (lastMsgs []*SinaFinanceMsg)
- func (c *SinaFinanceCollector) SaveToFile() (err error)
type SinaFinanceMsg
type SinaFinanceMsgs
- func (s SinaFinanceMsgs) Len() int
- func (s SinaFinanceMsgs) Less(i, j int) bool
- func (s SinaFinanceMsgs) Swap(i, j int)
type TestFutuMsgFilter
- func NewTestFutuMsgFilter() TestFutuMsgFilter
- func (r TestFutuMsgFilter) Alert(msg *FutuMsg) error
- func (r TestFutuMsgFilter) Match(msg *FutuMsg) bool

Constants ¶

View Source

const (
	FutuBaseURL              = "https://news.futunn.com/main/live-list?page=%d&page_size=%d"
	FutuDefaultPageSize      = 50
	FutuDefaultInitMsgNum    = 10000
	FutuDefaultLoadInterval  = 1 * time.Minute
	TheFutuCollectorFileName = "TheFutuCollector.data.test"
)

View Source

const (
	SinaFinanceBaseURL              = "http://zhibo.sina.com.cn/api/zhibo/feed?page=%d&page_size=%d&zhibo_id=152"
	SinaFinanceDefaultPageSize      = 100
	TheSinaFinanceCollectorFileName = "TheSinaFinanceCollector.data"
)

Variables ¶

View Source

var (
	TheFutuCollector = NewFutuCollector(TheFutuCollectorFileName).
		InitMsgNum(FutuDefaultPageSize)
)

View Source

var (
	TheSinaFinanceCollector = &SinaFinanceCollector{
		fileName: TheSinaFinanceCollectorFileName,
	}
)

Functions ¶

This section is empty.

Types ¶

type FutuCollector ¶

type FutuCollector struct {
	Msgs FutuMsgs
	// contains filtered or unexported fields
}

func NewFutuCollector ¶

func NewFutuCollector(fileName string) *FutuCollector

func (*FutuCollector) AddFilter ¶

func (c *FutuCollector) AddFilter(f FutuMsgFilter)

func (*FutuCollector) Analysis ¶

func (c *FutuCollector) Analysis()

func (*FutuCollector) ApplyFilter ¶

func (c *FutuCollector) ApplyFilter(msgsToAnalysis []*FutuMsg)

func (*FutuCollector) AutoSave ¶

func (c *FutuCollector) AutoSave()

func (*FutuCollector) GetMsgs ¶

func (c *FutuCollector) GetMsgs(page, pageSize int) (msgs []*FutuMsg, err error)

func (*FutuCollector) InitMsgNum ¶

func (c *FutuCollector) InitMsgNum(initMsgNum int) *FutuCollector

func (*FutuCollector) Load ¶

func (c *FutuCollector) Load() (err error)

func (*FutuCollector) LoadFromFile ¶

func (c *FutuCollector) LoadFromFile() (err error)

func (*FutuCollector) LookBack ¶

func (c *FutuCollector) LookBack(lookBack bool) *FutuCollector

func (*FutuCollector) MergeMsgs ¶

func (c *FutuCollector) MergeMsgs(sourceMsgs, newMsgs []*FutuMsg) (lastMsgs []*FutuMsg)

func (*FutuCollector) Process ¶

func (c *FutuCollector) Process() (err error)

func (*FutuCollector) SaveToFile ¶

func (c *FutuCollector) SaveToFile() (err error)

func (*FutuCollector) Start ¶

func (c *FutuCollector) Start() (err error)

func (*FutuCollector) Validation ¶

func (c *FutuCollector) Validation() (result bool)

type FutuMsg ¶

type FutuMsg struct {
	CommentID  int64  `json:"idx"`
	CreateTime string `json:"create_time_str"`
	RichText   string `json:"content"`
}

func (*FutuMsg) AutoMigrate ¶

func (s *FutuMsg) AutoMigrate()

func (*FutuMsg) ID ¶

func (s *FutuMsg) ID() int64

type FutuMsgFilter ¶

type FutuMsgFilter interface {
	Match(msg *FutuMsg) bool
	Alert(msg *FutuMsg) error
}

type FutuMsgs ¶

type FutuMsgs []*FutuMsg

func (FutuMsgs) Len ¶

func (s FutuMsgs) Len() int

func (FutuMsgs) Less ¶

func (s FutuMsgs) Less(i, j int) bool

We need the reversed order

func (FutuMsgs) Swap ¶

func (s FutuMsgs) Swap(i, j int)

type RateFutuMsgFilter ¶

type RateFutuMsgFilter struct {
}

func NewRateFutuMsgFilter ¶

func NewRateFutuMsgFilter() RateFutuMsgFilter

func (RateFutuMsgFilter) Alert ¶

func (r RateFutuMsgFilter) Alert(msg *FutuMsg) error

func (RateFutuMsgFilter) Match ¶

func (r RateFutuMsgFilter) Match(msg *FutuMsg) bool

type SinaFinanceCollector ¶

type SinaFinanceCollector struct {
	Msgs []*SinaFinanceMsg
	// contains filtered or unexported fields
}

func (*SinaFinanceCollector) GetMsgs ¶

func (c *SinaFinanceCollector) GetMsgs(page, pageSize int) (msgs []*SinaFinanceMsg, err error)

func (*SinaFinanceCollector) Load ¶

func (c *SinaFinanceCollector) Load(maxLength int64) (err error)

func (*SinaFinanceCollector) LoadFromFile ¶

func (c *SinaFinanceCollector) LoadFromFile() (err error)

func (*SinaFinanceCollector) MergeMsgs ¶

func (c *SinaFinanceCollector) MergeMsgs(sourceMsgs, newMsgs []*SinaFinanceMsg) (lastMsgs []*SinaFinanceMsg)

func (*SinaFinanceCollector) SaveToFile ¶

func (c *SinaFinanceCollector) SaveToFile() (err error)

type SinaFinanceMsg ¶

type SinaFinanceMsg struct {
	CommentID  string `json:"commentid"`
	CreateTime string `json:"create_time"`
	RichText   string `json:"rich_text"`
}

type SinaFinanceMsgs ¶

type SinaFinanceMsgs []*SinaFinanceMsg

func (SinaFinanceMsgs) Len ¶

func (s SinaFinanceMsgs) Len() int

func (SinaFinanceMsgs) Less ¶

func (s SinaFinanceMsgs) Less(i, j int) bool

func (SinaFinanceMsgs) Swap ¶

func (s SinaFinanceMsgs) Swap(i, j int)

type TestFutuMsgFilter ¶

type TestFutuMsgFilter struct {
}

func NewTestFutuMsgFilter ¶

func NewTestFutuMsgFilter() TestFutuMsgFilter

func (TestFutuMsgFilter) Alert ¶

func (r TestFutuMsgFilter) Alert(msg *FutuMsg) error

func (TestFutuMsgFilter) Match ¶

func (r TestFutuMsgFilter) Match(msg *FutuMsg) bool

Source Files ¶

View all Source files

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