agentpb

package
v2.0.0-beta4+incompatible Latest Latest
Warning

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

 Go to latest Published: Jul 16, 2019 License: AGPL-3.0 Imports: 14 Imported by: 29

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var MysqlExplainOutputFormat_name = map[int32]string{
	0: "MYSQL_EXPLAIN_OUTPUT_FORMAT_INVALID",
	1: "MYSQL_EXPLAIN_OUTPUT_FORMAT_DEFAULT",
	2: "MYSQL_EXPLAIN_OUTPUT_FORMAT_JSON",
	3: "MYSQL_EXPLAIN_OUTPUT_FORMAT_TRADITIONAL_JSON",
}
View Source 
var MysqlExplainOutputFormat_value = map[string]int32{
	"MYSQL_EXPLAIN_OUTPUT_FORMAT_INVALID":          0,
	"MYSQL_EXPLAIN_OUTPUT_FORMAT_DEFAULT":          1,
	"MYSQL_EXPLAIN_OUTPUT_FORMAT_JSON":             2,
	"MYSQL_EXPLAIN_OUTPUT_FORMAT_TRADITIONAL_JSON": 3,
}
View Source 
var Type_name = map[int32]string{
	0:  "TYPE_INVALID",
	1:  "PMM_AGENT",
	2:  "NODE_EXPORTER",
	3:  "MYSQLD_EXPORTER",
	4:  "MONGODB_EXPORTER",
	5:  "POSTGRES_EXPORTER",
	10: "PROXYSQL_EXPORTER",
	9:  "RDS_EXPORTER",
	6:  "QAN_MYSQL_PERFSCHEMA_AGENT",
	7:  "QAN_MYSQL_SLOWLOG_AGENT",
	8:  "QAN_MONGODB_PROFILER_AGENT",
	11: "QAN_POSTGRESQL_PGSTATEMENTS_AGENT",
}
View Source 
var Type_value = map[string]int32{
	"TYPE_INVALID":                      0,
	"PMM_AGENT":                         1,
	"NODE_EXPORTER":                     2,
	"MYSQLD_EXPORTER":                   3,
	"MONGODB_EXPORTER":                  4,
	"POSTGRES_EXPORTER":                 5,
	"PROXYSQL_EXPORTER":                 10,
	"RDS_EXPORTER":                      9,
	"QAN_MYSQL_PERFSCHEMA_AGENT":        6,
	"QAN_MYSQL_SLOWLOG_AGENT":           7,
	"QAN_MONGODB_PROFILER_AGENT":        8,
	"QAN_POSTGRESQL_PGSTATEMENTS_AGENT": 11,
}

Functions

func AddAgentConnectMetadata 

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

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

func RegisterAgentServer 

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

func SendServerConnectMetadata 

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

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

Types

type ActionResultRequest 

type ActionResultRequest struct {
	// Unique action ID.
	ActionId string `protobuf:"bytes,1,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
	// New chunk of action output.
	Output []byte `protobuf:"bytes,3,opt,name=output,proto3" json:"output,omitempty"`
	// True if action is finished.
	Done bool `protobuf:"varint,4,opt,name=done,proto3" json:"done,omitempty"`
	// Error message if action failed.
	Error                string   `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*ActionResultRequest) AgentMessageRequestPayload 

func (m *ActionResultRequest) AgentMessageRequestPayload() isAgentMessage_Payload

func (*ActionResultRequest) Descriptor 

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

func (*ActionResultRequest) GetActionId 

func (m *ActionResultRequest) GetActionId() string

func (*ActionResultRequest) GetDone 

func (m *ActionResultRequest) GetDone() bool

func (*ActionResultRequest) GetError 

func (m *ActionResultRequest) GetError() string

func (*ActionResultRequest) GetOutput 

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

func (*ActionResultRequest) ProtoMessage 

func (*ActionResultRequest) ProtoMessage()

func (*ActionResultRequest) Reset 

func (m *ActionResultRequest) Reset()

func (*ActionResultRequest) String 

func (m *ActionResultRequest) String() string

func (*ActionResultRequest) Validate 

func (this *ActionResultRequest) Validate() error

func (*ActionResultRequest) XXX_DiscardUnknown 

func (m *ActionResultRequest) XXX_DiscardUnknown()

