...
1 package resolver
2
3
4
5
6
7 import (
8 "context"
9
10 "edge-infra.dev/pkg/edge/api/graph/model"
11 )
12
13
14 func (r *mutationResolver) CreateLogReplay(ctx context.Context, clusterEdgeID string, replayPayload model.CreateLogReplayPayload) (bool, error) {
15 created, err := r.LogReplayService.CreateLogReplay(ctx, clusterEdgeID, replayPayload)
16 if err != nil {
17 return false, err
18 }
19 return created, nil
20 }
21
22
23 func (r *mutationResolver) DeleteLogReplay(ctx context.Context, logReplayID string) (bool, error) {
24 deleted, err := r.LogReplayService.DeleteLogReplay(ctx, logReplayID)
25 if err != nil {
26 return false, err
27 }
28 return deleted, nil
29 }
30
31
32 func (r *queryResolver) LogReplay(ctx context.Context, logReplayID string) (*model.LogReplay, error) {
33 logReplay, err := r.LogReplayService.GetLogReplay(ctx, logReplayID)
34 if err != nil {
35 return nil, err
36 }
37 return logReplay, nil
38 }
39
40
41 func (r *queryResolver) LogReplays(ctx context.Context, clusterEdgeID string, unexecutedLogReplays *bool) ([]*model.LogReplay, error) {
42 logReplays, err := r.LogReplayService.GetLogReplays(ctx, clusterEdgeID, unexecutedLogReplays)
43 if err != nil {
44 return nil, err
45 }
46 return logReplays, nil
47 }
48
View as plain text