telemetry

package
v1.9.3 Latest Latest
Warning

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

 Go to latest Published: Mar 24, 2022 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

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")
	ErrUnexpectedEndOfGroupReport = fmt.Errorf("proto: unexpected end of group")
)

Functions

func Enabled added in v1.4.3 

func Enabled() bool

Enabled return true if we enable telemetry.

func FillNodeInfo 

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

FillNodeInfo fill HardwareInfo and Os info.

func GetSecret added in v1.4.3 

func GetSecret() string

GetSecret return telemetry encrypt secret.

func GetUUID added in v1.4.3 

func GetUUID() string

GetUUID return telemetry uuid.

func NewSecret added in v1.4.2 

func NewSecret() string

NewSecret generates a new random string as encryption secret

func NewUUID 

func NewUUID() string

NewUUID return a new uuid.

func NodeInfoToText added in v1.4.3 

func NodeInfoToText(info *NodeInfo) (text string, err error)

NodeInfoToText get telemetry.NodeInfo in text.

func SaltedHash added in v1.4.3 

func SaltedHash(val string, salt ...string) string

SaltedHash preprend the secret before hashing input

func ScrubYaml 

func ScrubYaml(
	data []byte,
	hashFieldNames set.StringSet,
	omitFieldNames set.StringSet,
	salt string,
) (scrubed []byte, err error)

ScrubYaml scrub the values in yaml

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,proto3" json:"features,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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) MarshalToSizedBuffer added in v1.4.2 

