Method WriteStdLog

pkg/controller/rtctrl/logstore.go:219–256

(from int, buf []byte, eof bool)

}

func (s *kunLogStatStore) WriteStdLog(from int, buf []byte, eof bool) (int, error) {
	if s.flags.Has(flagClosed) {
		return 0, errReceiverClosed
	}

	if eof {
		if from == StdoutLog {
			s.outLogDone()
		} else if from == StderrLog {
			s.errLogDone()
		}
	}
	if len(buf) == 0 {
		return 0, nil
	}

	s.appendLogbuf(buf, false)
	logfile := s.logfile
	if logfile == nil {
		return len(buf), nil
	}
	l := &userlog.UserLog{
		Created:        time.Now(),
		RequestID:      s.requestID,
		TriggerType:    s.triggerType,
		RuntimeID:      s.runtimeID,
		Source:         logSource[from],
		UserID:         s.userID,
		FuncName:       s.funcName,
		FunctionBrn:    s.funcBrn,
		Version:        s.funcVersion,
		InvocationTime: -1,
		MemoryUsage:    -1,
		ResponseStatus: -1,
		Mode:           "",
	}
	return logfile.Write(l, buf)
}

func (s *kunLogStatStore) WriteFunctionLog(log string) error {
	if s.flags.Has(flagClosed) {