service

Documentation

Index

• Variables
• type AlertService
  • func NewAlertService(alert *biz.AlertUsecase) *AlertService
  • func (s *AlertService) CreateAlertRule(ctx context.Context, req *pb.CreateAlertRuleRequest) (*pb.AlertRule, error)
  • func (s *AlertService) DeleteAlertRule(ctx context.Context, req *pb.DeleteAlertRuleRequest) (*pb.DeleteAlertRuleReply, error)
  • func (s *AlertService) GetAlertRule(ctx context.Context, req *pb.GetAlertRuleRequest) (*pb.AlertRule, error)
  • func (s *AlertService) ListAlertEvents(ctx context.Context, req *pb.ListAlertEventsRequest) (*pb.ListAlertEventsReply, error)
  • func (s *AlertService) ListAlertRules(ctx context.Context, req *pb.ListAlertRulesRequest) (*pb.ListAlertRulesReply, error)
  • func (s *AlertService) UpdateAlertRule(ctx context.Context, req *pb.UpdateAlertRuleRequest) (*pb.AlertRule, error)
• type MessagingService
  • func NewMessagingService() *MessagingService
• type NodeService
  • func NewNodeService(nodes *biz.NodeUsecase) *NodeService
  • func (s *NodeService) DeleteNode(ctx context.Context, req *pb.DeleteNodeRequest) (*pb.DeleteNodeReply, error)
  • func (s *NodeService) GetNode(ctx context.Context, req *pb.GetNodeRequest) (*pb.GetNodeReply, error)
  • func (s *NodeService) GetNodeStatistics(ctx context.Context, _ *pb.GetNodeStatisticsRequest) (*pb.GetNodeStatisticsReply, error)
  • func (s *NodeService) ListNodes(ctx context.Context, req *pb.ListNodesRequest) (*pb.ListNodesReply, error)
  • func (s *NodeService) UpdateNode(ctx context.Context, req *pb.UpdateNodeRequest) (*pb.UpdateNodeReply, error)
  • func (s *NodeService) UpdateNodeLabels(ctx context.Context, req *pb.UpdateNodeLabelsRequest) (*pb.UpdateNodeReply, error)
• type RealtimeService
  • func NewRealtimeService(realtime *biz.RealtimeUsecase) *RealtimeService
  • func (s *RealtimeService) GetRealtimeOverview(ctx context.Context, req *pb.GetRealtimeOverviewRequest) (*pb.RealtimeOverview, error)
• type TaskService
  • func NewTaskService(task *biz.TaskUsecase) *TaskService
  • func (s *TaskService) CreateTask(ctx context.Context, req *pb.CreateTaskRequest) (*pb.CreateTaskReply, error)
  • func (s *TaskService) DeleteTask(ctx context.Context, req *pb.DeleteTaskRequest) (*pb.DeleteTaskReply, error)
  • func (s *TaskService) GetTask(ctx context.Context, req *pb.GetTaskRequest) (*pb.Task, error)
  • func (s *TaskService) ListTaskRunResults(ctx context.Context, req *pb.ListTaskRunResultsRequest) (*pb.ListTaskRunResultsReply, error)
  • func (s *TaskService) ListTaskRuns(ctx context.Context, req *pb.ListTaskRunsRequest) (*pb.ListTaskRunsReply, error)
  • func (s *TaskService) ListTasks(ctx context.Context, req *pb.ListTasksRequest) (*pb.ListTasksReply, error)
  • func (s *TaskService) PauseTask(ctx context.Context, req *pb.PauseTaskRequest) (*pb.PauseTaskReply, error)
  • func (s *TaskService) ResumeTask(ctx context.Context, req *pb.ResumeTaskRequest) (*pb.ResumeTaskReply, error)

Variables

var ProviderSet = wire.NewSet(
	NewMessagingService,
	NewNodeService,
	NewTaskService,
	NewRealtimeService,
	NewAlertService,
)

ProviderSet is service providers.

Types

type AlertService

type AlertService struct {
	pb.UnimplementedAlertServiceServer
	// contains filtered or unexported fields
}

func NewAlertService

func NewAlertService(alert *biz.AlertUsecase) *AlertService

func (*AlertService) CreateAlertRule

func (s *AlertService) CreateAlertRule(ctx context.Context, req *pb.CreateAlertRuleRequest) (*pb.AlertRule, error)

func (*AlertService) DeleteAlertRule