func (*ActionResultRequest) XXX_Marshal 

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

func (*ActionResultRequest) XXX_Merge 

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

func (*ActionResultRequest) XXX_Size 

func (m *ActionResultRequest) XXX_Size() int

func (*ActionResultRequest) XXX_Unmarshal 

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

type ActionResultResponse 

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

ActionResultResponse is an ServerMessage for ActionResultRequest acceptance.

func (*ActionResultResponse) Descriptor 

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

func (*ActionResultResponse) ProtoMessage 

func (*ActionResultResponse) ProtoMessage()

func (*ActionResultResponse) Reset 

func (m *ActionResultResponse) Reset()

func (*ActionResultResponse) ServerMessageResponsePayload 

func (m *ActionResultResponse) ServerMessageResponsePayload() isServerMessage_Payload

func (*ActionResultResponse) String 

func (m *ActionResultResponse) String() string

func (*ActionResultResponse) Validate 

func (this *ActionResultResponse) Validate() error

func (*ActionResultResponse) XXX_DiscardUnknown 

func (m *ActionResultResponse) XXX_DiscardUnknown()

func (*ActionResultResponse) XXX_Marshal 

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

func (*ActionResultResponse) XXX_Merge 

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

func (*ActionResultResponse) XXX_Size 

func (m *ActionResultResponse) XXX_Size() int

func (*ActionResultResponse) XXX_Unmarshal 

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

type AgentClient 

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

AgentClient is the client API for Agent service.

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

func NewAgentClient 

func NewAgentClient(cc *grpc.ClientConn) AgentClient

type AgentConnectMetadata 

type AgentConnectMetadata struct {
	ID          string
	Version     string
	MetricsPort uint16
}

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

func ReceiveAgentConnectMetadata 

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

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

type AgentMessage 

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

func (*AgentMessage) Descriptor 

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

func (*AgentMessage) GetActionResult 

func (m *AgentMessage) GetActionResult() *ActionResultRequest

func (*AgentMessage) GetCheckConnection 

func (m *AgentMessage) GetCheckConnection() *CheckConnectionResponse

func (*AgentMessage) GetId 

func (m *AgentMessage) GetId() uint32

func (*AgentMessage) GetPayload 

func (m *AgentMessage) GetPayload() isAgentMessage_Payload

func (*AgentMessage) GetPing 

func (m *AgentMessage) GetPing() *Ping

func (*AgentMessage) GetPong 

func (m *AgentMessage) GetPong() *Pong

func (*AgentMessage) GetQanCollect 

func (m *AgentMessage) GetQanCollect() *QANCollectRequest

func (*AgentMessage) GetSetState 

func (m *AgentMessage) GetSetState() *SetStateResponse

func (*AgentMessage) GetStartAction 

func (m *AgentMessage) GetStartAction() *StartActionResponse

func (*AgentMessage) GetStateChanged 

func (m *AgentMessage) GetStateChanged() *StateChangedRequest

func (*AgentMessage) GetStopAction 

func (m *AgentMessage) GetStopAction() *StopActionResponse

func (*AgentMessage) ProtoMessage 

func (*AgentMessage) ProtoMessage()

func (*AgentMessage) Reset 

func (m *AgentMessage) Reset()

func (*AgentMessage) String 

func (m *AgentMessage) String() string

func (*AgentMessage) Validate 

func (this *AgentMessage) Validate() error

func (*AgentMessage) XXX_DiscardUnknown 

func (m *AgentMessage) XXX_DiscardUnknown()

func (*AgentMessage) XXX_Marshal 

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

func (*AgentMessage) XXX_Merge 

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

func (*AgentMessage) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*AgentMessage) XXX_Size 

func (m *AgentMessage) XXX_Size() int

func (*AgentMessage) XXX_Unmarshal 

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

type AgentMessage_ActionResult 

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

type AgentMessage_CheckConnection 

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

type AgentMessage_Ping 

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

type AgentMessage_Pong 

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

type AgentMessage_QanCollect 

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

type AgentMessage_SetState 

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

type AgentMessage_StartAction 

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

type AgentMessage_StateChanged 

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

type AgentMessage_StopAction 

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

type AgentParams 

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

AgentParams is a common interface for AgentProcess and BuiltinAgent parameters.

type AgentRequestPayload 

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