func (m *CPUInfo) MarshalToSizedBuffer(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

func (*CPUInfo) XXX_DiscardUnknown added in v1.4.2 

func (m *CPUInfo) XXX_DiscardUnknown()

func (*CPUInfo) XXX_Marshal added in v1.4.2 

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

func (*CPUInfo) XXX_Merge added in v1.4.2 

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

func (*CPUInfo) XXX_Size added in v1.4.2 

func (m *CPUInfo) XXX_Size() int

func (*CPUInfo) XXX_Unmarshal added in v1.4.2 

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

type ClusterReport 

type ClusterReport struct {
	ID               string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,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,proto3" json:"nodes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

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) GetID added in v1.4.2 

func (m *ClusterReport) GetID() string

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

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

func (*ClusterReport) MarshalTo 

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

func (*ClusterReport) MarshalToSizedBuffer added in v1.4.2 

func (m *ClusterReport) MarshalToSizedBuffer(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

func (*ClusterReport) XXX_DiscardUnknown added in v1.4.2 

func (m *ClusterReport) XXX_DiscardUnknown()

func (*ClusterReport) XXX_Marshal added in v1.4.2 

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

func (*ClusterReport) XXX_Merge added in v1.4.2 

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

func (*ClusterReport) XXX_Size added in v1.4.2 

func (m *ClusterReport) XXX_Size() int

func (*ClusterReport) XXX_Unmarshal added in v1.4.2 

func (m *ClusterReport) XXX_Unmarshal(b []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,proto3" json:"cpu"`
	Mem                  MemInfo  `protobuf:"bytes,3,opt,name=mem,proto3" json:"mem"`
	Loadavg15            float32  `protobuf:"fixed32,4,opt,name=loadavg15,proto3" json:"loadavg15,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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) MarshalToSizedBuffer added in v1.4.2 

func (m *HardwareInfo) MarshalToSizedBuffer(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

func (*HardwareInfo) XXX_DiscardUnknown added in v1.4.2 

func (m *HardwareInfo) XXX_DiscardUnknown()

func (*HardwareInfo) XXX_Marshal added in v1.4.2 

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

func (*HardwareInfo) XXX_Merge added in v1.4.2 

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

func (*HardwareInfo) XXX_Size added in v1.4.2 

func (m *HardwareInfo) XXX_Size() int

func (*HardwareInfo) XXX_Unmarshal added in v1.4.2 

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

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) MarshalToSizedBuffer added in v1.4.2 

func (m *MemInfo) MarshalToSizedBuffer(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

func (*MemInfo) XXX_DiscardUnknown added in v1.4.2 

func (m *MemInfo) XXX_DiscardUnknown()

func (*MemInfo) XXX_Marshal added in v1.4.2 

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

func (*MemInfo) XXX_Merge added in v1.4.2 

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

func (*MemInfo) XXX_Size added in v1.4.2 

func (m *MemInfo) XXX_Size() int

func (*MemInfo) XXX_Unmarshal added in v1.4.2 

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

type Meta 

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

Meta data of telemetry.

func GetMeta added in v1.0.8 

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,proto3" json:"hardware"`
	Os                   OSInfo       `protobuf:"bytes,7,opt,name=os,proto3" json:"os"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func NodeInfoFromText added in v1.4.3 

func NodeInfoFromText(text string) (info *NodeInfo, err error)

NodeInfoFromText get telemetry.NodeInfo from the text.

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) MarshalToSizedBuffer added in v1.4.2 

func (m *NodeInfo) MarshalToSizedBuffer(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

func (*NodeInfo) XXX_DiscardUnknown added in v1.4.2 

func (m *NodeInfo) XXX_DiscardUnknown()

func (*NodeInfo) XXX_Marshal added in v1.4.2 

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

func (*NodeInfo) XXX_Merge added in v1.4.2 

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

func (*NodeInfo) XXX_Size added in v1.4.2 

func (m *NodeInfo) XXX_Size() int

func (*NodeInfo) XXX_Unmarshal added in v1.4.2 

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

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) MarshalToSizedBuffer added in v1.4.2 

func (m *OSInfo) MarshalToSizedBuffer(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

func (*OSInfo) XXX_DiscardUnknown added in v1.4.2 

func (m *OSInfo) XXX_DiscardUnknown()

func (*OSInfo) XXX_Marshal added in v1.4.2 

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

func (*OSInfo) XXX_Merge added in v1.4.2 

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

func (*OSInfo) XXX_Size added in v1.4.2 

func (m *OSInfo) XXX_Size() int

func (*OSInfo) XXX_Unmarshal added in v1.4.2 

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

type PlaygroundReport added in v1.4.3 

type PlaygroundReport struct {
	Topology             string   `protobuf:"bytes,1,opt,name=topology,proto3" json:"topology,omitempty"`
	TakeMilliseconds     uint64   `protobuf:"varint,2,opt,name=take_milliseconds,json=takeMilliseconds,proto3" json:"take_milliseconds,omitempty"`
	ExitCode             int32    `protobuf:"varint,3,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PlaygroundReport) Descriptor added in v1.4.3 

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

func (*PlaygroundReport) GetExitCode added in v1.4.3 

func (m *PlaygroundReport) GetExitCode() int32

func (*PlaygroundReport) GetTakeMilliseconds added in v1.4.3 

func (m *PlaygroundReport) GetTakeMilliseconds() uint64

func (*PlaygroundReport) GetTopology added in v1.4.3 

func (m *PlaygroundReport) GetTopology() string

func (*PlaygroundReport) Marshal added in v1.4.3 

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

func (*PlaygroundReport) MarshalTo added in v1.4.3 

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

func (*PlaygroundReport) MarshalToSizedBuffer added in v1.4.3 

func (m *PlaygroundReport) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PlaygroundReport) ProtoMessage added in v1.4.3 

func (*PlaygroundReport) ProtoMessage()

func (*PlaygroundReport) Reset added in v1.4.3 

func (m *PlaygroundReport) Reset()

func (*PlaygroundReport) Size added in v1.4.3 

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

func (*PlaygroundReport) String added in v1.4.3 

func (m *PlaygroundReport) String() string

func (*PlaygroundReport) Unmarshal added in v1.4.3 

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

func (*PlaygroundReport) XXX_DiscardUnknown added in v1.4.3 

func (m *PlaygroundReport) XXX_DiscardUnknown()

func (*PlaygroundReport) XXX_Marshal added in v1.4.3 

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

func (*PlaygroundReport) XXX_Merge added in v1.4.3 

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

func (*PlaygroundReport) XXX_Size added in v1.4.3 

func (m *PlaygroundReport) XXX_Size() int

func (*PlaygroundReport) XXX_Unmarshal added in v1.4.3 

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

type Report 

type Report struct {
	InstallationUUID   string    `protobuf:"bytes,1,opt,name=installationUUID,proto3" json:"installationUUID,omitempty"`
	EventUUID          string    `protobuf:"bytes,2,opt,name=eventUUID,proto3" json:"eventUUID,omitempty"`
	EventUnixTimestamp int64     `protobuf:"varint,3,opt,name=event_unix_timestamp,json=eventUnixTimestamp,proto3" json:"event_unix_timestamp,omitempty"`
	Version            *TiUPInfo `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	// Types that are valid to be assigned to EventDetail:
	//	*Report_Tiup
	//	*Report_Cluster
	//	*Report_Playground
	EventDetail          isReport_EventDetail `protobuf_oneof:"event_detail"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

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) GetInstallationUUID added in v1.4.2 

func (m *Report) GetInstallationUUID() string

func (*Report) GetPlayground added in v1.4.3 

func (m *Report) GetPlayground() *PlaygroundReport

func (*Report) GetTiup added in v1.4.2 

func (m *Report) GetTiup() *TiUPReport

func (*Report) GetVersion added in v1.4.3 

func (m *Report) GetVersion() *TiUPInfo

func (*Report) Marshal 

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

func (*Report) MarshalTo 

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

func (*Report) MarshalToSizedBuffer added in v1.4.2 

func (m *Report) MarshalToSizedBuffer(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_DiscardUnknown added in v1.4.2 

func (m *Report) XXX_DiscardUnknown()

func (*Report) XXX_Marshal added in v1.4.2 

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

func (*Report) XXX_Merge added in v1.4.2 

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

func (*Report) XXX_OneofWrappers added in v1.4.2 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Report) XXX_Size added in v1.4.2 

func (m *Report) XXX_Size() int

func (*Report) XXX_Unmarshal added in v1.4.2 

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

type Report_Cluster 

type Report_Cluster struct {
	Cluster *ClusterReport `protobuf:"bytes,6,opt,name=cluster,proto3,oneof" json:"cluster,omitempty"`
}

func (*Report_Cluster) MarshalTo 

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

func (*Report_Cluster) MarshalToSizedBuffer added in v1.4.2 

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

func (*Report_Cluster) Size 

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

type Report_Playground added in v1.4.3 

type Report_Playground struct {
	Playground *PlaygroundReport `protobuf:"bytes,7,opt,name=playground,proto3,oneof" json:"playground,omitempty"`
}

func (*Report_Playground) MarshalTo added in v1.4.3 

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

func (*Report_Playground) MarshalToSizedBuffer added in v1.4.3 

func (m *Report_Playground) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Report_Playground) Size added in v1.4.3 

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

type Report_Tiup added in v1.4.3 

type Report_Tiup struct {
	Tiup *TiUPReport `protobuf:"bytes,5,opt,name=tiup,proto3,oneof" json:"tiup,omitempty"`
}

func (*Report_Tiup) MarshalTo added in v1.4.3 

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

func (*Report_Tiup) MarshalToSizedBuffer added in v1.4.3 

func (m *Report_Tiup) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Report_Tiup) Size added in v1.4.3 

