manager

package
v0.0.0-...-3ac4113 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 21, 2020 License: Apache-2.0 Imports: 34 Imported by: 0

Documentation

Overview

Copyright 2019 The KubeSphere Authors. All rights reserved. Use of this source code is governed by a Apache license that can be found in the LICENSE file.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Serve 

func Serve()

func ServeApiGateway 

func ServeApiGateway()

func ValidateCreateActionParams 

func ValidateCreateActionParams(ctx context.Context, req *pb.CreateActionRequest) error

func ValidateCreateAlertParams 

func ValidateCreateAlertParams(ctx context.Context, req *pb.CreateAlertRequest) error

func ValidateCreateCommentParams 

func ValidateCreateCommentParams(ctx context.Context, req *pb.CreateCommentRequest) error

func ValidateCreateMetricParams 

func ValidateCreateMetricParams(ctx context.Context, req *pb.CreateMetricRequest) error

func ValidateCreatePolicyParams 

func ValidateCreatePolicyParams(ctx context.Context, req *pb.CreatePolicyRequest) error

func ValidateCreateResourceFilterParams 

func ValidateCreateResourceFilterParams(ctx context.Context, req *pb.CreateResourceFilterRequest) error

func ValidateCreateResourceTypeParams 

func ValidateCreateResourceTypeParams(ctx context.Context, req *pb.CreateResourceTypeRequest) error

func ValidateCreateRuleParams 

func ValidateCreateRuleParams(ctx context.Context, req *pb.CreateRuleRequest) error

func ValidateModifyActionParams 

func ValidateModifyActionParams(ctx context.Context, req *pb.ModifyActionRequest) error

func ValidateModifyAlertParams 

func ValidateModifyAlertParams(ctx context.Context, req *pb.ModifyAlertRequest) error

func ValidateModifyMetricParams 

func ValidateModifyMetricParams(ctx context.Context, req *pb.ModifyMetricRequest) error

func ValidateModifyPolicyParams 

func ValidateModifyPolicyParams(ctx context.Context, req *pb.ModifyPolicyRequest) error

func ValidateModifyResourceFilterParams 

func ValidateModifyResourceFilterParams(ctx context.Context, req *pb.ModifyResourceFilterRequest) error

func ValidateModifyResourceTypeParams 

func ValidateModifyResourceTypeParams(ctx context.Context, req *pb.ModifyResourceTypeRequest) error

func ValidateModifyRuleParams 

func ValidateModifyRuleParams(ctx context.Context, req *pb.ModifyRuleRequest) error

Types

type AlertBroadcast 

type AlertBroadcast struct {
}

func NewAlertBroadcast 

func NewAlertBroadcast() *AlertBroadcast

func (*AlertBroadcast) Broadcast 

func (ab *AlertBroadcast) Broadcast(alertId string, operation string, expireTime int64) error

type AlertQueue 

type AlertQueue struct {
	// contains filtered or unexported fields
}

func NewAlertQueue 

func NewAlertQueue() *AlertQueue

func (*AlertQueue) Enqueue 

func (aq *AlertQueue) Enqueue(alertId string) error

type BroadcastInfo 

type BroadcastInfo struct {
	AlertId   string
	Operation string
}

BroadcastInfo is the service register information to etcd

type Server 

type Server struct {
	// contains filtered or unexported fields
}

func (*Server) Checker 

func (s *Server) Checker(ctx context.Context, req interface{}) error

func (*Server) CreateAction 

func (s *Server) CreateAction(ctx context.Context, req *CreateActionRequest) (*CreateActionResponse, error)

9.Action ********************************************************************************************************

func (*Server) CreateAlert 

func (s *Server) CreateAlert(ctx context.Context, req *CreateAlertRequest) (*CreateAlertResponse, error)

6.Alert ********************************************************************************************************

func (*Server) CreateComment 

