telemetry

package
v1.3.1-0...-83f5247 Latest Latest
Warning

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

 Go to latest Published: Apr 8, 2021 License: Apache-2.0 Imports: 23 Imported by: 0

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

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 

func FillNodeInfo(ctx context.Context, info *NodeInfo) (err error)

FillNodeInfo fill HardwareInfo and Os info.

func HashReport 

func HashReport(val string) string

HashReport return the hash value of val.

func NewUUID 

func NewUUID() string

NewUUID return a new uuid.

func ScrubYaml 

func ScrubYaml(data []byte, hashFieldNames map[string]struct{}) (scrubed []byte, err error)

ScrubYaml scrub the value. for string type, replace as "_", unless the field name is in the hashFieldNames. for any other type set as the zero value of the according type.

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

func (*CPUInfo) GetCores 

func (m *CPUInfo) GetCores() int32

func (*CPUInfo) GetFeatures 

func (m *CPUInfo) GetFeatures() []string

func (*CPUInfo) GetMhz 

func (m *CPUInfo) GetMhz() float32

func (*CPUInfo) GetModel 

func (m *CPUInfo) GetModel() string

func (*CPUInfo) GetNumcpu 

func (m *CPUInfo) GetNumcpu() int32

func (*CPUInfo) GetSockets 

func (m *CPUInfo) GetSockets() int32

func (*CPUInfo) Marshal 

func (m *CPUInfo) Marshal() (dAtA []byte, err error)

func (*CPUInfo) MarshalTo 

func (m *CPUInfo) MarshalTo(dAtA []byte) (int, error)

func (*CPUInfo) ProtoMessage 

func (*CPUInfo) ProtoMessage()

func (*CPUInfo) Reset 

func (m *CPUInfo) Reset()

func (*CPUInfo) Size 

func (m *CPUInfo) Size() (n int)

func (*CPUInfo) String 

func (m *CPUInfo) String() string

func (*CPUInfo) Unmarshal 

func (m *CPUInfo) Unmarshal(dAtA []byte) error

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) MarshalTo 

func (m *ClusterReport) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *HardwareInfo) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*MemInfo) GetAvailable 

func (m *MemInfo) GetAvailable() uint64

func (*MemInfo) GetTotal 

func (m *MemInfo) GetTotal() uint64

func (*MemInfo) Marshal 

func (m *MemInfo) Marshal() (dAtA []byte, err error)

func (*MemInfo) MarshalTo 

func (m *MemInfo) MarshalTo(dAtA []byte) (int, error)

func (*MemInfo) ProtoMessage 

func (*MemInfo) ProtoMessage()

func (*MemInfo) Reset 

func (m *MemInfo) Reset()

func (*MemInfo) Size 

func (m *MemInfo) Size() (n int)

func (*MemInfo) String 

func (m *MemInfo) String() string

func (*MemInfo) Unmarshal 

func (m *MemInfo) Unmarshal(dAtA []byte) error

type Meta 

type Meta struct {
	UUID   string `yaml:"uuid,omitempty"`
	Status Status `yaml:"status,omitempty"`
}

Meta data of telemetry.

func GetMeta 

func GetMeta(env *environment.Environment) (meta *Meta, fname string, err error)

GetMeta read the telemeta from disk

func LoadFrom 

func LoadFrom(fname string) (meta *Meta, err error)

LoadFrom load meta from the specify file, return a default Meta and save it if the file not exist.

func NewMeta 

func NewMeta() *Meta

NewMeta create a new default Meta.

func (*Meta) SaveTo 

func (m *Meta) SaveTo(fname string) error

SaveTo save to the specified file.

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

func (*NodeInfo) GetHardware 

func (m *NodeInfo) GetHardware() HardwareInfo

func (*NodeInfo) GetNodeId 

func (m *NodeInfo) GetNodeId() string

func (*NodeInfo) GetOs 

func (m *NodeInfo) GetOs() OSInfo

func (*NodeInfo) Marshal 

func (m *NodeInfo) Marshal() (dAtA []byte, err error)

func (*NodeInfo) MarshalTo 

func (m *NodeInfo) MarshalTo(dAtA []byte) (int, error)

func (*NodeInfo) ProtoMessage 

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) Reset 

func (m *NodeInfo) Reset()

func (*NodeInfo) Size 

func (m *NodeInfo) Size() (n int)

func (*NodeInfo) String 

func (m *NodeInfo) String() string

func (*NodeInfo) Unmarshal 

func (m *NodeInfo) Unmarshal(dAtA []byte) error

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 GetOSInfo 

func GetOSInfo(ctx context.Context) (info OSInfo, err error)

GetOSInfo get the OSInfo.

func (*OSInfo) Descriptor 

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

func (*OSInfo) GetFamily 

func (m *OSInfo) GetFamily() string

func (*OSInfo) GetPlatform 

func (m *OSInfo) GetPlatform() string

func (*OSInfo) GetVersion 

func (m *OSInfo) GetVersion() string

func (*OSInfo) Marshal 

func (m *OSInfo) Marshal() (dAtA []byte, err error)

func (*OSInfo) MarshalTo 

func (m *OSInfo) MarshalTo(dAtA []byte) (int, error)

func (*OSInfo) ProtoMessage 

func (*OSInfo) ProtoMessage()

func (*OSInfo) Reset 

func (m *OSInfo) Reset()

func (*OSInfo) Size 

func (m *OSInfo) Size() (n int)

func (*OSInfo) String 

func (m *OSInfo) String() string

func (*OSInfo) Unmarshal 

func (m *OSInfo) Unmarshal(dAtA []byte) error

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

func (*Report) GetCluster 

func (m *Report) GetCluster() *ClusterReport

func (*Report) GetEventDetail 

func (m *Report) GetEventDetail() isReport_EventDetail

func (*Report) GetEventUUID 

func (m *Report) GetEventUUID() string

func (*Report) GetEventUnixTimestamp 

func (m *Report) GetEventUnixTimestamp() int64

func (*Report) Marshal 

func (m *Report) Marshal() (dAtA []byte, err error)

func (*Report) MarshalTo 

func (m *Report) MarshalTo(dAtA []byte) (int, error)

func (*Report) ProtoMessage 

func (*Report) ProtoMessage()

func (*Report) Reset 

func (m *Report) Reset()

func (*Report) Size 

func (m *Report) Size() (n int)

func (*Report) String 

func (m *Report) String() string

func (*Report) Unmarshal 

func (m *Report) Unmarshal(dAtA []byte) error

func (*Report) XXX_OneofFuncs 

func (*Report) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type Report_Cluster 

type Report_Cluster struct {
	Cluster *ClusterReport `protobuf:"bytes,3,opt,name=cluster,oneof"`
}

func (*Report_Cluster) MarshalTo 

func (m *Report_Cluster) MarshalTo(dAtA []byte) (int, error)

func (*Report_Cluster) Size 

func (m *Report_Cluster) Size() (n int)

type ScrubStrategy 

type ScrubStrategy int

ScrubStrategy for scrub sensible value.

type Status 

type Status string

Status of telemetry. 

const (
	EnableStatus  Status = "enable"
	DisableStatus Status = "disable"
)

Status of telemetry

type Telemetry 

type Telemetry struct {
	// contains filtered or unexported fields
}

Telemetry control telemetry.

func NewTelemetry 

func NewTelemetry() *Telemetry

NewTelemetry return a new Telemetry instance.

func (*Telemetry) Report 

func (t *Telemetry) Report(ctx context.Context, msg *Report) error

Report report the msg right away.

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.