AgentRequestPayload represents agent's request payload.

type AgentResponsePayload 

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

AgentResponsePayload represents agent's response payload.

type AgentServer 

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

AgentServer is the server API for Agent service.

type Agent_ConnectClient 

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

type Agent_ConnectServer 

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

type CheckConnectionRequest 

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

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

func (*CheckConnectionRequest) Descriptor 

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

func (*CheckConnectionRequest) GetDsn 

func (m *CheckConnectionRequest) GetDsn() string

func (*CheckConnectionRequest) GetTimeout 

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

func (*CheckConnectionRequest) GetType 

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

CheckConnectionResponse is an AgentMessage containing a result of connection check.

func (*CheckConnectionResponse) AgentMessageResponsePayload 

func (m *CheckConnectionResponse) AgentMessageResponsePayload() isAgentMessage_Payload

func (*CheckConnectionResponse) Descriptor 

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

func (*CheckConnectionResponse) GetError 

func (m *CheckConnectionResponse) GetError() string

func (*CheckConnectionResponse) ProtoMessage 

func (*CheckConnectionResponse) ProtoMessage()

func (*CheckConnectionResponse) Reset 

func (m *CheckConnectionResponse) Reset()

func (*CheckConnectionResponse) String 

func (m *CheckConnectionResponse) String() string

func (*CheckConnectionResponse) Validate 

func (this *CheckConnectionResponse) Validate() error

func (*CheckConnectionResponse) XXX_DiscardUnknown 

func (m *CheckConnectionResponse) XXX_DiscardUnknown()

func (*CheckConnectionResponse) XXX_Marshal 

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

func (*CheckConnectionResponse) XXX_Merge 

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

func (*CheckConnectionResponse) XXX_Size 

func (m *CheckConnectionResponse) XXX_Size() int

func (*CheckConnectionResponse) XXX_Unmarshal 

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

