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 (x *CheckConnectionRequest) GetType() inventorypb.ServiceType

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 (x *CheckConnectionResponse) GetStats() *CheckConnectionResponse_Stats

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 (x *CheckConnectionResponse_Stats) ProtoReflect() protoreflect.Message

func (*CheckConnectionResponse_Stats) Reset 

func (x *CheckConnectionResponse_Stats) Reset()

func (*CheckConnectionResponse_Stats) String 

func (x *CheckConnectionResponse_Stats) String() 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) Descriptor() protoreflect.EnumDescriptor

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 (x ExampleFormat) Number() protoreflect.EnumNumber

func (ExampleFormat) String 

func (x ExampleFormat) String() string

func (ExampleFormat) Type 

func (ExampleFormat) Type() protoreflect.EnumType

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) Descriptor() protoreflect.EnumDescriptor

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 

func (ExampleType) Type() protoreflect.EnumType

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 (x *JobProgress_MySQLRestoreBackup) ProtoReflect() protoreflect.Message

func (*JobProgress_MySQLRestoreBackup) Reset 

func (x *JobProgress_MySQLRestoreBackup) Reset()

func (*JobProgress_MySQLRestoreBackup) String 

func (x *JobProgress_MySQLRestoreBackup) String() 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 (x *JobResult_MySQLRestoreBackup) ProtoReflect() protoreflect.Message

func (*JobResult_MySQLRestoreBackup) Reset 

func (x *JobResult_MySQLRestoreBackup) Reset()

func (*JobResult_MySQLRestoreBackup) String 

func (x *JobResult_MySQLRestoreBackup) String() 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) Descriptor() protoreflect.EnumDescriptor

func (MysqlExplainOutputFormat) Enum 

func (x MysqlExplainOutputFormat) Enum() *MysqlExplainOutputFormat

func (MysqlExplainOutputFormat) EnumDescriptor deprecated 

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

Deprecated: Use MysqlExplainOutputFormat.Descriptor instead.

func (MysqlExplainOutputFormat) Number 

func (x MysqlExplainOutputFormat) Number() protoreflect.EnumNumber

func (MysqlExplainOutputFormat) String 

func (x MysqlExplainOutputFormat) String() string

func (MysqlExplainOutputFormat) Type 

func (MysqlExplainOutputFormat) Type() protoreflect.EnumType

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 (x *SetStateRequest_AgentProcess) GetType() inventorypb.AgentType

func (*SetStateRequest_AgentProcess) ProtoMessage 

func (*SetStateRequest_AgentProcess) ProtoMessage()

func (*SetStateRequest_AgentProcess) ProtoReflect 

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

func (*SetStateRequest_AgentProcess) Reset 

func (x *SetStateRequest_AgentProcess) Reset()

func (*SetStateRequest_AgentProcess) String 

func (x *SetStateRequest_AgentProcess) String() 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 (x *SetStateRequest_BuiltinAgent) GetDsn() string

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 (x *SetStateRequest_BuiltinAgent) GetType() inventorypb.AgentType

func (*SetStateRequest_BuiltinAgent) ProtoMessage 

func (*SetStateRequest_BuiltinAgent) ProtoMessage()

func (*SetStateRequest_BuiltinAgent) ProtoReflect 

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

func (*SetStateRequest_BuiltinAgent) Reset 

func (x *SetStateRequest_BuiltinAgent) Reset()

func (*SetStateRequest_BuiltinAgent) String 

func (x *SetStateRequest_BuiltinAgent) String() 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 (x *StartActionRequest_MongoDBExplainParams) GetDsn() string

func (*StartActionRequest_MongoDBExplainParams) GetQuery 

func (x *StartActionRequest_MongoDBExplainParams) GetQuery() string

func (*StartActionRequest_MongoDBExplainParams) GetTextFiles 

func (x *StartActionRequest_MongoDBExplainParams) GetTextFiles() *TextFiles

