workers

Documentation

Index

• Variables
• func ArchiveBotMain()
• func FetchProjects() (*model.ATTrackerProjects, error)
• func GetLogSocketNameFromLeaderboard(link string) string
• func HandleArchiveBotMessage(ctx context.Context, message []byte)
• func TrackerMain()
• type ArchiveBotJobInfo
• type ArchiveBotMessage
• type TrackerSocket
  • func (sock *TrackerSocket) Connect()
  • func (sock *TrackerSocket) OnConnect(ns *socketio.NameSpace)
  • func (sock *TrackerSocket) OnMessage(ns *socketio.NameSpace, message string)
• type TrackerWorker
  • func (worker *TrackerWorker) Init()
  • func (worker *TrackerWorker) LaunchSocket(project model.ATTrackerProject)

Variables

var (
	PushRedis  bool = util.GetBoolEnvWithDefault("PUSH_REDIS", false)
	PushInflux bool = util.GetBoolEnvWithDefault("PUSH_INFLUX", false)
)

Functions

func ArchiveBotMain

func ArchiveBotMain()

func FetchProjects

func FetchProjects() (*model.ATTrackerProjects, error)

func GetLogSocketNameFromLeaderboard

func GetLogSocketNameFromLeaderboard(link string) string

func HandleArchiveBotMessage

func HandleArchiveBotMessage(ctx context.Context, message []byte)

func TrackerMain

func TrackerMain()

Types

type ArchiveBotJobInfo

type ArchiveBotJobInfo struct {
	ItemsDownloaded string `json:"items_downloaded"`
	Concurrency     string `json:"concurrency"`
	Heartbeat       string `json:"heartbeat"`
	ItemsQueued     string `json:"items_queued"`
	NoOffsiteLinks  string `json:"no_offsite_links"`
	LastTrimmedLog  string `json:"last_trimmed_log_entry"`
	QueuedAt        string `json:"queued_at"`
	Url             string `json:"url"`
	R2xx            string `json:"r2xx"`
	R5xx            string `json:"r5xx"`
	SettingsAge     string `json:"settings_age"`
	Runk            string `json:"runk"`
	LastAnalyzedLog string `json:"last_analyzed_log_entry"`
	LastBroadcasted string `json:"last_broadcasted_log_entry"`
	UserAgent       string `json:"user_agent"`
	R1xx            string `json:"r1xx"`
	LogScore        string `json:"log_score"`
	IgnorePatterns  string `json:"ignore_patterns_set_key"`
	LogKey          string `json:"log_key"`
	PipelineId      string `json:"pipeline_id"`
	StartedIn       string `json:"started_in"`
	ErrorCount      string `json:"error_count"`
	Ts              string `json:"ts"`
	LastHeartbeat   string `json:"last_acknowledged_heartbeat"`
	StartedBy       string `json:"started_by"`
	Slug            string `json:"slug"`
	DelayMin        string `json:"delay_min"`
	BytesDownloaded string `json:"bytes_downloaded"`
	R4xx            string `json:"r4xx"`
	DeathTimer      string `json:"death_timer"`
	StartedAt       string `json:"started_at"`
	Note            string `json:"note"`
	DelayMax        string `json:"delay_max"`
	SuppressIgnores string `json:"suppress_ignore_reports"`
	R3xx            string `json:"r3xx"`
	Ident           string `json:"ident"`
}

type ArchiveBotMessage

type ArchiveBotMessage struct {
	// Timestamp is a unix timestamp in seconds
	Timestamp json.Number `json:"ts"`

	Url          string            `json:"url"`
	ResponseCode int               `json:"response_code"`
	WgetCode     string            `json:"wget_code"`
	IsError      bool              `json:"is_error"`
	IsWarning    bool              `json:"is_warning"`
	Type         string            `json:"type"`
	JobInfo      ArchiveBotJobInfo `json:"job_data"`
}

type TrackerSocket

type TrackerSocket struct {
	Worker  TrackerWorker
	Project string
}

func (*TrackerSocket) Connect

func (sock *TrackerSocket) Connect()

func (*TrackerSocket) OnConnect

func (sock *TrackerSocket) OnConnect(ns *socketio.NameSpace)

func (*TrackerSocket) OnMessage

func (sock *TrackerSocket) OnMessage(ns *socketio.NameSpace, message string)

type TrackerWorker

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

func (*TrackerWorker) Init

func (worker *TrackerWorker) Init()

func (*TrackerWorker) LaunchSocket

func (worker *TrackerWorker) LaunchSocket(project model.ATTrackerProject)