agentpb

package
v2.0.0-beta7+incompatible Latest Latest
Warning

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

Go to latest
Published: Sep 9, 2019 License: AGPL-3.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ExampleFormat_name = map[int32]string{
	0: "EXAMPLE_FORMAT_INVALID",
	1: "EXAMPLE",
	2: "FINGERPRINT",
}
View Source
var ExampleFormat_value = map[string]int32{
	"EXAMPLE_FORMAT_INVALID": 0,
	"EXAMPLE":                1,
	"FINGERPRINT":            2,
}
View Source
var ExampleType_name = map[int32]string{
	0: "EXAMPLE_TYPE_INVALID",
	1: "RANDOM",
	2: "SLOWEST",
	3: "FASTEST",
	4: "WITH_ERROR",
}
View Source
var ExampleType_value = map[string]int32{
	"EXAMPLE_TYPE_INVALID": 0,
	"RANDOM":               1,
	"SLOWEST":              2,
	"FASTEST":              3,
	"WITH_ERROR":           4,
}
View Source
var MysqlExplainOutputFormat_name = map[int32]string{
	0: "MYSQL_EXPLAIN_OUTPUT_FORMAT_INVALID",
	1: "MYSQL_EXPLAIN_OUTPUT_FORMAT_DEFAULT",
	2: "MYSQL_EXPLAIN_OUTPUT_FORMAT_JSON",
	3: "MYSQL_EXPLAIN_OUTPUT_FORMAT_TRADITIONAL_JSON",
}
View Source
var 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,
}
View Source
var Type_name = map[int32]string{
	0:  "TYPE_INVALID",
	1:  "PMM_AGENT",
	2:  "NODE_EXPORTER",
	3:  "MYSQLD_EXPORTER",
	4:  "MONGODB_EXPORTER",
	5:  "POSTGRES_EXPORTER",
	10: "PROXYSQL_EXPORTER",
	9:  "RDS_EXPORTER",
	6:  "QAN_MYSQL_PERFSCHEMA_AGENT",
	7:  "QAN_MYSQL_SLOWLOG_AGENT",
	8:  "QAN_MONGODB_PROFILER_AGENT",
	11: "QAN_POSTGRESQL_PGSTATEMENTS_AGENT",
}
View Source
var Type_value = map[string]int32{
	"TYPE_INVALID":                      0,
	"PMM_AGENT":                         1,
	"NODE_EXPORTER":                     2,
	"MYSQLD_EXPORTER":                   3,
	"MONGODB_EXPORTER":                  4,
	"POSTGRES_EXPORTER":                 5,
	"PROXYSQL_EXPORTER":                 10,
	"RDS_EXPORTER":                      9,
	"QAN_MYSQL_PERFSCHEMA_AGENT":        6,
	"QAN_MYSQL_SLOWLOG_AGENT":           7,
	"QAN_MONGODB_PROFILER_AGENT":        8,
	"QAN_POSTGRESQL_PGSTATEMENTS_AGENT": 11,
}

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 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.

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

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

func (*ActionResultRequest) GetActionId

func (m *ActionResultRequest) GetActionId() string

func (*ActionResultRequest) GetDone

func (m *ActionResultRequest) GetDone() bool

func (*ActionResultRequest) GetError

func (m *ActionResultRequest) GetError() string

func (*ActionResultRequest) GetOutput

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

func (*ActionResultRequest) ProtoMessage

func (*ActionResultRequest) ProtoMessage()

func (*ActionResultRequest) Reset

func (m *ActionResultRequest) Reset()

func (*ActionResultRequest) String

func (m *ActionResultRequest) String() string

func (*ActionResultRequest) Validate

func (this *ActionResultRequest) Validate() error

func (*ActionResultRequest) XXX_DiscardUnknown

func (m *ActionResultRequest) XXX_DiscardUnknown()

func (*ActionResultRequest) XXX_Marshal

func (m *ActionResultRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ActionResultRequest) XXX_Merge

func (m *ActionResultRequest) XXX_Merge(src proto.Message)

func (*ActionResultRequest) XXX_Size

func (m *ActionResultRequest) XXX_Size() int

func (*ActionResultRequest) XXX_Unmarshal

func (m *ActionResultRequest) XXX_Unmarshal(b []byte) error

type ActionResultResponse

type ActionResultResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ActionResultResponse is an ServerMessage for ActionResultRequest acceptance.

func (*ActionResultResponse) Descriptor

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

func (*ActionResultResponse) ProtoMessage

func (*ActionResultResponse) ProtoMessage()

func (*ActionResultResponse) Reset

func (m *ActionResultResponse) Reset()

func (*ActionResultResponse) ServerMessageResponsePayload

func (m *ActionResultResponse) ServerMessageResponsePayload() isServerMessage_Payload

func (*ActionResultResponse) String

func (m *ActionResultResponse) String() string

func (*ActionResultResponse) Validate

func (this *ActionResultResponse) Validate() error

func (*ActionResultResponse) XXX_DiscardUnknown

func (m *ActionResultResponse) XXX_DiscardUnknown()

func (*ActionResultResponse) XXX_Marshal

func (m *ActionResultResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ActionResultResponse) XXX_Merge

func (m *ActionResultResponse) XXX_Merge(src proto.Message)

func (*ActionResultResponse) XXX_Size

func (m *ActionResultResponse) XXX_Size() int

func (*ActionResultResponse) XXX_Unmarshal

func (m *ActionResultResponse) XXX_Unmarshal(b []byte) 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.ClientConn) AgentClient

type AgentConnectMetadata

type AgentConnectMetadata struct {
	ID          string
	Version     string
	MetricsPort uint16
}

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

func ReceiveAgentConnectMetadata

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

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

type AgentMessage