func (m *Report_Tiup) 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.

type TiUPInfo added in v1.4.2 

type TiUPInfo struct {
	TiUPVersion          string   `protobuf:"bytes,1,opt,name=TiUPVersion,proto3" json:"TiUPVersion,omitempty"`
	ComponentVersion     string   `protobuf:"bytes,2,opt,name=ComponentVersion,proto3" json:"ComponentVersion,omitempty"`
	GitRef               string   `protobuf:"bytes,3,opt,name=GitRef,proto3" json:"GitRef,omitempty"`
	GitCommit            string   `protobuf:"bytes,4,opt,name=GitCommit,proto3" json:"GitCommit,omitempty"`
	VerName              string   `protobuf:"bytes,5,opt,name=VerName,proto3" json:"VerName,omitempty"`
	Os                   string   `protobuf:"bytes,6,opt,name=os,proto3" json:"os,omitempty"`
	Arch                 string   `protobuf:"bytes,7,opt,name=arch,proto3" json:"arch,omitempty"`
	Go                   string   `protobuf:"bytes,8,opt,name=go,proto3" json:"go,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func TiUPMeta added in v1.4.3 

func TiUPMeta() *TiUPInfo

TiUPMeta returns metadata of TiUP Cluster itself

func (*TiUPInfo) Descriptor added in v1.4.2 

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

func (*TiUPInfo) GetArch added in v1.4.2 

func (m *TiUPInfo) GetArch() string

func (*TiUPInfo) GetComponentVersion added in v1.4.2 

func (m *TiUPInfo) GetComponentVersion() string

func (*TiUPInfo) GetGitCommit added in v1.4.2 

func (m *TiUPInfo) GetGitCommit() string

func (*TiUPInfo) GetGitRef added in v1.4.3 

func (m *TiUPInfo) GetGitRef() string

func (*TiUPInfo) GetGo added in v1.4.3 

func (m *TiUPInfo) GetGo() string

func (*TiUPInfo) GetOs added in v1.4.2 

func (m *TiUPInfo) GetOs() string

func (*TiUPInfo) GetTiUPVersion added in v1.4.2 

func (m *TiUPInfo) GetTiUPVersion() string

func (*TiUPInfo) GetVerName added in v1.4.3 

func (m *TiUPInfo) GetVerName() string

func (*TiUPInfo) Marshal added in v1.4.2 

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

func (*TiUPInfo) MarshalTo added in v1.4.2 

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

func (*TiUPInfo) MarshalToSizedBuffer added in v1.4.2 

func (m *TiUPInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TiUPInfo) ProtoMessage added in v1.4.2 

func (*TiUPInfo) ProtoMessage()

func (*TiUPInfo) Reset added in v1.4.2 

func (m *TiUPInfo) Reset()

func (*TiUPInfo) Size added in v1.4.2 

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

func (*TiUPInfo) String added in v1.4.2 

func (m *TiUPInfo) String() string

func (*TiUPInfo) Unmarshal added in v1.4.2 

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

func (*TiUPInfo) XXX_DiscardUnknown added in v1.4.2 

func (m *TiUPInfo) XXX_DiscardUnknown()

func (*TiUPInfo) XXX_Marshal added in v1.4.2 

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

func (*TiUPInfo) XXX_Merge added in v1.4.2 

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

func (*TiUPInfo) XXX_Size added in v1.4.2 

func (m *TiUPInfo) XXX_Size() int

func (*TiUPInfo) XXX_Unmarshal added in v1.4.2 

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

type TiUPReport added in v1.4.3 

type TiUPReport struct {
	Command              string   `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"`
	Tag                  string   `protobuf:"bytes,2,opt,name=tag,proto3" json:"tag,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"`
	CustomMirror         bool     `protobuf:"varint,5,opt,name=custom_mirror,json=customMirror,proto3" json:"custom_mirror,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TiUPReport) Descriptor added in v1.4.3 

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

func (*TiUPReport) GetCommand added in v1.4.3 

func (m *TiUPReport) GetCommand() string

func (*TiUPReport) GetCustomMirror added in v1.4.3 

func (m *TiUPReport) GetCustomMirror() bool

func (*TiUPReport) GetExitCode added in v1.4.3 

func (m *TiUPReport) GetExitCode() int32

func (*TiUPReport) GetTag added in v1.4.3 

func (m *TiUPReport) GetTag() string

func (*TiUPReport) GetTakeMilliseconds added in v1.4.3 

func (m *TiUPReport) GetTakeMilliseconds() uint64

func (*TiUPReport) Marshal added in v1.4.3 

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

func (*TiUPReport) MarshalTo added in v1.4.3 

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

func (*TiUPReport) MarshalToSizedBuffer added in v1.4.3 

func (m *TiUPReport) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TiUPReport) ProtoMessage added in v1.4.3 

func (*TiUPReport) ProtoMessage()

func (*TiUPReport) Reset added in v1.4.3 

func (m *TiUPReport) Reset()

func (*TiUPReport) Size added in v1.4.3 

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

func (*TiUPReport) String added in v1.4.3 

func (m *TiUPReport) String() string

func (*TiUPReport) Unmarshal added in v1.4.3 

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

func (*TiUPReport) XXX_DiscardUnknown added in v1.4.3 

func (m *TiUPReport) XXX_DiscardUnknown()

func (*TiUPReport) XXX_Marshal added in v1.4.3 

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

func (*TiUPReport) XXX_Merge added in v1.4.3 

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

func (*TiUPReport) XXX_Size added in v1.4.3 

func (m *TiUPReport) XXX_Size() int

func (*TiUPReport) XXX_Unmarshal added in v1.4.3 

func (m *TiUPReport) XXX_Unmarshal(b []byte) 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.