Documentation
¶
Overview ¶
Package agentpb contains pmm-agent<->pmm-managed protocol messages and helpers.
Index ¶
- Variables
- func AddAgentConnectMetadata(ctx context.Context, md *AgentConnectMetadata) context.Context
- func MarshalActionQueryDocsResult(docs []map[string]interface{}) ([]byte, error)
- func MarshalActionQuerySQLResult(columns []string, rows [][]interface{}) ([]byte, error)
- func RegisterAgentServer(s *grpc.Server, srv AgentServer)
- func SendServerConnectMetadata(stream grpc.ServerStream, md *ServerConnectMetadata) error
- func UnmarshalActionQueryResult(b []byte) ([]map[string]interface{}, error)
- type ActionResultRequest
- func (m *ActionResultRequest) AgentMessageRequestPayload() isAgentMessage_Payload
- func (*ActionResultRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ActionResultRequest) GetActionId() string
- func (x *ActionResultRequest) GetDone() bool
- func (x *ActionResultRequest) GetError() string
- func (x *ActionResultRequest) GetOutput() []byte
- func (*ActionResultRequest) ProtoMessage()
- func (x *ActionResultRequest) ProtoReflect() protoreflect.Message
- func (x *ActionResultRequest) Reset()
- func (x *ActionResultRequest) String() string
- func (this *ActionResultRequest) Validate() error
- type ActionResultResponse
- func (*ActionResultResponse) Descriptor() ([]byte, []int)deprecated
- func (*ActionResultResponse) ProtoMessage()
- func (x *ActionResultResponse) ProtoReflect() protoreflect.Message
- func (x *ActionResultResponse) Reset()
- func (m *ActionResultResponse) ServerMessageResponsePayload() isServerMessage_Payload
- func (x *ActionResultResponse) String() string
- func (this *ActionResultResponse) Validate() error
- type AgentClient
- type AgentConnectMetadata
- type AgentMessage
- func (*AgentMessage) Descriptor() ([]byte, []int)deprecated
- func (x *AgentMessage) GetActionResult() *ActionResultRequest
- func (x *AgentMessage) GetCheckConnection() *CheckConnectionResponse
- func (x *AgentMessage) GetId() uint32
- func (x *AgentMessage) GetJobProgress() *JobProgress
- func (x *AgentMessage) GetJobResult() *JobResult
- func (x *AgentMessage) GetJobStatus() *JobStatusResponse
- func (m *AgentMessage) GetPayload() isAgentMessage_Payload
- func (x *AgentMessage) GetPing() *Ping
- func (x *AgentMessage) GetPong() *Pong
- func (x *AgentMessage) GetQanCollect() *QANCollectRequest
- func (x *AgentMessage) GetSetState() *SetStateResponse
- func (x *AgentMessage) GetStartAction() *StartActionResponse
- func (x *AgentMessage) GetStartJob() *StartJobResponse
- func (x *AgentMessage) GetStateChanged() *StateChangedRequest
- func (x *AgentMessage) GetStatus() *status.Status
- func (x *AgentMessage) GetStopAction() *StopActionResponse
- func (x *AgentMessage) GetStopJob() *StopJobResponse
- func (*AgentMessage) ProtoMessage()
- func (x *AgentMessage) ProtoReflect() protoreflect.Message
- func (x *AgentMessage) Reset()
- func (x *AgentMessage) String() string
- func (this *AgentMessage) Validate() error
- type AgentMessage_ActionResult
- type AgentMessage_CheckConnection
- type AgentMessage_JobProgress
- type AgentMessage_JobResult
- type AgentMessage_JobStatus
- type AgentMessage_Ping
- type AgentMessage_Pong
- type AgentMessage_QanCollect
- type AgentMessage_SetState
- type AgentMessage_StartAction
- type AgentMessage_StartJob
- type AgentMessage_StateChanged
- type AgentMessage_StopAction
- type AgentMessage_StopJob
- type AgentParams
- type AgentRequestPayload
- type AgentResponsePayload
- type AgentServer
- type Agent_ConnectClient
- type Agent_ConnectServer
- type CheckConnectionRequest
- func (*CheckConnectionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CheckConnectionRequest) GetDsn() string
- func (x *CheckConnectionRequest) GetTextFiles() *TextFiles
- func (x *CheckConnectionRequest) GetTimeout() *duration.Duration
- func (x *CheckConnectionRequest) GetTlsSkipVerify() bool
- func (x *CheckConnectionRequest) GetType() inventorypb.ServiceType
- func (*CheckConnectionRequest) ProtoMessage()
- func (x *CheckConnectionRequest) ProtoReflect() protoreflect.Message
- func (x *CheckConnectionRequest) Reset()
- func (m *CheckConnectionRequest) ServerMessageRequestPayload() isServerMessage_Payload
- func (x *CheckConnectionRequest) String() string
- func (this *CheckConnectionRequest) Validate() error
- type CheckConnectionResponse
- func (m *CheckConnectionResponse) AgentMessageResponsePayload() isAgentMessage_Payload
- func (*CheckConnectionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CheckConnectionResponse) GetError() string
- func (x *CheckConnectionResponse) GetStats() *CheckConnectionResponse_Stats
- func (*CheckConnectionResponse) ProtoMessage()
- func (x *CheckConnectionResponse) ProtoReflect() protoreflect.Message
- func (x *CheckConnectionResponse) Reset()
- func (x *CheckConnectionResponse) String() string
- func (this *CheckConnectionResponse) Validate() error
- type CheckConnectionResponse_Stats
- func (*CheckConnectionResponse_Stats) Descriptor() ([]byte, []int)deprecated
- func (x *CheckConnectionResponse_Stats) GetTableCount() int32
- func (*CheckConnectionResponse_Stats) ProtoMessage()
- func (x *CheckConnectionResponse_Stats) ProtoReflect() protoreflect.Message
- func (x *CheckConnectionResponse_Stats) Reset()
- func (x *CheckConnectionResponse_Stats) String() string
- func (this *CheckConnectionResponse_Stats) Validate() error
- type ExampleFormatdeprecated
- func (ExampleFormat) Descriptor() protoreflect.EnumDescriptor
- func (x ExampleFormat) Enum() *ExampleFormat
- func (ExampleFormat) EnumDescriptor() ([]byte, []int)deprecated
- func (x ExampleFormat) Number() protoreflect.EnumNumber
- func (x ExampleFormat) String() string
- func (ExampleFormat) Type() protoreflect.EnumType
- type ExampleType
- func (ExampleType) Descriptor() protoreflect.EnumDescriptor
- func (x ExampleType) Enum() *ExampleType
- func (ExampleType) EnumDescriptor() ([]byte, []int)deprecated
- func (x ExampleType) Number() protoreflect.EnumNumber
- func (x ExampleType) String() string
- func (ExampleType) Type() protoreflect.EnumType
- type JobProgress
- func (m *JobProgress) AgentMessageRequestPayload() isAgentMessage_Payload
- func (m *JobProgress) AgentMessageResponsePayload() isAgentMessage_Payload
- func (*JobProgress) Descriptor() ([]byte, []int)deprecated
- func (x *JobProgress) GetEcho() *JobProgress_Echo
- func (x *JobProgress) GetJobId() string
- func (x *JobProgress) GetMysqlBackup() *JobProgress_MySQLBackup
- func (x *JobProgress) GetMysqlRestoreBackup() *JobProgress_MySQLRestoreBackup
- func (m *JobProgress) GetResult() isJobProgress_Result
- func (x *JobProgress) GetTimestamp() *timestamp.Timestamp
- func (*JobProgress) ProtoMessage()
- func (x *JobProgress) ProtoReflect() protoreflect.Message
- func (x *JobProgress) Reset()
- func (x *JobProgress) String() string
- func (this *JobProgress) Validate() error
- type JobProgress_Echo
- func (*JobProgress_Echo) Descriptor() ([]byte, []int)deprecated
- func (x *JobProgress_Echo) GetStatus() string
- func (*JobProgress_Echo) ProtoMessage()
- func (x *JobProgress_Echo) ProtoReflect() protoreflect.Message
- func (x *JobProgress_Echo) Reset()
- func (x *JobProgress_Echo) String() string
- func (this *JobProgress_Echo) Validate() error
- type JobProgress_Echo_
- type JobProgress_MySQLBackup
- func (*JobProgress_MySQLBackup) Descriptor() ([]byte, []int)deprecated
- func (*JobProgress_MySQLBackup) ProtoMessage()
- func (x *JobProgress_MySQLBackup) ProtoReflect() protoreflect.Message
- func (x *JobProgress_MySQLBackup) Reset()
- func (x *JobProgress_MySQLBackup) String() string
- func (this *JobProgress_MySQLBackup) Validate() error
- type JobProgress_MySQLRestoreBackup
- func (*JobProgress_MySQLRestoreBackup) Descriptor() ([]byte, []int)deprecated
- func (*JobProgress_MySQLRestoreBackup) ProtoMessage()
- func (x *JobProgress_MySQLRestoreBackup) ProtoReflect() protoreflect.Message
- func (x *JobProgress_MySQLRestoreBackup) Reset()
- func (x *JobProgress_MySQLRestoreBackup) String() string
- func (this *JobProgress_MySQLRestoreBackup) Validate() error
- type JobProgress_MysqlBackup
- type JobProgress_MysqlRestoreBackup
- type JobResult
- func (m *JobResult) AgentMessageRequestPayload() isAgentMessage_Payload
- func (m *JobResult) AgentMessageResponsePayload() isAgentMessage_Payload
- func (*JobResult) Descriptor() ([]byte, []int)deprecated
- func (x *JobResult) GetEcho() *JobResult_Echo
- func (x *JobResult) GetError() *JobResult_Error
- func (x *JobResult) GetJobId() string
- func (x *JobResult) GetMysqlBackup() *JobResult_MySQLBackup
- func (x *JobResult) GetMysqlRestoreBackup() *JobResult_MySQLRestoreBackup
- func (m *JobResult) GetResult() isJobResult_Result
- func (x *JobResult) GetTimestamp() *timestamp.Timestamp
- func (*JobResult) ProtoMessage()
- func (x *JobResult) ProtoReflect() protoreflect.Message
- func (x *JobResult) Reset()
- func (x *JobResult) String() string
- func (this *JobResult) Validate() error
- type JobResult_Echo
- func (*JobResult_Echo) Descriptor() ([]byte, []int)deprecated
- func (x *JobResult_Echo) GetMessage() string
- func (*JobResult_Echo) ProtoMessage()
- func (x *JobResult_Echo) ProtoReflect() protoreflect.Message
- func (x *JobResult_Echo) Reset()
- func (x *JobResult_Echo) String() string
- func (this *JobResult_Echo) Validate() error
- type JobResult_Echo_
- type JobResult_Error
- func (*JobResult_Error) Descriptor() ([]byte, []int)deprecated
- func (x *JobResult_Error) GetMessage() string
- func (*JobResult_Error) ProtoMessage()
- func (x *JobResult_Error) ProtoReflect() protoreflect.Message
- func (x *JobResult_Error) Reset()
- func (x *JobResult_Error) String() string
- func (this *JobResult_Error) Validate() error
- type JobResult_Error_
- type JobResult_MySQLBackup
- func (*JobResult_MySQLBackup) Descriptor() ([]byte, []int)deprecated
- func (*JobResult_MySQLBackup) ProtoMessage()
- func (x *JobResult_MySQLBackup) ProtoReflect() protoreflect.Message
- func (x *JobResult_MySQLBackup) Reset()
- func (x *JobResult_MySQLBackup) String() string
- func (this *JobResult_MySQLBackup) Validate() error
- type JobResult_MySQLRestoreBackup
- func (*JobResult_MySQLRestoreBackup) Descriptor() ([]byte, []int)deprecated
- func (*JobResult_MySQLRestoreBackup) ProtoMessage()
- func (x *JobResult_MySQLRestoreBackup) ProtoReflect() protoreflect.Message
- func (x *JobResult_MySQLRestoreBackup) Reset()
- func (x *JobResult_MySQLRestoreBackup) String() string
- func (this *JobResult_MySQLRestoreBackup) Validate() error
- type JobResult_MysqlBackup
- type JobResult_MysqlRestoreBackup
- type JobStatusRequest
- func (*JobStatusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *JobStatusRequest) GetJobId() string
- func (*JobStatusRequest) ProtoMessage()
- func (x *JobStatusRequest) ProtoReflect() protoreflect.Message
- func (x *JobStatusRequest) Reset()
- func (m *JobStatusRequest) ServerMessageRequestPayload() isServerMessage_Payload
- func (x *JobStatusRequest) String() string
- func (this *JobStatusRequest) Validate() error
- type JobStatusResponse
- func (m *JobStatusResponse) AgentMessageResponsePayload() isAgentMessage_Payload
- func (*JobStatusResponse) Descriptor() ([]byte, []int)deprecated
- func (x *JobStatusResponse) GetAlive() bool
- func (*JobStatusResponse) ProtoMessage()
- func (x *JobStatusResponse) ProtoReflect() protoreflect.Message
- func (x *JobStatusResponse) Reset()
- func (x *JobStatusResponse) String() string
- func (this *JobStatusResponse) Validate() error
- type MetricsBucket
- func (*MetricsBucket) Descriptor() ([]byte, []int)deprecated
- func (x *MetricsBucket) GetCommon() *MetricsBucket_Common
- func (x *MetricsBucket) GetMongodb() *MetricsBucket_MongoDB
- func (x *MetricsBucket) GetMysql() *MetricsBucket_MySQL
- func (x *MetricsBucket) GetPostgresql() *MetricsBucket_PostgreSQL
- func (*MetricsBucket) ProtoMessage()
- func (x *MetricsBucket) ProtoReflect() protoreflect.Message
- func (x *MetricsBucket) Reset()
- func (x *MetricsBucket) String() string
- func (this *MetricsBucket) Validate() error
- type MetricsBucket_Common
- func (*MetricsBucket_Common) Descriptor() ([]byte, []int)deprecated
- func (x *MetricsBucket_Common) GetAgentId() string
- func (x *MetricsBucket_Common) GetAgentType() inventorypb.AgentType
- func (x *MetricsBucket_Common) GetClientHost() string
- func (x *MetricsBucket_Common) GetDatabase() string
- func (x *MetricsBucket_Common) GetErrors() map[uint64]uint64
- func (x *MetricsBucket_Common) GetExample() string
- func (x *MetricsBucket_Common) GetExampleFormat() ExampleFormatdeprecated
- func (x *MetricsBucket_Common) GetExampleType() ExampleType
- func (x *MetricsBucket_Common) GetFingerprint() string
- func (x *MetricsBucket_Common) GetIsTruncated() bool
- func (x *MetricsBucket_Common) GetMQueryTimeCnt() float32
- func (x *MetricsBucket_Common) GetMQueryTimeMax() float32
- func (x *MetricsBucket_Common) GetMQueryTimeMin() float32
- func (x *MetricsBucket_Common) GetMQueryTimeP99() float32
- func (x *MetricsBucket_Common) GetMQueryTimeSum() float32
- func (x *MetricsBucket_Common) GetNumQueries() float32
- func (x *MetricsBucket_Common) GetNumQueriesWithErrors() float32
- func (x *MetricsBucket_Common) GetNumQueriesWithWarnings() float32
- func (x *MetricsBucket_Common) GetPeriodLengthSecs() uint32
- func (x *MetricsBucket_Common) GetPeriodStartUnixSecs() uint32
- func (x *MetricsBucket_Common) GetQueryid() string
- func (x *MetricsBucket_Common) GetSchema() string
- func (x *MetricsBucket_Common) GetTables() []string
- func (x *MetricsBucket_Common) GetUsername() string
- func (*MetricsBucket_Common) ProtoMessage()
- func (x *MetricsBucket_Common) ProtoReflect() protoreflect.Message
- func (x *MetricsBucket_Common) Reset()
- func (x *MetricsBucket_Common) String() string
- func (this *MetricsBucket_Common) Validate() error
- type MetricsBucket_MongoDB
- func (*MetricsBucket_MongoDB) Descriptor() ([]byte, []int)deprecated
- func (x *MetricsBucket_MongoDB) GetMDocsReturnedCnt() float32
- func (x *MetricsBucket_MongoDB) GetMDocsReturnedMax() float32
- func (x *MetricsBucket_MongoDB) GetMDocsReturnedMin() float32
- func (x *MetricsBucket_MongoDB) GetMDocsReturnedP99() float32
- func (x *MetricsBucket_MongoDB) GetMDocsReturnedSum() float32
- func (x *MetricsBucket_MongoDB) GetMDocsScannedCnt() float32
- func (x *MetricsBucket_MongoDB) GetMDocsScannedMax() float32
- func (x *MetricsBucket_MongoDB) GetMDocsScannedMin() float32
- func (x *MetricsBucket_MongoDB) GetMDocsScannedP99() float32
- func (x *MetricsBucket_MongoDB) GetMDocsScannedSum() float32
- func (x *MetricsBucket_MongoDB) GetMResponseLengthCnt() float32
- func (x *MetricsBucket_MongoDB) GetMResponseLengthMax() float32
- func (x *MetricsBucket_MongoDB) GetMResponseLengthMin() float32
- func (x *MetricsBucket_MongoDB) GetMResponseLengthP99() float32
- func (x *MetricsBucket_MongoDB) GetMResponseLengthSum() float32
- func (*MetricsBucket_MongoDB) ProtoMessage()
- func (x *MetricsBucket_MongoDB) ProtoReflect() protoreflect.Message
- func (x *MetricsBucket_MongoDB) Reset()
- func (x *MetricsBucket_MongoDB) String() string
- func (this *MetricsBucket_MongoDB) Validate() error
- type MetricsBucket_MySQL
- func (*MetricsBucket_MySQL) Descriptor() ([]byte, []int)deprecated
- func (x *MetricsBucket_MySQL) GetMBytesSentCnt() float32
- func (x *MetricsBucket_MySQL) GetMBytesSentMax() float32
- func (x *MetricsBucket_MySQL) GetMBytesSentMin() float32
- func (x *MetricsBucket_MySQL) GetMBytesSentP99() float32
- func (x *MetricsBucket_MySQL) GetMBytesSentSum() float32
- func (x *MetricsBucket_MySQL) GetMFilesortCnt() float32
- func (x *MetricsBucket_MySQL) GetMFilesortOnDiskCnt() float32
- func (x *MetricsBucket_MySQL) GetMFilesortOnDiskSum() float32
- func (x *MetricsBucket_MySQL) GetMFilesortSum() float32
- func (x *MetricsBucket_MySQL) GetMFullJoinCnt() float32
- func (x *MetricsBucket_MySQL) GetMFullJoinSum() float32
- func (x *MetricsBucket_MySQL) GetMFullScanCnt() float32
- func (x *MetricsBucket_MySQL) GetMFullScanSum() float32
- func (x *MetricsBucket_MySQL) GetMInnodbIoRBytesCnt() float32
- func (x *MetricsBucket_MySQL) GetMInnodbIoRBytesMax() float32
- func (x *MetricsBucket_MySQL) GetMInnodbIoRBytesMin() float32
- func (x *MetricsBucket_MySQL) GetMInnodbIoRBytesP99() float32
- func (x *MetricsBucket_MySQL) GetMInnodbIoRBytesSum() float32
- func (x *MetricsBucket_MySQL) GetMInnodbIoROpsCnt() float32
- func (x *MetricsBucket_MySQL) GetMInnodbIoROpsMax() float32
- func (x *MetricsBucket_MySQL) GetMInnodbIoROpsMin() float32
- func (x *MetricsBucket_MySQL) GetMInnodbIoROpsP99() float32
- func (x *MetricsBucket_MySQL) GetMInnodbIoROpsSum() float32
- func (x *MetricsBucket_MySQL) GetMInnodbIoRWaitCnt() float32
- func (x *MetricsBucket_MySQL) GetMInnodbIoRWaitMax() float32
- func (x *MetricsBucket_MySQL) GetMInnodbIoRWaitMin() float32
- func (x *MetricsBucket_MySQL) GetMInnodbIoRWaitP99() float32
- func (x *MetricsBucket_MySQL) GetMInnodbIoRWaitSum() float32
- func (x *MetricsBucket_MySQL) GetMInnodbPagesDistinctCnt() float32
- func (x *MetricsBucket_MySQL) GetMInnodbPagesDistinctMax() float32
- func (x *MetricsBucket_MySQL) GetMInnodbPagesDistinctMin() float32
- func (x *MetricsBucket_MySQL) GetMInnodbPagesDistinctP99() float32
- func (x *MetricsBucket_MySQL) GetMInnodbPagesDistinctSum() float32
- func (x *MetricsBucket_MySQL) GetMInnodbQueueWaitCnt() float32
- func (x *MetricsBucket_MySQL) GetMInnodbQueueWaitMax() float32
- func (x *MetricsBucket_MySQL) GetMInnodbQueueWaitMin() float32
- func (x *MetricsBucket_MySQL) GetMInnodbQueueWaitP99() float32
- func (x *MetricsBucket_MySQL) GetMInnodbQueueWaitSum() float32
- func (x *MetricsBucket_MySQL) GetMInnodbRecLockWaitCnt() float32
- func (x *MetricsBucket_MySQL) GetMInnodbRecLockWaitMax() float32
- func (x *MetricsBucket_MySQL) GetMInnodbRecLockWaitMin() float32
- func (x *MetricsBucket_MySQL) GetMInnodbRecLockWaitP99() float32
- func (x *MetricsBucket_MySQL) GetMInnodbRecLockWaitSum() float32
- func (x *MetricsBucket_MySQL) GetMLockTimeCnt() float32
- func (x *MetricsBucket_MySQL) GetMLockTimeMax() float32
- func (x *MetricsBucket_MySQL) GetMLockTimeMin() float32
- func (x *MetricsBucket_MySQL) GetMLockTimeP99() float32
- func (x *MetricsBucket_MySQL) GetMLockTimeSum() float32
- func (x *MetricsBucket_MySQL) GetMMergePassesCnt() float32
- func (x *MetricsBucket_MySQL) GetMMergePassesMax() float32
- func (x *MetricsBucket_MySQL) GetMMergePassesMin() float32
- func (x *MetricsBucket_MySQL) GetMMergePassesP99() float32
- func (x *MetricsBucket_MySQL) GetMMergePassesSum() float32
- func (x *MetricsBucket_MySQL) GetMNoGoodIndexUsedCnt() float32
- func (x *MetricsBucket_MySQL) GetMNoGoodIndexUsedSum() float32
- func (x *MetricsBucket_MySQL) GetMNoIndexUsedCnt() float32
- func (x *MetricsBucket_MySQL) GetMNoIndexUsedSum() float32
- func (x *MetricsBucket_MySQL) GetMQcHitCnt() float32
- func (x *MetricsBucket_MySQL) GetMQcHitSum() float32
- func (x *MetricsBucket_MySQL) GetMQueryLengthCnt() float32
- func (x *MetricsBucket_MySQL) GetMQueryLengthMax() float32
- func (x *MetricsBucket_MySQL) GetMQueryLengthMin() float32
- func (x *MetricsBucket_MySQL) GetMQueryLengthP99() float32
- func (x *MetricsBucket_MySQL) GetMQueryLengthSum() float32
- func (x *MetricsBucket_MySQL) GetMRowsAffectedCnt() float32
- func (x *MetricsBucket_MySQL) GetMRowsAffectedMax() float32
- func (x *MetricsBucket_MySQL) GetMRowsAffectedMin() float32
- func (x *MetricsBucket_MySQL) GetMRowsAffectedP99() float32
- func (x *MetricsBucket_MySQL) GetMRowsAffectedSum() float32
- func (x *MetricsBucket_MySQL) GetMRowsExaminedCnt() float32
- func (x *MetricsBucket_MySQL) GetMRowsExaminedMax() float32
- func (x *MetricsBucket_MySQL) GetMRowsExaminedMin() float32
- func (x *MetricsBucket_MySQL) GetMRowsExaminedP99() float32
- func (x *MetricsBucket_MySQL) GetMRowsExaminedSum() float32
- func (x *MetricsBucket_MySQL) GetMRowsReadCnt() float32
- func (x *MetricsBucket_MySQL) GetMRowsReadMax() float32
- func (x *MetricsBucket_MySQL) GetMRowsReadMin() float32
- func (x *MetricsBucket_MySQL) GetMRowsReadP99() float32
- func (x *MetricsBucket_MySQL) GetMRowsReadSum() float32
- func (x *MetricsBucket_MySQL) GetMRowsSentCnt() float32
- func (x *MetricsBucket_MySQL) GetMRowsSentMax() float32
- func (x *MetricsBucket_MySQL) GetMRowsSentMin() float32
- func (x *MetricsBucket_MySQL) GetMRowsSentP99() float32
- func (x *MetricsBucket_MySQL) GetMRowsSentSum() float32
- func (x *MetricsBucket_MySQL) GetMSelectFullRangeJoinCnt() float32
- func (x *MetricsBucket_MySQL) GetMSelectFullRangeJoinSum() float32
- func (x *MetricsBucket_MySQL) GetMSelectRangeCheckCnt() float32
- func (x *MetricsBucket_MySQL) GetMSelectRangeCheckSum() float32
- func (x *MetricsBucket_MySQL) GetMSelectRangeCnt() float32
- func (x *MetricsBucket_MySQL) GetMSelectRangeSum() float32
- func (x *MetricsBucket_MySQL) GetMSortRangeCnt() float32
- func (x *MetricsBucket_MySQL) GetMSortRangeSum() float32
- func (x *MetricsBucket_MySQL) GetMSortRowsCnt() float32
- func (x *MetricsBucket_MySQL) GetMSortRowsSum() float32
- func (x *MetricsBucket_MySQL) GetMSortScanCnt() float32
- func (x *MetricsBucket_MySQL) GetMSortScanSum() float32
- func (x *MetricsBucket_MySQL) GetMTmpDiskTablesCnt() float32
- func (x *MetricsBucket_MySQL) GetMTmpDiskTablesMax() float32
- func (x *MetricsBucket_MySQL) GetMTmpDiskTablesMin() float32
- func (x *MetricsBucket_MySQL) GetMTmpDiskTablesP99() float32
- func (x *MetricsBucket_MySQL) GetMTmpDiskTablesSum() float32
- func (x *MetricsBucket_MySQL) GetMTmpTableCnt() float32
- func (x *MetricsBucket_MySQL) GetMTmpTableOnDiskCnt() float32
- func (x *MetricsBucket_MySQL) GetMTmpTableOnDiskSum() float32
- func (x *MetricsBucket_MySQL) GetMTmpTableSizesCnt() float32
- func (x *MetricsBucket_MySQL) GetMTmpTableSizesMax() float32
- func (x *MetricsBucket_MySQL) GetMTmpTableSizesMin() float32
- func (x *MetricsBucket_MySQL) GetMTmpTableSizesP99() float32
- func (x *MetricsBucket_MySQL) GetMTmpTableSizesSum() float32
- func (x *MetricsBucket_MySQL) GetMTmpTableSum() float32
- func (x *MetricsBucket_MySQL) GetMTmpTablesCnt() float32
- func (x *MetricsBucket_MySQL) GetMTmpTablesMax() float32
- func (x *MetricsBucket_MySQL) GetMTmpTablesMin() float32
- func (x *MetricsBucket_MySQL) GetMTmpTablesP99() float32
- func (x *MetricsBucket_MySQL) GetMTmpTablesSum() float32
- func (*MetricsBucket_MySQL) ProtoMessage()
- func (x *MetricsBucket_MySQL) ProtoReflect() protoreflect.Message
- func (x *MetricsBucket_MySQL) Reset()
- func (x *MetricsBucket_MySQL) String() string
- func (this *MetricsBucket_MySQL) Validate() error
- type MetricsBucket_PostgreSQL
- func (*MetricsBucket_PostgreSQL) Descriptor() ([]byte, []int)deprecated
- func (x *MetricsBucket_PostgreSQL) GetMBlkReadTimeCnt() float32
- func (x *MetricsBucket_PostgreSQL) GetMBlkReadTimeSum() float32
- func (x *MetricsBucket_PostgreSQL) GetMBlkWriteTimeCnt() float32
- func (x *MetricsBucket_PostgreSQL) GetMBlkWriteTimeSum() float32
- func (x *MetricsBucket_PostgreSQL) GetMCpuSysTimeCnt() float32
- func (x *MetricsBucket_PostgreSQL) GetMCpuSysTimeSum() float32
- func (x *MetricsBucket_PostgreSQL) GetMCpuUserTimeCnt() float32
- func (x *MetricsBucket_PostgreSQL) GetMCpuUserTimeSum() float32
- func (x *MetricsBucket_PostgreSQL) GetMLocalBlksDirtiedCnt() float32
- func (x *MetricsBucket_PostgreSQL) GetMLocalBlksDirtiedSum() float32
- func (x *MetricsBucket_PostgreSQL) GetMLocalBlksHitCnt() float32
- func (x *MetricsBucket_PostgreSQL) GetMLocalBlksHitSum() float32
- func (x *MetricsBucket_PostgreSQL) GetMLocalBlksReadCnt() float32
- func (x *MetricsBucket_PostgreSQL) GetMLocalBlksReadSum() float32
- func (x *MetricsBucket_PostgreSQL) GetMLocalBlksWrittenCnt() float32
- func (x *MetricsBucket_PostgreSQL) GetMLocalBlksWrittenSum() float32
- func (x *MetricsBucket_PostgreSQL) GetMRowsCnt() float32
- func (x *MetricsBucket_PostgreSQL) GetMRowsSum() float32
- func (x *MetricsBucket_PostgreSQL) GetMSharedBlksDirtiedCnt() float32
- func (x *MetricsBucket_PostgreSQL) GetMSharedBlksDirtiedSum() float32
- func (x *MetricsBucket_PostgreSQL) GetMSharedBlksHitCnt() float32
- func (x *MetricsBucket_PostgreSQL) GetMSharedBlksHitSum() float32
- func (x *MetricsBucket_PostgreSQL) GetMSharedBlksReadCnt() float32
- func (x *MetricsBucket_PostgreSQL) GetMSharedBlksReadSum() float32
- func (x *MetricsBucket_PostgreSQL) GetMSharedBlksWrittenCnt() float32
- func (x *MetricsBucket_PostgreSQL) GetMSharedBlksWrittenSum() float32
- func (x *MetricsBucket_PostgreSQL) GetMTempBlksReadCnt() float32
- func (x *MetricsBucket_PostgreSQL) GetMTempBlksReadSum() float32
- func (x *MetricsBucket_PostgreSQL) GetMTempBlksWrittenCnt() float32
- func (x *MetricsBucket_PostgreSQL) GetMTempBlksWrittenSum() float32
- func (*MetricsBucket_PostgreSQL) ProtoMessage()
- func (x *MetricsBucket_PostgreSQL) ProtoReflect() protoreflect.Message
- func (x *MetricsBucket_PostgreSQL) Reset()
- func (x *MetricsBucket_PostgreSQL) String() string
- func (this *MetricsBucket_PostgreSQL) Validate() error
- type MysqlExplainOutputFormat
- func (MysqlExplainOutputFormat) Descriptor() protoreflect.EnumDescriptor
- func (x MysqlExplainOutputFormat) Enum() *MysqlExplainOutputFormat
- func (MysqlExplainOutputFormat) EnumDescriptor() ([]byte, []int)deprecated
- func (x MysqlExplainOutputFormat) Number() protoreflect.EnumNumber
- func (x MysqlExplainOutputFormat) String() string
- func (MysqlExplainOutputFormat) Type() protoreflect.EnumType
- type Ping
- func (m *Ping) AgentMessageRequestPayload() isAgentMessage_Payload
- func (*Ping) Descriptor() ([]byte, []int)deprecated
- func (*Ping) ProtoMessage()
- func (x *Ping) ProtoReflect() protoreflect.Message
- func (x *Ping) Reset()
- func (m *Ping) ServerMessageRequestPayload() isServerMessage_Payload
- func (x *Ping) String() string
- func (this *Ping) Validate() error
- type Pong
- func (m *Pong) AgentMessageResponsePayload() isAgentMessage_Payload
- func (*Pong) Descriptor() ([]byte, []int)deprecated
- func (x *Pong) GetCurrentTime() *timestamp.Timestamp
- func (*Pong) ProtoMessage()
- func (x *Pong) ProtoReflect() protoreflect.Message
- func (x *Pong) Reset()
- func (m *Pong) ServerMessageResponsePayload() isServerMessage_Payload
- func (x *Pong) String() string
- func (this *Pong) Validate() error
- type QANCollectRequest
- func (m *QANCollectRequest) AgentMessageRequestPayload() isAgentMessage_Payload
- func (*QANCollectRequest) Descriptor() ([]byte, []int)deprecated
- func (x *QANCollectRequest) GetMetricsBucket() []*MetricsBucket
- func (*QANCollectRequest) ProtoMessage()
- func (x *QANCollectRequest) ProtoReflect() protoreflect.Message
- func (x *QANCollectRequest) Reset()
- func (x *QANCollectRequest) String() string
- func (this *QANCollectRequest) Validate() error
- type QANCollectResponse
- func (*QANCollectResponse) Descriptor() ([]byte, []int)deprecated
- func (*QANCollectResponse) ProtoMessage()
- func (x *QANCollectResponse) ProtoReflect() protoreflect.Message
- func (x *QANCollectResponse) Reset()
- func (m *QANCollectResponse) ServerMessageResponsePayload() isServerMessage_Payload
- func (x *QANCollectResponse) String() string
- func (this *QANCollectResponse) Validate() error
- type QueryActionMap
- func (*QueryActionMap) Descriptor() ([]byte, []int)deprecated
- func (x *QueryActionMap) GetMap() map[string]*QueryActionValue
- func (*QueryActionMap) ProtoMessage()
- func (x *QueryActionMap) ProtoReflect() protoreflect.Message
- func (x *QueryActionMap) Reset()
- func (x *QueryActionMap) String() string
- func (this *QueryActionMap) Validate() error
- type QueryActionResult
- func (*QueryActionResult) Descriptor() ([]byte, []int)deprecated
- func (x *QueryActionResult) GetColumns() []string
- func (x *QueryActionResult) GetDocs() []*QueryActionMap
- func (x *QueryActionResult) GetRows() []*QueryActionSlice
- func (*QueryActionResult) ProtoMessage()
- func (x *QueryActionResult) ProtoReflect() protoreflect.Message
- func (x *QueryActionResult) Reset()
- func (x *QueryActionResult) String() string
- func (this *QueryActionResult) Validate() error
- type QueryActionSlice
- func (*QueryActionSlice) Descriptor() ([]byte, []int)deprecated
- func (x *QueryActionSlice) GetSlice() []*QueryActionValue
- func (*QueryActionSlice) ProtoMessage()
- func (x *QueryActionSlice) ProtoReflect() protoreflect.Message
- func (x *QueryActionSlice) Reset()
- func (x *QueryActionSlice) String() string
- func (this *QueryActionSlice) Validate() error
- type QueryActionValue
- func (*QueryActionValue) Descriptor() ([]byte, []int)deprecated
- func (x *QueryActionValue) GetBool() bool
- func (x *QueryActionValue) GetBytes() []byte
- func (x *QueryActionValue) GetDouble() float64
- func (x *QueryActionValue) GetInt64() int64
- func (m *QueryActionValue) GetKind() isQueryActionValue_Kind
- func (x *QueryActionValue) GetMap() *QueryActionMap
- func (x *QueryActionValue) GetNil() bool
- func (x *QueryActionValue) GetSlice() *QueryActionSlice
- func (x *QueryActionValue) GetTimestamp() *timestamp.Timestamp
- func (x *QueryActionValue) GetUint64() uint64
- func (*QueryActionValue) ProtoMessage()
- func (x *QueryActionValue) ProtoReflect() protoreflect.Message
- func (x *QueryActionValue) Reset()
- func (x *QueryActionValue) String() string
- func (this *QueryActionValue) Validate() error
- type QueryActionValue_Bool
- type QueryActionValue_Bytes
- type QueryActionValue_Double
- type QueryActionValue_Int64
- type QueryActionValue_Map
- type QueryActionValue_Nil
- type QueryActionValue_Slice
- type QueryActionValue_Timestamp
- type QueryActionValue_Uint64
- type S3LocationConfig
- func (*S3LocationConfig) Descriptor() ([]byte, []int)deprecated
- func (x *S3LocationConfig) GetAccessKey() string
- func (x *S3LocationConfig) GetBucketName() string
- func (x *S3LocationConfig) GetBucketRegion() string
- func (x *S3LocationConfig) GetEndpoint() string
- func (x *S3LocationConfig) GetSecretKey() string
- func (*S3LocationConfig) ProtoMessage()
- func (x *S3LocationConfig) ProtoReflect() protoreflect.Message
- func (x *S3LocationConfig) Reset()
- func (x *S3LocationConfig) String() string
- func (this *S3LocationConfig) Validate() error
- type ServerConnectMetadata
- type ServerMessage
- func (*ServerMessage) Descriptor() ([]byte, []int)deprecated
- func (x *ServerMessage) GetActionResult() *ActionResultResponse
- func (x *ServerMessage) GetCheckConnection() *CheckConnectionRequest
- func (x *ServerMessage) GetId() uint32
- func (x *ServerMessage) GetJobStatus() *JobStatusRequest
- func (m *ServerMessage) GetPayload() isServerMessage_Payload
- func (x *ServerMessage) GetPing() *Ping
- func (x *ServerMessage) GetPong() *Pong
- func (x *ServerMessage) GetQanCollect() *QANCollectResponse
- func (x *ServerMessage) GetSetState() *SetStateRequest
- func (x *ServerMessage) GetStartAction() *StartActionRequest
- func (x *ServerMessage) GetStartJob() *StartJobRequest
- func (x *ServerMessage) GetStateChanged() *StateChangedResponse
- func (x *ServerMessage) GetStatus() *status.Status
- func (x *ServerMessage) GetStopAction() *StopActionRequest
- func (x *ServerMessage) GetStopJob() *StopJobRequest
- func (*ServerMessage) ProtoMessage()
- func (x *ServerMessage) ProtoReflect() protoreflect.Message
- func (x *ServerMessage) Reset()
- func (x *ServerMessage) String() string
- func (this *ServerMessage) Validate() error
- type ServerMessage_ActionResult
- type ServerMessage_CheckConnection
- type ServerMessage_JobStatus
- type ServerMessage_Ping
- type ServerMessage_Pong
- type ServerMessage_QanCollect
- type ServerMessage_SetState
- type ServerMessage_StartAction
- type ServerMessage_StartJob
- type ServerMessage_StateChanged
- type ServerMessage_StopAction
- type ServerMessage_StopJob
- type ServerRequestPayload
- type ServerResponsePayload
- type SetStateRequest
- func (*SetStateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SetStateRequest) GetAgentProcesses() map[string]*SetStateRequest_AgentProcess
- func (x *SetStateRequest) GetBuiltinAgents() map[string]*SetStateRequest_BuiltinAgent
- func (*SetStateRequest) ProtoMessage()
- func (x *SetStateRequest) ProtoReflect() protoreflect.Message
- func (x *SetStateRequest) Reset()
- func (m *SetStateRequest) ServerMessageRequestPayload() isServerMessage_Payload
- func (x *SetStateRequest) String() string
- func (this *SetStateRequest) Validate() error
- type SetStateRequest_AgentProcess
- func (*SetStateRequest_AgentProcess) Descriptor() ([]byte, []int)deprecated
- func (x *SetStateRequest_AgentProcess) GetArgs() []string
- func (x *SetStateRequest_AgentProcess) GetEnv() []string
- func (x *SetStateRequest_AgentProcess) GetRedactWords() []string
- func (x *SetStateRequest_AgentProcess) GetTemplateLeftDelim() string
- func (x *SetStateRequest_AgentProcess) GetTemplateRightDelim() string
- func (x *SetStateRequest_AgentProcess) GetTextFiles() map[string]string
- func (x *SetStateRequest_AgentProcess) GetType() inventorypb.AgentType
- func (*SetStateRequest_AgentProcess) ProtoMessage()
- func (x *SetStateRequest_AgentProcess) ProtoReflect() protoreflect.Message
- func (x *SetStateRequest_AgentProcess) Reset()
- func (x *SetStateRequest_AgentProcess) String() string
- func (this *SetStateRequest_AgentProcess) Validate() error
- type SetStateRequest_BuiltinAgent
- func (*SetStateRequest_BuiltinAgent) Descriptor() ([]byte, []int)deprecated
- func (x *SetStateRequest_BuiltinAgent) GetDisableQueryExamples() bool
- func (x *SetStateRequest_BuiltinAgent) GetDsn() string
- func (x *SetStateRequest_BuiltinAgent) GetMaxQueryLogSize() int64
- func (x *SetStateRequest_BuiltinAgent) GetTextFiles() *TextFiles
- func (x *SetStateRequest_BuiltinAgent) GetTls() bool
- func (x *SetStateRequest_BuiltinAgent) GetTlsSkipVerify() bool
- func (x *SetStateRequest_BuiltinAgent) GetType() inventorypb.AgentType
- func (*SetStateRequest_BuiltinAgent) ProtoMessage()
- func (x *SetStateRequest_BuiltinAgent) ProtoReflect() protoreflect.Message
- func (x *SetStateRequest_BuiltinAgent) Reset()
- func (x *SetStateRequest_BuiltinAgent) String() string
- func (this *SetStateRequest_BuiltinAgent) Validate() error
- type SetStateResponse
- func (m *SetStateResponse) AgentMessageResponsePayload() isAgentMessage_Payload
- func (*SetStateResponse) Descriptor() ([]byte, []int)deprecated
- func (*SetStateResponse) ProtoMessage()
- func (x *SetStateResponse) ProtoReflect() protoreflect.Message
- func (x *SetStateResponse) Reset()
- func (x *SetStateResponse) String() string
- func (this *SetStateResponse) Validate() error
- type StartActionRequest
- func (*StartActionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StartActionRequest) GetActionId() string
- func (x *StartActionRequest) GetMongodbExplainParams() *StartActionRequest_MongoDBExplainParams
- func (x *StartActionRequest) GetMongodbQueryBuildinfoParams() *StartActionRequest_MongoDBQueryBuildInfoParams
- func (x *StartActionRequest) GetMongodbQueryGetcmdlineoptsParams() *StartActionRequest_MongoDBQueryGetCmdLineOptsParams
- func (x *StartActionRequest) GetMongodbQueryGetparameterParams() *StartActionRequest_MongoDBQueryGetParameterParams
- func (x *StartActionRequest) GetMysqlExplainParams() *StartActionRequest_MySQLExplainParams
- func (x *StartActionRequest) GetMysqlQuerySelectParams() *StartActionRequest_MySQLQuerySelectParams
- func (x *StartActionRequest) GetMysqlQueryShowParams() *StartActionRequest_MySQLQueryShowParams
- func (x *StartActionRequest) GetMysqlShowCreateTableParams() *StartActionRequest_MySQLShowCreateTableParams
- func (x *StartActionRequest) GetMysqlShowIndexParams() *StartActionRequest_MySQLShowIndexParams
- func (x *StartActionRequest) GetMysqlShowTableStatusParams() *StartActionRequest_MySQLShowTableStatusParams
- func (m *StartActionRequest) GetParams() isStartActionRequest_Params
- func (x *StartActionRequest) GetPostgresqlQuerySelectParams() *StartActionRequest_PostgreSQLQuerySelectParams
- func (x *StartActionRequest) GetPostgresqlQueryShowParams() *StartActionRequest_PostgreSQLQueryShowParams
- func (x *StartActionRequest) GetPostgresqlShowCreateTableParams() *StartActionRequest_PostgreSQLShowCreateTableParams
- func (x *StartActionRequest) GetPostgresqlShowIndexParams() *StartActionRequest_PostgreSQLShowIndexParams
- func (x *StartActionRequest) GetPtMongodbSummaryParams() *StartActionRequest_PTMongoDBSummaryParams
- func (x *StartActionRequest) GetPtMysqlSummaryParams() *StartActionRequest_PTMySQLSummaryParams
- func (x *StartActionRequest) GetPtPgSummaryParams() *StartActionRequest_PTPgSummaryParams
- func (x *StartActionRequest) GetPtSummaryParams() *StartActionRequest_PTSummaryParams
- func (x *StartActionRequest) GetTimeout() *duration.Duration
- func (*StartActionRequest) ProtoMessage()
- func (x *StartActionRequest) ProtoReflect() protoreflect.Message
- func (x *StartActionRequest) Reset()
- func (m *StartActionRequest) ServerMessageRequestPayload() isServerMessage_Payload
- func (x *StartActionRequest) String() string
- func (this *StartActionRequest) Validate() error
- type StartActionRequest_MongoDBExplainParams
- func (*StartActionRequest_MongoDBExplainParams) Descriptor() ([]byte, []int)deprecated
- func (x *StartActionRequest_MongoDBExplainParams) GetDsn() string
- func (x *StartActionRequest_MongoDBExplainParams) GetQuery() string
- func (x *StartActionRequest_MongoDBExplainParams) GetTextFiles() *TextFiles
- func (*StartActionRequest_MongoDBExplainParams) ProtoMessage()
- func (x *StartActionRequest_MongoDBExplainParams) ProtoReflect() protoreflect.Message
- func (x *StartActionRequest_MongoDBExplainParams) Reset()
- func (x *StartActionRequest_MongoDBExplainParams) String() string
- func (this *StartActionRequest_MongoDBExplainParams) Validate() error
- type StartActionRequest_MongoDBQueryBuildInfoParams
- func (*StartActionRequest_MongoDBQueryBuildInfoParams) Descriptor() ([]byte, []int)deprecated
- func (x *StartActionRequest_MongoDBQueryBuildInfoParams) GetDsn() string
- func (x *StartActionRequest_MongoDBQueryBuildInfoParams) GetTextFiles() *TextFiles
- func (*StartActionRequest_MongoDBQueryBuildInfoParams) ProtoMessage()
- func (x *StartActionRequest_MongoDBQueryBuildInfoParams) ProtoReflect() protoreflect.Message
- func (x *StartActionRequest_MongoDBQueryBuildInfoParams) Reset()
- func (x *StartActionRequest_MongoDBQueryBuildInfoParams) String() string
- func (this *StartActionRequest_MongoDBQueryBuildInfoParams) Validate() error
- type StartActionRequest_MongoDBQueryGetCmdLineOptsParams
- func (*StartActionRequest_MongoDBQueryGetCmdLineOptsParams) Descriptor() ([]byte, []int)deprecated
- func (x *StartActionRequest_MongoDBQueryGetCmdLineOptsParams) GetDsn() string
- func (x *StartActionRequest_MongoDBQueryGetCmdLineOptsParams) GetTextFiles() *TextFiles
- func (*StartActionRequest_MongoDBQueryGetCmdLineOptsParams) ProtoMessage()
- func (x *StartActionRequest_MongoDBQueryGetCmdLineOptsParams) ProtoReflect() protoreflect.Message
- func (x *StartActionRequest_MongoDBQueryGetCmdLineOptsParams) Reset()
- func (x *StartActionRequest_MongoDBQueryGetCmdLineOptsParams) String() string
- func (this *StartActionRequest_MongoDBQueryGetCmdLineOptsParams) Validate() error
- type StartActionRequest_MongoDBQueryGetParameterParams
- func (*StartActionRequest_MongoDBQueryGetParameterParams) Descriptor() ([]byte, []int)deprecated
- func (x *StartActionRequest_MongoDBQueryGetParameterParams) GetDsn() string
- func (x *StartActionRequest_MongoDBQueryGetParameterParams) GetTextFiles() *TextFiles
- func (*StartActionRequest_MongoDBQueryGetParameterParams) ProtoMessage()
- func (x *StartActionRequest_MongoDBQueryGetParameterParams) ProtoReflect() protoreflect.Message
- func (x *StartActionRequest_MongoDBQueryGetParameterParams) Reset()
- func (x *StartActionRequest_MongoDBQueryGetParameterParams) String() string
- func (this *StartActionRequest_MongoDBQueryGetParameterParams) Validate() error
- type StartActionRequest_MongodbExplainParams
- type StartActionRequest_MongodbQueryBuildinfoParams
- type StartActionRequest_MongodbQueryGetcmdlineoptsParams
- type StartActionRequest_MongodbQueryGetparameterParams
- type StartActionRequest_MySQLExplainParams
- func (*StartActionRequest_MySQLExplainParams) Descriptor() ([]byte, []int)deprecated
- func (x *StartActionRequest_MySQLExplainParams) GetDsn() string
- func (x *StartActionRequest_MySQLExplainParams) GetOutputFormat() MysqlExplainOutputFormat
- func (x *StartActionRequest_MySQLExplainParams) GetQuery() string
- func (x *StartActionRequest_MySQLExplainParams) GetTlsFiles() *TextFiles
- func (x *StartActionRequest_MySQLExplainParams) GetTlsSkipVerify() bool
- func (*StartActionRequest_MySQLExplainParams) ProtoMessage()
- func (x *StartActionRequest_MySQLExplainParams) ProtoReflect() protoreflect.Message
- func (x *StartActionRequest_MySQLExplainParams) Reset()
- func (x *StartActionRequest_MySQLExplainParams) String() string
- func (this *StartActionRequest_MySQLExplainParams) Validate() error
- type StartActionRequest_MySQLQuerySelectParams
- func (*StartActionRequest_MySQLQuerySelectParams) Descriptor() ([]byte, []int)deprecated
- func (x *StartActionRequest_MySQLQuerySelectParams) GetDsn() string
- func (x *StartActionRequest_MySQLQuerySelectParams) GetQuery() string
- func (x *StartActionRequest_MySQLQuerySelectParams) GetTlsFiles() *TextFiles
- func (x *StartActionRequest_MySQLQuerySelectParams) GetTlsSkipVerify() bool
- func (*StartActionRequest_MySQLQuerySelectParams) ProtoMessage()
- func (x *StartActionRequest_MySQLQuerySelectParams) ProtoReflect() protoreflect.Message
- func (x *StartActionRequest_MySQLQuerySelectParams) Reset()
- func (x *StartActionRequest_MySQLQuerySelectParams) String() string
- func (this *StartActionRequest_MySQLQuerySelectParams) Validate() error
- type StartActionRequest_MySQLQueryShowParams
- func (*StartActionRequest_MySQLQueryShowParams) Descriptor() ([]byte, []int)deprecated
- func (x *StartActionRequest_MySQLQueryShowParams) GetDsn() string
- func (x *StartActionRequest_MySQLQueryShowParams) GetQuery() string
- func (x *StartActionRequest_MySQLQueryShowParams) GetTlsFiles() *TextFiles
- func (x *StartActionRequest_MySQLQueryShowParams) GetTlsSkipVerify() bool
- func (*StartActionRequest_MySQLQueryShowParams) ProtoMessage()
- func (x *StartActionRequest_MySQLQueryShowParams) ProtoReflect() protoreflect.Message
- func (x *StartActionRequest_MySQLQueryShowParams) Reset()
- func (x *StartActionRequest_MySQLQueryShowParams) String() string
- func (this *StartActionRequest_MySQLQueryShowParams) Validate() error
- type StartActionRequest_MySQLShowCreateTableParams
- func (*StartActionRequest_MySQLShowCreateTableParams) Descriptor() ([]byte, []int)deprecated
- func (x *StartActionRequest_MySQLShowCreateTableParams) GetDsn() string
- func (x *StartActionRequest_MySQLShowCreateTableParams) GetTable() string
- func (x *StartActionRequest_MySQLShowCreateTableParams) GetTlsFiles() *TextFiles
- func (x *StartActionRequest_MySQLShowCreateTableParams) GetTlsSkipVerify() bool
- func (*StartActionRequest_MySQLShowCreateTableParams) ProtoMessage()
- func (x *StartActionRequest_MySQLShowCreateTableParams) ProtoReflect() protoreflect.Message
- func (x *StartActionRequest_MySQLShowCreateTableParams) Reset()
- func (x *StartActionRequest_MySQLShowCreateTableParams) String() string
- func (this *StartActionRequest_MySQLShowCreateTableParams) Validate() error
- type StartActionRequest_MySQLShowIndexParams
- func (*StartActionRequest_MySQLShowIndexParams) Descriptor() ([]byte, []int)deprecated
- func (x *StartActionRequest_MySQLShowIndexParams) GetDsn() string
- func (x *StartActionRequest_MySQLShowIndexParams) GetTable() string
- func (x *StartActionRequest_MySQLShowIndexParams) GetTlsFiles() *TextFiles
- func (x *StartActionRequest_MySQLShowIndexParams) GetTlsSkipVerify() bool
- func (*StartActionRequest_MySQLShowIndexParams) ProtoMessage()
- func (x *StartActionRequest_MySQLShowIndexParams) ProtoReflect() protoreflect.Message
- func (x *StartActionRequest_MySQLShowIndexParams) Reset()
- func (x *StartActionRequest_MySQLShowIndexParams) String() string
- func (this *StartActionRequest_MySQLShowIndexParams) Validate() error
- type StartActionRequest_MySQLShowTableStatusParams
- func (*StartActionRequest_MySQLShowTableStatusParams) Descriptor() ([]byte, []int)deprecated
- func (x *StartActionRequest_MySQLShowTableStatusParams) GetDsn() string
- func (x *StartActionRequest_MySQLShowTableStatusParams) GetTable() string
- func (x *StartActionRequest_MySQLShowTableStatusParams) GetTlsFiles() *TextFiles
- func (x *StartActionRequest_MySQLShowTableStatusParams) GetTlsSkipVerify() bool
- func (*StartActionRequest_MySQLShowTableStatusParams) ProtoMessage()
- func (x *StartActionRequest_MySQLShowTableStatusParams) ProtoReflect() protoreflect.Message
- func (x *StartActionRequest_MySQLShowTableStatusParams) Reset()
- func (x *StartActionRequest_MySQLShowTableStatusParams) String() string
- func (this *StartActionRequest_MySQLShowTableStatusParams) Validate() error
- type StartActionRequest_MysqlExplainParams
- type StartActionRequest_MysqlQuerySelectParams
- type StartActionRequest_MysqlQueryShowParams
- type StartActionRequest_MysqlShowCreateTableParams
- type StartActionRequest_MysqlShowIndexParams
- type StartActionRequest_MysqlShowTableStatusParams
- type StartActionRequest_PTMongoDBSummaryParams
- func (*StartActionRequest_PTMongoDBSummaryParams) Descriptor() ([]byte, []int)deprecated
- func (x *StartActionRequest_PTMongoDBSummaryParams) GetHost() string
- func (x *StartActionRequest_PTMongoDBSummaryParams) GetPassword() string
- func (x *StartActionRequest_PTMongoDBSummaryParams) GetPort() uint32
- func (x *StartActionRequest_PTMongoDBSummaryParams) GetUsername() string
- func (*StartActionRequest_PTMongoDBSummaryParams) ProtoMessage()
- func (x *StartActionRequest_PTMongoDBSummaryParams) ProtoReflect() protoreflect.Message
- func (x *StartActionRequest_PTMongoDBSummaryParams) Reset()
- func (x *StartActionRequest_PTMongoDBSummaryParams) String() string
- func (this *StartActionRequest_PTMongoDBSummaryParams) Validate() error
- type StartActionRequest_PTMySQLSummaryParams
- func (*StartActionRequest_PTMySQLSummaryParams) Descriptor() ([]byte, []int)deprecated
- func (x *StartActionRequest_PTMySQLSummaryParams) GetHost() string
- func (x *StartActionRequest_PTMySQLSummaryParams) GetPassword() string
- func (x *StartActionRequest_PTMySQLSummaryParams) GetPort() uint32
- func (x *StartActionRequest_PTMySQLSummaryParams) GetSocket() string
- func (x *StartActionRequest_PTMySQLSummaryParams) GetUsername() string
- func (*StartActionRequest_PTMySQLSummaryParams) ProtoMessage()
- func (x *StartActionRequest_PTMySQLSummaryParams) ProtoReflect() protoreflect.Message
- func (x *StartActionRequest_PTMySQLSummaryParams) Reset()
- func (x *StartActionRequest_PTMySQLSummaryParams) String() string
- func (this *StartActionRequest_PTMySQLSummaryParams) Validate() error
- type StartActionRequest_PTPgSummaryParams
- func (*StartActionRequest_PTPgSummaryParams) Descriptor() ([]byte, []int)deprecated
- func (x *StartActionRequest_PTPgSummaryParams) GetHost() string
- func (x *StartActionRequest_PTPgSummaryParams) GetPassword() string
- func (x *StartActionRequest_PTPgSummaryParams) GetPort() uint32
- func (x *StartActionRequest_PTPgSummaryParams) GetUsername() string
- func (*StartActionRequest_PTPgSummaryParams) ProtoMessage()
- func (x *StartActionRequest_PTPgSummaryParams) ProtoReflect() protoreflect.Message
- func (x *StartActionRequest_PTPgSummaryParams) Reset()
- func (x *StartActionRequest_PTPgSummaryParams) String() string
- func (this *StartActionRequest_PTPgSummaryParams) Validate() error
- type StartActionRequest_PTSummaryParams
- func (*StartActionRequest_PTSummaryParams) Descriptor() ([]byte, []int)deprecated
- func (*StartActionRequest_PTSummaryParams) ProtoMessage()
- func (x *StartActionRequest_PTSummaryParams) ProtoReflect() protoreflect.Message
- func (x *StartActionRequest_PTSummaryParams) Reset()
- func (x *StartActionRequest_PTSummaryParams) String() string
- func (this *StartActionRequest_PTSummaryParams) Validate() error
- type StartActionRequest_PostgreSQLQuerySelectParams
- func (*StartActionRequest_PostgreSQLQuerySelectParams) Descriptor() ([]byte, []int)deprecated
- func (x *StartActionRequest_PostgreSQLQuerySelectParams) GetDsn() string
- func (x *StartActionRequest_PostgreSQLQuerySelectParams) GetQuery() string
- func (*StartActionRequest_PostgreSQLQuerySelectParams) ProtoMessage()
- func (x *StartActionRequest_PostgreSQLQuerySelectParams) ProtoReflect() protoreflect.Message
- func (x *StartActionRequest_PostgreSQLQuerySelectParams) Reset()
- func (x *StartActionRequest_PostgreSQLQuerySelectParams) String() string
- func (this *StartActionRequest_PostgreSQLQuerySelectParams) Validate() error
- type StartActionRequest_PostgreSQLQueryShowParams
- func (*StartActionRequest_PostgreSQLQueryShowParams) Descriptor() ([]byte, []int)deprecated
- func (x *StartActionRequest_PostgreSQLQueryShowParams) GetDsn() string
- func (*StartActionRequest_PostgreSQLQueryShowParams) ProtoMessage()
- func (x *StartActionRequest_PostgreSQLQueryShowParams) ProtoReflect() protoreflect.Message
- func (x *StartActionRequest_PostgreSQLQueryShowParams) Reset()
- func (x *StartActionRequest_PostgreSQLQueryShowParams) String() string
- func (this *StartActionRequest_PostgreSQLQueryShowParams) Validate() error
- type StartActionRequest_PostgreSQLShowCreateTableParams
- func (*StartActionRequest_PostgreSQLShowCreateTableParams) Descriptor() ([]byte, []int)deprecated
- func (x *StartActionRequest_PostgreSQLShowCreateTableParams) GetDsn() string
- func (x *StartActionRequest_PostgreSQLShowCreateTableParams) GetTable() string
- func (*StartActionRequest_PostgreSQLShowCreateTableParams) ProtoMessage()
- func (x *StartActionRequest_PostgreSQLShowCreateTableParams) ProtoReflect() protoreflect.Message
- func (x *StartActionRequest_PostgreSQLShowCreateTableParams) Reset()
- func (x *StartActionRequest_PostgreSQLShowCreateTableParams) String() string
- func (this *StartActionRequest_PostgreSQLShowCreateTableParams) Validate() error
- type StartActionRequest_PostgreSQLShowIndexParams
- func (*StartActionRequest_PostgreSQLShowIndexParams) Descriptor() ([]byte, []int)deprecated
- func (x *StartActionRequest_PostgreSQLShowIndexParams) GetDsn() string
- func (x *StartActionRequest_PostgreSQLShowIndexParams) GetTable() string
- func (*StartActionRequest_PostgreSQLShowIndexParams) ProtoMessage()
- func (x *StartActionRequest_PostgreSQLShowIndexParams) ProtoReflect() protoreflect.Message
- func (x *StartActionRequest_PostgreSQLShowIndexParams) Reset()
- func (x *StartActionRequest_PostgreSQLShowIndexParams) String() string
- func (this *StartActionRequest_PostgreSQLShowIndexParams) Validate() error
- type StartActionRequest_PostgresqlQuerySelectParams
- type StartActionRequest_PostgresqlQueryShowParams
- type StartActionRequest_PostgresqlShowCreateTableParams
- type StartActionRequest_PostgresqlShowIndexParams
- type StartActionRequest_PtMongodbSummaryParams
- type StartActionRequest_PtMysqlSummaryParams
- type StartActionRequest_PtPgSummaryParams
- type StartActionRequest_PtSummaryParams
- type StartActionResponse
- func (m *StartActionResponse) AgentMessageResponsePayload() isAgentMessage_Payload
- func (*StartActionResponse) Descriptor() ([]byte, []int)deprecated
- func (*StartActionResponse) ProtoMessage()
- func (x *StartActionResponse) ProtoReflect() protoreflect.Message
- func (x *StartActionResponse) Reset()
- func (x *StartActionResponse) String() string
- func (this *StartActionResponse) Validate() error
- type StartJobRequest
- func (*StartJobRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StartJobRequest) GetEcho() *StartJobRequest_Echo
- func (m *StartJobRequest) GetJob() isStartJobRequest_Job
- func (x *StartJobRequest) GetJobId() string
- func (x *StartJobRequest) GetMysqlBackup() *StartJobRequest_MySQLBackup
- func (x *StartJobRequest) GetMysqlRestoreBackup() *StartJobRequest_MySQLRestoreBackup
- func (x *StartJobRequest) GetTimeout() *duration.Duration
- func (*StartJobRequest) ProtoMessage()
- func (x *StartJobRequest) ProtoReflect() protoreflect.Message
- func (x *StartJobRequest) Reset()
- func (m *StartJobRequest) ServerMessageRequestPayload() isServerMessage_Payload
- func (x *StartJobRequest) String() string
- func (this *StartJobRequest) Validate() error
- type StartJobRequest_Echo
- func (*StartJobRequest_Echo) Descriptor() ([]byte, []int)deprecated
- func (x *StartJobRequest_Echo) GetDelay() *duration.Duration
- func (x *StartJobRequest_Echo) GetMessage() string
- func (*StartJobRequest_Echo) ProtoMessage()
- func (x *StartJobRequest_Echo) ProtoReflect() protoreflect.Message
- func (x *StartJobRequest_Echo) Reset()
- func (x *StartJobRequest_Echo) String() string
- func (this *StartJobRequest_Echo) Validate() error
- type StartJobRequest_Echo_
- type StartJobRequest_MySQLBackup
- func (*StartJobRequest_MySQLBackup) Descriptor() ([]byte, []int)deprecated
- func (x *StartJobRequest_MySQLBackup) GetAddress() string
- func (m *StartJobRequest_MySQLBackup) GetLocationConfig() isStartJobRequest_MySQLBackup_LocationConfig
- func (x *StartJobRequest_MySQLBackup) GetName() string
- func (x *StartJobRequest_MySQLBackup) GetPassword() string
- func (x *StartJobRequest_MySQLBackup) GetPort() int32
- func (x *StartJobRequest_MySQLBackup) GetS3Config() *S3LocationConfig
- func (x *StartJobRequest_MySQLBackup) GetSocket() string
- func (x *StartJobRequest_MySQLBackup) GetUser() string
- func (*StartJobRequest_MySQLBackup) ProtoMessage()
- func (x *StartJobRequest_MySQLBackup) ProtoReflect() protoreflect.Message
- func (x *StartJobRequest_MySQLBackup) Reset()
- func (x *StartJobRequest_MySQLBackup) String() string
- func (this *StartJobRequest_MySQLBackup) Validate() error
- type StartJobRequest_MySQLBackup_S3Config
- type StartJobRequest_MySQLRestoreBackup
- func (*StartJobRequest_MySQLRestoreBackup) Descriptor() ([]byte, []int)deprecated
- func (m *StartJobRequest_MySQLRestoreBackup) GetLocationConfig() isStartJobRequest_MySQLRestoreBackup_LocationConfig
- func (x *StartJobRequest_MySQLRestoreBackup) GetName() string
- func (x *StartJobRequest_MySQLRestoreBackup) GetS3Config() *S3LocationConfig
- func (x *StartJobRequest_MySQLRestoreBackup) GetServiceId() string
- func (*StartJobRequest_MySQLRestoreBackup) ProtoMessage()
- func (x *StartJobRequest_MySQLRestoreBackup) ProtoReflect() protoreflect.Message
- func (x *StartJobRequest_MySQLRestoreBackup) Reset()
- func (x *StartJobRequest_MySQLRestoreBackup) String() string
- func (this *StartJobRequest_MySQLRestoreBackup) Validate() error
- type StartJobRequest_MySQLRestoreBackup_S3Config
- type StartJobRequest_MysqlBackup
- type StartJobRequest_MysqlRestoreBackup
- type StartJobResponse
- func (m *StartJobResponse) AgentMessageResponsePayload() isAgentMessage_Payload
- func (*StartJobResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StartJobResponse) GetError() string
- func (*StartJobResponse) ProtoMessage()
- func (x *StartJobResponse) ProtoReflect() protoreflect.Message
- func (x *StartJobResponse) Reset()
- func (x *StartJobResponse) String() string
- func (this *StartJobResponse) Validate() error
- type StateChangedRequest
- func (m *StateChangedRequest) AgentMessageRequestPayload() isAgentMessage_Payload
- func (*StateChangedRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StateChangedRequest) GetAgentId() string
- func (x *StateChangedRequest) GetListenPort() uint32
- func (x *StateChangedRequest) GetStatus() inventorypb.AgentStatus
- func (*StateChangedRequest) ProtoMessage()
- func (x *StateChangedRequest) ProtoReflect() protoreflect.Message
- func (x *StateChangedRequest) Reset()
- func (x *StateChangedRequest) String() string
- func (this *StateChangedRequest) Validate() error
- type StateChangedResponse
- func (*StateChangedResponse) Descriptor() ([]byte, []int)deprecated
- func (*StateChangedResponse) ProtoMessage()
- func (x *StateChangedResponse) ProtoReflect() protoreflect.Message
- func (x *StateChangedResponse) Reset()
- func (m *StateChangedResponse) ServerMessageResponsePayload() isServerMessage_Payload
- func (x *StateChangedResponse) String() string
- func (this *StateChangedResponse) Validate() error
- type StopActionRequest
- func (*StopActionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StopActionRequest) GetActionId() string
- func (*StopActionRequest) ProtoMessage()
- func (x *StopActionRequest) ProtoReflect() protoreflect.Message
- func (x *StopActionRequest) Reset()
- func (m *StopActionRequest) ServerMessageRequestPayload() isServerMessage_Payload
- func (x *StopActionRequest) String() string
- func (this *StopActionRequest) Validate() error
- type StopActionResponse
- func (m *StopActionResponse) AgentMessageResponsePayload() isAgentMessage_Payload
- func (*StopActionResponse) Descriptor() ([]byte, []int)deprecated
- func (*StopActionResponse) ProtoMessage()
- func (x *StopActionResponse) ProtoReflect() protoreflect.Message
- func (x *StopActionResponse) Reset()
- func (x *StopActionResponse) String() string
- func (this *StopActionResponse) Validate() error
- type StopJobRequest
- func (*StopJobRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StopJobRequest) GetJobId() string
- func (*StopJobRequest) ProtoMessage()
- func (x *StopJobRequest) ProtoReflect() protoreflect.Message
- func (x *StopJobRequest) Reset()
- func (m *StopJobRequest) ServerMessageRequestPayload() isServerMessage_Payload
- func (x *StopJobRequest) String() string
- func (this *StopJobRequest) Validate() error
- type StopJobResponse
- func (m *StopJobResponse) AgentMessageResponsePayload() isAgentMessage_Payload
- func (*StopJobResponse) Descriptor() ([]byte, []int)deprecated
- func (*StopJobResponse) ProtoMessage()
- func (x *StopJobResponse) ProtoReflect() protoreflect.Message
- func (x *StopJobResponse) Reset()
- func (x *StopJobResponse) String() string
- func (this *StopJobResponse) Validate() error
- type TextFiles
- func (*TextFiles) Descriptor() ([]byte, []int)deprecated
- func (x *TextFiles) GetFiles() map[string]string
- func (x *TextFiles) GetTemplateLeftDelim() string
- func (x *TextFiles) GetTemplateRightDelim() string
- func (*TextFiles) ProtoMessage()
- func (x *TextFiles) ProtoReflect() protoreflect.Message
- func (x *TextFiles) Reset()
- func (x *TextFiles) String() string
- func (this *TextFiles) Validate() error
- type UnimplementedAgentServer
Constants ¶
This section is empty.
Variables ¶
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.
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.
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.
var File_agentpb_agent_proto protoreflect.FileDescriptor
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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) GetEcho ¶
func (x *JobResult) GetEcho() *JobResult_Echo
func (*JobResult) GetError ¶
func (x *JobResult) GetError() *JobResult_Error
func (*JobResult) GetMysqlBackup ¶
func (x *JobResult) GetMysqlBackup() *JobResult_MySQLBackup
func (*JobResult) GetMysqlRestoreBackup ¶
func (x *JobResult) GetMysqlRestoreBackup() *JobResult_MySQLRestoreBackup
func (*JobResult) GetTimestamp ¶
func (*JobResult) ProtoMessage ¶
func (*JobResult) ProtoMessage()
func (*JobResult) ProtoReflect ¶
func (x *JobResult) ProtoReflect() protoreflect.Message
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"`
// Total number of shared block cache hits by the statement.
// Total number of shared blocks read by the statement.
// Total number of shared blocks dirtied by the statement.
// Total number of shared blocks written by the statement.
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) ProtoMessage ¶
func (*Ping) ProtoMessage()
func (*Ping) ProtoReflect ¶
func (x *Ping) ProtoReflect() protoreflect.Message
func (*Ping) ServerMessageRequestPayload ¶
func (m *Ping) ServerMessageRequestPayload() isServerMessage_Payload
ServerMessage request payloads
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) GetCurrentTime ¶
func (*Pong) ProtoMessage ¶
func (*Pong) ProtoMessage()
func (*Pong) ProtoReflect ¶
func (x *Pong) ProtoReflect() protoreflect.Message
func (*Pong) ServerMessageResponsePayload ¶
func (m *Pong) ServerMessageResponsePayload() isServerMessage_Payload
ServerMessage response payloads
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_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 ¶
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) GetTemplateLeftDelim ¶
func (*TextFiles) GetTemplateRightDelim ¶
func (*TextFiles) ProtoMessage ¶
func (*TextFiles) ProtoMessage()
func (*TextFiles) ProtoReflect ¶
func (x *TextFiles) ProtoReflect() protoreflect.Message
type UnimplementedAgentServer ¶
type UnimplementedAgentServer struct {
}
UnimplementedAgentServer can be embedded to have forward compatible implementations.
func (*UnimplementedAgentServer) Connect ¶
func (*UnimplementedAgentServer) Connect(Agent_ConnectServer) error