category

Documentation

Index

• Constants
• type Event
  • func NewEvent(cname, absPath string, inode, size uint64, alwaysFlock bool, isFinal bool) Event
• type FinalSyncRequest
• type Listener
  • func NewListener(ctx context.Context, config *lsdProto.LsdConfigClientConfigT, name string, ...) *Listener
  • func (cl *Listener) Listen()

Constants

const AVERAGE_LINES_COUNT = 50

const BIG_FILE_SUFFIX = "_big"

const LOG_FILE_SUFFIX = ".log"

const MAX_BYTES_PER_BATCH = network.MAX_BYTES_TO_SEND / 2 // depends on how much we can to network at once

const MAX_BYTES_PER_LINE = 1 << 20 // 1mb per line

const OLD_FILE_SUFFIX = ".old"

const READ_BUFFER_SIZE = 1 << 14 // 16kb

Types

type Event

type Event struct {
	Name         string
	AbsolutePath string
	Inode        uint64
	Size         uint64
	IsExclusive  bool
	IsRotated    bool
	IsFinal      bool
}

func NewEvent

func NewEvent(cname, absPath string, inode, size uint64, alwaysFlock bool, isFinal bool) Event

type FinalSyncRequest

type FinalSyncRequest struct {
	AbsolutePath string
	Inode        uint64
	Size         uint64
}

type Listener

type Listener struct {
	InCh chan Event
	// contains filtered or unexported fields
}

func NewListener

func NewListener(ctx context.Context, config *lsdProto.LsdConfigClientConfigT, name string, odb *offsets.Db, checker *usage.Checker, inCh chan Event, outCh chan *lsdProto.RequestNewEventsEventT, finalSyncCh chan FinalSyncRequest) *Listener

func (*Listener) Listen

func (cl *Listener) Listen()