func (*StartActionRequest_MongoDBExplainParams) ProtoMessage 

func (*StartActionRequest_MongoDBExplainParams) ProtoMessage()

func (*StartActionRequest_MongoDBExplainParams) ProtoReflect 

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

func (*StartActionRequest_MongoDBExplainParams) Reset 

func (x *StartActionRequest_MongoDBExplainParams) Reset()

func (*StartActionRequest_MongoDBExplainParams) String 

func (x *StartActionRequest_MongoDBExplainParams) String() string

func (*StartActionRequest_MongoDBExplainParams) Validate 

func (this *StartActionRequest_MongoDBExplainParams) Validate() error

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 

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

Deprecated: Use StartActionRequest_MongoDBQueryBuildInfoParams.ProtoReflect.Descriptor instead.

func (*StartActionRequest_MongoDBQueryBuildInfoParams) GetDsn 

func (x *StartActionRequest_MongoDBQueryBuildInfoParams) GetDsn() string

func (*StartActionRequest_MongoDBQueryBuildInfoParams) GetTextFiles 

func (x *StartActionRequest_MongoDBQueryBuildInfoParams) GetTextFiles() *TextFiles

func (*StartActionRequest_MongoDBQueryBuildInfoParams) ProtoMessage 

func (*StartActionRequest_MongoDBQueryBuildInfoParams) ProtoMessage()

func (*StartActionRequest_MongoDBQueryBuildInfoParams) ProtoReflect 

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

func (*StartActionRequest_MongoDBQueryBuildInfoParams) Reset 

func (x *StartActionRequest_MongoDBQueryBuildInfoParams) Reset()

func (*StartActionRequest_MongoDBQueryBuildInfoParams) String 

func (x *StartActionRequest_MongoDBQueryBuildInfoParams) String() string

func (*StartActionRequest_MongoDBQueryBuildInfoParams) Validate 

func (this *StartActionRequest_MongoDBQueryBuildInfoParams) Validate() error

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 

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

Deprecated: Use StartActionRequest_MongoDBQueryGetCmdLineOptsParams.ProtoReflect.Descriptor instead.

func (*StartActionRequest_MongoDBQueryGetCmdLineOptsParams) GetDsn 

func (x *StartActionRequest_MongoDBQueryGetCmdLineOptsParams) GetDsn() string

func (*StartActionRequest_MongoDBQueryGetCmdLineOptsParams) GetTextFiles 

func (x *StartActionRequest_MongoDBQueryGetCmdLineOptsParams) GetTextFiles() *TextFiles

func (*StartActionRequest_MongoDBQueryGetCmdLineOptsParams) ProtoMessage 

func (*StartActionRequest_MongoDBQueryGetCmdLineOptsParams) ProtoMessage()

func (*StartActionRequest_MongoDBQueryGetCmdLineOptsParams) ProtoReflect 

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

func (*StartActionRequest_MongoDBQueryGetCmdLineOptsParams) Reset 

func (x *StartActionRequest_MongoDBQueryGetCmdLineOptsParams) Reset()

func (*StartActionRequest_MongoDBQueryGetCmdLineOptsParams) String 

func (x *StartActionRequest_MongoDBQueryGetCmdLineOptsParams) String() string

func (*StartActionRequest_MongoDBQueryGetCmdLineOptsParams) Validate 

func (this *StartActionRequest_MongoDBQueryGetCmdLineOptsParams) Validate() error

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 

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

Deprecated: Use StartActionRequest_MongoDBQueryGetParameterParams.ProtoReflect.Descriptor instead.

func (*StartActionRequest_MongoDBQueryGetParameterParams) GetDsn 

func (x *StartActionRequest_MongoDBQueryGetParameterParams) GetDsn() string

func (*StartActionRequest_MongoDBQueryGetParameterParams) GetTextFiles 

func (x *StartActionRequest_MongoDBQueryGetParameterParams) GetTextFiles() *TextFiles

