agentpb

package
v2.0.0-alpha5+incompat... Latest Latest
Warning

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

 Go to latest Published: May 23, 2019 License: AGPL-3.0 Imports: 11 Imported by: 0

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",
}
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,
}
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",
	6: "QAN_MYSQL_PERFSCHEMA_AGENT",
	7: "QAN_MYSQL_SLOWLOG_AGENT",
	8: "QAN_MONGODB_PROFILER_AGENT",
	9: "RDS_EXPORTER",
}
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,
	"QAN_MYSQL_PERFSCHEMA_AGENT": 6,
	"QAN_MYSQL_SLOWLOG_AGENT":    7,
	"QAN_MONGODB_PROFILER_AGENT": 8,
	"RDS_EXPORTER":               9,
}

Functions

func AddAgentConnectMetadata 

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

AddAgentConnectMetadata adds metadata to pmm-agent's Connect RPC call. Used by pmm-agent.

func RegisterAgentServer 

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

func SendAgentServerMetadata 

func SendAgentServerMetadata(stream grpc.ServerStream, md *AgentServerMetadata) error

SendAgentServerMetadata sends metadata to pmm-agent. 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
}

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

func GetAgentConnectMetadata 

func GetAgentConnectMetadata(ctx context.Context) AgentConnectMetadata

GetAgentConnectMetadata returns 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 AgentServerMetadata 

type AgentServerMetadata struct {
	AgentRunsOnNodeID string
	ServerVersion     string
}

AgentServerMetadata represents metadata sent by pmm-managed to pmm-agent.

func GetAgentServerMetadata 

func GetAgentServerMetadata(stream grpc.ClientStream) (AgentServerMetadata, error)

GetAgentServerMetadata receives metadata from pmm-managed. Used by pmm-agent.

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.
	Dsn                  string   `protobuf:"bytes,2,opt,name=dsn,proto3" json:"dsn,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) 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 is 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 check request.

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
	MysqlExplainOutputFormat_MYSQL_EXPLAIN_OUTPUT_FORMAT_DEFAULT MysqlExplainOutputFormat = 1
	MysqlExplainOutputFormat_MYSQL_EXPLAIN_OUTPUT_FORMAT_JSON    MysqlExplainOutputFormat = 2
)

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 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"`
	Type     managementpb.ActionType `protobuf:"varint,2,opt,name=type,proto3,enum=management.ActionType" json:"type,omitempty"`
	// Types that are valid to be assigned to Params:
	//	*StartActionRequest_ProcessParams_
	//	*StartActionRequest_MysqlExplainParams
	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) GetParams 

func (m *StartActionRequest) GetParams() isStartActionRequest_Params

func (*StartActionRequest) GetProcessParams 

func (m *StartActionRequest) GetProcessParams() *StartActionRequest_ProcessParams

func (*StartActionRequest) GetType 

func (m *StartActionRequest) GetType() managementpb.ActionType

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_MysqlExplainParams 

type StartActionRequest_MysqlExplainParams struct {
	MysqlExplainParams *StartActionRequest_MySQLExplainParams `protobuf:"bytes,4,opt,name=mysql_explain_params,json=mysqlExplainParams,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_ProcessParams_ 

type StartActionRequest_ProcessParams_ struct {
	ProcessParams *StartActionRequest_ProcessParams `protobuf:"bytes,3,opt,name=process_params,json=processParams,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_QAN_MYSQL_PERFSCHEMA_AGENT Type = 6
	Type_QAN_MYSQL_SLOWLOG_AGENT    Type = 7
	Type_QAN_MONGODB_PROFILER_AGENT Type = 8
	Type_RDS_EXPORTER               Type = 9
)

func (Type) EnumDescriptor 

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

func (Type) String 

func (x Type) String() string

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.