agentpb

package
v2.2.1+incompatible Latest Latest
Warning

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

 Go to latest Published: Jan 21, 2020 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,
}

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

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"`
	Stats                *CheckConnectionResponse_Stats `protobuf:"bytes,2,opt,name=stats,proto3" json:"stats,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) GetStats 

func (m *CheckConnectionResponse) GetStats() *CheckConnectionResponse_Stats

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 CheckConnectionResponse_Stats 

type CheckConnectionResponse_Stats struct {
	// A number of tables, 0 if unknown.
	TableCount           int32    `protobuf:"varint,1,opt,name=table_count,json=tableCount,proto3" json:"table_count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Stats contains various Service statistics.

func (*CheckConnectionResponse_Stats) Descriptor 

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

func (*CheckConnectionResponse_Stats) GetTableCount 

func (m *CheckConnectionResponse_Stats) GetTableCount() int32

func (*CheckConnectionResponse_Stats) ProtoMessage 

func (*CheckConnectionResponse_Stats) ProtoMessage()

func (*CheckConnectionResponse_Stats) Reset 

func (m *CheckConnectionResponse_Stats) Reset()

func (*CheckConnectionResponse_Stats) String 

func (m *CheckConnectionResponse_Stats) String() string

func (*CheckConnectionResponse_Stats) Validate 

func (this *CheckConnectionResponse_Stats) Validate() error

func (*CheckConnectionResponse_Stats) XXX_DiscardUnknown 

func (m *CheckConnectionResponse_Stats) XXX_DiscardUnknown()

func (*CheckConnectionResponse_Stats) XXX_Marshal 

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

func (*CheckConnectionResponse_Stats) XXX_Merge 

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

func (*CheckConnectionResponse_Stats) XXX_Size 

func (m *CheckConnectionResponse_Stats) XXX_Size() int

func (*CheckConnectionResponse_Stats) XXX_Unmarshal 

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

type ExampleFormat deprecated 

type ExampleFormat int32

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

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

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

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 `` // Deprecated: Do not use.
	/* 127-byte string literal not displayed */
	ExampleType ExampleType `protobuf:"varint,14,opt,name=example_type,json=exampleType,proto3,enum=agent.ExampleType" json:"example_type,omitempty"`
	// Indicates if query examples is too long and was truncated.
	IsTruncated bool `protobuf:"varint,24,opt,name=is_truncated,json=isTruncated,proto3" json:"is_truncated,omitempty"`
	// How many queries was with warnings in bucket.
	NumQueriesWithWarnings float32 `` /* 134-byte string literal not displayed */
	// How many queries was with error in bucket.
	NumQueriesWithErrors float32 `` /* 128-byte string literal not displayed */
	// List of errors: {code: count}.
	Errors map[uint64]uint64 `` /* 156-byte string literal not displayed */
	// Amount queries in this bucket.
	NumQueries float32 `protobuf:"fixed32,18,opt,name=num_queries,json=numQueries,proto3" json:"num_queries,omitempty"`
	// How many times query_time was found.
	MQueryTimeCnt float32 `protobuf:"fixed32,19,opt,name=m_query_time_cnt,json=mQueryTimeCnt,proto3" json:"m_query_time_cnt,omitempty"`
	// The statement execution time in seconds.
	MQueryTimeSum float32 `protobuf:"fixed32,20,opt,name=m_query_time_sum,json=mQueryTimeSum,proto3" json:"m_query_time_sum,omitempty"`
	// Smallest value of query_time in bucket.
	MQueryTimeMin float32 `protobuf:"fixed32,21,opt,name=m_query_time_min,json=mQueryTimeMin,proto3" json:"m_query_time_min,omitempty"`
	// Biggest value of query_time in bucket.
	MQueryTimeMax float32 `protobuf:"fixed32,22,opt,name=m_query_time_max,json=mQueryTimeMax,proto3" json:"m_query_time_max,omitempty"`
	// 99 percentile of value of query_time in bucket.
	MQueryTimeP99        float32  `protobuf:"fixed32,23,opt,name=m_query_time_p99,json=mQueryTimeP99,proto3" json:"m_query_time_p99,omitempty"`
	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 deprecated 

func (m *MetricsBucket_Common) GetExampleFormat() ExampleFormat

Deprecated: Do not use.

func (*MetricsBucket_Common) GetExampleType 

func (m *MetricsBucket_Common) GetExampleType() ExampleType

func (*MetricsBucket_Common) GetFingerprint 