func (*StartActionRequest_MongoDBQueryGetParameterParams) ProtoMessage 

func (*StartActionRequest_MongoDBQueryGetParameterParams) ProtoMessage()

func (*StartActionRequest_MongoDBQueryGetParameterParams) ProtoReflect 

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

func (*StartActionRequest_MongoDBQueryGetParameterParams) Reset 

func (x *StartActionRequest_MongoDBQueryGetParameterParams) Reset()

func (*StartActionRequest_MongoDBQueryGetParameterParams) String 

func (x *StartActionRequest_MongoDBQueryGetParameterParams) String() string

func (*StartActionRequest_MongoDBQueryGetParameterParams) Validate 

func (this *StartActionRequest_MongoDBQueryGetParameterParams) Validate() error

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 (x *StartActionRequest_MySQLExplainParams) GetDsn() string

func (*StartActionRequest_MySQLExplainParams) GetOutputFormat 

func (x *StartActionRequest_MySQLExplainParams) GetOutputFormat() MysqlExplainOutputFormat

func (*StartActionRequest_MySQLExplainParams) GetQuery 

func (x *StartActionRequest_MySQLExplainParams) GetQuery() string

func (*StartActionRequest_MySQLExplainParams) GetTlsFiles 

func (x *StartActionRequest_MySQLExplainParams) GetTlsFiles() *TextFiles

func (*StartActionRequest_MySQLExplainParams) GetTlsSkipVerify 

func (x *StartActionRequest_MySQLExplainParams) GetTlsSkipVerify() bool

func (*StartActionRequest_MySQLExplainParams) ProtoMessage 

func (*StartActionRequest_MySQLExplainParams) ProtoMessage()

func (*StartActionRequest_MySQLExplainParams) ProtoReflect 

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

func (*StartActionRequest_MySQLExplainParams) Reset 

func (x *StartActionRequest_MySQLExplainParams) Reset()

func (*StartActionRequest_MySQLExplainParams) String 

func (x *StartActionRequest_MySQLExplainParams) String() string

func (*StartActionRequest_MySQLExplainParams) Validate 

func (this *StartActionRequest_MySQLExplainParams) Validate() error

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 (x *StartActionRequest_MySQLQuerySelectParams) GetDsn() string

func (*StartActionRequest_MySQLQuerySelectParams) GetQuery 

func (x *StartActionRequest_MySQLQuerySelectParams) GetQuery() string

func (*StartActionRequest_MySQLQuerySelectParams) GetTlsFiles 

func (x *StartActionRequest_MySQLQuerySelectParams) GetTlsFiles() *TextFiles

func (*StartActionRequest_MySQLQuerySelectParams) GetTlsSkipVerify 

func (x *StartActionRequest_MySQLQuerySelectParams) GetTlsSkipVerify() bool

func (*StartActionRequest_MySQLQuerySelectParams) ProtoMessage 

func (*StartActionRequest_MySQLQuerySelectParams) ProtoMessage()

func (*StartActionRequest_MySQLQuerySelectParams) ProtoReflect 

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

func (*StartActionRequest_MySQLQuerySelectParams) Reset 

func (x *StartActionRequest_MySQLQuerySelectParams) Reset()

func (*StartActionRequest_MySQLQuerySelectParams) String 

func (x *StartActionRequest_MySQLQuerySelectParams) String() string

func (*StartActionRequest_MySQLQuerySelectParams) Validate 

func (this *StartActionRequest_MySQLQuerySelectParams) Validate() error

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 (x *StartActionRequest_MySQLQueryShowParams) GetDsn() string

func (*StartActionRequest_MySQLQueryShowParams) GetQuery 

func (x *StartActionRequest_MySQLQueryShowParams) GetQuery() string

func (*StartActionRequest_MySQLQueryShowParams) GetTlsFiles 

func (x *StartActionRequest_MySQLQueryShowParams) GetTlsFiles() *TextFiles

