agentpb

package
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: 0

Documentation

Overview

Package agentpb contains pmm-agent<->pmm-managed protocol messages and helpers.

Index

Constants

This section is empty.

Variables

View Source
var (
	MysqlExplainOutputFormat_name = map[int32]string{
		0: "MYSQL_EXPLAIN_OUTPUT_FORMAT_INVALID",
		1: "MYSQL_EXPLAIN_OUTPUT_FORMAT_DEFAULT",
		2: "MYSQL_EXPLAIN_OUTPUT_FORMAT_JSON",
		3: "MYSQL_EXPLAIN_OUTPUT_FORMAT_TRADITIONAL_JSON",
	}
	MysqlExplainOutputFormat_value = map[string]int32{
		"MYSQL_EXPLAIN_OUTPUT_FORMAT_INVALID":          0,
		"MYSQL_EXPLAIN_OUTPUT_FORMAT_DEFAULT":          1,
		"MYSQL_EXPLAIN_OUTPUT_FORMAT_JSON":             2,
		"MYSQL_EXPLAIN_OUTPUT_FORMAT_TRADITIONAL_JSON": 3,
	}
)

Enum value maps for MysqlExplainOutputFormat.

View Source
var (
	ExampleFormat_name = map[int32]string{
		0: "EXAMPLE_FORMAT_INVALID",
		1: "EXAMPLE",
		2: "FINGERPRINT",
	}
	ExampleFormat_value = map[string]int32{
		"EXAMPLE_FORMAT_INVALID": 0,
		"EXAMPLE":                1,
		"FINGERPRINT":            2,
	}
)

Enum value maps for ExampleFormat.

View Source
var (
	ExampleType_name = map[int32]string{
		0: "EXAMPLE_TYPE_INVALID",
		1: "RANDOM",
		2: "SLOWEST",
		3: "FASTEST",
		4: "WITH_ERROR",
	}
	ExampleType_value = map[string]int32{
		"EXAMPLE_TYPE_INVALID": 0,
		"RANDOM":               1,
		"SLOWEST":              2,
		"FASTEST":              3,
		"WITH_ERROR":           4,
	}
)

Enum value maps for ExampleType.

View Source
var File_agentpb_agent_proto protoreflect.FileDescriptor
View Source
var File_agentpb_collector_proto protoreflect.FileDescriptor

Functions

func AddAgentConnectMetadata

func AddAgentConnectMetadata(ctx context.Context, md *AgentConnectMetadata) context.Context

AddAgentConnectMetadata adds pmm-agent's metadata to outgoing context. Used by pmm-agent.

func MarshalActionQueryDocsResult

func MarshalActionQueryDocsResult(docs []map[string]interface{}) ([]byte, error)

MarshalActionQueryDocsResult returns serialized form of query Action documents result.

It supports the same types as MarshalActionQuerySQLResult plus: * MongoDB's primitive.DateTime and primitive.Timestamp are converted to time.Time.

func MarshalActionQuerySQLResult

func MarshalActionQuerySQLResult(columns []string, rows [][]interface{}) ([]byte, error)

MarshalActionQuerySQLResult returns serialized form of query Action SQL result.

It supports the following types:

  • untyped nil;
  • bool;
  • int, int8, int16, int32, int64;
  • uint, uint8, uint16, uint32, uint64;
  • float32, float64;
  • string, []byte;
  • time.Time;
  • []T for any T from above, including other slices and maps;
  • map[string]T for any T from above, including other slices and maps.

func RegisterAgentServer

func RegisterAgentServer(s *grpc.Server, srv AgentServer)

func SendServerConnectMetadata

func SendServerConnectMetadata(stream grpc.ServerStream, md *ServerConnectMetadata) error

SendServerConnectMetadata sends pmm-managed's metadata. Used by pmm-managed.

func UnmarshalActionQueryResult

func UnmarshalActionQueryResult(b []byte) ([]map[string]interface{}, error)

UnmarshalActionQueryResult returns deserialized form of query Action result, both SQL and documents.

Types

type ActionResultRequest

type ActionResultRequest struct {

	// Unique action ID.
	ActionId string `protobuf:"bytes,1,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
	// New chunk of action output.
	Output []byte `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
}

ActionResultRequest is an AgentMessage containing action run status and new chunk of output.

func (*ActionResultRequest) AgentMessageRequestPayload

func (m *ActionResultRequest) AgentMessageRequestPayload() isAgentMessage_Payload

func (*ActionResultRequest) Descriptor deprecated

func (*ActionResultRequest) Descriptor() ([]byte, []int)

Deprecated: Use ActionResultRequest.ProtoReflect.Descriptor instead.

func (*ActionResultRequest) GetActionId

func (x *ActionResultRequest) GetActionId() string

func (*ActionResultRequest) GetDone

func (x *ActionResultRequest) GetDone() bool

func (*ActionResultRequest) GetError

func (x *ActionResultRequest) GetError() string

func (*ActionResultRequest) GetOutput

func (x *ActionResultRequest) GetOutput() []byte

func (*ActionResultRequest) ProtoMessage

func (*ActionResultRequest) ProtoMessage()

func (*ActionResultRequest) ProtoReflect

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

func (*ActionResultRequest) Reset

func (x *ActionResultRequest) Reset()

func (*ActionResultRequest) String

func (x *ActionResultRequest) String() string

func (*ActionResultRequest) Validate

func (this *ActionResultRequest) Validate() error

type ActionResultResponse

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

ActionResultResponse is an ServerMessage for ActionResultRequest acceptance.

func (*ActionResultResponse) Descriptor deprecated

func (*ActionResultResponse) Descriptor() ([]byte, []int)

Deprecated: Use ActionResultResponse.ProtoReflect.Descriptor instead.

func (*ActionResultResponse) ProtoMessage

func (*ActionResultResponse) ProtoMessage()

func (*ActionResultResponse) ProtoReflect

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

func (*ActionResultResponse) Reset

func (x *ActionResultResponse) Reset()

func (*ActionResultResponse) ServerMessageResponsePayload

func (m *ActionResultResponse) ServerMessageResponsePayload() isServerMessage_Payload

func (*ActionResultResponse) String

func (x *ActionResultResponse) String() string

func (*ActionResultResponse) Validate

func (this *ActionResultResponse) Validate() error

type AgentClient

type AgentClient interface {
	// Connect establishes two-way communication channel between pmm-agent and pmm-managed.
	Connect(ctx context.Context, opts ...grpc.CallOption) (Agent_ConnectClient, error)
}

AgentClient is the client API for Agent service.

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

func NewAgentClient

func NewAgentClient(cc grpc.ClientConnInterface) AgentClient

type AgentConnectMetadata

type AgentConnectMetadata struct {
	ID          string
	Version     string
	MetricsPort uint16
}

AgentConnectMetadata represents metadata sent by pmm-agent with Connect RPC method call.

func ReceiveAgentConnectMetadata

func ReceiveAgentConnectMetadata(stream grpc.ServerStream) (*AgentConnectMetadata, error)

ReceiveAgentConnectMetadata receives pmm-agent's metadata. Used by pmm-managed.

type AgentMessage

type AgentMessage struct {
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// The responder sets the status field in two situations:
	// 1. When it received a request with the payload field not set.
	//    That means that responded is older than the requester, and doesn't know about newer payload types.
	//    Status code UNIMPLEMENTED (12) is reserved for that case.
	// 2. When the payload is set, but the request can't be performed due to some error.
	Status *status.Status `protobuf:"bytes,2047,opt,name=status,proto3" json:"status,omitempty"`
	// Types that are assignable to Payload:
	//	*AgentMessage_Ping
	//	*AgentMessage_StateChanged
	//	*AgentMessage_QanCollect
	//	*AgentMessage_ActionResult
	//	*AgentMessage_Pong
	//	*AgentMessage_SetState
	//	*AgentMessage_StartAction
	//	*AgentMessage_StopAction
	//	*AgentMessage_CheckConnection
	//	*AgentMessage_StartJob
	//	*AgentMessage_StopJob
	//	*AgentMessage_JobStatus
	//	*AgentMessage_JobResult
	//	*AgentMessage_JobProgress
	Payload isAgentMessage_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*AgentMessage) Descriptor deprecated

func (*AgentMessage) Descriptor() ([]byte, []int)

Deprecated: Use AgentMessage.ProtoReflect.Descriptor instead.

func (*AgentMessage) GetActionResult

func (x *AgentMessage) GetActionResult() *ActionResultRequest

func (*AgentMessage) GetCheckConnection

func (x *AgentMessage) GetCheckConnection() *CheckConnectionResponse

func (*AgentMessage) GetId

func (x *AgentMessage) GetId() uint32

func (*AgentMessage) GetJobProgress

func (x *AgentMessage) GetJobProgress() *JobProgress

func (*AgentMessage) GetJobResult

func (x *AgentMessage) GetJobResult() *JobResult

func (*AgentMessage) GetJobStatus

func (x *AgentMessage) GetJobStatus() *JobStatusResponse

func (*AgentMessage) GetPayload

func (m *AgentMessage) GetPayload() isAgentMessage_Payload

func (*AgentMessage) GetPing

func (x *AgentMessage) GetPing() *Ping

func (*AgentMessage) GetPong

func (x *AgentMessage) GetPong() *Pong

func (*AgentMessage) GetQanCollect

func (x *AgentMessage) GetQanCollect() *QANCollectRequest

func (*AgentMessage) GetSetState

func (x *AgentMessage) GetSetState() *SetStateResponse

func (*AgentMessage) GetStartAction

func (x *AgentMessage) GetStartAction() *StartActionResponse

func (*AgentMessage) GetStartJob

func (x *AgentMessage) GetStartJob() *StartJobResponse

func (*AgentMessage) GetStateChanged

func (x *AgentMessage) GetStateChanged() *StateChangedRequest

func (*AgentMessage) GetStatus

func (x *AgentMessage) GetStatus() *status.Status

func (*AgentMessage) GetStopAction

func (x *AgentMessage) GetStopAction() *StopActionResponse

func (*AgentMessage) GetStopJob

func (x *AgentMessage) GetStopJob() *StopJobResponse

func (*AgentMessage) ProtoMessage

func (*AgentMessage) ProtoMessage()

func (*AgentMessage) ProtoReflect

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

func (*AgentMessage) Reset

func (x *AgentMessage) Reset()

func (*AgentMessage) String

func (x *AgentMessage) String() string

func (*AgentMessage) Validate

func (this *AgentMessage) Validate() error

type AgentMessage_ActionResult

type AgentMessage_ActionResult struct {
	ActionResult *ActionResultRequest `protobuf:"bytes,5,opt,name=action_result,json=actionResult,proto3,oneof"`
}

type AgentMessage_CheckConnection

type AgentMessage_CheckConnection struct {
	CheckConnection *CheckConnectionResponse `protobuf:"bytes,12,opt,name=check_connection,json=checkConnection,proto3,oneof"`
}

type AgentMessage_JobProgress

type AgentMessage_JobProgress struct {
	JobProgress *JobProgress `protobuf:"bytes,17,opt,name=job_progress,json=jobProgress,proto3,oneof"`
}

type AgentMessage_JobResult

type AgentMessage_JobResult struct {
	JobResult *JobResult `protobuf:"bytes,16,opt,name=job_result,json=jobResult,proto3,oneof"`
}

type AgentMessage_JobStatus

type AgentMessage_JobStatus struct {
	JobStatus *JobStatusResponse `protobuf:"bytes,15,opt,name=job_status,json=jobStatus,proto3,oneof"`
}

type AgentMessage_Ping

type AgentMessage_Ping struct {
	// requests from agent
	Ping *Ping `protobuf:"bytes,2,opt,name=ping,proto3,oneof"`
}

type AgentMessage_Pong

type AgentMessage_Pong struct {
	// responses from agent
	Pong *Pong `protobuf:"bytes,8,opt,name=pong,proto3,oneof"`
}

type AgentMessage_QanCollect

type AgentMessage_QanCollect struct {
	QanCollect *QANCollectRequest `protobuf:"bytes,4,opt,name=qan_collect,json=qanCollect,proto3,oneof"`
}

type AgentMessage_SetState

type AgentMessage_SetState struct {
	SetState *SetStateResponse `protobuf:"bytes,9,opt,name=set_state,json=setState,proto3,oneof"`
}

type AgentMessage_StartAction

type AgentMessage_StartAction struct {
	StartAction *StartActionResponse `protobuf:"bytes,10,opt,name=start_action,json=startAction,proto3,oneof"`
}

type AgentMessage_StartJob

type AgentMessage_StartJob struct {
	StartJob *StartJobResponse `protobuf:"bytes,13,opt,name=start_job,json=startJob,proto3,oneof"`
}

type AgentMessage_StateChanged

type AgentMessage_StateChanged struct {
	StateChanged *StateChangedRequest `protobuf:"bytes,3,opt,name=state_changed,json=stateChanged,proto3,oneof"`
}

type AgentMessage_StopAction

type AgentMessage_StopAction struct {
	StopAction *StopActionResponse `protobuf:"bytes,11,opt,name=stop_action,json=stopAction,proto3,oneof"`
}

type AgentMessage_StopJob

type AgentMessage_StopJob struct {
	StopJob *StopJobResponse `protobuf:"bytes,14,opt,name=stop_job,json=stopJob,proto3,oneof"`
}

type AgentParams

type AgentParams interface {
	proto.Message
	// contains filtered or unexported methods
}

AgentParams is a common interface for AgentProcess and BuiltinAgent parameters.

type AgentRequestPayload

type AgentRequestPayload interface {
	AgentMessageRequestPayload() isAgentMessage_Payload
	// contains filtered or unexported methods
}

AgentRequestPayload represents agent's request payload.

type AgentResponsePayload

type AgentResponsePayload interface {
	AgentMessageResponsePayload() isAgentMessage_Payload
	// contains filtered or unexported methods
}

AgentResponsePayload represents agent's response payload.

type AgentServer

type AgentServer interface {
	// Connect establishes two-way communication channel between pmm-agent and pmm-managed.
	Connect(Agent_ConnectServer) error
}

AgentServer is the server API for Agent service.

type Agent_ConnectClient

type Agent_ConnectClient interface {
	Send(*AgentMessage) error
	Recv() (*ServerMessage, error)
	grpc.ClientStream
}

type Agent_ConnectServer

type Agent_ConnectServer interface {
	Send(*ServerMessage) error
	Recv() (*AgentMessage, error)
	grpc.ServerStream
}

type CheckConnectionRequest

type CheckConnectionRequest struct {

	// Service type.
	Type inventorypb.ServiceType `protobuf:"varint,1,opt,name=type,proto3,enum=inventory.ServiceType" json:"type,omitempty"`
	// DSN for the service. May contain connection (dial) timeout.
	Dsn string `protobuf:"bytes,2,opt,name=dsn,proto3" json:"dsn,omitempty"`
	// Timeout for the whole request.
	Timeout *duration.Duration `protobuf:"bytes,3,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// Contains files and their contents which can be used in DSN.
	TextFiles *TextFiles `protobuf:"bytes,4,opt,name=text_files,json=textFiles,proto3" json:"text_files,omitempty"`
	// TLS certificate wont be verified.
	TlsSkipVerify bool `protobuf:"varint,5,opt,name=tls_skip_verify,json=tlsSkipVerify,proto3" json:"tls_skip_verify,omitempty"`
	// contains filtered or unexported fields
}

CheckConnectionRequest is a ServerMessage asking pmm-agent to check connection with Service.

func (*CheckConnectionRequest) Descriptor deprecated

func (*CheckConnectionRequest) Descriptor() ([]byte, []int)

Deprecated: Use CheckConnectionRequest.ProtoReflect.Descriptor instead.

func (*CheckConnectionRequest) GetDsn

func (x *CheckConnectionRequest) GetDsn() string

func (*CheckConnectionRequest) GetTextFiles

func (x *CheckConnectionRequest) GetTextFiles() *TextFiles

func (*CheckConnectionRequest) GetTimeout

func (x *CheckConnectionRequest) GetTimeout() *duration.Duration

func (*CheckConnectionRequest) GetTlsSkipVerify

func (x *CheckConnectionRequest) GetTlsSkipVerify() bool

func (*CheckConnectionRequest) GetType

func (*CheckConnectionRequest) ProtoMessage

func (*CheckConnectionRequest) ProtoMessage()

func (*CheckConnectionRequest) ProtoReflect

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

func (*CheckConnectionRequest) Reset

func (x *CheckConnectionRequest) Reset()

func (*CheckConnectionRequest) ServerMessageRequestPayload

func (m *CheckConnectionRequest) ServerMessageRequestPayload() isServerMessage_Payload

func (*CheckConnectionRequest) String

func (x *CheckConnectionRequest) String() string

func (*CheckConnectionRequest) Validate

func (this *CheckConnectionRequest) Validate() error

type CheckConnectionResponse

type CheckConnectionResponse struct {

	// Error message if connection check failed.
	Error string                         `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Stats *CheckConnectionResponse_Stats `protobuf:"bytes,2,opt,name=stats,proto3" json:"stats,omitempty"`
	// contains filtered or unexported fields
}

CheckConnectionResponse is an AgentMessage containing a result of connection check.

func (*CheckConnectionResponse) AgentMessageResponsePayload

func (m *CheckConnectionResponse) AgentMessageResponsePayload() isAgentMessage_Payload

func (*CheckConnectionResponse) Descriptor deprecated

func (*CheckConnectionResponse) Descriptor() ([]byte, []int)

Deprecated: Use CheckConnectionResponse.ProtoReflect.Descriptor instead.

func (*CheckConnectionResponse) GetError

func (x *CheckConnectionResponse) GetError() string

func (*CheckConnectionResponse) GetStats

func (*CheckConnectionResponse) ProtoMessage

func (*CheckConnectionResponse) ProtoMessage()

func (*CheckConnectionResponse) ProtoReflect

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

func (*CheckConnectionResponse) Reset

func (x *CheckConnectionResponse) Reset()

func (*CheckConnectionResponse) String

func (x *CheckConnectionResponse) String() string

func (*CheckConnectionResponse) Validate

func (this *CheckConnectionResponse) Validate() error

type CheckConnectionResponse_Stats

type CheckConnectionResponse_Stats struct {

	// A number of tables, 0 if unknown.
	TableCount int32 `protobuf:"varint,1,opt,name=table_count,json=tableCount,proto3" json:"table_count,omitempty"`
	// contains filtered or unexported fields
}

Stats contains various Service statistics.

func (*CheckConnectionResponse_Stats) Descriptor deprecated

func (*CheckConnectionResponse_Stats) Descriptor() ([]byte, []int)

Deprecated: Use CheckConnectionResponse_Stats.ProtoReflect.Descriptor instead.

func (*CheckConnectionResponse_Stats) GetTableCount

func (x *CheckConnectionResponse_Stats) GetTableCount() int32

func (*CheckConnectionResponse_Stats) ProtoMessage

func (*CheckConnectionResponse_Stats) ProtoMessage()

func (*CheckConnectionResponse_Stats) ProtoReflect

func (*CheckConnectionResponse_Stats) Reset

func (x *CheckConnectionResponse_Stats) Reset()

func (*CheckConnectionResponse_Stats) String

func (*CheckConnectionResponse_Stats) Validate

func (this *CheckConnectionResponse_Stats) Validate() error

type ExampleFormat deprecated

type ExampleFormat int32

ExampleFormat is format of query example: real or query without values.

Deprecated: is not used, should not be used, should be removed.

const (
	// Deprecated: Do not use.
	ExampleFormat_EXAMPLE_FORMAT_INVALID ExampleFormat = 0
	// Deprecated: Do not use.
	ExampleFormat_EXAMPLE ExampleFormat = 1
	// Deprecated: Do not use.
	ExampleFormat_FINGERPRINT ExampleFormat = 2
)

func (ExampleFormat) Descriptor

func (ExampleFormat) Enum

func (x ExampleFormat) Enum() *ExampleFormat

func (ExampleFormat) EnumDescriptor deprecated

func (ExampleFormat) EnumDescriptor() ([]byte, []int)

Deprecated: Use ExampleFormat.Descriptor instead.

func (ExampleFormat) Number

func (ExampleFormat) String

func (x ExampleFormat) String() string

func (ExampleFormat) Type

type ExampleType

type ExampleType int32

ExampleType is a type of query example selected for this query class in given period of time.

const (
	ExampleType_EXAMPLE_TYPE_INVALID ExampleType = 0
	ExampleType_RANDOM               ExampleType = 1
	ExampleType_SLOWEST              ExampleType = 2
	ExampleType_FASTEST              ExampleType = 3
	ExampleType_WITH_ERROR           ExampleType = 4
)

func (ExampleType) Descriptor

func (ExampleType) Enum

func (x ExampleType) Enum() *ExampleType

func (ExampleType) EnumDescriptor deprecated