func (m *MetricsBucket_Common) GetFingerprint() string

func (*MetricsBucket_Common) GetIsTruncated 

func (m *MetricsBucket_Common) GetIsTruncated() bool

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 metric was met.
	// - *_sum - how many times this metric was true.
	//
	MQcHitCnt float32 `protobuf:"fixed32,86,opt,name=m_qc_hit_cnt,json=mQcHitCnt,proto3" json:"m_qc_hit_cnt,omitempty"`
	// Query Cache hits.
	MQcHitSum    float32 `protobuf:"fixed32,87,opt,name=m_qc_hit_sum,json=mQcHitSum,proto3" json:"m_qc_hit_sum,omitempty"`
	MFullScanCnt float32 `protobuf:"fixed32,88,opt,name=m_full_scan_cnt,json=mFullScanCnt,proto3" json:"m_full_scan_cnt,omitempty"`
	// The query performed a full table scan.
	MFullScanSum float32 `protobuf:"fixed32,89,opt,name=m_full_scan_sum,json=mFullScanSum,proto3" json:"m_full_scan_sum,omitempty"`
	MFullJoinCnt float32 `protobuf:"fixed32,90,opt,name=m_full_join_cnt,json=mFullJoinCnt,proto3" json:"m_full_join_cnt,omitempty"`
	// The query performed a full join (a join without indexes).
	MFullJoinSum float32 `protobuf:"fixed32,91,opt,name=m_full_join_sum,json=mFullJoinSum,proto3" json:"m_full_join_sum,omitempty"`
	MTmpTableCnt float32 `protobuf:"fixed32,92,opt,name=m_tmp_table_cnt,json=mTmpTableCnt,proto3" json:"m_tmp_table_cnt,omitempty"`
	// The query created an implicit internal temporary table.
	MTmpTableSum       float32 `protobuf:"fixed32,93,opt,name=m_tmp_table_sum,json=mTmpTableSum,proto3" json:"m_tmp_table_sum,omitempty"`
	MTmpTableOnDiskCnt float32 `` /* 126-byte string literal not displayed */
	// The querys temporary table was stored on disk.
	MTmpTableOnDiskSum float32 `` /* 126-byte string literal not displayed */
	MFilesortCnt       float32 `protobuf:"fixed32,96,opt,name=m_filesort_cnt,json=mFilesortCnt,proto3" json:"m_filesort_cnt,omitempty"`
	// The query used a filesort.
	MFilesortSum       float32 `protobuf:"fixed32,97,opt,name=m_filesort_sum,json=mFilesortSum,proto3" json:"m_filesort_sum,omitempty"`
	MFilesortOnDiskCnt float32 `protobuf:"fixed32,98,opt,name=m_filesort_on_disk_cnt,json=mFilesortOnDiskCnt,proto3" json:"m_filesort_on_disk_cnt,omitempty"`
	// The filesort was performed on disk.
	MFilesortOnDiskSum      float32 `protobuf:"fixed32,99,opt,name=m_filesort_on_disk_sum,json=mFilesortOnDiskSum,proto3" json:"m_filesort_on_disk_sum,omitempty"`
	MSelectFullRangeJoinCnt float32 `` /* 142-byte string literal not displayed */
	// The number of joins that used a range search on a reference table.
	MSelectFullRangeJoinSum float32 `` /* 142-byte string literal not displayed */
	MSelectRangeCnt         float32 `protobuf:"fixed32,102,opt,name=m_select_range_cnt,json=mSelectRangeCnt,proto3" json:"m_select_range_cnt,omitempty"`
	// The number of joins that used ranges on the first table.
	MSelectRangeSum      float32 `protobuf:"fixed32,103,opt,name=m_select_range_sum,json=mSelectRangeSum,proto3" json:"m_select_range_sum,omitempty"`
	MSelectRangeCheckCnt float32 `` /* 131-byte string literal not displayed */
	// The number of joins without keys that check for key usage after each row.
	MSelectRangeCheckSum float32 `` /* 131-byte string literal not displayed */
	MSortRangeCnt        float32 `protobuf:"fixed32,106,opt,name=m_sort_range_cnt,json=mSortRangeCnt,proto3" json:"m_sort_range_cnt,omitempty"`
	// The number of sorts that were done using ranges.
	MSortRangeSum float32 `protobuf:"fixed32,107,opt,name=m_sort_range_sum,json=mSortRangeSum,proto3" json:"m_sort_range_sum,omitempty"`
	MSortRowsCnt  float32 `protobuf:"fixed32,108,opt,name=m_sort_rows_cnt,json=mSortRowsCnt,proto3" json:"m_sort_rows_cnt,omitempty"`
	// The number of sorted rows.
	MSortRowsSum float32 `protobuf:"fixed32,109,opt,name=m_sort_rows_sum,json=mSortRowsSum,proto3" json:"m_sort_rows_sum,omitempty"`
	MSortScanCnt float32 `protobuf:"fixed32,110,opt,name=m_sort_scan_cnt,json=mSortScanCnt,proto3" json:"m_sort_scan_cnt,omitempty"`
	// The number of sorts that were done by scanning the table.
	MSortScanSum    float32 `protobuf:"fixed32,111,opt,name=m_sort_scan_sum,json=mSortScanSum,proto3" json:"m_sort_scan_sum,omitempty"`
	MNoIndexUsedCnt float32 `protobuf:"fixed32,112,opt,name=m_no_index_used_cnt,json=mNoIndexUsedCnt,proto3" json:"m_no_index_used_cnt,omitempty"`
	// The number of queries without index.
	MNoIndexUsedSum     float32 `protobuf:"fixed32,113,opt,name=m_no_index_used_sum,json=mNoIndexUsedSum,proto3" json:"m_no_index_used_sum,omitempty"`
	MNoGoodIndexUsedCnt float32 `` /* 130-byte string literal not displayed */
	// The number of queries without good index.
	MNoGoodIndexUsedSum  float32  `` /* 130-byte string literal not displayed */
	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                 inventorypb.AgentType `protobuf:"varint,1,opt,name=type,proto3,enum=inventory.AgentType" json:"type,omitempty"`
	TemplateLeftDelim    string                `protobuf:"bytes,2,opt,name=template_left_delim,json=templateLeftDelim,proto3" json:"template_left_delim,omitempty"`
	TemplateRightDelim   string                `protobuf:"bytes,3,opt,name=template_right_delim,json=templateRightDelim,proto3" json:"template_right_delim,omitempty"`
	Args                 []string              `protobuf:"bytes,4,rep,name=args,proto3" json:"args,omitempty"`
	Env                  []string              `protobuf:"bytes,5,rep,name=env,proto3" json:"env,omitempty"`
	TextFiles            map[string]string     `` /* 176-byte string literal not displayed */
	RedactWords          []string              `protobuf:"bytes,7,rep,name=redact_words,json=redactWords,proto3" json:"redact_words,omitempty"`
	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) GetRedactWords 