func (*StartActionRequest_MySQLQueryShowParams) GetTlsSkipVerify 

func (x *StartActionRequest_MySQLQueryShowParams) GetTlsSkipVerify() bool

func (*StartActionRequest_MySQLQueryShowParams) ProtoMessage 

func (*StartActionRequest_MySQLQueryShowParams) ProtoMessage()

func (*StartActionRequest_MySQLQueryShowParams) ProtoReflect 

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

func (*StartActionRequest_MySQLQueryShowParams) Reset 

func (x *StartActionRequest_MySQLQueryShowParams) Reset()

func (*StartActionRequest_MySQLQueryShowParams) String 

func (x *StartActionRequest_MySQLQueryShowParams) String() string

func (*StartActionRequest_MySQLQueryShowParams) Validate 

func (this *StartActionRequest_MySQLQueryShowParams) Validate() error

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 

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

Deprecated: Use StartActionRequest_MySQLShowCreateTableParams.ProtoReflect.Descriptor instead.

func (*StartActionRequest_MySQLShowCreateTableParams) GetDsn 

func (x *StartActionRequest_MySQLShowCreateTableParams) GetDsn() string

func (*StartActionRequest_MySQLShowCreateTableParams) GetTable 

func (x *StartActionRequest_MySQLShowCreateTableParams) GetTable() string

func (*StartActionRequest_MySQLShowCreateTableParams) GetTlsFiles 

func (x *StartActionRequest_MySQLShowCreateTableParams) GetTlsFiles() *TextFiles

func (*StartActionRequest_MySQLShowCreateTableParams) GetTlsSkipVerify 

func (x *StartActionRequest_MySQLShowCreateTableParams) GetTlsSkipVerify() bool

func (*StartActionRequest_MySQLShowCreateTableParams) ProtoMessage 

func (*StartActionRequest_MySQLShowCreateTableParams) ProtoMessage()

func (*StartActionRequest_MySQLShowCreateTableParams) ProtoReflect 

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

func (*StartActionRequest_MySQLShowCreateTableParams) Reset 

func (x *StartActionRequest_MySQLShowCreateTableParams) Reset()

func (*StartActionRequest_MySQLShowCreateTableParams) String 

func (x *StartActionRequest_MySQLShowCreateTableParams) String() string

func (*StartActionRequest_MySQLShowCreateTableParams) Validate 

func (this *StartActionRequest_MySQLShowCreateTableParams) Validate() error

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 (x *StartActionRequest_MySQLShowIndexParams) GetDsn() string

func (*StartActionRequest_MySQLShowIndexParams) GetTable 

func (x *StartActionRequest_MySQLShowIndexParams) GetTable() string

func (*StartActionRequest_MySQLShowIndexParams) GetTlsFiles 

func (x *StartActionRequest_MySQLShowIndexParams) GetTlsFiles() *TextFiles

func (*StartActionRequest_MySQLShowIndexParams) GetTlsSkipVerify 

func (x *StartActionRequest_MySQLShowIndexParams) GetTlsSkipVerify() bool

func (*StartActionRequest_MySQLShowIndexParams) ProtoMessage 

func (*StartActionRequest_MySQLShowIndexParams) ProtoMessage()

func (*StartActionRequest_MySQLShowIndexParams) ProtoReflect 

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

func (*StartActionRequest_MySQLShowIndexParams) Reset 

func (x *StartActionRequest_MySQLShowIndexParams) Reset()

func (*StartActionRequest_MySQLShowIndexParams) String 

func (x *StartActionRequest_MySQLShowIndexParams) String() string

func (*StartActionRequest_MySQLShowIndexParams) Validate 

func (this *StartActionRequest_MySQLShowIndexParams) Validate() error

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 

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

Deprecated: Use StartActionRequest_MySQLShowTableStatusParams.ProtoReflect.Descriptor instead.

func (*StartActionRequest_MySQLShowTableStatusParams) GetDsn 