func (s *AlertService) DeleteAlertRule(ctx context.Context, req *pb.DeleteAlertRuleRequest) (*pb.DeleteAlertRuleReply, error)

func (*AlertService) GetAlertRule

func (s *AlertService) GetAlertRule(ctx context.Context, req *pb.GetAlertRuleRequest) (*pb.AlertRule, error)

func (*AlertService) ListAlertEvents

func (s *AlertService) ListAlertEvents(ctx context.Context, req *pb.ListAlertEventsRequest) (*pb.ListAlertEventsReply, error)

func (*AlertService) ListAlertRules

func (s *AlertService) ListAlertRules(ctx context.Context, req *pb.ListAlertRulesRequest) (*pb.ListAlertRulesReply, error)

func (*AlertService) UpdateAlertRule

func (s *AlertService) UpdateAlertRule(ctx context.Context, req *pb.UpdateAlertRuleRequest) (*pb.AlertRule, error)

type MessagingService

type MessagingService struct {
}

func NewMessagingService

func NewMessagingService() *MessagingService

type NodeService

type NodeService struct {
	pb.UnimplementedNodeServiceServer
	// contains filtered or unexported fields
}

func NewNodeService

func NewNodeService(nodes *biz.NodeUsecase) *NodeService

func (*NodeService) DeleteNode

func (s *NodeService) DeleteNode(ctx context.Context, req *pb.DeleteNodeRequest) (*pb.DeleteNodeReply, error)

func (*NodeService) GetNode

func (s *NodeService) GetNode(ctx context.Context, req *pb.GetNodeRequest) (*pb.GetNodeReply, error)

func (*NodeService) GetNodeStatistics

func (s *NodeService) GetNodeStatistics(ctx context.Context, _ *pb.GetNodeStatisticsRequest) (*pb.GetNodeStatisticsReply, error)

func (*NodeService) ListNodes

func (s *NodeService) ListNodes(ctx context.Context, req *pb.ListNodesRequest) (*pb.ListNodesReply, error)

func (*NodeService) UpdateNode

func (s *NodeService) UpdateNode(ctx context.Context, req *pb.UpdateNodeRequest) (*pb.UpdateNodeReply, error)

func (*NodeService) UpdateNodeLabels

func (s *NodeService) UpdateNodeLabels(ctx context.Context, req *pb.UpdateNodeLabelsRequest) (*pb.UpdateNodeReply, error)

type RealtimeService

type RealtimeService struct {
	pb.UnimplementedRealtimeServiceServer
	// contains filtered or unexported fields
}

func NewRealtimeService

func NewRealtimeService(realtime *biz.RealtimeUsecase) *RealtimeService

func (*RealtimeService) GetRealtimeOverview

func (s *RealtimeService) GetRealtimeOverview(ctx context.Context, req *pb.GetRealtimeOverviewRequest) (*pb.RealtimeOverview, error)

type TaskService

type TaskService struct {
	pb.UnimplementedTaskServiceServer
	// contains filtered or unexported fields
}

func NewTaskService

func NewTaskService(task *biz.TaskUsecase) *TaskService

func (*TaskService) CreateTask

func (s *TaskService) CreateTask(ctx context.Context, req *pb.CreateTaskRequest) (*pb.CreateTaskReply, error)

func (*TaskService) DeleteTask

func (s *TaskService) DeleteTask(ctx context.Context, req *pb.DeleteTaskRequest) (*pb.DeleteTaskReply, error)

func (*TaskService) GetTask

func (s *TaskService) GetTask(ctx context.Context, req *pb.GetTaskRequest) (*pb.Task, error)

func (*TaskService) ListTaskRunResults

func (s *TaskService) ListTaskRunResults(ctx context.Context, req *pb.ListTaskRunResultsRequest) (*pb.ListTaskRunResultsReply, error)

func (*TaskService) ListTaskRuns

func (s *TaskService) ListTaskRuns(ctx context.Context, req *pb.ListTaskRunsRequest) (*pb.ListTaskRunsReply, error)

func (*TaskService) ListTasks

func (s *TaskService) ListTasks(ctx context.Context, req *pb.ListTasksRequest) (*pb.ListTasksReply, error)

func (*TaskService) PauseTask

func (s *TaskService) PauseTask(ctx context.Context, req *pb.PauseTaskRequest) (*pb.PauseTaskReply, error)

func (*TaskService) ResumeTask

func (s *TaskService) ResumeTask(ctx context.Context, req *pb.ResumeTaskRequest) (*pb.ResumeTaskReply, error)