func (m *SetStateRequest_AgentProcess) GetRedactWords() []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() inventorypb.AgentType

func (*SetStateRequest_AgentProcess) ProtoMessage 

func (*SetStateRequest_AgentProcess) ProtoMessage()

func (*SetStateRequest_AgentProcess) Reset 

func (m *SetStateRequest_AgentProcess) Reset()

func (*SetStateRequest_AgentProcess) String 

func (m *SetStateRequest_AgentProcess) String() 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 inventorypb.AgentType `protobuf:"varint,1,opt,name=type,proto3,enum=inventory.AgentType" json:"type,omitempty"`
	Dsn  string                `protobuf:"bytes,2,opt,name=dsn,proto3" json:"dsn,omitempty"`
	// Disables query examples for QAN Agents if true.
	DisableQueryExamples bool `protobuf:"varint,3,opt,name=disable_query_examples,json=disableQueryExamples,proto3" json:"disable_query_examples,omitempty"`
	// Instructs QAN Agents to rotate query log file or table at this size if > 0.
	MaxQueryLogSize      int64    `protobuf:"varint,4,opt,name=max_query_log_size,json=maxQueryLogSize,proto3" json:"max_query_log_size,omitempty"`
	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 (m *SetStateRequest_BuiltinAgent) GetDsn() string

func (*SetStateRequest_BuiltinAgent) GetMaxQueryLogSize 

func (m *SetStateRequest_BuiltinAgent) GetMaxQueryLogSize() int64

func (*SetStateRequest_BuiltinAgent) GetType 

func (m *SetStateRequest_BuiltinAgent) GetType() inventorypb.AgentType

func (*SetStateRequest_BuiltinAgent) ProtoMessage 

func (*SetStateRequest_BuiltinAgent) ProtoMessage()

func (*SetStateRequest_BuiltinAgent) Reset 

func (m *SetStateRequest_BuiltinAgent) Reset()