func (x *StartActionRequest_MySQLShowTableStatusParams) GetDsn() string

func (*StartActionRequest_MySQLShowTableStatusParams) GetTable 

func (x *StartActionRequest_MySQLShowTableStatusParams) GetTable() string

func (*StartActionRequest_MySQLShowTableStatusParams) GetTlsFiles 

func (x *StartActionRequest_MySQLShowTableStatusParams) GetTlsFiles() *TextFiles

func (*StartActionRequest_MySQLShowTableStatusParams) GetTlsSkipVerify 

func (x *StartActionRequest_MySQLShowTableStatusParams) GetTlsSkipVerify() bool

func (*StartActionRequest_MySQLShowTableStatusParams) ProtoMessage 

func (*StartActionRequest_MySQLShowTableStatusParams) ProtoMessage()

func (*StartActionRequest_MySQLShowTableStatusParams) ProtoReflect 

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

func (*StartActionRequest_MySQLShowTableStatusParams) Reset 

func (x *StartActionRequest_MySQLShowTableStatusParams) Reset()

func (*StartActionRequest_MySQLShowTableStatusParams) String 

func (x *StartActionRequest_MySQLShowTableStatusParams) String() string

func (*StartActionRequest_MySQLShowTableStatusParams) Validate 

func (this *StartActionRequest_MySQLShowTableStatusParams) Validate() error

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 (x *StartActionRequest_PTMongoDBSummaryParams) GetHost() string

func (*StartActionRequest_PTMongoDBSummaryParams) GetPassword 

func (x *StartActionRequest_PTMongoDBSummaryParams) GetPassword() string

func (*StartActionRequest_PTMongoDBSummaryParams) GetPort 

func (x *StartActionRequest_PTMongoDBSummaryParams) GetPort() uint32

func (*StartActionRequest_PTMongoDBSummaryParams) GetUsername 

func (x *StartActionRequest_PTMongoDBSummaryParams) GetUsername() string

func (*StartActionRequest_PTMongoDBSummaryParams) ProtoMessage 

func (*StartActionRequest_PTMongoDBSummaryParams) ProtoMessage()

func (*StartActionRequest_PTMongoDBSummaryParams) ProtoReflect 

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

func (*StartActionRequest_PTMongoDBSummaryParams) Reset 

func (x *StartActionRequest_PTMongoDBSummaryParams) Reset()

func (*StartActionRequest_PTMongoDBSummaryParams) String 

func (x *StartActionRequest_PTMongoDBSummaryParams) String() string

func (*StartActionRequest_PTMongoDBSummaryParams) Validate 

func (this *StartActionRequest_PTMongoDBSummaryParams) Validate() error

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 (x *StartActionRequest_PTMySQLSummaryParams) GetHost() string

func (*StartActionRequest_PTMySQLSummaryParams) GetPassword 

func (x *StartActionRequest_PTMySQLSummaryParams) GetPassword() string

func (*StartActionRequest_PTMySQLSummaryParams) GetPort 

func (x *StartActionRequest_PTMySQLSummaryParams) GetPort() uint32

func (*StartActionRequest_PTMySQLSummaryParams) GetSocket 

func (x *StartActionRequest_PTMySQLSummaryParams) GetSocket() string

func (*StartActionRequest_PTMySQLSummaryParams) GetUsername 

func (x *StartActionRequest_PTMySQLSummaryParams) GetUsername() string

func (*StartActionRequest_PTMySQLSummaryParams) ProtoMessage 

func (*StartActionRequest_PTMySQLSummaryParams) ProtoMessage()

func (*StartActionRequest_PTMySQLSummaryParams) ProtoReflect 

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

func (*StartActionRequest_PTMySQLSummaryParams) Reset 

func (x *StartActionRequest_PTMySQLSummaryParams) Reset()

func (*StartActionRequest_PTMySQLSummaryParams) String 

