Function FollowLog

host/log_windows.go:93–133

(name string)

}

func FollowLog(name string) error {
	lastID := uint64(0)
	events, err := queryWindowsEvents(name, 1)
	if err != nil {
		return err
	}
	if len(events) > 0 {
		lastID = events[0].RecordID
	}

	ticker := time.NewTicker(2 * time.Second)
	defer ticker.Stop()
	for range ticker.C {
		events, err := queryWindowsEvents(name, 50)
		if err != nil {
			return err
		}
		var newEvents []windowsEvent
		for _, e := range events {
			if e.RecordID > lastID {
				newEvents = append(newEvents, e)
			}
		}
		if len(newEvents) == 0 {
			continue
		}
		sort.Slice(newEvents, func(i, j int) bool {
			return newEvents[i].RecordID < newEvents[j].RecordID
		})
		for _, e := range newEvents {
			if _, err := fmt.Fprintln(os.Stdout, e.Text); err != nil {
				return err
			}
			if _, err := fmt.Fprintln(os.Stdout); err != nil {
				return err
			}
			lastID = e.RecordID
		}
	}
	return nil
}

type windowsEvent struct {
	RecordID uint64