service

README

Service

Documentation

Index

• Variables
• type AgentService
  • func NewAgentService(logger log.Logger, cri *biz.CRIUsecase, clusters *biz.ClusterUsecase) *AgentService
  • func (s *AgentService) Check(ctx context.Context) error
  • func (s *AgentService) GetKey(ctx context.Context, req *pb.GetKeyRequest) (*pb.GetKeyReply, error)
  • func (s *AgentService) ListCluster(ctx context.Context, req *pb.ListClusterRequest) (*pb.ListClusterReply, error)
  • func (s *AgentService) ListKey(ctx context.Context, req *pb.ListKeyRequest) (*pb.ListKeyReply, error)
  • func (s *AgentService) ListService(ctx context.Context, req *pb.ListServiceRequest) (*pb.ListServiceReply, error)
  • func (s *AgentService) ListServiceGroup(ctx context.Context, req *pb.ListServiceGroupRequest) (*pb.ListServiceGroupReply, error)
  • func (s *AgentService) UpdateHangState(ctx context.Context, req *pb.UpdateHangStateRequest) (*pb.UpdateHangStateReply, error)

Variables

var ProviderSet = wire.NewSet(
	NewAgentService,
)

ProviderSet is service providers.

Types

type AgentService

type AgentService struct {
	pb.UnimplementedAgentServer
	// contains filtered or unexported fields
}

func NewAgentService

func NewAgentService(logger log.Logger, cri *biz.CRIUsecase, clusters *biz.ClusterUsecase) *AgentService

func (*AgentService) Check

func (s *AgentService) Check(ctx context.Context) error

func (*AgentService) GetKey

func (s *AgentService) GetKey(ctx context.Context, req *pb.GetKeyRequest) (*pb.GetKeyReply, error)

func (*AgentService) ListCluster

func (s *AgentService) ListCluster(ctx context.Context, req *pb.ListClusterRequest) (*pb.ListClusterReply, error)

func (*AgentService) ListKey

func (s *AgentService) ListKey(ctx context.Context, req *pb.ListKeyRequest) (*pb.ListKeyReply, error)

func (*AgentService) ListService

func (s *AgentService) ListService(ctx context.Context, req *pb.ListServiceRequest) (*pb.ListServiceReply, error)

func (*AgentService) ListServiceGroup

func (s *AgentService) ListServiceGroup(ctx context.Context, req *pb.ListServiceGroupRequest) (*pb.ListServiceGroupReply, error)

func (*AgentService) UpdateHangState

func (s *AgentService) UpdateHangState(ctx context.Context, req *pb.UpdateHangStateRequest) (*pb.UpdateHangStateReply, error)