func (x *StartActionRequest_PTMySQLSummaryParams) String() string

func (*StartActionRequest_PTMySQLSummaryParams) Validate 

func (this *StartActionRequest_PTMySQLSummaryParams) Validate() error

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 (x *StartActionRequest_PTPgSummaryParams) GetHost() string

func (*StartActionRequest_PTPgSummaryParams) GetPassword 

func (x *StartActionRequest_PTPgSummaryParams) GetPassword() string

func (*StartActionRequest_PTPgSummaryParams) GetPort 

func (x *StartActionRequest_PTPgSummaryParams) GetPort() uint32

func (*StartActionRequest_PTPgSummaryParams) GetUsername 

func (x *StartActionRequest_PTPgSummaryParams) GetUsername() string

func (*StartActionRequest_PTPgSummaryParams) ProtoMessage 

func (*StartActionRequest_PTPgSummaryParams) ProtoMessage()

func (*StartActionRequest_PTPgSummaryParams) ProtoReflect 

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

func (*StartActionRequest_PTPgSummaryParams) Reset 

func (x *StartActionRequest_PTPgSummaryParams) Reset()

func (*StartActionRequest_PTPgSummaryParams) String 

func (x *StartActionRequest_PTPgSummaryParams) String() string

func (*StartActionRequest_PTPgSummaryParams) Validate 

func (this *StartActionRequest_PTPgSummaryParams) Validate() error

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 (x *StartActionRequest_PTSummaryParams) ProtoReflect() protoreflect.Message

func (*StartActionRequest_PTSummaryParams) Reset 

func (x *StartActionRequest_PTSummaryParams) Reset()

func (*StartActionRequest_PTSummaryParams) String 

func (x *StartActionRequest_PTSummaryParams) String() 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 

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

Deprecated: Use StartActionRequest_PostgreSQLQuerySelectParams.ProtoReflect.Descriptor instead.

func (*StartActionRequest_PostgreSQLQuerySelectParams) GetDsn 

func (x *StartActionRequest_PostgreSQLQuerySelectParams) GetDsn() string

func (*StartActionRequest_PostgreSQLQuerySelectParams) GetQuery 

func (x *StartActionRequest_PostgreSQLQuerySelectParams) GetQuery() string

func (*StartActionRequest_PostgreSQLQuerySelectParams) ProtoMessage 

func (*StartActionRequest_PostgreSQLQuerySelectParams) ProtoMessage()

func (*StartActionRequest_PostgreSQLQuerySelectParams) ProtoReflect 

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

func (*StartActionRequest_PostgreSQLQuerySelectParams) Reset 

func (x *StartActionRequest_PostgreSQLQuerySelectParams) Reset()

func (*StartActionRequest_PostgreSQLQuerySelectParams) String 

func (x *StartActionRequest_PostgreSQLQuerySelectParams) String() string

func (*StartActionRequest_PostgreSQLQuerySelectParams) Validate 

func (this *StartActionRequest_PostgreSQLQuerySelectParams) Validate() error

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 

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

Deprecated: Use StartActionRequest_PostgreSQLQueryShowParams.ProtoReflect.Descriptor instead.

func (*StartActionRequest_PostgreSQLQueryShowParams) GetDsn 

func (x *StartActionRequest_PostgreSQLQueryShowParams) GetDsn() string

func (*StartActionRequest_PostgreSQLQueryShowParams) ProtoMessage 

func (*StartActionRequest_PostgreSQLQueryShowParams) ProtoMessage()

func (*StartActionRequest_PostgreSQLQueryShowParams) ProtoReflect 

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

func (*StartActionRequest_PostgreSQLQueryShowParams) Reset 

func (x *StartActionRequest_PostgreSQLQueryShowParams) Reset()

func (*StartActionRequest_PostgreSQLQueryShowParams) String 

func (x *StartActionRequest_PostgreSQLQueryShowParams) String() string

func (*StartActionRequest_PostgreSQLQueryShowParams) Validate 