type AgentMessage struct {
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are valid to be assigned to Payload:
	//	*AgentMessage_Ping
	//	*AgentMessage_StateChanged
	//	*AgentMessage_QanCollect
	//	*AgentMessage_ActionResult
	//	*AgentMessage_Pong
	//	*AgentMessage_SetState
	//	*AgentMessage_StartAction
	//	*AgentMessage_StopAction
	//	*AgentMessage_CheckConnection
	Payload              isAgentMessage_Payload `protobuf_oneof:"payload"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*AgentMessage) Descriptor

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

func (*AgentMessage) GetActionResult

func (m *AgentMessage) GetActionResult() *ActionResultRequest

func (*AgentMessage) GetCheckConnection

func (m *AgentMessage) GetCheckConnection() *CheckConnectionResponse

func (*AgentMessage) GetId

func (m *AgentMessage) GetId() uint32

func (*AgentMessage) GetPayload

func (m *AgentMessage) GetPayload() isAgentMessage_Payload

func (*AgentMessage) GetPing

func (m *AgentMessage) GetPing() *Ping

func (*AgentMessage) GetPong

func (m *AgentMessage) GetPong() *Pong

func (*AgentMessage) GetQanCollect

func (m *AgentMessage) GetQanCollect() *QANCollectRequest

func (*AgentMessage) GetSetState

func (m *AgentMessage) GetSetState() *SetStateResponse

func (*AgentMessage) GetStartAction

func (m *AgentMessage) GetStartAction() *StartActionResponse

func (*AgentMessage) GetStateChanged

func (m *AgentMessage) GetStateChanged() *StateChangedRequest

func (*AgentMessage) GetStopAction

func (m *AgentMessage) GetStopAction() *StopActionResponse

func (*AgentMessage) ProtoMessage

func (*AgentMessage) ProtoMessage()

func (*AgentMessage) Reset

func (m *AgentMessage) Reset()

func (*AgentMessage) String

func (m *AgentMessage) String() string

func (*AgentMessage) Validate

func (this *AgentMessage) Validate() error

func (*AgentMessage) XXX_DiscardUnknown

func (m *AgentMessage) XXX_DiscardUnknown()

func (*AgentMessage) XXX_Marshal

func (m *AgentMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AgentMessage) XXX_Merge

func (m *AgentMessage) XXX_Merge(src proto.Message)

func (*AgentMessage) XXX_OneofWrappers

func (*AgentMessage) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*AgentMessage) XXX_Size

func (m *AgentMessage) XXX_Size() int

func (*AgentMessage) XXX_Unmarshal

func (m *AgentMessage) XXX_Unmarshal(b []byte) 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_Ping

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

type AgentMessage_Pong

type AgentMessage_Pong struct {
	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_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 AgentParams

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

AgentParams is a common interface for AgentProcess and BuiltinAgent parameters.

type AgentRequestPayload

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

AgentRequestPayload represents agent's request payload.

type AgentResponsePayload

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

AgentResponsePayload represents agent's response payload.

type AgentServer

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

AgentServer is the server API for Agent service.

type Agent_ConnectClient

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

type Agent_ConnectServer

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

type CheckConnectionRequest

type CheckConnectionRequest struct {
	// Service type.
	Type inventorypb.ServiceType `protobuf:"varint,1,opt,name=type,proto3,enum=inventory.ServiceType" json:"type,omitempty"`
	// DSN for the service. May contain connection (dial) timeout.
	Dsn string `protobuf:"bytes,2,opt,name=dsn,proto3" json:"dsn,omitempty"`
	// Timeout for the whole request. Default is 3 seconds.
	Timeout              *duration.Duration `protobuf:"bytes,3,opt,name=timeout,proto3" json:"timeout,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

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

func (*CheckConnectionRequest) Descriptor

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

func (*CheckConnectionRequest) GetDsn

func (m *CheckConnectionRequest) GetDsn() string

func (*CheckConnectionRequest) GetTimeout

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

func (*CheckConnectionRequest) GetType

func (*CheckConnectionRequest) ProtoMessage

func (*CheckConnectionRequest) ProtoMessage()

func (*CheckConnectionRequest) Reset

func (m *CheckConnectionRequest) Reset()

func (*CheckConnectionRequest) ServerMessageRequestPayload

func (m *CheckConnectionRequest) ServerMessageRequestPayload() isServerMessage_Payload

func (*CheckConnectionRequest) String

func (m *CheckConnectionRequest) String() string

func (*CheckConnectionRequest) Validate

func (this *CheckConnectionRequest) Validate() error

func (*CheckConnectionRequest) XXX_DiscardUnknown

func (m *CheckConnectionRequest) XXX_DiscardUnknown()

func (*CheckConnectionRequest) XXX_Marshal

func (m *CheckConnectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckConnectionRequest) XXX_Merge

func (m *CheckConnectionRequest) XXX_Merge(src proto.Message)

func (*CheckConnectionRequest) XXX_Size

func (m *CheckConnectionRequest) XXX_Size() int

func (*CheckConnectionRequest) XXX_Unmarshal

func (m *CheckConnectionRequest) XXX_Unmarshal(b []byte) error

type CheckConnectionResponse

type CheckConnectionResponse struct {
	// Error message if connection check failed.
	Error                string   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CheckConnectionResponse is an AgentMessage containing a result of connection check.

func (*CheckConnectionResponse) AgentMessageResponsePayload

func (m *CheckConnectionResponse) AgentMessageResponsePayload() isAgentMessage_Payload

func (*CheckConnectionResponse) Descriptor

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

func (*CheckConnectionResponse) GetError

func (m *CheckConnectionResponse) GetError() string

func (*CheckConnectionResponse) ProtoMessage

func (*CheckConnectionResponse) ProtoMessage()

func (*CheckConnectionResponse) Reset

func (m *CheckConnectionResponse) Reset()

func (*CheckConnectionResponse) String

func (m *CheckConnectionResponse) String() string

func (*CheckConnectionResponse) Validate

func (this *CheckConnectionResponse) Validate() error

func (*CheckConnectionResponse) XXX_DiscardUnknown

func (m *CheckConnectionResponse) XXX_DiscardUnknown()

func (*CheckConnectionResponse) XXX_Marshal

func (m *CheckConnectionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckConnectionResponse) XXX_Merge

func (m *CheckConnectionResponse) XXX_Merge(src proto.Message)

func (*CheckConnectionResponse) XXX_Size

func (m *CheckConnectionResponse) XXX_Size() int

func (*CheckConnectionResponse) XXX_Unmarshal

func (m *CheckConnectionResponse) XXX_Unmarshal(b []byte) error

type ExampleFormat

type ExampleFormat int32

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

const (
	ExampleFormat_EXAMPLE_FORMAT_INVALID ExampleFormat = 0
	ExampleFormat_EXAMPLE                ExampleFormat = 1
	ExampleFormat_FINGERPRINT            ExampleFormat = 2
)

func (ExampleFormat) EnumDescriptor

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

func (ExampleFormat) String

func (x ExampleFormat) String() string

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) EnumDescriptor

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

func (ExampleType) String

func (x ExampleType) String() string

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"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

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

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

func (*MetricsBucket) GetCommon

func (m *MetricsBucket) GetCommon() *MetricsBucket_Common

func (*MetricsBucket) GetMongodb

func (m *MetricsBucket) GetMongodb() *MetricsBucket_MongoDB

func (*MetricsBucket) GetMysql

func (m *MetricsBucket) GetMysql() *MetricsBucket_MySQL

func (*MetricsBucket) GetPostgresql

func (m *MetricsBucket) GetPostgresql() *MetricsBucket_PostgreSQL

func (*MetricsBucket) ProtoMessage

func (*MetricsBucket) ProtoMessage()

func (*MetricsBucket) Reset

func (m *MetricsBucket) Reset()

func (*MetricsBucket) String

func (m *MetricsBucket) String() string

func (*MetricsBucket) Validate

func (this *MetricsBucket) Validate() error

func (*MetricsBucket) XXX_DiscardUnknown

func (m *MetricsBucket) XXX_DiscardUnknown()

func (*MetricsBucket) XXX_Marshal

func (m *MetricsBucket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetricsBucket) XXX_Merge

func (m *MetricsBucket) XXX_Merge(src proto.Message)

func (*MetricsBucket) XXX_Size

func (m *MetricsBucket) XXX_Size() int

func (*MetricsBucket) XXX_Unmarshal

func (m *MetricsBucket) XXX_Unmarshal(b []byte) 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"`
	ExampleFormat ExampleFormat `` /* 127-byte string literal not displayed */
	ExampleType   ExampleType   `protobuf:"varint,15,opt,name=example_type,json=exampleType,proto3,enum=agent.ExampleType" json:"example_type,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,21,opt,name=num_queries,json=numQueries,proto3" json:"num_queries,omitempty"`
	// How many times query_time was found.
	MQueryTimeCnt float32 `protobuf:"fixed32,22,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,23,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,24,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,25,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,26,opt,name=m_query_time_p99,json=mQueryTimeP99,proto3" json:"m_query_time_p99,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Common contains common fields for all DBs.

func (*MetricsBucket_Common) Descriptor

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

func (*MetricsBucket_Common) GetAgentId

func (m *MetricsBucket_Common) GetAgentId() string

func (*MetricsBucket_Common) GetAgentType

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

func (*MetricsBucket_Common) GetClientHost

func (m *MetricsBucket_Common) GetClientHost() string

func (*MetricsBucket_Common) GetDatabase

func (m *MetricsBucket_Common) GetDatabase() string

func (*MetricsBucket_Common) GetErrors

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

func (*MetricsBucket_Common) GetExample

func (m *MetricsBucket_Common) GetExample() string

func (*MetricsBucket_Common) GetExampleFormat

func (m *MetricsBucket_Common) GetExampleFormat() ExampleFormat

func (*MetricsBucket_Common) GetExampleType

func (m *MetricsBucket_Common) GetExampleType() ExampleType

func (*MetricsBucket_Common) GetFingerprint

func (m *MetricsBucket_Common) GetFingerprint() string

func (*MetricsBucket_Common) GetMQueryTimeCnt

func (m *MetricsBucket_Common) GetMQueryTimeCnt() float32

func (*MetricsBucket_Common) GetMQueryTimeMax

func (m *MetricsBucket_Common) GetMQueryTimeMax() float32

func (*MetricsBucket_Common) GetMQueryTimeMin

func (m *MetricsBucket_Common) GetMQueryTimeMin() float32

func (*MetricsBucket_Common) GetMQueryTimeP99

func (m *MetricsBucket_Common) GetMQueryTimeP99() float32

func (*MetricsBucket_Common) GetMQueryTimeSum

func (m *MetricsBucket_Common) GetMQueryTimeSum() float32

func (*MetricsBucket_Common) GetNumQueries

func (m *MetricsBucket_Common) GetNumQueries() float32

func (*MetricsBucket_Common) GetNumQueriesWithErrors

func (m *MetricsBucket_Common) GetNumQueriesWithErrors() float32

func (*MetricsBucket_Common) GetNumQueriesWithWarnings

func (m *MetricsBucket_Common) GetNumQueriesWithWarnings() float32

func (*MetricsBucket_Common) GetPeriodLengthSecs

func (m *MetricsBucket_Common) GetPeriodLengthSecs() uint32

func (*MetricsBucket_Common) GetPeriodStartUnixSecs

func (m *MetricsBucket_Common) GetPeriodStartUnixSecs() uint32

func (*MetricsBucket_Common) GetQueryid

func (m *MetricsBucket_Common) GetQueryid() string

func (*MetricsBucket_Common) GetSchema

func (m *MetricsBucket_Common) GetSchema() string

func (*MetricsBucket_Common) GetTables

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

func (*MetricsBucket_Common) GetUsername

func (m *MetricsBucket_Common) GetUsername() string

func (*MetricsBucket_Common) ProtoMessage

func (*MetricsBucket_Common) ProtoMessage()

func (*MetricsBucket_Common) Reset

func (m *MetricsBucket_Common) Reset()

func (*MetricsBucket_Common) String

func (m *MetricsBucket_Common) String() string

func (*MetricsBucket_Common) Validate

func (this *MetricsBucket_Common) Validate() error

func (*MetricsBucket_Common) XXX_DiscardUnknown

func (m *MetricsBucket_Common) XXX_DiscardUnknown()

func (*MetricsBucket_Common) XXX_Marshal

func (m *MetricsBucket_Common) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetricsBucket_Common) XXX_Merge

func (m *MetricsBucket_Common) XXX_Merge(src proto.Message)

func (*MetricsBucket_Common) XXX_Size

func (m *MetricsBucket_Common) XXX_Size() int

func (*MetricsBucket_Common) XXX_Unmarshal

func (m *MetricsBucket_Common) XXX_Unmarshal(b []byte) 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

MongoDB contains metrics for Mongo DB.

func (*MetricsBucket_MongoDB) Descriptor

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

func (*MetricsBucket_MongoDB) GetMDocsReturnedCnt

func (m *MetricsBucket_MongoDB) GetMDocsReturnedCnt() float32

func (*MetricsBucket_MongoDB) GetMDocsReturnedMax

func (m *MetricsBucket_MongoDB) GetMDocsReturnedMax() float32

func (*MetricsBucket_MongoDB) GetMDocsReturnedMin

func (m *MetricsBucket_MongoDB) GetMDocsReturnedMin() float32

func (*MetricsBucket_MongoDB) GetMDocsReturnedP99

func (m *MetricsBucket_MongoDB) GetMDocsReturnedP99() float32

func (*MetricsBucket_MongoDB) GetMDocsReturnedSum

func (m *MetricsBucket_MongoDB) GetMDocsReturnedSum() float32

func (*MetricsBucket_MongoDB) GetMDocsScannedCnt

func (m *MetricsBucket_MongoDB) GetMDocsScannedCnt() float32

func (*MetricsBucket_MongoDB) GetMDocsScannedMax

func (m *MetricsBucket_MongoDB) GetMDocsScannedMax() float32

func (*MetricsBucket_MongoDB) GetMDocsScannedMin

func (m *MetricsBucket_MongoDB) GetMDocsScannedMin() float32

func (*MetricsBucket_MongoDB) GetMDocsScannedP99

func (m *MetricsBucket_MongoDB) GetMDocsScannedP99() float32

func (*MetricsBucket_MongoDB) GetMDocsScannedSum

func (m *MetricsBucket_MongoDB) GetMDocsScannedSum() float32

func (*MetricsBucket_MongoDB) GetMResponseLengthCnt

func (m *MetricsBucket_MongoDB) GetMResponseLengthCnt() float32

func (*MetricsBucket_MongoDB) GetMResponseLengthMax

func (m *MetricsBucket_MongoDB) GetMResponseLengthMax() float32

func (*MetricsBucket_MongoDB) GetMResponseLengthMin

func (m *MetricsBucket_MongoDB) GetMResponseLengthMin() float32

func (*MetricsBucket_MongoDB) GetMResponseLengthP99

func (m *MetricsBucket_MongoDB) GetMResponseLengthP99() float32

func (*MetricsBucket_MongoDB) GetMResponseLengthSum

func (m *MetricsBucket_MongoDB) GetMResponseLengthSum() float32

func (*MetricsBucket_MongoDB) ProtoMessage

func (*MetricsBucket_MongoDB) ProtoMessage()

func (*MetricsBucket_MongoDB) Reset

func (m *MetricsBucket_MongoDB) Reset()

func (*MetricsBucket_MongoDB) String

func (m *MetricsBucket_MongoDB) String() string

func (*MetricsBucket_MongoDB) Validate

func (this *MetricsBucket_MongoDB) Validate() error

func (*MetricsBucket_MongoDB) XXX_DiscardUnknown

func (m *MetricsBucket_MongoDB) XXX_DiscardUnknown()

func (*MetricsBucket_MongoDB) XXX_Marshal

func (m *MetricsBucket_MongoDB) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetricsBucket_MongoDB) XXX_Merge

func (m *MetricsBucket_MongoDB) XXX_Merge(src proto.Message)

func (*MetricsBucket_MongoDB) XXX_Size

func (m *MetricsBucket_MongoDB) XXX_Size() int

func (*MetricsBucket_MongoDB) XXX_Unmarshal

func (m *MetricsBucket_MongoDB) XXX_Unmarshal(b []byte) 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 matric was met.
	// - *_sum - how many times this matric 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 */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

MySQL contains metrics for MySQL.

func (*MetricsBucket_MySQL) Descriptor

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

func (*MetricsBucket_MySQL) GetMBytesSentCnt

func (m *MetricsBucket_MySQL) GetMBytesSentCnt() float32

func (*MetricsBucket_MySQL) GetMBytesSentMax

func (m *MetricsBucket_MySQL) GetMBytesSentMax() float32

func (*MetricsBucket_MySQL) GetMBytesSentMin

func (m *MetricsBucket_MySQL) GetMBytesSentMin() float32

func (*MetricsBucket_MySQL) GetMBytesSentP99

func (m *MetricsBucket_MySQL) GetMBytesSentP99() float32

func (*MetricsBucket_MySQL) GetMBytesSentSum

func (m *MetricsBucket_MySQL) GetMBytesSentSum() float32

func (*MetricsBucket_MySQL) GetMFilesortCnt

func (m *MetricsBucket_MySQL) GetMFilesortCnt() float32

func (*MetricsBucket_MySQL) GetMFilesortOnDiskCnt

func (m *MetricsBucket_MySQL) GetMFilesortOnDiskCnt() float32

func (*MetricsBucket_MySQL) GetMFilesortOnDiskSum

func (m *MetricsBucket_MySQL) GetMFilesortOnDiskSum() float32

func (*MetricsBucket_MySQL) GetMFilesortSum

func (m *MetricsBucket_MySQL) GetMFilesortSum() float32

func (*MetricsBucket_MySQL) GetMFullJoinCnt

func (m *MetricsBucket_MySQL) GetMFullJoinCnt() float32

func (*MetricsBucket_MySQL) GetMFullJoinSum

func (m *MetricsBucket_MySQL) GetMFullJoinSum() float32

func (*MetricsBucket_MySQL) GetMFullScanCnt

func (m *MetricsBucket_MySQL) GetMFullScanCnt() float32

func (*MetricsBucket_MySQL) GetMFullScanSum

func (m *MetricsBucket_MySQL) GetMFullScanSum() float32

func (*MetricsBucket_MySQL) GetMInnodbIoRBytesCnt

func (m *MetricsBucket_MySQL) GetMInnodbIoRBytesCnt() float32

func (*MetricsBucket_MySQL) GetMInnodbIoRBytesMax

func (m *MetricsBucket_MySQL) GetMInnodbIoRBytesMax() float32

func (*MetricsBucket_MySQL) GetMInnodbIoRBytesMin

func (m *MetricsBucket_MySQL) GetMInnodbIoRBytesMin() float32

func (*MetricsBucket_MySQL) GetMInnodbIoRBytesP99

func (m *MetricsBucket_MySQL) GetMInnodbIoRBytesP99() float32

func (*MetricsBucket_MySQL) GetMInnodbIoRBytesSum

func (m *MetricsBucket_MySQL) GetMInnodbIoRBytesSum() float32

func (*MetricsBucket_MySQL) GetMInnodbIoROpsCnt

func (m *MetricsBucket_MySQL) GetMInnodbIoROpsCnt() float32

func (*MetricsBucket_MySQL) GetMInnodbIoROpsMax

func (m *MetricsBucket_MySQL) GetMInnodbIoROpsMax() float32

func (*MetricsBucket_MySQL) GetMInnodbIoROpsMin

func (m *MetricsBucket_MySQL) GetMInnodbIoROpsMin() float32

func (*MetricsBucket_MySQL) GetMInnodbIoROpsP99

func (m *MetricsBucket_MySQL) GetMInnodbIoROpsP99() float32

func (*MetricsBucket_MySQL) GetMInnodbIoROpsSum

func (m *MetricsBucket_MySQL) GetMInnodbIoROpsSum() float32

func (*MetricsBucket_MySQL) GetMInnodbIoRWaitCnt

func (m *MetricsBucket_MySQL) GetMInnodbIoRWaitCnt() float32

func (*MetricsBucket_MySQL) GetMInnodbIoRWaitMax

func (m *MetricsBucket_MySQL) GetMInnodbIoRWaitMax() float32

func (*MetricsBucket_MySQL) GetMInnodbIoRWaitMin

func (m *MetricsBucket_MySQL) GetMInnodbIoRWaitMin() float32

func (*MetricsBucket_MySQL) GetMInnodbIoRWaitP99

func (m *MetricsBucket_MySQL) GetMInnodbIoRWaitP99() float32

func (*MetricsBucket_MySQL) GetMInnodbIoRWaitSum

func (m *MetricsBucket_MySQL) GetMInnodbIoRWaitSum() float32

func (*MetricsBucket_MySQL) GetMInnodbPagesDistinctCnt

func (m *MetricsBucket_MySQL) GetMInnodbPagesDistinctCnt() float32

func (*MetricsBucket_MySQL) GetMInnodbPagesDistinctMax

func (m *MetricsBucket_MySQL) GetMInnodbPagesDistinctMax() float32

func (*MetricsBucket_MySQL) GetMInnodbPagesDistinctMin

func (m *MetricsBucket_MySQL) GetMInnodbPagesDistinctMin() float32

func (*MetricsBucket_MySQL) GetMInnodbPagesDistinctP99

func (m *MetricsBucket_MySQL) GetMInnodbPagesDistinctP99() float32

func (*MetricsBucket_MySQL) GetMInnodbPagesDistinctSum

func (m *MetricsBucket_MySQL) GetMInnodbPagesDistinctSum() float32

func (*MetricsBucket_MySQL) GetMInnodbQueueWaitCnt

func (m *MetricsBucket_MySQL) GetMInnodbQueueWaitCnt() float32

func (*MetricsBucket_MySQL) GetMInnodbQueueWaitMax

func (m *MetricsBucket_MySQL) GetMInnodbQueueWaitMax() float32

func (*MetricsBucket_MySQL) GetMInnodbQueueWaitMin

func (m *MetricsBucket_MySQL) GetMInnodbQueueWaitMin() float32

func (*MetricsBucket_MySQL) GetMInnodbQueueWaitP99

func (m *MetricsBucket_MySQL) GetMInnodbQueueWaitP99() float32

func (*MetricsBucket_MySQL) GetMInnodbQueueWaitSum

func (m *MetricsBucket_MySQL) GetMInnodbQueueWaitSum() float32

func (*MetricsBucket_MySQL) GetMInnodbRecLockWaitCnt

func (m *MetricsBucket_MySQL) GetMInnodbRecLockWaitCnt() float32

func (*MetricsBucket_MySQL) GetMInnodbRecLockWaitMax

func (m *MetricsBucket_MySQL) GetMInnodbRecLockWaitMax() float32

func (*MetricsBucket_MySQL) GetMInnodbRecLockWaitMin

func (m *MetricsBucket_MySQL) GetMInnodbRecLockWaitMin() float32

func (*MetricsBucket_MySQL) GetMInnodbRecLockWaitP99

func (m *MetricsBucket_MySQL) GetMInnodbRecLockWaitP99() float32

func (*MetricsBucket_MySQL) GetMInnodbRecLockWaitSum

func (m *MetricsBucket_MySQL) GetMInnodbRecLockWaitSum() float32

func (*MetricsBucket_MySQL) GetMLockTimeCnt

func (m *MetricsBucket_MySQL) GetMLockTimeCnt() float32

func (*MetricsBucket_MySQL) GetMLockTimeMax

func (m *MetricsBucket_MySQL) GetMLockTimeMax() float32

func (*MetricsBucket_MySQL) GetMLockTimeMin

func (m *MetricsBucket_MySQL) GetMLockTimeMin() float32

func (*MetricsBucket_MySQL) GetMLockTimeP99

func (m *MetricsBucket_MySQL) GetMLockTimeP99() float32

func (*MetricsBucket_MySQL) GetMLockTimeSum

func (m *MetricsBucket_MySQL) GetMLockTimeSum() float32

func (*MetricsBucket_MySQL) GetMMergePassesCnt

func (m *MetricsBucket_MySQL) GetMMergePassesCnt() float32

func (*MetricsBucket_MySQL) GetMMergePassesMax

func (m *MetricsBucket_MySQL) GetMMergePassesMax() float32

func (*MetricsBucket_MySQL) GetMMergePassesMin

func (m *MetricsBucket_MySQL) GetMMergePassesMin() float32

func (*MetricsBucket_MySQL) GetMMergePassesP99

func (m *MetricsBucket_MySQL) GetMMergePassesP99() float32

func (*MetricsBucket_MySQL) GetMMergePassesSum

func (m *MetricsBucket_MySQL) GetMMergePassesSum() float32

func (*MetricsBucket_MySQL) GetMNoGoodIndexUsedCnt

func (m *MetricsBucket_MySQL) GetMNoGoodIndexUsedCnt() float32

func (*MetricsBucket_MySQL) GetMNoGoodIndexUsedSum

func (m *MetricsBucket_MySQL) GetMNoGoodIndexUsedSum() float32

func (*MetricsBucket_MySQL) GetMNoIndexUsedCnt

func (m *MetricsBucket_MySQL) GetMNoIndexUsedCnt() float32

func (*MetricsBucket_MySQL) GetMNoIndexUsedSum

func (m *MetricsBucket_MySQL) GetMNoIndexUsedSum() float32

func (*MetricsBucket_MySQL) GetMQcHitCnt

func (m *MetricsBucket_MySQL) GetMQcHitCnt() float32

func (*MetricsBucket_MySQL) GetMQcHitSum

func (m *MetricsBucket_MySQL) GetMQcHitSum() float32

func (*MetricsBucket_MySQL) GetMQueryLengthCnt

func (m *MetricsBucket_MySQL) GetMQueryLengthCnt() float32

func (*MetricsBucket_MySQL) GetMQueryLengthMax

func (m *MetricsBucket_MySQL) GetMQueryLengthMax() float32

func (*MetricsBucket_MySQL) GetMQueryLengthMin

func (m *MetricsBucket_MySQL) GetMQueryLengthMin() float32

func (*MetricsBucket_MySQL) GetMQueryLengthP99

func (m *MetricsBucket_MySQL) GetMQueryLengthP99() float32

func (*MetricsBucket_MySQL) GetMQueryLengthSum

func (m *MetricsBucket_MySQL) GetMQueryLengthSum() float32

func (*MetricsBucket_MySQL) GetMRowsAffectedCnt

func (m *MetricsBucket_MySQL) GetMRowsAffectedCnt() float32

func (*MetricsBucket_MySQL) GetMRowsAffectedMax

func (m *MetricsBucket_MySQL) GetMRowsAffectedMax() float32

func (*MetricsBucket_MySQL) GetMRowsAffectedMin

func (m *MetricsBucket_MySQL) GetMRowsAffectedMin() float32

func (*MetricsBucket_MySQL) GetMRowsAffectedP99

func (m *MetricsBucket_MySQL) GetMRowsAffectedP99() float32

func (*MetricsBucket_MySQL) GetMRowsAffectedSum

func (m *MetricsBucket_MySQL) GetMRowsAffectedSum() float32

func (*MetricsBucket_MySQL) GetMRowsExaminedCnt

func (m *MetricsBucket_MySQL) GetMRowsExaminedCnt() float32

func (*MetricsBucket_MySQL) GetMRowsExaminedMax

func (m *MetricsBucket_MySQL) GetMRowsExaminedMax() float32

func (*MetricsBucket_MySQL) GetMRowsExaminedMin

func (m *MetricsBucket_MySQL) GetMRowsExaminedMin() float32

func (*MetricsBucket_MySQL) GetMRowsExaminedP99

func (m *MetricsBucket_MySQL) GetMRowsExaminedP99() float32

func (*MetricsBucket_MySQL) GetMRowsExaminedSum

func (m *MetricsBucket_MySQL) GetMRowsExaminedSum() float32

func (*MetricsBucket_MySQL) GetMRowsReadCnt

func (m *MetricsBucket_MySQL) GetMRowsReadCnt() float32

func (*MetricsBucket_MySQL) GetMRowsReadMax

func (m *MetricsBucket_MySQL) GetMRowsReadMax() float32

func (*MetricsBucket_MySQL) GetMRowsReadMin

func (m *MetricsBucket_MySQL) GetMRowsReadMin() float32

func (*MetricsBucket_MySQL) GetMRowsReadP99

func (m *MetricsBucket_MySQL) GetMRowsReadP99() float32

func (*MetricsBucket_MySQL) GetMRowsReadSum

func (m *MetricsBucket_MySQL) GetMRowsReadSum() float32

func (*MetricsBucket_MySQL) GetMRowsSentCnt

func (m *MetricsBucket_MySQL) GetMRowsSentCnt() float32

func (*MetricsBucket_MySQL) GetMRowsSentMax

func (m *MetricsBucket_MySQL) GetMRowsSentMax() float32

func (*MetricsBucket_MySQL) GetMRowsSentMin

func (m *MetricsBucket_MySQL) GetMRowsSentMin() float32

func (*MetricsBucket_MySQL) GetMRowsSentP99

func (m *MetricsBucket_MySQL) GetMRowsSentP99() float32

func (*MetricsBucket_MySQL) GetMRowsSentSum

func (m *MetricsBucket_MySQL) GetMRowsSentSum() float32

func (*MetricsBucket_MySQL) GetMSelectFullRangeJoinCnt

func (m *MetricsBucket_MySQL) GetMSelectFullRangeJoinCnt() float32

func (*MetricsBucket_MySQL) GetMSelectFullRangeJoinSum

func (m *MetricsBucket_MySQL) GetMSelectFullRangeJoinSum() float32

func (*MetricsBucket_MySQL) GetMSelectRangeCheckCnt

func (m *MetricsBucket_MySQL) GetMSelectRangeCheckCnt() float32

func (*MetricsBucket_MySQL) GetMSelectRangeCheckSum

func (m *MetricsBucket_MySQL) GetMSelectRangeCheckSum() float32

func (*MetricsBucket_MySQL) GetMSelectRangeCnt

func (m *MetricsBucket_MySQL) GetMSelectRangeCnt() float32

func (*MetricsBucket_MySQL) GetMSelectRangeSum

func (m *MetricsBucket_MySQL) GetMSelectRangeSum() float32

func (*MetricsBucket_MySQL) GetMSortRangeCnt

func (m *MetricsBucket_MySQL) GetMSortRangeCnt() float32

func (*MetricsBucket_MySQL) GetMSortRangeSum

func (m *MetricsBucket_MySQL) GetMSortRangeSum() float32

func (*MetricsBucket_MySQL) GetMSortRowsCnt

func (m *MetricsBucket_MySQL) GetMSortRowsCnt() float32

func (*MetricsBucket_MySQL) GetMSortRowsSum

func (m *MetricsBucket_MySQL) GetMSortRowsSum() float32

func (*MetricsBucket_MySQL) GetMSortScanCnt

func (m *MetricsBucket_MySQL) GetMSortScanCnt() float32

func (*MetricsBucket_MySQL) GetMSortScanSum

func (m *MetricsBucket_MySQL) GetMSortScanSum() float32

func (*MetricsBucket_MySQL) GetMTmpDiskTablesCnt

func (m *MetricsBucket_MySQL) GetMTmpDiskTablesCnt() float32

func (*MetricsBucket_MySQL) GetMTmpDiskTablesMax

func (m *MetricsBucket_MySQL) GetMTmpDiskTablesMax() float32

func (*MetricsBucket_MySQL) GetMTmpDiskTablesMin

func (m *MetricsBucket_MySQL) GetMTmpDiskTablesMin() float32

func (*MetricsBucket_MySQL) GetMTmpDiskTablesP99

func (m *MetricsBucket_MySQL) GetMTmpDiskTablesP99() float32

func (*MetricsBucket_MySQL) GetMTmpDiskTablesSum

func (m *MetricsBucket_MySQL) GetMTmpDiskTablesSum() float32

func (*MetricsBucket_MySQL) GetMTmpTableCnt

func (m *MetricsBucket_MySQL) GetMTmpTableCnt() float32

func (*MetricsBucket_MySQL) GetMTmpTableOnDiskCnt

func (m *MetricsBucket_MySQL) GetMTmpTableOnDiskCnt() float32

func (*MetricsBucket_MySQL) GetMTmpTableOnDiskSum

func (m *MetricsBucket_MySQL) GetMTmpTableOnDiskSum() float32

func (*MetricsBucket_MySQL) GetMTmpTableSizesCnt

func (m *MetricsBucket_MySQL) GetMTmpTableSizesCnt() float32

func (*MetricsBucket_MySQL) GetMTmpTableSizesMax

func (m *MetricsBucket_MySQL) GetMTmpTableSizesMax() float32

func (*MetricsBucket_MySQL) GetMTmpTableSizesMin

func (m *MetricsBucket_MySQL) GetMTmpTableSizesMin() float32

func (*MetricsBucket_MySQL) GetMTmpTableSizesP99

func (m *MetricsBucket_MySQL) GetMTmpTableSizesP99() float32

func (*MetricsBucket_MySQL) GetMTmpTableSizesSum

func (m *MetricsBucket_MySQL) GetMTmpTableSizesSum() float32

func (*MetricsBucket_MySQL) GetMTmpTableSum

func (m *MetricsBucket_MySQL) GetMTmpTableSum() float32

func (*MetricsBucket_MySQL) GetMTmpTablesCnt

func (m *MetricsBucket_MySQL) GetMTmpTablesCnt() float32

func (*MetricsBucket_MySQL) GetMTmpTablesMax

func (m *MetricsBucket_MySQL) GetMTmpTablesMax() float32

func (*MetricsBucket_MySQL) GetMTmpTablesMin

func (m *MetricsBucket_MySQL) GetMTmpTablesMin() float32

func (*MetricsBucket_MySQL) GetMTmpTablesP99

func (m *MetricsBucket_MySQL) GetMTmpTablesP99() float32

func (*MetricsBucket_MySQL) GetMTmpTablesSum

func (m *MetricsBucket_MySQL) GetMTmpTablesSum() float32

func (*MetricsBucket_MySQL) ProtoMessage

func (*MetricsBucket_MySQL) ProtoMessage()

func (*MetricsBucket_MySQL) Reset

func (m *MetricsBucket_MySQL) Reset()

func (*MetricsBucket_MySQL) String

func (m *MetricsBucket_MySQL) String() string

func (*MetricsBucket_MySQL) Validate

func (this *MetricsBucket_MySQL) Validate() error

func (*MetricsBucket_MySQL) XXX_DiscardUnknown

func (m *MetricsBucket_MySQL) XXX_DiscardUnknown()

func (*MetricsBucket_MySQL) XXX_Marshal

func (m *MetricsBucket_MySQL) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetricsBucket_MySQL) XXX_Merge

func (m *MetricsBucket_MySQL) XXX_Merge(src proto.Message)

func (*MetricsBucket_MySQL) XXX_Size

func (m *MetricsBucket_MySQL) XXX_Size() int

func (*MetricsBucket_MySQL) XXX_Unmarshal

func (m *MetricsBucket_MySQL) XXX_Unmarshal(b []byte) error

type MetricsBucket_PostgreSQL

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

PostgreSQL contains metrics for PostgreSQL.

func (*MetricsBucket_PostgreSQL) Descriptor

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

func (*MetricsBucket_PostgreSQL) GetMBlkReadTimeCnt

func (m *MetricsBucket_PostgreSQL) GetMBlkReadTimeCnt() float32

func (*MetricsBucket_PostgreSQL) GetMBlkReadTimeSum

func (m *MetricsBucket_PostgreSQL) GetMBlkReadTimeSum() float32

func (*MetricsBucket_PostgreSQL) GetMBlkWriteTimeCnt

func (m *MetricsBucket_PostgreSQL) GetMBlkWriteTimeCnt() float32

func (*MetricsBucket_PostgreSQL) GetMBlkWriteTimeSum

func (m *MetricsBucket_PostgreSQL) GetMBlkWriteTimeSum() float32

func (*MetricsBucket_PostgreSQL) GetMLocalBlksDirtiedCnt

func (m *MetricsBucket_PostgreSQL) GetMLocalBlksDirtiedCnt() float32

func (*MetricsBucket_PostgreSQL) GetMLocalBlksDirtiedSum

func (m *MetricsBucket_PostgreSQL) GetMLocalBlksDirtiedSum() float32

func (*MetricsBucket_PostgreSQL) GetMLocalBlksHitCnt

func (m *MetricsBucket_PostgreSQL) GetMLocalBlksHitCnt() float32

func (*MetricsBucket_PostgreSQL) GetMLocalBlksHitSum

func (m *MetricsBucket_PostgreSQL) GetMLocalBlksHitSum() float32

func (*MetricsBucket_PostgreSQL) GetMLocalBlksReadCnt

func (m *MetricsBucket_PostgreSQL) GetMLocalBlksReadCnt() float32

func (*MetricsBucket_PostgreSQL) GetMLocalBlksReadSum

func (m *MetricsBucket_PostgreSQL) GetMLocalBlksReadSum() float32

func (*MetricsBucket_PostgreSQL) GetMLocalBlksWrittenCnt

func (m *MetricsBucket_PostgreSQL) GetMLocalBlksWrittenCnt() float32

func (*MetricsBucket_PostgreSQL) GetMLocalBlksWrittenSum

func (m *MetricsBucket_PostgreSQL) GetMLocalBlksWrittenSum() float32

func (*MetricsBucket_PostgreSQL) GetMRowsCnt

func (m *MetricsBucket_PostgreSQL) GetMRowsCnt() float32

func (*MetricsBucket_PostgreSQL) GetMRowsSum

func (m *MetricsBucket_PostgreSQL) GetMRowsSum() float32

func (*MetricsBucket_PostgreSQL) GetMSharedBlksDirtiedCnt

func (m *MetricsBucket_PostgreSQL) GetMSharedBlksDirtiedCnt() float32

func (*MetricsBucket_PostgreSQL) GetMSharedBlksDirtiedSum

func (m *MetricsBucket_PostgreSQL) GetMSharedBlksDirtiedSum() float32

func (*MetricsBucket_PostgreSQL) GetMSharedBlksHitCnt

func (m *MetricsBucket_PostgreSQL) GetMSharedBlksHitCnt() float32

func (*MetricsBucket_PostgreSQL) GetMSharedBlksHitSum

func (m *MetricsBucket_PostgreSQL) GetMSharedBlksHitSum() float32

func (*MetricsBucket_PostgreSQL) GetMSharedBlksReadCnt

func (m *MetricsBucket_PostgreSQL) GetMSharedBlksReadCnt() float32

func (*MetricsBucket_PostgreSQL) GetMSharedBlksReadSum

func (m *MetricsBucket_PostgreSQL) GetMSharedBlksReadSum() float32

func (*MetricsBucket_PostgreSQL) GetMSharedBlksWrittenCnt

func (m *MetricsBucket_PostgreSQL) GetMSharedBlksWrittenCnt() float32

func (*MetricsBucket_PostgreSQL) GetMSharedBlksWrittenSum

func (m *MetricsBucket_PostgreSQL) GetMSharedBlksWrittenSum() float32

func (*MetricsBucket_PostgreSQL) GetMTempBlksReadCnt

func (m *MetricsBucket_PostgreSQL) GetMTempBlksReadCnt() float32

func (*MetricsBucket_PostgreSQL) GetMTempBlksReadSum

func (m *MetricsBucket_PostgreSQL) GetMTempBlksReadSum() float32

func (*MetricsBucket_PostgreSQL) GetMTempBlksWrittenCnt

func (m *MetricsBucket_PostgreSQL) GetMTempBlksWrittenCnt() float32

func (*MetricsBucket_PostgreSQL) GetMTempBlksWrittenSum

func (m *MetricsBucket_PostgreSQL) GetMTempBlksWrittenSum() float32

func (*MetricsBucket_PostgreSQL) ProtoMessage

func (*MetricsBucket_PostgreSQL) ProtoMessage()

func (*MetricsBucket_PostgreSQL) Reset

func (m *MetricsBucket_PostgreSQL) Reset()

func (*MetricsBucket_PostgreSQL) String

func (m *MetricsBucket_PostgreSQL) String() string

func (*MetricsBucket_PostgreSQL) Validate

func (this *MetricsBucket_PostgreSQL) Validate() error

func (*MetricsBucket_PostgreSQL) XXX_DiscardUnknown

func (m *MetricsBucket_PostgreSQL) XXX_DiscardUnknown()

func (*MetricsBucket_PostgreSQL) XXX_Marshal

func (m *MetricsBucket_PostgreSQL) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetricsBucket_PostgreSQL) XXX_Merge

func (m *MetricsBucket_PostgreSQL) XXX_Merge(src proto.Message)

func (*MetricsBucket_PostgreSQL) XXX_Size

func (m *MetricsBucket_PostgreSQL) XXX_Size() int

func (*MetricsBucket_PostgreSQL) XXX_Unmarshal

func (m *MetricsBucket_PostgreSQL) XXX_Unmarshal(b []byte) 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) EnumDescriptor

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

func (MysqlExplainOutputFormat) String

func (x MysqlExplainOutputFormat) String() string

type Ping

type Ping struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

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

func (*Ping) ProtoMessage

func (*Ping) ProtoMessage()

func (*Ping) Reset

func (m *Ping) Reset()

func (*Ping) ServerMessageRequestPayload

func (m *Ping) ServerMessageRequestPayload() isServerMessage_Payload

ServerMessage request payloads

func (*Ping) String

func (m *Ping) String() string

func (*Ping) Validate

func (this *Ping) Validate() error

func (*Ping) XXX_DiscardUnknown

func (m *Ping) XXX_DiscardUnknown()

func (*Ping) XXX_Marshal

func (m *Ping) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Ping) XXX_Merge

func (m *Ping) XXX_Merge(src proto.Message)

func (*Ping) XXX_Size

func (m *Ping) XXX_Size() int

func (*Ping) XXX_Unmarshal

func (m *Ping) XXX_Unmarshal(b []byte) error

type Pong

type Pong struct {
	CurrentTime          *timestamp.Timestamp `protobuf:"bytes,1,opt,name=current_time,json=currentTime,proto3" json:"current_time,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

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

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

func (*Pong) GetCurrentTime

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

func (*Pong) ProtoMessage

func (*Pong) ProtoMessage()

func (*Pong) Reset

func (m *Pong) Reset()

func (*Pong) ServerMessageResponsePayload

func (m *Pong) ServerMessageResponsePayload() isServerMessage_Payload

ServerMessage response payloads

func (*Pong) String

func (m *Pong) String() string

func (*Pong) Validate

func (this *Pong) Validate() error

func (*Pong) XXX_DiscardUnknown

func (m *Pong) XXX_DiscardUnknown()

func (*Pong) XXX_Marshal

func (m *Pong) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Pong) XXX_Merge

