...
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18 package chaosdaemon
19
20 import (
21 "context"
22
23 "github.com/go-logr/logr"
24 "github.com/golang/protobuf/ptypes/empty"
25
26 pb "github.com/chaos-mesh/chaos-mesh/pkg/chaosdaemon/pb"
27 "github.com/chaos-mesh/chaos-mesh/pkg/chaosdaemon/tasks"
28 )
29
30 type TimeChaosServer struct {
31 podContainerNameProcessMap tasks.PodContainerNameProcessMap
32 manager tasks.TaskManager
33
34 nameLocker tasks.LockMap[tasks.PodContainerName]
35 logger logr.Logger
36 }
37
38 func (s *TimeChaosServer) SetPodContainerNameProcess(idName tasks.PodContainerName, sysID tasks.SysPID) {
39 }
40
41 func (s *TimeChaosServer) DelPodContainerNameProcess(idName tasks.PodContainerName) {
42 }
43
44 func (s *TimeChaosServer) SetTimeOffset(uid tasks.TaskID, id tasks.PodContainerName, config interface{}) error {
45 return nil
46 }
47
48 func (s *DaemonServer) SetTimeOffset(ctx context.Context, req *pb.TimeRequest) (*empty.Empty, error) {
49 return &empty.Empty{}, nil
50 }
51
52 func (s *DaemonServer) RecoverTimeOffset(ctx context.Context, req *pb.TimeRequest) (*empty.Empty, error) {
53 return &empty.Empty{}, nil
54 }
55