func (s *Server) CreateComment(ctx context.Context, req *CreateCommentRequest) (*CreateCommentResponse, error)

8.Comment ********************************************************************************************************

func (*Server) CreateExecutor 

func (s *Server) CreateExecutor(context.Context, *CreateExecutorRequest) (*CreateExecutorResponse, error)

0.Executor ********************************************************************************************************

func (*Server) CreateHistory 

func (s *Server) CreateHistory(context.Context, *CreateHistoryRequest) (*CreateHistoryResponse, error)

7.History ********************************************************************************************************

func (*Server) CreateMetric 

func (s *Server) CreateMetric(ctx context.Context, req *CreateMetricRequest) (*CreateMetricResponse, error)

3.Metric ********************************************************************************************************

func (*Server) CreatePolicy 

func (s *Server) CreatePolicy(ctx context.Context, req *CreatePolicyRequest) (*CreatePolicyResponse, error)

4.Policy ********************************************************************************************************

func (*Server) CreateResourceFilter 

func (s *Server) CreateResourceFilter(ctx context.Context, req *CreateResourceFilterRequest) (*CreateResourceFilterResponse, error)

2.Resource Filter ********************************************************************************************************

func (*Server) CreateResourceType 

func (s *Server) CreateResourceType(ctx context.Context, req *CreateResourceTypeRequest) (*CreateResourceTypeResponse, error)

1.ResourceType ********************************************************************************************************

func (*Server) CreateRule 

func (s *Server) CreateRule(ctx context.Context, req *CreateRuleRequest) (*CreateRuleResponse, error)

5.Rule ********************************************************************************************************

func (*Server) DeleteActions 

func (s *Server) DeleteActions(ctx context.Context, req *DeleteActionsRequest) (*DeleteActionsResponse, error)

func (*Server) DeleteAlerts 

func (s *Server) DeleteAlerts(ctx context.Context, req *DeleteAlertsRequest) (*DeleteAlertsResponse, error)

func (*Server) DeleteComments 

func (s *Server) DeleteComments(context.Context, *DeleteCommentsRequest) (*DeleteCommentsResponse, error)

func (*Server) DeleteExecutors 

func (s *Server) DeleteExecutors(context.Context, *DeleteExecutorsRequest) (*DeleteExecutorsResponse, error)

func (*Server) DeleteHistories 

func (s *Server) DeleteHistories(context.Context, *DeleteHistoriesRequest) (*DeleteHistoriesResponse, error)

func (*Server) DeleteMetrics 

func (s *Server) DeleteMetrics(ctx context.Context, req *DeleteMetricsRequest) (*DeleteMetricsResponse, error)

func (*Server) DeletePolicies 

func (s *Server) DeletePolicies(ctx context.Context, req *DeletePoliciesRequest) (*DeletePoliciesResponse, error)

func (*Server) DeleteResourceFilters 

func (s *Server) DeleteResourceFilters(ctx context.Context, req *DeleteResourceFiltersRequest) (*DeleteResourceFiltersResponse, error)

func (*Server) DeleteResourceTypes 

func (s *Server) DeleteResourceTypes(ctx context.Context, req *DeleteResourceTypesRequest) (*DeleteResourceTypesResponse, error)

func (*Server) DeleteRules 

func (s *Server) DeleteRules(ctx context.Context, req *DeleteRulesRequest) (*DeleteRulesResponse, error)

func (*Server) DescribeActions 

func (s *Server) DescribeActions(ctx context.Context, req *DescribeActionsRequest) (*DescribeActionsResponse, error)

func (*Server) DescribeAlertDetails 

func (s *Server) DescribeAlertDetails(ctx context.Context, req *DescribeAlertDetailsRequest) (*DescribeAlertDetailsResponse, error)

func (*Server) DescribeAlertStatus 

func (s *Server) DescribeAlertStatus(ctx context.Context, req *DescribeAlertStatusRequest) (*DescribeAlertStatusResponse, error)

