pulse_go_proto

Documentation

Index

• type AgentId
  • func (*AgentId) Descriptor() ([]byte, []int)
  • func (m *AgentId) GetContainerId() string
  • func (m *AgentId) GetHostName() string
  • func (m *AgentId) GetPrefix() string
  • func (m *AgentId) GetProcessId() string
  • func (*AgentId) ProtoMessage()
  • func (m *AgentId) Reset()
  • func (m *AgentId) String() string
  • func (m *AgentId) XXX_DiscardUnknown()
  • func (m *AgentId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *AgentId) XXX_Merge(src proto.Message)
  • func (m *AgentId) XXX_Size() int
  • func (m *AgentId) XXX_Unmarshal(b []byte) error
• type Msg
  • func (*Msg) Descriptor() ([]byte, []int)
  • func (m *Msg) GetAgentId() *AgentId
  • func (m *Msg) GetAgentLogsDir() string
  • func (m *Msg) GetAgentTransferredBytes() int64
  • func (m *Msg) GetAgentTransferredListBytes() int64
  • func (m *Msg) GetAgentUptimeMs() int64
  • func (m *Msg) GetAgentVersion() string
  • func (m *Msg) GetCopyInternalRetries() int64
  • func (m *Msg) GetCopyOpenMs() int64
  • func (m *Msg) GetCopyReadMs() int64
  • func (m *Msg) GetCopySeekMs() int64
  • func (m *Msg) GetCopyStatMs() int64
  • func (m *Msg) GetCopyWriteMs() int64
  • func (m *Msg) GetListDirOpenMs() int64
  • func (m *Msg) GetListDirReadMs() int64
  • func (m *Msg) GetListDirWriteMs() int64
  • func (m *Msg) GetListFileWriteMs() int64
  • func (*Msg) ProtoMessage()
  • func (m *Msg) Reset()
  • func (m *Msg) String() string
  • func (m *Msg) XXX_DiscardUnknown()
  • func (m *Msg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Msg) XXX_Merge(src proto.Message)
  • func (m *Msg) XXX_Size() int
  • func (m *Msg) XXX_Unmarshal(b []byte) error

Types

type AgentId