func (m *Pong) XXX_Merge(src proto.Message)

func (*Pong) XXX_Size

func (m *Pong) XXX_Size() int

func (*Pong) XXX_Unmarshal

func (m *Pong) XXX_Unmarshal(b []byte) error

type QANCollectRequest

type QANCollectRequest struct {
	MetricsBucket        []*MetricsBucket `protobuf:"bytes,1,rep,name=metrics_bucket,json=metricsBucket,proto3" json:"metrics_bucket,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

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

func (*QANCollectRequest) AgentMessageRequestPayload

func (m *QANCollectRequest) AgentMessageRequestPayload() isAgentMessage_Payload

func (*QANCollectRequest) Descriptor

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

func (*QANCollectRequest) GetMetricsBucket

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

func (*QANCollectRequest) ProtoMessage

func (*QANCollectRequest) ProtoMessage()

func (*QANCollectRequest) Reset

func (m *QANCollectRequest) Reset()

func (*QANCollectRequest) String

func (m *QANCollectRequest) String() string

func (*QANCollectRequest) Validate

func (this *QANCollectRequest) Validate() error

func (*QANCollectRequest) XXX_DiscardUnknown

func (m *QANCollectRequest) XXX_DiscardUnknown()

func (*QANCollectRequest) XXX_Marshal

func (m *QANCollectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QANCollectRequest) XXX_Merge

func (m *QANCollectRequest) XXX_Merge(src proto.Message)

func (*QANCollectRequest) XXX_Size

func (m *QANCollectRequest) XXX_Size() int

func (*QANCollectRequest) XXX_Unmarshal

func (m *QANCollectRequest) XXX_Unmarshal(b []byte) error

type QANCollectResponse

type QANCollectResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

QANCollectResponse is a ServerMessage for QAN data acceptance.

func (*QANCollectResponse) Descriptor

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

func (*QANCollectResponse) ProtoMessage

func (*QANCollectResponse) ProtoMessage()

func (*QANCollectResponse) Reset

func (m *QANCollectResponse) Reset()

func (*QANCollectResponse) ServerMessageResponsePayload

func (m *QANCollectResponse) ServerMessageResponsePayload() isServerMessage_Payload

func (*QANCollectResponse) String

func (m *QANCollectResponse) String() string

func (*QANCollectResponse) Validate

func (this *QANCollectResponse) Validate() error

func (*QANCollectResponse) XXX_DiscardUnknown

func (m *QANCollectResponse) XXX_DiscardUnknown()

func (*QANCollectResponse) XXX_Marshal

func (m *QANCollectResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QANCollectResponse) XXX_Merge

func (m *QANCollectResponse) XXX_Merge(src proto.Message)

func (*QANCollectResponse) XXX_Size

func (m *QANCollectResponse) XXX_Size() int

func (*QANCollectResponse) XXX_Unmarshal

func (m *QANCollectResponse) XXX_Unmarshal(b []byte) error

type ServerConnectMetadata

type ServerConnectMetadata struct {
	AgentRunsOnNodeID string
	ServerVersion     string
}

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

func ReceiveServerConnectMetadata

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

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

type ServerMessage

type ServerMessage struct {
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are valid to be assigned to Payload:
	//	*ServerMessage_Pong
	//	*ServerMessage_StateChanged
	//	*ServerMessage_QanCollect
	//	*ServerMessage_ActionResult
	//	*ServerMessage_Ping
	//	*ServerMessage_SetState
	//	*ServerMessage_StartAction
	//	*ServerMessage_StopAction
	//	*ServerMessage_CheckConnection
	Payload              isServerMessage_Payload `protobuf_oneof:"payload"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*ServerMessage) Descriptor

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

