sentry_candidates

package
v0.0.0-...-ff78b6e Latest Latest
Warning

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

Go to latest
Published: Dec 6, 2023 License: GPL-3.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Intake

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

func NewIntake

func NewIntake(
	logPath string,
	db database.DBRetrier,
	saveQueue *utils.TaskQueue,
	chain string,
	handshakeRefreshTimeout time.Duration,
	statusLogPeriod time.Duration,
	logger log.Logger,
) *Intake

func (*Intake) Run

func (intake *Intake) Run(ctx context.Context) error

type LineReader

type LineReader interface {
	ReadLine() (*string, error)
}

type Log

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

func NewLog

func NewLog(reader LineReader) *Log

func (*Log) Read

func (log *Log) Read() (*LogEvent, error)

type LogEvent

type LogEvent struct {
	Timestamp    time.Time `json:"t"`
	Message      string    `json:"msg"`
	PeerIDHex    string    `json:"peer,omitempty"`
	NodeURL      string    `json:"nodeURL,omitempty"`
	ClientID     string    `json:"clientID,omitempty"`
	Capabilities []string  `json:"capabilities,omitempty"`
}

func (*LogEvent) EthVersion

func (event *LogEvent) EthVersion() uint

type ScannerLineReader

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

func NewScannerLineReader

func NewScannerLineReader(reader io.Reader) *ScannerLineReader

func (*ScannerLineReader) ReadLine

func (reader *ScannerLineReader) ReadLine() (*string, error)

type TailLineReader

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

func NewTailLineReader

func NewTailLineReader(ctx context.Context, tail *tail.Tail) *TailLineReader

func (*TailLineReader) ReadLine

func (reader *TailLineReader) ReadLine() (*string, error)

Jump to

Keyboard shortcuts

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