Documentation
¶
Overview ¶
Package telemetry is a generated protocol buffer package.
It is generated from these files:
report.proto
It has these top-level messages:
Report ClusterReport NodeInfo CPUInfo HardwareInfo OSInfo MemInfo
Index ¶
- Variables
- func FillNodeInfo(ctx context.Context, info *NodeInfo) (err error)
- func HashReport(val string) string
- func NewUUID() string
- func ScrubYaml(data []byte, hashFieldNames map[string]struct{}) (scrubed []byte, err error)
- type CPUInfo
- func (*CPUInfo) Descriptor() ([]byte, []int)
- func (m *CPUInfo) GetCores() int32
- func (m *CPUInfo) GetFeatures() []string
- func (m *CPUInfo) GetMhz() float32
- func (m *CPUInfo) GetModel() string
- func (m *CPUInfo) GetNumcpu() int32
- func (m *CPUInfo) GetSockets() int32
- func (m *CPUInfo) Marshal() (dAtA []byte, err error)
- func (m *CPUInfo) MarshalTo(dAtA []byte) (int, error)
- func (*CPUInfo) ProtoMessage()
- func (m *CPUInfo) Reset()
- func (m *CPUInfo) Size() (n int)
- func (m *CPUInfo) String() string
- func (m *CPUInfo) Unmarshal(dAtA []byte) error
- type ClusterReport
- func (*ClusterReport) Descriptor() ([]byte, []int)
- func (m *ClusterReport) GetCommand() string
- func (m *ClusterReport) GetExitCode() int32
- func (m *ClusterReport) GetNodes() []*NodeInfo
- func (m *ClusterReport) GetTakeMilliseconds() uint64
- func (m *ClusterReport) GetTopology() string
- func (m *ClusterReport) GetUUID() string
- func (m *ClusterReport) Marshal() (dAtA []byte, err error)
- func (m *ClusterReport) MarshalTo(dAtA []byte) (int, error)
- func (*ClusterReport) ProtoMessage()
- func (m *ClusterReport) Reset()
- func (m *ClusterReport) Size() (n int)
- func (m *ClusterReport) String() string
- func (m *ClusterReport) Unmarshal(dAtA []byte) error
- type HardwareInfo
- func (*HardwareInfo) Descriptor() ([]byte, []int)
- func (m *HardwareInfo) GetCpu() CPUInfo
- func (m *HardwareInfo) GetLoadavg15() float32
- func (m *HardwareInfo) GetMem() MemInfo
- func (m *HardwareInfo) GetVirtualization() string
- func (m *HardwareInfo) Marshal() (dAtA []byte, err error)
- func (m *HardwareInfo) MarshalTo(dAtA []byte) (int, error)
- func (*HardwareInfo) ProtoMessage()
- func (m *HardwareInfo) Reset()
- func (m *HardwareInfo) Size() (n int)
- func (m *HardwareInfo) String() string
- func (m *HardwareInfo) Unmarshal(dAtA []byte) error
- type MemInfo
- func (*MemInfo) Descriptor() ([]byte, []int)
- func (m *MemInfo) GetAvailable() uint64
- func (m *MemInfo) GetTotal() uint64
- func (m *MemInfo) Marshal() (dAtA []byte, err error)
- func (m *MemInfo) MarshalTo(dAtA []byte) (int, error)
- func (*MemInfo) ProtoMessage()
- func (m *MemInfo) Reset()
- func (m *MemInfo) Size() (n int)
- func (m *MemInfo) String() string
- func (m *MemInfo) Unmarshal(dAtA []byte) error
- type Meta
- type NodeInfo
- func (*NodeInfo) Descriptor() ([]byte, []int)
- func (m *NodeInfo) GetHardware() HardwareInfo
- func (m *NodeInfo) GetNodeId() string
- func (m *NodeInfo) GetOs() OSInfo
- func (m *NodeInfo) Marshal() (dAtA []byte, err error)
- func (m *NodeInfo) MarshalTo(dAtA []byte) (int, error)
- func (*NodeInfo) ProtoMessage()
- func (m *NodeInfo) Reset()
- func (m *NodeInfo) Size() (n int)
- func (m *NodeInfo) String() string
- func (m *NodeInfo) Unmarshal(dAtA []byte) error
- type OSInfo
- func (*OSInfo) Descriptor() ([]byte, []int)
- func (m *OSInfo) GetFamily() string
- func (m *OSInfo) GetPlatform() string
- func (m *OSInfo) GetVersion() string
- func (m *OSInfo) Marshal() (dAtA []byte, err error)
- func (m *OSInfo) MarshalTo(dAtA []byte) (int, error)
- func (*OSInfo) ProtoMessage()
- func (m *OSInfo) Reset()
- func (m *OSInfo) Size() (n int)
- func (m *OSInfo) String() string
- func (m *OSInfo) Unmarshal(dAtA []byte) error
- type Report
- func (*Report) Descriptor() ([]byte, []int)
- func (m *Report) GetCluster() *ClusterReport
- func (m *Report) GetEventDetail() isReport_EventDetail
- func (m *Report) GetEventUUID() string
- func (m *Report) GetEventUnixTimestamp() int64
- func (m *Report) Marshal() (dAtA []byte, err error)
- func (m *Report) MarshalTo(dAtA []byte) (int, error)
- func (*Report) ProtoMessage()
- func (m *Report) Reset()
- func (m *Report) Size() (n int)
- func (m *Report) String() string
- func (m *Report) Unmarshal(dAtA []byte) error
- func (*Report) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- type Report_Cluster
- type ScrubStrategy
- type Status
- type Telemetry
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthReport = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowReport = fmt.Errorf("proto: integer overflow") )
Functions ¶
func FillNodeInfo ¶
FillNodeInfo fill HardwareInfo and Os info.
Types ¶
type CPUInfo ¶
type CPUInfo struct { Numcpu int32 `protobuf:"varint,1,opt,name=numcpu,proto3" json:"numcpu,omitempty"` Sockets int32 `protobuf:"varint,2,opt,name=sockets,proto3" json:"sockets,omitempty"` Cores int32 `protobuf:"varint,3,opt,name=cores,proto3" json:"cores,omitempty"` Model string `protobuf:"bytes,4,opt,name=model,proto3" json:"model,omitempty"` Mhz float32 `protobuf:"fixed32,5,opt,name=mhz,proto3" json:"mhz,omitempty"` Features []string `protobuf:"bytes,6,rep,name=features" json:"features,omitempty"` }
func (*CPUInfo) Descriptor ¶
func (*CPUInfo) GetFeatures ¶
func (*CPUInfo) GetSockets ¶
func (*CPUInfo) ProtoMessage ¶
func (*CPUInfo) ProtoMessage()
type ClusterReport ¶
type ClusterReport struct { UUID string `protobuf:"bytes,1,opt,name=UUID,proto3" json:"UUID,omitempty"` Command string `protobuf:"bytes,2,opt,name=command,proto3" json:"command,omitempty"` TakeMilliseconds uint64 `protobuf:"varint,3,opt,name=take_milliseconds,json=takeMilliseconds,proto3" json:"take_milliseconds,omitempty"` ExitCode int32 `protobuf:"varint,4,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"` // only deploy and scale-out is setted: Topology string `protobuf:"bytes,5,opt,name=topology,proto3" json:"topology,omitempty"` Nodes []*NodeInfo `protobuf:"bytes,6,rep,name=nodes" json:"nodes,omitempty"` }
func (*ClusterReport) Descriptor ¶
func (*ClusterReport) Descriptor() ([]byte, []int)
func (*ClusterReport) GetCommand ¶
func (m *ClusterReport) GetCommand() string
func (*ClusterReport) GetExitCode ¶
func (m *ClusterReport) GetExitCode() int32
func (*ClusterReport) GetNodes ¶
func (m *ClusterReport) GetNodes() []*NodeInfo
func (*ClusterReport) GetTakeMilliseconds ¶
func (m *ClusterReport) GetTakeMilliseconds() uint64
func (*ClusterReport) GetTopology ¶
func (m *ClusterReport) GetTopology() string
func (*ClusterReport) GetUUID ¶
func (m *ClusterReport) GetUUID() string
func (*ClusterReport) Marshal ¶
func (m *ClusterReport) Marshal() (dAtA []byte, err error)
func (*ClusterReport) ProtoMessage ¶
func (*ClusterReport) ProtoMessage()
func (*ClusterReport) Reset ¶
func (m *ClusterReport) Reset()
func (*ClusterReport) Size ¶
func (m *ClusterReport) Size() (n int)
func (*ClusterReport) String ¶
func (m *ClusterReport) String() string
func (*ClusterReport) Unmarshal ¶
func (m *ClusterReport) Unmarshal(dAtA []byte) error
type HardwareInfo ¶
type HardwareInfo struct { Virtualization string `protobuf:"bytes,1,opt,name=virtualization,proto3" json:"virtualization,omitempty"` Cpu CPUInfo `protobuf:"bytes,2,opt,name=cpu" json:"cpu"` Mem MemInfo `protobuf:"bytes,3,opt,name=mem" json:"mem"` Loadavg15 float32 `protobuf:"fixed32,4,opt,name=loadavg15,proto3" json:"loadavg15,omitempty"` }
func GetHardwareInfo ¶
func GetHardwareInfo(ctx context.Context) (info HardwareInfo, err error)
GetHardwareInfo get the HardwareInfo.
func (*HardwareInfo) Descriptor ¶
func (*HardwareInfo) Descriptor() ([]byte, []int)
func (*HardwareInfo) GetCpu ¶
func (m *HardwareInfo) GetCpu() CPUInfo
func (*HardwareInfo) GetLoadavg15 ¶
func (m *HardwareInfo) GetLoadavg15() float32
func (*HardwareInfo) GetMem ¶
func (m *HardwareInfo) GetMem() MemInfo
func (*HardwareInfo) GetVirtualization ¶
func (m *HardwareInfo) GetVirtualization() string
func (*HardwareInfo) Marshal ¶
func (m *HardwareInfo) Marshal() (dAtA []byte, err error)
func (*HardwareInfo) ProtoMessage ¶
func (*HardwareInfo) ProtoMessage()
func (*HardwareInfo) Reset ¶
func (m *HardwareInfo) Reset()
func (*HardwareInfo) Size ¶
func (m *HardwareInfo) Size() (n int)
func (*HardwareInfo) String ¶
func (m *HardwareInfo) String() string
func (*HardwareInfo) Unmarshal ¶
func (m *HardwareInfo) Unmarshal(dAtA []byte) error
type MemInfo ¶
type MemInfo struct { Total uint64 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"` Available uint64 `protobuf:"varint,2,opt,name=available,proto3" json:"available,omitempty"` }
func (*MemInfo) Descriptor ¶
func (*MemInfo) GetAvailable ¶
func (*MemInfo) ProtoMessage ¶
func (*MemInfo) ProtoMessage()
type Meta ¶
Meta data of telemetry.
type NodeInfo ¶
type NodeInfo struct { NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` Hardware HardwareInfo `protobuf:"bytes,6,opt,name=hardware" json:"hardware"` Os OSInfo `protobuf:"bytes,7,opt,name=os" json:"os"` }
func (*NodeInfo) Descriptor ¶
func (*NodeInfo) GetHardware ¶
func (m *NodeInfo) GetHardware() HardwareInfo
func (*NodeInfo) ProtoMessage ¶
func (*NodeInfo) ProtoMessage()
type OSInfo ¶
type OSInfo struct { Family string `protobuf:"bytes,1,opt,name=family,proto3" json:"family,omitempty"` Platform string `protobuf:"bytes,2,opt,name=platform,proto3" json:"platform,omitempty"` Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"` }
func (*OSInfo) Descriptor ¶
func (*OSInfo) GetPlatform ¶
func (*OSInfo) GetVersion ¶
func (*OSInfo) ProtoMessage ¶
func (*OSInfo) ProtoMessage()
type Report ¶
type Report struct { EventUUID string `protobuf:"bytes,1,opt,name=eventUUID,proto3" json:"eventUUID,omitempty"` EventUnixTimestamp int64 `protobuf:"varint,2,opt,name=event_unix_timestamp,json=eventUnixTimestamp,proto3" json:"event_unix_timestamp,omitempty"` // Types that are valid to be assigned to EventDetail: // *Report_Cluster EventDetail isReport_EventDetail `protobuf_oneof:"event_detail"` }
func (*Report) Descriptor ¶
func (*Report) GetCluster ¶
func (m *Report) GetCluster() *ClusterReport
func (*Report) GetEventDetail ¶
func (m *Report) GetEventDetail() isReport_EventDetail
func (*Report) GetEventUUID ¶
func (*Report) GetEventUnixTimestamp ¶
func (*Report) ProtoMessage ¶
func (*Report) ProtoMessage()
type Report_Cluster ¶
type Report_Cluster struct {
Cluster *ClusterReport `protobuf:"bytes,3,opt,name=cluster,oneof"`
}
func (*Report_Cluster) Size ¶
func (m *Report_Cluster) Size() (n int)
Click to show internal directories.
Click to hide internal directories.