func (*ServerMessage) GetActionResult

func (m *ServerMessage) GetActionResult() *ActionResultResponse

func (*ServerMessage) GetCheckConnection

func (m *ServerMessage) GetCheckConnection() *CheckConnectionRequest

func (*ServerMessage) GetId

func (m *ServerMessage) GetId() uint32

func (*ServerMessage) GetPayload

func (m *ServerMessage) GetPayload() isServerMessage_Payload

func (*ServerMessage) GetPing

func (m *ServerMessage) GetPing() *Ping

func (*ServerMessage) GetPong

func (m *ServerMessage) GetPong() *Pong

func (*ServerMessage) GetQanCollect

func (m *ServerMessage) GetQanCollect() *QANCollectResponse

func (*ServerMessage) GetSetState

func (m *ServerMessage) GetSetState() *SetStateRequest

func (*ServerMessage) GetStartAction

func (m *ServerMessage) GetStartAction() *StartActionRequest

func (*ServerMessage) GetStateChanged

func (m *ServerMessage) GetStateChanged() *StateChangedResponse

func (*ServerMessage) GetStopAction

func (m *ServerMessage) GetStopAction() *StopActionRequest

func (*ServerMessage) ProtoMessage

func (*ServerMessage) ProtoMessage()

func (*ServerMessage) Reset

