dbmonitor

Documentation

Index

• Variables
• func GetAssociatedUsersForFinishedCrawls(cntr controller.CntrInterface, allCrawls []common.CrawlingStatus) ([]datastructures.FinishedCrawlWithItsUser, error)
• func GetRecentFinishedCrawlsAfterTimestamp(timestamp int64) []datastructures.FinishedCrawlWithItsUser
• func GetRecentFinishedShortestDistanceCrawlsAfterTimestamp(timestamp int64) []datastructures.ShortestDistanceInfo
• func GetTotalCrawlsCompleted() int64
• func GetTotalUsersInDB() int64
• func Monitor(cntr controller.CntrInterface)
• func SetCrawlingStatsStreamWebsocketConnections(connections []WebsocketConn)
• func SetNewUserStreamWebsocketConnections(connections []WebsocketConn)
• type WebsocketConn
  • func AddNewStreamWebsocketConnection(conn WebsocketConn, connections []WebsocketConn, lock *sync.Mutex) []WebsocketConn
  • func GetCrawlingStatsStreamWebsocketConnections() []WebsocketConn
  • func GetNewUserStreamWebsocketConnections() []WebsocketConn
  • func RemoveAWebsocketConnection(websocketID string, connections []WebsocketConn, lock *sync.Mutex) ([]WebsocketConn, error)

Variables

var (
	NewUserStreamWebsockets []WebsocketConn
	NewUserStreamLock       sync.Mutex
	LastEightUserEvents     []datastructures.AddUserEvent

	CrawlingStatsStreamWebsockets []WebsocketConn
	CrawlingStatsStreamLock       sync.Mutex

	LastTwelveFinishedCrawls []datastructures.FinishedCrawlWithItsUser

	LastTwelveFinishedShortestDistanceCrawls []datastructures.ShortestDistanceInfo

	TotalUsersInDB int64

	TotalCrawlsCompleted int64
)

Functions

func GetAssociatedUsersForFinishedCrawls

func GetAssociatedUsersForFinishedCrawls(cntr controller.CntrInterface, allCrawls []common.CrawlingStatus) ([]datastructures.FinishedCrawlWithItsUser, error)

func GetRecentFinishedCrawlsAfterTimestamp

func GetRecentFinishedCrawlsAfterTimestamp(timestamp int64) []datastructures.FinishedCrawlWithItsUser

func GetRecentFinishedShortestDistanceCrawlsAfterTimestamp

func GetRecentFinishedShortestDistanceCrawlsAfterTimestamp(timestamp int64) []datastructures.ShortestDistanceInfo

func GetTotalCrawlsCompleted

func GetTotalCrawlsCompleted() int64

func GetTotalUsersInDB

func GetTotalUsersInDB() int64

func Monitor

func Monitor(cntr controller.CntrInterface)

func SetCrawlingStatsStreamWebsocketConnections

func SetCrawlingStatsStreamWebsocketConnections(connections []WebsocketConn)

func SetNewUserStreamWebsocketConnections

func SetNewUserStreamWebsocketConnections(connections []WebsocketConn)

Types

type WebsocketConn

type WebsocketConn struct {
	Ws      *websocket.Conn
	ID      string
	MatchOn string
}

func AddNewStreamWebsocketConnection

func AddNewStreamWebsocketConnection(conn WebsocketConn, connections []WebsocketConn, lock *sync.Mutex) []WebsocketConn

func GetCrawlingStatsStreamWebsocketConnections

func GetCrawlingStatsStreamWebsocketConnections() []WebsocketConn

func GetNewUserStreamWebsocketConnections

func GetNewUserStreamWebsocketConnections() []WebsocketConn

func RemoveAWebsocketConnection

func RemoveAWebsocketConnection(websocketID string, connections []WebsocketConn, lock *sync.Mutex) ([]WebsocketConn, error)