func (*SetStateRequest_BuiltinAgent) String 

func (m *SetStateRequest_BuiltinAgent) String() 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_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) 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 (m *StartActionRequest_MySQLExplainParams) GetDsn() string

func (*StartActionRequest_MySQLExplainParams) GetOutputFormat 

func (m *StartActionRequest_MySQLExplainParams) GetOutputFormat() MysqlExplainOutputFormat

func (*StartActionRequest_MySQLExplainParams) GetQuery 

func (m *StartActionRequest_MySQLExplainParams) GetQuery() string

func (*StartActionRequest_MySQLExplainParams) ProtoMessage 

func (*StartActionRequest_MySQLExplainParams) ProtoMessage()

func (*StartActionRequest_MySQLExplainParams) Reset 

func (m *StartActionRequest_MySQLExplainParams) Reset()

func (*StartActionRequest_MySQLExplainParams) String 

func (m *StartActionRequest_MySQLExplainParams) String() string

func (*StartActionRequest_MySQLExplainParams) Validate 

func (this *StartActionRequest_MySQLExplainParams) Validate() error

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 (m *StartActionRequest_MySQLExplainParams) XXX_Merge(src proto.Message)

func (*StartActionRequest_MySQLExplainParams) XXX_Size 

func (m *StartActionRequest_MySQLExplainParams) XXX_Size() int

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) Descriptor() ([]byte, []int)

func (*StartActionRequest_MySQLShowCreateTableParams) GetDsn 

func (m *StartActionRequest_MySQLShowCreateTableParams) GetDsn() string

func (*StartActionRequest_MySQLShowCreateTableParams) GetTable 

func (m *StartActionRequest_MySQLShowCreateTableParams) GetTable() string

func (*StartActionRequest_MySQLShowCreateTableParams) ProtoMessage 

func (*StartActionRequest_MySQLShowCreateTableParams) ProtoMessage()

func (*StartActionRequest_MySQLShowCreateTableParams) Reset 

func (m *StartActionRequest_MySQLShowCreateTableParams) Reset()

func (*StartActionRequest_MySQLShowCreateTableParams) String 

func (m *StartActionRequest_MySQLShowCreateTableParams) String() string

func (*StartActionRequest_MySQLShowCreateTableParams) Validate 

func (this *StartActionRequest_MySQLShowCreateTableParams) Validate() error

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 (m *StartActionRequest_MySQLShowCreateTableParams) XXX_Merge(src proto.Message)

func (*StartActionRequest_MySQLShowCreateTableParams) XXX_Size 

func (m *StartActionRequest_MySQLShowCreateTableParams) XXX_Size() int

func (*StartActionRequest_MySQLShowCreateTableParams) XXX_Unmarshal 

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

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

func (*StartActionRequest_MySQLShowIndexParams) GetTable 

func (m *StartActionRequest_MySQLShowIndexParams) GetTable() string

func (*StartActionRequest_MySQLShowIndexParams) ProtoMessage 

func (*StartActionRequest_MySQLShowIndexParams) ProtoMessage()

func (*StartActionRequest_MySQLShowIndexParams) Reset 

func (m *StartActionRequest_MySQLShowIndexParams) Reset()

func (*StartActionRequest_MySQLShowIndexParams) String 

func (m *StartActionRequest_MySQLShowIndexParams) String() string

func (*StartActionRequest_MySQLShowIndexParams) Validate 

func (this *StartActionRequest_MySQLShowIndexParams) Validate() error

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 (m *StartActionRequest_MySQLShowIndexParams) XXX_Merge(src proto.Message)

func (*StartActionRequest_MySQLShowIndexParams) XXX_Size 

func (m *StartActionRequest_MySQLShowIndexParams) XXX_Size() int

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) Descriptor() ([]byte, []int)

func (*StartActionRequest_MySQLShowTableStatusParams) GetDsn 

func (m *StartActionRequest_MySQLShowTableStatusParams) GetDsn() string

func (*StartActionRequest_MySQLShowTableStatusParams) GetTable 

func (m *StartActionRequest_MySQLShowTableStatusParams) GetTable() string

func (*StartActionRequest_MySQLShowTableStatusParams) ProtoMessage 

func (*StartActionRequest_MySQLShowTableStatusParams) ProtoMessage()

func (*StartActionRequest_MySQLShowTableStatusParams) Reset 

func (m *StartActionRequest_MySQLShowTableStatusParams) Reset()

func (*StartActionRequest_MySQLShowTableStatusParams) String 