func (this *StartActionRequest_PostgreSQLQueryShowParams) Validate() error

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 

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

Deprecated: Use StartActionRequest_PostgreSQLShowCreateTableParams.ProtoReflect.Descriptor instead.

func (*StartActionRequest_PostgreSQLShowCreateTableParams) GetDsn 

func (x *StartActionRequest_PostgreSQLShowCreateTableParams) GetDsn() string

func (*StartActionRequest_PostgreSQLShowCreateTableParams) GetTable 

func (x *StartActionRequest_PostgreSQLShowCreateTableParams) GetTable() string

func (*StartActionRequest_PostgreSQLShowCreateTableParams) ProtoMessage 

func (*StartActionRequest_PostgreSQLShowCreateTableParams) ProtoMessage()

func (*StartActionRequest_PostgreSQLShowCreateTableParams) ProtoReflect 

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

func (*StartActionRequest_PostgreSQLShowCreateTableParams) Reset 

func (x *StartActionRequest_PostgreSQLShowCreateTableParams) Reset()

func (*StartActionRequest_PostgreSQLShowCreateTableParams) String 

func (x *StartActionRequest_PostgreSQLShowCreateTableParams) String() string

func (*StartActionRequest_PostgreSQLShowCreateTableParams) Validate 

func (this *StartActionRequest_PostgreSQLShowCreateTableParams) Validate() error

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 

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

Deprecated: Use StartActionRequest_PostgreSQLShowIndexParams.ProtoReflect.Descriptor instead.

func (*StartActionRequest_PostgreSQLShowIndexParams) GetDsn 

func (x *StartActionRequest_PostgreSQLShowIndexParams) GetDsn() string

func (*StartActionRequest_PostgreSQLShowIndexParams) GetTable 

func (x *StartActionRequest_PostgreSQLShowIndexParams) GetTable() string

func (*StartActionRequest_PostgreSQLShowIndexParams) ProtoMessage 

func (*StartActionRequest_PostgreSQLShowIndexParams) ProtoMessage()

func (*StartActionRequest_PostgreSQLShowIndexParams) ProtoReflect 

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

func (*StartActionRequest_PostgreSQLShowIndexParams) Reset 

func (x *StartActionRequest_PostgreSQLShowIndexParams) Reset()

func (*StartActionRequest_PostgreSQLShowIndexParams) String 

func (x *StartActionRequest_PostgreSQLShowIndexParams) String() string

func (*StartActionRequest_PostgreSQLShowIndexParams) Validate 

func (this *StartActionRequest_PostgreSQLShowIndexParams) Validate() error

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 (x *StartJobRequest_MySQLBackup) GetS3Config() *S3LocationConfig

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 (x *StartJobRequest_MySQLBackup) ProtoReflect() protoreflect.Message

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 (x *StartJobRequest_MySQLRestoreBackup) GetName() string

func (*StartJobRequest_MySQLRestoreBackup) GetS3Config 

func (x *StartJobRequest_MySQLRestoreBackup) GetS3Config() *S3LocationConfig

func (*StartJobRequest_MySQLRestoreBackup) GetServiceId 

func (x *StartJobRequest_MySQLRestoreBackup) GetServiceId() string

func (*StartJobRequest_MySQLRestoreBackup) ProtoMessage 

func (*StartJobRequest_MySQLRestoreBackup) ProtoMessage()

func (*StartJobRequest_MySQLRestoreBackup) ProtoReflect 

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

func (*StartJobRequest_MySQLRestoreBackup) Reset 

func (x *StartJobRequest_MySQLRestoreBackup) Reset()

func (*StartJobRequest_MySQLRestoreBackup) String 

func (x *StartJobRequest_MySQLRestoreBackup) String() 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 (x *StateChangedRequest) GetStatus() inventorypb.AgentStatus

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 

func (*UnimplementedAgentServer) Connect(Agent_ConnectServer) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

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