nexclipper

package
v0.2.1-0...-6d22bef Latest Latest
Warning

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

 Go to latest Published: Dec 11, 2019 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Metric_SourceType_name = map[int32]string{
	0:  "NONE",
	1:  "NODE",
	2:  "PROCESS",
	3:  "CONTAINER",
	10: "K8S_NODE",
	11: "K8S_POD",
	12: "K8S_CONTAINER",
}
View Source 
var Metric_SourceType_value = map[string]int32{
	"NONE":          0,
	"NODE":          1,
	"PROCESS":       2,
	"CONTAINER":     3,
	"K8S_NODE":      10,
	"K8S_POD":       11,
	"K8S_CONTAINER": 12,
}

Functions

func RegisterCollectorServer 

func RegisterCollectorServer(s *grpc.Server, srv CollectorServer)

Types

type Agent 

type Agent struct {
	Version              string   `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	MachineId            string   `protobuf:"bytes,2,opt,name=machineId,proto3" json:"machineId,omitempty"`
	Cluster              string   `protobuf:"bytes,3,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Node                 *Node    `protobuf:"bytes,4,opt,name=node,proto3" json:"node,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Agent) Descriptor 

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

func (*Agent) GetCluster 

func (m *Agent) GetCluster() string

func (*Agent) GetMachineId 

func (m *Agent) GetMachineId() string

func (*Agent) GetNode 

func (m *Agent) GetNode() *Node

func (*Agent) GetVersion 

func (m *Agent) GetVersion() string

func (*Agent) ProtoMessage 

func (*Agent) ProtoMessage()

func (*Agent) Reset 

func (m *Agent) Reset()

func (*Agent) String 

func (m *Agent) String() string

func (*Agent) XXX_DiscardUnknown 

func (m *Agent) XXX_DiscardUnknown()

func (*Agent) XXX_Marshal 

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

func (*Agent) XXX_Merge 

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

func (*Agent) XXX_Size 

func (m *Agent) XXX_Size() int

func (*Agent) XXX_Unmarshal 

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

type CPU 

type CPU struct {
	Cpu                  int32    `protobuf:"varint,1,opt,name=cpu,proto3" json:"cpu,omitempty"`
	VendorId             string   `protobuf:"bytes,2,opt,name=vendor_id,json=vendorId,proto3" json:"vendor_id,omitempty"`
	Family               string   `protobuf:"bytes,3,opt,name=family,proto3" json:"family,omitempty"`
	Model                string   `protobuf:"bytes,4,opt,name=model,proto3" json:"model,omitempty"`
	Stepping             int32    `protobuf:"varint,5,opt,name=stepping,proto3" json:"stepping,omitempty"`
	PhysicalId           string   `protobuf:"bytes,6,opt,name=physical_id,json=physicalId,proto3" json:"physical_id,omitempty"`
	CoreId               string   `protobuf:"bytes,7,opt,name=core_id,json=coreId,proto3" json:"core_id,omitempty"`
	Cores                int32    `protobuf:"varint,8,opt,name=cores,proto3" json:"cores,omitempty"`
	ModelName            string   `protobuf:"bytes,9,opt,name=model_name,json=modelName,proto3" json:"model_name,omitempty"`
	Mhz                  float64  `protobuf:"fixed64,10,opt,name=mhz,proto3" json:"mhz,omitempty"`
	CacheSize            int32    `protobuf:"varint,11,opt,name=cache_size,json=cacheSize,proto3" json:"cache_size,omitempty"`
	Microcode            string   `protobuf:"bytes,12,opt,name=microcode,proto3" json:"microcode,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CPU) Descriptor 

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

func (*CPU) GetCacheSize 

func (m *CPU) GetCacheSize() int32

func (*CPU) GetCoreId 

func (m *CPU) GetCoreId() string

func (*CPU) GetCores 

func (m *CPU) GetCores() int32

func (*CPU) GetCpu 

func (m *CPU) GetCpu() int32

func (*CPU) GetFamily 

func (m *CPU) GetFamily() string

func (*CPU) GetMhz 

func (m *CPU) GetMhz() float64

func (*CPU) GetMicrocode 

func (m *CPU) GetMicrocode() string

func (*CPU) GetModel 

func (m *CPU) GetModel() string

func (*CPU) GetModelName 

func (m *CPU) GetModelName() string

func (*CPU) GetPhysicalId 

func (m *CPU) GetPhysicalId() string

func (*CPU) GetStepping 

func (m *CPU) GetStepping() int32

func (*CPU) GetVendorId 

func (m *CPU) GetVendorId() string

func (*CPU) ProtoMessage 

func (*CPU) ProtoMessage()

func (*CPU) Reset 

func (m *CPU) Reset()

func (*CPU) String 

func (m *CPU) String() string

func (*CPU) XXX_DiscardUnknown 

func (m *CPU) XXX_DiscardUnknown()

func (*CPU) XXX_Marshal 

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

func (*CPU) XXX_Merge 

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

func (*CPU) XXX_Size 

func (m *CPU) XXX_Size() int

func (*CPU) XXX_Unmarshal 

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

type CollectorClient 

type CollectorClient interface {
	Ping(ctx context.Context, opts ...grpc.CallOption) (Collector_PingClient, error)
	UpdateAgent(ctx context.Context, in *Agent, opts ...grpc.CallOption) (*Response, error)
	UpdateProcess(ctx context.Context, in *ProcessAll, opts ...grpc.CallOption) (*Response, error)
	UpdateContainer(ctx context.Context, in *ContainerAll, opts ...grpc.CallOption) (*Response, error)
	ReportMetrics(ctx context.Context, in *Metrics, opts ...grpc.CallOption) (*Response, error)
	ReportNodeMetrics(ctx context.Context, in *NodeMetrics, opts ...grpc.CallOption) (*Response, error)
	ReportProcessMetrics(ctx context.Context, in *ProcessMetrics, opts ...grpc.CallOption) (*Response, error)
	ReportContainerMetrics(ctx context.Context, in *ContainerMetrics, opts ...grpc.CallOption) (*Response, error)
	UpdateK8SCluster(ctx context.Context, in *K8SCluster, opts ...grpc.CallOption) (*Response, error)
	ReportK8SMetrics(ctx context.Context, in *K8SMetrics, opts ...grpc.CallOption) (*Response, error)
}

CollectorClient is the client API for Collector service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewCollectorClient 

func NewCollectorClient(cc *grpc.ClientConn) CollectorClient

type CollectorServer 

type CollectorServer interface {
	Ping(Collector_PingServer) error
	UpdateAgent(context.Context, *Agent) (*Response, error)
	UpdateProcess(context.Context, *ProcessAll) (*Response, error)
	UpdateContainer(context.Context, *ContainerAll) (*Response, error)
	ReportMetrics(context.Context, *Metrics) (*Response, error)
	ReportNodeMetrics(context.Context, *NodeMetrics) (*Response, error)
	ReportProcessMetrics(context.Context, *ProcessMetrics) (*Response, error)
	ReportContainerMetrics(context.Context, *ContainerMetrics) (*Response, error)
	UpdateK8SCluster(context.Context, *K8SCluster) (*Response, error)
	ReportK8SMetrics(context.Context, *K8SMetrics) (*Response, error)
}

CollectorServer is the server API for Collector service.

type Collector_PingClient 

type Collector_PingClient interface {
	Send(*Status) error
	Recv() (*Status, error)
	grpc.ClientStream
}

type Collector_PingServer 

type Collector_PingServer interface {
	Send(*Status) error
	Recv() (*Status, error)
	grpc.ServerStream
}

type Container 

type Container struct {
	Type                 string   `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	ContainerId          string   `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	Name                 string   `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Image                string   `protobuf:"bytes,4,opt,name=image,proto3" json:"image,omitempty"`
	Metrics              *Metrics `protobuf:"bytes,6,opt,name=metrics,proto3" json:"metrics,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Container) Descriptor 

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

func (*Container) GetContainerId 

func (m *Container) GetContainerId() string

func (*Container) GetImage 

func (m *Container) GetImage() string

func (*Container) GetMetrics 

func (m *Container) GetMetrics() *Metrics

func (*Container) GetName 

func (m *Container) GetName() string

func (*Container) GetType 

func (m *Container) GetType() string

func (*Container) ProtoMessage 

func (*Container) ProtoMessage()

func (*Container) Reset 

func (m *Container) Reset()

func (*Container) String 

func (m *Container) String() string

func (*Container) XXX_DiscardUnknown 

func (m *Container) XXX_DiscardUnknown()

func (*Container) XXX_Marshal 

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

func (*Container) XXX_Merge 

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

func (*Container) XXX_Size 

func (m *Container) XXX_Size() int

func (*Container) XXX_Unmarshal 

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

type ContainerAll 

type ContainerAll struct {
	Cluster              string       `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Host                 string       `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	Containers           []*Container `protobuf:"bytes,3,rep,name=containers,proto3" json:"containers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ContainerAll) Descriptor 

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

func (*ContainerAll) GetCluster 

func (m *ContainerAll) GetCluster() string

func (*ContainerAll) GetContainers 

func (m *ContainerAll) GetContainers() []*Container

func (*ContainerAll) GetHost 

func (m *ContainerAll) GetHost() string

func (*ContainerAll) ProtoMessage 

func (*ContainerAll) ProtoMessage()

func (*ContainerAll) Reset 

func (m *ContainerAll) Reset()

func (*ContainerAll) String 

func (m *ContainerAll) String() string

func (*ContainerAll) XXX_DiscardUnknown 

func (m *ContainerAll) XXX_DiscardUnknown()

func (*ContainerAll) XXX_Marshal 

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

func (*ContainerAll) XXX_Merge 

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

func (*ContainerAll) XXX_Size 

func (m *ContainerAll) XXX_Size() int

func (*ContainerAll) XXX_Unmarshal 

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

type ContainerMetrics 

type ContainerMetrics struct {
	Cluster              string   `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Host                 string   `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	ContainerId          string   `protobuf:"bytes,3,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	Metrics              *Metrics `protobuf:"bytes,4,opt,name=metrics,proto3" json:"metrics,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ContainerMetrics) Descriptor 

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

func (*ContainerMetrics) GetCluster 

func (m *ContainerMetrics) GetCluster() string

func (*ContainerMetrics) GetContainerId 

func (m *ContainerMetrics) GetContainerId() string

func (*ContainerMetrics) GetHost 

func (m *ContainerMetrics) GetHost() string

func (*ContainerMetrics) GetMetrics 

func (m *ContainerMetrics) GetMetrics() *Metrics

func (*ContainerMetrics) ProtoMessage 

func (*ContainerMetrics) ProtoMessage()

func (*ContainerMetrics) Reset 

func (m *ContainerMetrics) Reset()

func (*ContainerMetrics) String 

func (m *ContainerMetrics) String() string

func (*ContainerMetrics) XXX_DiscardUnknown 

func (m *ContainerMetrics) XXX_DiscardUnknown()

func (*ContainerMetrics) XXX_Marshal 

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

func (*ContainerMetrics) XXX_Merge 

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

func (*ContainerMetrics) XXX_Size 

func (m *ContainerMetrics) XXX_Size() int

func (*ContainerMetrics) XXX_Unmarshal 

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

type K8SCluster 

type K8SCluster struct {
	Object               *K8SObject      `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	AgentCluster         string          `protobuf:"bytes,2,opt,name=agent_cluster,json=agentCluster,proto3" json:"agent_cluster,omitempty"`
	K8SNamespaces        []*K8SNamespace `protobuf:"bytes,3,rep,name=k8s_namespaces,json=k8sNamespaces,proto3" json:"k8s_namespaces,omitempty"`
	K8SNodes             []*K8SObject    `protobuf:"bytes,4,rep,name=k8s_nodes,json=k8sNodes,proto3" json:"k8s_nodes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*K8SCluster) Descriptor 

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

func (*K8SCluster) GetAgentCluster 

func (m *K8SCluster) GetAgentCluster() string

func (*K8SCluster) GetK8SNamespaces 

func (m *K8SCluster) GetK8SNamespaces() []*K8SNamespace

func (*K8SCluster) GetK8SNodes 

func (m *K8SCluster) GetK8SNodes() []*K8SObject

func (*K8SCluster) GetObject 

func (m *K8SCluster) GetObject() *K8SObject

func (*K8SCluster) ProtoMessage 

func (*K8SCluster) ProtoMessage()

func (*K8SCluster) Reset 

func (m *K8SCluster) Reset()

func (*K8SCluster) String 

func (m *K8SCluster) String() string

func (*K8SCluster) XXX_DiscardUnknown 

func (m *K8SCluster) XXX_DiscardUnknown()

func (*K8SCluster) XXX_Marshal 

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

func (*K8SCluster) XXX_Merge 

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

func (*K8SCluster) XXX_Size 

func (m *K8SCluster) XXX_Size() int

func (*K8SCluster) XXX_Unmarshal 

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

type K8SContainerMetric 

type K8SContainerMetric struct {
	Container            string    `protobuf:"bytes,1,opt,name=container,proto3" json:"container,omitempty"`
	Metrics              []*Metric `protobuf:"bytes,2,rep,name=metrics,proto3" json:"metrics,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*K8SContainerMetric) Descriptor 

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

func (*K8SContainerMetric) GetContainer 

func (m *K8SContainerMetric) GetContainer() string

func (*K8SContainerMetric) GetMetrics 

func (m *K8SContainerMetric) GetMetrics() []*Metric

func (*K8SContainerMetric) ProtoMessage 

func (*K8SContainerMetric) ProtoMessage()

func (*K8SContainerMetric) Reset 

func (m *K8SContainerMetric) Reset()

func (*K8SContainerMetric) String 

func (m *K8SContainerMetric) String() string

func (*K8SContainerMetric) XXX_DiscardUnknown 

func (m *K8SContainerMetric) XXX_DiscardUnknown()

func (*K8SContainerMetric) XXX_Marshal 

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

func (*K8SContainerMetric) XXX_Merge 

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

func (*K8SContainerMetric) XXX_Size 

func (m *K8SContainerMetric) XXX_Size() int

func (*K8SContainerMetric) XXX_Unmarshal 

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

type K8SMetrics 

type K8SMetrics struct {
	AgentCluster         string           `protobuf:"bytes,1,opt,name=agent_cluster,json=agentCluster,proto3" json:"agent_cluster,omitempty"`
	K8SCluster           string           `protobuf:"bytes,2,opt,name=k8s_cluster,json=k8sCluster,proto3" json:"k8s_cluster,omitempty"`
	K8SNodeMetrics       []*K8SNodeMetric `protobuf:"bytes,3,rep,name=k8s_node_metrics,json=k8sNodeMetrics,proto3" json:"k8s_node_metrics,omitempty"`
	K8SPodMetrics        []*K8SPodMetric  `protobuf:"bytes,4,rep,name=k8s_pod_metrics,json=k8sPodMetrics,proto3" json:"k8s_pod_metrics,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*K8SMetrics) Descriptor 

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

func (*K8SMetrics) GetAgentCluster 

func (m *K8SMetrics) GetAgentCluster() string

func (*K8SMetrics) GetK8SCluster 

func (m *K8SMetrics) GetK8SCluster() string

func (*K8SMetrics) GetK8SNodeMetrics 

func (m *K8SMetrics) GetK8SNodeMetrics() []*K8SNodeMetric

func (*K8SMetrics) GetK8SPodMetrics 

func (m *K8SMetrics) GetK8SPodMetrics() []*K8SPodMetric

func (*K8SMetrics) ProtoMessage 

func (*K8SMetrics) ProtoMessage()

func (*K8SMetrics) Reset 

func (m *K8SMetrics) Reset()

func (*K8SMetrics) String 

func (m *K8SMetrics) String() string

func (*K8SMetrics) XXX_DiscardUnknown 

func (m *K8SMetrics) XXX_DiscardUnknown()

func (*K8SMetrics) XXX_Marshal 

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

func (*K8SMetrics) XXX_Merge 

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

func (*K8SMetrics) XXX_Size 

func (m *K8SMetrics) XXX_Size() int

func (*K8SMetrics) XXX_Unmarshal 

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

type K8SNamespace 

type K8SNamespace struct {
	Object               *K8SObject   `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	Items                []*K8SObject `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"`
	Workloads            []*K8SObject `protobuf:"bytes,3,rep,name=workloads,proto3" json:"workloads,omitempty"`
	Pods                 []*K8SPod    `protobuf:"bytes,4,rep,name=pods,proto3" json:"pods,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*K8SNamespace) Descriptor 

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

func (*K8SNamespace) GetItems 

func (m *K8SNamespace) GetItems() []*K8SObject

func (*K8SNamespace) GetObject 

func (m *K8SNamespace) GetObject() *K8SObject

func (*K8SNamespace) GetPods 

func (m *K8SNamespace) GetPods() []*K8SPod

func (*K8SNamespace) GetWorkloads 

func (m *K8SNamespace) GetWorkloads() []*K8SObject

func (*K8SNamespace) ProtoMessage 

func (*K8SNamespace) ProtoMessage()

func (*K8SNamespace) Reset 

func (m *K8SNamespace) Reset()

func (*K8SNamespace) String 

func (m *K8SNamespace) String() string

func (*K8SNamespace) XXX_DiscardUnknown 

func (m *K8SNamespace) XXX_DiscardUnknown()

func (*K8SNamespace) XXX_Marshal 

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

func (*K8SNamespace) XXX_Merge 

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

func (*K8SNamespace) XXX_Size 

func (m *K8SNamespace) XXX_Size() int

func (*K8SNamespace) XXX_Unmarshal 

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

type K8SNodeMetric 

type K8SNodeMetric struct {
	NodeName             string    `protobuf:"bytes,1,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	Metrics              []*Metric `protobuf:"bytes,2,rep,name=metrics,proto3" json:"metrics,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*K8SNodeMetric) Descriptor 

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

func (*K8SNodeMetric) GetMetrics 

func (m *K8SNodeMetric) GetMetrics() []*Metric

func (*K8SNodeMetric) GetNodeName 

func (m *K8SNodeMetric) GetNodeName() string

func (*K8SNodeMetric) ProtoMessage 

func (*K8SNodeMetric) ProtoMessage()

func (*K8SNodeMetric) Reset 

func (m *K8SNodeMetric) Reset()

func (*K8SNodeMetric) String 

func (m *K8SNodeMetric) String() string

func (*K8SNodeMetric) XXX_DiscardUnknown 

func (m *K8SNodeMetric) XXX_DiscardUnknown()

func (*K8SNodeMetric) XXX_Marshal 

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

func (*K8SNodeMetric) XXX_Merge 

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

func (*K8SNodeMetric) XXX_Size 

func (m *K8SNodeMetric) XXX_Size() int

func (*K8SNodeMetric) XXX_Unmarshal 

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

type K8SObject 

type K8SObject struct {
	ApiVersion           string            `protobuf:"bytes,4,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"`
	Metadata             string            `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Spec                 string            `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	Status               string            `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	Kind                 string            `protobuf:"bytes,5,opt,name=kind,proto3" json:"kind,omitempty"`
	Name                 string            `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty"`
	Labels               map[string]string `` /* 153-byte string literal not displayed */
	K8SCluster           string            `protobuf:"bytes,8,opt,name=k8s_cluster,json=k8sCluster,proto3" json:"k8s_cluster,omitempty"`
	K8SNamespace         string            `protobuf:"bytes,9,opt,name=k8s_namespace,json=k8sNamespace,proto3" json:"k8s_namespace,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*K8SObject) Descriptor 

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

func (*K8SObject) GetApiVersion 

func (m *K8SObject) GetApiVersion() string

func (*K8SObject) GetK8SCluster 

func (m *K8SObject) GetK8SCluster() string

func (*K8SObject) GetK8SNamespace 

func (m *K8SObject) GetK8SNamespace() string

func (*K8SObject) GetKind 

func (m *K8SObject) GetKind() string

func (*K8SObject) GetLabels 

func (m *K8SObject) GetLabels() map[string]string

func (*K8SObject) GetMetadata 

func (m *K8SObject) GetMetadata() string

func (*K8SObject) GetName 

func (m *K8SObject) GetName() string

func (*K8SObject) GetSpec 

func (m *K8SObject) GetSpec() string

func (*K8SObject) GetStatus 

func (m *K8SObject) GetStatus() string

func (*K8SObject) ProtoMessage 

func (*K8SObject) ProtoMessage()

func (*K8SObject) Reset 

func (m *K8SObject) Reset()

func (*K8SObject) String 

func (m *K8SObject) String() string

func (*K8SObject) XXX_DiscardUnknown 

func (m *K8SObject) XXX_DiscardUnknown()

func (*K8SObject) XXX_Marshal 

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

func (*K8SObject) XXX_Merge 

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

func (*K8SObject) XXX_Size 

func (m *K8SObject) XXX_Size() int

func (*K8SObject) XXX_Unmarshal 

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

type K8SPod 

type K8SPod struct {
	Object               *K8SObject   `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	Qos                  string       `protobuf:"bytes,2,opt,name=qos,proto3" json:"qos,omitempty"`
	Containers           []*Container `protobuf:"bytes,3,rep,name=containers,proto3" json:"containers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*K8SPod) Descriptor 

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

func (*K8SPod) GetContainers 

func (m *K8SPod) GetContainers() []*Container

func (*K8SPod) GetObject 

func (m *K8SPod) GetObject() *K8SObject

func (*K8SPod) GetQos 

func (m *K8SPod) GetQos() string

func (*K8SPod) ProtoMessage 

func (*K8SPod) ProtoMessage()

func (*K8SPod) Reset 

func (m *K8SPod) Reset()

func (*K8SPod) String 

func (m *K8SPod) String() string

func (*K8SPod) XXX_DiscardUnknown 

func (m *K8SPod) XXX_DiscardUnknown()

func (*K8SPod) XXX_Marshal 

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

func (*K8SPod) XXX_Merge 

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

func (*K8SPod) XXX_Size 

func (m *K8SPod) XXX_Size() int

func (*K8SPod) XXX_Unmarshal 

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

type K8SPodMetric 

type K8SPodMetric struct {
	Namespace            string                `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	PodName              string                `protobuf:"bytes,2,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"`
	K8SContainerMetrics  []*K8SContainerMetric `protobuf:"bytes,3,rep,name=k8s_container_metrics,json=k8sContainerMetrics,proto3" json:"k8s_container_metrics,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*K8SPodMetric) Descriptor 

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

func (*K8SPodMetric) GetK8SContainerMetrics 

func (m *K8SPodMetric) GetK8SContainerMetrics() []*K8SContainerMetric

func (*K8SPodMetric) GetNamespace 

func (m *K8SPodMetric) GetNamespace() string

func (*K8SPodMetric) GetPodName 

func (m *K8SPodMetric) GetPodName() string

func (*K8SPodMetric) ProtoMessage 

func (*K8SPodMetric) ProtoMessage()

func (*K8SPodMetric) Reset 

func (m *K8SPodMetric) Reset()

func (*K8SPodMetric) String 

func (m *K8SPodMetric) String() string

func (*K8SPodMetric) XXX_DiscardUnknown 

func (m *K8SPodMetric) XXX_DiscardUnknown()

func (*K8SPodMetric) XXX_Marshal 

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

func (*K8SPodMetric) XXX_Merge 

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

func (*K8SPodMetric) XXX_Size 

func (m *K8SPodMetric) XXX_Size() int

func (*K8SPodMetric) XXX_Unmarshal 

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

type Metric 

type Metric struct {
	Value                float64           `protobuf:"fixed64,1,opt,name=value,proto3" json:"value,omitempty"`
	Ts                   int64             `protobuf:"varint,2,opt,name=ts,proto3" json:"ts,omitempty"`
	Cluster              string            `protobuf:"bytes,3,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Node                 string            `protobuf:"bytes,4,opt,name=node,proto3" json:"node,omitempty"`
	SourceType           Metric_SourceType `protobuf:"varint,5,opt,name=source_type,json=sourceType,proto3,enum=Metric_SourceType" json:"source_type,omitempty"`
	Source               string            `protobuf:"bytes,6,opt,name=source,proto3" json:"source,omitempty"`
	SourceInt            int32             `protobuf:"varint,7,opt,name=source_int,json=sourceInt,proto3" json:"source_int,omitempty"`
	Endpoint             string            `protobuf:"bytes,8,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Name                 string            `protobuf:"bytes,9,opt,name=name,proto3" json:"name,omitempty"`
	Label                string            `protobuf:"bytes,10,opt,name=label,proto3" json:"label,omitempty"`
	Type                 string            `protobuf:"bytes,11,opt,name=type,proto3" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Metric) Descriptor 

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

func (*Metric) GetCluster 

func (m *Metric) GetCluster() string

func (*Metric) GetEndpoint 

func (m *Metric) GetEndpoint() string

func (*Metric) GetLabel 

func (m *Metric) GetLabel() string

func (*Metric) GetName 

func (m *Metric) GetName() string

func (*Metric) GetNode 

func (m *Metric) GetNode() string

func (*Metric) GetSource 

func (m *Metric) GetSource() string

func (*Metric) GetSourceInt 

func (m *Metric) GetSourceInt() int32

func (*Metric) GetSourceType 

func (m *Metric) GetSourceType() Metric_SourceType

func (*Metric) GetTs 

func (m *Metric) GetTs() int64

func (*Metric) GetType 

func (m *Metric) GetType() string

func (*Metric) GetValue 

func (m *Metric) GetValue() float64

func (*Metric) ProtoMessage 

func (*Metric) ProtoMessage()

func (*Metric) Reset 

func (m *Metric) Reset()

func (*Metric) String 

func (m *Metric) String() string

func (*Metric) XXX_DiscardUnknown 

func (m *Metric) XXX_DiscardUnknown()

func (*Metric) XXX_Marshal 

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

func (*Metric) XXX_Merge 

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

func (*Metric) XXX_Size 

func (m *Metric) XXX_Size() int

func (*Metric) XXX_Unmarshal 

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

type Metric_SourceType 

type Metric_SourceType int32
const (
	Metric_NONE          Metric_SourceType = 0
	Metric_NODE          Metric_SourceType = 1
	Metric_PROCESS       Metric_SourceType = 2
	Metric_CONTAINER     Metric_SourceType = 3
	Metric_K8S_NODE      Metric_SourceType = 10
	Metric_K8S_POD       Metric_SourceType = 11
	Metric_K8S_CONTAINER Metric_SourceType = 12
)

func (Metric_SourceType) EnumDescriptor 

func (Metric_SourceType) EnumDescriptor() ([]byte, []int)

func (Metric_SourceType) String 

func (x Metric_SourceType) String() string

type Metrics 

type Metrics struct {
	Metrics              []*Metric `protobuf:"bytes,2,rep,name=metrics,proto3" json:"metrics,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*Metrics) Descriptor 

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

func (*Metrics) GetMetrics 

func (m *Metrics) GetMetrics() []*Metric

func (*Metrics) ProtoMessage 

func (*Metrics) ProtoMessage()

func (*Metrics) Reset 

func (m *Metrics) Reset()

func (*Metrics) String 

func (m *Metrics) String() string

func (*Metrics) XXX_DiscardUnknown 

func (m *Metrics) XXX_DiscardUnknown()

func (*Metrics) XXX_Marshal 

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

func (*Metrics) XXX_Merge 

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

func (*Metrics) XXX_Size 

func (m *Metrics) XXX_Size() int

func (*Metrics) XXX_Unmarshal 

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

type Node 

type Node struct {
	Host                 string   `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Os                   string   `protobuf:"bytes,2,opt,name=os,proto3" json:"os,omitempty"`
	Platform             string   `protobuf:"bytes,3,opt,name=platform,proto3" json:"platform,omitempty"`
	PlatformFamily       string   `protobuf:"bytes,4,opt,name=platform_family,json=platformFamily,proto3" json:"platform_family,omitempty"`
	PlatformVersion      string   `protobuf:"bytes,5,opt,name=platform_version,json=platformVersion,proto3" json:"platform_version,omitempty"`
	VirtualizationSystem string   `protobuf:"bytes,6,opt,name=virtualization_system,json=virtualizationSystem,proto3" json:"virtualization_system,omitempty"`
	VirtualizationRole   string   `protobuf:"bytes,7,opt,name=virtualization_role,json=virtualizationRole,proto3" json:"virtualization_role,omitempty"`
	Uptime               uint64   `protobuf:"varint,8,opt,name=uptime,proto3" json:"uptime,omitempty"`
	Ipv4                 string   `protobuf:"bytes,9,opt,name=ipv4,proto3" json:"ipv4,omitempty"`
	Ipv6                 string   `protobuf:"bytes,10,opt,name=ipv6,proto3" json:"ipv6,omitempty"`
	Port                 uint32   `protobuf:"varint,11,opt,name=port,proto3" json:"port,omitempty"`
	Metrics              *Metrics `protobuf:"bytes,12,opt,name=metrics,proto3" json:"metrics,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Node) Descriptor 

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

func (*Node) GetHost 

func (m *Node) GetHost() string

func (*Node) GetIpv4 

func (m *Node) GetIpv4() string

func (*Node) GetIpv6 

func (m *Node) GetIpv6() string

func (*Node) GetMetrics 

func (m *Node) GetMetrics() *Metrics

func (*Node) GetOs 

func (m *Node) GetOs() string

func (*Node) GetPlatform 

func (m *Node) GetPlatform() string

func (*Node) GetPlatformFamily 

func (m *Node) GetPlatformFamily() string

func (*Node) GetPlatformVersion 

func (m *Node) GetPlatformVersion() string

func (*Node) GetPort 

func (m *Node) GetPort() uint32

func (*Node) GetUptime 

func (m *Node) GetUptime() uint64

func (*Node) GetVirtualizationRole 

func (m *Node) GetVirtualizationRole() string

func (*Node) GetVirtualizationSystem 

func (m *Node) GetVirtualizationSystem() string

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) Reset 

func (m *Node) Reset()

func (*Node) String 

func (m *Node) String() string

func (*Node) XXX_DiscardUnknown 

func (m *Node) XXX_DiscardUnknown()

func (*Node) XXX_Marshal 

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

func (*Node) XXX_Merge 

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

func (*Node) XXX_Size 

func (m *Node) XXX_Size() int

func (*Node) XXX_Unmarshal 

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

type NodeMetrics 

type NodeMetrics struct {
	Cluster              string   `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Host                 string   `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	Metrics              *Metrics `protobuf:"bytes,3,opt,name=metrics,proto3" json:"metrics,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodeMetrics) Descriptor 

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

func (*NodeMetrics) GetCluster 

func (m *NodeMetrics) GetCluster() string

func (*NodeMetrics) GetHost 

func (m *NodeMetrics) GetHost() string

func (*NodeMetrics) GetMetrics 

func (m *NodeMetrics) GetMetrics() *Metrics

func (*NodeMetrics) ProtoMessage 

func (*NodeMetrics) ProtoMessage()

func (*NodeMetrics) Reset 

func (m *NodeMetrics) Reset()

func (*NodeMetrics) String 

func (m *NodeMetrics) String() string

func (*NodeMetrics) XXX_DiscardUnknown 

func (m *NodeMetrics) XXX_DiscardUnknown()

func (*NodeMetrics) XXX_Marshal 

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

func (*NodeMetrics) XXX_Merge 

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

func (*NodeMetrics) XXX_Size 

func (m *NodeMetrics) XXX_Size() int

func (*NodeMetrics) XXX_Unmarshal 

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

type Process 

type Process struct {
	Container            string   `protobuf:"bytes,1,opt,name=container,proto3" json:"container,omitempty"`
	Pid                  int32    `protobuf:"varint,2,opt,name=pid,proto3" json:"pid,omitempty"`
	Name                 string   `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Cmd                  string   `protobuf:"bytes,4,opt,name=cmd,proto3" json:"cmd,omitempty"`
	User                 string   `protobuf:"bytes,5,opt,name=user,proto3" json:"user,omitempty"`
	Group                string   `protobuf:"bytes,6,opt,name=group,proto3" json:"group,omitempty"`
	Metrics              *Metrics `protobuf:"bytes,7,opt,name=metrics,proto3" json:"metrics,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Process) Descriptor 

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

func (*Process) GetCmd 

func (m *Process) GetCmd() string

func (*Process) GetContainer 

func (m *Process) GetContainer() string

func (*Process) GetGroup 

func (m *Process) GetGroup() string

func (*Process) GetMetrics 

func (m *Process) GetMetrics() *Metrics

func (*Process) GetName 

func (m *Process) GetName() string

func (*Process) GetPid 

func (m *Process) GetPid() int32

func (*Process) GetUser 

func (m *Process) GetUser() string

func (*Process) ProtoMessage 

func (*Process) ProtoMessage()

func (*Process) Reset 

func (m *Process) Reset()

func (*Process) String 

func (m *Process) String() string

func (*Process) XXX_DiscardUnknown 

func (m *Process) XXX_DiscardUnknown()

func (*Process) XXX_Marshal 

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

func (*Process) XXX_Merge 

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

func (*Process) XXX_Size 

func (m *Process) XXX_Size() int

func (*Process) XXX_Unmarshal 

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

type ProcessAll 

type ProcessAll struct {
	Cluster              string     `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Host                 string     `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	Processes            []*Process `protobuf:"bytes,3,rep,name=processes,proto3" json:"processes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*ProcessAll) Descriptor 

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

func (*ProcessAll) GetCluster 

func (m *ProcessAll) GetCluster() string

func (*ProcessAll) GetHost 

func (m *ProcessAll) GetHost() string

func (*ProcessAll) GetProcesses 

func (m *ProcessAll) GetProcesses() []*Process

func (*ProcessAll) ProtoMessage 

func (*ProcessAll) ProtoMessage()

func (*ProcessAll) Reset 

func (m *ProcessAll) Reset()

func (*ProcessAll) String 

func (m *ProcessAll) String() string

func (*ProcessAll) XXX_DiscardUnknown 

func (m *ProcessAll) XXX_DiscardUnknown()

func (*ProcessAll) XXX_Marshal 

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

func (*ProcessAll) XXX_Merge 

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

func (*ProcessAll) XXX_Size 

func (m *ProcessAll) XXX_Size() int

func (*ProcessAll) XXX_Unmarshal 

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

type ProcessMetrics 

type ProcessMetrics struct {
	Cluster              string   `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Host                 string   `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	Container            string   `protobuf:"bytes,3,opt,name=container,proto3" json:"container,omitempty"`
	Pid                  int32    `protobuf:"varint,4,opt,name=pid,proto3" json:"pid,omitempty"`
	Name                 string   `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"`
	Metrics              *Metrics `protobuf:"bytes,6,opt,name=metrics,proto3" json:"metrics,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProcessMetrics) Descriptor 

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

func (*ProcessMetrics) GetCluster 

func (m *ProcessMetrics) GetCluster() string

func (*ProcessMetrics) GetContainer 

func (m *ProcessMetrics) GetContainer() string

func (*ProcessMetrics) GetHost 

func (m *ProcessMetrics) GetHost() string

func (*ProcessMetrics) GetMetrics 

func (m *ProcessMetrics) GetMetrics() *Metrics

func (*ProcessMetrics) GetName 

func (m *ProcessMetrics) GetName() string

func (*ProcessMetrics) GetPid 

func (m *ProcessMetrics) GetPid() int32

func (*ProcessMetrics) ProtoMessage 

func (*ProcessMetrics) ProtoMessage()

func (*ProcessMetrics) Reset 

func (m *ProcessMetrics) Reset()

func (*ProcessMetrics) String 

func (m *ProcessMetrics) String() string

func (*ProcessMetrics) XXX_DiscardUnknown 

func (m *ProcessMetrics) XXX_DiscardUnknown()

func (*ProcessMetrics) XXX_Marshal 

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

func (*ProcessMetrics) XXX_Merge 

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

func (*ProcessMetrics) XXX_Size 

func (m *ProcessMetrics) XXX_Size() int

func (*ProcessMetrics) XXX_Unmarshal 

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

type Request 

type Request struct {
	DataInt32            []int32  `protobuf:"varint,1,rep,packed,name=data_int32,json=dataInt32,proto3" json:"data_int32,omitempty"`
	DataInt64            []int64  `protobuf:"varint,2,rep,packed,name=data_int64,json=dataInt64,proto3" json:"data_int64,omitempty"`
	DataString           []string `protobuf:"bytes,3,rep,name=data_string,json=dataString,proto3" json:"data_string,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Request) Descriptor 

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

func (*Request) GetDataInt32 

func (m *Request) GetDataInt32() []int32

func (*Request) GetDataInt64 

func (m *Request) GetDataInt64() []int64

func (*Request) GetDataString 

func (m *Request) GetDataString() []string

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) Reset 

func (m *Request) Reset()

func (*Request) String 

func (m *Request) String() string

func (*Request) XXX_DiscardUnknown 

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal 

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

func (*Request) XXX_Merge 

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

func (*Request) XXX_Size 

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal 

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

type Response 

type Response struct {
	Success              bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Code                 uint32   `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"`
	Error                string   `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	DataInt32            []int32  `protobuf:"varint,4,rep,packed,name=data_int32,json=dataInt32,proto3" json:"data_int32,omitempty"`
	DataInt64            []int64  `protobuf:"varint,5,rep,packed,name=data_int64,json=dataInt64,proto3" json:"data_int64,omitempty"`
	DataString           []string `protobuf:"bytes,6,rep,name=data_string,json=dataString,proto3" json:"data_string,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Response) Descriptor 

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

func (*Response) GetCode 

func (m *Response) GetCode() uint32

func (*Response) GetDataInt32 

func (m *Response) GetDataInt32() []int32

func (*Response) GetDataInt64 

func (m *Response) GetDataInt64() []int64

func (*Response) GetDataString 

func (m *Response) GetDataString() []string

func (*Response) GetError 

func (m *Response) GetError() string

func (*Response) GetSuccess 

func (m *Response) GetSuccess() bool

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) String 

func (m *Response) String() string

func (*Response) XXX_DiscardUnknown 

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal 

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

func (*Response) XXX_Merge 

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

func (*Response) XXX_Size 

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal 

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

type Status 

type Status struct {
	Uuid                 string   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Timestamp            int64    `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Status) Descriptor 

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

func (*Status) GetTimestamp 

func (m *Status) GetTimestamp() int64

func (*Status) GetUuid 

func (m *Status) GetUuid() string

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) Reset 

func (m *Status) Reset()

func (*Status) String 

func (m *Status) String() string

func (*Status) XXX_DiscardUnknown 

func (m *Status) XXX_DiscardUnknown()

func (*Status) XXX_Marshal 

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

func (*Status) XXX_Merge 

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

func (*Status) XXX_Size 

func (m *Status) XXX_Size() int

func (*Status) XXX_Unmarshal 

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

type UnimplementedCollectorServer 

type UnimplementedCollectorServer struct {
}

UnimplementedCollectorServer can be embedded to have forward compatible implementations.

func (*UnimplementedCollectorServer) Ping 

func (*UnimplementedCollectorServer) Ping(srv Collector_PingServer) error

func (*UnimplementedCollectorServer) ReportContainerMetrics 

func (*UnimplementedCollectorServer) ReportContainerMetrics(ctx context.Context, req *ContainerMetrics) (*Response, error)

func (*UnimplementedCollectorServer) ReportK8SMetrics 

func (*UnimplementedCollectorServer) ReportK8SMetrics(ctx context.Context, req *K8SMetrics) (*Response, error)

func (*UnimplementedCollectorServer) ReportMetrics 

func (*UnimplementedCollectorServer) ReportMetrics(ctx context.Context, req *Metrics) (*Response, error)

func (*UnimplementedCollectorServer) ReportNodeMetrics 

func (*UnimplementedCollectorServer) ReportNodeMetrics(ctx context.Context, req *NodeMetrics) (*Response, error)

func (*UnimplementedCollectorServer) ReportProcessMetrics 

func (*UnimplementedCollectorServer) ReportProcessMetrics(ctx context.Context, req *ProcessMetrics) (*Response, error)

func (*UnimplementedCollectorServer) UpdateAgent 

func (*UnimplementedCollectorServer) UpdateAgent(ctx context.Context, req *Agent) (*Response, error)

func (*UnimplementedCollectorServer) UpdateContainer 

func (*UnimplementedCollectorServer) UpdateContainer(ctx context.Context, req *ContainerAll) (*Response, error)

func (*UnimplementedCollectorServer) UpdateK8SCluster 

func (*UnimplementedCollectorServer) UpdateK8SCluster(ctx context.Context, req *K8SCluster) (*Response, error)

func (*UnimplementedCollectorServer) UpdateProcess 

func (*UnimplementedCollectorServer) UpdateProcess(ctx context.Context, req *ProcessAll) (*Response, 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.