func (m *StartActionRequest_MySQLShowTableStatusParams) String() string

func (*StartActionRequest_MySQLShowTableStatusParams) Validate 

func (this *StartActionRequest_MySQLShowTableStatusParams) Validate() error

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 (m *StartActionRequest_MySQLShowTableStatusParams) XXX_Merge(src proto.Message)

func (*StartActionRequest_MySQLShowTableStatusParams) XXX_Size 

func (m *StartActionRequest_MySQLShowTableStatusParams) XXX_Size() int

func (*StartActionRequest_MySQLShowTableStatusParams) XXX_Unmarshal 

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

type StartActionRequest_MysqlExplainParams 

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

type StartActionRequest_MysqlShowCreateTableParams 

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

type StartActionRequest_MysqlShowIndexParams 

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

type StartActionRequest_MysqlShowTableStatusParams 

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

type StartActionRequest_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) Descriptor() ([]byte, []int)

func (*StartActionRequest_PostgreSQLShowCreateTableParams) GetDsn 

func (m *StartActionRequest_PostgreSQLShowCreateTableParams) GetDsn() string

func (*StartActionRequest_PostgreSQLShowCreateTableParams) GetTable 

func (m *StartActionRequest_PostgreSQLShowCreateTableParams) GetTable() string

func (*StartActionRequest_PostgreSQLShowCreateTableParams) ProtoMessage 

func (*StartActionRequest_PostgreSQLShowCreateTableParams) ProtoMessage()

func (*StartActionRequest_PostgreSQLShowCreateTableParams) Reset 

func (m *StartActionRequest_PostgreSQLShowCreateTableParams) Reset()

func (*StartActionRequest_PostgreSQLShowCreateTableParams) String 

func (m *StartActionRequest_PostgreSQLShowCreateTableParams) String() string

func (*StartActionRequest_PostgreSQLShowCreateTableParams) Validate 

func (this *StartActionRequest_PostgreSQLShowCreateTableParams) Validate() error

func (*StartActionRequest_PostgreSQLShowCreateTableParams) XXX_DiscardUnknown 

func (m *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 (m *StartActionRequest_PostgreSQLShowCreateTableParams) XXX_Merge(src proto.Message)

func (*StartActionRequest_PostgreSQLShowCreateTableParams) XXX_Size 

func (m *StartActionRequest_PostgreSQLShowCreateTableParams) XXX_Size() int

func (*StartActionRequest_PostgreSQLShowCreateTableParams) XXX_Unmarshal 

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

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) Descriptor() ([]byte, []int)

func (*StartActionRequest_PostgreSQLShowIndexParams) GetDsn 

func (m *StartActionRequest_PostgreSQLShowIndexParams) GetDsn() string

func (*StartActionRequest_PostgreSQLShowIndexParams) GetTable 

func (m *StartActionRequest_PostgreSQLShowIndexParams) GetTable() string

func (*StartActionRequest_PostgreSQLShowIndexParams) ProtoMessage 

func (*StartActionRequest_PostgreSQLShowIndexParams) ProtoMessage()

func (*StartActionRequest_PostgreSQLShowIndexParams) Reset 

func (m *StartActionRequest_PostgreSQLShowIndexParams) Reset()

func (*StartActionRequest_PostgreSQLShowIndexParams) String 

func (m *StartActionRequest_PostgreSQLShowIndexParams) String() string

func (*StartActionRequest_PostgreSQLShowIndexParams) Validate 

func (this *StartActionRequest_PostgreSQLShowIndexParams) Validate() error

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 (m *StartActionRequest_PostgreSQLShowIndexParams) XXX_Merge(src proto.Message)

func (*StartActionRequest_PostgreSQLShowIndexParams) XXX_Size 

func (m *StartActionRequest_PostgreSQLShowIndexParams) XXX_Size() int

func (*StartActionRequest_PostgreSQLShowIndexParams) XXX_Unmarshal 

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

type StartActionRequest_PostgresqlShowCreateTableParams 

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

type StartActionRequest_PostgresqlShowIndexParams 

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

type 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 (m *StateChangedRequest) GetStatus() inventorypb.AgentStatus

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 UnimplementedAgentServer 

type UnimplementedAgentServer struct {
}

UnimplementedAgentServer can be embedded to have forward compatible implementations.

func (*UnimplementedAgentServer) Connect 

func (*UnimplementedAgentServer) Connect(srv Agent_ConnectServer) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

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