management

package
v2.17.0+incompatible Latest Latest
Warning

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

 Go to latest Published: May 7, 2021 License: AGPL-3.0 Imports: 31 Imported by: 2

Documentation

Overview

Package management contains management business logic and APIs.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AnnotationService 

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

AnnotationService Annotation Service.

func NewAnnotationService 

func NewAnnotationService(db *reform.DB, grafanaClient grafanaClient) *AnnotationService

NewAnnotationService create new Annotation Service.

func (*AnnotationService) AddAnnotation 

func (as *AnnotationService) AddAnnotation(
	ctx context.Context,
	authorizationHeaders []string,
	req *managementpb.AddAnnotationRequest,
) (*managementpb.AddAnnotationResponse, error)

AddAnnotation create annotation in grafana.

type AzureDatabaseInstanceData 

type AzureDatabaseInstanceData struct {
	ID            string                 `json:"id"`
	Location      string                 `json:"location"`
	Name          string                 `json:"name"`
	Properties    map[string]interface{} `json:"properties"`
	Tags          map[string]string      `json:"tags"`
	Sku           map[string]interface{} `json:"sku"`
	ResourceGroup string                 `json:"resourceGroup"`
	Type          string                 `json:"type"`
	Zones         string                 `json:"zones"`
}

AzureDatabaseInstanceData reflects Azure Database Instance Data of Discovery Response.

type AzureDatabaseService 

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

AzureDatabaseService represents instance discovery service.

func NewAzureDatabaseService 

func NewAzureDatabaseService(db *reform.DB, registry agentsRegistry) *AzureDatabaseService

NewAzureDatabaseService creates new instance discovery service.

func (*AzureDatabaseService) AddAzureDatabase 

func (s *AzureDatabaseService) AddAzureDatabase(ctx context.Context, req *azurev1beta1.AddAzureDatabaseRequest) (*azurev1beta1.AddAzureDatabaseResponse, error)

AddAzureDatabase add azure database to monitoring.

func (*AzureDatabaseService) DiscoverAzureDatabase 

func (s *AzureDatabaseService) DiscoverAzureDatabase(
	ctx context.Context,
	req *azurev1beta1.DiscoverAzureDatabaseRequest,
) (*azurev1beta1.DiscoverAzureDatabaseResponse, error)

DiscoverAzureDatabase discovers database instances on Azure.

func (*AzureDatabaseService) Enabled 

func (s *AzureDatabaseService) Enabled() bool

Enabled returns if service is enabled and can be used.

type ChecksAPIService 

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

ChecksAPIService represents security checks service API.

func NewChecksAPIService 

func NewChecksAPIService(checksService checksService) *ChecksAPIService

NewChecksAPIService creates new Checks API Service.

func (*ChecksAPIService) ChangeSecurityChecks 

func (s *ChecksAPIService) ChangeSecurityChecks(ctx context.Context, req *managementpb.ChangeSecurityChecksRequest) (*managementpb.ChangeSecurityChecksResponse, error)

ChangeSecurityChecks enables/disables Security Thread Tool checks by names or changes its execution interval.

func (*ChecksAPIService) GetSecurityCheckResults 

func (s *ChecksAPIService) GetSecurityCheckResults(ctx context.Context, request *managementpb.GetSecurityCheckResultsRequest) (*managementpb.GetSecurityCheckResultsResponse, error)

GetSecurityCheckResults returns Security Thread Tool's latest checks results.

func (*ChecksAPIService) ListSecurityChecks 

func (s *ChecksAPIService) ListSecurityChecks(ctx context.Context, req *managementpb.ListSecurityChecksRequest) (*managementpb.ListSecurityChecksResponse, error)

ListSecurityChecks returns a list of available Security Thread Tool checks and their statuses.

func (*ChecksAPIService) StartSecurityChecks 

func (s *ChecksAPIService) StartSecurityChecks(ctx context.Context, request *managementpb.StartSecurityChecksRequest) (*managementpb.StartSecurityChecksResponse, error)

StartSecurityChecks executes Security Thread Tool checks and returns when all checks are executed.

type ExternalService 

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

ExternalService External Management Service.

func NewExternalService 

func NewExternalService(db *reform.DB, registry agentsRegistry, vmdb prometheusService) *ExternalService

NewExternalService creates new External Management Service.

func (*ExternalService) AddExternal 

func (e *ExternalService) AddExternal(ctx context.Context, req *managementpb.AddExternalRequest) (*managementpb.AddExternalResponse, error)

type HAProxyService 

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

HAProxyService HAProxy Management Service.

func NewHAProxyService 

func NewHAProxyService(db *reform.DB, registry agentsRegistry, vmdb prometheusService) *HAProxyService

NewHAProxyService creates new HAProxy Management Service.

func (HAProxyService) AddHAProxy 

func (e HAProxyService) AddHAProxy(ctx context.Context, req *managementpb.AddHAProxyRequest) (*managementpb.AddHAProxyResponse, error)

type JobsAPIService 

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

JobsAPIService provides methods for Jobs starting and management.

func NewJobsAPIServer 

func NewJobsAPIServer(db *reform.DB, service jobsService) *JobsAPIService