type AgentId struct {
	HostName             string   `protobuf:"bytes,1,opt,name=host_name,json=hostName,proto3" json:"host_name,omitempty"`
	ProcessId            string   `protobuf:"bytes,2,opt,name=process_id,json=processId,proto3" json:"process_id,omitempty"`
	Prefix               string   `protobuf:"bytes,3,opt,name=prefix,proto3" json:"prefix,omitempty"`
	ContainerId          string   `protobuf:"bytes,4,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

This message stores a unique identifier for each agent. The DCP can use this to separate each agent and monitor future behaviors.

func (*AgentId) Descriptor

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

func (*AgentId) GetContainerId

func (m *AgentId) GetContainerId() string

func (*AgentId) GetHostName

func (m *AgentId) GetHostName() string

func (*AgentId) GetPrefix

func (m *AgentId) GetPrefix() string

func (*AgentId) GetProcessId

func (m *AgentId) GetProcessId() string

func (*AgentId) ProtoMessage

func (*AgentId) ProtoMessage()

func (*AgentId) Reset

func (m *AgentId) Reset()

func (*AgentId) String

func (m *AgentId) String() string

func (*AgentId) XXX_DiscardUnknown

func (m *AgentId) XXX_DiscardUnknown()

func (*AgentId) XXX_Marshal

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

func (*AgentId) XXX_Merge

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

func (*AgentId) XXX_Size

func (m *AgentId) XXX_Size() int

func (*AgentId) XXX_Unmarshal

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

type Msg

type Msg struct {
	AgentId       *AgentId `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	AgentVersion  string   `protobuf:"bytes,3,opt,name=agent_version,json=agentVersion,proto3" json:"agent_version,omitempty"`
	AgentLogsDir  string   `protobuf:"bytes,4,opt,name=agent_logs_dir,json=agentLogsDir,proto3" json:"agent_logs_dir,omitempty"`
	AgentUptimeMs int64    `protobuf:"varint,7,opt,name=agent_uptime_ms,json=agentUptimeMs,proto3" json:"agent_uptime_ms,omitempty"`
	// Below measurements are accumulated and reset with each pulse sent.
	AgentTransferredBytes int64 `` /* 127-byte string literal not displayed */
	// Bytes the Agent wrote during listing.
	AgentTransferredListBytes int64 `` /* 141-byte string literal not displayed */
	CopyOpenMs                int64 `protobuf:"varint,9,opt,name=copy_open_ms,json=copyOpenMs,proto3" json:"copy_open_ms,omitempty"`
	CopyStatMs                int64 `protobuf:"varint,10,opt,name=copy_stat_ms,json=copyStatMs,proto3" json:"copy_stat_ms,omitempty"`
	CopySeekMs                int64 `protobuf:"varint,11,opt,name=copy_seek_ms,json=copySeekMs,proto3" json:"copy_seek_ms,omitempty"`
	CopyReadMs                int64 `protobuf:"varint,12,opt,name=copy_read_ms,json=copyReadMs,proto3" json:"copy_read_ms,omitempty"`
	CopyWriteMs               int64 `protobuf:"varint,13,opt,name=copy_write_ms,json=copyWriteMs,proto3" json:"copy_write_ms,omitempty"`
	CopyInternalRetries       int64 `protobuf:"varint,14,opt,name=copy_internal_retries,json=copyInternalRetries,proto3" json:"copy_internal_retries,omitempty"`
	// Duration in millis spent opening directories.
	ListDirOpenMs int64 `protobuf:"varint,15,opt,name=list_dir_open_ms,json=listDirOpenMs,proto3" json:"list_dir_open_ms,omitempty"`
	// Duration in millis spent reading directories.
	ListDirReadMs int64 `protobuf:"varint,16,opt,name=list_dir_read_ms,json=listDirReadMs,proto3" json:"list_dir_read_ms,omitempty"`
	// Duration in millis spent writing file listing output.
	ListFileWriteMs int64 `protobuf:"varint,17,opt,name=list_file_write_ms,json=listFileWriteMs,proto3" json:"list_file_write_ms,omitempty"`
	// Duration in millis spent writing unexplored dir listing output.
	ListDirWriteMs       int64    `protobuf:"varint,18,opt,name=list_dir_write_ms,json=listDirWriteMs,proto3" json:"list_dir_write_ms,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The Agent periodically sends this msg to the DCP. The DCP uses this info to know that the Agent is alive, and to expose info about that Agent.

func (*Msg) Descriptor

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

func (*Msg) GetAgentId

func (m *Msg) GetAgentId() *AgentId

func (*Msg) GetAgentLogsDir

func (m *Msg) GetAgentLogsDir() string

func (*Msg) GetAgentTransferredBytes

func (m *Msg) GetAgentTransferredBytes() int64

func (*Msg) GetAgentTransferredListBytes

func (m *Msg) GetAgentTransferredListBytes() int64

func (*Msg) GetAgentUptimeMs

func (m *Msg) GetAgentUptimeMs() int64

func (*Msg) GetAgentVersion

func (m *Msg) GetAgentVersion() string

func (*Msg) GetCopyInternalRetries

func (m *Msg) GetCopyInternalRetries() int64

func (*Msg) GetCopyOpenMs

func (m *Msg) GetCopyOpenMs() int64

func (*Msg) GetCopyReadMs

func (m *Msg) GetCopyReadMs() int64

func (*Msg) GetCopySeekMs

func (m *Msg) GetCopySeekMs() int64

func (*Msg) GetCopyStatMs

func (m *Msg) GetCopyStatMs() int64

func (*Msg) GetCopyWriteMs

func (m *Msg) GetCopyWriteMs() int64

func (*Msg) GetListDirOpenMs

func (m *Msg) GetListDirOpenMs() int64

func (*Msg) GetListDirReadMs

func (m *Msg) GetListDirReadMs() int64

func (*Msg) GetListDirWriteMs

func (m *Msg) GetListDirWriteMs() int64

func (*Msg) GetListFileWriteMs

func (m *Msg) GetListFileWriteMs() int64

func (*Msg) ProtoMessage

func (*Msg) ProtoMessage()

func (*Msg) Reset

func (m *Msg) Reset()

func (*Msg) String

func (m *Msg) String() string

func (*Msg) XXX_DiscardUnknown

func (m *Msg) XXX_DiscardUnknown()

func (*Msg) XXX_Marshal

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

func (*Msg) XXX_Merge

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

func (*Msg) XXX_Size

func (m *Msg) XXX_Size() int

func (*Msg) XXX_Unmarshal

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