func (*Server) DescribeAlerts 

func (s *Server) DescribeAlerts(ctx context.Context, req *DescribeAlertsRequest) (*DescribeAlertsResponse, error)

func (*Server) DescribeAlertsWithResource 

func (s *Server) DescribeAlertsWithResource(ctx context.Context, req *DescribeAlertsWithResourceRequest) (*DescribeAlertsWithResourceResponse, error)

0.Alert ********************************************************************************************************

func (*Server) DescribeComments 

func (s *Server) DescribeComments(ctx context.Context, req *DescribeCommentsRequest) (*DescribeCommentsResponse, error)

func (*Server) DescribeExecutors 

func (s *Server) DescribeExecutors(context.Context, *DescribeExecutorsRequest) (*DescribeExecutorsResponse, error)

func (*Server) DescribeHistories 

func (s *Server) DescribeHistories(ctx context.Context, req *DescribeHistoriesRequest) (*DescribeHistoriesResponse, error)

func (*Server) DescribeHistoryDetail 

func (s *Server) DescribeHistoryDetail(ctx context.Context, req *DescribeHistoryDetailRequest) (*DescribeHistoryDetailResponse, error)

1.History ********************************************************************************************************

func (*Server) DescribeMetrics 

func (s *Server) DescribeMetrics(ctx context.Context, req *DescribeMetricsRequest) (*DescribeMetricsResponse, error)

func (*Server) DescribePolicies 

func (s *Server) DescribePolicies(ctx context.Context, req *DescribePoliciesRequest) (*DescribePoliciesResponse, error)

func (*Server) DescribeResourceFilters 

func (s *Server) DescribeResourceFilters(ctx context.Context, req *DescribeResourceFiltersRequest) (*DescribeResourceFiltersResponse, error)

func (*Server) DescribeResourceTypes 

func (s *Server) DescribeResourceTypes(ctx context.Context, req *DescribeResourceTypesRequest) (*DescribeResourceTypesResponse, error)

func (*Server) DescribeRules 

func (s *Server) DescribeRules(ctx context.Context, req *DescribeRulesRequest) (*DescribeRulesResponse, error)

func (*Server) ModifyAction 

func (s *Server) ModifyAction(ctx context.Context, req *ModifyActionRequest) (*ModifyActionResponse, error)

func (*Server) ModifyAlert 

func (s *Server) ModifyAlert(ctx context.Context, req *ModifyAlertRequest) (*ModifyAlertResponse, error)

func (*Server) ModifyComment 

func (s *Server) ModifyComment(context.Context, *ModifyCommentRequest) (*ModifyCommentResponse, error)

func (*Server) ModifyExecutor 

func (s *Server) ModifyExecutor(context.Context, *ModifyExecutorRequest) (*ModifyExecutorResponse, error)

func (*Server) ModifyHistory 

func (s *Server) ModifyHistory(context.Context, *ModifyHistoryRequest) (*ModifyHistoryResponse, error)

func (*Server) ModifyMetric 

func (s *Server) ModifyMetric(ctx context.Context, req *ModifyMetricRequest) (*ModifyMetricResponse, error)

func (*Server) ModifyPolicy 

func (s *Server) ModifyPolicy(ctx context.Context, req *ModifyPolicyRequest) (*ModifyPolicyResponse, error)

func (*Server) ModifyResourceFilter 

func (s *Server) ModifyResourceFilter(ctx context.Context, req *ModifyResourceFilterRequest) (*ModifyResourceFilterResponse, error)

func (*Server) ModifyResourceType 

func (s *Server) ModifyResourceType(ctx context.Context, req *ModifyResourceTypeRequest) (*ModifyResourceTypeResponse, error)

func (*Server) ModifyRule 

func (s *Server) ModifyRule(ctx context.Context, req *ModifyRuleRequest) (*ModifyRuleResponse, error)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.