managementpb

package
Version: v2.18.0+incompatible Latest Latest
Warning

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

Go to latest
Published: May 17, 2021 License: AGPL-3.0 Imports: 22 Imported by: 4

Documentation

Overview

Package managementpb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package managementpb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package managementpb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package managementpb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package managementpb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package managementpb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package managementpb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package managementpb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package managementpb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package managementpb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package managementpb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package managementpb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source
var (
	ActionType_name = map[int32]string{
		0:  "ACTION_TYPE_INVALID",
		1:  "MYSQL_EXPLAIN",
		2:  "MYSQL_SHOW_CREATE_TABLE",
		3:  "MYSQL_SHOW_TABLE_STATUS",
		4:  "MYSQL_SHOW_INDEX",
		5:  "POSTGRESQL_SHOW_CREATE_TABLE",
		6:  "POSTGRESQL_SHOW_INDEX",
		7:  "MONGODB_EXPLAIN",
		8:  "PT_SUMMARY",
		9:  "PT_MYSQL_SUMMARY",
		10: "PT_PG_SUMMARY",
		11: "PT_MONGODB_SUMMARY",
	}
	ActionType_value = map[string]int32{
		"ACTION_TYPE_INVALID":          0,
		"MYSQL_EXPLAIN":                1,
		"MYSQL_SHOW_CREATE_TABLE":      2,
		"MYSQL_SHOW_TABLE_STATUS":      3,
		"MYSQL_SHOW_INDEX":             4,
		"POSTGRESQL_SHOW_CREATE_TABLE": 5,
		"POSTGRESQL_SHOW_INDEX":        6,
		"MONGODB_EXPLAIN":              7,
		"PT_SUMMARY":                   8,
		"PT_MYSQL_SUMMARY":             9,
		"PT_PG_SUMMARY":                10,
		"PT_MONGODB_SUMMARY":           11,
	}
)

Enum value maps for ActionType.

View Source
var (
	SecurityCheckInterval_name = map[int32]string{
		0: "SECURITY_CHECK_INTERVAL_INVALID",
		1: "STANDARD",
		2: "FREQUENT",
		3: "RARE",
	}
	SecurityCheckInterval_value = map[string]int32{
		"SECURITY_CHECK_INTERVAL_INVALID": 0,
		"STANDARD":                        1,
		"FREQUENT":                        2,
		"RARE":                            3,
	}
)

Enum value maps for SecurityCheckInterval.

View Source
var (
	MetricsMode_name = map[int32]string{
		0: "AUTO",
		1: "PULL",
		2: "PUSH",
	}
	MetricsMode_value = map[string]int32{
		"AUTO": 0,
		"PULL": 1,
		"PUSH": 2,
	}
)

Enum value maps for MetricsMode.

View Source
var (
	DiscoverRDSEngine_name = map[int32]string{
		0: "DISCOVER_RDS_ENGINE_INVALID",
		1: "DISCOVER_RDS_MYSQL",
		2: "DISCOVER_RDS_POSTGRESQL",
	}
	DiscoverRDSEngine_value = map[string]int32{
		"DISCOVER_RDS_ENGINE_INVALID": 0,
		"DISCOVER_RDS_MYSQL":          1,
		"DISCOVER_RDS_POSTGRESQL":     2,
	}
)

Enum value maps for DiscoverRDSEngine.

View Source
var (
	Severity_name = map[int32]string{
		0: "SEVERITY_INVALID",
		1: "SEVERITY_EMERGENCY",
		2: "SEVERITY_ALERT",
		3: "SEVERITY_CRITICAL",
		4: "SEVERITY_ERROR",
		5: "SEVERITY_WARNING",
		6: "SEVERITY_NOTICE",
		7: "SEVERITY_INFO",
		8: "SEVERITY_DEBUG",
	}
	Severity_value = map[string]int32{
		"SEVERITY_INVALID":   0,
		"SEVERITY_EMERGENCY": 1,
		"SEVERITY_ALERT":     2,
		"SEVERITY_CRITICAL":  3,
		"SEVERITY_ERROR":     4,
		"SEVERITY_WARNING":   5,
		"SEVERITY_NOTICE":    6,
		"SEVERITY_INFO":      7,
		"SEVERITY_DEBUG":     8,
	}
)

Enum value maps for Severity.

View Source
var File_managementpb_actions_proto protoreflect.FileDescriptor
View Source
var File_managementpb_annotation_proto protoreflect.FileDescriptor
View Source
var File_managementpb_checks_proto protoreflect.FileDescriptor
View Source
var File_managementpb_external_proto protoreflect.FileDescriptor
View Source
var File_managementpb_haproxy_proto protoreflect.FileDescriptor
View Source
var File_managementpb_metrics_proto protoreflect.FileDescriptor
View Source
var File_managementpb_mongodb_proto protoreflect.FileDescriptor
View Source
var File_managementpb_mysql_proto protoreflect.FileDescriptor
View Source
var File_managementpb_node_proto protoreflect.FileDescriptor
View Source
var File_managementpb_postgresql_proto protoreflect.FileDescriptor
View Source
var File_managementpb_proxysql_proto protoreflect.FileDescriptor
View Source
var File_managementpb_rds_proto protoreflect.FileDescriptor
View Source
var File_managementpb_service_proto protoreflect.FileDescriptor
View Source
var File_managementpb_severity_proto protoreflect.FileDescriptor

Functions

func RegisterActionsHandler

func RegisterActionsHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterActionsHandler registers the http handlers for service Actions to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterActionsHandlerClient

func RegisterActionsHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ActionsClient) error

RegisterActionsHandlerClient registers the http handlers for service Actions to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ActionsClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ActionsClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ActionsClient" to call the correct interceptors.

func RegisterActionsHandlerFromEndpoint

func RegisterActionsHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterActionsHandlerFromEndpoint is same as RegisterActionsHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterActionsHandlerServer

func RegisterActionsHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ActionsServer) error

RegisterActionsHandlerServer registers the http handlers for service Actions to "mux". UnaryRPC :call ActionsServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterActionsHandlerFromEndpoint instead.

func RegisterActionsServer

func RegisterActionsServer(s *grpc.Server, srv ActionsServer)

func RegisterAnnotationHandler

func RegisterAnnotationHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterAnnotationHandler registers the http handlers for service Annotation to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterAnnotationHandlerClient

func RegisterAnnotationHandlerClient(ctx context.Context, mux *runtime.ServeMux, client AnnotationClient) error

RegisterAnnotationHandlerClient registers the http handlers for service Annotation to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "AnnotationClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "AnnotationClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "AnnotationClient" to call the correct interceptors.

func RegisterAnnotationHandlerFromEndpoint

func RegisterAnnotationHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterAnnotationHandlerFromEndpoint is same as RegisterAnnotationHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterAnnotationHandlerServer

func RegisterAnnotationHandlerServer(ctx context.Context, mux *runtime.ServeMux, server AnnotationServer) error

RegisterAnnotationHandlerServer registers the http handlers for service Annotation to "mux". UnaryRPC :call AnnotationServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterAnnotationHandlerFromEndpoint instead.

func RegisterAnnotationServer

func RegisterAnnotationServer(s *grpc.Server, srv AnnotationServer)

func RegisterExternalHandler

func RegisterExternalHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterExternalHandler registers the http handlers for service External to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterExternalHandlerClient

func RegisterExternalHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ExternalClient) error

RegisterExternalHandlerClient registers the http handlers for service External to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ExternalClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ExternalClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ExternalClient" to call the correct interceptors.

func RegisterExternalHandlerFromEndpoint

func RegisterExternalHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterExternalHandlerFromEndpoint is same as RegisterExternalHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterExternalHandlerServer

func RegisterExternalHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ExternalServer) error

RegisterExternalHandlerServer registers the http handlers for service External to "mux". UnaryRPC :call ExternalServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterExternalHandlerFromEndpoint instead.

func RegisterExternalServer

func RegisterExternalServer(s *grpc.Server, srv ExternalServer)

func RegisterHAProxyHandler

func RegisterHAProxyHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterHAProxyHandler registers the http handlers for service HAProxy to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterHAProxyHandlerClient

func RegisterHAProxyHandlerClient(ctx context.Context, mux *runtime.ServeMux, client HAProxyClient) error

RegisterHAProxyHandlerClient registers the http handlers for service HAProxy to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "HAProxyClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "HAProxyClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "HAProxyClient" to call the correct interceptors.

func RegisterHAProxyHandlerFromEndpoint

func RegisterHAProxyHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterHAProxyHandlerFromEndpoint is same as RegisterHAProxyHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterHAProxyHandlerServer

func RegisterHAProxyHandlerServer(ctx context.Context, mux *runtime.ServeMux, server HAProxyServer) error

RegisterHAProxyHandlerServer registers the http handlers for service HAProxy to "mux". UnaryRPC :call HAProxyServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterHAProxyHandlerFromEndpoint instead.

func RegisterHAProxyServer

func RegisterHAProxyServer(s *grpc.Server, srv HAProxyServer)

func RegisterMongoDBHandler

func RegisterMongoDBHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterMongoDBHandler registers the http handlers for service MongoDB to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterMongoDBHandlerClient

func RegisterMongoDBHandlerClient(ctx context.Context, mux *runtime.ServeMux, client MongoDBClient) error

RegisterMongoDBHandlerClient registers the http handlers for service MongoDB to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "MongoDBClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "MongoDBClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "MongoDBClient" to call the correct interceptors.

func RegisterMongoDBHandlerFromEndpoint

func RegisterMongoDBHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterMongoDBHandlerFromEndpoint is same as RegisterMongoDBHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterMongoDBHandlerServer

func RegisterMongoDBHandlerServer(ctx context.Context, mux *runtime.ServeMux, server MongoDBServer) error

RegisterMongoDBHandlerServer registers the http handlers for service MongoDB to "mux". UnaryRPC :call MongoDBServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterMongoDBHandlerFromEndpoint instead.

func RegisterMongoDBServer

func RegisterMongoDBServer(s *grpc.Server, srv MongoDBServer)

func RegisterMySQLHandler

func RegisterMySQLHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterMySQLHandler registers the http handlers for service MySQL to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterMySQLHandlerClient

func RegisterMySQLHandlerClient(ctx context.Context, mux *runtime.ServeMux, client MySQLClient) error

RegisterMySQLHandlerClient registers the http handlers for service MySQL to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "MySQLClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "MySQLClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "MySQLClient" to call the correct interceptors.

func RegisterMySQLHandlerFromEndpoint

func RegisterMySQLHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterMySQLHandlerFromEndpoint is same as RegisterMySQLHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterMySQLHandlerServer

func RegisterMySQLHandlerServer(ctx context.Context, mux *runtime.ServeMux, server MySQLServer) error

RegisterMySQLHandlerServer registers the http handlers for service MySQL to "mux". UnaryRPC :call MySQLServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterMySQLHandlerFromEndpoint instead.

func RegisterMySQLServer

func RegisterMySQLServer(s *grpc.Server, srv MySQLServer)

func RegisterNodeHandler

func RegisterNodeHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterNodeHandler registers the http handlers for service Node to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterNodeHandlerClient

func RegisterNodeHandlerClient(ctx context.Context, mux *runtime.ServeMux, client NodeClient) error

RegisterNodeHandlerClient registers the http handlers for service Node to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "NodeClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "NodeClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "NodeClient" to call the correct interceptors.

func RegisterNodeHandlerFromEndpoint

func RegisterNodeHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterNodeHandlerFromEndpoint is same as RegisterNodeHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterNodeHandlerServer

func RegisterNodeHandlerServer(ctx context.Context, mux *runtime.ServeMux, server NodeServer) error

RegisterNodeHandlerServer registers the http handlers for service Node to "mux". UnaryRPC :call NodeServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterNodeHandlerFromEndpoint instead.

func RegisterNodeServer

func RegisterNodeServer(s *grpc.Server, srv NodeServer)

func RegisterPostgreSQLHandler

func RegisterPostgreSQLHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterPostgreSQLHandler registers the http handlers for service PostgreSQL to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterPostgreSQLHandlerClient

func RegisterPostgreSQLHandlerClient(ctx context.Context, mux *runtime.ServeMux, client PostgreSQLClient) error

RegisterPostgreSQLHandlerClient registers the http handlers for service PostgreSQL to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "PostgreSQLClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "PostgreSQLClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "PostgreSQLClient" to call the correct interceptors.

func RegisterPostgreSQLHandlerFromEndpoint

func RegisterPostgreSQLHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterPostgreSQLHandlerFromEndpoint is same as RegisterPostgreSQLHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterPostgreSQLHandlerServer

func RegisterPostgreSQLHandlerServer(ctx context.Context, mux *runtime.ServeMux, server PostgreSQLServer) error

RegisterPostgreSQLHandlerServer registers the http handlers for service PostgreSQL to "mux". UnaryRPC :call PostgreSQLServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterPostgreSQLHandlerFromEndpoint instead.

func RegisterPostgreSQLServer

func RegisterPostgreSQLServer(s *grpc.Server, srv PostgreSQLServer)

func RegisterProxySQLHandler

func RegisterProxySQLHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterProxySQLHandler registers the http handlers for service ProxySQL to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterProxySQLHandlerClient

func RegisterProxySQLHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ProxySQLClient) error

RegisterProxySQLHandlerClient registers the http handlers for service ProxySQL to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ProxySQLClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ProxySQLClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ProxySQLClient" to call the correct interceptors.

func RegisterProxySQLHandlerFromEndpoint

func RegisterProxySQLHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterProxySQLHandlerFromEndpoint is same as RegisterProxySQLHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterProxySQLHandlerServer

func RegisterProxySQLHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ProxySQLServer) error

RegisterProxySQLHandlerServer registers the http handlers for service ProxySQL to "mux". UnaryRPC :call ProxySQLServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterProxySQLHandlerFromEndpoint instead.

func RegisterProxySQLServer

func RegisterProxySQLServer(s *grpc.Server, srv ProxySQLServer)

func RegisterRDSHandler

func RegisterRDSHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterRDSHandler registers the http handlers for service RDS to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterRDSHandlerClient

func RegisterRDSHandlerClient(ctx context.Context, mux *runtime.ServeMux, client RDSClient) error

RegisterRDSHandlerClient registers the http handlers for service RDS to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "RDSClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "RDSClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "RDSClient" to call the correct interceptors.

func RegisterRDSHandlerFromEndpoint

func RegisterRDSHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterRDSHandlerFromEndpoint is same as RegisterRDSHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterRDSHandlerServer

func RegisterRDSHandlerServer(ctx context.Context, mux *runtime.ServeMux, server RDSServer) error

RegisterRDSHandlerServer registers the http handlers for service RDS to "mux". UnaryRPC :call RDSServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterRDSHandlerFromEndpoint instead.

func RegisterRDSServer

func RegisterRDSServer(s *grpc.Server, srv RDSServer)

func RegisterSecurityChecksHandler

func RegisterSecurityChecksHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterSecurityChecksHandler registers the http handlers for service SecurityChecks to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterSecurityChecksHandlerClient

func RegisterSecurityChecksHandlerClient(ctx context.Context, mux *runtime.ServeMux, client SecurityChecksClient) error

RegisterSecurityChecksHandlerClient registers the http handlers for service SecurityChecks to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "SecurityChecksClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "SecurityChecksClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "SecurityChecksClient" to call the correct interceptors.

func RegisterSecurityChecksHandlerFromEndpoint

func RegisterSecurityChecksHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterSecurityChecksHandlerFromEndpoint is same as RegisterSecurityChecksHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterSecurityChecksHandlerServer

func RegisterSecurityChecksHandlerServer(ctx context.Context, mux *runtime.ServeMux, server SecurityChecksServer) error

RegisterSecurityChecksHandlerServer registers the http handlers for service SecurityChecks to "mux". UnaryRPC :call SecurityChecksServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterSecurityChecksHandlerFromEndpoint instead.

func RegisterSecurityChecksServer

func RegisterSecurityChecksServer(s *grpc.Server, srv SecurityChecksServer)

func RegisterServiceHandler

func RegisterServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterServiceHandler registers the http handlers for service Service to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterServiceHandlerClient

func RegisterServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ServiceClient) error

RegisterServiceHandlerClient registers the http handlers for service Service to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ServiceClient" to call the correct interceptors.

func RegisterServiceHandlerFromEndpoint

func RegisterServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterServiceHandlerFromEndpoint is same as RegisterServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterServiceHandlerServer

func RegisterServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ServiceServer) error

RegisterServiceHandlerServer registers the http handlers for service Service to "mux". UnaryRPC :call ServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterServiceHandlerFromEndpoint instead.

func RegisterServiceServer

func RegisterServiceServer(s *grpc.Server, srv ServiceServer)

Types

type ActionType

type ActionType int32

ActionType represents Action type.

const (
	ActionType_ACTION_TYPE_INVALID          ActionType = 0
	ActionType_MYSQL_EXPLAIN                ActionType = 1
	ActionType_MYSQL_SHOW_CREATE_TABLE      ActionType = 2
	ActionType_MYSQL_SHOW_TABLE_STATUS      ActionType = 3
	ActionType_MYSQL_SHOW_INDEX             ActionType = 4
	ActionType_POSTGRESQL_SHOW_CREATE_TABLE ActionType = 5
	ActionType_POSTGRESQL_SHOW_INDEX        ActionType = 6
	ActionType_MONGODB_EXPLAIN              ActionType = 7
	ActionType_PT_SUMMARY                   ActionType = 8
	ActionType_PT_MYSQL_SUMMARY             ActionType = 9
	ActionType_PT_PG_SUMMARY                ActionType = 10
	ActionType_PT_MONGODB_SUMMARY           ActionType = 11
)

func (ActionType) Descriptor

func (ActionType) Descriptor() protoreflect.EnumDescriptor

func (ActionType) Enum

func (x ActionType) Enum() *ActionType

func (ActionType) EnumDescriptor deprecated