func (ExampleType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ExampleType.Descriptor instead.

func (ExampleType) Number

func (x ExampleType) Number() protoreflect.EnumNumber

func (ExampleType) String

func (x ExampleType) String() string

func (ExampleType) Type

type JobProgress

type JobProgress struct {
	JobId     string               `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	Timestamp *timestamp.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Types that are assignable to Result:
	//	*JobProgress_Echo_
	//	*JobProgress_MysqlBackup
	//	*JobProgress_MysqlRestoreBackup
	Result isJobProgress_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

JobProgress represents job progress messages like percentage of completion, status updates, etc.

func (*JobProgress) AgentMessageRequestPayload

func (m *JobProgress) AgentMessageRequestPayload() isAgentMessage_Payload

func (*JobProgress) AgentMessageResponsePayload

func (m *JobProgress) AgentMessageResponsePayload() isAgentMessage_Payload

func (*JobProgress) Descriptor deprecated

func (*JobProgress) Descriptor() ([]byte, []int)

Deprecated: Use JobProgress.ProtoReflect.Descriptor instead.

func (*JobProgress) GetEcho

func (x *JobProgress) GetEcho() *JobProgress_Echo

func (*JobProgress) GetJobId

func (x *JobProgress) GetJobId() string

func (*JobProgress) GetMysqlBackup

func (x *JobProgress) GetMysqlBackup() *JobProgress_MySQLBackup

func (*JobProgress) GetMysqlRestoreBackup

func (x *JobProgress) GetMysqlRestoreBackup() *JobProgress_MySQLRestoreBackup

func (*JobProgress) GetResult

func (m *JobProgress) GetResult() isJobProgress_Result

func (*JobProgress) GetTimestamp

func (x *JobProgress) GetTimestamp() *timestamp.Timestamp

func (*JobProgress) ProtoMessage

func (*JobProgress) ProtoMessage()

func (*JobProgress) ProtoReflect

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

func (*JobProgress) Reset

func (x *JobProgress) Reset()

func (*JobProgress) String

func (x *JobProgress) String() string

func (*JobProgress) Validate

func (this *JobProgress) Validate() error

type JobProgress_Echo

type JobProgress_Echo struct {
	Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

Echo contains echo job status update.

func (*JobProgress_Echo) Descriptor deprecated

func (*JobProgress_Echo) Descriptor() ([]byte, []int)

Deprecated: Use JobProgress_Echo.ProtoReflect.Descriptor instead.

func (*JobProgress_Echo) GetStatus

func (x *JobProgress_Echo) GetStatus() string

func (*JobProgress_Echo) ProtoMessage

func (*JobProgress_Echo) ProtoMessage()

func (*JobProgress_Echo) ProtoReflect

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

func (*JobProgress_Echo) Reset

func (x *JobProgress_Echo) Reset()

func (*JobProgress_Echo) String

func (x *JobProgress_Echo) String() string

func (*JobProgress_Echo) Validate

func (this *JobProgress_Echo) Validate() error

type JobProgress_Echo_

type JobProgress_Echo_ struct {
	Echo *JobProgress_Echo `protobuf:"bytes,10,opt,name=echo,proto3,oneof"`
}

type JobProgress_MySQLBackup

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

MySQLBackup contains backup job status update.

func (*JobProgress_MySQLBackup) Descriptor deprecated

func (*JobProgress_MySQLBackup) Descriptor() ([]byte, []int)

Deprecated: Use JobProgress_MySQLBackup.ProtoReflect.Descriptor instead.

func (*JobProgress_MySQLBackup) ProtoMessage

func (*JobProgress_MySQLBackup) ProtoMessage()

func (*JobProgress_MySQLBackup) ProtoReflect

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

func (*JobProgress_MySQLBackup) Reset

func (x *JobProgress_MySQLBackup) Reset()

func (*JobProgress_MySQLBackup) String

func (x *JobProgress_MySQLBackup) String() string

func (*JobProgress_MySQLBackup) Validate

func (this *JobProgress_MySQLBackup) Validate() error

type JobProgress_MySQLRestoreBackup

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

MySQLRestoreBackup contains restore backup job status update.

func (*JobProgress_MySQLRestoreBackup) Descriptor deprecated

func (*JobProgress_MySQLRestoreBackup) Descriptor() ([]byte, []int)

Deprecated: Use JobProgress_MySQLRestoreBackup.ProtoReflect.Descriptor instead.

func (*JobProgress_MySQLRestoreBackup) ProtoMessage

func (*JobProgress_MySQLRestoreBackup) ProtoMessage()

func (*JobProgress_MySQLRestoreBackup) ProtoReflect

func (*JobProgress_MySQLRestoreBackup) Reset

func (x *JobProgress_MySQLRestoreBackup) Reset()

func (*JobProgress_MySQLRestoreBackup) String

func (*JobProgress_MySQLRestoreBackup) Validate

func (this *JobProgress_MySQLRestoreBackup) Validate() error

type JobProgress_MysqlBackup

type JobProgress_MysqlBackup struct {
	MysqlBackup *JobProgress_MySQLBackup `protobuf:"bytes,11,opt,name=mysql_backup,json=mysqlBackup,proto3,oneof"`
}

type JobProgress_MysqlRestoreBackup

type JobProgress_MysqlRestoreBackup struct {
	MysqlRestoreBackup *JobProgress_MySQLRestoreBackup `protobuf:"bytes,12,opt,name=mysql_restore_backup,json=mysqlRestoreBackup,proto3,oneof"`
}

type JobResult

type JobResult struct {
	JobId     string               `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	Timestamp *timestamp.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Types that are assignable to Result:
	//	*JobResult_Error_
	//	*JobResult_Echo_
	//	*JobResult_MysqlBackup
	//	*JobResult_MysqlRestoreBackup
	Result isJobResult_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

JobResult represents job result.

func (*JobResult) AgentMessageRequestPayload

func (m *JobResult) AgentMessageRequestPayload() isAgentMessage_Payload

func (*JobResult) AgentMessageResponsePayload

func (m *JobResult) AgentMessageResponsePayload() isAgentMessage_Payload

func (*JobResult) Descriptor deprecated

func (*JobResult) Descriptor() ([]byte, []int)

Deprecated: Use JobResult.ProtoReflect.Descriptor instead.

func (*JobResult) GetEcho

func (x *JobResult) GetEcho() *JobResult_Echo

func (*JobResult) GetError

func (x *JobResult) GetError() *JobResult_Error

func (*JobResult) GetJobId

func (x *JobResult) GetJobId() string

func (*JobResult) GetMysqlBackup

func (x *JobResult) GetMysqlBackup() *JobResult_MySQLBackup

func (*JobResult) GetMysqlRestoreBackup

func (x *JobResult) GetMysqlRestoreBackup() *JobResult_MySQLRestoreBackup

func (*JobResult) GetResult

func (m *JobResult) GetResult() isJobResult_Result

func (*JobResult) GetTimestamp

func (x *JobResult) GetTimestamp() *timestamp.Timestamp

func (*JobResult) ProtoMessage

func (*JobResult) ProtoMessage()

func (*JobResult) ProtoReflect

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

func (*JobResult) Reset

func (x *JobResult) Reset()

func (*JobResult) String

func (x *JobResult) String() string

func (*JobResult) Validate

func (this *JobResult) Validate() error

type JobResult_Echo

type JobResult_Echo struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

Echo contains result for echo job.

func (*JobResult_Echo) Descriptor deprecated

func (*JobResult_Echo) Descriptor() ([]byte, []int)

Deprecated: Use JobResult_Echo.ProtoReflect.Descriptor instead.

func (*JobResult_Echo) GetMessage

func (x *JobResult_Echo) GetMessage() string

func (*JobResult_Echo) ProtoMessage

func (*JobResult_Echo) ProtoMessage()

func (*JobResult_Echo) ProtoReflect

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

func (*JobResult_Echo) Reset

func (x *JobResult_Echo) Reset()

func (*JobResult_Echo) String

func (x *JobResult_Echo) String() string

func (*JobResult_Echo) Validate

func (this *JobResult_Echo) Validate() error

type JobResult_Echo_

type JobResult_Echo_ struct {
	Echo *JobResult_Echo `protobuf:"bytes,11,opt,name=echo,proto3,oneof"`
}

type JobResult_Error

type JobResult_Error struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

Error contains job error message.

func (*JobResult_Error) Descriptor deprecated

func (*JobResult_Error) Descriptor() ([]byte, []int)

Deprecated: Use JobResult_Error.ProtoReflect.Descriptor instead.

func (*JobResult_Error) GetMessage

func (x *JobResult_Error) GetMessage() string

func (*JobResult_Error) ProtoMessage

func (*JobResult_Error) ProtoMessage()

func (*JobResult_Error) ProtoReflect

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

func (*JobResult_Error) Reset

func (x *JobResult_Error) Reset()

func (*JobResult_Error) String

func (x *JobResult_Error) String() string

func (*JobResult_Error) Validate

func (this *JobResult_Error) Validate() error

type JobResult_Error_

type JobResult_Error_ struct {
	Error *JobResult_Error `protobuf:"bytes,10,opt,name=error,proto3,oneof"`
}

type JobResult_MySQLBackup

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

MySQLBackup contains result for MySQL backup job.

func (*JobResult_MySQLBackup) Descriptor deprecated

func (*JobResult_MySQLBackup) Descriptor() ([]byte, []int)

Deprecated: Use JobResult_MySQLBackup.ProtoReflect.Descriptor instead.

func (*JobResult_MySQLBackup) ProtoMessage

func (*JobResult_MySQLBackup) ProtoMessage()

func (*JobResult_MySQLBackup) ProtoReflect

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

func (*JobResult_MySQLBackup) Reset

func (x *JobResult_MySQLBackup) Reset()

func (*JobResult_MySQLBackup) String

func (x *JobResult_MySQLBackup) String() string

func (*JobResult_MySQLBackup) Validate

func (this *JobResult_MySQLBackup) Validate() error

type JobResult_MySQLRestoreBackup

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

MySQLRestoreBackup contains result for MySQL restore backup job.

func (*JobResult_MySQLRestoreBackup) Descriptor deprecated

func (*JobResult_MySQLRestoreBackup) Descriptor() ([]byte, []int)

Deprecated: Use JobResult_MySQLRestoreBackup.ProtoReflect.Descriptor instead.

func (*JobResult_MySQLRestoreBackup) ProtoMessage

func (*JobResult_MySQLRestoreBackup) ProtoMessage()

func (*JobResult_MySQLRestoreBackup) ProtoReflect

func (*JobResult_MySQLRestoreBackup) Reset

func (x *JobResult_MySQLRestoreBackup) Reset()

func (*JobResult_MySQLRestoreBackup) String

func (*JobResult_MySQLRestoreBackup) Validate

func (this *JobResult_MySQLRestoreBackup) Validate() error

type JobResult_MysqlBackup

type JobResult_MysqlBackup struct {
	MysqlBackup *JobResult_MySQLBackup `protobuf:"bytes,12,opt,name=mysql_backup,json=mysqlBackup,proto3,oneof"`
}

type JobResult_MysqlRestoreBackup

type JobResult_MysqlRestoreBackup struct {
	MysqlRestoreBackup *JobResult_MySQLRestoreBackup `protobuf:"bytes,13,opt,name=mysql_restore_backup,json=mysqlRestoreBackup,proto3,oneof"`
}

type JobStatusRequest

type JobStatusRequest struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

JobStatusRequest is a ServerMessage asking pmm-agent for job status.

func (*JobStatusRequest) Descriptor deprecated

func (*JobStatusRequest) Descriptor() ([]byte, []int)

Deprecated: Use JobStatusRequest.ProtoReflect.Descriptor instead.

func (*JobStatusRequest) GetJobId

func (x *JobStatusRequest) GetJobId() string

func (*JobStatusRequest) ProtoMessage

func (*JobStatusRequest) ProtoMessage()

func (*JobStatusRequest) ProtoReflect

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

func (*JobStatusRequest) Reset

func (x *JobStatusRequest) Reset()

func (*JobStatusRequest) ServerMessageRequestPayload

func (m *JobStatusRequest) ServerMessageRequestPayload() isServerMessage_Payload

func (*JobStatusRequest) String

func (x *JobStatusRequest) String() string

func (*JobStatusRequest) Validate

func (this *JobStatusRequest) Validate() error

type JobStatusResponse

type JobStatusResponse struct {
	Alive bool `protobuf:"varint,1,opt,name=alive,proto3" json:"alive,omitempty"`
	// contains filtered or unexported fields
}

JobStatusResponse is an AgentMessage containing job status.

func (*JobStatusResponse) AgentMessageResponsePayload

func (m *JobStatusResponse) AgentMessageResponsePayload() isAgentMessage_Payload

func (*JobStatusResponse) Descriptor deprecated

func (*JobStatusResponse) Descriptor() ([]byte, []int)

Deprecated: Use JobStatusResponse.ProtoReflect.Descriptor instead.

func (*JobStatusResponse) GetAlive

func (x *JobStatusResponse) GetAlive() bool

func (*JobStatusResponse) ProtoMessage

func (*JobStatusResponse) ProtoMessage()

func (*JobStatusResponse) ProtoReflect

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

func (*JobStatusResponse) Reset

func (x *JobStatusResponse) Reset()

func (*JobStatusResponse) String

func (x *JobStatusResponse) String() string

func (*JobStatusResponse) Validate

func (this *JobStatusResponse) Validate() error

type MetricsBucket

type MetricsBucket struct {
	Common     *MetricsBucket_Common     `protobuf:"bytes,1,opt,name=common,proto3" json:"common,omitempty"`
	Mysql      *MetricsBucket_MySQL      `protobuf:"bytes,2,opt,name=mysql,proto3" json:"mysql,omitempty"`
	Mongodb    *MetricsBucket_MongoDB    `protobuf:"bytes,3,opt,name=mongodb,proto3" json:"mongodb,omitempty"`
	Postgresql *MetricsBucket_PostgreSQL `protobuf:"bytes,4,opt,name=postgresql,proto3" json:"postgresql,omitempty"`
	// contains filtered or unexported fields
}

MetricsBucket is aggregated message created by pmm-agent. Contains information about one query selected in defined way from query class in specific period of time.

func (*MetricsBucket) Descriptor deprecated

func (*MetricsBucket) Descriptor() ([]byte, []int)

Deprecated: Use MetricsBucket.ProtoReflect.Descriptor instead.

func (*MetricsBucket) GetCommon

func (x *MetricsBucket) GetCommon() *MetricsBucket_Common

func (*MetricsBucket) GetMongodb

func (x *MetricsBucket) GetMongodb() *MetricsBucket_MongoDB

func (*MetricsBucket) GetMysql

func (x *MetricsBucket) GetMysql() *MetricsBucket_MySQL

func (*MetricsBucket) GetPostgresql

func (x *MetricsBucket) GetPostgresql() *MetricsBucket_PostgreSQL

func (*MetricsBucket) ProtoMessage

func (*MetricsBucket) ProtoMessage()

func (*MetricsBucket) ProtoReflect

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

func (*MetricsBucket) Reset

func (x *MetricsBucket) Reset()

func (*MetricsBucket) String

func (x *MetricsBucket) String() string

func (*MetricsBucket) Validate

func (this *MetricsBucket) Validate() error

type MetricsBucket_Common

type MetricsBucket_Common struct {

	// md5 of digest_text/fingerprint.
	Queryid string `protobuf:"bytes,1,opt,name=queryid,proto3" json:"queryid,omitempty"`
	// digest_text - query signature. Query without values.
	Fingerprint string `protobuf:"bytes,2,opt,name=fingerprint,proto3" json:"fingerprint,omitempty"`
	//
	// Dimension Group.
	//
	// MongoDB or PostgreSQL database.
	// Several databases can't be combined in a single declarative query.
	Database string `protobuf:"bytes,3,opt,name=database,proto3" json:"database,omitempty"`
	// MySQL database or PostgreSQL schema.
	// Several schemas can be combined in a single declarative query.
	Schema string `protobuf:"bytes,4,opt,name=schema,proto3" json:"schema,omitempty"`
	// Tables or Collections list.
	Tables []string `protobuf:"bytes,5,rep,name=tables,proto3" json:"tables,omitempty"`
	// client user name.
	Username string `protobuf:"bytes,6,opt,name=username,proto3" json:"username,omitempty"`
	// client IP or hostname.
	ClientHost string `protobuf:"bytes,7,opt,name=client_host,json=clientHost,proto3" json:"client_host,omitempty"`
	// Identifier of agent that collect and send metrics.
	AgentId string `protobuf:"bytes,8,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	// Metrics source.
	AgentType inventorypb.AgentType `protobuf:"varint,9,opt,name=agent_type,json=agentType,proto3,enum=inventory.AgentType" json:"agent_type,omitempty"`
	// Time when collection of bucket started.
	PeriodStartUnixSecs uint32 `protobuf:"varint,10,opt,name=period_start_unix_secs,json=periodStartUnixSecs,proto3" json:"period_start_unix_secs,omitempty"`
	// Duration of bucket.
	PeriodLengthSecs uint32 `protobuf:"varint,11,opt,name=period_length_secs,json=periodLengthSecs,proto3" json:"period_length_secs,omitempty"`
	// One of query example from set found in bucket.
	Example string `protobuf:"bytes,12,opt,name=example,proto3" json:"example,omitempty"`
	// Deprecated: should not be used, should be removed.
	//
	// Deprecated: Do not use.
	ExampleFormat ExampleFormat `` /* 127-byte string literal not displayed */
	ExampleType   ExampleType   `protobuf:"varint,14,opt,name=example_type,json=exampleType,proto3,enum=agent.ExampleType" json:"example_type,omitempty"`
	// Indicates if the query example is truncated.
	IsTruncated bool `protobuf:"varint,24,opt,name=is_truncated,json=isTruncated,proto3" json:"is_truncated,omitempty"`
	// How many queries was with warnings in bucket.
	NumQueriesWithWarnings float32 `` /* 134-byte string literal not displayed */
	// How many queries was with error in bucket.
	NumQueriesWithErrors float32 `` /* 128-byte string literal not displayed */
	// List of errors: {code: count}.
	Errors map[uint64]uint64 `` /* 156-byte string literal not displayed */
	// Amount queries in this bucket.
	NumQueries float32 `protobuf:"fixed32,18,opt,name=num_queries,json=numQueries,proto3" json:"num_queries,omitempty"`
	// How many times query_time was found.
	MQueryTimeCnt float32 `protobuf:"fixed32,19,opt,name=m_query_time_cnt,json=mQueryTimeCnt,proto3" json:"m_query_time_cnt,omitempty"`
	// The statement execution time in seconds.
	MQueryTimeSum float32 `protobuf:"fixed32,20,opt,name=m_query_time_sum,json=mQueryTimeSum,proto3" json:"m_query_time_sum,omitempty"`
	// Smallest value of query_time in bucket.
	MQueryTimeMin float32 `protobuf:"fixed32,21,opt,name=m_query_time_min,json=mQueryTimeMin,proto3" json:"m_query_time_min,omitempty"`
	// Biggest value of query_time in bucket.
	MQueryTimeMax float32 `protobuf:"fixed32,22,opt,name=m_query_time_max,json=mQueryTimeMax,proto3" json:"m_query_time_max,omitempty"`
	// 99 percentile of value of query_time in bucket.
	MQueryTimeP99 float32 `protobuf:"fixed32,23,opt,name=m_query_time_p99,json=mQueryTimeP99,proto3" json:"m_query_time_p99,omitempty"`
	// contains filtered or unexported fields
}

Common contains common fields for all DBs.

func (*MetricsBucket_Common) Descriptor deprecated

func (*MetricsBucket_Common) Descriptor() ([]byte, []int)

Deprecated: Use MetricsBucket_Common.ProtoReflect.Descriptor instead.

func (*MetricsBucket_Common) GetAgentId

func (x *MetricsBucket_Common) GetAgentId() string

func (*MetricsBucket_Common) GetAgentType

func (x *MetricsBucket_Common) GetAgentType() inventorypb.AgentType

func (*MetricsBucket_Common) GetClientHost

func (x *MetricsBucket_Common) GetClientHost() string

func (*MetricsBucket_Common) GetDatabase

func (x *MetricsBucket_Common) GetDatabase() string

func (*MetricsBucket_Common) GetErrors

func (x *MetricsBucket_Common) GetErrors() map[uint64]uint64

func (*MetricsBucket_Common) GetExample

func (x *MetricsBucket_Common) GetExample() string

func (*MetricsBucket_Common) GetExampleFormat deprecated

func (x *MetricsBucket_Common) GetExampleFormat() ExampleFormat

Deprecated: Do not use.

func (*MetricsBucket_Common) GetExampleType

func (x *MetricsBucket_Common) GetExampleType() ExampleType

func (*MetricsBucket_Common) GetFingerprint

func (x *MetricsBucket_Common) GetFingerprint() string

func (*MetricsBucket_Common) GetIsTruncated

func (x *MetricsBucket_Common) GetIsTruncated() bool

func (*MetricsBucket_Common) GetMQueryTimeCnt

func (x *MetricsBucket_Common) GetMQueryTimeCnt() float32

func (*MetricsBucket_Common) GetMQueryTimeMax

func (x *MetricsBucket_Common) GetMQueryTimeMax() float32

func (*MetricsBucket_Common) GetMQueryTimeMin

func (x *MetricsBucket_Common) GetMQueryTimeMin() float32

func (*MetricsBucket_Common) GetMQueryTimeP99

func (x *MetricsBucket_Common) GetMQueryTimeP99() float32

func (*MetricsBucket_Common) GetMQueryTimeSum

func (x *MetricsBucket_Common) GetMQueryTimeSum() float32

func (*MetricsBucket_Common) GetNumQueries

func (x *MetricsBucket_Common) GetNumQueries() float32

func (*MetricsBucket_Common) GetNumQueriesWithErrors

func (x *MetricsBucket_Common) GetNumQueriesWithErrors() float32

func (*MetricsBucket_Common) GetNumQueriesWithWarnings

func (x *MetricsBucket_Common) GetNumQueriesWithWarnings() float32

func (*MetricsBucket_Common) GetPeriodLengthSecs

func (x *MetricsBucket_Common) GetPeriodLengthSecs() uint32

func (*MetricsBucket_Common) GetPeriodStartUnixSecs

func (x *MetricsBucket_Common) GetPeriodStartUnixSecs() uint32

func (*MetricsBucket_Common) GetQueryid

func (x *MetricsBucket_Common) GetQueryid() string

func (*MetricsBucket_Common) GetSchema

func (x *MetricsBucket_Common) GetSchema() string

func (*MetricsBucket_Common) GetTables

func (x *MetricsBucket_Common) GetTables() []string

func (*MetricsBucket_Common) GetUsername

func (x *MetricsBucket_Common) GetUsername() string

func (*MetricsBucket_Common) ProtoMessage

func (*MetricsBucket_Common) ProtoMessage()

func (*MetricsBucket_Common) ProtoReflect

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

func (*MetricsBucket_Common) Reset

func (x *MetricsBucket_Common) Reset()

func (*MetricsBucket_Common) String

func (x *MetricsBucket_Common) String() string

func (*MetricsBucket_Common) Validate

func (this *MetricsBucket_Common) Validate() error

type MetricsBucket_MongoDB

type MetricsBucket_MongoDB struct {
	MDocsReturnedCnt float32 `protobuf:"fixed32,1,opt,name=m_docs_returned_cnt,json=mDocsReturnedCnt,proto3" json:"m_docs_returned_cnt,omitempty"`
	// The number of returned documents.
	MDocsReturnedSum   float32 `protobuf:"fixed32,2,opt,name=m_docs_returned_sum,json=mDocsReturnedSum,proto3" json:"m_docs_returned_sum,omitempty"`
	MDocsReturnedMin   float32 `protobuf:"fixed32,3,opt,name=m_docs_returned_min,json=mDocsReturnedMin,proto3" json:"m_docs_returned_min,omitempty"`
	MDocsReturnedMax   float32 `protobuf:"fixed32,4,opt,name=m_docs_returned_max,json=mDocsReturnedMax,proto3" json:"m_docs_returned_max,omitempty"`
	MDocsReturnedP99   float32 `protobuf:"fixed32,5,opt,name=m_docs_returned_p99,json=mDocsReturnedP99,proto3" json:"m_docs_returned_p99,omitempty"`
	MResponseLengthCnt float32 `protobuf:"fixed32,6,opt,name=m_response_length_cnt,json=mResponseLengthCnt,proto3" json:"m_response_length_cnt,omitempty"`
	// The response length of the query result in bytes.
	MResponseLengthSum float32 `protobuf:"fixed32,7,opt,name=m_response_length_sum,json=mResponseLengthSum,proto3" json:"m_response_length_sum,omitempty"`
	MResponseLengthMin float32 `protobuf:"fixed32,8,opt,name=m_response_length_min,json=mResponseLengthMin,proto3" json:"m_response_length_min,omitempty"`
	MResponseLengthMax float32 `protobuf:"fixed32,9,opt,name=m_response_length_max,json=mResponseLengthMax,proto3" json:"m_response_length_max,omitempty"`
	MResponseLengthP99 float32 `protobuf:"fixed32,10,opt,name=m_response_length_p99,json=mResponseLengthP99,proto3" json:"m_response_length_p99,omitempty"`
	MDocsScannedCnt    float32 `protobuf:"fixed32,11,opt,name=m_docs_scanned_cnt,json=mDocsScannedCnt,proto3" json:"m_docs_scanned_cnt,omitempty"`
	// The number of scanned documents.
	MDocsScannedSum float32 `protobuf:"fixed32,12,opt,name=m_docs_scanned_sum,json=mDocsScannedSum,proto3" json:"m_docs_scanned_sum,omitempty"`
	MDocsScannedMin float32 `protobuf:"fixed32,13,opt,name=m_docs_scanned_min,json=mDocsScannedMin,proto3" json:"m_docs_scanned_min,omitempty"`
	MDocsScannedMax float32 `protobuf:"fixed32,14,opt,name=m_docs_scanned_max,json=mDocsScannedMax,proto3" json:"m_docs_scanned_max,omitempty"`
	MDocsScannedP99 float32 `protobuf:"fixed32,15,opt,name=m_docs_scanned_p99,json=mDocsScannedP99,proto3" json:"m_docs_scanned_p99,omitempty"`
	// contains filtered or unexported fields
}

MongoDB contains metrics for Mongo DB.

func (*MetricsBucket_MongoDB) Descriptor deprecated

func (*MetricsBucket_MongoDB) Descriptor() ([]byte, []int)

Deprecated: Use MetricsBucket_MongoDB.ProtoReflect.Descriptor instead.

func (*MetricsBucket_MongoDB) GetMDocsReturnedCnt

func (x *MetricsBucket_MongoDB) GetMDocsReturnedCnt() float32

func (*MetricsBucket_MongoDB) GetMDocsReturnedMax

func (x *MetricsBucket_MongoDB) GetMDocsReturnedMax() float32

func (*MetricsBucket_MongoDB) GetMDocsReturnedMin

func (x *MetricsBucket_MongoDB) GetMDocsReturnedMin() float32

func (*MetricsBucket_MongoDB) GetMDocsReturnedP99

func (x *MetricsBucket_MongoDB) GetMDocsReturnedP99() float32

func (*MetricsBucket_MongoDB) GetMDocsReturnedSum

func (x *MetricsBucket_MongoDB) GetMDocsReturnedSum() float32

func (*MetricsBucket_MongoDB) GetMDocsScannedCnt

func (x *MetricsBucket_MongoDB) GetMDocsScannedCnt() float32

func (*MetricsBucket_MongoDB) GetMDocsScannedMax

func (x *MetricsBucket_MongoDB) GetMDocsScannedMax() float32

func (*MetricsBucket_MongoDB) GetMDocsScannedMin

func (x *MetricsBucket_MongoDB) GetMDocsScannedMin() float32

func (*MetricsBucket_MongoDB) GetMDocsScannedP99

func (x *MetricsBucket_MongoDB) GetMDocsScannedP99() float32

func (*MetricsBucket_MongoDB) GetMDocsScannedSum

func (x *MetricsBucket_MongoDB) GetMDocsScannedSum() float32

func (*MetricsBucket_MongoDB) GetMResponseLengthCnt

func (x *MetricsBucket_MongoDB) GetMResponseLengthCnt() float32

func (*MetricsBucket_MongoDB) GetMResponseLengthMax

func (x *MetricsBucket_MongoDB) GetMResponseLengthMax() float32

func (*MetricsBucket_MongoDB) GetMResponseLengthMin

func (x *MetricsBucket_MongoDB) GetMResponseLengthMin() float32

func (*MetricsBucket_MongoDB) GetMResponseLengthP99

func (x *MetricsBucket_MongoDB) GetMResponseLengthP99() float32

func (*MetricsBucket_MongoDB) GetMResponseLengthSum

func (x *MetricsBucket_MongoDB) GetMResponseLengthSum() float32

func (*MetricsBucket_MongoDB) ProtoMessage

func (*MetricsBucket_MongoDB) ProtoMessage()

func (*MetricsBucket_MongoDB) ProtoReflect

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

func (*MetricsBucket_MongoDB) Reset

func (x *MetricsBucket_MongoDB) Reset()

func (*MetricsBucket_MongoDB) String

func (x *MetricsBucket_MongoDB) String() string

func (*MetricsBucket_MongoDB) Validate

func (this *MetricsBucket_MongoDB) Validate() error

type MetricsBucket_MySQL

type MetricsBucket_MySQL struct {
	MLockTimeCnt float32 `protobuf:"fixed32,1,opt,name=m_lock_time_cnt,json=mLockTimeCnt,proto3" json:"m_lock_time_cnt,omitempty"`
	// The time to acquire locks in seconds.
	MLockTimeSum float32 `protobuf:"fixed32,2,opt,name=m_lock_time_sum,json=mLockTimeSum,proto3" json:"m_lock_time_sum,omitempty"`
	MLockTimeMin float32 `protobuf:"fixed32,3,opt,name=m_lock_time_min,json=mLockTimeMin,proto3" json:"m_lock_time_min,omitempty"`
	MLockTimeMax float32 `protobuf:"fixed32,4,opt,name=m_lock_time_max,json=mLockTimeMax,proto3" json:"m_lock_time_max,omitempty"`
	MLockTimeP99 float32 `protobuf:"fixed32,5,opt,name=m_lock_time_p99,json=mLockTimeP99,proto3" json:"m_lock_time_p99,omitempty"`
	MRowsSentCnt float32 `protobuf:"fixed32,6,opt,name=m_rows_sent_cnt,json=mRowsSentCnt,proto3" json:"m_rows_sent_cnt,omitempty"`
	// The number of rows sent to the client.
	MRowsSentSum     float32 `protobuf:"fixed32,7,opt,name=m_rows_sent_sum,json=mRowsSentSum,proto3" json:"m_rows_sent_sum,omitempty"`
	MRowsSentMin     float32 `protobuf:"fixed32,8,opt,name=m_rows_sent_min,json=mRowsSentMin,proto3" json:"m_rows_sent_min,omitempty"`
	MRowsSentMax     float32 `protobuf:"fixed32,9,opt,name=m_rows_sent_max,json=mRowsSentMax,proto3" json:"m_rows_sent_max,omitempty"`
	MRowsSentP99     float32 `protobuf:"fixed32,10,opt,name=m_rows_sent_p99,json=mRowsSentP99,proto3" json:"m_rows_sent_p99,omitempty"`
	MRowsExaminedCnt float32 `protobuf:"fixed32,11,opt,name=m_rows_examined_cnt,json=mRowsExaminedCnt,proto3" json:"m_rows_examined_cnt,omitempty"`
	// Number of rows scanned - SELECT.
	MRowsExaminedSum float32 `protobuf:"fixed32,12,opt,name=m_rows_examined_sum,json=mRowsExaminedSum,proto3" json:"m_rows_examined_sum,omitempty"`
	MRowsExaminedMin float32 `protobuf:"fixed32,13,opt,name=m_rows_examined_min,json=mRowsExaminedMin,proto3" json:"m_rows_examined_min,omitempty"`
	MRowsExaminedMax float32 `protobuf:"fixed32,14,opt,name=m_rows_examined_max,json=mRowsExaminedMax,proto3" json:"m_rows_examined_max,omitempty"`
	MRowsExaminedP99 float32 `protobuf:"fixed32,15,opt,name=m_rows_examined_p99,json=mRowsExaminedP99,proto3" json:"m_rows_examined_p99,omitempty"`
	MRowsAffectedCnt float32 `protobuf:"fixed32,16,opt,name=m_rows_affected_cnt,json=mRowsAffectedCnt,proto3" json:"m_rows_affected_cnt,omitempty"`
	// Number of rows changed - UPDATE, DELETE, INSERT.
	MRowsAffectedSum float32 `protobuf:"fixed32,17,opt,name=m_rows_affected_sum,json=mRowsAffectedSum,proto3" json:"m_rows_affected_sum,omitempty"`
	MRowsAffectedMin float32 `protobuf:"fixed32,18,opt,name=m_rows_affected_min,json=mRowsAffectedMin,proto3" json:"m_rows_affected_min,omitempty"`
	MRowsAffectedMax float32 `protobuf:"fixed32,19,opt,name=m_rows_affected_max,json=mRowsAffectedMax,proto3" json:"m_rows_affected_max,omitempty"`
	MRowsAffectedP99 float32 `protobuf:"fixed32,20,opt,name=m_rows_affected_p99,json=mRowsAffectedP99,proto3" json:"m_rows_affected_p99,omitempty"`
	MRowsReadCnt     float32 `protobuf:"fixed32,21,opt,name=m_rows_read_cnt,json=mRowsReadCnt,proto3" json:"m_rows_read_cnt,omitempty"`
	// The number of rows read from tables.
	MRowsReadSum    float32 `protobuf:"fixed32,22,opt,name=m_rows_read_sum,json=mRowsReadSum,proto3" json:"m_rows_read_sum,omitempty"`
	MRowsReadMin    float32 `protobuf:"fixed32,23,opt,name=m_rows_read_min,json=mRowsReadMin,proto3" json:"m_rows_read_min,omitempty"`
	MRowsReadMax    float32 `protobuf:"fixed32,24,opt,name=m_rows_read_max,json=mRowsReadMax,proto3" json:"m_rows_read_max,omitempty"`
	MRowsReadP99    float32 `protobuf:"fixed32,25,opt,name=m_rows_read_p99,json=mRowsReadP99,proto3" json:"m_rows_read_p99,omitempty"`
	MMergePassesCnt float32 `protobuf:"fixed32,26,opt,name=m_merge_passes_cnt,json=mMergePassesCnt,proto3" json:"m_merge_passes_cnt,omitempty"`
	// The number of merge passes that the sort algorithm has had to do.
	MMergePassesSum  float32 `protobuf:"fixed32,27,opt,name=m_merge_passes_sum,json=mMergePassesSum,proto3" json:"m_merge_passes_sum,omitempty"`
	MMergePassesMin  float32 `protobuf:"fixed32,28,opt,name=m_merge_passes_min,json=mMergePassesMin,proto3" json:"m_merge_passes_min,omitempty"`
	MMergePassesMax  float32 `protobuf:"fixed32,29,opt,name=m_merge_passes_max,json=mMergePassesMax,proto3" json:"m_merge_passes_max,omitempty"`
	MMergePassesP99  float32 `protobuf:"fixed32,30,opt,name=m_merge_passes_p99,json=mMergePassesP99,proto3" json:"m_merge_passes_p99,omitempty"`
	MInnodbIoROpsCnt float32 `protobuf:"fixed32,31,opt,name=m_innodb_io_r_ops_cnt,json=mInnodbIoROpsCnt,proto3" json:"m_innodb_io_r_ops_cnt,omitempty"`
	// Counts the number of page read operations scheduled.
	MInnodbIoROpsSum   float32 `protobuf:"fixed32,32,opt,name=m_innodb_io_r_ops_sum,json=mInnodbIoROpsSum,proto3" json:"m_innodb_io_r_ops_sum,omitempty"`
	MInnodbIoROpsMin   float32 `protobuf:"fixed32,33,opt,name=m_innodb_io_r_ops_min,json=mInnodbIoROpsMin,proto3" json:"m_innodb_io_r_ops_min,omitempty"`
	MInnodbIoROpsMax   float32 `protobuf:"fixed32,34,opt,name=m_innodb_io_r_ops_max,json=mInnodbIoROpsMax,proto3" json:"m_innodb_io_r_ops_max,omitempty"`
	MInnodbIoROpsP99   float32 `protobuf:"fixed32,35,opt,name=m_innodb_io_r_ops_p99,json=mInnodbIoROpsP99,proto3" json:"m_innodb_io_r_ops_p99,omitempty"`
	MInnodbIoRBytesCnt float32 `` /* 126-byte string literal not displayed */
	// Similar to innodb_IO_r_ops, but the unit is bytes.
	MInnodbIoRBytesSum float32 `` /* 126-byte string literal not displayed */
	MInnodbIoRBytesMin float32 `` /* 126-byte string literal not displayed */
	MInnodbIoRBytesMax float32 `` /* 126-byte string literal not displayed */
	MInnodbIoRBytesP99 float32 `` /* 126-byte string literal not displayed */
	MInnodbIoRWaitCnt  float32 `protobuf:"fixed32,41,opt,name=m_innodb_io_r_wait_cnt,json=mInnodbIoRWaitCnt,proto3" json:"m_innodb_io_r_wait_cnt,omitempty"`
	// Shows how long (in seconds) it took InnoDB to actually read the data from storage.
	MInnodbIoRWaitSum     float32 `protobuf:"fixed32,42,opt,name=m_innodb_io_r_wait_sum,json=mInnodbIoRWaitSum,proto3" json:"m_innodb_io_r_wait_sum,omitempty"`
	MInnodbIoRWaitMin     float32 `protobuf:"fixed32,43,opt,name=m_innodb_io_r_wait_min,json=mInnodbIoRWaitMin,proto3" json:"m_innodb_io_r_wait_min,omitempty"`
	MInnodbIoRWaitMax     float32 `protobuf:"fixed32,44,opt,name=m_innodb_io_r_wait_max,json=mInnodbIoRWaitMax,proto3" json:"m_innodb_io_r_wait_max,omitempty"`
	MInnodbIoRWaitP99     float32 `protobuf:"fixed32,45,opt,name=m_innodb_io_r_wait_p99,json=mInnodbIoRWaitP99,proto3" json:"m_innodb_io_r_wait_p99,omitempty"`
	MInnodbRecLockWaitCnt float32 `` /* 135-byte string literal not displayed */
	// Shows how long (in seconds) the query waited for row locks.
	MInnodbRecLockWaitSum float32 `` /* 135-byte string literal not displayed */
	MInnodbRecLockWaitMin float32 `` /* 135-byte string literal not displayed */
	MInnodbRecLockWaitMax float32 `` /* 135-byte string literal not displayed */
	MInnodbRecLockWaitP99 float32 `` /* 135-byte string literal not displayed */
	MInnodbQueueWaitCnt   float32 `` /* 127-byte string literal not displayed */
	// Shows how long (in seconds) the query spent either waiting to enter the InnoDB queue or inside that queue waiting for execution.
	MInnodbQueueWaitSum     float32 `` /* 127-byte string literal not displayed */
	MInnodbQueueWaitMin     float32 `` /* 127-byte string literal not displayed */
	MInnodbQueueWaitMax     float32 `` /* 127-byte string literal not displayed */
	MInnodbQueueWaitP99     float32 `` /* 127-byte string literal not displayed */
	MInnodbPagesDistinctCnt float32 `` /* 139-byte string literal not displayed */
	// Counts approximately the number of unique pages the query accessed.
	MInnodbPagesDistinctSum float32 `` /* 139-byte string literal not displayed */
	MInnodbPagesDistinctMin float32 `` /* 139-byte string literal not displayed */
	MInnodbPagesDistinctMax float32 `` /* 139-byte string literal not displayed */
	MInnodbPagesDistinctP99 float32 `` /* 139-byte string literal not displayed */
	MQueryLengthCnt         float32 `protobuf:"fixed32,61,opt,name=m_query_length_cnt,json=mQueryLengthCnt,proto3" json:"m_query_length_cnt,omitempty"`
	// Shows how long the query is.
	MQueryLengthSum float32 `protobuf:"fixed32,62,opt,name=m_query_length_sum,json=mQueryLengthSum,proto3" json:"m_query_length_sum,omitempty"`
	MQueryLengthMin float32 `protobuf:"fixed32,63,opt,name=m_query_length_min,json=mQueryLengthMin,proto3" json:"m_query_length_min,omitempty"`
	MQueryLengthMax float32 `protobuf:"fixed32,64,opt,name=m_query_length_max,json=mQueryLengthMax,proto3" json:"m_query_length_max,omitempty"`
	MQueryLengthP99 float32 `protobuf:"fixed32,65,opt,name=m_query_length_p99,json=mQueryLengthP99,proto3" json:"m_query_length_p99,omitempty"`
	MBytesSentCnt   float32 `protobuf:"fixed32,66,opt,name=m_bytes_sent_cnt,json=mBytesSentCnt,proto3" json:"m_bytes_sent_cnt,omitempty"`
	// The number of bytes sent to all clients.
	MBytesSentSum float32 `protobuf:"fixed32,67,opt,name=m_bytes_sent_sum,json=mBytesSentSum,proto3" json:"m_bytes_sent_sum,omitempty"`
	MBytesSentMin float32 `protobuf:"fixed32,68,opt,name=m_bytes_sent_min,json=mBytesSentMin,proto3" json:"m_bytes_sent_min,omitempty"`
	MBytesSentMax float32 `protobuf:"fixed32,69,opt,name=m_bytes_sent_max,json=mBytesSentMax,proto3" json:"m_bytes_sent_max,omitempty"`
	MBytesSentP99 float32 `protobuf:"fixed32,70,opt,name=m_bytes_sent_p99,json=mBytesSentP99,proto3" json:"m_bytes_sent_p99,omitempty"`
	MTmpTablesCnt float32 `protobuf:"fixed32,71,opt,name=m_tmp_tables_cnt,json=mTmpTablesCnt,proto3" json:"m_tmp_tables_cnt,omitempty"`
	// Number of temporary tables created on memory for the query.
	MTmpTablesSum     float32 `protobuf:"fixed32,72,opt,name=m_tmp_tables_sum,json=mTmpTablesSum,proto3" json:"m_tmp_tables_sum,omitempty"`
	MTmpTablesMin     float32 `protobuf:"fixed32,73,opt,name=m_tmp_tables_min,json=mTmpTablesMin,proto3" json:"m_tmp_tables_min,omitempty"`
	MTmpTablesMax     float32 `protobuf:"fixed32,74,opt,name=m_tmp_tables_max,json=mTmpTablesMax,proto3" json:"m_tmp_tables_max,omitempty"`
	MTmpTablesP99     float32 `protobuf:"fixed32,75,opt,name=m_tmp_tables_p99,json=mTmpTablesP99,proto3" json:"m_tmp_tables_p99,omitempty"`
	MTmpDiskTablesCnt float32 `protobuf:"fixed32,76,opt,name=m_tmp_disk_tables_cnt,json=mTmpDiskTablesCnt,proto3" json:"m_tmp_disk_tables_cnt,omitempty"`
	// Number of temporary tables created on disk for the query.
	MTmpDiskTablesSum float32 `protobuf:"fixed32,77,opt,name=m_tmp_disk_tables_sum,json=mTmpDiskTablesSum,proto3" json:"m_tmp_disk_tables_sum,omitempty"`
	MTmpDiskTablesMin float32 `protobuf:"fixed32,78,opt,name=m_tmp_disk_tables_min,json=mTmpDiskTablesMin,proto3" json:"m_tmp_disk_tables_min,omitempty"`
	MTmpDiskTablesMax float32 `protobuf:"fixed32,79,opt,name=m_tmp_disk_tables_max,json=mTmpDiskTablesMax,proto3" json:"m_tmp_disk_tables_max,omitempty"`
	MTmpDiskTablesP99 float32 `protobuf:"fixed32,80,opt,name=m_tmp_disk_tables_p99,json=mTmpDiskTablesP99,proto3" json:"m_tmp_disk_tables_p99,omitempty"`
	MTmpTableSizesCnt float32 `protobuf:"fixed32,81,opt,name=m_tmp_table_sizes_cnt,json=mTmpTableSizesCnt,proto3" json:"m_tmp_table_sizes_cnt,omitempty"`
	// Total Size in bytes for all temporary tables used in the query.
	MTmpTableSizesSum float32 `protobuf:"fixed32,82,opt,name=m_tmp_table_sizes_sum,json=mTmpTableSizesSum,proto3" json:"m_tmp_table_sizes_sum,omitempty"`
	MTmpTableSizesMin float32 `protobuf:"fixed32,83,opt,name=m_tmp_table_sizes_min,json=mTmpTableSizesMin,proto3" json:"m_tmp_table_sizes_min,omitempty"`
	MTmpTableSizesMax float32 `protobuf:"fixed32,84,opt,name=m_tmp_table_sizes_max,json=mTmpTableSizesMax,proto3" json:"m_tmp_table_sizes_max,omitempty"`
	MTmpTableSizesP99 float32 `protobuf:"fixed32,85,opt,name=m_tmp_table_sizes_p99,json=mTmpTableSizesP99,proto3" json:"m_tmp_table_sizes_p99,omitempty"`
	//
	// Boolean metrics:
	// - *_cnt - how many times this metric was met.
	// - *_sum - how many times this metric was true.
	//
	MQcHitCnt float32 `protobuf:"fixed32,86,opt,name=m_qc_hit_cnt,json=mQcHitCnt,proto3" json:"m_qc_hit_cnt,omitempty"`
	// Query Cache hits.
	MQcHitSum    float32 `protobuf:"fixed32,87,opt,name=m_qc_hit_sum,json=mQcHitSum,proto3" json:"m_qc_hit_sum,omitempty"`
	MFullScanCnt float32 `protobuf:"fixed32,88,opt,name=m_full_scan_cnt,json=mFullScanCnt,proto3" json:"m_full_scan_cnt,omitempty"`
	// The query performed a full table scan.
	MFullScanSum float32 `protobuf:"fixed32,89,opt,name=m_full_scan_sum,json=mFullScanSum,proto3" json:"m_full_scan_sum,omitempty"`
	MFullJoinCnt float32 `protobuf:"fixed32,90,opt,name=m_full_join_cnt,json=mFullJoinCnt,proto3" json:"m_full_join_cnt,omitempty"`
	// The query performed a full join (a join without indexes).
	MFullJoinSum float32 `protobuf:"fixed32,91,opt,name=m_full_join_sum,json=mFullJoinSum,proto3" json:"m_full_join_sum,omitempty"`
	MTmpTableCnt float32 `protobuf:"fixed32,92,opt,name=m_tmp_table_cnt,json=mTmpTableCnt,proto3" json:"m_tmp_table_cnt,omitempty"`
	// The query created an implicit internal temporary table.
	MTmpTableSum       float32 `protobuf:"fixed32,93,opt,name=m_tmp_table_sum,json=mTmpTableSum,proto3" json:"m_tmp_table_sum,omitempty"`
	MTmpTableOnDiskCnt float32 `` /* 126-byte string literal not displayed */
	// The querys temporary table was stored on disk.
	MTmpTableOnDiskSum float32 `` /* 126-byte string literal not displayed */
	MFilesortCnt       float32 `protobuf:"fixed32,96,opt,name=m_filesort_cnt,json=mFilesortCnt,proto3" json:"m_filesort_cnt,omitempty"`
	// The query used a filesort.
	MFilesortSum       float32 `protobuf:"fixed32,97,opt,name=m_filesort_sum,json=mFilesortSum,proto3" json:"m_filesort_sum,omitempty"`
	MFilesortOnDiskCnt float32 `protobuf:"fixed32,98,opt,name=m_filesort_on_disk_cnt,json=mFilesortOnDiskCnt,proto3" json:"m_filesort_on_disk_cnt,omitempty"`
	// The filesort was performed on disk.
	MFilesortOnDiskSum      float32 `protobuf:"fixed32,99,opt,name=m_filesort_on_disk_sum,json=mFilesortOnDiskSum,proto3" json:"m_filesort_on_disk_sum,omitempty"`
	MSelectFullRangeJoinCnt float32 `` /* 142-byte string literal not displayed */
	// The number of joins that used a range search on a reference table.
	MSelectFullRangeJoinSum float32 `` /* 142-byte string literal not displayed */
	MSelectRangeCnt         float32 `protobuf:"fixed32,102,opt,name=m_select_range_cnt,json=mSelectRangeCnt,proto3" json:"m_select_range_cnt,omitempty"`
	// The number of joins that used ranges on the first table.
	MSelectRangeSum      float32 `protobuf:"fixed32,103,opt,name=m_select_range_sum,json=mSelectRangeSum,proto3" json:"m_select_range_sum,omitempty"`
	MSelectRangeCheckCnt float32 `` /* 131-byte string literal not displayed */
	// The number of joins without keys that check for key usage after each row.
	MSelectRangeCheckSum float32 `` /* 131-byte string literal not displayed */
	MSortRangeCnt        float32 `protobuf:"fixed32,106,opt,name=m_sort_range_cnt,json=mSortRangeCnt,proto3" json:"m_sort_range_cnt,omitempty"`
	// The number of sorts that were done using ranges.
	MSortRangeSum float32 `protobuf:"fixed32,107,opt,name=m_sort_range_sum,json=mSortRangeSum,proto3" json:"m_sort_range_sum,omitempty"`
	MSortRowsCnt  float32 `protobuf:"fixed32,108,opt,name=m_sort_rows_cnt,json=mSortRowsCnt,proto3" json:"m_sort_rows_cnt,omitempty"`
	// The number of sorted rows.
	MSortRowsSum float32 `protobuf:"fixed32,109,opt,name=m_sort_rows_sum,json=mSortRowsSum,proto3" json:"m_sort_rows_sum,omitempty"`
	MSortScanCnt float32 `protobuf:"fixed32,110,opt,name=m_sort_scan_cnt,json=mSortScanCnt,proto3" json:"m_sort_scan_cnt,omitempty"`
	// The number of sorts that were done by scanning the table.
	MSortScanSum    float32 `protobuf:"fixed32,111,opt,name=m_sort_scan_sum,json=mSortScanSum,proto3" json:"m_sort_scan_sum,omitempty"`
	MNoIndexUsedCnt float32 `protobuf:"fixed32,112,opt,name=m_no_index_used_cnt,json=mNoIndexUsedCnt,proto3" json:"m_no_index_used_cnt,omitempty"`
	// The number of queries without index.
	MNoIndexUsedSum     float32 `protobuf:"fixed32,113,opt,name=m_no_index_used_sum,json=mNoIndexUsedSum,proto3" json:"m_no_index_used_sum,omitempty"`
	MNoGoodIndexUsedCnt float32 `` /* 130-byte string literal not displayed */
	// The number of queries without good index.
	MNoGoodIndexUsedSum float32 `` /* 130-byte string literal not displayed */
	// contains filtered or unexported fields
}

MySQL contains metrics for MySQL.

func (*MetricsBucket_MySQL) Descriptor deprecated

func (*MetricsBucket_MySQL) Descriptor() ([]byte, []int)

Deprecated: Use MetricsBucket_MySQL.ProtoReflect.Descriptor instead.

func (*MetricsBucket_MySQL) GetMBytesSentCnt

func (x *MetricsBucket_MySQL) GetMBytesSentCnt() float32

func (*MetricsBucket_MySQL) GetMBytesSentMax

func (x *MetricsBucket_MySQL) GetMBytesSentMax() float32

func (*MetricsBucket_MySQL) GetMBytesSentMin

func (x *MetricsBucket_MySQL) GetMBytesSentMin() float32

func (*MetricsBucket_MySQL) GetMBytesSentP99

func (x *MetricsBucket_MySQL) GetMBytesSentP99() float32

func (*MetricsBucket_MySQL) GetMBytesSentSum

func (x *MetricsBucket_MySQL) GetMBytesSentSum() float32

func (*MetricsBucket_MySQL) GetMFilesortCnt

func (x *MetricsBucket_MySQL) GetMFilesortCnt() float32

func (*MetricsBucket_MySQL) GetMFilesortOnDiskCnt

func (x *MetricsBucket_MySQL) GetMFilesortOnDiskCnt() float32

func (*MetricsBucket_MySQL) GetMFilesortOnDiskSum

func (x *MetricsBucket_MySQL) GetMFilesortOnDiskSum() float32

func (*MetricsBucket_MySQL) GetMFilesortSum

func (x *MetricsBucket_MySQL) GetMFilesortSum() float32

func (*MetricsBucket_MySQL) GetMFullJoinCnt

func (x *MetricsBucket_MySQL) GetMFullJoinCnt() float32

func (*MetricsBucket_MySQL) GetMFullJoinSum

func (x *MetricsBucket_MySQL) GetMFullJoinSum() float32

func (*MetricsBucket_MySQL) GetMFullScanCnt

func (x *MetricsBucket_MySQL) GetMFullScanCnt() float32

func (*MetricsBucket_MySQL) GetMFullScanSum

func (x *MetricsBucket_MySQL) GetMFullScanSum() float32

func (*MetricsBucket_MySQL) GetMInnodbIoRBytesCnt

func (x *MetricsBucket_MySQL) GetMInnodbIoRBytesCnt() float32

func (*MetricsBucket_MySQL) GetMInnodbIoRBytesMax

func (x *MetricsBucket_MySQL) GetMInnodbIoRBytesMax() float32

func (*MetricsBucket_MySQL) GetMInnodbIoRBytesMin

func (x *MetricsBucket_MySQL) GetMInnodbIoRBytesMin() float32

func (*MetricsBucket_MySQL) GetMInnodbIoRBytesP99

func (x *MetricsBucket_MySQL) GetMInnodbIoRBytesP99() float32

func (*MetricsBucket_MySQL) GetMInnodbIoRBytesSum

func (x *MetricsBucket_MySQL) GetMInnodbIoRBytesSum() float32

func (*MetricsBucket_MySQL) GetMInnodbIoROpsCnt

func (x *MetricsBucket_MySQL) GetMInnodbIoROpsCnt() float32

func (*MetricsBucket_MySQL) GetMInnodbIoROpsMax

func (x *MetricsBucket_MySQL) GetMInnodbIoROpsMax() float32

func (*MetricsBucket_MySQL) GetMInnodbIoROpsMin

func (x *MetricsBucket_MySQL) GetMInnodbIoROpsMin() float32

func (*MetricsBucket_MySQL) GetMInnodbIoROpsP99

func (x *MetricsBucket_MySQL) GetMInnodbIoROpsP99() float32

func (*MetricsBucket_MySQL) GetMInnodbIoROpsSum

func (x *MetricsBucket_MySQL) GetMInnodbIoROpsSum() float32

func (*MetricsBucket_MySQL) GetMInnodbIoRWaitCnt

func (x *MetricsBucket_MySQL) GetMInnodbIoRWaitCnt() float32

func (*MetricsBucket_MySQL) GetMInnodbIoRWaitMax

func (x *MetricsBucket_MySQL) GetMInnodbIoRWaitMax() float32

func (*MetricsBucket_MySQL) GetMInnodbIoRWaitMin

func (x *MetricsBucket_MySQL) GetMInnodbIoRWaitMin() float32

func (*MetricsBucket_MySQL) GetMInnodbIoRWaitP99

func (x *MetricsBucket_MySQL) GetMInnodbIoRWaitP99() float32

func (*MetricsBucket_MySQL) GetMInnodbIoRWaitSum

func (x *MetricsBucket_MySQL) GetMInnodbIoRWaitSum() float32

func (*MetricsBucket_MySQL) GetMInnodbPagesDistinctCnt

func (x *MetricsBucket_MySQL) GetMInnodbPagesDistinctCnt() float32

func (*MetricsBucket_MySQL) GetMInnodbPagesDistinctMax

func (x *MetricsBucket_MySQL) GetMInnodbPagesDistinctMax() float32

func (*MetricsBucket_MySQL) GetMInnodbPagesDistinctMin

func (x *MetricsBucket_MySQL) GetMInnodbPagesDistinctMin() float32

func (*MetricsBucket_MySQL) GetMInnodbPagesDistinctP99

func (x *MetricsBucket_MySQL) GetMInnodbPagesDistinctP99() float32

func (*MetricsBucket_MySQL) GetMInnodbPagesDistinctSum

func (x *MetricsBucket_MySQL) GetMInnodbPagesDistinctSum() float32

func (*MetricsBucket_MySQL) GetMInnodbQueueWaitCnt

func (x *MetricsBucket_MySQL) GetMInnodbQueueWaitCnt() float32

func (*MetricsBucket_MySQL) GetMInnodbQueueWaitMax

func (x *MetricsBucket_MySQL) GetMInnodbQueueWaitMax() float32

func (*MetricsBucket_MySQL) GetMInnodbQueueWaitMin

func (x *MetricsBucket_MySQL) GetMInnodbQueueWaitMin() float32

func (*MetricsBucket_MySQL) GetMInnodbQueueWaitP99

func (x *MetricsBucket_MySQL) GetMInnodbQueueWaitP99() float32

func (*MetricsBucket_MySQL) GetMInnodbQueueWaitSum

func (x *MetricsBucket_MySQL) GetMInnodbQueueWaitSum() float32

func (*MetricsBucket_MySQL) GetMInnodbRecLockWaitCnt

func (x *MetricsBucket_MySQL) GetMInnodbRecLockWaitCnt() float32

func (*MetricsBucket_MySQL) GetMInnodbRecLockWaitMax

func (x *MetricsBucket_MySQL) GetMInnodbRecLockWaitMax() float32

func (*MetricsBucket_MySQL) GetMInnodbRecLockWaitMin

func (x *MetricsBucket_MySQL) GetMInnodbRecLockWaitMin() float32

func (*MetricsBucket_MySQL) GetMInnodbRecLockWaitP99

func (x *MetricsBucket_MySQL) GetMInnodbRecLockWaitP99() float32

func (*MetricsBucket_MySQL) GetMInnodbRecLockWaitSum

func (x *MetricsBucket_MySQL) GetMInnodbRecLockWaitSum() float32

func (*MetricsBucket_MySQL) GetMLockTimeCnt

func (x *MetricsBucket_MySQL) GetMLockTimeCnt() float32

func (*MetricsBucket_MySQL) GetMLockTimeMax

func (x *MetricsBucket_MySQL) GetMLockTimeMax() float32

func (*MetricsBucket_MySQL) GetMLockTimeMin

func (x *MetricsBucket_MySQL) GetMLockTimeMin() float32

func (*MetricsBucket_MySQL) GetMLockTimeP99

func (x *MetricsBucket_MySQL) GetMLockTimeP99() float32

func (*MetricsBucket_MySQL) GetMLockTimeSum

func (x *MetricsBucket_MySQL) GetMLockTimeSum() float32

func (*MetricsBucket_MySQL) GetMMergePassesCnt

func (x *MetricsBucket_MySQL) GetMMergePassesCnt() float32

func (*MetricsBucket_MySQL) GetMMergePassesMax

func (x *MetricsBucket_MySQL) GetMMergePassesMax() float32

func (*MetricsBucket_MySQL) GetMMergePassesMin

func (x *MetricsBucket_MySQL) GetMMergePassesMin() float32

func (*MetricsBucket_MySQL) GetMMergePassesP99

func (x *MetricsBucket_MySQL) GetMMergePassesP99() float32

func (*MetricsBucket_MySQL) GetMMergePassesSum

func (x *MetricsBucket_MySQL) GetMMergePassesSum() float32

func (*MetricsBucket_MySQL) GetMNoGoodIndexUsedCnt

func (x *MetricsBucket_MySQL) GetMNoGoodIndexUsedCnt() float32

func (*MetricsBucket_MySQL) GetMNoGoodIndexUsedSum

func (x *MetricsBucket_MySQL) GetMNoGoodIndexUsedSum() float32

func (*MetricsBucket_MySQL) GetMNoIndexUsedCnt

func (x *MetricsBucket_MySQL) GetMNoIndexUsedCnt() float32

func (*MetricsBucket_MySQL) GetMNoIndexUsedSum

func (x *MetricsBucket_MySQL) GetMNoIndexUsedSum() float32

func (*MetricsBucket_MySQL) GetMQcHitCnt

func (x *MetricsBucket_MySQL) GetMQcHitCnt() float32

func (*MetricsBucket_MySQL) GetMQcHitSum

func (x *MetricsBucket_MySQL) GetMQcHitSum() float32

func (*MetricsBucket_MySQL) GetMQueryLengthCnt

func (x *MetricsBucket_MySQL) GetMQueryLengthCnt() float32

func (*MetricsBucket_MySQL) GetMQueryLengthMax

func (x *MetricsBucket_MySQL) GetMQueryLengthMax() float32

func (*MetricsBucket_MySQL) GetMQueryLengthMin

func (x *MetricsBucket_MySQL) GetMQueryLengthMin() float32

func (*MetricsBucket_MySQL) GetMQueryLengthP99

func (x *MetricsBucket_MySQL) GetMQueryLengthP99() float32

func (*MetricsBucket_MySQL) GetMQueryLengthSum

func (x *MetricsBucket_MySQL) GetMQueryLengthSum() float32

func (*MetricsBucket_MySQL) GetMRowsAffectedCnt

func (x *MetricsBucket_MySQL) GetMRowsAffectedCnt() float32

func (*MetricsBucket_MySQL) GetMRowsAffectedMax

func (x *MetricsBucket_MySQL) GetMRowsAffectedMax() float32

func (*MetricsBucket_MySQL) GetMRowsAffectedMin

func (x *MetricsBucket_MySQL) GetMRowsAffectedMin() float32

func (*MetricsBucket_MySQL) GetMRowsAffectedP99

func (x *MetricsBucket_MySQL) GetMRowsAffectedP99() float32

func (*MetricsBucket_MySQL) GetMRowsAffectedSum

func (x *MetricsBucket_MySQL) GetMRowsAffectedSum() float32

func (*MetricsBucket_MySQL) GetMRowsExaminedCnt

func (x *MetricsBucket_MySQL) GetMRowsExaminedCnt() float32

func (*MetricsBucket_MySQL) GetMRowsExaminedMax

func (x *MetricsBucket_MySQL) GetMRowsExaminedMax() float32

func (*MetricsBucket_MySQL) GetMRowsExaminedMin

func (x *MetricsBucket_MySQL) GetMRowsExaminedMin() float32

func (*MetricsBucket_MySQL) GetMRowsExaminedP99

func (x *MetricsBucket_MySQL) GetMRowsExaminedP99() float32

func (*MetricsBucket_MySQL) GetMRowsExaminedSum

func (x *MetricsBucket_MySQL) GetMRowsExaminedSum() float32

func (*MetricsBucket_MySQL) GetMRowsReadCnt

func (x *MetricsBucket_MySQL) GetMRowsReadCnt() float32

func (*MetricsBucket_MySQL) GetMRowsReadMax

func (x *MetricsBucket_MySQL) GetMRowsReadMax() float32

func (*MetricsBucket_MySQL) GetMRowsReadMin

func (x *MetricsBucket_MySQL) GetMRowsReadMin() float32

func (*MetricsBucket_MySQL) GetMRowsReadP99

func (x *MetricsBucket_MySQL) GetMRowsReadP99() float32

func (*MetricsBucket_MySQL) GetMRowsReadSum

func (x *MetricsBucket_MySQL) GetMRowsReadSum() float32

func (*MetricsBucket_MySQL) GetMRowsSentCnt

func (x *MetricsBucket_MySQL) GetMRowsSentCnt() float32

func (*MetricsBucket_MySQL) GetMRowsSentMax

func (x *MetricsBucket_MySQL) GetMRowsSentMax() float32

func (*MetricsBucket_MySQL) GetMRowsSentMin

func (x *MetricsBucket_MySQL) GetMRowsSentMin() float32

func (*MetricsBucket_MySQL) GetMRowsSentP99

func (x *MetricsBucket_MySQL) GetMRowsSentP99() float32

func (*MetricsBucket_MySQL) GetMRowsSentSum

func (x *MetricsBucket_MySQL) GetMRowsSentSum() float32

func (*MetricsBucket_MySQL) GetMSelectFullRangeJoinCnt

func (x *MetricsBucket_MySQL) GetMSelectFullRangeJoinCnt() float32

func (*MetricsBucket_MySQL) GetMSelectFullRangeJoinSum

func (x *MetricsBucket_MySQL) GetMSelectFullRangeJoinSum() float32

func (*MetricsBucket_MySQL) GetMSelectRangeCheckCnt

func (x *MetricsBucket_MySQL) GetMSelectRangeCheckCnt() float32

func (*MetricsBucket_MySQL) GetMSelectRangeCheckSum

func (x *MetricsBucket_MySQL) GetMSelectRangeCheckSum() float32

func (*MetricsBucket_MySQL) GetMSelectRangeCnt

func (x *MetricsBucket_MySQL) GetMSelectRangeCnt() float32

func (*MetricsBucket_MySQL) GetMSelectRangeSum

func (x *MetricsBucket_MySQL) GetMSelectRangeSum() float32

func (*MetricsBucket_MySQL) GetMSortRangeCnt

func (x *MetricsBucket_MySQL) GetMSortRangeCnt() float32

func (*MetricsBucket_MySQL) GetMSortRangeSum

func (x *MetricsBucket_MySQL) GetMSortRangeSum() float32

func (*MetricsBucket_MySQL) GetMSortRowsCnt

func (x *MetricsBucket_MySQL) GetMSortRowsCnt() float32

func (*MetricsBucket_MySQL) GetMSortRowsSum

func (x *MetricsBucket_MySQL) GetMSortRowsSum() float32

func (*MetricsBucket_MySQL) GetMSortScanCnt

func (x *MetricsBucket_MySQL) GetMSortScanCnt() float32

func (*MetricsBucket_MySQL) GetMSortScanSum

func (x *MetricsBucket_MySQL) GetMSortScanSum() float32

func (*MetricsBucket_MySQL) GetMTmpDiskTablesCnt

func (x *MetricsBucket_MySQL) GetMTmpDiskTablesCnt() float32

func (*MetricsBucket_MySQL) GetMTmpDiskTablesMax

func (x *MetricsBucket_MySQL) GetMTmpDiskTablesMax() float32

func (*MetricsBucket_MySQL) GetMTmpDiskTablesMin

func (x *MetricsBucket_MySQL) GetMTmpDiskTablesMin() float32

func (*MetricsBucket_MySQL) GetMTmpDiskTablesP99

func (x *MetricsBucket_MySQL) GetMTmpDiskTablesP99() float32

func (*MetricsBucket_MySQL) GetMTmpDiskTablesSum

func (x *MetricsBucket_MySQL) GetMTmpDiskTablesSum() float32

func (*MetricsBucket_MySQL) GetMTmpTableCnt

func (x *MetricsBucket_MySQL) GetMTmpTableCnt() float32

func (*MetricsBucket_MySQL) GetMTmpTableOnDiskCnt

func (x *MetricsBucket_MySQL) GetMTmpTableOnDiskCnt() float32

func (*MetricsBucket_MySQL) GetMTmpTableOnDiskSum

func (x *MetricsBucket_MySQL) GetMTmpTableOnDiskSum() float32

func (*MetricsBucket_MySQL) GetMTmpTableSizesCnt

func (x *MetricsBucket_MySQL) GetMTmpTableSizesCnt() float32

func (*MetricsBucket_MySQL) GetMTmpTableSizesMax

func (x *MetricsBucket_MySQL) GetMTmpTableSizesMax() float32

func (*MetricsBucket_MySQL) GetMTmpTableSizesMin

func (x *MetricsBucket_MySQL) GetMTmpTableSizesMin() float32

func (*MetricsBucket_MySQL) GetMTmpTableSizesP99

func (x *MetricsBucket_MySQL) GetMTmpTableSizesP99() float32

func (*MetricsBucket_MySQL) GetMTmpTableSizesSum

func (x *MetricsBucket_MySQL) GetMTmpTableSizesSum() float32

func (*MetricsBucket_MySQL) GetMTmpTableSum

func (x *MetricsBucket_MySQL) GetMTmpTableSum() float32

func (*MetricsBucket_MySQL) GetMTmpTablesCnt

func (x *MetricsBucket_MySQL) GetMTmpTablesCnt() float32

func (*MetricsBucket_MySQL) GetMTmpTablesMax

func (x *MetricsBucket_MySQL) GetMTmpTablesMax() float32

func (*MetricsBucket_MySQL) GetMTmpTablesMin

func (x *MetricsBucket_MySQL) GetMTmpTablesMin() float32

func (*MetricsBucket_MySQL) GetMTmpTablesP99

func (x *MetricsBucket_MySQL) GetMTmpTablesP99() float32

func (*MetricsBucket_MySQL) GetMTmpTablesSum

func (x *MetricsBucket_MySQL) GetMTmpTablesSum() float32

func (*MetricsBucket_MySQL) ProtoMessage

func (*MetricsBucket_MySQL) ProtoMessage()

func (*MetricsBucket_MySQL) ProtoReflect

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

func (*MetricsBucket_MySQL) Reset

func (x *MetricsBucket_MySQL) Reset()

func (*MetricsBucket_MySQL) String

func (x *MetricsBucket_MySQL) String() string

func (*MetricsBucket_MySQL) Validate

func (this *MetricsBucket_MySQL) Validate() error

type MetricsBucket_PostgreSQL

type MetricsBucket_PostgreSQL struct {
	MRowsCnt float32 `protobuf:"fixed32,1,opt,name=m_rows_cnt,json=mRowsCnt,proto3" json:"m_rows_cnt,omitempty"`
	// The number of rows sent to the client.
	MRowsSum          float32 `protobuf:"fixed32,2,opt,name=m_rows_sum,json=mRowsSum,proto3" json:"m_rows_sum,omitempty"`
	MSharedBlksHitCnt float32 `protobuf:"fixed32,3,opt,name=m_shared_blks_hit_cnt,json=mSharedBlksHitCnt,proto3" json:"m_shared_blks_hit_cnt,omitempty"`
	// Total number of shared block cache hits by the statement.
	MSharedBlksHitSum  float32 `protobuf:"fixed32,4,opt,name=m_shared_blks_hit_sum,json=mSharedBlksHitSum,proto3" json:"m_shared_blks_hit_sum,omitempty"`
	MSharedBlksReadCnt float32 `protobuf:"fixed32,5,opt,name=m_shared_blks_read_cnt,json=mSharedBlksReadCnt,proto3" json:"m_shared_blks_read_cnt,omitempty"`
	// Total number of shared blocks read by the statement.
	MSharedBlksReadSum    float32 `protobuf:"fixed32,6,opt,name=m_shared_blks_read_sum,json=mSharedBlksReadSum,proto3" json:"m_shared_blks_read_sum,omitempty"`
	MSharedBlksDirtiedCnt float32 `` /* 132-byte string literal not displayed */
	// Total number of shared blocks dirtied by the statement.
	MSharedBlksDirtiedSum float32 `` /* 132-byte string literal not displayed */
	MSharedBlksWrittenCnt float32 `` /* 132-byte string literal not displayed */
	// Total number of shared blocks written by the statement.
	MSharedBlksWrittenSum float32 `` /* 133-byte string literal not displayed */
	MLocalBlksHitCnt      float32 `protobuf:"fixed32,11,opt,name=m_local_blks_hit_cnt,json=mLocalBlksHitCnt,proto3" json:"m_local_blks_hit_cnt,omitempty"`
	// Total number of local block cache hits by the statement.
	MLocalBlksHitSum  float32 `protobuf:"fixed32,12,opt,name=m_local_blks_hit_sum,json=mLocalBlksHitSum,proto3" json:"m_local_blks_hit_sum,omitempty"`
	MLocalBlksReadCnt float32 `protobuf:"fixed32,13,opt,name=m_local_blks_read_cnt,json=mLocalBlksReadCnt,proto3" json:"m_local_blks_read_cnt,omitempty"`
	// Total number of local blocks read by the statement.
	MLocalBlksReadSum    float32 `protobuf:"fixed32,14,opt,name=m_local_blks_read_sum,json=mLocalBlksReadSum,proto3" json:"m_local_blks_read_sum,omitempty"`
	MLocalBlksDirtiedCnt float32 `` /* 130-byte string literal not displayed */
	// Total number of local blocks dirtied by the statement.
	MLocalBlksDirtiedSum float32 `` /* 130-byte string literal not displayed */
	MLocalBlksWrittenCnt float32 `` /* 130-byte string literal not displayed */
	// Total number of local blocks written by the statement.
	MLocalBlksWrittenSum float32 `` /* 130-byte string literal not displayed */
	MTempBlksReadCnt     float32 `protobuf:"fixed32,19,opt,name=m_temp_blks_read_cnt,json=mTempBlksReadCnt,proto3" json:"m_temp_blks_read_cnt,omitempty"`
	// Total number of temp blocks read by the statement.
	MTempBlksReadSum    float32 `protobuf:"fixed32,20,opt,name=m_temp_blks_read_sum,json=mTempBlksReadSum,proto3" json:"m_temp_blks_read_sum,omitempty"`
	MTempBlksWrittenCnt float32 `` /* 127-byte string literal not displayed */
	// Total number of temp blocks written by the statement.
	MTempBlksWrittenSum float32 `` /* 127-byte string literal not displayed */
	MBlkReadTimeCnt     float32 `protobuf:"fixed32,23,opt,name=m_blk_read_time_cnt,json=mBlkReadTimeCnt,proto3" json:"m_blk_read_time_cnt,omitempty"`
	// Total time the statement spent reading blocks, in milliseconds (if track_io_timing is enabled, otherwise zero).
	MBlkReadTimeSum  float32 `protobuf:"fixed32,24,opt,name=m_blk_read_time_sum,json=mBlkReadTimeSum,proto3" json:"m_blk_read_time_sum,omitempty"`
	MBlkWriteTimeCnt float32 `protobuf:"fixed32,25,opt,name=m_blk_write_time_cnt,json=mBlkWriteTimeCnt,proto3" json:"m_blk_write_time_cnt,omitempty"`
	// Total time the statement spent writing blocks, in milliseconds (if track_io_timing is enabled, otherwise zero).
	MBlkWriteTimeSum float32 `protobuf:"fixed32,26,opt,name=m_blk_write_time_sum,json=mBlkWriteTimeSum,proto3" json:"m_blk_write_time_sum,omitempty"`
	MCpuUserTimeCnt  float32 `protobuf:"fixed32,27,opt,name=m_cpu_user_time_cnt,json=mCpuUserTimeCnt,proto3" json:"m_cpu_user_time_cnt,omitempty"`
	// Total time user spent in query.
	MCpuUserTimeSum float32 `protobuf:"fixed32,28,opt,name=m_cpu_user_time_sum,json=mCpuUserTimeSum,proto3" json:"m_cpu_user_time_sum,omitempty"`
	MCpuSysTimeCnt  float32 `protobuf:"fixed32,29,opt,name=m_cpu_sys_time_cnt,json=mCpuSysTimeCnt,proto3" json:"m_cpu_sys_time_cnt,omitempty"`
	// Total time system spent in query.
	MCpuSysTimeSum float32 `protobuf:"fixed32,30,opt,name=m_cpu_sys_time_sum,json=mCpuSysTimeSum,proto3" json:"m_cpu_sys_time_sum,omitempty"`
	// contains filtered or unexported fields
}

PostgreSQL contains metrics for PostgreSQL.

func (*MetricsBucket_PostgreSQL) Descriptor deprecated

func (*MetricsBucket_PostgreSQL) Descriptor() ([]byte, []int)

Deprecated: Use MetricsBucket_PostgreSQL.ProtoReflect.Descriptor instead.

func (*MetricsBucket_PostgreSQL) GetMBlkReadTimeCnt

func (x *MetricsBucket_PostgreSQL) GetMBlkReadTimeCnt() float32

func (*MetricsBucket_PostgreSQL) GetMBlkReadTimeSum

func (x *MetricsBucket_PostgreSQL) GetMBlkReadTimeSum() float32

func (*MetricsBucket_PostgreSQL) GetMBlkWriteTimeCnt

func (x *MetricsBucket_PostgreSQL) GetMBlkWriteTimeCnt() float32

func (*MetricsBucket_PostgreSQL) GetMBlkWriteTimeSum

func (x *MetricsBucket_PostgreSQL) GetMBlkWriteTimeSum() float32

func (*MetricsBucket_PostgreSQL) GetMCpuSysTimeCnt

func (x *MetricsBucket_PostgreSQL) GetMCpuSysTimeCnt() float32

func (*MetricsBucket_PostgreSQL) GetMCpuSysTimeSum

func (x *MetricsBucket_PostgreSQL) GetMCpuSysTimeSum() float32

func (*MetricsBucket_PostgreSQL) GetMCpuUserTimeCnt

func (x *MetricsBucket_PostgreSQL) GetMCpuUserTimeCnt() float32

func (*MetricsBucket_PostgreSQL) GetMCpuUserTimeSum

func (x *MetricsBucket_PostgreSQL) GetMCpuUserTimeSum() float32

func (*MetricsBucket_PostgreSQL) GetMLocalBlksDirtiedCnt

func (x *MetricsBucket_PostgreSQL) GetMLocalBlksDirtiedCnt() float32

func (*MetricsBucket_PostgreSQL) GetMLocalBlksDirtiedSum

func (x *MetricsBucket_PostgreSQL) GetMLocalBlksDirtiedSum() float32

func (*MetricsBucket_PostgreSQL) GetMLocalBlksHitCnt

func (x *MetricsBucket_PostgreSQL) GetMLocalBlksHitCnt() float32

func (*MetricsBucket_PostgreSQL) GetMLocalBlksHitSum

func (x *MetricsBucket_PostgreSQL) GetMLocalBlksHitSum() float32

func (*MetricsBucket_PostgreSQL) GetMLocalBlksReadCnt

func (x *MetricsBucket_PostgreSQL) GetMLocalBlksReadCnt() float32

func (*MetricsBucket_PostgreSQL) GetMLocalBlksReadSum

func (x *MetricsBucket_PostgreSQL) GetMLocalBlksReadSum() float32

func (*MetricsBucket_PostgreSQL) GetMLocalBlksWrittenCnt

func (x *MetricsBucket_PostgreSQL) GetMLocalBlksWrittenCnt() float32

func (*MetricsBucket_PostgreSQL) GetMLocalBlksWrittenSum

func (x *MetricsBucket_PostgreSQL) GetMLocalBlksWrittenSum() float32

func (*MetricsBucket_PostgreSQL) GetMRowsCnt

func (x *MetricsBucket_PostgreSQL) GetMRowsCnt() float32

func (*MetricsBucket_PostgreSQL) GetMRowsSum

func (x *MetricsBucket_PostgreSQL) GetMRowsSum() float32

func (*MetricsBucket_PostgreSQL) GetMSharedBlksDirtiedCnt

func (x *MetricsBucket_PostgreSQL) GetMSharedBlksDirtiedCnt() float32

func (*MetricsBucket_PostgreSQL) GetMSharedBlksDirtiedSum

func (x *MetricsBucket_PostgreSQL) GetMSharedBlksDirtiedSum() float32

func (*MetricsBucket_PostgreSQL) GetMSharedBlksHitCnt

func (x *MetricsBucket_PostgreSQL) GetMSharedBlksHitCnt() float32

func (*MetricsBucket_PostgreSQL) GetMSharedBlksHitSum

func (x *MetricsBucket_PostgreSQL) GetMSharedBlksHitSum() float32

func (*MetricsBucket_PostgreSQL) GetMSharedBlksReadCnt

func (x *MetricsBucket_PostgreSQL) GetMSharedBlksReadCnt() float32

func (*MetricsBucket_PostgreSQL) GetMSharedBlksReadSum

func (x *MetricsBucket_PostgreSQL) GetMSharedBlksReadSum() float32

func (*MetricsBucket_PostgreSQL) GetMSharedBlksWrittenCnt

func (x *MetricsBucket_PostgreSQL) GetMSharedBlksWrittenCnt() float32

func (*MetricsBucket_PostgreSQL) GetMSharedBlksWrittenSum

func (x *MetricsBucket_PostgreSQL) GetMSharedBlksWrittenSum() float32

func (*MetricsBucket_PostgreSQL) GetMTempBlksReadCnt

func (x *MetricsBucket_PostgreSQL) GetMTempBlksReadCnt() float32

func (*MetricsBucket_PostgreSQL) GetMTempBlksReadSum

func (x *MetricsBucket_PostgreSQL) GetMTempBlksReadSum() float32

func (*MetricsBucket_PostgreSQL) GetMTempBlksWrittenCnt

func (x *MetricsBucket_PostgreSQL) GetMTempBlksWrittenCnt() float32

func (*MetricsBucket_PostgreSQL) GetMTempBlksWrittenSum

func (x *MetricsBucket_PostgreSQL) GetMTempBlksWrittenSum() float32

func (*MetricsBucket_PostgreSQL) ProtoMessage

func (*MetricsBucket_PostgreSQL) ProtoMessage()

func (*MetricsBucket_PostgreSQL) ProtoReflect

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

func (*MetricsBucket_PostgreSQL) Reset

func (x *MetricsBucket_PostgreSQL) Reset()

func (*MetricsBucket_PostgreSQL) String

func (x *MetricsBucket_PostgreSQL) String() string

func (*MetricsBucket_PostgreSQL) Validate

func (this *MetricsBucket_PostgreSQL) Validate() error

type MysqlExplainOutputFormat

type MysqlExplainOutputFormat int32

MysqlExplainOutputFormat output formats supported by MySQL Explain action.

const (
	MysqlExplainOutputFormat_MYSQL_EXPLAIN_OUTPUT_FORMAT_INVALID MysqlExplainOutputFormat = 0
	// EXPLAIN FORMAT=TRADITIONAL, returns result as text
	MysqlExplainOutputFormat_MYSQL_EXPLAIN_OUTPUT_FORMAT_DEFAULT MysqlExplainOutputFormat = 1
	// EXPLAIN FORMAT=JSON
	MysqlExplainOutputFormat_MYSQL_EXPLAIN_OUTPUT_FORMAT_JSON MysqlExplainOutputFormat = 2
	// EXPLAIN FORMAT=TRADITIONAL, returns result as JSON
	MysqlExplainOutputFormat_MYSQL_EXPLAIN_OUTPUT_FORMAT_TRADITIONAL_JSON MysqlExplainOutputFormat = 3
)

func (MysqlExplainOutputFormat) Descriptor

func (MysqlExplainOutputFormat) Enum

func (MysqlExplainOutputFormat) EnumDescriptor deprecated

func (MysqlExplainOutputFormat) EnumDescriptor() ([]byte, []int)

Deprecated: Use MysqlExplainOutputFormat.Descriptor instead.

func (MysqlExplainOutputFormat) Number

func (MysqlExplainOutputFormat) String

func (x MysqlExplainOutputFormat) String() string

func (MysqlExplainOutputFormat) Type

type Ping

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

Ping is a AgentMessage/ServerMessage for checking connectivity, latency and clock drift.

func (*Ping) AgentMessageRequestPayload

func (m *Ping) AgentMessageRequestPayload() isAgentMessage_Payload

AgentMessage request payloads

func (*Ping) Descriptor deprecated

func (*Ping) Descriptor() ([]byte, []int)

Deprecated: Use Ping.ProtoReflect.Descriptor instead.

func (*Ping) ProtoMessage

func (*Ping) ProtoMessage()

func (*Ping) ProtoReflect

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

func (*Ping) Reset

func (x *Ping) Reset()

func (*Ping) ServerMessageRequestPayload

func (m *Ping) ServerMessageRequestPayload() isServerMessage_Payload

ServerMessage request payloads

func (*Ping) String

func (x *Ping) String() string

func (*Ping) Validate

func (this *Ping) Validate() error

type Pong

type Pong struct {
	CurrentTime *timestamp.Timestamp `protobuf:"bytes,1,opt,name=current_time,json=currentTime,proto3" json:"current_time,omitempty"`
	// contains filtered or unexported fields
}

Pong is an AgentMessage/ServerMessage with current time for measuring clock drift.

func (*Pong) AgentMessageResponsePayload

func (m *Pong) AgentMessageResponsePayload() isAgentMessage_Payload

AgentMessage response payloads

func (*Pong) Descriptor deprecated

func (*Pong) Descriptor() ([]byte, []int)

Deprecated: Use Pong.ProtoReflect.Descriptor instead.

func (*Pong) GetCurrentTime

func (x *Pong) GetCurrentTime() *timestamp.Timestamp

func (*Pong) ProtoMessage

func (*Pong) ProtoMessage()

func (*Pong) ProtoReflect

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

func (*Pong) Reset

func (x *Pong) Reset()

func (*Pong) ServerMessageResponsePayload

func (m *Pong) ServerMessageResponsePayload() isServerMessage_Payload

ServerMessage response payloads

func (*Pong) String

func (x *Pong) String() string

func (*Pong) Validate

func (this *Pong) Validate() error

type QANCollectRequest

type QANCollectRequest struct {
	MetricsBucket []*MetricsBucket `protobuf:"bytes,1,rep,name=metrics_bucket,json=metricsBucket,proto3" json:"metrics_bucket,omitempty"`
	// contains filtered or unexported fields
}

QANCollectRequest is an AgentMessage for sending QAN data for qan-api.

func (*QANCollectRequest) AgentMessageRequestPayload

func (m *QANCollectRequest) AgentMessageRequestPayload() isAgentMessage_Payload

func (*QANCollectRequest) Descriptor deprecated

func (*QANCollectRequest) Descriptor() ([]byte, []int)

Deprecated: Use QANCollectRequest.ProtoReflect.Descriptor instead.

func (*QANCollectRequest) GetMetricsBucket

func (x *QANCollectRequest) GetMetricsBucket() []*MetricsBucket

func (*QANCollectRequest) ProtoMessage

func (*QANCollectRequest) ProtoMessage()

func (*QANCollectRequest) ProtoReflect

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

func (*QANCollectRequest) Reset

func (x *QANCollectRequest) Reset()

func (*QANCollectRequest) String

func (x *QANCollectRequest) String() string

func (*QANCollectRequest) Validate

func (this *QANCollectRequest) Validate() error

type QANCollectResponse

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

QANCollectResponse is a ServerMessage for QAN data acceptance.

func (*QANCollectResponse) Descriptor deprecated

func (*QANCollectResponse) Descriptor() ([]byte, []int)

Deprecated: Use QANCollectResponse.ProtoReflect.Descriptor instead.

func (*QANCollectResponse) ProtoMessage

func (*QANCollectResponse) ProtoMessage()

func (*QANCollectResponse) ProtoReflect

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

func (*QANCollectResponse) Reset

func (x *QANCollectResponse) Reset()

func (*QANCollectResponse) ServerMessageResponsePayload

func (m *QANCollectResponse) ServerMessageResponsePayload() isServerMessage_Payload

func (*QANCollectResponse) String

func (x *QANCollectResponse) String() string

func (*QANCollectResponse) Validate

func (this *QANCollectResponse) Validate() error

type QueryActionMap

type QueryActionMap struct {
	Map map[string]*QueryActionValue `` /* 147-byte string literal not displayed */
	// contains filtered or unexported fields
}

QueryActionMap represents a map of values used in query Actions.

func (*QueryActionMap) Descriptor deprecated

func (*QueryActionMap) Descriptor() ([]byte, []int)

Deprecated: Use QueryActionMap.ProtoReflect.Descriptor instead.

func (*QueryActionMap) GetMap

func (x *QueryActionMap) GetMap() map[string]*QueryActionValue

func (*QueryActionMap) ProtoMessage

func (*QueryActionMap) ProtoMessage()

func (*QueryActionMap) ProtoReflect

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

func (*QueryActionMap) Reset

func (x *QueryActionMap) Reset()

func (*QueryActionMap) String

func (x *QueryActionMap) String() string

func (*QueryActionMap) Validate

func (this *QueryActionMap) Validate() error

type QueryActionResult

type QueryActionResult struct {

	// SQL result column names.
	Columns []string `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
	// SQL result data rows.
	Rows []*QueryActionSlice `protobuf:"bytes,2,rep,name=rows,proto3" json:"rows,omitempty"`
	// MongoDB documents.
	Docs []*QueryActionMap `protobuf:"bytes,3,rep,name=docs,proto3" json:"docs,omitempty"`
	// contains filtered or unexported fields
}

QueryActionResult represents query Action result.

func (*QueryActionResult) Descriptor deprecated

func (*QueryActionResult) Descriptor() ([]byte, []int)

Deprecated: Use QueryActionResult.ProtoReflect.Descriptor instead.

func (*QueryActionResult) GetColumns

func (x *QueryActionResult) GetColumns() []string

func (*QueryActionResult) GetDocs

func (x *QueryActionResult) GetDocs() []*QueryActionMap

func (*QueryActionResult) GetRows

func (x *QueryActionResult) GetRows() []*QueryActionSlice

func (*QueryActionResult) ProtoMessage

func (*QueryActionResult) ProtoMessage()

func (*QueryActionResult) ProtoReflect

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

func (*QueryActionResult) Reset

func (x *QueryActionResult) Reset()

func (*QueryActionResult) String

func (x *QueryActionResult) String() string

func (*QueryActionResult) Validate

func (this *QueryActionResult) Validate() error

type QueryActionSlice

type QueryActionSlice struct {
	Slice []*QueryActionValue `protobuf:"bytes,1,rep,name=slice,proto3" json:"slice,omitempty"`
	// contains filtered or unexported fields
}

QueryActionSlice represents a slice of values used in query Actions.

func (*QueryActionSlice) Descriptor deprecated

func (*QueryActionSlice) Descriptor() ([]byte, []int)

Deprecated: Use QueryActionSlice.ProtoReflect.Descriptor instead.

func (*QueryActionSlice) GetSlice

func (x *QueryActionSlice) GetSlice() []*QueryActionValue

func (*QueryActionSlice) ProtoMessage

func (*QueryActionSlice) ProtoMessage()

func (*QueryActionSlice) ProtoReflect

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

func (*QueryActionSlice) Reset

func (x *QueryActionSlice) Reset()

func (*QueryActionSlice) String

func (x *QueryActionSlice) String() string

func (*QueryActionSlice) Validate

func (this *QueryActionSlice) Validate() error

type QueryActionValue

type QueryActionValue struct {

	// Types that are assignable to Kind:
	//	*QueryActionValue_Nil
	//	*QueryActionValue_Bool
	//	*QueryActionValue_Int64
	//	*QueryActionValue_Uint64
	//	*QueryActionValue_Double
	//	*QueryActionValue_Bytes
	//	*QueryActionValue_Timestamp
	//	*QueryActionValue_Slice
	//	*QueryActionValue_Map
	Kind isQueryActionValue_Kind `protobuf_oneof:"kind"`
	// contains filtered or unexported fields
}

QueryActionValue represents a single value used in query Actions.

func (*QueryActionValue) Descriptor deprecated

func (*QueryActionValue) Descriptor() ([]byte, []int)

Deprecated: Use QueryActionValue.ProtoReflect.Descriptor instead.

func (*QueryActionValue) GetBool

func (x *QueryActionValue) GetBool() bool

func (*QueryActionValue) GetBytes

func (x *QueryActionValue) GetBytes() []byte

func (*QueryActionValue) GetDouble

func (x *QueryActionValue) GetDouble() float64

func (*QueryActionValue) GetInt64

func (x *QueryActionValue) GetInt64() int64

func (*QueryActionValue) GetKind

func (m *QueryActionValue) GetKind() isQueryActionValue_Kind

func (*QueryActionValue) GetMap

func (x *QueryActionValue) GetMap() *QueryActionMap

func (*QueryActionValue) GetNil

func (x *QueryActionValue) GetNil() bool

func (*QueryActionValue) GetSlice

func (x *QueryActionValue) GetSlice() *QueryActionSlice

func (*QueryActionValue) GetTimestamp

func (x *QueryActionValue) GetTimestamp() *timestamp.Timestamp

func (*QueryActionValue) GetUint64

func (x *QueryActionValue) GetUint64() uint64

func (*QueryActionValue) ProtoMessage

func (*QueryActionValue) ProtoMessage()

func (*QueryActionValue) ProtoReflect

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

func (*QueryActionValue) Reset

func (x *QueryActionValue) Reset()

func (*QueryActionValue) String

func (x *QueryActionValue) String() string

func (*QueryActionValue) Validate

func (this *QueryActionValue) Validate() error

type QueryActionValue_Bool

type QueryActionValue_Bool struct {
	Bool bool `protobuf:"varint,2,opt,name=bool,proto3,oneof"`
}

type QueryActionValue_Bytes

type QueryActionValue_Bytes struct {
	Bytes []byte `protobuf:"bytes,6,opt,name=bytes,proto3,oneof"`
}

type QueryActionValue_Double

type QueryActionValue_Double struct {
	Double float64 `protobuf:"fixed64,5,opt,name=double,proto3,oneof"`
}

type QueryActionValue_Int64

type QueryActionValue_Int64 struct {
	Int64 int64 `protobuf:"varint,3,opt,name=int64,proto3,oneof"`
}

type QueryActionValue_Map

type QueryActionValue_Map struct {
	Map *QueryActionMap `protobuf:"bytes,11,opt,name=map,proto3,oneof"`
}

type QueryActionValue_Nil

type QueryActionValue_Nil struct {
	Nil bool `protobuf:"varint,1,opt,name=nil,proto3,oneof"`
}

type QueryActionValue_Slice

type QueryActionValue_Slice struct {
	Slice *QueryActionSlice `protobuf:"bytes,10,opt,name=slice,proto3,oneof"`
}

type QueryActionValue_Timestamp

type QueryActionValue_Timestamp struct {
	Timestamp *timestamp.Timestamp `protobuf:"bytes,8,opt,name=timestamp,proto3,oneof"`
}

type QueryActionValue_Uint64

type QueryActionValue_Uint64 struct {
	Uint64 uint64 `protobuf:"varint,4,opt,name=uint64,proto3,oneof"`
}

type S3LocationConfig

type S3LocationConfig struct {
	Endpoint     string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	AccessKey    string `protobuf:"bytes,2,opt,name=access_key,json=accessKey,proto3" json:"access_key,omitempty"`
	SecretKey    string `protobuf:"bytes,3,opt,name=secret_key,json=secretKey,proto3" json:"secret_key,omitempty"`
	BucketName   string `protobuf:"bytes,4,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	BucketRegion string `protobuf:"bytes,5,opt,name=bucket_region,json=bucketRegion,proto3" json:"bucket_region,omitempty"`
	// contains filtered or unexported fields
}

S3LocationConfig represents S3 bucket configuration.

func (*S3LocationConfig) Descriptor deprecated

func (*S3LocationConfig) Descriptor() ([]byte, []int)

Deprecated: Use S3LocationConfig.ProtoReflect.Descriptor instead.

func (*S3LocationConfig) GetAccessKey

func (x *S3LocationConfig) GetAccessKey() string

func (*S3LocationConfig) GetBucketName

func (x *S3LocationConfig) GetBucketName() string

func (*S3LocationConfig) GetBucketRegion

func (x *S3LocationConfig) GetBucketRegion() string

func (*S3LocationConfig) GetEndpoint

func (x *S3LocationConfig) GetEndpoint() string

func (*S3LocationConfig) GetSecretKey

func (x *S3LocationConfig) GetSecretKey() string

func (*S3LocationConfig) ProtoMessage

func (*S3LocationConfig) ProtoMessage()

func (*S3LocationConfig) ProtoReflect

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

func (*S3LocationConfig) Reset

func (x *S3LocationConfig) Reset()

func (*S3LocationConfig) String

func (x *S3LocationConfig) String() string

func (*S3LocationConfig) Validate

func (this *S3LocationConfig) Validate() error

type ServerConnectMetadata

type ServerConnectMetadata struct {
	AgentRunsOnNodeID string
	ServerVersion     string
}

ServerConnectMetadata represents metadata sent by pmm-managed in response to Connect RPC method call.

func ReceiveServerConnectMetadata

func ReceiveServerConnectMetadata(stream grpc.ClientStream) (*ServerConnectMetadata, error)

ReceiveServerConnectMetadata receives pmm-managed's metadata. Used by pmm-agent.

type ServerMessage

type ServerMessage struct {
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// The responder sets the status field in two situations:
	// 1. When it received a request with the payload field not set.
	//    That means that responded is older than the requester, and doesn't know about newer payload types.
	//    Status code UNIMPLEMENTED (12) is reserved for that case.
	// 2. When the payload is set, but the request can't be performed due to some error.
	Status *status.Status `protobuf:"bytes,2047,opt,name=status,proto3" json:"status,omitempty"`
	// Types that are assignable to Payload:
	//	*ServerMessage_Pong
	//	*ServerMessage_StateChanged
	//	*ServerMessage_QanCollect
	//	*ServerMessage_ActionResult
	//	*ServerMessage_Ping
	//	*ServerMessage_SetState
	//	*ServerMessage_StartAction
	//	*ServerMessage_StopAction
	//	*ServerMessage_CheckConnection
	//	*ServerMessage_StartJob
	//	*ServerMessage_StopJob
	//	*ServerMessage_JobStatus
	Payload isServerMessage_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*ServerMessage) Descriptor deprecated

func (*ServerMessage) Descriptor() ([]byte, []int)

Deprecated: Use ServerMessage.ProtoReflect.Descriptor instead.

func (*ServerMessage) GetActionResult

func (x *ServerMessage) GetActionResult() *ActionResultResponse

func (*ServerMessage) GetCheckConnection

func (x *ServerMessage) GetCheckConnection() *CheckConnectionRequest

func (*ServerMessage) GetId

func (x *ServerMessage) GetId() uint32

func (*ServerMessage) GetJobStatus

func (x *ServerMessage) GetJobStatus() *JobStatusRequest

func (*ServerMessage) GetPayload

func (m *ServerMessage) GetPayload() isServerMessage_Payload

func (*ServerMessage) GetPing

func (x *ServerMessage) GetPing() *Ping

func (*ServerMessage) GetPong

func (x *ServerMessage) GetPong() *Pong

func (*ServerMessage) GetQanCollect

func (x *ServerMessage) GetQanCollect() *QANCollectResponse

func (*ServerMessage) GetSetState

func (x *ServerMessage) GetSetState() *SetStateRequest

func (*ServerMessage) GetStartAction

func (x *ServerMessage) GetStartAction() *StartActionRequest

func (*ServerMessage) GetStartJob

func (x *ServerMessage) GetStartJob() *StartJobRequest

func (*ServerMessage) GetStateChanged

func (x *ServerMessage) GetStateChanged() *StateChangedResponse

func (*ServerMessage) GetStatus

func (x *ServerMessage) GetStatus() *status.Status

func (*ServerMessage) GetStopAction

func (x *ServerMessage) GetStopAction() *StopActionRequest

func (*ServerMessage) GetStopJob

func (x *ServerMessage) GetStopJob() *StopJobRequest

func (*ServerMessage) ProtoMessage

func (*ServerMessage) ProtoMessage()

func (*ServerMessage) ProtoReflect

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

func (*ServerMessage) Reset

func (x *ServerMessage) Reset()

func (*ServerMessage) String

func (x *ServerMessage) String() string

func (*ServerMessage) Validate

func (this *ServerMessage) Validate() error

type ServerMessage_ActionResult

type ServerMessage_ActionResult struct {
	ActionResult *ActionResultResponse `protobuf:"bytes,5,opt,name=action_result,json=actionResult,proto3,oneof"`
}

type ServerMessage_CheckConnection

type ServerMessage_CheckConnection struct {
	CheckConnection *CheckConnectionRequest `protobuf:"bytes,12,opt,name=check_connection,json=checkConnection,proto3,oneof"`
}

type ServerMessage_JobStatus

type ServerMessage_JobStatus struct {
	JobStatus *JobStatusRequest `protobuf:"bytes,15,opt,name=job_status,json=jobStatus,proto3,oneof"`
}

type ServerMessage_Ping

type ServerMessage_Ping struct {
	// requests from server
	Ping *Ping `protobuf:"bytes,8,opt,name=ping,proto3,oneof"`
}

type ServerMessage_Pong

type ServerMessage_Pong struct {
	// responses from server
	Pong *Pong `protobuf:"bytes,2,opt,name=pong,proto3,oneof"`
}

type ServerMessage_QanCollect

type ServerMessage_QanCollect struct {
	QanCollect *QANCollectResponse `protobuf:"bytes,4,opt,name=qan_collect,json=qanCollect,proto3,oneof"`
}

type ServerMessage_SetState

type ServerMessage_SetState struct {
	SetState *SetStateRequest `protobuf:"bytes,9,opt,name=set_state,json=setState,proto3,oneof"`
}

type ServerMessage_StartAction

type ServerMessage_StartAction struct {
	StartAction *StartActionRequest `protobuf:"bytes,10,opt,name=start_action,json=startAction,proto3,oneof"`
}

type ServerMessage_StartJob

type ServerMessage_StartJob struct {
	StartJob *StartJobRequest `protobuf:"bytes,13,opt,name=start_job,json=startJob,proto3,oneof"`
}

type ServerMessage_StateChanged

type ServerMessage_StateChanged struct {
	StateChanged *StateChangedResponse `protobuf:"bytes,3,opt,name=state_changed,json=stateChanged,proto3,oneof"`
}

type ServerMessage_StopAction

type ServerMessage_StopAction struct {
	StopAction *StopActionRequest `protobuf:"bytes,11,opt,name=stop_action,json=stopAction,proto3,oneof"`
}

type ServerMessage_StopJob

type ServerMessage_StopJob struct {
	StopJob *StopJobRequest `protobuf:"bytes,14,opt,name=stop_job,json=stopJob,proto3,oneof"`
}

type ServerRequestPayload

type ServerRequestPayload interface {
	ServerMessageRequestPayload() isServerMessage_Payload
	// contains filtered or unexported methods
}

ServerRequestPayload represents server's request payload.

type ServerResponsePayload

type ServerResponsePayload interface {
	ServerMessageResponsePayload() isServerMessage_Payload
	// contains filtered or unexported methods
}

ServerResponsePayload represents server's response payload.

type SetStateRequest

type SetStateRequest struct {
	AgentProcesses map[string]*SetStateRequest_AgentProcess `` /* 191-byte string literal not displayed */
	BuiltinAgents  map[string]*SetStateRequest_BuiltinAgent `` /* 188-byte string literal not displayed */
	// contains filtered or unexported fields
}

SetStateRequest is a ServerMessage asking pmm-agent to run agents according to desired state.

func (*SetStateRequest) Descriptor deprecated

func (*SetStateRequest) Descriptor() ([]byte, []int)

Deprecated: Use SetStateRequest.ProtoReflect.Descriptor instead.

func (*SetStateRequest) GetAgentProcesses

func (x *SetStateRequest) GetAgentProcesses() map[string]*SetStateRequest_AgentProcess

func (*SetStateRequest) GetBuiltinAgents

func (x *SetStateRequest) GetBuiltinAgents() map[string]*SetStateRequest_BuiltinAgent

func (*SetStateRequest) ProtoMessage

func (*SetStateRequest) ProtoMessage()

func (*SetStateRequest) ProtoReflect

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

func (*SetStateRequest) Reset

func (x *SetStateRequest) Reset()

func (*SetStateRequest) ServerMessageRequestPayload

func (m *SetStateRequest) ServerMessageRequestPayload() isServerMessage_Payload

func (*SetStateRequest) String

func (x *SetStateRequest) String() string

func (*SetStateRequest) Validate

func (this *SetStateRequest) Validate() error

type SetStateRequest_AgentProcess

type SetStateRequest_AgentProcess struct {
	Type               inventorypb.AgentType `protobuf:"varint,1,opt,name=type,proto3,enum=inventory.AgentType" json:"type,omitempty"`
	TemplateLeftDelim  string                `protobuf:"bytes,2,opt,name=template_left_delim,json=templateLeftDelim,proto3" json:"template_left_delim,omitempty"`
	TemplateRightDelim string                `protobuf:"bytes,3,opt,name=template_right_delim,json=templateRightDelim,proto3" json:"template_right_delim,omitempty"`
	Args               []string              `protobuf:"bytes,4,rep,name=args,proto3" json:"args,omitempty"`
	Env                []string              `protobuf:"bytes,5,rep,name=env,proto3" json:"env,omitempty"`
	TextFiles          map[string]string     `` /* 176-byte string literal not displayed */
	RedactWords        []string              `protobuf:"bytes,7,rep,name=redact_words,json=redactWords,proto3" json:"redact_words,omitempty"`
	// contains filtered or unexported fields
}

AgentProcess describes desired configuration of a single agent process started by pmm-agent.

func (*SetStateRequest_AgentProcess) Descriptor deprecated

func (*SetStateRequest_AgentProcess) Descriptor() ([]byte, []int)

Deprecated: Use SetStateRequest_AgentProcess.ProtoReflect.Descriptor instead.

func (*SetStateRequest_AgentProcess) GetArgs

func (x *SetStateRequest_AgentProcess) GetArgs() []string

func (*SetStateRequest_AgentProcess) GetEnv

func (x *SetStateRequest_AgentProcess) GetEnv() []string

func (*SetStateRequest_AgentProcess) GetRedactWords

func (x *SetStateRequest_AgentProcess) GetRedactWords() []string

func (*SetStateRequest_AgentProcess) GetTemplateLeftDelim

func (x *SetStateRequest_AgentProcess) GetTemplateLeftDelim() string

func (*SetStateRequest_AgentProcess) GetTemplateRightDelim

func (x *SetStateRequest_AgentProcess) GetTemplateRightDelim() string

func (*SetStateRequest_AgentProcess) GetTextFiles

func (x *SetStateRequest_AgentProcess) GetTextFiles() map[string]string

func (*SetStateRequest_AgentProcess) GetType

func (*SetStateRequest_AgentProcess) ProtoMessage

func (*SetStateRequest_AgentProcess) ProtoMessage()

func (*SetStateRequest_AgentProcess) ProtoReflect

func (*SetStateRequest_AgentProcess) Reset

func (x *SetStateRequest_AgentProcess) Reset()

func (*SetStateRequest_AgentProcess) String

func (*SetStateRequest_AgentProcess) Validate

func (this *SetStateRequest_AgentProcess) Validate() error

type SetStateRequest_BuiltinAgent

type SetStateRequest_BuiltinAgent struct {
	Type inventorypb.AgentType `protobuf:"varint,1,opt,name=type,proto3,enum=inventory.AgentType" json:"type,omitempty"`
	Dsn  string                `protobuf:"bytes,2,opt,name=dsn,proto3" json:"dsn,omitempty"`
	// Disables query examples for QAN Agents if true.
	DisableQueryExamples bool `protobuf:"varint,3,opt,name=disable_query_examples,json=disableQueryExamples,proto3" json:"disable_query_examples,omitempty"`
	// Instructs QAN Agents to rotate query log file or table at this size if > 0.
	MaxQueryLogSize int64 `protobuf:"varint,4,opt,name=max_query_log_size,json=maxQueryLogSize,proto3" json:"max_query_log_size,omitempty"`
	// Contains files and their contents which can be used in DSN.
	TextFiles *TextFiles `protobuf:"bytes,5,opt,name=text_files,json=textFiles,proto3" json:"text_files,omitempty"`
	// TLS in enabled if true.
	Tls bool `protobuf:"varint,6,opt,name=tls,proto3" json:"tls,omitempty"`
	// TLS certificate wont be verified.
	TlsSkipVerify bool `protobuf:"varint,7,opt,name=tls_skip_verify,json=tlsSkipVerify,proto3" json:"tls_skip_verify,omitempty"`
	// contains filtered or unexported fields
}

BuiltinAgent describes desired configuration of a single built-in agent for pmm-agent.

func (*SetStateRequest_BuiltinAgent) Descriptor deprecated

func (*SetStateRequest_BuiltinAgent) Descriptor() ([]byte, []int)

Deprecated: Use SetStateRequest_BuiltinAgent.ProtoReflect.Descriptor instead.

func (*SetStateRequest_BuiltinAgent) GetDisableQueryExamples

func (x *SetStateRequest_BuiltinAgent) GetDisableQueryExamples() bool

func (*SetStateRequest_BuiltinAgent) GetDsn

func (*SetStateRequest_BuiltinAgent) GetMaxQueryLogSize

func (x *SetStateRequest_BuiltinAgent) GetMaxQueryLogSize() int64

func (*SetStateRequest_BuiltinAgent) GetTextFiles

func (x *SetStateRequest_BuiltinAgent) GetTextFiles() *TextFiles

func (*SetStateRequest_BuiltinAgent) GetTls

func (x *SetStateRequest_BuiltinAgent) GetTls() bool

func (*SetStateRequest_BuiltinAgent) GetTlsSkipVerify

func (x *SetStateRequest_BuiltinAgent) GetTlsSkipVerify() bool

func (*SetStateRequest_BuiltinAgent) GetType

func (*SetStateRequest_BuiltinAgent) ProtoMessage

func (*SetStateRequest_BuiltinAgent) ProtoMessage()

func (*SetStateRequest_BuiltinAgent) ProtoReflect

func (*SetStateRequest_BuiltinAgent) Reset

func (x *SetStateRequest_BuiltinAgent) Reset()

func (*SetStateRequest_BuiltinAgent) String

func (*SetStateRequest_BuiltinAgent) Validate

func (this *SetStateRequest_BuiltinAgent) Validate() error

type SetStateResponse

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

SetStateResponse is an AgentMessage for SetStateRequest acceptance.

func (*SetStateResponse) AgentMessageResponsePayload

func (m *SetStateResponse) AgentMessageResponsePayload() isAgentMessage_Payload

func (*SetStateResponse) Descriptor deprecated

func (*SetStateResponse) Descriptor() ([]byte, []int)

Deprecated: Use SetStateResponse.ProtoReflect.Descriptor instead.

func (*SetStateResponse) ProtoMessage

func (*SetStateResponse) ProtoMessage()

func (*SetStateResponse) ProtoReflect

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

func (*SetStateResponse) Reset

func (x *SetStateResponse) Reset()

func (*SetStateResponse) String

func (x *SetStateResponse) String() string

func (*SetStateResponse) Validate

func (this *SetStateResponse) Validate() error

type StartActionRequest

type StartActionRequest struct {
	ActionId string `protobuf:"bytes,1,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
	// Types that are assignable to Params:
	//	*StartActionRequest_MysqlExplainParams
	//	*StartActionRequest_MysqlShowCreateTableParams
	//	*StartActionRequest_MysqlShowTableStatusParams
	//	*StartActionRequest_MysqlShowIndexParams
	//	*StartActionRequest_PostgresqlShowCreateTableParams
	//	*StartActionRequest_PostgresqlShowIndexParams
	//	*StartActionRequest_MongodbExplainParams
	//	*StartActionRequest_PtSummaryParams
	//	*StartActionRequest_PtPgSummaryParams
	//	*StartActionRequest_PtMongodbSummaryParams
	//	*StartActionRequest_PtMysqlSummaryParams
	//	*StartActionRequest_MysqlQueryShowParams
	//	*StartActionRequest_MysqlQuerySelectParams
	//	*StartActionRequest_PostgresqlQueryShowParams
	//	*StartActionRequest_PostgresqlQuerySelectParams
	//	*StartActionRequest_MongodbQueryGetparameterParams
	//	*StartActionRequest_MongodbQueryBuildinfoParams
	//	*StartActionRequest_MongodbQueryGetcmdlineoptsParams
	Params isStartActionRequest_Params `protobuf_oneof:"params"`
	// Timeout for the whole action. If zero or absent, pmm-agent will pick one itself.
	Timeout *duration.Duration `protobuf:"bytes,9,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

StartActionRequest is a ServerMessage asking pmm-agent to start action.

func (*StartActionRequest) Descriptor deprecated

func (*StartActionRequest) Descriptor() ([]byte, []int)

Deprecated: Use StartActionRequest.ProtoReflect.Descriptor instead.

func (*StartActionRequest) GetActionId

func (x *StartActionRequest) GetActionId() string

func (*StartActionRequest) GetMongodbExplainParams

func (x *StartActionRequest) GetMongodbExplainParams() *StartActionRequest_MongoDBExplainParams

func (*StartActionRequest) GetMongodbQueryBuildinfoParams

func (x *StartActionRequest) GetMongodbQueryBuildinfoParams() *StartActionRequest_MongoDBQueryBuildInfoParams

func (*StartActionRequest) GetMongodbQueryGetcmdlineoptsParams

func (x *StartActionRequest) GetMongodbQueryGetcmdlineoptsParams() *StartActionRequest_MongoDBQueryGetCmdLineOptsParams

func (*StartActionRequest) GetMongodbQueryGetparameterParams

func (x *StartActionRequest) GetMongodbQueryGetparameterParams() *StartActionRequest_MongoDBQueryGetParameterParams

func (*StartActionRequest) GetMysqlExplainParams

func (x *StartActionRequest) GetMysqlExplainParams() *StartActionRequest_MySQLExplainParams

func (*StartActionRequest) GetMysqlQuerySelectParams

func (x *StartActionRequest) GetMysqlQuerySelectParams() *StartActionRequest_MySQLQuerySelectParams

func (*StartActionRequest) GetMysqlQueryShowParams

func (x *StartActionRequest) GetMysqlQueryShowParams() *StartActionRequest_MySQLQueryShowParams

func (*StartActionRequest) GetMysqlShowCreateTableParams

func (x *StartActionRequest) GetMysqlShowCreateTableParams() *StartActionRequest_MySQLShowCreateTableParams

func (*StartActionRequest) GetMysqlShowIndexParams

func (x *StartActionRequest) GetMysqlShowIndexParams() *StartActionRequest_MySQLShowIndexParams

func (*StartActionRequest) GetMysqlShowTableStatusParams

func (x *StartActionRequest) GetMysqlShowTableStatusParams() *StartActionRequest_MySQLShowTableStatusParams

func (*StartActionRequest) GetParams

func (m *StartActionRequest) GetParams() isStartActionRequest_Params

func (*StartActionRequest) GetPostgresqlQuerySelectParams

func (x *StartActionRequest) GetPostgresqlQuerySelectParams() *StartActionRequest_PostgreSQLQuerySelectParams

func (*StartActionRequest) GetPostgresqlQueryShowParams

func (x *StartActionRequest) GetPostgresqlQueryShowParams() *StartActionRequest_PostgreSQLQueryShowParams

func (*StartActionRequest) GetPostgresqlShowCreateTableParams

func (x *StartActionRequest) GetPostgresqlShowCreateTableParams() *StartActionRequest_PostgreSQLShowCreateTableParams

func (*StartActionRequest) GetPostgresqlShowIndexParams

func (x *StartActionRequest) GetPostgresqlShowIndexParams() *StartActionRequest_PostgreSQLShowIndexParams

func (*StartActionRequest) GetPtMongodbSummaryParams

func (x *StartActionRequest) GetPtMongodbSummaryParams() *StartActionRequest_PTMongoDBSummaryParams

func (*StartActionRequest) GetPtMysqlSummaryParams

func (x *StartActionRequest) GetPtMysqlSummaryParams() *StartActionRequest_PTMySQLSummaryParams

func (*StartActionRequest) GetPtPgSummaryParams

func (x *StartActionRequest) GetPtPgSummaryParams() *StartActionRequest_PTPgSummaryParams

func (*StartActionRequest) GetPtSummaryParams

func (x *StartActionRequest) GetPtSummaryParams() *StartActionRequest_PTSummaryParams

func (*StartActionRequest) GetTimeout

func (x *StartActionRequest) GetTimeout() *duration.Duration

func (*StartActionRequest) ProtoMessage

func (*StartActionRequest) ProtoMessage()

func (*StartActionRequest) ProtoReflect

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

func (*StartActionRequest) Reset

func (x *StartActionRequest) Reset()

func (*StartActionRequest) ServerMessageRequestPayload

func (m *StartActionRequest) ServerMessageRequestPayload() isServerMessage_Payload

func (*StartActionRequest) String

func (x *StartActionRequest) String() string

func (*StartActionRequest) Validate

func (this *StartActionRequest) Validate() error

type StartActionRequest_MongoDBExplainParams

type StartActionRequest_MongoDBExplainParams struct {

	// DSN for the service. May contain connection (dial) timeout.
	// May contain placeholders for file paths in DSN.
	Dsn   string `protobuf:"bytes,1,opt,name=dsn,proto3" json:"dsn,omitempty"`
	Query string `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	// Contains files and their contents which can be used in DSN.
	TextFiles *TextFiles `protobuf:"bytes,3,opt,name=text_files,json=textFiles,proto3" json:"text_files,omitempty"`
	// contains filtered or unexported fields
}

MongoDBExplainParams describes MongoDB EXPLAIN action parameters.

func (*StartActionRequest_MongoDBExplainParams) Descriptor deprecated

func (*StartActionRequest_MongoDBExplainParams) Descriptor() ([]byte, []int)

Deprecated: Use StartActionRequest_MongoDBExplainParams.ProtoReflect.Descriptor instead.

func (*StartActionRequest_MongoDBExplainParams) GetDsn

func (*StartActionRequest_MongoDBExplainParams) GetQuery

func (*StartActionRequest_MongoDBExplainParams) GetTextFiles

func (*StartActionRequest_MongoDBExplainParams) ProtoMessage

func (*StartActionRequest_MongoDBExplainParams) ProtoReflect

func (*StartActionRequest_MongoDBExplainParams) Reset

func (*StartActionRequest_MongoDBExplainParams) String

func (*StartActionRequest_MongoDBExplainParams) Validate

type StartActionRequest_MongoDBQueryBuildInfoParams

type StartActionRequest_MongoDBQueryBuildInfoParams struct {

	// DSN for the service. May contain connection (dial) timeout.
	// May contain placeholders for file paths in DSN.
	Dsn string `protobuf:"bytes,1,opt,name=dsn,proto3" json:"dsn,omitempty"`
	// Contains files and their contents which can be used in DSN.
	TextFiles *TextFiles `protobuf:"bytes,2,opt,name=text_files,json=textFiles,proto3" json:"text_files,omitempty"`
	// contains filtered or unexported fields
}

MongoDBQueryBuildInfoParams describes MongoDB buildInfo query action parameters.

func (*StartActionRequest_MongoDBQueryBuildInfoParams) Descriptor deprecated

Deprecated: Use StartActionRequest_MongoDBQueryBuildInfoParams.ProtoReflect.Descriptor instead.

func (*StartActionRequest_MongoDBQueryBuildInfoParams) GetDsn

func (*StartActionRequest_MongoDBQueryBuildInfoParams) GetTextFiles

func (*StartActionRequest_MongoDBQueryBuildInfoParams) ProtoMessage

func (*StartActionRequest_MongoDBQueryBuildInfoParams) ProtoReflect

func (*StartActionRequest_MongoDBQueryBuildInfoParams) Reset

func (*StartActionRequest_MongoDBQueryBuildInfoParams) String

func (*StartActionRequest_MongoDBQueryBuildInfoParams) Validate

type StartActionRequest_MongoDBQueryGetCmdLineOptsParams

type StartActionRequest_MongoDBQueryGetCmdLineOptsParams struct {

	// DSN for the service. May contain connection (dial) timeout.
	// May contain placeholders for file paths in DSN.
	Dsn string `protobuf:"bytes,1,opt,name=dsn,proto3" json:"dsn,omitempty"`
	// Contains files and their contents which can be used in DSN.
	TextFiles *TextFiles `protobuf:"bytes,2,opt,name=text_files,json=textFiles,proto3" json:"text_files,omitempty"`
	// contains filtered or unexported fields
}

MongoDBQueryGetCmdLineOptsParams describes MongoDB getCmdLineOpts query action parameters.

func (*StartActionRequest_MongoDBQueryGetCmdLineOptsParams) Descriptor deprecated

Deprecated: Use StartActionRequest_MongoDBQueryGetCmdLineOptsParams.ProtoReflect.Descriptor instead.

func (*StartActionRequest_MongoDBQueryGetCmdLineOptsParams) GetDsn

func (*StartActionRequest_MongoDBQueryGetCmdLineOptsParams) GetTextFiles

func (*StartActionRequest_MongoDBQueryGetCmdLineOptsParams) ProtoMessage

func (*StartActionRequest_MongoDBQueryGetCmdLineOptsParams) ProtoReflect

func (*StartActionRequest_MongoDBQueryGetCmdLineOptsParams) Reset

func (*StartActionRequest_MongoDBQueryGetCmdLineOptsParams) String

func (*StartActionRequest_MongoDBQueryGetCmdLineOptsParams) Validate

type StartActionRequest_MongoDBQueryGetParameterParams

type StartActionRequest_MongoDBQueryGetParameterParams struct {

	// DSN for the service. May contain connection (dial) timeout.
	// May contain placeholders for file paths in DSN.
	Dsn string `protobuf:"bytes,1,opt,name=dsn,proto3" json:"dsn,omitempty"`
	// Contains files and their contents which can be used in DSN.
	TextFiles *TextFiles `protobuf:"bytes,2,opt,name=text_files,json=textFiles,proto3" json:"text_files,omitempty"`
	// contains filtered or unexported fields
}

MongoDBQueryGetParameterParams describes MongoDB getParameter query action parameters.

func (*StartActionRequest_MongoDBQueryGetParameterParams) Descriptor deprecated

Deprecated: Use StartActionRequest_MongoDBQueryGetParameterParams.ProtoReflect.Descriptor instead.

func (*StartActionRequest_MongoDBQueryGetParameterParams) GetDsn

func (*StartActionRequest_MongoDBQueryGetParameterParams) GetTextFiles

func (*StartActionRequest_MongoDBQueryGetParameterParams) ProtoMessage

func (*StartActionRequest_MongoDBQueryGetParameterParams) ProtoReflect

func (*StartActionRequest_MongoDBQueryGetParameterParams) Reset

func (*StartActionRequest_MongoDBQueryGetParameterParams) String

func (*StartActionRequest_MongoDBQueryGetParameterParams) Validate

type StartActionRequest_MongodbExplainParams

type StartActionRequest_MongodbExplainParams struct {
	MongodbExplainParams *StartActionRequest_MongoDBExplainParams `protobuf:"bytes,8,opt,name=mongodb_explain_params,json=mongodbExplainParams,proto3,oneof"`
}

type StartActionRequest_MongodbQueryBuildinfoParams

type StartActionRequest_MongodbQueryBuildinfoParams struct {
	MongodbQueryBuildinfoParams *StartActionRequest_MongoDBQueryBuildInfoParams `protobuf:"bytes,55,opt,name=mongodb_query_buildinfo_params,json=mongodbQueryBuildinfoParams,proto3,oneof"`
}

type StartActionRequest_MongodbQueryGetcmdlineoptsParams

type StartActionRequest_MongodbQueryGetcmdlineoptsParams struct {
	MongodbQueryGetcmdlineoptsParams *StartActionRequest_MongoDBQueryGetCmdLineOptsParams `protobuf:"bytes,56,opt,name=mongodb_query_getcmdlineopts_params,json=mongodbQueryGetcmdlineoptsParams,proto3,oneof"`
}

type StartActionRequest_MongodbQueryGetparameterParams

type StartActionRequest_MongodbQueryGetparameterParams struct {
	MongodbQueryGetparameterParams *StartActionRequest_MongoDBQueryGetParameterParams `protobuf:"bytes,54,opt,name=mongodb_query_getparameter_params,json=mongodbQueryGetparameterParams,proto3,oneof"`
}

type StartActionRequest_MySQLExplainParams

type StartActionRequest_MySQLExplainParams struct {

	// DSN for the service. May contain connection (dial) timeout.
	Dsn          string                   `protobuf:"bytes,1,opt,name=dsn,proto3" json:"dsn,omitempty"`
	Query        string                   `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	OutputFormat MysqlExplainOutputFormat `` /* 134-byte string literal not displayed */
	// Contains files and their contents which can be used in DSN.
	TlsFiles *TextFiles `protobuf:"bytes,4,opt,name=tls_files,json=tlsFiles,proto3" json:"tls_files,omitempty"`
	// TLS certificate wont be verified.
	TlsSkipVerify bool `protobuf:"varint,5,opt,name=tls_skip_verify,json=tlsSkipVerify,proto3" json:"tls_skip_verify,omitempty"`
	// contains filtered or unexported fields
}

MySQLExplainParams describes MySQL EXPLAIN action parameters.

func (*StartActionRequest_MySQLExplainParams) Descriptor deprecated

func (*StartActionRequest_MySQLExplainParams) Descriptor() ([]byte, []int)

Deprecated: Use StartActionRequest_MySQLExplainParams.ProtoReflect.Descriptor instead.

func (*StartActionRequest_MySQLExplainParams) GetDsn

func (*StartActionRequest_MySQLExplainParams) GetOutputFormat

func (*StartActionRequest_MySQLExplainParams) GetQuery

func (*StartActionRequest_MySQLExplainParams) GetTlsFiles

func (*StartActionRequest_MySQLExplainParams) GetTlsSkipVerify

func (x *StartActionRequest_MySQLExplainParams) GetTlsSkipVerify() bool

func (*StartActionRequest_MySQLExplainParams) ProtoMessage

func (*StartActionRequest_MySQLExplainParams) ProtoMessage()

func (*StartActionRequest_MySQLExplainParams) ProtoReflect

func (*StartActionRequest_MySQLExplainParams) Reset

func (*StartActionRequest_MySQLExplainParams) String

func (*StartActionRequest_MySQLExplainParams) Validate

type StartActionRequest_MySQLQuerySelectParams

type StartActionRequest_MySQLQuerySelectParams struct {

	// DSN for the service. May contain connection (dial) timeout.
	Dsn string `protobuf:"bytes,1,opt,name=dsn,proto3" json:"dsn,omitempty"`
	// Query suffix (without leading SELECT).
	Query string `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	// Contains files and their contents which can be used in DSN.
	TlsFiles *TextFiles `protobuf:"bytes,3,opt,name=tls_files,json=tlsFiles,proto3" json:"tls_files,omitempty"`
	// TLS certificate wont be verified.
	TlsSkipVerify bool `protobuf:"varint,4,opt,name=tls_skip_verify,json=tlsSkipVerify,proto3" json:"tls_skip_verify,omitempty"`
	// contains filtered or unexported fields
}

MySQLQuerySelectParams describes MySQL SELECT query action parameters.

func (*StartActionRequest_MySQLQuerySelectParams) Descriptor deprecated

func (*StartActionRequest_MySQLQuerySelectParams) Descriptor() ([]byte, []int)

Deprecated: Use StartActionRequest_MySQLQuerySelectParams.ProtoReflect.Descriptor instead.

func (*StartActionRequest_MySQLQuerySelectParams) GetDsn

func (*StartActionRequest_MySQLQuerySelectParams) GetQuery

func (*StartActionRequest_MySQLQuerySelectParams) GetTlsFiles

func (*StartActionRequest_MySQLQuerySelectParams) GetTlsSkipVerify

func (x *StartActionRequest_MySQLQuerySelectParams) GetTlsSkipVerify() bool

func (*StartActionRequest_MySQLQuerySelectParams) ProtoMessage

func (*StartActionRequest_MySQLQuerySelectParams) ProtoReflect

func (*StartActionRequest_MySQLQuerySelectParams) Reset

func (*StartActionRequest_MySQLQuerySelectParams) String

func (*StartActionRequest_MySQLQuerySelectParams) Validate

type StartActionRequest_MySQLQueryShowParams

type StartActionRequest_MySQLQueryShowParams struct {

	// DSN for the service. May contain connection (dial) timeout.
	Dsn string `protobuf:"bytes,1,opt,name=dsn,proto3" json:"dsn,omitempty"`
	// Query suffix (without leading SHOW).
	Query string `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	// Contains files and their contents which can be used in DSN.
	TlsFiles *TextFiles `protobuf:"bytes,3,opt,name=tls_files,json=tlsFiles,proto3" json:"tls_files,omitempty"`
	// TLS certificate wont be verified.
	TlsSkipVerify bool `protobuf:"varint,4,opt,name=tls_skip_verify,json=tlsSkipVerify,proto3" json:"tls_skip_verify,omitempty"`
	// contains filtered or unexported fields
}

MySQLQueryShowParams describes MySQL SHOW query action parameters.

func (*StartActionRequest_MySQLQueryShowParams) Descriptor deprecated

func (*StartActionRequest_MySQLQueryShowParams) Descriptor() ([]byte, []int)

Deprecated: Use StartActionRequest_MySQLQueryShowParams.ProtoReflect.Descriptor instead.

func (*StartActionRequest_MySQLQueryShowParams) GetDsn

func (*StartActionRequest_MySQLQueryShowParams) GetQuery

func (*StartActionRequest_MySQLQueryShowParams) GetTlsFiles

func (*StartActionRequest_MySQLQueryShowParams) GetTlsSkipVerify

func (x *StartActionRequest_MySQLQueryShowParams) GetTlsSkipVerify() bool

func (*StartActionRequest_MySQLQueryShowParams) ProtoMessage

func (*StartActionRequest_MySQLQueryShowParams) ProtoReflect

func (*StartActionRequest_MySQLQueryShowParams) Reset

func (*StartActionRequest_MySQLQueryShowParams) String

func (*StartActionRequest_MySQLQueryShowParams) Validate

type StartActionRequest_MySQLShowCreateTableParams

type StartActionRequest_MySQLShowCreateTableParams struct {

	// DSN for the service. May contain connection (dial) timeout.
	Dsn   string `protobuf:"bytes,1,opt,name=dsn,proto3" json:"dsn,omitempty"`
	Table string `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	// Contains files and their contents which can be used in DSN.
	TlsFiles *TextFiles `protobuf:"bytes,3,opt,name=tls_files,json=tlsFiles,proto3" json:"tls_files,omitempty"`
	// TLS certificate wont be verified.
	TlsSkipVerify bool `protobuf:"varint,4,opt,name=tls_skip_verify,json=tlsSkipVerify,proto3" json:"tls_skip_verify,omitempty"`
	// contains filtered or unexported fields
}

MySQLShowCreateTableParams describes MySQL SHOW CREATE TABLE action parameters.

func (*StartActionRequest_MySQLShowCreateTableParams) Descriptor deprecated

Deprecated: Use StartActionRequest_MySQLShowCreateTableParams.ProtoReflect.Descriptor instead.

func (*StartActionRequest_MySQLShowCreateTableParams) GetDsn

func (*StartActionRequest_MySQLShowCreateTableParams) GetTable

func (*StartActionRequest_MySQLShowCreateTableParams) GetTlsFiles

func (*StartActionRequest_MySQLShowCreateTableParams) GetTlsSkipVerify

func (*StartActionRequest_MySQLShowCreateTableParams) ProtoMessage

func (*StartActionRequest_MySQLShowCreateTableParams) ProtoReflect

func (*StartActionRequest_MySQLShowCreateTableParams) Reset

func (*StartActionRequest_MySQLShowCreateTableParams) String

func (*StartActionRequest_MySQLShowCreateTableParams) Validate

type StartActionRequest_MySQLShowIndexParams

type StartActionRequest_MySQLShowIndexParams struct {

	// DSN for the service. May contain connection (dial) timeout.
	Dsn   string `protobuf:"bytes,1,opt,name=dsn,proto3" json:"dsn,omitempty"`
	Table string `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	// Contains files and their contents which can be used in DSN.
	TlsFiles *TextFiles `protobuf:"bytes,3,opt,name=tls_files,json=tlsFiles,proto3" json:"tls_files,omitempty"`
	// TLS certificate wont be verified.
	TlsSkipVerify bool `protobuf:"varint,4,opt,name=tls_skip_verify,json=tlsSkipVerify,proto3" json:"tls_skip_verify,omitempty"`
	// contains filtered or unexported fields
}

MySQLShowIndexParams describes MySQL SHOW INDEX action parameters.

func (*StartActionRequest_MySQLShowIndexParams) Descriptor deprecated

func (*StartActionRequest_MySQLShowIndexParams) Descriptor() ([]byte, []int)

Deprecated: Use StartActionRequest_MySQLShowIndexParams.ProtoReflect.Descriptor instead.

func (*StartActionRequest_MySQLShowIndexParams) GetDsn

func (*StartActionRequest_MySQLShowIndexParams) GetTable

func (*StartActionRequest_MySQLShowIndexParams) GetTlsFiles

func (*StartActionRequest_MySQLShowIndexParams) GetTlsSkipVerify

func (x *StartActionRequest_MySQLShowIndexParams) GetTlsSkipVerify() bool

func (*StartActionRequest_MySQLShowIndexParams) ProtoMessage

func (*StartActionRequest_MySQLShowIndexParams) ProtoReflect

func (*StartActionRequest_MySQLShowIndexParams) Reset

func (*StartActionRequest_MySQLShowIndexParams) String

func (*StartActionRequest_MySQLShowIndexParams) Validate

type StartActionRequest_MySQLShowTableStatusParams

type StartActionRequest_MySQLShowTableStatusParams struct {

	// DSN for the service. May contain connection (dial) timeout.
	Dsn   string `protobuf:"bytes,1,opt,name=dsn,proto3" json:"dsn,omitempty"`
	Table string `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	// Contains files and their contents which can be used in DSN.
	TlsFiles *TextFiles `protobuf:"bytes,3,opt,name=tls_files,json=tlsFiles,proto3" json:"tls_files,omitempty"`
	// TLS certificate wont be verified.
	TlsSkipVerify bool `protobuf:"varint,4,opt,name=tls_skip_verify,json=tlsSkipVerify,proto3" json:"tls_skip_verify,omitempty"`
	// contains filtered or unexported fields
}

MySQLShowTableStatusParams describes MySQL SHOW TABLE STATUS action parameters.

func (*StartActionRequest_MySQLShowTableStatusParams) Descriptor deprecated

Deprecated: Use StartActionRequest_MySQLShowTableStatusParams.ProtoReflect.Descriptor instead.

func (*StartActionRequest_MySQLShowTableStatusParams) GetDsn

func (*StartActionRequest_MySQLShowTableStatusParams) GetTable

func (*StartActionRequest_MySQLShowTableStatusParams) GetTlsFiles

func (*StartActionRequest_MySQLShowTableStatusParams) GetTlsSkipVerify

func (*StartActionRequest_MySQLShowTableStatusParams) ProtoMessage

func (*StartActionRequest_MySQLShowTableStatusParams) ProtoReflect

func (*StartActionRequest_MySQLShowTableStatusParams) Reset

func (*StartActionRequest_MySQLShowTableStatusParams) String

func (*StartActionRequest_MySQLShowTableStatusParams) Validate

type StartActionRequest_MysqlExplainParams

type StartActionRequest_MysqlExplainParams struct {
	MysqlExplainParams *StartActionRequest_MySQLExplainParams `protobuf:"bytes,2,opt,name=mysql_explain_params,json=mysqlExplainParams,proto3,oneof"`
}

type StartActionRequest_MysqlQuerySelectParams

type StartActionRequest_MysqlQuerySelectParams struct {
	MysqlQuerySelectParams *StartActionRequest_MySQLQuerySelectParams `protobuf:"bytes,51,opt,name=mysql_query_select_params,json=mysqlQuerySelectParams,proto3,oneof"`
}

type StartActionRequest_MysqlQueryShowParams

type StartActionRequest_MysqlQueryShowParams struct {
	MysqlQueryShowParams *StartActionRequest_MySQLQueryShowParams `protobuf:"bytes,50,opt,name=mysql_query_show_params,json=mysqlQueryShowParams,proto3,oneof"`
}

type StartActionRequest_MysqlShowCreateTableParams

type StartActionRequest_MysqlShowCreateTableParams struct {
	MysqlShowCreateTableParams *StartActionRequest_MySQLShowCreateTableParams `protobuf:"bytes,3,opt,name=mysql_show_create_table_params,json=mysqlShowCreateTableParams,proto3,oneof"`
}

type StartActionRequest_MysqlShowIndexParams

type StartActionRequest_MysqlShowIndexParams struct {
	MysqlShowIndexParams *StartActionRequest_MySQLShowIndexParams `protobuf:"bytes,5,opt,name=mysql_show_index_params,json=mysqlShowIndexParams,proto3,oneof"`
}

type StartActionRequest_MysqlShowTableStatusParams

type StartActionRequest_MysqlShowTableStatusParams struct {
	MysqlShowTableStatusParams *StartActionRequest_MySQLShowTableStatusParams `protobuf:"bytes,4,opt,name=mysql_show_table_status_params,json=mysqlShowTableStatusParams,proto3,oneof"`
}

type StartActionRequest_PTMongoDBSummaryParams

type StartActionRequest_PTMongoDBSummaryParams struct {
	Host     string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Port     uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	Username string `protobuf:"bytes,3,opt,name=username,proto3" json:"username,omitempty"`
	Password string `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

PTMongoDBSummaryParams describes parameters for PT MongoDB summary.

func (*StartActionRequest_PTMongoDBSummaryParams) Descriptor deprecated

func (*StartActionRequest_PTMongoDBSummaryParams) Descriptor() ([]byte, []int)

Deprecated: Use StartActionRequest_PTMongoDBSummaryParams.ProtoReflect.Descriptor instead.

func (*StartActionRequest_PTMongoDBSummaryParams) GetHost

func (*StartActionRequest_PTMongoDBSummaryParams) GetPassword

func (*StartActionRequest_PTMongoDBSummaryParams) GetPort

func (*StartActionRequest_PTMongoDBSummaryParams) GetUsername

func (*StartActionRequest_PTMongoDBSummaryParams) ProtoMessage

func (*StartActionRequest_PTMongoDBSummaryParams) ProtoReflect

func (*StartActionRequest_PTMongoDBSummaryParams) Reset

func (*StartActionRequest_PTMongoDBSummaryParams) String

func (*StartActionRequest_PTMongoDBSummaryParams) Validate

type StartActionRequest_PTMySQLSummaryParams

type StartActionRequest_PTMySQLSummaryParams struct {
	Host     string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Port     uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	Socket   string `protobuf:"bytes,3,opt,name=socket,proto3" json:"socket,omitempty"`
	Username string `protobuf:"bytes,4,opt,name=username,proto3" json:"username,omitempty"`
	Password string `protobuf:"bytes,5,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

PTMySQLSummaryParams describes parameters for PT MySQL summary.

func (*StartActionRequest_PTMySQLSummaryParams) Descriptor deprecated

func (*StartActionRequest_PTMySQLSummaryParams) Descriptor() ([]byte, []int)

Deprecated: Use StartActionRequest_PTMySQLSummaryParams.ProtoReflect.Descriptor instead.

func (*StartActionRequest_PTMySQLSummaryParams) GetHost

func (*StartActionRequest_PTMySQLSummaryParams) GetPassword

func (*StartActionRequest_PTMySQLSummaryParams) GetPort

func (*StartActionRequest_PTMySQLSummaryParams) GetSocket

func (*StartActionRequest_PTMySQLSummaryParams) GetUsername

func (*StartActionRequest_PTMySQLSummaryParams) ProtoMessage

func (*StartActionRequest_PTMySQLSummaryParams) ProtoReflect

func (*StartActionRequest_PTMySQLSummaryParams) Reset

func (*StartActionRequest_PTMySQLSummaryParams) String

func (*StartActionRequest_PTMySQLSummaryParams) Validate

type StartActionRequest_PTPgSummaryParams

type StartActionRequest_PTPgSummaryParams struct {
	Host     string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Port     uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	Username string `protobuf:"bytes,3,opt,name=username,proto3" json:"username,omitempty"`
	Password string `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

PTPgSummaryParams describes parameters for PT PG summary.

func (*StartActionRequest_PTPgSummaryParams) Descriptor deprecated

func (*StartActionRequest_PTPgSummaryParams) Descriptor() ([]byte, []int)

Deprecated: Use StartActionRequest_PTPgSummaryParams.ProtoReflect.Descriptor instead.

func (*StartActionRequest_PTPgSummaryParams) GetHost

func (*StartActionRequest_PTPgSummaryParams) GetPassword

func (*StartActionRequest_PTPgSummaryParams) GetPort

func (*StartActionRequest_PTPgSummaryParams) GetUsername

func (*StartActionRequest_PTPgSummaryParams) ProtoMessage

func (*StartActionRequest_PTPgSummaryParams) ProtoMessage()

func (*StartActionRequest_PTPgSummaryParams) ProtoReflect

func (*StartActionRequest_PTPgSummaryParams) Reset

func (*StartActionRequest_PTPgSummaryParams) String

func (*StartActionRequest_PTPgSummaryParams) Validate

type StartActionRequest_PTSummaryParams

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

PTSummaryParams describes parameters for PT summary.

func (*StartActionRequest_PTSummaryParams) Descriptor deprecated

func (*StartActionRequest_PTSummaryParams) Descriptor() ([]byte, []int)

Deprecated: Use StartActionRequest_PTSummaryParams.ProtoReflect.Descriptor instead.

func (*StartActionRequest_PTSummaryParams) ProtoMessage

func (*StartActionRequest_PTSummaryParams) ProtoMessage()

func (*StartActionRequest_PTSummaryParams) ProtoReflect

func (*StartActionRequest_PTSummaryParams) Reset

func (*StartActionRequest_PTSummaryParams) String

func (*StartActionRequest_PTSummaryParams) Validate

func (this *StartActionRequest_PTSummaryParams) Validate() error

type StartActionRequest_PostgreSQLQuerySelectParams

type StartActionRequest_PostgreSQLQuerySelectParams struct {

	// DSN for the service. May contain connection (dial) timeout.
	Dsn string `protobuf:"bytes,1,opt,name=dsn,proto3" json:"dsn,omitempty"`
	// Query suffix (without leading SELECT).
	Query string `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	// contains filtered or unexported fields
}

PostgreSQLQuerySelectParams describes PostgreSQL SELECT query action parameters.

func (*StartActionRequest_PostgreSQLQuerySelectParams) Descriptor deprecated

Deprecated: Use StartActionRequest_PostgreSQLQuerySelectParams.ProtoReflect.Descriptor instead.

func (*StartActionRequest_PostgreSQLQuerySelectParams) GetDsn

func (*StartActionRequest_PostgreSQLQuerySelectParams) GetQuery

func (*StartActionRequest_PostgreSQLQuerySelectParams) ProtoMessage

func (*StartActionRequest_PostgreSQLQuerySelectParams) ProtoReflect

func (*StartActionRequest_PostgreSQLQuerySelectParams) Reset

func (*StartActionRequest_PostgreSQLQuerySelectParams) String

func (*StartActionRequest_PostgreSQLQuerySelectParams) Validate

type StartActionRequest_PostgreSQLQueryShowParams

type StartActionRequest_PostgreSQLQueryShowParams struct {

	// DSN for the service. May contain connection (dial) timeout.
	Dsn string `protobuf:"bytes,1,opt,name=dsn,proto3" json:"dsn,omitempty"`
	// contains filtered or unexported fields
}

PostgreSQLQueryShowParams describes PostgreSQL SHOW query action parameters.

func (*StartActionRequest_PostgreSQLQueryShowParams) Descriptor deprecated

Deprecated: Use StartActionRequest_PostgreSQLQueryShowParams.ProtoReflect.Descriptor instead.

func (*StartActionRequest_PostgreSQLQueryShowParams) GetDsn

func (*StartActionRequest_PostgreSQLQueryShowParams) ProtoMessage

func (*StartActionRequest_PostgreSQLQueryShowParams) ProtoReflect

func (*StartActionRequest_PostgreSQLQueryShowParams) Reset

func (*StartActionRequest_PostgreSQLQueryShowParams) String

func (*StartActionRequest_PostgreSQLQueryShowParams) Validate

type StartActionRequest_PostgreSQLShowCreateTableParams

type StartActionRequest_PostgreSQLShowCreateTableParams struct {

	// DSN for the service. May contain connection (dial) timeout.
	Dsn   string `protobuf:"bytes,1,opt,name=dsn,proto3" json:"dsn,omitempty"`
	Table string `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	// contains filtered or unexported fields
}

PostgreSQLShowCreateTableParams describes PostgreSQL SHOW CREATE TABLE action parameters.

func (*StartActionRequest_PostgreSQLShowCreateTableParams) Descriptor deprecated

Deprecated: Use StartActionRequest_PostgreSQLShowCreateTableParams.ProtoReflect.Descriptor instead.

func (*StartActionRequest_PostgreSQLShowCreateTableParams) GetDsn

func (*StartActionRequest_PostgreSQLShowCreateTableParams) GetTable

func (*StartActionRequest_PostgreSQLShowCreateTableParams) ProtoMessage

func (*StartActionRequest_PostgreSQLShowCreateTableParams) ProtoReflect

func (*StartActionRequest_PostgreSQLShowCreateTableParams) Reset

func (*StartActionRequest_PostgreSQLShowCreateTableParams) String

func (*StartActionRequest_PostgreSQLShowCreateTableParams) Validate

type StartActionRequest_PostgreSQLShowIndexParams

type StartActionRequest_PostgreSQLShowIndexParams struct {

	// DSN for the service. May contain connection (dial) timeout.
	Dsn   string `protobuf:"bytes,1,opt,name=dsn,proto3" json:"dsn,omitempty"`
	Table string `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	// contains filtered or unexported fields
}

PostgreSQLShowIndexParams describes PostgreSQL SHOW INDEX action parameters.

func (*StartActionRequest_PostgreSQLShowIndexParams) Descriptor deprecated

Deprecated: Use StartActionRequest_PostgreSQLShowIndexParams.ProtoReflect.Descriptor instead.

func (*StartActionRequest_PostgreSQLShowIndexParams) GetDsn

func (*StartActionRequest_PostgreSQLShowIndexParams) GetTable

func (*StartActionRequest_PostgreSQLShowIndexParams) ProtoMessage

func (*StartActionRequest_PostgreSQLShowIndexParams) ProtoReflect

func (*StartActionRequest_PostgreSQLShowIndexParams) Reset

func (*StartActionRequest_PostgreSQLShowIndexParams) String

func (*StartActionRequest_PostgreSQLShowIndexParams) Validate

type StartActionRequest_PostgresqlQuerySelectParams

type StartActionRequest_PostgresqlQuerySelectParams struct {
	PostgresqlQuerySelectParams *StartActionRequest_PostgreSQLQuerySelectParams `protobuf:"bytes,53,opt,name=postgresql_query_select_params,json=postgresqlQuerySelectParams,proto3,oneof"`
}

type StartActionRequest_PostgresqlQueryShowParams

type StartActionRequest_PostgresqlQueryShowParams struct {
	PostgresqlQueryShowParams *StartActionRequest_PostgreSQLQueryShowParams `protobuf:"bytes,52,opt,name=postgresql_query_show_params,json=postgresqlQueryShowParams,proto3,oneof"`
}

type StartActionRequest_PostgresqlShowCreateTableParams

type StartActionRequest_PostgresqlShowCreateTableParams struct {
	PostgresqlShowCreateTableParams *StartActionRequest_PostgreSQLShowCreateTableParams `protobuf:"bytes,6,opt,name=postgresql_show_create_table_params,json=postgresqlShowCreateTableParams,proto3,oneof"`
}

type StartActionRequest_PostgresqlShowIndexParams

type StartActionRequest_PostgresqlShowIndexParams struct {
	PostgresqlShowIndexParams *StartActionRequest_PostgreSQLShowIndexParams `protobuf:"bytes,7,opt,name=postgresql_show_index_params,json=postgresqlShowIndexParams,proto3,oneof"`
}

type StartActionRequest_PtMongodbSummaryParams

type StartActionRequest_PtMongodbSummaryParams struct {
	PtMongodbSummaryParams *StartActionRequest_PTMongoDBSummaryParams `protobuf:"bytes,13,opt,name=pt_mongodb_summary_params,json=ptMongodbSummaryParams,proto3,oneof"`
}

type StartActionRequest_PtMysqlSummaryParams

type StartActionRequest_PtMysqlSummaryParams struct {
	PtMysqlSummaryParams *StartActionRequest_PTMySQLSummaryParams `protobuf:"bytes,11,opt,name=pt_mysql_summary_params,json=ptMysqlSummaryParams,proto3,oneof"`
}

type StartActionRequest_PtPgSummaryParams

type StartActionRequest_PtPgSummaryParams struct {
	PtPgSummaryParams *StartActionRequest_PTPgSummaryParams `protobuf:"bytes,12,opt,name=pt_pg_summary_params,json=ptPgSummaryParams,proto3,oneof"`
}

type StartActionRequest_PtSummaryParams

type StartActionRequest_PtSummaryParams struct {
	PtSummaryParams *StartActionRequest_PTSummaryParams `protobuf:"bytes,10,opt,name=pt_summary_params,json=ptSummaryParams,proto3,oneof"`
}

type StartActionResponse

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

StartActionResponse is an AgentMessage for StartActionRequest acceptance.

func (*StartActionResponse) AgentMessageResponsePayload

func (m *StartActionResponse) AgentMessageResponsePayload() isAgentMessage_Payload

func (*StartActionResponse) Descriptor deprecated

func (*StartActionResponse) Descriptor() ([]byte, []int)

Deprecated: Use StartActionResponse.ProtoReflect.Descriptor instead.

func (*StartActionResponse) ProtoMessage

func (*StartActionResponse) ProtoMessage()

func (*StartActionResponse) ProtoReflect

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

func (*StartActionResponse) Reset

func (x *StartActionResponse) Reset()

func (*StartActionResponse) String

func (x *StartActionResponse) String() string

func (*StartActionResponse) Validate

func (this *StartActionResponse) Validate() error

type StartJobRequest

type StartJobRequest struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// Timeout for the job.
	Timeout *duration.Duration `protobuf:"bytes,2,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// Types that are assignable to Job:
	//	*StartJobRequest_Echo_
	//	*StartJobRequest_MysqlBackup
	//	*StartJobRequest_MysqlRestoreBackup
	Job isStartJobRequest_Job `protobuf_oneof:"job"`
	// contains filtered or unexported fields
}

StartJobRequest is a ServerMessage asking pmm-agent to start job.

func (*StartJobRequest) Descriptor deprecated

func (*StartJobRequest) Descriptor() ([]byte, []int)

Deprecated: Use StartJobRequest.ProtoReflect.Descriptor instead.

func (*StartJobRequest) GetEcho

func (x *StartJobRequest) GetEcho() *StartJobRequest_Echo

func (*StartJobRequest) GetJob

func (m *StartJobRequest) GetJob() isStartJobRequest_Job

func (*StartJobRequest) GetJobId

func (x *StartJobRequest) GetJobId() string

func (*StartJobRequest) GetMysqlBackup

func (x *StartJobRequest) GetMysqlBackup() *StartJobRequest_MySQLBackup

func (*StartJobRequest) GetMysqlRestoreBackup

func (x *StartJobRequest) GetMysqlRestoreBackup() *StartJobRequest_MySQLRestoreBackup

func (*StartJobRequest) GetTimeout

func (x *StartJobRequest) GetTimeout() *duration.Duration

func (*StartJobRequest) ProtoMessage

func (*StartJobRequest) ProtoMessage()

func (*StartJobRequest) ProtoReflect

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

func (*StartJobRequest) Reset

func (x *StartJobRequest) Reset()

func (*StartJobRequest) ServerMessageRequestPayload

func (m *StartJobRequest) ServerMessageRequestPayload() isServerMessage_Payload

func (*StartJobRequest) String

func (x *StartJobRequest) String() string

func (*StartJobRequest) Validate

func (this *StartJobRequest) Validate() error

type StartJobRequest_Echo

type StartJobRequest_Echo struct {
	Message string             `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Delay   *duration.Duration `protobuf:"bytes,2,opt,name=delay,proto3" json:"delay,omitempty"`
	// contains filtered or unexported fields
}

Echo is a simple echo job that can be delayed.

func (*StartJobRequest_Echo) Descriptor deprecated

func (*StartJobRequest_Echo) Descriptor() ([]byte, []int)

Deprecated: Use StartJobRequest_Echo.ProtoReflect.Descriptor instead.

func (*StartJobRequest_Echo) GetDelay

func (x *StartJobRequest_Echo) GetDelay() *duration.Duration

func (*StartJobRequest_Echo) GetMessage

func (x *StartJobRequest_Echo) GetMessage() string

func (*StartJobRequest_Echo) ProtoMessage

func (*StartJobRequest_Echo) ProtoMessage()

func (*StartJobRequest_Echo) ProtoReflect

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

func (*StartJobRequest_Echo) Reset

func (x *StartJobRequest_Echo) Reset()

func (*StartJobRequest_Echo) String

func (x *StartJobRequest_Echo) String() string

func (*StartJobRequest_Echo) Validate

func (this *StartJobRequest_Echo) Validate() error

type StartJobRequest_Echo_

type StartJobRequest_Echo_ struct {
	Echo *StartJobRequest_Echo `protobuf:"bytes,10,opt,name=echo,proto3,oneof"`
}

type StartJobRequest_MySQLBackup

type StartJobRequest_MySQLBackup struct {

	// Database user;
	User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	// Database password.
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// Database address. Can't be specified with socket.
	Address string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"`
	// Database port. Can't be specified with socket.
	Port int32 `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
	// Database unix socket. Can't be specified with address/port.
	Socket string `protobuf:"bytes,5,opt,name=socket,proto3" json:"socket,omitempty"`
	// Backup name.
	Name string `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty"`
	// Backup target location.
	//
	// Types that are assignable to LocationConfig:
	//	*StartJobRequest_MySQLBackup_S3Config
	LocationConfig isStartJobRequest_MySQLBackup_LocationConfig `protobuf_oneof:"location_config"`
	// contains filtered or unexported fields
}

MySQLBackup is job for backup MySQL service.

func (*StartJobRequest_MySQLBackup) Descriptor deprecated

func (*StartJobRequest_MySQLBackup) Descriptor() ([]byte, []int)

Deprecated: Use StartJobRequest_MySQLBackup.ProtoReflect.Descriptor instead.

func (*StartJobRequest_MySQLBackup) GetAddress

func (x *StartJobRequest_MySQLBackup) GetAddress() string

func (*StartJobRequest_MySQLBackup) GetLocationConfig

func (m *StartJobRequest_MySQLBackup) GetLocationConfig() isStartJobRequest_MySQLBackup_LocationConfig

func (*StartJobRequest_MySQLBackup) GetName

func (x *StartJobRequest_MySQLBackup) GetName() string

func (*StartJobRequest_MySQLBackup) GetPassword

func (x *StartJobRequest_MySQLBackup) GetPassword() string

func (*StartJobRequest_MySQLBackup) GetPort

func (x *StartJobRequest_MySQLBackup) GetPort() int32

func (*StartJobRequest_MySQLBackup) GetS3Config

func (*StartJobRequest_MySQLBackup) GetSocket

func (x *StartJobRequest_MySQLBackup) GetSocket() string

func (*StartJobRequest_MySQLBackup) GetUser

func (x *StartJobRequest_MySQLBackup) GetUser() string

func (*StartJobRequest_MySQLBackup) ProtoMessage

func (*StartJobRequest_MySQLBackup) ProtoMessage()

func (*StartJobRequest_MySQLBackup) ProtoReflect

func (*StartJobRequest_MySQLBackup) Reset

func (x *StartJobRequest_MySQLBackup) Reset()

func (*StartJobRequest_MySQLBackup) String

func (x *StartJobRequest_MySQLBackup) String() string

func (*StartJobRequest_MySQLBackup) Validate

func (this *StartJobRequest_MySQLBackup) Validate() error

type StartJobRequest_MySQLBackup_S3Config

type StartJobRequest_MySQLBackup_S3Config struct {
	S3Config *S3LocationConfig `protobuf:"bytes,10,opt,name=s3_config,json=s3Config,proto3,oneof"`
}

type StartJobRequest_MySQLRestoreBackup

type StartJobRequest_MySQLRestoreBackup struct {

	// Service identifier where the backup should be restored.
	ServiceId string `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	// Backup name.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Where backup is stored.
	//
	// Types that are assignable to LocationConfig:
	//	*StartJobRequest_MySQLRestoreBackup_S3Config
	LocationConfig isStartJobRequest_MySQLRestoreBackup_LocationConfig `protobuf_oneof:"location_config"`
	// contains filtered or unexported fields
}

MySQLRestoreBackup is job for MySQL restore backup service.

func (*StartJobRequest_MySQLRestoreBackup) Descriptor deprecated

func (*StartJobRequest_MySQLRestoreBackup) Descriptor() ([]byte, []int)

Deprecated: Use StartJobRequest_MySQLRestoreBackup.ProtoReflect.Descriptor instead.

func (*StartJobRequest_MySQLRestoreBackup) GetLocationConfig

func (m *StartJobRequest_MySQLRestoreBackup) GetLocationConfig() isStartJobRequest_MySQLRestoreBackup_LocationConfig

func (*StartJobRequest_MySQLRestoreBackup) GetName

func (*StartJobRequest_MySQLRestoreBackup) GetS3Config

func (*StartJobRequest_MySQLRestoreBackup) GetServiceId

func (x *StartJobRequest_MySQLRestoreBackup) GetServiceId() string

func (*StartJobRequest_MySQLRestoreBackup) ProtoMessage

func (*StartJobRequest_MySQLRestoreBackup) ProtoMessage()

func (*StartJobRequest_MySQLRestoreBackup) ProtoReflect

func (*StartJobRequest_MySQLRestoreBackup) Reset

func (*StartJobRequest_MySQLRestoreBackup) String

func (*StartJobRequest_MySQLRestoreBackup) Validate

func (this *StartJobRequest_MySQLRestoreBackup) Validate() error

type StartJobRequest_MySQLRestoreBackup_S3Config

type StartJobRequest_MySQLRestoreBackup_S3Config struct {
	S3Config *S3LocationConfig `protobuf:"bytes,10,opt,name=s3_config,json=s3Config,proto3,oneof"`
}

type StartJobRequest_MysqlBackup

type StartJobRequest_MysqlBackup struct {
	MysqlBackup *StartJobRequest_MySQLBackup `protobuf:"bytes,11,opt,name=mysql_backup,json=mysqlBackup,proto3,oneof"`
}

type StartJobRequest_MysqlRestoreBackup

type StartJobRequest_MysqlRestoreBackup struct {
	MysqlRestoreBackup *StartJobRequest_MySQLRestoreBackup `protobuf:"bytes,12,opt,name=mysql_restore_backup,json=mysqlRestoreBackup,proto3,oneof"`
}

type StartJobResponse

type StartJobResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

StartJobResponse is an AgentMessage for StartJobRequest acceptance.

func (*StartJobResponse) AgentMessageResponsePayload

func (m *StartJobResponse) AgentMessageResponsePayload() isAgentMessage_Payload

func (*StartJobResponse) Descriptor deprecated

func (*StartJobResponse) Descriptor() ([]byte, []int)

Deprecated: Use StartJobResponse.ProtoReflect.Descriptor instead.

func (*StartJobResponse) GetError

func (x *StartJobResponse) GetError() string

func (*StartJobResponse) ProtoMessage

func (*StartJobResponse) ProtoMessage()

func (*StartJobResponse) ProtoReflect

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

func (*StartJobResponse) Reset

func (x *StartJobResponse) Reset()

func (*StartJobResponse) String

func (x *StartJobResponse) String() string

func (*StartJobResponse) Validate

func (this *StartJobResponse) Validate() error

type StateChangedRequest

type StateChangedRequest struct {
	AgentId    string                  `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	Status     inventorypb.AgentStatus `protobuf:"varint,2,opt,name=status,proto3,enum=inventory.AgentStatus" json:"status,omitempty"`
	ListenPort uint32                  `protobuf:"varint,3,opt,name=listen_port,json=listenPort,proto3" json:"listen_port,omitempty"`
	// contains filtered or unexported fields
}

StateChangedRequest is an AgentMessage describing actual agent status.

func (*StateChangedRequest) AgentMessageRequestPayload

func (m *StateChangedRequest) AgentMessageRequestPayload() isAgentMessage_Payload

func (*StateChangedRequest) Descriptor deprecated

func (*StateChangedRequest) Descriptor() ([]byte, []int)

Deprecated: Use StateChangedRequest.ProtoReflect.Descriptor instead.

func (*StateChangedRequest) GetAgentId

func (x *StateChangedRequest) GetAgentId() string

func (*StateChangedRequest) GetListenPort

func (x *StateChangedRequest) GetListenPort() uint32

func (*StateChangedRequest) GetStatus

func (*StateChangedRequest) ProtoMessage

func (*StateChangedRequest) ProtoMessage()

func (*StateChangedRequest) ProtoReflect

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

func (*StateChangedRequest) Reset

func (x *StateChangedRequest) Reset()

func (*StateChangedRequest) String

func (x *StateChangedRequest) String() string

func (*StateChangedRequest) Validate

func (this *StateChangedRequest) Validate() error

type StateChangedResponse

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

StateChangedResponse is a ServerMessage for StateChangedRequest acceptance.

func (*StateChangedResponse) Descriptor deprecated

func (*StateChangedResponse) Descriptor() ([]byte, []int)

Deprecated: Use StateChangedResponse.ProtoReflect.Descriptor instead.

func (*StateChangedResponse) ProtoMessage

func (*StateChangedResponse) ProtoMessage()

func (*StateChangedResponse) ProtoReflect

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

func (*StateChangedResponse) Reset

func (x *StateChangedResponse) Reset()

func (*StateChangedResponse) ServerMessageResponsePayload

func (m *StateChangedResponse) ServerMessageResponsePayload() isServerMessage_Payload

func (*StateChangedResponse) String

func (x *StateChangedResponse) String() string

func (*StateChangedResponse) Validate

func (this *StateChangedResponse) Validate() error

type StopActionRequest

type StopActionRequest struct {
	ActionId string `protobuf:"bytes,1,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
	// contains filtered or unexported fields
}

StopActionRequest is a ServerMessage asking pmm-agent to stop action.

func (*StopActionRequest) Descriptor deprecated

func (*StopActionRequest) Descriptor() ([]byte, []int)

Deprecated: Use StopActionRequest.ProtoReflect.Descriptor instead.

func (*StopActionRequest) GetActionId

func (x *StopActionRequest) GetActionId() string

func (*StopActionRequest) ProtoMessage

func (*StopActionRequest) ProtoMessage()

func (*StopActionRequest) ProtoReflect

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

func (*StopActionRequest) Reset

func (x *StopActionRequest) Reset()

func (*StopActionRequest) ServerMessageRequestPayload

func (m *StopActionRequest) ServerMessageRequestPayload() isServerMessage_Payload

func (*StopActionRequest) String

func (x *StopActionRequest) String() string

func (*StopActionRequest) Validate

func (this *StopActionRequest) Validate() error

type StopActionResponse

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

StopActionResponse is an AgentMessage for StopActionRequest acceptance.

func (*StopActionResponse) AgentMessageResponsePayload

func (m *StopActionResponse) AgentMessageResponsePayload() isAgentMessage_Payload

func (*StopActionResponse) Descriptor deprecated

func (*StopActionResponse) Descriptor() ([]byte, []int)

Deprecated: Use StopActionResponse.ProtoReflect.Descriptor instead.

func (*StopActionResponse) ProtoMessage

func (*StopActionResponse) ProtoMessage()

func (*StopActionResponse) ProtoReflect

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

func (*StopActionResponse) Reset

func (x *StopActionResponse) Reset()

func (*StopActionResponse) String

func (x *StopActionResponse) String() string

func (*StopActionResponse) Validate

func (this *StopActionResponse) Validate() error

type StopJobRequest

type StopJobRequest struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

StopJobRequest is a ServerMessage asking pmm-agent to stop job.

func (*StopJobRequest) Descriptor deprecated

func (*StopJobRequest) Descriptor() ([]byte, []int)

Deprecated: Use StopJobRequest.ProtoReflect.Descriptor instead.

func (*StopJobRequest) GetJobId

func (x *StopJobRequest) GetJobId() string

func (*StopJobRequest) ProtoMessage

func (*StopJobRequest) ProtoMessage()

func (*StopJobRequest) ProtoReflect

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

func (*StopJobRequest) Reset

func (x *StopJobRequest) Reset()

func (*StopJobRequest) ServerMessageRequestPayload

func (m *StopJobRequest) ServerMessageRequestPayload() isServerMessage_Payload

func (*StopJobRequest) String

func (x *StopJobRequest) String() string

func (*StopJobRequest) Validate

func (this *StopJobRequest) Validate() error

type StopJobResponse

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

StopJobResponse is an AgentMessage for StopJobRequest acceptance.

func (*StopJobResponse) AgentMessageResponsePayload

func (m *StopJobResponse) AgentMessageResponsePayload() isAgentMessage_Payload

func (*StopJobResponse) Descriptor deprecated

func (*StopJobResponse) Descriptor() ([]byte, []int)

Deprecated: Use StopJobResponse.ProtoReflect.Descriptor instead.

func (*StopJobResponse) ProtoMessage

func (*StopJobResponse) ProtoMessage()

func (*StopJobResponse) ProtoReflect

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

func (*StopJobResponse) Reset

func (x *StopJobResponse) Reset()

func (*StopJobResponse) String

func (x *StopJobResponse) String() string

func (*StopJobResponse) Validate

func (this *StopJobResponse) Validate() error

type TextFiles

type TextFiles struct {

	// files contains files which can be used to connect to DB (certificates, keys and etc).
	Files map[string]string `` /* 151-byte string literal not displayed */
	// template_left_delim is used to replace placeholders in templates (DSN and etc.) with paths to files.
	TemplateLeftDelim string `protobuf:"bytes,2,opt,name=template_left_delim,json=templateLeftDelim,proto3" json:"template_left_delim,omitempty"`
	// template_right_delim is used to replace placeholders in templates (DSN and etc.) with paths to files.
	TemplateRightDelim string `protobuf:"bytes,3,opt,name=template_right_delim,json=templateRightDelim,proto3" json:"template_right_delim,omitempty"`
	// contains filtered or unexported fields
}

TextFiles contains files which can be used to connect to DB (certificates, keys and etc).

func (*TextFiles) Descriptor deprecated

func (*TextFiles) Descriptor() ([]byte, []int)

Deprecated: Use TextFiles.ProtoReflect.Descriptor instead.

func (*TextFiles) GetFiles

func (x *TextFiles) GetFiles() map[string]string

func (*TextFiles) GetTemplateLeftDelim

func (x *TextFiles) GetTemplateLeftDelim() string

func (*TextFiles) GetTemplateRightDelim

func (x *TextFiles) GetTemplateRightDelim() string

func (*TextFiles) ProtoMessage

func (*TextFiles) ProtoMessage()

func (*TextFiles) ProtoReflect

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

func (*TextFiles) Reset

func (x *TextFiles) Reset()

func (*TextFiles) String

func (x *TextFiles) String() string

func (*TextFiles) Validate

func (this *TextFiles) Validate() error

type UnimplementedAgentServer

type UnimplementedAgentServer struct {
}

UnimplementedAgentServer can be embedded to have forward compatible implementations.

func (*UnimplementedAgentServer) Connect

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL