collectorpb

package
v0.0.0-...-6159ff7 Latest Latest
Warning

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

 Go to latest Published: Aug 5, 2024 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_api_pb_metrics_proto protoreflect.FileDescriptor
View Source 
var MetricsCollector_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "collector.MetricsCollector",
	HandlerType: (*MetricsCollectorServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "CollectMetrics",
			Handler:       _MetricsCollector_CollectMetrics_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "api/pb/metrics.proto",
}

MetricsCollector_ServiceDesc is the grpc.ServiceDesc for MetricsCollector service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterMetricsCollectorServer 

func RegisterMetricsCollectorServer(s grpc.ServiceRegistrar, srv MetricsCollectorServer)

Types

type CPUUsage 

type CPUUsage struct {
	UserMode   float64 `protobuf:"fixed64,1,opt,name=user_mode,json=userMode,proto3" json:"user_mode,omitempty"`
	SystemMode float64 `protobuf:"fixed64,2,opt,name=system_mode,json=systemMode,proto3" json:"system_mode,omitempty"`
	Idle       float64 `protobuf:"fixed64,3,opt,name=idle,proto3" json:"idle,omitempty"`
	// contains filtered or unexported fields
}

func (*CPUUsage) Descriptor deprecated 

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

Deprecated: Use CPUUsage.ProtoReflect.Descriptor instead.

func (*CPUUsage) GetIdle 

func (x *CPUUsage) GetIdle() float64

func (*CPUUsage) GetSystemMode 

func (x *CPUUsage) GetSystemMode() float64

func (*CPUUsage) GetUserMode 

func (x *CPUUsage) GetUserMode() float64

func (*CPUUsage) ProtoMessage 

func (*CPUUsage) ProtoMessage()

func (*CPUUsage) ProtoReflect 

func (x *CPUUsage) ProtoReflect() protoreflect.Message

func (*CPUUsage) Reset 

func (x *CPUUsage) Reset()

func (*CPUUsage) String 

func (x *CPUUsage) String() string

type Collector 

type Collector struct {
	Loadaverage     *LoadAverage       `protobuf:"bytes,1,opt,name=loadaverage,proto3" json:"loadaverage,omitempty"`
	Cpuusage        *CPUUsage          `protobuf:"bytes,2,opt,name=cpuusage,proto3" json:"cpuusage,omitempty"`
	Diskusage       []*DiskUsage       `protobuf:"bytes,3,rep,name=diskusage,proto3" json:"diskusage,omitempty"`
	Filesystemusage []*FileSystemUsage `protobuf:"bytes,4,rep,name=filesystemusage,proto3" json:"filesystemusage,omitempty"`
	Networkprotocol []*NetworkProtocol `protobuf:"bytes,5,rep,name=networkprotocol,proto3" json:"networkprotocol,omitempty"`
	Trafficinfo     []*TrafficInfo     `protobuf:"bytes,6,rep,name=trafficinfo,proto3" json:"trafficinfo,omitempty"`
	Tcpstates       []*TCPStates       `protobuf:"bytes,7,rep,name=tcpstates,proto3" json:"tcpstates,omitempty"`
	Listeningsocket []*ListeningSocket `protobuf:"bytes,8,rep,name=listeningsocket,proto3" json:"listeningsocket,omitempty"`
	// contains filtered or unexported fields
}

func (*Collector) Descriptor deprecated 

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

Deprecated: Use Collector.ProtoReflect.Descriptor instead.

func (*Collector) GetCpuusage 

func (x *Collector) GetCpuusage() *CPUUsage

func (*Collector) GetDiskusage 

func (x *Collector) GetDiskusage() []*DiskUsage

func (*Collector) GetFilesystemusage 

func (x *Collector) GetFilesystemusage() []*FileSystemUsage

func (*Collector) GetListeningsocket 

func (x *Collector) GetListeningsocket() []*ListeningSocket

func (*Collector) GetLoadaverage 

func (x *Collector) GetLoadaverage() *LoadAverage

func (*Collector) GetNetworkprotocol 

func (x *Collector) GetNetworkprotocol() []*NetworkProtocol

func (*Collector) GetTcpstates 

func (x *Collector) GetTcpstates() []*TCPStates

func (*Collector) GetTrafficinfo 

func (x *Collector) GetTrafficinfo() []*TrafficInfo

func (*Collector) ProtoMessage 

func (*Collector) ProtoMessage()

func (*Collector) ProtoReflect 

func (x *Collector) ProtoReflect() protoreflect.Message

func (*Collector) Reset 

func (x *Collector) Reset()

func (*Collector) String 

func (x *Collector) String() string

type DiskUsage 

type DiskUsage struct {
	Name     string  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Tps      float64 `protobuf:"fixed64,2,opt,name=tps,proto3" json:"tps,omitempty"`
	Kbpersec float64 `protobuf:"fixed64,3,opt,name=kbpersec,proto3" json:"kbpersec,omitempty"`
	// contains filtered or unexported fields
}

func (*DiskUsage) Descriptor deprecated 

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

Deprecated: Use DiskUsage.ProtoReflect.Descriptor instead.

func (*DiskUsage) GetKbpersec 

func (x *DiskUsage) GetKbpersec() float64

func (*DiskUsage) GetName 

func (x *DiskUsage) GetName() string

func (*DiskUsage) GetTps 

func (x *DiskUsage) GetTps() float64

func (*DiskUsage) ProtoMessage 

func (*DiskUsage) ProtoMessage()

func (*DiskUsage) ProtoReflect 

func (x *DiskUsage) ProtoReflect() protoreflect.Message

func (*DiskUsage) Reset 

func (x *DiskUsage) Reset()

func (*DiskUsage) String 

func (x *DiskUsage) String() string

type FileSystemUsage 

type FileSystemUsage struct {
	FileSystem   string  `protobuf:"bytes,1,opt,name=file_system,json=fileSystem,proto3" json:"file_system,omitempty"`
	Usedmb       float64 `protobuf:"fixed64,2,opt,name=usedmb,proto3" json:"usedmb,omitempty"`
	UsedPercent  float64 `protobuf:"fixed64,3,opt,name=used_percent,json=usedPercent,proto3" json:"used_percent,omitempty"`
	UsedInode    float64 `protobuf:"fixed64,4,opt,name=used_inode,json=usedInode,proto3" json:"used_inode,omitempty"`
	InodePercent float64 `protobuf:"fixed64,5,opt,name=inode_percent,json=inodePercent,proto3" json:"inode_percent,omitempty"`
	// contains filtered or unexported fields
}

func (*FileSystemUsage) Descriptor deprecated 

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

Deprecated: Use FileSystemUsage.ProtoReflect.Descriptor instead.

func (*FileSystemUsage) GetFileSystem 

func (x *FileSystemUsage) GetFileSystem() string

func (*FileSystemUsage) GetInodePercent 

func (x *FileSystemUsage) GetInodePercent() float64

func (*FileSystemUsage) GetUsedInode 

func (x *FileSystemUsage) GetUsedInode() float64

func (*FileSystemUsage) GetUsedPercent 

func (x *FileSystemUsage) GetUsedPercent() float64

func (*FileSystemUsage) GetUsedmb 

func (x *FileSystemUsage) GetUsedmb() float64

func (*FileSystemUsage) ProtoMessage 

func (*FileSystemUsage) ProtoMessage()

func (*FileSystemUsage) ProtoReflect 

func (x *FileSystemUsage) ProtoReflect() protoreflect.Message

func (*FileSystemUsage) Reset 

func (x *FileSystemUsage) Reset()

func (*FileSystemUsage) String 

func (x *FileSystemUsage) String() string

type ListeningSocket 

type ListeningSocket struct {
	Command  string `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"`
	Pid      int64  `protobuf:"varint,2,opt,name=pid,proto3" json:"pid,omitempty"`
	User     string `protobuf:"bytes,3,opt,name=user,proto3" json:"user,omitempty"`
	Protocol string `protobuf:"bytes,4,opt,name=protocol,proto3" json:"protocol,omitempty"`
	Port     int64  `protobuf:"varint,5,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*ListeningSocket) Descriptor deprecated 

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

Deprecated: Use ListeningSocket.ProtoReflect.Descriptor instead.

func (*ListeningSocket) GetCommand 

func (x *ListeningSocket) GetCommand() string

func (*ListeningSocket) GetPid 

func (x *ListeningSocket) GetPid() int64

func (*ListeningSocket) GetPort 

func (x *ListeningSocket) GetPort() int64

func (*ListeningSocket) GetProtocol 

func (x *ListeningSocket) GetProtocol() string

func (*ListeningSocket) GetUser 

func (x *ListeningSocket) GetUser() string

func (*ListeningSocket) ProtoMessage 

func (*ListeningSocket) ProtoMessage()

func (*ListeningSocket) ProtoReflect 

func (x *ListeningSocket) ProtoReflect() protoreflect.Message

func (*ListeningSocket) Reset 

func (x *ListeningSocket) Reset()

func (*ListeningSocket) String 

func (x *ListeningSocket) String() string

type LoadAverage 

type LoadAverage struct {
	OneMinute      float64 `protobuf:"fixed64,1,opt,name=one_minute,json=oneMinute,proto3" json:"one_minute,omitempty"`
	FiveMinutes    float64 `protobuf:"fixed64,2,opt,name=five_minutes,json=fiveMinutes,proto3" json:"five_minutes,omitempty"`
	FifteenMinutes float64 `protobuf:"fixed64,3,opt,name=fifteen_minutes,json=fifteenMinutes,proto3" json:"fifteen_minutes,omitempty"`
	// contains filtered or unexported fields
}

func (*LoadAverage) Descriptor deprecated 

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

Deprecated: Use LoadAverage.ProtoReflect.Descriptor instead.

func (*LoadAverage) GetFifteenMinutes 

func (x *LoadAverage) GetFifteenMinutes() float64

func (*LoadAverage) GetFiveMinutes 

func (x *LoadAverage) GetFiveMinutes() float64

func (*LoadAverage) GetOneMinute 

func (x *LoadAverage) GetOneMinute() float64

func (*LoadAverage) ProtoMessage 

func (*LoadAverage) ProtoMessage()

func (*LoadAverage) ProtoReflect 

func (x *LoadAverage) ProtoReflect() protoreflect.Message

func (*LoadAverage) Reset 

func (x *LoadAverage) Reset()

func (*LoadAverage) String 

func (x *LoadAverage) String() string

type MetricsCollectorClient 

type MetricsCollectorClient interface {
	CollectMetrics(ctx context.Context, in *MetricsRequest, opts ...grpc.CallOption) (MetricsCollector_CollectMetricsClient, error)
}

MetricsCollectorClient is the client API for MetricsCollector service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewMetricsCollectorClient 

func NewMetricsCollectorClient(cc grpc.ClientConnInterface) MetricsCollectorClient

type MetricsCollectorServer 

type MetricsCollectorServer interface {
	CollectMetrics(*MetricsRequest, MetricsCollector_CollectMetricsServer) error
	// contains filtered or unexported methods
}

MetricsCollectorServer is the server API for MetricsCollector service. All implementations must embed UnimplementedMetricsCollectorServer for forward compatibility

type MetricsCollector_CollectMetricsClient 

type MetricsCollector_CollectMetricsClient interface {
	Recv() (*MetricsResponse, error)
	grpc.ClientStream
}

type MetricsCollector_CollectMetricsServer 

type MetricsCollector_CollectMetricsServer interface {
	Send(*MetricsResponse) error
	grpc.ServerStream
}

type MetricsRequest 

type MetricsRequest struct {
	NSecond int32 `protobuf:"varint,1,opt,name=n_second,json=nSecond,proto3" json:"n_second,omitempty"`
	MSecond int32 `protobuf:"varint,2,opt,name=m_second,json=mSecond,proto3" json:"m_second,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricsRequest) Descriptor deprecated 

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

Deprecated: Use MetricsRequest.ProtoReflect.Descriptor instead.

func (*MetricsRequest) GetMSecond 

func (x *MetricsRequest) GetMSecond() int32

func (*MetricsRequest) GetNSecond 

func (x *MetricsRequest) GetNSecond() int32

func (*MetricsRequest) ProtoMessage 

func (*MetricsRequest) ProtoMessage()

func (*MetricsRequest) ProtoReflect 

func (x *MetricsRequest) ProtoReflect() protoreflect.Message

func (*MetricsRequest) Reset 

func (x *MetricsRequest) Reset()

func (*MetricsRequest) String 

func (x *MetricsRequest) String() string

type MetricsResponse 

type MetricsResponse struct {
	Collector *Collector `protobuf:"bytes,1,opt,name=collector,proto3" json:"collector,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricsResponse) Descriptor deprecated 

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

Deprecated: Use MetricsResponse.ProtoReflect.Descriptor instead.

func (*MetricsResponse) GetCollector 

func (x *MetricsResponse) GetCollector() *Collector

func (*MetricsResponse) ProtoMessage 

func (*MetricsResponse) ProtoMessage()

func (*MetricsResponse) ProtoReflect 

func (x *MetricsResponse) ProtoReflect() protoreflect.Message

func (*MetricsResponse) Reset 

func (x *MetricsResponse) Reset()

func (*MetricsResponse) String 

func (x *MetricsResponse) String() string

type NetworkProtocol 

type NetworkProtocol struct {
	Protocol string  `protobuf:"bytes,1,opt,name=protocol,proto3" json:"protocol,omitempty"`
	Bytes    int64   `protobuf:"varint,2,opt,name=bytes,proto3" json:"bytes,omitempty"`
	Percent  float64 `protobuf:"fixed64,3,opt,name=percent,proto3" json:"percent,omitempty"`
	// contains filtered or unexported fields
}

func (*NetworkProtocol) Descriptor deprecated 

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

Deprecated: Use NetworkProtocol.ProtoReflect.Descriptor instead.

func (*NetworkProtocol) GetBytes 

func (x *NetworkProtocol) GetBytes() int64

func (*NetworkProtocol) GetPercent 

func (x *NetworkProtocol) GetPercent() float64

func (*NetworkProtocol) GetProtocol 

func (x *NetworkProtocol) GetProtocol() string

func (*NetworkProtocol) ProtoMessage 

func (*NetworkProtocol) ProtoMessage()

func (*NetworkProtocol) ProtoReflect 

func (x *NetworkProtocol) ProtoReflect() protoreflect.Message

func (*NetworkProtocol) Reset 

func (x *NetworkProtocol) Reset()

func (*NetworkProtocol) String 

func (x *NetworkProtocol) String() string

type TCPStates 

type TCPStates struct {
	State string `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	Count int64  `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*TCPStates) Descriptor deprecated 

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

Deprecated: Use TCPStates.ProtoReflect.Descriptor instead.

func (*TCPStates) GetCount 

func (x *TCPStates) GetCount() int64

func (*TCPStates) GetState 

func (x *TCPStates) GetState() string

func (*TCPStates) ProtoMessage 

func (*TCPStates) ProtoMessage()

func (*TCPStates) ProtoReflect 

func (x *TCPStates) ProtoReflect() protoreflect.Message

func (*TCPStates) Reset 

func (x *TCPStates) Reset()

func (*TCPStates) String 

func (x *TCPStates) String() string

type TrafficInfo 

type TrafficInfo struct {
	Sourceip   string  `protobuf:"bytes,1,opt,name=sourceip,proto3" json:"sourceip,omitempty"`
	SourcePort int64   `protobuf:"varint,2,opt,name=source_port,json=sourcePort,proto3" json:"source_port,omitempty"`
	Destip     string  `protobuf:"bytes,3,opt,name=destip,proto3" json:"destip,omitempty"`
	DestPort   int64   `protobuf:"varint,4,opt,name=dest_port,json=destPort,proto3" json:"dest_port,omitempty"`
	Protocol   string  `protobuf:"bytes,5,opt,name=protocol,proto3" json:"protocol,omitempty"`
	Bps        float64 `protobuf:"fixed64,6,opt,name=bps,proto3" json:"bps,omitempty"`
	Bytes      int64   `protobuf:"varint,7,opt,name=Bytes,proto3" json:"Bytes,omitempty"`
	State      string  `protobuf:"bytes,8,opt,name=State,proto3" json:"State,omitempty"`
	// contains filtered or unexported fields
}

func (*TrafficInfo) Descriptor deprecated 

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

Deprecated: Use TrafficInfo.ProtoReflect.Descriptor instead.

func (*TrafficInfo) GetBps 

func (x *TrafficInfo) GetBps() float64

func (*TrafficInfo) GetBytes 

func (x *TrafficInfo) GetBytes() int64

func (*TrafficInfo) GetDestPort 

func (x *TrafficInfo) GetDestPort() int64

func (*TrafficInfo) GetDestip 

func (x *TrafficInfo) GetDestip() string

func (*TrafficInfo) GetProtocol 

func (x *TrafficInfo) GetProtocol() string

func (*TrafficInfo) GetSourcePort 

func (x *TrafficInfo) GetSourcePort() int64

func (*TrafficInfo) GetSourceip 

func (x *TrafficInfo) GetSourceip() string

func (*TrafficInfo) GetState 

func (x *TrafficInfo) GetState() string

func (*TrafficInfo) ProtoMessage 

func (*TrafficInfo) ProtoMessage()

func (*TrafficInfo) ProtoReflect 

func (x *TrafficInfo) ProtoReflect() protoreflect.Message

func (*TrafficInfo) Reset 

func (x *TrafficInfo) Reset()

func (*TrafficInfo) String 

func (x *TrafficInfo) String() string

type UnimplementedMetricsCollectorServer 

type UnimplementedMetricsCollectorServer struct {
}

UnimplementedMetricsCollectorServer must be embedded to have forward compatible implementations.

func (UnimplementedMetricsCollectorServer) CollectMetrics 

func (UnimplementedMetricsCollectorServer) CollectMetrics(*MetricsRequest, MetricsCollector_CollectMetricsServer) error

type UnsafeMetricsCollectorServer 

type UnsafeMetricsCollectorServer interface {
	// contains filtered or unexported methods
}

UnsafeMetricsCollectorServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MetricsCollectorServer will result in compilation errors.

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.