func (m *ServerMessage) Reset()

func (*ServerMessage) String

func (m *ServerMessage) String() string

func (*ServerMessage) Validate

func (this *ServerMessage) Validate() error

func (*ServerMessage) XXX_DiscardUnknown

func (m *ServerMessage) XXX_DiscardUnknown()

func (*ServerMessage) XXX_Marshal

func (m *ServerMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServerMessage) XXX_Merge

func (m *ServerMessage) XXX_Merge(src proto.Message)

func (*ServerMessage) XXX_OneofWrappers

func (*ServerMessage) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ServerMessage) XXX_Size

func (m *ServerMessage) XXX_Size() int

func (*ServerMessage) XXX_Unmarshal

func (m *ServerMessage) XXX_Unmarshal(b []byte) 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_Ping

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

type ServerMessage_Pong

type ServerMessage_Pong struct {
	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_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 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 */
	XXX_NoUnkeyedLiteral struct{}                                 `json:"-"`
	XXX_unrecognized     []byte                                   `json:"-"`
	XXX_sizecache        int32                                    `json:"-"`
}

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

func (*SetStateRequest) Descriptor

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

func (*SetStateRequest) GetAgentProcesses

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

func (*SetStateRequest) GetBuiltinAgents

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

func (*SetStateRequest) ProtoMessage