This method has been deprecated.
func (ActionType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ActionType.Descriptor instead.

func (ActionType) Number

func (x ActionType) Number() protoreflect.EnumNumber

func (ActionType) String

func (x ActionType) String() string

func (ActionType) Type

type ActionsClient

type ActionsClient interface {
	// GetAction gets an result of given Action.
	GetAction(ctx context.Context, in *GetActionRequest, opts ...grpc.CallOption) (*GetActionResponse, error)
	// StartMySQLExplainAction starts MySQL EXPLAIN Action with traditional output.
	StartMySQLExplainAction(ctx context.Context, in *StartMySQLExplainActionRequest, opts ...grpc.CallOption) (*StartMySQLExplainActionResponse, error)
	// StartMySQLExplainJSONAction starts MySQL EXPLAIN Action with JSON output.
	StartMySQLExplainJSONAction(ctx context.Context, in *StartMySQLExplainJSONActionRequest, opts ...grpc.CallOption) (*StartMySQLExplainJSONActionResponse, error)
	// StartMySQLExplainTraditionalJSONAction starts MySQL EXPLAIN Action with traditional JSON output.
	StartMySQLExplainTraditionalJSONAction(ctx context.Context, in *StartMySQLExplainTraditionalJSONActionRequest, opts ...grpc.CallOption) (*StartMySQLExplainTraditionalJSONActionResponse, error)
	// StartMySQLShowCreateTableAction starts MySQL SHOW CREATE TABLE Action.
	StartMySQLShowCreateTableAction(ctx context.Context, in *StartMySQLShowCreateTableActionRequest, opts ...grpc.CallOption) (*StartMySQLShowCreateTableActionResponse, error)
	// StartMySQLShowTableStatusAction starts MySQL SHOW TABLE STATUS Action.
	StartMySQLShowTableStatusAction(ctx context.Context, in *StartMySQLShowTableStatusActionRequest, opts ...grpc.CallOption) (*StartMySQLShowTableStatusActionResponse, error)
	// StartMySQLShowIndexAction starts MySQL SHOW INDEX Action.
	StartMySQLShowIndexAction(ctx context.Context, in *StartMySQLShowIndexActionRequest, opts ...grpc.CallOption) (*StartMySQLShowIndexActionResponse, error)
	// StartPostgreSQLShowCreateTableAction starts PostgreSQL SHOW CREATE TABLE Action.
	StartPostgreSQLShowCreateTableAction(ctx context.Context, in *StartPostgreSQLShowCreateTableActionRequest, opts ...grpc.CallOption) (*StartPostgreSQLShowCreateTableActionResponse, error)
	// StartPostgreSQLShowIndexAction starts PostgreSQL SHOW INDEX Action.
	StartPostgreSQLShowIndexAction(ctx context.Context, in *StartPostgreSQLShowIndexActionRequest, opts ...grpc.CallOption) (*StartPostgreSQLShowIndexActionResponse, error)
	// StartMongoDBExplainAction starts MongoDB EXPLAIN Action.
	StartMongoDBExplainAction(ctx context.Context, in *StartMongoDBExplainActionRequest, opts ...grpc.CallOption) (*StartMongoDBExplainActionResponse, error)
	// StartPTSummaryAction starts pt-summary Action.
	StartPTSummaryAction(ctx context.Context, in *StartPTSummaryActionRequest, opts ...grpc.CallOption) (*StartPTSummaryActionResponse, error)
	// StartPTPgSummaryAction starts pt-pg-summary Action.
	StartPTPgSummaryAction(ctx context.Context, in *StartPTPgSummaryActionRequest, opts ...grpc.CallOption) (*StartPTPgSummaryActionResponse, error)
	// StartPTMongoDBSummaryAction starts pt-mongodb-summary Action.
	StartPTMongoDBSummaryAction(ctx context.Context, in *StartPTMongoDBSummaryActionRequest, opts ...grpc.CallOption) (*StartPTMongoDBSummaryActionResponse, error)
	// StartPTMySQLSummaryAction starts pt--mysql-summary Action.
	StartPTMySQLSummaryAction(ctx context.Context, in *StartPTMySQLSummaryActionRequest, opts ...grpc.CallOption) (*StartPTMySQLSummaryActionResponse, error)
	// CancelAction stops an Action.
	CancelAction(ctx context.Context, in *CancelActionRequest, opts ...grpc.CallOption) (*CancelActionResponse, error)
}

ActionsClient is the client API for Actions service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewActionsClient

func NewActionsClient(cc grpc.ClientConnInterface) ActionsClient

type ActionsServer

type ActionsServer interface {
	// GetAction gets an result of given Action.
	GetAction(context.Context, *GetActionRequest) (*GetActionResponse, error)
	// StartMySQLExplainAction starts MySQL EXPLAIN Action with traditional output.
	StartMySQLExplainAction(context.Context, *StartMySQLExplainActionRequest) (*StartMySQLExplainActionResponse, error)
	// StartMySQLExplainJSONAction starts MySQL EXPLAIN Action with JSON output.
	StartMySQLExplainJSONAction(context.Context, *StartMySQLExplainJSONActionRequest) (*StartMySQLExplainJSONActionResponse, error)
	// StartMySQLExplainTraditionalJSONAction starts MySQL EXPLAIN Action with traditional JSON output.
	StartMySQLExplainTraditionalJSONAction(context.Context, *StartMySQLExplainTraditionalJSONActionRequest) (*StartMySQLExplainTraditionalJSONActionResponse, error)
	// StartMySQLShowCreateTableAction starts MySQL SHOW CREATE TABLE Action.
	StartMySQLShowCreateTableAction(context.Context, *StartMySQLShowCreateTableActionRequest) (*StartMySQLShowCreateTableActionResponse, error)
	// StartMySQLShowTableStatusAction starts MySQL SHOW TABLE STATUS Action.
	StartMySQLShowTableStatusAction(context.Context, *StartMySQLShowTableStatusActionRequest) (*StartMySQLShowTableStatusActionResponse, error)
	// StartMySQLShowIndexAction starts MySQL SHOW INDEX Action.
	StartMySQLShowIndexAction(context.Context, *StartMySQLShowIndexActionRequest) (*StartMySQLShowIndexActionResponse, error)
	// StartPostgreSQLShowCreateTableAction starts PostgreSQL SHOW CREATE TABLE Action.
	StartPostgreSQLShowCreateTableAction(context.Context, *StartPostgreSQLShowCreateTableActionRequest) (*StartPostgreSQLShowCreateTableActionResponse, error)
	// StartPostgreSQLShowIndexAction starts PostgreSQL SHOW INDEX Action.
	StartPostgreSQLShowIndexAction(context.Context, *StartPostgreSQLShowIndexActionRequest) (*StartPostgreSQLShowIndexActionResponse, error)
	// StartMongoDBExplainAction starts MongoDB EXPLAIN Action.
	StartMongoDBExplainAction(context.Context, *StartMongoDBExplainActionRequest) (*StartMongoDBExplainActionResponse, error)
	// StartPTSummaryAction starts pt-summary Action.
	StartPTSummaryAction(context.Context, *StartPTSummaryActionRequest) (*StartPTSummaryActionResponse, error)
	// StartPTPgSummaryAction starts pt-pg-summary Action.
	StartPTPgSummaryAction(context.Context, *StartPTPgSummaryActionRequest) (*StartPTPgSummaryActionResponse, error)
	// StartPTMongoDBSummaryAction starts pt-mongodb-summary Action.
	StartPTMongoDBSummaryAction(context.Context, *StartPTMongoDBSummaryActionRequest) (*StartPTMongoDBSummaryActionResponse, error)
	// StartPTMySQLSummaryAction starts pt--mysql-summary Action.
	StartPTMySQLSummaryAction(context.Context, *StartPTMySQLSummaryActionRequest) (*StartPTMySQLSummaryActionResponse, error)
	// CancelAction stops an Action.
	CancelAction(context.Context, *CancelActionRequest) (*CancelActionResponse, error)
}

ActionsServer is the server API for Actions service.

type AddAnnotationRequest

type AddAnnotationRequest struct {

	// An annotation description. Required.
	Text string `protobuf:"bytes,1,opt,name=text,proto3" json:"text,omitempty"`
	// Tags are used to filter annotations.
	Tags []string `protobuf:"bytes,2,rep,name=tags,proto3" json:"tags,omitempty"`
	// Used for annotate node.
	NodeName string `protobuf:"bytes,3,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	// Used for annotate services.
	ServiceNames []string `protobuf:"bytes,4,rep,name=service_names,json=serviceNames,proto3" json:"service_names,omitempty"`
	// contains filtered or unexported fields
}

AddAnnotationRequest is a params to add new annotation.

func (*AddAnnotationRequest) Descriptor deprecated

This method has been deprecated.
func (*AddAnnotationRequest) Descriptor() ([]byte, []int)

Deprecated: Use AddAnnotationRequest.ProtoReflect.Descriptor instead.

func (*AddAnnotationRequest) GetNodeName

func (x *AddAnnotationRequest) GetNodeName() string

func (*AddAnnotationRequest) GetServiceNames

func (x *AddAnnotationRequest) GetServiceNames() []string

func (*AddAnnotationRequest) GetTags

func (x *AddAnnotationRequest) GetTags() []string

func (*AddAnnotationRequest) GetText

func (x *AddAnnotationRequest) GetText() string

func (*AddAnnotationRequest) ProtoMessage

func (*AddAnnotationRequest) ProtoMessage()

func (*AddAnnotationRequest) ProtoReflect

func (x *AddAnnotationRequest) ProtoReflect() protoreflect.Message

func (*AddAnnotationRequest) Reset

func (x *AddAnnotationRequest) Reset()

func (*AddAnnotationRequest) String

func (x *AddAnnotationRequest) String() string

func (*AddAnnotationRequest) Validate

func (this *AddAnnotationRequest) Validate() error

type AddAnnotationResponse

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

func (*AddAnnotationResponse) Descriptor deprecated

This method has been deprecated.
func (*AddAnnotationResponse) Descriptor() ([]byte, []int)

Deprecated: Use AddAnnotationResponse.ProtoReflect.Descriptor instead.

func (*AddAnnotationResponse) ProtoMessage

func (*AddAnnotationResponse) ProtoMessage()

func (*AddAnnotationResponse) ProtoReflect

func (x *AddAnnotationResponse) ProtoReflect() protoreflect.Message

func (*AddAnnotationResponse) Reset

func (x *AddAnnotationResponse) Reset()

func (*AddAnnotationResponse) String

func (x *AddAnnotationResponse) String() string

func (*AddAnnotationResponse) Validate

func (this *AddAnnotationResponse) Validate() error

type AddExternalRequest

type AddExternalRequest struct {

	// Node identifier on which an external exporter is been running.
	// runs_on_node_id always should be passed with node_id.
	// Exactly one of these parameters should be present: node_id, node_name, add_node.
	RunsOnNodeId string `protobuf:"bytes,1,opt,name=runs_on_node_id,json=runsOnNodeId,proto3" json:"runs_on_node_id,omitempty"`
	// Node name on which a service and node is been running.
	// Exactly one of these parameters should be present: node_id, node_name, add_node.
	NodeName string `protobuf:"bytes,18,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	// Create a new Node with those parameters.
	// add_node always should be passed with address.
	// Exactly one of these parameters should be present: node_id, node_name, add_node.
	AddNode *AddNodeParams `protobuf:"bytes,19,opt,name=add_node,json=addNode,proto3" json:"add_node,omitempty"`
	// Node and Exporter access address (DNS name or IP).
	// address always should be passed with add_node.
	Address string `protobuf:"bytes,20,opt,name=address,proto3" json:"address,omitempty"`
	// Unique across all Services user-defined name. Required.
	ServiceName string `protobuf:"bytes,2,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	// HTTP basic auth username for collecting metrics.
	Username string `protobuf:"bytes,3,opt,name=username,proto3" json:"username,omitempty"`
	// HTTP basic auth password for collecting metrics.
	Password string `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"`
	// Scheme to generate URI to exporter metrics endpoints.
	Scheme string `protobuf:"bytes,5,opt,name=scheme,proto3" json:"scheme,omitempty"`
	// Path under which metrics are exposed, used to generate URI.
	MetricsPath string `protobuf:"bytes,6,opt,name=metrics_path,json=metricsPath,proto3" json:"metrics_path,omitempty"`
	// Listen port for scraping metrics.
	ListenPort uint32 `protobuf:"varint,7,opt,name=listen_port,json=listenPort,proto3" json:"listen_port,omitempty"`
	// Node identifier on which an external service is been running.
	// node_id always should be passed with runs_on_node_id.
	NodeId string `protobuf:"bytes,8,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// Environment name.
	Environment string `protobuf:"bytes,9,opt,name=environment,proto3" json:"environment,omitempty"`
	// Cluster name.
	Cluster string `protobuf:"bytes,10,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// Replication set name.
	ReplicationSet string `protobuf:"bytes,11,opt,name=replication_set,json=replicationSet,proto3" json:"replication_set,omitempty"`
	// Custom user-assigned labels for Service.
	CustomLabels map[string]string `` /* 186-byte string literal not displayed */
	// Group name of external service.
	Group string `protobuf:"bytes,16,opt,name=group,proto3" json:"group,omitempty"`
	// Defines metrics flow model for this exporter.
	// Metrics could be pushed to the server with vmagent,
	// pulled by the server, or the server could choose behavior automatically.
	// Node with registered pmm_agent_id must present at pmm-server
	// in case of push metrics_mode.
	MetricsMode MetricsMode `protobuf:"varint,17,opt,name=metrics_mode,json=metricsMode,proto3,enum=management.MetricsMode" json:"metrics_mode,omitempty"`
	// Skip connection check.
	SkipConnectionCheck bool `protobuf:"varint,21,opt,name=skip_connection_check,json=skipConnectionCheck,proto3" json:"skip_connection_check,omitempty"`
	// contains filtered or unexported fields
}

func (*AddExternalRequest) Descriptor deprecated

This method has been deprecated.
func (*AddExternalRequest) Descriptor() ([]byte, []int)

Deprecated: Use AddExternalRequest.ProtoReflect.Descriptor instead.

func (*AddExternalRequest) GetAddNode

func (x *AddExternalRequest) GetAddNode() *AddNodeParams

func (*AddExternalRequest) GetAddress

func (x *AddExternalRequest) GetAddress() string

func (*AddExternalRequest) GetCluster

func (x *AddExternalRequest) GetCluster() string

func (*AddExternalRequest) GetCustomLabels

func (x *AddExternalRequest) GetCustomLabels() map[string]string

func (*AddExternalRequest) GetEnvironment

func (x *AddExternalRequest) GetEnvironment() string

func (*AddExternalRequest) GetGroup

func (x *AddExternalRequest) GetGroup() string

func (*AddExternalRequest) GetListenPort

func (x *AddExternalRequest) GetListenPort() uint32

func (*AddExternalRequest) GetMetricsMode

func (x *AddExternalRequest) GetMetricsMode() MetricsMode

func (*AddExternalRequest) GetMetricsPath

func (x *AddExternalRequest) GetMetricsPath() string

func (*AddExternalRequest) GetNodeId

func (x *AddExternalRequest) GetNodeId() string

func (*AddExternalRequest) GetNodeName

func (x *AddExternalRequest) GetNodeName() string

func (*AddExternalRequest) GetPassword

func (x *AddExternalRequest) GetPassword() string

func (*AddExternalRequest) GetReplicationSet

func (x *AddExternalRequest) GetReplicationSet() string

func (*AddExternalRequest) GetRunsOnNodeId

func (x *AddExternalRequest) GetRunsOnNodeId() string

func (*AddExternalRequest) GetScheme

func (x *AddExternalRequest) GetScheme() string

func (*AddExternalRequest) GetServiceName

func (x *AddExternalRequest) GetServiceName() string

func (*AddExternalRequest) GetSkipConnectionCheck

func (x *AddExternalRequest) GetSkipConnectionCheck() bool

func (*AddExternalRequest) GetUsername

func (x *AddExternalRequest) GetUsername() string

func (*AddExternalRequest) ProtoMessage

func (*AddExternalRequest) ProtoMessage()

func (*AddExternalRequest) ProtoReflect

func (x *AddExternalRequest) ProtoReflect() protoreflect.Message

func (*AddExternalRequest) Reset

func (x *AddExternalRequest) Reset()

func (*AddExternalRequest) String

func (x *AddExternalRequest) String() string

func (*AddExternalRequest) Validate

func (this *AddExternalRequest) Validate() error

type AddExternalResponse

type AddExternalResponse struct {
	Service          *inventorypb.ExternalService  `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	ExternalExporter *inventorypb.ExternalExporter `protobuf:"bytes,2,opt,name=external_exporter,json=externalExporter,proto3" json:"external_exporter,omitempty"`
	// contains filtered or unexported fields
}

func (*AddExternalResponse) Descriptor deprecated

This method has been deprecated.
func (*AddExternalResponse) Descriptor() ([]byte, []int)

Deprecated: Use AddExternalResponse.ProtoReflect.Descriptor instead.

func (*AddExternalResponse) GetExternalExporter

func (x *AddExternalResponse) GetExternalExporter() *inventorypb.ExternalExporter

func (*AddExternalResponse) GetService

func (*AddExternalResponse) ProtoMessage

func (*AddExternalResponse) ProtoMessage()

func (*AddExternalResponse) ProtoReflect

func (x *AddExternalResponse) ProtoReflect() protoreflect.Message

func (*AddExternalResponse) Reset

func (x *AddExternalResponse) Reset()

func (*AddExternalResponse) String

func (x *AddExternalResponse) String() string

func (*AddExternalResponse) Validate

func (this *AddExternalResponse) Validate() error

type AddHAProxyRequest

type AddHAProxyRequest struct {

	// Node identifier on which an external exporter is been running.
	// Exactly one of these parameters should be present: node_id, node_name, add_node.
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// Node name on which a service and node is been running.
	// Exactly one of these parameters should be present: node_id, node_name, add_node.
	NodeName string `protobuf:"bytes,18,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	// Create a new Node with those parameters.
	// add_node always should be passed with address.
	// Exactly one of these parameters should be present: node_id, node_name, add_node.
	AddNode *AddNodeParams `protobuf:"bytes,19,opt,name=add_node,json=addNode,proto3" json:"add_node,omitempty"`
	// Node and Exporter access address (DNS name or IP).
	// address always should be passed with add_node.
	Address string `protobuf:"bytes,20,opt,name=address,proto3" json:"address,omitempty"`
	// Unique across all Services user-defined name. Required.
	ServiceName string `protobuf:"bytes,2,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	// HTTP basic auth username for collecting metrics.
	Username string `protobuf:"bytes,3,opt,name=username,proto3" json:"username,omitempty"`
	// HTTP basic auth password for collecting metrics.
	Password string `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"`
	// Scheme to generate URI to exporter metrics endpoints.
	Scheme string `protobuf:"bytes,5,opt,name=scheme,proto3" json:"scheme,omitempty"`
	// Path under which metrics are exposed, used to generate URI.
	MetricsPath string `protobuf:"bytes,6,opt,name=metrics_path,json=metricsPath,proto3" json:"metrics_path,omitempty"`
	// Listen port for scraping metrics.
	ListenPort uint32 `protobuf:"varint,7,opt,name=listen_port,json=listenPort,proto3" json:"listen_port,omitempty"`
	// Environment name.
	Environment string `protobuf:"bytes,9,opt,name=environment,proto3" json:"environment,omitempty"`
	// Cluster name.
	Cluster string `protobuf:"bytes,10,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// Replication set name.
	ReplicationSet string `protobuf:"bytes,11,opt,name=replication_set,json=replicationSet,proto3" json:"replication_set,omitempty"`
	// Custom user-assigned labels for Service.
	CustomLabels map[string]string `` /* 186-byte string literal not displayed */
	// Defines metrics flow model for this exporter.
	// Metrics could be pushed to the server with vmagent,
	// pulled by the server, or the server could choose behavior automatically.
	// Node with registered pmm_agent_id must present at pmm-server
	// in case of push metrics_mode.
	MetricsMode MetricsMode `protobuf:"varint,16,opt,name=metrics_mode,json=metricsMode,proto3,enum=management.MetricsMode" json:"metrics_mode,omitempty"`
	// Skip connection check.
	SkipConnectionCheck bool `protobuf:"varint,21,opt,name=skip_connection_check,json=skipConnectionCheck,proto3" json:"skip_connection_check,omitempty"`
	// contains filtered or unexported fields
}

func (*AddHAProxyRequest) Descriptor deprecated

This method has been deprecated.
func (*AddHAProxyRequest) Descriptor() ([]byte, []int)

Deprecated: Use AddHAProxyRequest.ProtoReflect.Descriptor instead.

func (*AddHAProxyRequest) GetAddNode

func (x *AddHAProxyRequest) GetAddNode() *AddNodeParams

func (*AddHAProxyRequest) GetAddress

func (x *AddHAProxyRequest) GetAddress() string

func (*AddHAProxyRequest) GetCluster

func (x *AddHAProxyRequest) GetCluster() string

func (*AddHAProxyRequest) GetCustomLabels

func (x *AddHAProxyRequest) GetCustomLabels() map[string]string

func (*AddHAProxyRequest) GetEnvironment

func (x *AddHAProxyRequest) GetEnvironment() string

func (*AddHAProxyRequest) GetListenPort

func (x *AddHAProxyRequest) GetListenPort() uint32

func (*AddHAProxyRequest) GetMetricsMode

func (x *AddHAProxyRequest) GetMetricsMode() MetricsMode

func (*AddHAProxyRequest) GetMetricsPath

func (x *AddHAProxyRequest) GetMetricsPath() string

func (*AddHAProxyRequest) GetNodeId

func (x *AddHAProxyRequest) GetNodeId() string

func (*AddHAProxyRequest) GetNodeName

func (x *AddHAProxyRequest) GetNodeName() string

func (*AddHAProxyRequest) GetPassword

func (x *AddHAProxyRequest) GetPassword() string

func (*AddHAProxyRequest) GetReplicationSet

func (x *AddHAProxyRequest) GetReplicationSet() string

func (*AddHAProxyRequest) GetScheme

func (x *AddHAProxyRequest) GetScheme() string

func (*AddHAProxyRequest) GetServiceName

func (x *AddHAProxyRequest) GetServiceName() string

func (*AddHAProxyRequest) GetSkipConnectionCheck

func (x *AddHAProxyRequest) GetSkipConnectionCheck() bool

func (*AddHAProxyRequest) GetUsername

func (x *AddHAProxyRequest) GetUsername() string

func (*AddHAProxyRequest) ProtoMessage

func (*AddHAProxyRequest) ProtoMessage()

func (*AddHAProxyRequest) ProtoReflect

func (x *AddHAProxyRequest) ProtoReflect() protoreflect.Message

func (*AddHAProxyRequest) Reset

func (x *AddHAProxyRequest) Reset()

func (*AddHAProxyRequest) String

func (x *AddHAProxyRequest) String() string

func (*AddHAProxyRequest) Validate

func (this *AddHAProxyRequest) Validate() error

type AddHAProxyResponse

type AddHAProxyResponse struct {
	Service          *inventorypb.HAProxyService   `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	ExternalExporter *inventorypb.ExternalExporter `protobuf:"bytes,2,opt,name=external_exporter,json=externalExporter,proto3" json:"external_exporter,omitempty"`
	// contains filtered or unexported fields
}

func (*AddHAProxyResponse) Descriptor deprecated

This method has been deprecated.
func (*AddHAProxyResponse) Descriptor() ([]byte, []int)

Deprecated: Use AddHAProxyResponse.ProtoReflect.Descriptor instead.

func (*AddHAProxyResponse) GetExternalExporter

func (x *AddHAProxyResponse) GetExternalExporter() *inventorypb.ExternalExporter

func (*AddHAProxyResponse) GetService

func (*AddHAProxyResponse) ProtoMessage

func (*AddHAProxyResponse) ProtoMessage()

func (*AddHAProxyResponse) ProtoReflect

func (x *AddHAProxyResponse) ProtoReflect() protoreflect.Message

func (*AddHAProxyResponse) Reset

func (x *AddHAProxyResponse) Reset()

func (*AddHAProxyResponse) String

func (x *AddHAProxyResponse) String() string

func (*AddHAProxyResponse) Validate

func (this *AddHAProxyResponse) Validate() error

type AddMongoDBRequest

type AddMongoDBRequest struct {

	// Node identifier on which a service is been running.
	// Exactly one of these parameters should be present: node_id, node_name, add_node.
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// Node name on which a service is been running.
	// Exactly one of these parameters should be present: node_id, node_name, add_node.
	NodeName string `protobuf:"bytes,2,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	// Create a new Node with those parameters.
	// Exactly one of these parameters should be present: node_id, node_name, add_node.
	AddNode *AddNodeParams `protobuf:"bytes,3,opt,name=add_node,json=addNode,proto3" json:"add_node,omitempty"`
	// Unique across all Services user-defined name. Required.
	ServiceName string `protobuf:"bytes,4,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	// Node and Service access address (DNS name or IP).
	// Address (and port) or socket is required.
	Address string `protobuf:"bytes,5,opt,name=address,proto3" json:"address,omitempty"`
	// Service Access port.
	// Port is required when the address present.
	Port uint32 `protobuf:"varint,6,opt,name=port,proto3" json:"port,omitempty"`
	// Service Access socket.
	// Address (and port) or socket is required.
	Socket string `protobuf:"bytes,19,opt,name=socket,proto3" json:"socket,omitempty"`
	// The "pmm-agent" identifier which should run agents. Required.
	PmmAgentId string `protobuf:"bytes,7,opt,name=pmm_agent_id,json=pmmAgentId,proto3" json:"pmm_agent_id,omitempty"`
	// Environment name.
	Environment string `protobuf:"bytes,8,opt,name=environment,proto3" json:"environment,omitempty"`
	// Cluster name.
	Cluster string `protobuf:"bytes,9,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// Replication set name.
	ReplicationSet string `protobuf:"bytes,10,opt,name=replication_set,json=replicationSet,proto3" json:"replication_set,omitempty"`
	// MongoDB username for exporter and QAN agent access.
	Username string `protobuf:"bytes,11,opt,name=username,proto3" json:"username,omitempty"`
	// MongoDB password for exporter and QAN agent access.
	Password string `protobuf:"bytes,12,opt,name=password,proto3" json:"password,omitempty"`
	// If true, adds qan-mongodb-profiler-agent for provided service.
	QanMongodbProfiler bool `protobuf:"varint,13,opt,name=qan_mongodb_profiler,json=qanMongodbProfiler,proto3" json:"qan_mongodb_profiler,omitempty"`
	// Custom user-assigned labels for Service.
	CustomLabels map[string]string `` /* 186-byte string literal not displayed */
	// Skip connection check.
	SkipConnectionCheck bool `protobuf:"varint,15,opt,name=skip_connection_check,json=skipConnectionCheck,proto3" json:"skip_connection_check,omitempty"`
	// Use TLS for database connections.
	Tls bool `protobuf:"varint,17,opt,name=tls,proto3" json:"tls,omitempty"`
	// Skip TLS certificate and hostname validation.
	TlsSkipVerify bool `protobuf:"varint,18,opt,name=tls_skip_verify,json=tlsSkipVerify,proto3" json:"tls_skip_verify,omitempty"`
	// Client certificate and key.
	TlsCertificateKey string `protobuf:"bytes,21,opt,name=tls_certificate_key,json=tlsCertificateKey,proto3" json:"tls_certificate_key,omitempty"`
	// Password for decrypting tls_certificate_key.
	TlsCertificateKeyFilePassword string `` /* 155-byte string literal not displayed */
	// Certificate Authority certificate chain.
	TlsCa string `protobuf:"bytes,23,opt,name=tls_ca,json=tlsCa,proto3" json:"tls_ca,omitempty"`
	// Defines metrics flow model for this exporter.
	// Metrics could be pushed to the server with vmagent,
	// pulled by the server, or the server could choose behavior automatically.
	MetricsMode MetricsMode `protobuf:"varint,20,opt,name=metrics_mode,json=metricsMode,proto3,enum=management.MetricsMode" json:"metrics_mode,omitempty"`
	// List of collector names to disable in this exporter.
	DisableCollectors []string `protobuf:"bytes,24,rep,name=disable_collectors,json=disableCollectors,proto3" json:"disable_collectors,omitempty"`
	// contains filtered or unexported fields
}

func (*AddMongoDBRequest) Descriptor deprecated

This method has been deprecated.
func (*AddMongoDBRequest) Descriptor() ([]byte, []int)

Deprecated: Use AddMongoDBRequest.ProtoReflect.Descriptor instead.

func (*AddMongoDBRequest) GetAddNode

func (x *AddMongoDBRequest) GetAddNode() *AddNodeParams

func (*AddMongoDBRequest) GetAddress

func (x *AddMongoDBRequest) GetAddress() string

func (*AddMongoDBRequest) GetCluster

func (x *AddMongoDBRequest) GetCluster() string

func (*AddMongoDBRequest) GetCustomLabels

func (x *AddMongoDBRequest) GetCustomLabels() map[string]string

func (*AddMongoDBRequest) GetDisableCollectors

func (x *AddMongoDBRequest) GetDisableCollectors() []string

func (*AddMongoDBRequest) GetEnvironment

func (x *AddMongoDBRequest) GetEnvironment() string

func (*AddMongoDBRequest) GetMetricsMode

func (x *AddMongoDBRequest) GetMetricsMode() MetricsMode

func (*AddMongoDBRequest) GetNodeId

func (x *AddMongoDBRequest) GetNodeId() string

func (*AddMongoDBRequest) GetNodeName

func (x *AddMongoDBRequest) GetNodeName() string

func (*AddMongoDBRequest) GetPassword

func (x *AddMongoDBRequest) GetPassword() string

func (*AddMongoDBRequest) GetPmmAgentId

func (x *AddMongoDBRequest) GetPmmAgentId() string

func (*AddMongoDBRequest) GetPort

func (x *AddMongoDBRequest) GetPort() uint32

func (*AddMongoDBRequest) GetQanMongodbProfiler

func (x *AddMongoDBRequest) GetQanMongodbProfiler() bool

func (*AddMongoDBRequest) GetReplicationSet

func (x *AddMongoDBRequest) GetReplicationSet() string

func (*AddMongoDBRequest) GetServiceName

func (x *AddMongoDBRequest) GetServiceName() string

func (*AddMongoDBRequest) GetSkipConnectionCheck

func (x *AddMongoDBRequest) GetSkipConnectionCheck() bool

func (*AddMongoDBRequest) GetSocket

func (x *AddMongoDBRequest) GetSocket() string

func (*AddMongoDBRequest) GetTls

func (x *AddMongoDBRequest) GetTls() bool

func (*AddMongoDBRequest) GetTlsCa

func (x *AddMongoDBRequest) GetTlsCa() string

func (*AddMongoDBRequest) GetTlsCertificateKey

func (x *AddMongoDBRequest) GetTlsCertificateKey() string

func (*AddMongoDBRequest) GetTlsCertificateKeyFilePassword

func (x *AddMongoDBRequest) GetTlsCertificateKeyFilePassword() string

func (*AddMongoDBRequest) GetTlsSkipVerify

func (x *AddMongoDBRequest) GetTlsSkipVerify() bool

func (*AddMongoDBRequest) GetUsername

func (x *AddMongoDBRequest) GetUsername() string

func (*AddMongoDBRequest) ProtoMessage

func (*AddMongoDBRequest) ProtoMessage()

func (*AddMongoDBRequest) ProtoReflect

func (x *AddMongoDBRequest) ProtoReflect() protoreflect.Message

func (*AddMongoDBRequest) Reset

func (x *AddMongoDBRequest) Reset()

func (*AddMongoDBRequest) String

func (x *AddMongoDBRequest) String() string

func (*AddMongoDBRequest) Validate

func (this *AddMongoDBRequest) Validate() error

type AddMongoDBResponse

type AddMongoDBResponse struct {
	Service            *inventorypb.MongoDBService          `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	MongodbExporter    *inventorypb.MongoDBExporter         `protobuf:"bytes,2,opt,name=mongodb_exporter,json=mongodbExporter,proto3" json:"mongodb_exporter,omitempty"`
	QanMongodbProfiler *inventorypb.QANMongoDBProfilerAgent `protobuf:"bytes,3,opt,name=qan_mongodb_profiler,json=qanMongodbProfiler,proto3" json:"qan_mongodb_profiler,omitempty"`
	// contains filtered or unexported fields
}

func (*AddMongoDBResponse) Descriptor deprecated

This method has been deprecated.
func (*AddMongoDBResponse) Descriptor() ([]byte, []int)

Deprecated: Use AddMongoDBResponse.ProtoReflect.Descriptor instead.

func (*AddMongoDBResponse) GetMongodbExporter

func (x *AddMongoDBResponse) GetMongodbExporter() *inventorypb.MongoDBExporter

func (*AddMongoDBResponse) GetQanMongodbProfiler

func (x *AddMongoDBResponse) GetQanMongodbProfiler() *inventorypb.QANMongoDBProfilerAgent

func (*AddMongoDBResponse) GetService

func (*AddMongoDBResponse) ProtoMessage

func (*AddMongoDBResponse) ProtoMessage()

func (*AddMongoDBResponse) ProtoReflect

func (x *AddMongoDBResponse) ProtoReflect() protoreflect.Message

func (*AddMongoDBResponse) Reset

func (x *AddMongoDBResponse) Reset()

func (*AddMongoDBResponse) String

func (x *AddMongoDBResponse) String() string

func (*AddMongoDBResponse) Validate

func (this *AddMongoDBResponse) Validate() error

type AddMySQLRequest

type AddMySQLRequest struct {

	// Node identifier on which a service is been running.
	// Exactly one of these parameters should be present: node_id, node_name, add_node.
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// Node name on which a service is been running.
	// Exactly one of these parameters should be present: node_id, node_name, add_node.
	NodeName string `protobuf:"bytes,2,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	// Create a new Node with those parameters.
	// Exactly one of these parameters should be present: node_id, node_name, add_node.
	AddNode *AddNodeParams `protobuf:"bytes,3,opt,name=add_node,json=addNode,proto3" json:"add_node,omitempty"`
	// Unique across all Services user-defined name. Required.
	ServiceName string `protobuf:"bytes,4,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	// Node and Service access address (DNS name or IP).
	// Address (and port) or socket is required.
	Address string `protobuf:"bytes,5,opt,name=address,proto3" json:"address,omitempty"`
	// Service Access port.
	// Port is required when the address present.
	Port uint32 `protobuf:"varint,6,opt,name=port,proto3" json:"port,omitempty"`
	// Service Access socket.
	// Address (and port) or socket is required.
	Socket string `protobuf:"bytes,22,opt,name=socket,proto3" json:"socket,omitempty"`
	// The "pmm-agent" identifier which should run agents. Required.
	PmmAgentId string `protobuf:"bytes,7,opt,name=pmm_agent_id,json=pmmAgentId,proto3" json:"pmm_agent_id,omitempty"`
	// Environment name.
	Environment string `protobuf:"bytes,8,opt,name=environment,proto3" json:"environment,omitempty"`
	// Cluster name.
	Cluster string `protobuf:"bytes,9,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// Replication set name.
	ReplicationSet string `protobuf:"bytes,10,opt,name=replication_set,json=replicationSet,proto3" json:"replication_set,omitempty"`
	// MySQL username for scraping metrics.
	Username string `protobuf:"bytes,11,opt,name=username,proto3" json:"username,omitempty"`
	// MySQL password for scraping metrics.
	Password string `protobuf:"bytes,12,opt,name=password,proto3" json:"password,omitempty"`
	// If true, adds qan-mysql-perfschema-agent for provided service.
	QanMysqlPerfschema bool `protobuf:"varint,13,opt,name=qan_mysql_perfschema,json=qanMysqlPerfschema,proto3" json:"qan_mysql_perfschema,omitempty"`
	// If true, adds qan-mysql-slowlog-agent for provided service.
	QanMysqlSlowlog bool `protobuf:"varint,14,opt,name=qan_mysql_slowlog,json=qanMysqlSlowlog,proto3" json:"qan_mysql_slowlog,omitempty"`
	// Custom user-assigned labels for Service.
	CustomLabels map[string]string `` /* 186-byte string literal not displayed */
	// Skip connection check.
	SkipConnectionCheck bool `protobuf:"varint,16,opt,name=skip_connection_check,json=skipConnectionCheck,proto3" json:"skip_connection_check,omitempty"`
	// Disable query examples.
	DisableQueryExamples bool `protobuf:"varint,17,opt,name=disable_query_examples,json=disableQueryExamples,proto3" json:"disable_query_examples,omitempty"`
	// If qan-mysql-slowlog-agent is added, slowlog file is rotated at this size if > 0.
	// If zero, server's default value is used.
	// Use negative value to disable rotation.
	MaxSlowlogFileSize int64 `protobuf:"varint,18,opt,name=max_slowlog_file_size,json=maxSlowlogFileSize,proto3" json:"max_slowlog_file_size,omitempty"`
	// Use TLS for database connections.
	Tls bool `protobuf:"varint,19,opt,name=tls,proto3" json:"tls,omitempty"`
	// Skip TLS certificate and hostname validation.
	TlsSkipVerify bool `protobuf:"varint,20,opt,name=tls_skip_verify,json=tlsSkipVerify,proto3" json:"tls_skip_verify,omitempty"`
	// Certificate Authority certificate chain.
	TlsCa string `protobuf:"bytes,25,opt,name=tls_ca,json=tlsCa,proto3" json:"tls_ca,omitempty"`
	// Client certificate.
	TlsCert string `protobuf:"bytes,26,opt,name=tls_cert,json=tlsCert,proto3" json:"tls_cert,omitempty"`
	// Password for decrypting tls_cert.
	TlsKey string `protobuf:"bytes,27,opt,name=tls_key,json=tlsKey,proto3" json:"tls_key,omitempty"`
	// Tablestats group collectors will be disabled if there are more than that number of tables.
	// If zero, server's default value is used.
	// Use negative value to disable them.
	TablestatsGroupTableLimit int32 `` /* 142-byte string literal not displayed */
	// Defines metrics flow model for this exporter.
	// Metrics could be pushed to the server with vmagent,
	// pulled by the server, or the server could choose behavior automatically.
	MetricsMode MetricsMode `protobuf:"varint,23,opt,name=metrics_mode,json=metricsMode,proto3,enum=management.MetricsMode" json:"metrics_mode,omitempty"`
	// List of collector names to disable in this exporter.
	DisableCollectors []string `protobuf:"bytes,24,rep,name=disable_collectors,json=disableCollectors,proto3" json:"disable_collectors,omitempty"`
	// contains filtered or unexported fields
}

func (*AddMySQLRequest) Descriptor deprecated

This method has been deprecated.
func (*AddMySQLRequest) Descriptor() ([]byte, []int)

Deprecated: Use AddMySQLRequest.ProtoReflect.Descriptor instead.

func (*AddMySQLRequest) GetAddNode

func (x *AddMySQLRequest) GetAddNode() *AddNodeParams

func (*AddMySQLRequest) GetAddress

func (x *AddMySQLRequest) GetAddress() string

func (*AddMySQLRequest) GetCluster

func (x *AddMySQLRequest) GetCluster() string

func (*AddMySQLRequest) GetCustomLabels

func (x *AddMySQLRequest) GetCustomLabels() map[string]string

func (*AddMySQLRequest) GetDisableCollectors

func (x *AddMySQLRequest) GetDisableCollectors() []string

func (*AddMySQLRequest) GetDisableQueryExamples

func (x *AddMySQLRequest) GetDisableQueryExamples() bool

func (*AddMySQLRequest) GetEnvironment

func (x *AddMySQLRequest) GetEnvironment() string

func (*AddMySQLRequest) GetMaxSlowlogFileSize

func (x *AddMySQLRequest) GetMaxSlowlogFileSize() int64

func (*AddMySQLRequest) GetMetricsMode

func (x *AddMySQLRequest) GetMetricsMode() MetricsMode

func (*AddMySQLRequest) GetNodeId

func (x *AddMySQLRequest) GetNodeId() string

func (*AddMySQLRequest) GetNodeName

func (x *AddMySQLRequest) GetNodeName() string

func (*AddMySQLRequest) GetPassword

func (x *AddMySQLRequest) GetPassword() string

func (*AddMySQLRequest) GetPmmAgentId

func (x *AddMySQLRequest) GetPmmAgentId() string

func (*AddMySQLRequest) GetPort

func (x *AddMySQLRequest) GetPort() uint32

func (*AddMySQLRequest) GetQanMysqlPerfschema

func (x *AddMySQLRequest) GetQanMysqlPerfschema() bool

func (*AddMySQLRequest) GetQanMysqlSlowlog

func (x *AddMySQLRequest) GetQanMysqlSlowlog() bool

func (*AddMySQLRequest) GetReplicationSet

func (x *AddMySQLRequest) GetReplicationSet() string

func (*AddMySQLRequest) GetServiceName

func (x *AddMySQLRequest) GetServiceName() string

func (*AddMySQLRequest) GetSkipConnectionCheck

func (x *AddMySQLRequest) GetSkipConnectionCheck() bool

func (*AddMySQLRequest) GetSocket

func (x *AddMySQLRequest) GetSocket() string

func (*AddMySQLRequest) GetTablestatsGroupTableLimit

func (x *AddMySQLRequest) GetTablestatsGroupTableLimit() int32

func (*AddMySQLRequest) GetTls

func (x *AddMySQLRequest) GetTls() bool

func (*AddMySQLRequest) GetTlsCa

func (x *AddMySQLRequest) GetTlsCa() string

func (*AddMySQLRequest) GetTlsCert

func (x *AddMySQLRequest) GetTlsCert() string

func (*AddMySQLRequest) GetTlsKey

func (x *AddMySQLRequest) GetTlsKey() string

func (*AddMySQLRequest) GetTlsSkipVerify

func (x *AddMySQLRequest) GetTlsSkipVerify() bool

func (*AddMySQLRequest) GetUsername

func (x *AddMySQLRequest) GetUsername() string

func (*AddMySQLRequest) ProtoMessage

func (*AddMySQLRequest) ProtoMessage()

func (*AddMySQLRequest) ProtoReflect

func (x *AddMySQLRequest) ProtoReflect() protoreflect.Message

func (*AddMySQLRequest) Reset

func (x *AddMySQLRequest) Reset()

func (*AddMySQLRequest) String

func (x *AddMySQLRequest) String() string

func (*AddMySQLRequest) Validate

func (this *AddMySQLRequest) Validate() error

type AddMySQLResponse

type AddMySQLResponse struct {
	Service            *inventorypb.MySQLService            `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	MysqldExporter     *inventorypb.MySQLdExporter          `protobuf:"bytes,2,opt,name=mysqld_exporter,json=mysqldExporter,proto3" json:"mysqld_exporter,omitempty"`
	QanMysqlPerfschema *inventorypb.QANMySQLPerfSchemaAgent `protobuf:"bytes,3,opt,name=qan_mysql_perfschema,json=qanMysqlPerfschema,proto3" json:"qan_mysql_perfschema,omitempty"`
	QanMysqlSlowlog    *inventorypb.QANMySQLSlowlogAgent    `protobuf:"bytes,4,opt,name=qan_mysql_slowlog,json=qanMysqlSlowlog,proto3" json:"qan_mysql_slowlog,omitempty"`
	// Actual table count at the moment of adding.
	TableCount int32 `protobuf:"varint,5,opt,name=table_count,json=tableCount,proto3" json:"table_count,omitempty"`
	// contains filtered or unexported fields
}

func (*AddMySQLResponse) Descriptor deprecated

This method has been deprecated.
func (*AddMySQLResponse) Descriptor() ([]byte, []int)

Deprecated: Use AddMySQLResponse.ProtoReflect.Descriptor instead.

func (*AddMySQLResponse) GetMysqldExporter

func (x *AddMySQLResponse) GetMysqldExporter() *inventorypb.MySQLdExporter

func (*AddMySQLResponse) GetQanMysqlPerfschema

func (x *AddMySQLResponse) GetQanMysqlPerfschema() *inventorypb.QANMySQLPerfSchemaAgent

func (*AddMySQLResponse) GetQanMysqlSlowlog

func (x *AddMySQLResponse) GetQanMysqlSlowlog() *inventorypb.QANMySQLSlowlogAgent

func (*AddMySQLResponse) GetService

func (x *AddMySQLResponse) GetService() *inventorypb.MySQLService

func (*AddMySQLResponse) GetTableCount

func (x *AddMySQLResponse) GetTableCount() int32

func (*AddMySQLResponse) ProtoMessage

func (*AddMySQLResponse) ProtoMessage()

func (*AddMySQLResponse) ProtoReflect

func (x *AddMySQLResponse) ProtoReflect() protoreflect.Message

func (*AddMySQLResponse) Reset

func (x *AddMySQLResponse) Reset()

func (*AddMySQLResponse) String

func (x *AddMySQLResponse) String() string

func (*AddMySQLResponse) Validate

func (this *AddMySQLResponse) Validate() error

type AddNodeParams

type AddNodeParams struct {

	// Node type to be registered.
	NodeType inventorypb.NodeType `protobuf:"varint,1,opt,name=node_type,json=nodeType,proto3,enum=inventory.NodeType" json:"node_type,omitempty"`
	// Unique across all Nodes user-defined name.
	NodeName string `protobuf:"bytes,2,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	// Linux machine-id.
	MachineId string `protobuf:"bytes,3,opt,name=machine_id,json=machineId,proto3" json:"machine_id,omitempty"`
	// Linux distribution name and version.
	Distro string `protobuf:"bytes,4,opt,name=distro,proto3" json:"distro,omitempty"`
	// Container identifier. If specified, must be a unique Docker container identifier.
	ContainerId string `protobuf:"bytes,5,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	// Container name.
	ContainerName string `protobuf:"bytes,6,opt,name=container_name,json=containerName,proto3" json:"container_name,omitempty"`
	// Node model.
	NodeModel string `protobuf:"bytes,7,opt,name=node_model,json=nodeModel,proto3" json:"node_model,omitempty"`
	// Node region.
	Region string `protobuf:"bytes,8,opt,name=region,proto3" json:"region,omitempty"`
	// Node availability zone.
	Az string `protobuf:"bytes,9,opt,name=az,proto3" json:"az,omitempty"`
	// Custom user-assigned labels for Node.
	CustomLabels map[string]string `` /* 186-byte string literal not displayed */
	// contains filtered or unexported fields
}

AddNodeParams is a params to add new node to inventory while adding new service.

func (*AddNodeParams) Descriptor deprecated

This method has been deprecated.
func (*AddNodeParams) Descriptor() ([]byte, []int)

Deprecated: Use AddNodeParams.ProtoReflect.Descriptor instead.

func (*AddNodeParams) GetAz

func (x *AddNodeParams) GetAz() string

func (*AddNodeParams) GetContainerId

func (x *AddNodeParams) GetContainerId() string

func (*AddNodeParams) GetContainerName

func (x *AddNodeParams) GetContainerName() string

func (*AddNodeParams) GetCustomLabels

func (x *AddNodeParams) GetCustomLabels() map[string]string

func (*AddNodeParams) GetDistro

func (x *AddNodeParams) GetDistro() string

func (*AddNodeParams) GetMachineId

func (x *AddNodeParams) GetMachineId() string

func (*AddNodeParams) GetNodeModel

func (x *AddNodeParams) GetNodeModel() string

func (*AddNodeParams) GetNodeName

func (x *AddNodeParams) GetNodeName() string

func (*AddNodeParams) GetNodeType

func (x *AddNodeParams) GetNodeType() inventorypb.NodeType

func (*AddNodeParams) GetRegion

func (x *AddNodeParams) GetRegion() string

func (*AddNodeParams) ProtoMessage

func (*AddNodeParams) ProtoMessage()

func (*AddNodeParams) ProtoReflect

func (x *AddNodeParams) ProtoReflect() protoreflect.Message

func (*AddNodeParams) Reset

func (x *AddNodeParams) Reset()

func (*AddNodeParams) String

func (x *AddNodeParams) String() string

func (*AddNodeParams) Validate

func (this *AddNodeParams) Validate() error

type AddPostgreSQLRequest

type AddPostgreSQLRequest struct {

	// Node identifier on which a service is been running.
	// Exactly one of these parameters should be present: node_id, node_name, add_node.
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// Node name on which a service is been running.
	// Exactly one of these parameters should be present: node_id, node_name, add_node.
	NodeName string `protobuf:"bytes,2,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	// Create a new Node with those parameters.
	// Exactly one of these parameters should be present: node_id, node_name, add_node.
	AddNode *AddNodeParams `protobuf:"bytes,3,opt,name=add_node,json=addNode,proto3" json:"add_node,omitempty"`
	// Unique across all Services user-defined name. Required.
	ServiceName string `protobuf:"bytes,4,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	// Node and Service access address (DNS name or IP).
	// Address (and port) or socket is required.
	Address string `protobuf:"bytes,5,opt,name=address,proto3" json:"address,omitempty"`
	// Service Access port.
	// Port is required when the address present.
	Port uint32 `protobuf:"varint,6,opt,name=port,proto3" json:"port,omitempty"`
	// Service Access socket.
	// Address (and port) or socket is required.
	Socket string `protobuf:"bytes,18,opt,name=socket,proto3" json:"socket,omitempty"`
	// The "pmm-agent" identifier which should run agents. Required.
	PmmAgentId string `protobuf:"bytes,7,opt,name=pmm_agent_id,json=pmmAgentId,proto3" json:"pmm_agent_id,omitempty"`
	// Environment name.
	Environment string `protobuf:"bytes,8,opt,name=environment,proto3" json:"environment,omitempty"`
	// Cluster name.
	Cluster string `protobuf:"bytes,9,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// Replication set name.
	ReplicationSet string `protobuf:"bytes,10,opt,name=replication_set,json=replicationSet,proto3" json:"replication_set,omitempty"`
	// PostgreSQL username for scraping metrics.
	Username string `protobuf:"bytes,11,opt,name=username,proto3" json:"username,omitempty"`
	// PostgreSQL password for scraping metrics.
	Password string `protobuf:"bytes,12,opt,name=password,proto3" json:"password,omitempty"`
	// If true, adds qan-postgresql-pgstatements-agent for provided service.
	QanPostgresqlPgstatementsAgent bool `` /* 157-byte string literal not displayed */
	// If true, adds qan-postgresql-pgstatmonitor-agent for provided service.
	QanPostgresqlPgstatmonitorAgent bool `` /* 160-byte string literal not displayed */
	// Disable query examples.
	DisableQueryExamples bool `protobuf:"varint,20,opt,name=disable_query_examples,json=disableQueryExamples,proto3" json:"disable_query_examples,omitempty"`
	// Custom user-assigned labels for Service.
	CustomLabels map[string]string `` /* 186-byte string literal not displayed */
	// Skip connection check.
	SkipConnectionCheck bool `protobuf:"varint,15,opt,name=skip_connection_check,json=skipConnectionCheck,proto3" json:"skip_connection_check,omitempty"`
	// Use TLS for database connections.
	Tls bool `protobuf:"varint,16,opt,name=tls,proto3" json:"tls,omitempty"`
	// Skip TLS certificate and hostname validation. Uses sslmode=required instead of verify-full.
	TlsSkipVerify bool `protobuf:"varint,17,opt,name=tls_skip_verify,json=tlsSkipVerify,proto3" json:"tls_skip_verify,omitempty"`
	// Defines metrics flow model for this exporter.
	// Metrics could be pushed to the server with vmagent,
	// pulled by the server, or the server could choose behavior automatically.
	MetricsMode MetricsMode `protobuf:"varint,21,opt,name=metrics_mode,json=metricsMode,proto3,enum=management.MetricsMode" json:"metrics_mode,omitempty"`
	// List of collector names to disable in this exporter.
	DisableCollectors []string `protobuf:"bytes,22,rep,name=disable_collectors,json=disableCollectors,proto3" json:"disable_collectors,omitempty"`
	// contains filtered or unexported fields
}

func (*AddPostgreSQLRequest) Descriptor deprecated

This method has been deprecated.
func (*AddPostgreSQLRequest) Descriptor() ([]byte, []int)

Deprecated: Use AddPostgreSQLRequest.ProtoReflect.Descriptor instead.

func (*AddPostgreSQLRequest) GetAddNode

func (x *AddPostgreSQLRequest) GetAddNode() *AddNodeParams

func (*AddPostgreSQLRequest) GetAddress

func (x *AddPostgreSQLRequest) GetAddress() string

func (*AddPostgreSQLRequest) GetCluster

func (x *AddPostgreSQLRequest) GetCluster() string

func (*AddPostgreSQLRequest) GetCustomLabels

func (x *AddPostgreSQLRequest) GetCustomLabels() map[string]string

func (*AddPostgreSQLRequest) GetDisableCollectors

func (x *AddPostgreSQLRequest) GetDisableCollectors() []string

func (*AddPostgreSQLRequest) GetDisableQueryExamples

func (x *AddPostgreSQLRequest) GetDisableQueryExamples() bool

func (*AddPostgreSQLRequest) GetEnvironment

func (x *AddPostgreSQLRequest) GetEnvironment() string

func (*AddPostgreSQLRequest) GetMetricsMode

func (x *AddPostgreSQLRequest) GetMetricsMode() MetricsMode

func (*AddPostgreSQLRequest) GetNodeId

func (x *AddPostgreSQLRequest) GetNodeId() string

func (*AddPostgreSQLRequest) GetNodeName

func (x *AddPostgreSQLRequest) GetNodeName() string

func (*AddPostgreSQLRequest) GetPassword

func (x *AddPostgreSQLRequest) GetPassword() string

func (*AddPostgreSQLRequest) GetPmmAgentId

func (x *AddPostgreSQLRequest) GetPmmAgentId() string

func (*AddPostgreSQLRequest) GetPort

func (x *AddPostgreSQLRequest) GetPort() uint32

func (*AddPostgreSQLRequest) GetQanPostgresqlPgstatementsAgent

func (x *AddPostgreSQLRequest) GetQanPostgresqlPgstatementsAgent() bool

func (*AddPostgreSQLRequest) GetQanPostgresqlPgstatmonitorAgent

func (x *AddPostgreSQLRequest) GetQanPostgresqlPgstatmonitorAgent() bool

func (*AddPostgreSQLRequest) GetReplicationSet

func (x *AddPostgreSQLRequest) GetReplicationSet() string

func (*AddPostgreSQLRequest) GetServiceName

func (x *AddPostgreSQLRequest) GetServiceName() string

func (*AddPostgreSQLRequest) GetSkipConnectionCheck

func (x *AddPostgreSQLRequest) GetSkipConnectionCheck() bool

func (*AddPostgreSQLRequest) GetSocket

func (x *AddPostgreSQLRequest) GetSocket() string

func (*AddPostgreSQLRequest) GetTls

func (x *AddPostgreSQLRequest) GetTls() bool

func (*AddPostgreSQLRequest) GetTlsSkipVerify

func (x *AddPostgreSQLRequest) GetTlsSkipVerify() bool

func (*AddPostgreSQLRequest) GetUsername

func (x *AddPostgreSQLRequest) GetUsername() string

func (*AddPostgreSQLRequest) ProtoMessage

func (*AddPostgreSQLRequest) ProtoMessage()

func (*AddPostgreSQLRequest) ProtoReflect

func (x *AddPostgreSQLRequest) ProtoReflect() protoreflect.Message

func (*AddPostgreSQLRequest) Reset

func (x *AddPostgreSQLRequest) Reset()

func (*AddPostgreSQLRequest) String

func (x *AddPostgreSQLRequest) String() string

func (*AddPostgreSQLRequest) Validate

func (this *AddPostgreSQLRequest) Validate() error

type AddPostgreSQLResponse

type AddPostgreSQLResponse struct {
	Service                         *inventorypb.PostgreSQLService               `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	PostgresExporter                *inventorypb.PostgresExporter                `protobuf:"bytes,2,opt,name=postgres_exporter,json=postgresExporter,proto3" json:"postgres_exporter,omitempty"`
	QanPostgresqlPgstatementsAgent  *inventorypb.QANPostgreSQLPgStatementsAgent  `` /* 155-byte string literal not displayed */
	QanPostgresqlPgstatmonitorAgent *inventorypb.QANPostgreSQLPgStatMonitorAgent `` /* 158-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*AddPostgreSQLResponse) Descriptor deprecated

This method has been deprecated.
func (*AddPostgreSQLResponse) Descriptor() ([]byte, []int)

Deprecated: Use AddPostgreSQLResponse.ProtoReflect.Descriptor instead.

func (*AddPostgreSQLResponse) GetPostgresExporter

func (x *AddPostgreSQLResponse) GetPostgresExporter() *inventorypb.PostgresExporter

func (*AddPostgreSQLResponse) GetQanPostgresqlPgstatementsAgent

func (x *AddPostgreSQLResponse) GetQanPostgresqlPgstatementsAgent() *inventorypb.QANPostgreSQLPgStatementsAgent

func (*AddPostgreSQLResponse) GetQanPostgresqlPgstatmonitorAgent

func (x *AddPostgreSQLResponse) GetQanPostgresqlPgstatmonitorAgent() *inventorypb.QANPostgreSQLPgStatMonitorAgent

func (*AddPostgreSQLResponse) GetService

func (*AddPostgreSQLResponse) ProtoMessage

func (*AddPostgreSQLResponse) ProtoMessage()

func (*AddPostgreSQLResponse) ProtoReflect

func (x *AddPostgreSQLResponse) ProtoReflect() protoreflect.Message

func (*AddPostgreSQLResponse) Reset

func (x *AddPostgreSQLResponse) Reset()

func (*AddPostgreSQLResponse) String

func (x *AddPostgreSQLResponse) String() string

func (*AddPostgreSQLResponse) Validate

func (this *AddPostgreSQLResponse) Validate() error

type AddProxySQLRequest

type AddProxySQLRequest struct {

	// Node identifier on which a service is been running.
	// Exactly one of these parameters should be present: node_id, node_name, add_node.
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// Node name on which a service is been running.
	// Exactly one of these parameters should be present: node_id, node_name, add_node.
	NodeName string `protobuf:"bytes,2,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	// Create a new Node with those parameters.
	// Exactly one of these parameters should be present: node_id, node_name, add_node.
	AddNode *AddNodeParams `protobuf:"bytes,3,opt,name=add_node,json=addNode,proto3" json:"add_node,omitempty"`
	// Unique across all Services user-defined name. Required.
	ServiceName string `protobuf:"bytes,4,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	// Node and Service access address (DNS name or IP).
	// Address (and port) or socket is required.
	Address string `protobuf:"bytes,5,opt,name=address,proto3" json:"address,omitempty"`
	// Service Access port.
	// Port is required when the address present.
	Port uint32 `protobuf:"varint,6,opt,name=port,proto3" json:"port,omitempty"`
	// Service Access socket.
	// Address (and port) or socket is required.
	Socket string `protobuf:"bytes,17,opt,name=socket,proto3" json:"socket,omitempty"`
	// The "pmm-agent" identifier which should run agents. Required.
	PmmAgentId string `protobuf:"bytes,7,opt,name=pmm_agent_id,json=pmmAgentId,proto3" json:"pmm_agent_id,omitempty"`
	// Environment name.
	Environment string `protobuf:"bytes,8,opt,name=environment,proto3" json:"environment,omitempty"`
	// Cluster name.
	Cluster string `protobuf:"bytes,9,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// Replication set name.
	ReplicationSet string `protobuf:"bytes,10,opt,name=replication_set,json=replicationSet,proto3" json:"replication_set,omitempty"`
	// ProxySQL username for scraping metrics.
	Username string `protobuf:"bytes,11,opt,name=username,proto3" json:"username,omitempty"`
	// ProxySQL password for scraping metrics.
	Password string `protobuf:"bytes,12,opt,name=password,proto3" json:"password,omitempty"`
	// Custom user-assigned labels for Service.
	CustomLabels map[string]string `` /* 186-byte string literal not displayed */
	// Skip connection check.
	SkipConnectionCheck bool `protobuf:"varint,14,opt,name=skip_connection_check,json=skipConnectionCheck,proto3" json:"skip_connection_check,omitempty"`
	// Use TLS for database connections.
	Tls bool `protobuf:"varint,15,opt,name=tls,proto3" json:"tls,omitempty"`
	// Skip TLS certificate and hostname validation.
	TlsSkipVerify bool `protobuf:"varint,16,opt,name=tls_skip_verify,json=tlsSkipVerify,proto3" json:"tls_skip_verify,omitempty"`
	// Defines metrics flow model for this exporter.
	// Metrics could be pushed to the server with vmagent,
	// pulled by the server, or the server could choose behavior automatically.
	MetricsMode MetricsMode `protobuf:"varint,18,opt,name=metrics_mode,json=metricsMode,proto3,enum=management.MetricsMode" json:"metrics_mode,omitempty"`
	// List of collector names to disable in this exporter.
	DisableCollectors []string `protobuf:"bytes,19,rep,name=disable_collectors,json=disableCollectors,proto3" json:"disable_collectors,omitempty"`
	// contains filtered or unexported fields
}

func (*AddProxySQLRequest) Descriptor deprecated

This method has been deprecated.
func (*AddProxySQLRequest) Descriptor() ([]byte, []int)

Deprecated: Use AddProxySQLRequest.ProtoReflect.Descriptor instead.

func (*AddProxySQLRequest) GetAddNode

func (x *AddProxySQLRequest) GetAddNode() *AddNodeParams

func (*AddProxySQLRequest) GetAddress

func (x *AddProxySQLRequest) GetAddress() string

func (*AddProxySQLRequest) GetCluster

func (x *AddProxySQLRequest) GetCluster() string

func (*AddProxySQLRequest) GetCustomLabels

func (x *AddProxySQLRequest) GetCustomLabels() map[string]string

func (*AddProxySQLRequest) GetDisableCollectors

func (x *AddProxySQLRequest) GetDisableCollectors() []string

func (*AddProxySQLRequest) GetEnvironment

func (x *AddProxySQLRequest) GetEnvironment() string

func (*AddProxySQLRequest) GetMetricsMode

func (x *AddProxySQLRequest) GetMetricsMode() MetricsMode

func (*AddProxySQLRequest) GetNodeId

func (x *AddProxySQLRequest) GetNodeId() string

func (*AddProxySQLRequest) GetNodeName

func (x *AddProxySQLRequest) GetNodeName() string

func (*AddProxySQLRequest) GetPassword

func (x *AddProxySQLRequest) GetPassword() string

func (*AddProxySQLRequest) GetPmmAgentId

func (x *AddProxySQLRequest) GetPmmAgentId() string

func (*AddProxySQLRequest) GetPort

func (x *AddProxySQLRequest) GetPort() uint32

func (*AddProxySQLRequest) GetReplicationSet

func (x *AddProxySQLRequest) GetReplicationSet() string

func (*AddProxySQLRequest) GetServiceName

func (x *AddProxySQLRequest) GetServiceName() string

func (*AddProxySQLRequest) GetSkipConnectionCheck

func (x *AddProxySQLRequest) GetSkipConnectionCheck() bool

func (*AddProxySQLRequest) GetSocket

func (x *AddProxySQLRequest) GetSocket() string

func (*AddProxySQLRequest) GetTls

func (x *AddProxySQLRequest) GetTls() bool

func (*AddProxySQLRequest) GetTlsSkipVerify

func (x *AddProxySQLRequest) GetTlsSkipVerify() bool

func (*AddProxySQLRequest) GetUsername

func (x *AddProxySQLRequest) GetUsername() string

func (*AddProxySQLRequest) ProtoMessage

func (*AddProxySQLRequest) ProtoMessage()

func (*AddProxySQLRequest) ProtoReflect

func (x *AddProxySQLRequest) ProtoReflect() protoreflect.Message

func (*AddProxySQLRequest) Reset

func (x *AddProxySQLRequest) Reset()

func (*AddProxySQLRequest) String

func (x *AddProxySQLRequest) String() string

func (*AddProxySQLRequest) Validate

func (this *AddProxySQLRequest) Validate() error

type AddProxySQLResponse

type AddProxySQLResponse struct {
	Service          *inventorypb.ProxySQLService  `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	ProxysqlExporter *inventorypb.ProxySQLExporter `protobuf:"bytes,2,opt,name=proxysql_exporter,json=proxysqlExporter,proto3" json:"proxysql_exporter,omitempty"`
	// contains filtered or unexported fields
}

func (*AddProxySQLResponse) Descriptor deprecated

This method has been deprecated.
func (*AddProxySQLResponse) Descriptor() ([]byte, []int)

Deprecated: Use AddProxySQLResponse.ProtoReflect.Descriptor instead.

func (*AddProxySQLResponse) GetProxysqlExporter

func (x *AddProxySQLResponse) GetProxysqlExporter() *inventorypb.ProxySQLExporter

func (*AddProxySQLResponse) GetService

func (*AddProxySQLResponse) ProtoMessage

func (*AddProxySQLResponse) ProtoMessage()

func (*AddProxySQLResponse) ProtoReflect

func (x *AddProxySQLResponse) ProtoReflect() protoreflect.Message

func (*AddProxySQLResponse) Reset

func (x *AddProxySQLResponse) Reset()

func (*AddProxySQLResponse) String

func (x *AddProxySQLResponse) String() string

func (*AddProxySQLResponse) Validate

func (this *AddProxySQLResponse) Validate() error

type AddRDSRequest

type AddRDSRequest struct {

	// AWS region.
	Region string `protobuf:"bytes,1,opt,name=region,proto3" json:"region,omitempty"`
	// AWS availability zone.
	Az string `protobuf:"bytes,2,opt,name=az,proto3" json:"az,omitempty"`
	// AWS instance ID.
	InstanceId string `protobuf:"bytes,3,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// AWS instance class.
	NodeModel string `protobuf:"bytes,4,opt,name=node_model,json=nodeModel,proto3" json:"node_model,omitempty"`
	// Address used to connect to it.
	Address string `protobuf:"bytes,5,opt,name=address,proto3" json:"address,omitempty"`
	// Access port.
	Port uint32 `protobuf:"varint,6,opt,name=port,proto3" json:"port,omitempty"`
	// Instance engine.
	Engine DiscoverRDSEngine `protobuf:"varint,7,opt,name=engine,proto3,enum=management.DiscoverRDSEngine" json:"engine,omitempty"`
	// Unique across all Nodes user-defined name. Defaults to AWS instance ID.
	NodeName string `protobuf:"bytes,8,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	// Unique across all Services user-defined name. Defaults to AWS instance ID.
	ServiceName string `protobuf:"bytes,9,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	// Environment name.
	Environment string `protobuf:"bytes,10,opt,name=environment,proto3" json:"environment,omitempty"`
	// Cluster name.
	Cluster string `protobuf:"bytes,11,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// Replication set name.
	ReplicationSet string `protobuf:"bytes,12,opt,name=replication_set,json=replicationSet,proto3" json:"replication_set,omitempty"`
	// Username for scraping metrics.
	Username string `protobuf:"bytes,13,opt,name=username,proto3" json:"username,omitempty"`
	// Password for scraping metrics.
	Password string `protobuf:"bytes,14,opt,name=password,proto3" json:"password,omitempty"`
	// AWS Access key.
	AwsAccessKey string `protobuf:"bytes,15,opt,name=aws_access_key,json=awsAccessKey,proto3" json:"aws_access_key,omitempty"`
	// AWS Secret key.
	AwsSecretKey string `protobuf:"bytes,16,opt,name=aws_secret_key,json=awsSecretKey,proto3" json:"aws_secret_key,omitempty"`
	// If true, adds rds_exporter.
	RdsExporter bool `protobuf:"varint,17,opt,name=rds_exporter,json=rdsExporter,proto3" json:"rds_exporter,omitempty"`
	// If true, adds qan-mysql-perfschema-agent.
	QanMysqlPerfschema bool `protobuf:"varint,18,opt,name=qan_mysql_perfschema,json=qanMysqlPerfschema,proto3" json:"qan_mysql_perfschema,omitempty"`
	// Custom user-assigned labels for Node and Service.
	CustomLabels map[string]string `` /* 186-byte string literal not displayed */
	// Skip connection check.
	SkipConnectionCheck bool `protobuf:"varint,20,opt,name=skip_connection_check,json=skipConnectionCheck,proto3" json:"skip_connection_check,omitempty"`
	// Use TLS for database connections.
	Tls bool `protobuf:"varint,21,opt,name=tls,proto3" json:"tls,omitempty"`
	// Skip TLS certificate and hostname validation.
	TlsSkipVerify bool `protobuf:"varint,22,opt,name=tls_skip_verify,json=tlsSkipVerify,proto3" json:"tls_skip_verify,omitempty"`
	// Disable query examples.
	DisableQueryExamples bool `protobuf:"varint,23,opt,name=disable_query_examples,json=disableQueryExamples,proto3" json:"disable_query_examples,omitempty"`
	// Tablestats group collectors will be disabled if there are more than that number of tables.
	// If zero, server's default value is used.
	// Use negative value to disable them.
	TablestatsGroupTableLimit int32 `` /* 142-byte string literal not displayed */
	// Disable basic metrics.
	DisableBasicMetrics bool `protobuf:"varint,25,opt,name=disable_basic_metrics,json=disableBasicMetrics,proto3" json:"disable_basic_metrics,omitempty"`
	// Disable enhanced metrics.
	DisableEnhancedMetrics bool `` /* 131-byte string literal not displayed */
	// Defines metrics flow model for this exporter.
	// Push metrics mode is not allowed.
	MetricsMode MetricsMode `protobuf:"varint,27,opt,name=metrics_mode,json=metricsMode,proto3,enum=management.MetricsMode" json:"metrics_mode,omitempty"`
	// If true, add qan-pgstatements
	QanPostgresqlPgstatements bool `` /* 140-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*AddRDSRequest) Descriptor deprecated

This method has been deprecated.
func (*AddRDSRequest) Descriptor() ([]byte, []int)

Deprecated: Use AddRDSRequest.ProtoReflect.Descriptor instead.

func (*AddRDSRequest) GetAddress

func (x *AddRDSRequest) GetAddress() string

func (*AddRDSRequest) GetAwsAccessKey

func (x *AddRDSRequest) GetAwsAccessKey() string

func (*AddRDSRequest) GetAwsSecretKey

func (x *AddRDSRequest) GetAwsSecretKey() string

func (*AddRDSRequest) GetAz

func (x *AddRDSRequest) GetAz() string

func (*AddRDSRequest) GetCluster

func (x *AddRDSRequest) GetCluster() string

func (*AddRDSRequest) GetCustomLabels

func (x *AddRDSRequest) GetCustomLabels() map[string]string

func (*AddRDSRequest) GetDisableBasicMetrics

func (x *AddRDSRequest) GetDisableBasicMetrics() bool

func (*AddRDSRequest) GetDisableEnhancedMetrics

func (x *AddRDSRequest) GetDisableEnhancedMetrics() bool

func (*AddRDSRequest) GetDisableQueryExamples

func (x *AddRDSRequest) GetDisableQueryExamples() bool

func (*AddRDSRequest) GetEngine

func (x *AddRDSRequest) GetEngine() DiscoverRDSEngine

func (*AddRDSRequest) GetEnvironment

func (x *AddRDSRequest) GetEnvironment() string

func (*AddRDSRequest) GetInstanceId

func (x *AddRDSRequest) GetInstanceId() string

func (*AddRDSRequest) GetMetricsMode

func (x *AddRDSRequest) GetMetricsMode() MetricsMode

func (*AddRDSRequest) GetNodeModel

func (x *AddRDSRequest) GetNodeModel() string

func (*AddRDSRequest) GetNodeName

func (x *AddRDSRequest) GetNodeName() string

func (*AddRDSRequest) GetPassword

func (x *AddRDSRequest) GetPassword() string

func (*AddRDSRequest) GetPort

func (x *AddRDSRequest) GetPort() uint32

func (*AddRDSRequest) GetQanMysqlPerfschema

func (x *AddRDSRequest) GetQanMysqlPerfschema() bool

func (*AddRDSRequest) GetQanPostgresqlPgstatements

func (x *AddRDSRequest) GetQanPostgresqlPgstatements() bool

func (*AddRDSRequest) GetRdsExporter

func (x *AddRDSRequest) GetRdsExporter() bool

func (*AddRDSRequest) GetRegion

func (x *AddRDSRequest) GetRegion() string

func (*AddRDSRequest) GetReplicationSet

func (x *AddRDSRequest) GetReplicationSet() string

func (*AddRDSRequest) GetServiceName

func (x *AddRDSRequest) GetServiceName() string

func (*AddRDSRequest) GetSkipConnectionCheck

func (x *AddRDSRequest) GetSkipConnectionCheck() bool

func (*AddRDSRequest) GetTablestatsGroupTableLimit

func (x *AddRDSRequest) GetTablestatsGroupTableLimit() int32

func (*AddRDSRequest) GetTls

func (x *AddRDSRequest) GetTls() bool

func (*AddRDSRequest) GetTlsSkipVerify

func (x *AddRDSRequest) GetTlsSkipVerify() bool

func (*AddRDSRequest) GetUsername

func (x *AddRDSRequest) GetUsername() string

func (*AddRDSRequest) ProtoMessage

func (*AddRDSRequest) ProtoMessage()

func (*AddRDSRequest) ProtoReflect

func (x *AddRDSRequest) ProtoReflect() protoreflect.Message

func (*AddRDSRequest) Reset

func (x *AddRDSRequest) Reset()

func (*AddRDSRequest) String

func (x *AddRDSRequest) String() string

func (*AddRDSRequest) Validate

func (this *AddRDSRequest) Validate() error

type AddRDSResponse

type AddRDSResponse struct {
	Node               *inventorypb.RemoteRDSNode           `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	RdsExporter        *inventorypb.RDSExporter             `protobuf:"bytes,2,opt,name=rds_exporter,json=rdsExporter,proto3" json:"rds_exporter,omitempty"`
	Mysql              *inventorypb.MySQLService            `protobuf:"bytes,3,opt,name=mysql,proto3" json:"mysql,omitempty"`
	MysqldExporter     *inventorypb.MySQLdExporter          `protobuf:"bytes,4,opt,name=mysqld_exporter,json=mysqldExporter,proto3" json:"mysqld_exporter,omitempty"`
	QanMysqlPerfschema *inventorypb.QANMySQLPerfSchemaAgent `protobuf:"bytes,5,opt,name=qan_mysql_perfschema,json=qanMysqlPerfschema,proto3" json:"qan_mysql_perfschema,omitempty"`
	// Actual table count at the moment of adding.
	TableCount                int32                                       `protobuf:"varint,6,opt,name=table_count,json=tableCount,proto3" json:"table_count,omitempty"`
	Postgresql                *inventorypb.PostgreSQLService              `protobuf:"bytes,7,opt,name=postgresql,proto3" json:"postgresql,omitempty"`
	PostgresqlExporter        *inventorypb.PostgresExporter               `protobuf:"bytes,8,opt,name=postgresql_exporter,json=postgresqlExporter,proto3" json:"postgresql_exporter,omitempty"`
	QanPostgresqlPgstatements *inventorypb.QANPostgreSQLPgStatementsAgent `` /* 138-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*AddRDSResponse) Descriptor deprecated

This method has been deprecated.
func (*AddRDSResponse) Descriptor() ([]byte, []int)

Deprecated: Use AddRDSResponse.ProtoReflect.Descriptor instead.

func (*AddRDSResponse) GetMysql

func (x *AddRDSResponse) GetMysql() *inventorypb.MySQLService

func (*AddRDSResponse) GetMysqldExporter

func (x *AddRDSResponse) GetMysqldExporter() *inventorypb.MySQLdExporter

func (*AddRDSResponse) GetNode

func (*AddRDSResponse) GetPostgresql

func (x *AddRDSResponse) GetPostgresql() *inventorypb.PostgreSQLService

func (*AddRDSResponse) GetPostgresqlExporter

func (x *AddRDSResponse) GetPostgresqlExporter() *inventorypb.PostgresExporter

func (*AddRDSResponse) GetQanMysqlPerfschema

func (x *AddRDSResponse) GetQanMysqlPerfschema() *inventorypb.QANMySQLPerfSchemaAgent

func (*AddRDSResponse) GetQanPostgresqlPgstatements

func (x *AddRDSResponse) GetQanPostgresqlPgstatements() *inventorypb.QANPostgreSQLPgStatementsAgent

func (*AddRDSResponse) GetRdsExporter

func (x *AddRDSResponse) GetRdsExporter() *inventorypb.RDSExporter

func (*AddRDSResponse) GetTableCount

func (x *AddRDSResponse) GetTableCount() int32

func (*AddRDSResponse) ProtoMessage

func (*AddRDSResponse) ProtoMessage()

func (*AddRDSResponse) ProtoReflect

func (x *AddRDSResponse) ProtoReflect() protoreflect.Message

func (*AddRDSResponse) Reset

func (x *AddRDSResponse) Reset()

func (*AddRDSResponse) String

func (x *AddRDSResponse) String() string

func (*AddRDSResponse) Validate

func (this *AddRDSResponse) Validate() error

type AnnotationClient

type AnnotationClient interface {
	// AddAnnotation adds annotation.
	AddAnnotation(ctx context.Context, in *AddAnnotationRequest, opts ...grpc.CallOption) (*AddAnnotationResponse, error)
}

AnnotationClient is the client API for Annotation service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewAnnotationClient

func NewAnnotationClient(cc grpc.ClientConnInterface) AnnotationClient

type AnnotationServer

type AnnotationServer interface {
	// AddAnnotation adds annotation.
	AddAnnotation(context.Context, *AddAnnotationRequest) (*AddAnnotationResponse, error)
}

AnnotationServer is the server API for Annotation service.

type CancelActionRequest

type CancelActionRequest struct {

	// Unique Action ID. Required.
	ActionId string `protobuf:"bytes,1,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelActionRequest) Descriptor deprecated

This method has been deprecated.
func (*CancelActionRequest) Descriptor() ([]byte, []int)

Deprecated: Use CancelActionRequest.ProtoReflect.Descriptor instead.

func (*CancelActionRequest) GetActionId

func (x *CancelActionRequest) GetActionId() string

func (*CancelActionRequest) ProtoMessage

func (*CancelActionRequest) ProtoMessage()

func (*CancelActionRequest) ProtoReflect

func (x *CancelActionRequest) ProtoReflect() protoreflect.Message

func (*CancelActionRequest) Reset

func (x *CancelActionRequest) Reset()

func (*CancelActionRequest) String

func (x *CancelActionRequest) String() string

func (*CancelActionRequest) Validate

func (this *CancelActionRequest) Validate() error

type CancelActionResponse

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

func (*CancelActionResponse) Descriptor deprecated

This method has been deprecated.
func (*CancelActionResponse) Descriptor() ([]byte, []int)

Deprecated: Use CancelActionResponse.ProtoReflect.Descriptor instead.

func (*CancelActionResponse) ProtoMessage

func (*CancelActionResponse) ProtoMessage()

func (*CancelActionResponse) ProtoReflect

func (x *CancelActionResponse) ProtoReflect() protoreflect.Message

func (*CancelActionResponse) Reset

func (x *CancelActionResponse) Reset()

func (*CancelActionResponse) String

func (x *CancelActionResponse) String() string

func (*CancelActionResponse) Validate

func (this *CancelActionResponse) Validate() error

type ChangeSecurityCheckParams

type ChangeSecurityCheckParams struct {

	// The name of the check to change.
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Enable  bool   `protobuf:"varint,2,opt,name=enable,proto3" json:"enable,omitempty"`
	Disable bool   `protobuf:"varint,3,opt,name=disable,proto3" json:"disable,omitempty"`
	// check execution interval.
	Interval SecurityCheckInterval `protobuf:"varint,4,opt,name=interval,proto3,enum=management.SecurityCheckInterval" json:"interval,omitempty"`
	// contains filtered or unexported fields
}

ChangeSecurityCheckParams specifies a single check parameters.

func (*ChangeSecurityCheckParams) Descriptor deprecated

This method has been deprecated.
func (*ChangeSecurityCheckParams) Descriptor() ([]byte, []int)

Deprecated: Use ChangeSecurityCheckParams.ProtoReflect.Descriptor instead.

func (*ChangeSecurityCheckParams) GetDisable

func (x *ChangeSecurityCheckParams) GetDisable() bool

func (*ChangeSecurityCheckParams) GetEnable

func (x *ChangeSecurityCheckParams) GetEnable() bool

func (*ChangeSecurityCheckParams) GetInterval

func (*ChangeSecurityCheckParams) GetName

func (x *ChangeSecurityCheckParams) GetName() string

func (*ChangeSecurityCheckParams) ProtoMessage

func (*ChangeSecurityCheckParams) ProtoMessage()

func (*ChangeSecurityCheckParams) ProtoReflect

func (*ChangeSecurityCheckParams) Reset

func (x *ChangeSecurityCheckParams) Reset()

func (*ChangeSecurityCheckParams) String

func (x *ChangeSecurityCheckParams) String() string

func (*ChangeSecurityCheckParams) Validate

func (this *ChangeSecurityCheckParams) Validate() error

type ChangeSecurityChecksRequest

type ChangeSecurityChecksRequest struct {
	Params []*ChangeSecurityCheckParams `protobuf:"bytes,1,rep,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangeSecurityChecksRequest) Descriptor deprecated

This method has been deprecated.
func (*ChangeSecurityChecksRequest) Descriptor() ([]byte, []int)

Deprecated: Use ChangeSecurityChecksRequest.ProtoReflect.Descriptor instead.

func (*ChangeSecurityChecksRequest) GetParams

func (*ChangeSecurityChecksRequest) ProtoMessage

func (*ChangeSecurityChecksRequest) ProtoMessage()

func (*ChangeSecurityChecksRequest) ProtoReflect

func (*ChangeSecurityChecksRequest) Reset

func (x *ChangeSecurityChecksRequest) Reset()

func (*ChangeSecurityChecksRequest) String

func (x *ChangeSecurityChecksRequest) String() string

func (*ChangeSecurityChecksRequest) Validate

func (this *ChangeSecurityChecksRequest) Validate() error

type ChangeSecurityChecksResponse

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

func (*ChangeSecurityChecksResponse) Descriptor deprecated

This method has been deprecated.
func (*ChangeSecurityChecksResponse) Descriptor() ([]byte, []int)

Deprecated: Use ChangeSecurityChecksResponse.ProtoReflect.Descriptor instead.

func (*ChangeSecurityChecksResponse) ProtoMessage

func (*ChangeSecurityChecksResponse) ProtoMessage()

func (*ChangeSecurityChecksResponse) ProtoReflect

func (*ChangeSecurityChecksResponse) Reset

func (x *ChangeSecurityChecksResponse) Reset()

func (*ChangeSecurityChecksResponse) String

func (*ChangeSecurityChecksResponse) Validate

func (this *ChangeSecurityChecksResponse) Validate() error

type DiscoverRDSEngine

type DiscoverRDSEngine int32

DiscoverRDSEngine describes supported RDS instance engines.

const (
	DiscoverRDSEngine_DISCOVER_RDS_ENGINE_INVALID DiscoverRDSEngine = 0
	DiscoverRDSEngine_DISCOVER_RDS_MYSQL          DiscoverRDSEngine = 1
	DiscoverRDSEngine_DISCOVER_RDS_POSTGRESQL     DiscoverRDSEngine = 2
)

func (DiscoverRDSEngine) Descriptor

func (DiscoverRDSEngine) Enum

func (DiscoverRDSEngine) EnumDescriptor deprecated

This method has been deprecated.
func (DiscoverRDSEngine) EnumDescriptor() ([]byte, []int)

Deprecated: Use DiscoverRDSEngine.Descriptor instead.

func (DiscoverRDSEngine) Number

func (DiscoverRDSEngine) String

func (x DiscoverRDSEngine) String() string

func (DiscoverRDSEngine) Type

type DiscoverRDSInstance

type DiscoverRDSInstance struct {

	// AWS region.
	Region string `protobuf:"bytes,1,opt,name=region,proto3" json:"region,omitempty"`
	// AWS availability zone.
	Az string `protobuf:"bytes,2,opt,name=az,proto3" json:"az,omitempty"`
	// AWS instance ID.
	InstanceId string `protobuf:"bytes,3,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// AWS instance class.
	NodeModel string `protobuf:"bytes,4,opt,name=node_model,json=nodeModel,proto3" json:"node_model,omitempty"`
	// Address used to connect to it.
	Address string `protobuf:"bytes,5,opt,name=address,proto3" json:"address,omitempty"`
	// Access port.
	Port uint32 `protobuf:"varint,6,opt,name=port,proto3" json:"port,omitempty"`
	// Instance engine.
	Engine DiscoverRDSEngine `protobuf:"varint,7,opt,name=engine,proto3,enum=management.DiscoverRDSEngine" json:"engine,omitempty"`
	// Engine version.
	EngineVersion string `protobuf:"bytes,8,opt,name=engine_version,json=engineVersion,proto3" json:"engine_version,omitempty"`
	// contains filtered or unexported fields
}

DiscoverRDSInstance models an unique RDS instance for the list of instances returned by Discovery.

func (*DiscoverRDSInstance) Descriptor deprecated

This method has been deprecated.
func (*DiscoverRDSInstance) Descriptor() ([]byte, []int)

Deprecated: Use DiscoverRDSInstance.ProtoReflect.Descriptor instead.

func (*DiscoverRDSInstance) GetAddress

func (x *DiscoverRDSInstance) GetAddress() string

func (*DiscoverRDSInstance) GetAz

func (x *DiscoverRDSInstance) GetAz() string

func (*DiscoverRDSInstance) GetEngine

func (x *DiscoverRDSInstance) GetEngine() DiscoverRDSEngine

func (*DiscoverRDSInstance) GetEngineVersion

func (x *DiscoverRDSInstance) GetEngineVersion() string

func (*DiscoverRDSInstance) GetInstanceId

func (x *DiscoverRDSInstance) GetInstanceId() string

func (*DiscoverRDSInstance) GetNodeModel

func (x *DiscoverRDSInstance) GetNodeModel() string

func (*DiscoverRDSInstance) GetPort

func (x *DiscoverRDSInstance) GetPort() uint32

func (*DiscoverRDSInstance) GetRegion

func (x *DiscoverRDSInstance) GetRegion() string

func (*DiscoverRDSInstance) ProtoMessage

func (*DiscoverRDSInstance) ProtoMessage()

func (*DiscoverRDSInstance) ProtoReflect

func (x *DiscoverRDSInstance) ProtoReflect() protoreflect.Message

func (*DiscoverRDSInstance) Reset

func (x *DiscoverRDSInstance) Reset()

func (*DiscoverRDSInstance) String

func (x *DiscoverRDSInstance) String() string

func (*DiscoverRDSInstance) Validate

func (this *DiscoverRDSInstance) Validate() error

type DiscoverRDSRequest

type DiscoverRDSRequest struct {

	// AWS Access key. Optional.
	AwsAccessKey string `protobuf:"bytes,1,opt,name=aws_access_key,json=awsAccessKey,proto3" json:"aws_access_key,omitempty"`
	// AWS Secret key. Optional.
	AwsSecretKey string `protobuf:"bytes,2,opt,name=aws_secret_key,json=awsSecretKey,proto3" json:"aws_secret_key,omitempty"`
	// contains filtered or unexported fields
}

func (*DiscoverRDSRequest) Descriptor deprecated

This method has been deprecated.
func (*DiscoverRDSRequest) Descriptor() ([]byte, []int)

Deprecated: Use DiscoverRDSRequest.ProtoReflect.Descriptor instead.

func (*DiscoverRDSRequest) GetAwsAccessKey

func (x *DiscoverRDSRequest) GetAwsAccessKey() string

func (*DiscoverRDSRequest) GetAwsSecretKey

func (x *DiscoverRDSRequest) GetAwsSecretKey() string

func (*DiscoverRDSRequest) ProtoMessage

func (*DiscoverRDSRequest) ProtoMessage()

func (*DiscoverRDSRequest) ProtoReflect

func (x *DiscoverRDSRequest) ProtoReflect() protoreflect.Message

func (*DiscoverRDSRequest) Reset

func (x *DiscoverRDSRequest) Reset()

func (*DiscoverRDSRequest) String

func (x *DiscoverRDSRequest) String() string

func (*DiscoverRDSRequest) Validate

func (this *DiscoverRDSRequest) Validate() error

type DiscoverRDSResponse

type DiscoverRDSResponse struct {
	RdsInstances []*DiscoverRDSInstance `protobuf:"bytes,1,rep,name=rds_instances,json=rdsInstances,proto3" json:"rds_instances,omitempty"`
	// contains filtered or unexported fields
}

func (*DiscoverRDSResponse) Descriptor deprecated

This method has been deprecated.
func (*DiscoverRDSResponse) Descriptor() ([]byte, []int)

Deprecated: Use DiscoverRDSResponse.ProtoReflect.Descriptor instead.

func (*DiscoverRDSResponse) GetRdsInstances

func (x *DiscoverRDSResponse) GetRdsInstances() []*DiscoverRDSInstance

func (*DiscoverRDSResponse) ProtoMessage

func (*DiscoverRDSResponse) ProtoMessage()

func (*DiscoverRDSResponse) ProtoReflect

func (x *DiscoverRDSResponse) ProtoReflect() protoreflect.Message

func (*DiscoverRDSResponse) Reset

func (x *DiscoverRDSResponse) Reset()

func (*DiscoverRDSResponse) String

func (x *DiscoverRDSResponse) String() string

func (*DiscoverRDSResponse) Validate

func (this *DiscoverRDSResponse) Validate() error

type ExternalClient

type ExternalClient interface {
	// AddExternal adds external service and adds external exporter.
	// It automatically adds a service to inventory, which is running on provided "node_id",
	// then adds an "external exporter" agent to inventory, which is running on provided "runs_on_node_id".
	AddExternal(ctx context.Context, in *AddExternalRequest, opts ...grpc.CallOption) (*AddExternalResponse, error)
}

ExternalClient is the client API for External service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewExternalClient

func NewExternalClient(cc grpc.ClientConnInterface) ExternalClient

type ExternalServer

type ExternalServer interface {
	// AddExternal adds external service and adds external exporter.
	// It automatically adds a service to inventory, which is running on provided "node_id",
	// then adds an "external exporter" agent to inventory, which is running on provided "runs_on_node_id".
	AddExternal(context.Context, *AddExternalRequest) (*AddExternalResponse, error)
}

ExternalServer is the server API for External service.

type GetActionRequest

type GetActionRequest struct {

	// Unique Action ID.
	ActionId string `protobuf:"bytes,1,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetActionRequest) Descriptor deprecated

This method has been deprecated.
func (*GetActionRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetActionRequest.ProtoReflect.Descriptor instead.

func (*GetActionRequest) GetActionId

func (x *GetActionRequest) GetActionId() string

func (*GetActionRequest) ProtoMessage

func (*GetActionRequest) ProtoMessage()

func (*GetActionRequest) ProtoReflect

func (x *GetActionRequest) ProtoReflect() protoreflect.Message

func (*GetActionRequest) Reset

func (x *GetActionRequest) Reset()

func (*GetActionRequest) String

func (x *GetActionRequest) String() string

func (*GetActionRequest) Validate

func (this *GetActionRequest) Validate() error

type GetActionResponse

type GetActionResponse struct {

	// Unique Action ID.
	ActionId string `protobuf:"bytes,1,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
	// pmm-agent ID where this Action is running / was run.
	PmmAgentId string `protobuf:"bytes,2,opt,name=pmm_agent_id,json=pmmAgentId,proto3" json:"pmm_agent_id,omitempty"`
	// Current Action output; may be partial if Action is still running.
	Output string `protobuf:"bytes,3,opt,name=output,proto3" json:"output,omitempty"`
	// True if Action is finished.
	Done bool `protobuf:"varint,4,opt,name=done,proto3" json:"done,omitempty"`
	// Error message if Action failed.
	Error string `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*GetActionResponse) Descriptor deprecated

This method has been deprecated.
func (*GetActionResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetActionResponse.ProtoReflect.Descriptor instead.

func (*GetActionResponse) GetActionId

func (x *GetActionResponse) GetActionId() string

func (*GetActionResponse) GetDone

func (x *GetActionResponse) GetDone() bool

func (*GetActionResponse) GetError

func (x *GetActionResponse) GetError() string

func (*GetActionResponse) GetOutput

func (x *GetActionResponse) GetOutput() string

func (*GetActionResponse) GetPmmAgentId

func (x *GetActionResponse) GetPmmAgentId() string

func (*GetActionResponse) ProtoMessage

func (*GetActionResponse) ProtoMessage()

func (*GetActionResponse) ProtoReflect

func (x *GetActionResponse) ProtoReflect() protoreflect.Message

func (*GetActionResponse) Reset

func (x *GetActionResponse) Reset()

func (*GetActionResponse) String

func (x *GetActionResponse) String() string

func (*GetActionResponse) Validate

func (this *GetActionResponse) Validate() error

type GetSecurityCheckResultsRequest

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

func (*GetSecurityCheckResultsRequest) Descriptor deprecated

This method has been deprecated.
func (*GetSecurityCheckResultsRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetSecurityCheckResultsRequest.ProtoReflect.Descriptor instead.

func (*GetSecurityCheckResultsRequest) ProtoMessage

func (*GetSecurityCheckResultsRequest) ProtoMessage()

func (*GetSecurityCheckResultsRequest) ProtoReflect

func (*GetSecurityCheckResultsRequest) Reset

func (x *GetSecurityCheckResultsRequest) Reset()

func (*GetSecurityCheckResultsRequest) String

func (*GetSecurityCheckResultsRequest) Validate

func (this *GetSecurityCheckResultsRequest) Validate() error

type GetSecurityCheckResultsResponse

type GetSecurityCheckResultsResponse struct {
	Results []*SecurityCheckResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSecurityCheckResultsResponse) Descriptor deprecated

This method has been deprecated.
func (*GetSecurityCheckResultsResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetSecurityCheckResultsResponse.ProtoReflect.Descriptor instead.

func (*GetSecurityCheckResultsResponse) GetResults

func (*GetSecurityCheckResultsResponse) ProtoMessage

func (*GetSecurityCheckResultsResponse) ProtoMessage()

func (*GetSecurityCheckResultsResponse) ProtoReflect

func (*GetSecurityCheckResultsResponse) Reset

func (*GetSecurityCheckResultsResponse) String

func (*GetSecurityCheckResultsResponse) Validate

func (this *GetSecurityCheckResultsResponse) Validate() error

type HAProxyClient

type HAProxyClient interface {
	// AddHAProxy adds HAProxy service and adds external exporter.
	// It automatically adds a service to inventory, which is running on provided "node_id",
	// then adds an "external exporter" agent to inventory.
	AddHAProxy(ctx context.Context, in *AddHAProxyRequest, opts ...grpc.CallOption) (*AddHAProxyResponse, error)
}

HAProxyClient is the client API for HAProxy service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewHAProxyClient

func NewHAProxyClient(cc grpc.ClientConnInterface) HAProxyClient

type HAProxyServer

type HAProxyServer interface {
	// AddHAProxy adds HAProxy service and adds external exporter.
	// It automatically adds a service to inventory, which is running on provided "node_id",
	// then adds an "external exporter" agent to inventory.
	AddHAProxy(context.Context, *AddHAProxyRequest) (*AddHAProxyResponse, error)
}

HAProxyServer is the server API for HAProxy service.

type ListSecurityChecksRequest

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

func (*ListSecurityChecksRequest) Descriptor deprecated

This method has been deprecated.
func (*ListSecurityChecksRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListSecurityChecksRequest.ProtoReflect.Descriptor instead.

func (*ListSecurityChecksRequest) ProtoMessage

func (*ListSecurityChecksRequest) ProtoMessage()

func (*ListSecurityChecksRequest) ProtoReflect

func (*ListSecurityChecksRequest) Reset

func (x *ListSecurityChecksRequest) Reset()

func (*ListSecurityChecksRequest) String

func (x *ListSecurityChecksRequest) String() string

func (*ListSecurityChecksRequest) Validate

func (this *ListSecurityChecksRequest) Validate() error

type ListSecurityChecksResponse

type ListSecurityChecksResponse struct {
	Checks []*SecurityCheck `protobuf:"bytes,1,rep,name=checks,proto3" json:"checks,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSecurityChecksResponse) Descriptor deprecated

This method has been deprecated.
func (*ListSecurityChecksResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListSecurityChecksResponse.ProtoReflect.Descriptor instead.

func (*ListSecurityChecksResponse) GetChecks

func (x *ListSecurityChecksResponse) GetChecks() []*SecurityCheck

func (*ListSecurityChecksResponse) ProtoMessage

func (*ListSecurityChecksResponse) ProtoMessage()

func (*ListSecurityChecksResponse) ProtoReflect

func (*ListSecurityChecksResponse) Reset

func (x *ListSecurityChecksResponse) Reset()

func (*ListSecurityChecksResponse) String

func (x *ListSecurityChecksResponse) String() string

func (*ListSecurityChecksResponse) Validate

func (this *ListSecurityChecksResponse) Validate() error

type MetricsMode

type MetricsMode int32

MetricsMode defines desired metrics mode for agent, it can be pull, push or auto mode chosen by server.

const (
	MetricsMode_AUTO MetricsMode = 0
	MetricsMode_PULL MetricsMode = 1
	MetricsMode_PUSH MetricsMode = 2
)

func (MetricsMode) Descriptor

func (MetricsMode) Enum

func (x MetricsMode) Enum() *MetricsMode

func (MetricsMode) EnumDescriptor deprecated

This method has been deprecated.
func (MetricsMode) EnumDescriptor() ([]byte, []int)

Deprecated: Use MetricsMode.Descriptor instead.

func (MetricsMode) Number

func (x MetricsMode) Number() protoreflect.EnumNumber

func (MetricsMode) String

func (x MetricsMode) String() string

func (MetricsMode) Type

type MongoDBClient

type MongoDBClient interface {
	// AddMongoDB adds MongoDB Service and starts several Agents.
	// It automatically adds a service to inventory, which is running on provided "node_id",
	// then adds "mongodb_exporter", and "qan_mongodb_profiler" agents
	// with provided "pmm_agent_id" and other parameters.
	AddMongoDB(ctx context.Context, in *AddMongoDBRequest, opts ...grpc.CallOption) (*AddMongoDBResponse, error)
}

MongoDBClient is the client API for MongoDB service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMongoDBClient

func NewMongoDBClient(cc grpc.ClientConnInterface) MongoDBClient

type MongoDBServer

type MongoDBServer interface {
	// AddMongoDB adds MongoDB Service and starts several Agents.
	// It automatically adds a service to inventory, which is running on provided "node_id",
	// then adds "mongodb_exporter", and "qan_mongodb_profiler" agents
	// with provided "pmm_agent_id" and other parameters.
	AddMongoDB(context.Context, *AddMongoDBRequest) (*AddMongoDBResponse, error)
}

MongoDBServer is the server API for MongoDB service.

type MySQLClient

type MySQLClient interface {
	// AddMySQL adds MySQL Service and starts several Agents.
	// It automatically adds a service to inventory, which is running on provided "node_id",
	// then adds "mysqld_exporter", and "qan_mysql_perfschema" agents
	// with provided "pmm_agent_id" and other parameters.
	AddMySQL(ctx context.Context, in *AddMySQLRequest, opts ...grpc.CallOption) (*AddMySQLResponse, error)
}

MySQLClient is the client API for MySQL service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMySQLClient

func NewMySQLClient(cc grpc.ClientConnInterface) MySQLClient

type MySQLServer

type MySQLServer interface {
	// AddMySQL adds MySQL Service and starts several Agents.
	// It automatically adds a service to inventory, which is running on provided "node_id",
	// then adds "mysqld_exporter", and "qan_mysql_perfschema" agents
	// with provided "pmm_agent_id" and other parameters.
	AddMySQL(context.Context, *AddMySQLRequest) (*AddMySQLResponse, error)
}

MySQLServer is the server API for MySQL service.

type NodeClient

type NodeClient interface {
	// RegisterNode registers a new Node and pmm-agent.
	RegisterNode(ctx context.Context, in *RegisterNodeRequest, opts ...grpc.CallOption) (*RegisterNodeResponse, error)
}

NodeClient is the client API for Node service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewNodeClient

func NewNodeClient(cc grpc.ClientConnInterface) NodeClient

type NodeServer

type NodeServer interface {
	// RegisterNode registers a new Node and pmm-agent.
	RegisterNode(context.Context, *RegisterNodeRequest) (*RegisterNodeResponse, error)
}

NodeServer is the server API for Node service.

type PostgreSQLClient

type PostgreSQLClient interfa