NewJobsAPIServer creates new jobs service.

func (*JobsAPIService) CancelJob 

func (s *JobsAPIService) CancelJob(_ context.Context, req *jobsAPI.CancelJobRequest) (*jobsAPI.CancelJobResponse, error)

CancelJob terminates job.

func (*JobsAPIService) GetJob 

func (s *JobsAPIService) GetJob(_ context.Context, req *jobsAPI.GetJobRequest) (*jobsAPI.GetJobResponse, error)

GetJob returns job result.

func (*JobsAPIService) StartEchoJob 

func (s *JobsAPIService) StartEchoJob(_ context.Context, req *jobsAPI.StartEchoJobRequest) (*jobsAPI.StartEchoJobResponse, error)

StartEchoJob starts echo job. Its purpose is testing.

type MongoDBService 

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

MongoDBService MongoDB Management Service.

func NewMongoDBService 

func NewMongoDBService(db *reform.DB, registry agentsRegistry) *MongoDBService

NewMongoDBService creates new MongoDB Management Service.

func (*MongoDBService) Add 

func (s *MongoDBService) Add(ctx context.Context, req *managementpb.AddMongoDBRequest) (*managementpb.AddMongoDBResponse, error)

Add adds "MongoDB Service", "MongoDB Exporter Agent" and "QAN MongoDB Profiler".

type MySQLService 

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

MySQLService MySQL Management Service.

func NewMySQLService 

func NewMySQLService(db *reform.DB, registry agentsRegistry) *MySQLService

NewMySQLService creates new MySQL Management Service.

func (*MySQLService) Add 

func (s *MySQLService) Add(ctx context.Context, req *managementpb.AddMySQLRequest) (*managementpb.AddMySQLResponse, error)

Add adds "MySQL Service", "MySQL Exporter Agent" and "QAN MySQL PerfSchema Agent".

type NodeService 

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

NodeService represents service for working with nodes.

func NewNodeService 

func NewNodeService(db *reform.DB, registry agentsRegistry) *NodeService

NewNodeService creates NodeService instance.

func (*NodeService) Register 

func (s *NodeService) Register(ctx context.Context, req *managementpb.RegisterNodeRequest) (*managementpb.RegisterNodeResponse, error)

Register do registration of the new node.

type PostgreSQLService 

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

PostgreSQLService PostgreSQL Management Service.

func NewPostgreSQLService 

func NewPostgreSQLService(db *reform.DB, registry agentsRegistry) *PostgreSQLService

NewPostgreSQLService creates new PostgreSQL Management Service.

func (*PostgreSQLService) Add 

func (s *PostgreSQLService) Add(ctx context.Context, req *managementpb.AddPostgreSQLRequest) (*managementpb.AddPostgreSQLResponse, error)

Add adds "PostgreSQL Service", "PostgreSQL Exporter Agent" and "QAN PostgreSQL PerfSchema Agent".

type ProxySQLService 

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

ProxySQLService ProxySQL Management Service.

func NewProxySQLService 

func NewProxySQLService(db *reform.DB, registry agentsRegistry) *ProxySQLService

NewProxySQLService creates new ProxySQL Management Service.

func (*ProxySQLService) Add 

func (s *ProxySQLService) Add(ctx context.Context, req *managementpb.AddProxySQLRequest) (*managementpb.AddProxySQLResponse, error)

Add adds "ProxySQL Service", "ProxySQL Exporter Agent" and "QAN ProxySQL PerfSchema Agent".

type RDSService 

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

RDSService represents instance discovery service.

func NewRDSService 

func NewRDSService(db *reform.DB, registry agentsRegistry) *RDSService

NewRDSService creates new instance discovery service.

func (*RDSService) AddRDS 

func (s *RDSService) AddRDS(ctx context.Context, req *managementpb.AddRDSRequest) (*managementpb.AddRDSResponse, error)

AddRDS adds RDS instance.

func (*RDSService) DiscoverRDS 

func (s *RDSService) DiscoverRDS(ctx context.Context, req *managementpb.DiscoverRDSRequest) (*managementpb.DiscoverRDSResponse, error)

DiscoverRDS discovers RDS instances.

type ServiceService 

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

ServiceService represents service for working with services.

func NewServiceService 

func NewServiceService(db *reform.DB, registry agentsRegistry, vmdb prometheusService) *ServiceService

NewServiceService creates ServiceService instance.

func (*ServiceService) RemoveService 

func (s *ServiceService) RemoveService(ctx context.Context, req *managementpb.RemoveServiceRequest) (*managementpb.RemoveServiceResponse, error)

RemoveService removes Service with Agents.

Source Files

View all Source files

Directories

Path Synopsis
Package backup provides backup functionality.
 Package backup provides backup functionality.
Package dbaas contains all APIs related to DBaaS. Package dbaas contains all logic related to dbaas services.
 Package dbaas contains all APIs related to DBaaS. Package dbaas contains all logic related to dbaas services.
Package grpc provides gRPC servers.
 Package grpc provides gRPC servers.
Package ia contains Integrated Alerting APIs implementations.
 Package ia contains Integrated Alerting APIs implementations.

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.