func (*SetStateRequest) ProtoMessage()

func (*SetStateRequest) Reset

func (m *SetStateRequest) Reset()

func (*SetStateRequest) ServerMessageRequestPayload

func (m *SetStateRequest) ServerMessageRequestPayload() isServerMessage_Payload

func (*SetStateRequest) String

func (m *SetStateRequest) String() string

func (*SetStateRequest) Validate

func (this *SetStateRequest) Validate() error

func (*SetStateRequest) XXX_DiscardUnknown

func (m *SetStateRequest) XXX_DiscardUnknown()

func (*SetStateRequest) XXX_Marshal

func (m *SetStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetStateRequest) XXX_Merge

func (m *SetStateRequest) XXX_Merge(src proto.Message)

func (*SetStateRequest) XXX_Size

func (m *SetStateRequest) XXX_Size() int

func (*SetStateRequest) XXX_Unmarshal

func (m *SetStateRequest) XXX_Unmarshal(b []byte) error

type SetStateRequest_AgentProcess

type SetStateRequest_AgentProcess struct {
	Type                 Type              `protobuf:"varint,1,opt,name=type,proto3,enum=agent.Type" 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 */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

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

func (*SetStateRequest_AgentProcess) Descriptor

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

func (*SetStateRequest_AgentProcess) GetArgs

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

func (*SetStateRequest_AgentProcess) GetEnv

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

func (*SetStateRequest_AgentProcess) GetTemplateLeftDelim

func (m *SetStateRequest_AgentProcess) GetTemplateLeftDelim() string

func (*SetStateRequest_AgentProcess) GetTemplateRightDelim

func (m *SetStateRequest_AgentProcess) GetTemplateRightDelim() string

func (*SetStateRequest_AgentProcess) GetTextFiles

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

func (*SetStateRequest_AgentProcess) GetType

func (m *SetStateRequest_AgentProcess) GetType() Type

func (*SetStateRequest_AgentProcess) ProtoMessage

func (*SetStateRequest_AgentProcess) ProtoMessage()

func (*SetStateRequest_AgentProcess) Reset

func (m *SetStateRequest_AgentProcess) Reset()

func (*SetStateRequest_AgentProcess) String

func (*SetStateRequest_AgentProcess) Validate

func (this *SetStateRequest_AgentProcess) Validate() error

func (*SetStateRequest_AgentProcess) XXX_DiscardUnknown

func (m *SetStateRequest_AgentProcess) XXX_DiscardUnknown()

func (*SetStateRequest_AgentProcess) XXX_Marshal

func (m *SetStateRequest_AgentProcess) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetStateRequest_AgentProcess) XXX_Merge

func (m *SetStateRequest_AgentProcess) XXX_Merge(src proto.Message)

func (*SetStateRequest_AgentProcess) XXX_Size

func (m *SetStateRequest_AgentProcess) XXX_Size() int

func (*SetStateRequest_AgentProcess) XXX_Unmarshal

func (m *SetStateRequest_AgentProcess) XXX_Unmarshal(b []byte) error

type SetStateRequest_BuiltinAgent

type SetStateRequest_BuiltinAgent struct {
	Type                 Type     `protobuf:"varint,1,opt,name=type,proto3,enum=agent.Type" json:"type,omitempty"`
	Dsn                  string   `protobuf:"bytes,2,opt,name=dsn,proto3" json:"dsn,omitempty"`
	DisableQueryExamples bool     `protobuf:"varint,3,opt,name=disable_query_examples,json=disableQueryExamples,proto3" json:"disable_query_examples,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*SetStateRequest_BuiltinAgent) Descriptor

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

func (*SetStateRequest_BuiltinAgent) GetDisableQueryExamples

func (m *SetStateRequest_BuiltinAgent) GetDisableQueryExamples() bool

func (*SetStateRequest_BuiltinAgent) GetDsn

func (*SetStateRequest_BuiltinAgent) GetType

func (m *SetStateRequest_BuiltinAgent) GetType() Type

func (*SetStateRequest_BuiltinAgent) ProtoMessage

func (*SetStateRequest_BuiltinAgent) ProtoMessage()

func (*SetStateRequest_BuiltinAgent) Reset

func (m *SetStateRequest_BuiltinAgent) Reset()

func (*SetStateRequest_BuiltinAgent) String

func (*SetStateRequest_BuiltinAgent) Validate

func (this *SetStateRequest_BuiltinAgent) Validate() error

func (*SetStateRequest_BuiltinAgent) XXX_DiscardUnknown

func (m *SetStateRequest_BuiltinAgent) XXX_DiscardUnknown()

func (*SetStateRequest_BuiltinAgent) XXX_Marshal

func (m *SetStateRequest_BuiltinAgent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetStateRequest_BuiltinAgent) XXX_Merge

func (m *SetStateRequest_BuiltinAgent) XXX_Merge(src proto.Message)

func (*SetStateRequest_BuiltinAgent) XXX_Size

func (m *SetStateRequest_BuiltinAgent) XXX_Size() int

func (*SetStateRequest_BuiltinAgent) XXX_Unmarshal

func (m *SetStateRequest_BuiltinAgent) XXX_Unmarshal(b []byte) error

type SetStateResponse

type SetStateResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

SetStateResponse is an AgentMessage for SetStateRequest acceptance.

func (*SetStateResponse) AgentMessageResponsePayload

func (m *SetStateResponse) AgentMessageResponsePayload() isAgentMessage_Payload

func (*SetStateResponse) Descriptor

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

func (*SetStateResponse) ProtoMessage

func (*SetStateResponse) ProtoMessage()

func (*SetStateResponse) Reset

func (m *SetStateResponse) Reset()

func (*SetStateResponse) String

func (m *SetStateResponse) String() string

func (*SetStateResponse) Validate

func (this *SetStateResponse) Validate() error

func (*SetStateResponse) XXX_DiscardUnknown

func (m *SetStateResponse) XXX_DiscardUnknown()

func (*SetStateResponse) XXX_Marshal

func (m *SetStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetStateResponse) XXX_Merge

func (m *SetStateResponse) XXX_Merge(src proto.Message)

func (*SetStateResponse) XXX_Size

func (m *SetStateResponse) XXX_Size() int

func (*SetStateResponse) XXX_Unmarshal

func (m *SetStateResponse) XXX_Unmarshal(b []byte) 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 valid to be assigned to Params:
	//	*StartActionRequest_PtSummaryParams
	//	*StartActionRequest_PtMysqlSummaryParams
	//	*StartActionRequest_MysqlExplainParams
	//	*StartActionRequest_MysqlShowCreateTableParams
	//	*StartActionRequest_MysqlShowTableStatusParams
	//	*StartActionRequest_MysqlShowIndexParams
	//	*StartActionRequest_PostgresqlShowCreateTableParams
	//	*StartActionRequest_PostgresqlShowIndexParams
	Params               isStartActionRequest_Params `protobuf_oneof:"params"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

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

func (*StartActionRequest) Descriptor

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

func (*StartActionRequest) GetActionId

func (m *StartActionRequest) GetActionId() string

func (*StartActionRequest) GetMysqlExplainParams

func (m *StartActionRequest) GetMysqlExplainParams() *StartActionRequest_MySQLExplainParams

func (*StartActionRequest) GetMysqlShowCreateTableParams

func (m *StartActionRequest) GetMysqlShowCreateTableParams() *StartActionRequest_MySQLShowCreateTableParams

func (*StartActionRequest) GetMysqlShowIndexParams

func (m *StartActionRequest) GetMysqlShowIndexParams() *StartActionRequest_MySQLShowIndexParams

func (*StartActionRequest) GetMysqlShowTableStatusParams

func (m *StartActionRequest) GetMysqlShowTableStatusParams() *StartActionRequest_MySQLShowTableStatusParams

func (*StartActionRequest) GetParams

func (m *StartActionRequest) GetParams() isStartActionRequest_Params

func (*StartActionRequest) GetPostgresqlShowCreateTableParams

func (m *StartActionRequest) GetPostgresqlShowCreateTableParams() *StartActionRequest_PostgreSQLShowCreateTableParams

func (*StartActionRequest) GetPostgresqlShowIndexParams

func (m *StartActionRequest) GetPostgresqlShowIndexParams() *StartActionRequest_PostgreSQLShowIndexParams

func (*StartActionRequest) GetPtMysqlSummaryParams

func (m *StartActionRequest) GetPtMysqlSummaryParams() *StartActionRequest_ProcessParams

func (*StartActionRequest) GetPtSummaryParams

func (m *StartActionRequest) GetPtSummaryParams() *StartActionRequest_ProcessParams

func (*StartActionRequest) ProtoMessage

func (*StartActionRequest) ProtoMessage()

func (*StartActionRequest) Reset

func (m *StartActionRequest) Reset()

func (*StartActionRequest) ServerMessageRequestPayload

func (m *StartActionRequest) ServerMessageRequestPayload() isServerMessage_Payload

func (*StartActionRequest) String

func (m *StartActionRequest) String() string

func (*StartActionRequest) Validate

func (this *StartActionRequest) Validate() error

func (*StartActionRequest) XXX_DiscardUnknown

func (m *StartActionRequest) XXX_DiscardUnknown()

func (*StartActionRequest) XXX_Marshal

func (m *StartActionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartActionRequest) XXX_Merge

func (m *StartActionRequest) XXX_Merge(src proto.Message)

func (*StartActionRequest) XXX_OneofWrappers

func (*StartActionRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*StartActionRequest) XXX_Size

func (m *StartActionRequest) XXX_Size() int

func (*StartActionRequest) XXX_Unmarshal

func (m *StartActionRequest) XXX_Unmarshal(b []byte) error

type StartActionRequest_MySQLExplainParams

type StartActionRequest_MySQLExplainParams struct {
	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 */
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

MySQLExplainParams describes MySQL EXPLAIN action parameters.

func (*StartActionRequest_MySQLExplainParams) Descriptor

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

func (*StartActionRequest_MySQLExplainParams) GetDsn

func (*StartActionRequest_MySQLExplainParams) GetOutputFormat

func (*StartActionRequest_MySQLExplainParams) GetQuery

func (*StartActionRequest_MySQLExplainParams) ProtoMessage

func (*StartActionRequest_MySQLExplainParams) ProtoMessage()

func (*StartActionRequest_MySQLExplainParams) Reset

func (*StartActionRequest_MySQLExplainParams) String

func (*StartActionRequest_MySQLExplainParams) Validate

func (*StartActionRequest_MySQLExplainParams) XXX_DiscardUnknown

func (m *StartActionRequest_MySQLExplainParams) XXX_DiscardUnknown()

func (*StartActionRequest_MySQLExplainParams) XXX_Marshal

func (m *StartActionRequest_MySQLExplainParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartActionRequest_MySQLExplainParams) XXX_Merge

func (*StartActionRequest_MySQLExplainParams) XXX_Size

func (*StartActionRequest_MySQLExplainParams) XXX_Unmarshal

func (m *StartActionRequest_MySQLExplainParams) XXX_Unmarshal(b []byte) error

type StartActionRequest_MySQLShowCreateTableParams

type StartActionRequest_MySQLShowCreateTableParams struct {
	Dsn                  string   `protobuf:"bytes,1,opt,name=dsn,proto3" json:"dsn,omitempty"`
	Table                string   `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

MySQLShowCreateTableParams describes MySQL SHOW CREATE TABLE action parameters.

func (*StartActionRequest_MySQLShowCreateTableParams) Descriptor

func (*StartActionRequest_MySQLShowCreateTableParams) GetDsn

func (*StartActionRequest_MySQLShowCreateTableParams) GetTable

func (*StartActionRequest_MySQLShowCreateTableParams) ProtoMessage

func (*StartActionRequest_MySQLShowCreateTableParams) Reset

func (*StartActionRequest_MySQLShowCreateTableParams) String

func (*StartActionRequest_MySQLShowCreateTableParams) Validate

func (*StartActionRequest_MySQLShowCreateTableParams) XXX_DiscardUnknown

func (m *StartActionRequest_MySQLShowCreateTableParams) XXX_DiscardUnknown()

func (*StartActionRequest_MySQLShowCreateTableParams) XXX_Marshal

func (m *StartActionRequest_MySQLShowCreateTableParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartActionRequest_MySQLShowCreateTableParams) XXX_Merge

func (*StartActionRequest_MySQLShowCreateTableParams) XXX_Size

func (*StartActionRequest_MySQLShowCreateTableParams) XXX_Unmarshal

type StartActionRequest_MySQLShowIndexParams

type StartActionRequest_MySQLShowIndexParams struct {
	Dsn                  string   `protobuf:"bytes,1,opt,name=dsn,proto3" json:"dsn,omitempty"`
	Table                string   `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

MySQLShowIndexParams describes MySQL SHOW INDEX action parameters.

func (*StartActionRequest_MySQLShowIndexParams) Descriptor

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

func (*StartActionRequest_MySQLShowIndexParams) GetDsn

func (*StartActionRequest_MySQLShowIndexParams) GetTable

func (*StartActionRequest_MySQLShowIndexParams) ProtoMessage

func (*StartActionRequest_MySQLShowIndexParams) Reset

func (*StartActionRequest_MySQLShowIndexParams) String

func (*StartActionRequest_MySQLShowIndexParams) Validate

func (*StartActionRequest_MySQLShowIndexParams) XXX_DiscardUnknown

func (m *StartActionRequest_MySQLShowIndexParams) XXX_DiscardUnknown()

func (*StartActionRequest_MySQLShowIndexParams) XXX_Marshal

func (m *StartActionRequest_MySQLShowIndexParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartActionRequest_MySQLShowIndexParams) XXX_Merge

func (*StartActionRequest_MySQLShowIndexParams) XXX_Size

func (*StartActionRequest_MySQLShowIndexParams) XXX_Unmarshal

func (m *StartActionRequest_MySQLShowIndexParams) XXX_Unmarshal(b []byte) error

type StartActionRequest_MySQLShowTableStatusParams

type StartActionRequest_MySQLShowTableStatusParams struct {
	Dsn                  string   `protobuf:"bytes,1,opt,name=dsn,proto3" json:"dsn,omitempty"`
	Table                string   `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

MySQLShowTableStatusParams describes MySQL SHOW TABLE STATUS action parameters.

func (*StartActionRequest_MySQLShowTableStatusParams) Descriptor

func (*StartActionRequest_MySQLShowTableStatusParams) GetDsn

func (*StartActionRequest_MySQLShowTableStatusParams) GetTable

func (*StartActionRequest_MySQLShowTableStatusParams) ProtoMessage

func (*StartActionRequest_MySQLShowTableStatusParams) Reset

func (*StartActionRequest_MySQLShowTableStatusParams) String

func (*StartActionRequest_MySQLShowTableStatusParams) Validate

func (*StartActionRequest_MySQLShowTableStatusParams) XXX_DiscardUnknown

func (m *StartActionRequest_MySQLShowTableStatusParams) XXX_DiscardUnknown()

func (*StartActionRequest_MySQLShowTableStatusParams) XXX_Marshal

func (m *StartActionRequest_MySQLShowTableStatusParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartActionRequest_MySQLShowTableStatusParams) XXX_Merge

func (*StartActionRequest_MySQLShowTableStatusParams) XXX_Size

func (*StartActionRequest_MySQLShowTableStatusParams) XXX_Unmarshal

type StartActionRequest_MysqlExplainParams

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

type StartActionRequest_MysqlShowCreateTableParams

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

type StartActionRequest_MysqlShowIndexParams

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

type StartActionRequest_MysqlShowTableStatusParams

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

type StartActionRequest_PostgreSQLShowCreateTableParams

type StartActionRequest_PostgreSQLShowCreateTableParams struct {
	Dsn                  string   `protobuf:"bytes,1,opt,name=dsn,proto3" json:"dsn,omitempty"`
	Table                string   `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

PostgreSQLShowCreateTableParams describes PostgreSQL SHOW CREATE TABLE action parameters.

func (*StartActionRequest_PostgreSQLShowCreateTableParams) Descriptor

func (*StartActionRequest_PostgreSQLShowCreateTableParams) GetDsn

func (*StartActionRequest_PostgreSQLShowCreateTableParams) GetTable

func (*StartActionRequest_PostgreSQLShowCreateTableParams) ProtoMessage

func (*StartActionRequest_PostgreSQLShowCreateTableParams) Reset

func (*StartActionRequest_PostgreSQLShowCreateTableParams) String

func (*StartActionRequest_PostgreSQLShowCreateTableParams) Validate

func (*StartActionRequest_PostgreSQLShowCreateTableParams) XXX_DiscardUnknown

func (*StartActionRequest_PostgreSQLShowCreateTableParams) XXX_Marshal

func (m *StartActionRequest_PostgreSQLShowCreateTableParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartActionRequest_PostgreSQLShowCreateTableParams) XXX_Merge

func (*StartActionRequest_PostgreSQLShowCreateTableParams) XXX_Size

func (*StartActionRequest_PostgreSQLShowCreateTableParams) XXX_Unmarshal

type StartActionRequest_PostgreSQLShowIndexParams

type StartActionRequest_PostgreSQLShowIndexParams struct {
	Dsn                  string   `protobuf:"bytes,1,opt,name=dsn,proto3" json:"dsn,omitempty"`
	Table                string   `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

PostgreSQLShowIndexParams describes PostgreSQL SHOW INDEX action parameters.

func (*StartActionRequest_PostgreSQLShowIndexParams) Descriptor

func (*StartActionRequest_PostgreSQLShowIndexParams) GetDsn

func (*StartActionRequest_PostgreSQLShowIndexParams) GetTable

func (*StartActionRequest_PostgreSQLShowIndexParams) ProtoMessage

func (*StartActionRequest_PostgreSQLShowIndexParams) Reset

func (*StartActionRequest_PostgreSQLShowIndexParams) String

func (*StartActionRequest_PostgreSQLShowIndexParams) Validate

func (*StartActionRequest_PostgreSQLShowIndexParams) XXX_DiscardUnknown

func (m *StartActionRequest_PostgreSQLShowIndexParams) XXX_DiscardUnknown()

func (*StartActionRequest_PostgreSQLShowIndexParams) XXX_Marshal

func (m *StartActionRequest_PostgreSQLShowIndexParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartActionRequest_PostgreSQLShowIndexParams) XXX_Merge

func (*StartActionRequest_PostgreSQLShowIndexParams) XXX_Size

func (*StartActionRequest_PostgreSQLShowIndexParams) XXX_Unmarshal

type StartActionRequest_PostgresqlShowCreateTableParams

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

type StartActionRequest_PostgresqlShowIndexParams

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

type StartActionRequest_ProcessParams

type StartActionRequest_ProcessParams struct {
	Args                 []string `protobuf:"bytes,1,rep,name=args,proto3" json:"args,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ProcessParams describes parameters for all process actions.

func (*StartActionRequest_ProcessParams) Descriptor

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

func (*StartActionRequest_ProcessParams) GetArgs

func (*StartActionRequest_ProcessParams) ProtoMessage

func (*StartActionRequest_ProcessParams) ProtoMessage()

func (*StartActionRequest_ProcessParams) Reset

func (*StartActionRequest_ProcessParams) String

func (*StartActionRequest_ProcessParams) Validate

func (this *StartActionRequest_ProcessParams) Validate() error

func (*StartActionRequest_ProcessParams) XXX_DiscardUnknown

func (m *StartActionRequest_ProcessParams) XXX_DiscardUnknown()

func (*StartActionRequest_ProcessParams) XXX_Marshal

func (m *StartActionRequest_ProcessParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartActionRequest_ProcessParams) XXX_Merge

func (*StartActionRequest_ProcessParams) XXX_Size

func (m *StartActionRequest_ProcessParams) XXX_Size() int

func (*StartActionRequest_ProcessParams) XXX_Unmarshal

func (m *StartActionRequest_ProcessParams) XXX_Unmarshal(b []byte) error

type StartActionRequest_PtMysqlSummaryParams

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

type StartActionRequest_PtSummaryParams

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

type StartActionResponse

type StartActionResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

StartActionResponse is an AgentMessage for StartActionRequest acceptance.

func (*StartActionResponse) AgentMessageResponsePayload

func (m *StartActionResponse) AgentMessageResponsePayload() isAgentMessage_Payload

func (*StartActionResponse) Descriptor

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

func (*StartActionResponse) ProtoMessage

func (*StartActionResponse) ProtoMessage()

func (*StartActionResponse) Reset

func (m *StartActionResponse) Reset()

func (*StartActionResponse) String

func (m *StartActionResponse) String() string

func (*StartActionResponse) Validate

func (this *StartActionResponse) Validate() error

func (*StartActionResponse) XXX_DiscardUnknown

func (m *StartActionResponse) XXX_DiscardUnknown()

func (*StartActionResponse) XXX_Marshal

func (m *StartActionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartActionResponse) XXX_Merge

func (m *StartActionResponse) XXX_Merge(src proto.Message)

func (*StartActionResponse) XXX_Size

func (m *StartActionResponse) XXX_Size() int

func (*StartActionResponse) XXX_Unmarshal

func (m *StartActionResponse) XXX_Unmarshal(b []byte) 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"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

StateChangedRequest is an AgentMessage describing actual agent status.

func (*StateChangedRequest) AgentMessageRequestPayload

func (m *StateChangedRequest) AgentMessageRequestPayload() isAgentMessage_Payload

func (*StateChangedRequest) Descriptor

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

func (*StateChangedRequest) GetAgentId

func (m *StateChangedRequest) GetAgentId() string

func (*StateChangedRequest) GetListenPort

func (m *StateChangedRequest) GetListenPort() uint32

func (*StateChangedRequest) GetStatus

func (*StateChangedRequest) ProtoMessage

func (*StateChangedRequest) ProtoMessage()

func (*StateChangedRequest) Reset

func (m *StateChangedRequest) Reset()

func (*StateChangedRequest) String

func (m *StateChangedRequest) String() string

func (*StateChangedRequest) Validate

func (this *StateChangedRequest) Validate() error

func (*StateChangedRequest) XXX_DiscardUnknown

func (m *StateChangedRequest) XXX_DiscardUnknown()

func (*StateChangedRequest) XXX_Marshal

func (m *StateChangedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StateChangedRequest) XXX_Merge

func (m *StateChangedRequest) XXX_Merge(src proto.Message)

func (*StateChangedRequest) XXX_Size

func (m *StateChangedRequest) XXX_Size() int

func (*StateChangedRequest) XXX_Unmarshal

func (m *StateChangedRequest) XXX_Unmarshal(b []byte) error

type StateChangedResponse

type StateChangedResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

StateChangedResponse is a ServerMessage for StateChangedRequest acceptance.

func (*StateChangedResponse) Descriptor

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

func (*StateChangedResponse) ProtoMessage

func (*StateChangedResponse) ProtoMessage()

func (*StateChangedResponse) Reset

func (m *StateChangedResponse) Reset()

func (*StateChangedResponse) ServerMessageResponsePayload

func (m *StateChangedResponse) ServerMessageResponsePayload() isServerMessage_Payload

func (*StateChangedResponse) String

func (m *StateChangedResponse) String() string

func (*StateChangedResponse) Validate

func (this *StateChangedResponse) Validate() error

func (*StateChangedResponse) XXX_DiscardUnknown

func (m *StateChangedResponse) XXX_DiscardUnknown()

func (*StateChangedResponse) XXX_Marshal

func (m *StateChangedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StateChangedResponse) XXX_Merge

func (m *StateChangedResponse) XXX_Merge(src proto.Message)

func (*StateChangedResponse) XXX_Size

func (m *StateChangedResponse) XXX_Size() int

func (*StateChangedResponse) XXX_Unmarshal

func (m *StateChangedResponse) XXX_Unmarshal(b []byte) error

type StopActionRequest

type StopActionRequest struct {
	ActionId             string   `protobuf:"bytes,1,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*StopActionRequest) Descriptor

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

func (*StopActionRequest) GetActionId

func (m *StopActionRequest) GetActionId() string

func (*StopActionRequest) ProtoMessage

func (*StopActionRequest) ProtoMessage()

func (*StopActionRequest) Reset

func (m *StopActionRequest) Reset()

func (*StopActionRequest) ServerMessageRequestPayload

func (m *StopActionRequest) ServerMessageRequestPayload() isServerMessage_Payload

func (*StopActionRequest) String

func (m *StopActionRequest) String() string

func (*StopActionRequest) Validate

func (this *StopActionRequest) Validate() error

func (*StopActionRequest) XXX_DiscardUnknown

func (m *StopActionRequest) XXX_DiscardUnknown()

func (*StopActionRequest) XXX_Marshal

func (m *StopActionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StopActionRequest) XXX_Merge

func (m *StopActionRequest) XXX_Merge(src proto.Message)

func (*StopActionRequest) XXX_Size

func (m *StopActionRequest) XXX_Size() int

func (*StopActionRequest) XXX_Unmarshal

func (m *StopActionRequest) XXX_Unmarshal(b []byte) error

type StopActionResponse

type StopActionResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

StopActionResponse is an AgentMessage for StopActionRequest acceptance.

func (*StopActionResponse) AgentMessageResponsePayload

func (m *StopActionResponse) AgentMessageResponsePayload() isAgentMessage_Payload

func (*StopActionResponse) Descriptor

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

func (*StopActionResponse) ProtoMessage

func (*StopActionResponse) ProtoMessage()

func (*StopActionResponse) Reset

func (m *StopActionResponse) Reset()

func (*StopActionResponse) String

func (m *StopActionResponse) String() string

func (*StopActionResponse) Validate

func (this *StopActionResponse) Validate() error

func (*StopActionResponse) XXX_DiscardUnknown

func (m *StopActionResponse) XXX_DiscardUnknown()

func (*StopActionResponse) XXX_Marshal

func (m *StopActionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StopActionResponse) XXX_Merge

func (m *StopActionResponse) XXX_Merge(src proto.Message)

func (*StopActionResponse) XXX_Size

func (m *StopActionResponse) XXX_Size() int

func (*StopActionResponse) XXX_Unmarshal

func (m *StopActionResponse) XXX_Unmarshal(b []byte) error

type Type

type Type int32

Type represents Agent type. TODO Replace with inventory.AgentType. https://jira.percona.com/browse/PMM-3786

const (
	Type_TYPE_INVALID                      Type = 0
	Type_PMM_AGENT                         Type = 1
	Type_NODE_EXPORTER                     Type = 2
	Type_MYSQLD_EXPORTER                   Type = 3
	Type_MONGODB_EXPORTER                  Type = 4
	Type_POSTGRES_EXPORTER                 Type = 5
	Type_PROXYSQL_EXPORTER                 Type = 10
	Type_RDS_EXPORTER                      Type = 9
	Type_QAN_MYSQL_PERFSCHEMA_AGENT        Type = 6
	Type_QAN_MYSQL_SLOWLOG_AGENT           Type = 7
	Type_QAN_MONGODB_PROFILER_AGENT        Type = 8
	Type_QAN_POSTGRESQL_PGSTATEMENTS_AGENT Type = 11
)

func (Type) EnumDescriptor

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

func (Type) String

func (x Type) String() string

type UnimplementedAgentServer

type UnimplementedAgentServer struct {
}

UnimplementedAgentServer can be embedded to have forward compatible implementations.

func (*UnimplementedAgentServer) Connect

Jump to

Keyboard shortcuts

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