mirror of
https://github.com/ultravioletrs/cocos.git
synced 2026-06-23 04:10:25 +00:00
NOISSUE - Rename error to warning (#249)
* rename error to warning Signed-off-by: WashingtonKK <washingtonkigan@gmail.com> * update logging package Signed-off-by: WashingtonKK <washingtonkigan@gmail.com> --------- Signed-off-by: WashingtonKK <washingtonkigan@gmail.com>
This commit is contained in:
committed by
GitHub
parent
a7caa59137
commit
df923f9b1f
@@ -17,9 +17,9 @@ var (
|
||||
)
|
||||
|
||||
const (
|
||||
bufSize = 1024
|
||||
algorithmRun = "AlgorithmRun"
|
||||
errorStatus = "Error"
|
||||
bufSize = 1024
|
||||
algorithmRun = "AlgorithmRun"
|
||||
warningStatus = "Warning"
|
||||
)
|
||||
|
||||
type Stdout struct {
|
||||
@@ -70,7 +70,7 @@ func (s *Stderr) Write(p []byte) (n int, err error) {
|
||||
s.Logger.Error(string(buf[:n]))
|
||||
}
|
||||
|
||||
if err := s.EventSvc.SendEvent(algorithmRun, errorStatus, json.RawMessage{}); err != nil {
|
||||
if err := s.EventSvc.SendEvent(algorithmRun, warningStatus, json.RawMessage{}); err != nil {
|
||||
return len(p), err
|
||||
}
|
||||
|
||||
|
||||
@@ -73,7 +73,7 @@ func TestStderrWrite(t *testing.T) {
|
||||
for _, tt := range tests {
|
||||
t.Run(tt.name, func(t *testing.T) {
|
||||
mockEventService := mocks.NewService(t)
|
||||
mockEventService.On("SendEvent", "AlgorithmRun", manager.Error.String(), mock.Anything).Return(nil)
|
||||
mockEventService.On("SendEvent", "AlgorithmRun", manager.Warning.String(), mock.Anything).Return(nil)
|
||||
|
||||
stderr := &Stderr{Logger: mglog.NewMock(), EventSvc: mockEventService}
|
||||
n, err := stderr.Write([]byte(tt.input))
|
||||
|
||||
+1
-1
@@ -33,7 +33,7 @@ const (
|
||||
Ready
|
||||
Completed
|
||||
Terminated
|
||||
Error
|
||||
Warning
|
||||
)
|
||||
|
||||
type event uint8
|
||||
|
||||
@@ -13,12 +13,12 @@ func _() {
|
||||
_ = x[Ready-2]
|
||||
_ = x[Completed-3]
|
||||
_ = x[Terminated-4]
|
||||
_ = x[Error-5]
|
||||
_ = x[Warning-5]
|
||||
}
|
||||
|
||||
const _Status_name = "IdleStateInProgressReadyCompletedTerminatedError"
|
||||
const _Status_name = "IdleStateInProgressReadyCompletedTerminatedWarning"
|
||||
|
||||
var _Status_index = [...]uint8{0, 9, 19, 24, 33, 43, 48}
|
||||
var _Status_index = [...]uint8{0, 9, 19, 24, 33, 43, 50}
|
||||
|
||||
func (i Status) String() string {
|
||||
if i >= Status(len(_Status_index)-1) {
|
||||
|
||||
@@ -121,7 +121,7 @@ func (s *Stderr) Write(p []byte) (n int, err error) {
|
||||
EventType: manager.VmRunning.String(),
|
||||
Timestamp: timestamppb.Now(),
|
||||
Originator: "manager",
|
||||
Status: manager.Error.String(),
|
||||
Status: manager.Warning.String(),
|
||||
},
|
||||
},
|
||||
}
|
||||
|
||||
@@ -122,7 +122,7 @@ func TestStderrWrite(t *testing.T) {
|
||||
assert.NotNil(t, agentEvent)
|
||||
assert.Equal(t, "test-computation", agentEvent.ComputationId)
|
||||
assert.Equal(t, manager.VmRunning.String(), agentEvent.EventType)
|
||||
assert.Equal(t, manager.Error.String(), agentEvent.Status)
|
||||
assert.Equal(t, manager.Warning.String(), agentEvent.Status)
|
||||
assert.NotNil(t, agentEvent.Timestamp)
|
||||
}
|
||||
case <-time.After(time.Second):
|
||||
|
||||
@@ -17,6 +17,6 @@ type ManagerStatus uint8
|
||||
const (
|
||||
Starting ManagerStatus = iota
|
||||
Stopped
|
||||
Error
|
||||
Warning
|
||||
Disconnected
|
||||
)
|
||||
|
||||
@@ -10,13 +10,13 @@ func _() {
|
||||
var x [1]struct{}
|
||||
_ = x[Starting-0]
|
||||
_ = x[Stopped-1]
|
||||
_ = x[Error-2]
|
||||
_ = x[Warning-2]
|
||||
_ = x[Disconnected-3]
|
||||
}
|
||||
|
||||
const _ManagerStatus_name = "StartingStoppedErrorDisconnected"
|
||||
const _ManagerStatus_name = "StartingStoppedWarningDisconnected"
|
||||
|
||||
var _ManagerStatus_index = [...]uint8{0, 8, 15, 20, 32}
|
||||
var _ManagerStatus_index = [...]uint8{0, 8, 15, 22, 34}
|
||||
|
||||
func (i ManagerStatus) String() string {
|
||||
if i >= ManagerStatus(len(_ManagerStatus_index)-1) {
|
||||
|
||||
Reference in New Issue
Block a user