type 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 {
	Message              *qanpb.CollectRequest `protobuf:"bytes,1,opt,name=message,proto3" json:"message,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) GetMessage 

func (m *QANCollectRequest) GetMessage() *qanpb.CollectRequest

func (*QANCollectRequest) ProtoMessage 

func (*QANCollectRequest) ProtoMessage()

func (*QANCollectRequest) Reset 

func (m *QANCollectRequest) Reset()

func (*QANCollectRequest) String 

func (m *QANCollectRequest) String() string

func (*QANCollectRequest) Validate 

func (this *QANCollectRequest) Validate() error

func (*QANCollectRequest) XXX_DiscardUnknown 

func (m *QANCollectRequest) XXX_DiscardUnknown()

func (*QANCollectRequest) XXX_Marshal 

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

func (*QANCollectRequest) XXX_Merge 

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

func (*QANCollectRequest) XXX_Size 

func (m *QANCollectRequest) XXX_Size() int

func (*QANCollectRequest) XXX_Unmarshal 

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

type QANCollectResponse 

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

QANCollectResponse is a ServerMessage for QAN data acceptance.

func (*QANCollectResponse) Descriptor 

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

func (*QANCollectResponse) ProtoMessage 

func (*QANCollectResponse) ProtoMessage()

func (*QANCollectResponse) Reset 

func (m *QANCollectResponse) Reset()

func (*QANCollectResponse) ServerMessageResponsePayload 

func (m *QANCollectResponse) ServerMessageResponsePayload() isServerMessage_Payload

func (*QANCollectResponse) String 

func (m *QANCollectResponse) String() string

func (*QANCollectResponse) Validate 

func (this *QANCollectResponse) Validate() error

func (*QANCollectResponse) XXX_DiscardUnknown 

func (m *QANCollectResponse) XXX_DiscardUnknown()

func (*QANCollectResponse) XXX_Marshal 

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

func (*QANCollectResponse) XXX_Merge 

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

func (*QANCollectResponse) XXX_Size 

func (m *QANCollectResponse) XXX_Size() int

func (*QANCollectResponse) XXX_Unmarshal 

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

type ServerConnectMetadata 

type ServerConnectMetadata struct {
	AgentRunsOnNodeID string
	ServerVersion     string
}

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

func ReceiveServerConnectMetadata 

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

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

type ServerMessage 

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

func (*ServerMessage) Descriptor 

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

func (*ServerMessage) GetActionResult 

func (m *ServerMessage) GetActionResult() *ActionResultResponse

func (*ServerMessage) GetCheckConnection 

func (m *ServerMessage) GetCheckConnection() *CheckConnectionRequest

func (*ServerMessage) GetId 

func (m *ServerMessage) GetId() uint32

func (*ServerMessage) GetPayload 

func (m *ServerMessage) GetPayload() isServerMessage_Payload

func (*ServerMessage) GetPing 

func (m *ServerMessage) GetPing() *Ping

func (*ServerMessage) GetPong 

func (m *ServerMessage) GetPong() *Pong

func (*ServerMessage) GetQanCollect 

func (m *ServerMessage) GetQanCollect() *QANCollectResponse

func (*ServerMessage) GetSetState 

func (m *ServerMessage) GetSetState() *SetStateRequest

func (*ServerMessage) GetStartAction 

func (m *ServerMessage) GetStartAction() *StartActionRequest

func (*ServerMessage) GetStateChanged 

func (m *ServerMessage) GetStateChanged() *StateChangedResponse

func (*ServerMessage) GetStopAction 

func (m *ServerMessage) GetStopAction() *StopActionRequest

func (*ServerMessage) ProtoMessage 

func (*ServerMessage) ProtoMessage()

func (*ServerMessage) Reset 

func (m *ServerMessage) Reset()

func (*ServerMessage) String 

func (m *ServerMessage) String() string

func (*ServerMessage) Validate 

func (this *ServerMessage) Validate() error

func (*ServerMessage) XXX_DiscardUnknown 

func (m *ServerMessage) XXX_DiscardUnknown()

func (*ServerMessage) XXX_Marshal 

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

func (*ServerMessage) XXX_Merge 

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

func (*ServerMessage) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ServerMessage) XXX_Size 

func (m *ServerMessage) XXX_Size() int

func (*ServerMessage) XXX_Unmarshal 

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

type ServerMessage_ActionResult 

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

type ServerMessage_CheckConnection 

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

type ServerMessage_Ping 

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

type ServerMessage_Pong 

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

type ServerMessage_QanCollect 

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

type ServerMessage_SetState 

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

type ServerMessage_StartAction 

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

type ServerMessage_StateChanged 

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

type ServerMessage_StopAction 

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

type ServerRequestPayload 

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

ServerRequestPayload represents server's request payload.

type ServerResponsePayload 

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

ServerResponsePayload represents server's response payload.

type SetStateRequest 

type SetStateRequest struct {
	AgentProcesses       map[string]*SetStateRequest_AgentProcess `` /* 191-byte string literal not displayed */
	BuiltinAgents        map[string]*SetStateRequest_BuiltinAgent `` /* 188-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                 `json:"-"`
	XXX_unrecognized     []byte                                   `json:"-"`
	XXX_sizecache        int32                                    `json:"-"`
}

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

func (*SetStateRequest) Descriptor 

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

func (*SetStateRequest) GetAgentProcesses 

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

func (*SetStateRequest) GetBuiltinAgents 

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

func (*SetStateRequest) ProtoMessage 

func (*SetStateRequest) ProtoMessage()

func (*SetStateRequest) Reset 

func (m *SetStateRequest) Reset()

func (*SetStateRequest) ServerMessageRequestPayload 

func (m *SetStateRequest) ServerMessageRequestPayload() isServerMessage_Payload

func (*SetStateRequest) String 

func (m *SetStateRequest) String() string

func (*SetStateRequest) Validate 

func (this *SetStateRequest) Validate() error

func (*SetStateRequest) XXX_DiscardUnknown 

func (m *SetStateRequest) XXX_DiscardUnknown()

func (*SetStateRequest) XXX_Marshal 

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

func (*SetStateRequest) XXX_Merge 

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

func (*SetStateRequest) XXX_Size 

func (m *SetStateRequest) XXX_Size() int

func (*SetStateRequest) XXX_Unmarshal 

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

type SetStateRequest_AgentProcess 

type SetStateRequest_AgentProcess struct {
	Type                 Type              `protobuf:"varint,1,opt,name=type,proto3,enum=agent.Type" json:"type,omitempty"`
	TemplateLeftDelim    string            `protobuf:"bytes,2,opt,name=template_left_delim,json=templateLeftDelim,proto3" json:"template_left_delim,omitempty"`
	TemplateRightDelim   string            `protobuf:"bytes,3,opt,name=template_right_delim,json=templateRightDelim,proto3" json:"template_right_delim,omitempty"`
	Args                 []string          `protobuf:"bytes,4,rep,name=args,proto3" json:"args,omitempty"`
	Env                  []string          `protobuf:"bytes,5,rep,name=env,proto3" json:"env,omitempty"`
	TextFiles            map[string]string `` /* 176-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

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

func (*SetStateRequest_AgentProcess) Descriptor 

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

func (*SetStateRequest_AgentProcess) GetArgs 

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

func (*SetStateRequest_AgentProcess) GetEnv 

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

func (*SetStateRequest_AgentProcess) GetTemplateLeftDelim 

func (m *SetStateRequest_AgentProcess) GetTemplateLeftDelim() string

func (*SetStateRequest_AgentProcess) GetTemplateRightDelim 

func (m *SetStateRequest_AgentProcess) GetTemplateRightDelim() string

func (*SetStateRequest_AgentProcess) GetTextFiles 

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

func (*SetStateRequest_AgentProcess) GetType 

func (m *SetStateRequest_AgentProcess) GetType() Type

func (*SetStateRequest_AgentProcess) ProtoMessage 

func (*SetStateRequest_AgentProcess) ProtoMessage()

func (*SetStateRequest_AgentProcess) Reset 

func (m *SetStateRequest_AgentProcess) Reset()

func (*SetStateRequest_AgentProcess) String 

func (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                 Type     `protobuf:"varint,1,opt,name=type,proto3,enum=agent.Type" json:"type,omitempty"`
	Dsn                  string   `protobuf:"bytes,2,opt,name=dsn,proto3" json:"dsn,omitempty"`
	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) GetDsn 

func (m *SetStateRequest_BuiltinAgent) GetDsn() string

func (*SetStateRequest_BuiltinAgent) GetType 

func (m *SetStateRequest_BuiltinAgent) GetType() Type

func (*SetStateRequest_BuiltinAgent) ProtoMessage 

func (*SetStateRequest_BuiltinAgent) ProtoMessage()

func (*SetStateRequest_BuiltinAgent) Reset 

func (m *SetStateRequest_BuiltinAgent) Reset()

func (*SetStateRequest_BuiltinAgent) String 

func (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_PtSummaryParams
	//	*StartActionRequest_PtMysqlSummaryParams
	//	*StartActionRequest_MysqlExplainParams
	//	*StartActionRequest_MysqlShowCreateTableParams
	//	*StartActionRequest_MysqlShowTableStatusParams
	//	*StartActionRequest_MysqlShowIndexParams
	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) GetPtMysqlSummaryParams 

func (m *StartActionRequest) GetPtMysqlSummaryParams() *StartActionRequest_ProcessParams

func (*StartActionRequest) GetPtSummaryParams 

func (m *StartActionRequest) GetPtSummaryParams() *StartActionRequest_ProcessParams

func (*StartActionRequest) ProtoMessage 

func (*StartActionRequest) ProtoMessage()

func (*StartActionRequest) Reset 

func (m *StartActionRequest) Reset()

func (*StartActionRequest) ServerMessageRequestPayload 

func (m *StartActionRequest) ServerMessageRequestPayload() isServerMessage_Payload

func (*StartActionRequest) String 

func (m *StartActionRequest) String() string

func (*StartActionRequest) Validate 

func (this *StartActionRequest) Validate() error

func (*StartActionRequest) XXX_DiscardUnknown 

func (m *StartActionRequest) XXX_DiscardUnknown()

func (*StartActionRequest) XXX_Marshal 

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

func (*StartActionRequest) XXX_Merge 

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

func (*StartActionRequest) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*StartActionRequest) XXX_Size 

func (m *StartActionRequest) XXX_Size() int

func (*StartActionRequest) XXX_Unmarshal 

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

type StartActionRequest_MySQLExplainParams 

type StartActionRequest_MySQLExplainParams struct {
	Dsn                  string                   `protobuf:"bytes,1,opt,name=dsn,proto3" json:"dsn,omitempty"`
	Query                string                   `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	OutputFormat         MysqlExplainOutputFormat `` /* 134-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

MySQLExplainParams describes MySQL EXPLAIN action parameters.

func (*StartActionRequest_MySQLExplainParams) Descriptor 

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

func (*StartActionRequest_MySQLExplainParams) GetDsn 

func (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,8,opt,name=mysql_explain_params,json=mysqlExplainParams,proto3,oneof"`
}

type StartActionRequest_MysqlShowCreateTableParams 

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

type StartActionRequest_MysqlShowIndexParams 

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

type StartActionRequest_MysqlShowTableStatusParams 

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

type StartActionRequest_ProcessParams 

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

ProcessParams describes parameters for all process actions.

func (*StartActionRequest_ProcessParams) Descriptor 

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

func (*StartActionRequest_ProcessParams) GetArgs 

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

func (*StartActionRequest_ProcessParams) ProtoMessage 

func (*StartActionRequest_ProcessParams) ProtoMessage()

func (*StartActionRequest_ProcessParams) Reset 

func (m *StartActionRequest_ProcessParams) Reset()

func (*StartActionRequest_ProcessParams) String 

func (m *StartActionRequest_ProcessParams) String() string

func (*StartActionRequest_ProcessParams) Validate 

func (this *StartActionRequest_ProcessParams) Validate() error

func (*StartActionRequest_ProcessParams) XXX_DiscardUnknown 

func (m *StartActionRequest_ProcessParams) XXX_DiscardUnknown()

func (*StartActionRequest_ProcessParams) XXX_Marshal 

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

func (*StartActionRequest_ProcessParams) XXX_Merge 

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

func (*StartActionRequest_ProcessParams) XXX_Size 

func (m *StartActionRequest_ProcessParams) XXX_Size() int

func (*StartActionRequest_ProcessParams) XXX_Unmarshal 

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

type StartActionRequest_PtMysqlSummaryParams 

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

type StartActionRequest_PtSummaryParams 

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

type StartActionResponse 

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

StartActionResponse is an AgentMessage for StartActionRequest acceptance.

func (*StartActionResponse) AgentMessageResponsePayload 

func (m *StartActionResponse) AgentMessageResponsePayload() isAgentMessage_Payload

func (*StartActionResponse) Descriptor 

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

func (*StartActionResponse) ProtoMessage 

func (*StartActionResponse) ProtoMessage()

func (*StartActionResponse) Reset 

func (m *StartActionResponse) Reset()

func (*StartActionResponse) String 

func (m *StartActionResponse) String() string

func (*StartActionResponse) Validate 

func (this *StartActionResponse) Validate() error

func (*StartActionResponse) XXX_DiscardUnknown 

func (m *StartActionResponse) XXX_DiscardUnknown()

func (*StartActionResponse) XXX_Marshal 

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

func (*StartActionResponse) XXX_Merge 

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

func (*StartActionResponse) XXX_Size 

func (m *StartActionResponse) XXX_Size() int

func (*StartActionResponse) XXX_Unmarshal 

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

type StateChangedRequest 

type StateChangedRequest struct {
	AgentId              string                  `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	Status               inventorypb.AgentStatus `protobuf:"varint,2,opt,name=status,proto3,enum=inventory.AgentStatus" json:"status,omitempty"`
	ListenPort           uint32                  `protobuf:"varint,3,opt,name=listen_port,json=listenPort,proto3" json:"listen_port,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

StateChangedRequest is an AgentMessage describing actual agent status.

func (*StateChangedRequest) AgentMessageRequestPayload 

func (m *StateChangedRequest) AgentMessageRequestPayload() isAgentMessage_Payload

func (*StateChangedRequest) Descriptor 

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

func (*StateChangedRequest) GetAgentId 

func (m *StateChangedRequest) GetAgentId() string

func (*StateChangedRequest) GetListenPort 

func (m *StateChangedRequest) GetListenPort() uint32

func (*StateChangedRequest) GetStatus 

func (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 Type 

type Type int32

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

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

func (Type) EnumDescriptor 

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

func (Type) String 

func (x Type) String() string

type UnimplementedAgentServer 

type UnimplementedAgentServer struct {
}

UnimplementedAgentServer can be embedded to have forward compatible implementations.

func (*UnimplementedAgentServer) Connect 

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.