rocky

Documentation

Index

• type RockyIngester
  • func NewRockyIngester(filePath string, sshdProcessor sshd.SshdProcessor, ...) RockyIngester
  • func (r *RockyIngester) Ingest(ctx context.Context) error
  • func (r *RockyIngester) ParseRockySecureMessage(line string) sshd.SshdLogEntry
  • func (r *RockyIngester) Process(ctx context.Context, line string) error

Types

type RockyIngester

type RockyIngester struct {
	FilePath      string
	SshdProcessor sshd.SshdProcessor
	// contains filtered or unexported fields
}

func NewRockyIngester

func NewRockyIngester(
	filePath string,
	sshdProcessor sshd.SshdProcessor,
	namedPipeIngester namedpipe.NamedPipeIngester,
) RockyIngester

func (*RockyIngester) Ingest

func (r *RockyIngester) Ingest(ctx context.Context) error

func (*RockyIngester) ParseRockySecureMessage

func (r *RockyIngester) ParseRockySecureMessage(line string) sshd.SshdLogEntry

func (*RockyIngester) Process

func (r *RockyIngester) Process(ctx context.Context, line string) error