stats

package
v0.17.0 Latest Latest
Warning

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

 Go to latest Published: Nov 30, 2017 License: Apache-2.0 Imports: 18 Imported by: 2

Documentation

Overview

Package stats is a generated protocol buffer package.

It is generated from these files: 

github.com/appcelerator/amp/api/rpc/stats/stats.proto

It has these top-level messages: 

MetricsEntry
MetricsCPUEntry
MetricsIOEntry
MetricsMemEntry
MetricsNetEntry
StatsRequest
StatsReply

Package stats is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterStatsHandler added in v0.4.0 

func RegisterStatsHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterStatsHandler registers the http handlers for service Stats to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterStatsHandlerClient added in v0.16.0 

func RegisterStatsHandlerClient(ctx context.Context, mux *runtime.ServeMux, client StatsClient) error

RegisterStatsHandler registers the http handlers for service Stats to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "StatsClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "StatsClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "StatsClient" to call the correct interceptors.

func RegisterStatsHandlerFromEndpoint added in v0.4.0 

func RegisterStatsHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterStatsHandlerFromEndpoint is same as RegisterStatsHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterStatsServer 

func RegisterStatsServer(s *grpc.Server, srv StatsServer)

Types

type MetricsCPUEntry added in v0.9.0 

type MetricsCPUEntry struct {
	TotalUsage        float64 `protobuf:"fixed64,1,opt,name=total_usage,json=totalUsage" json:"total_usage,omitempty"`
	UsageInKernelMode float64 `protobuf:"fixed64,2,opt,name=usage_in_kernel_mode,json=usageInKernelMode" json:"usage_in_kernel_mode,omitempty"`
	UsageInUserMode   float64 `protobuf:"fixed64,3,opt,name=usage_in_user_mode,json=usageInUserMode" json:"usage_in_user_mode,omitempty"`
}

func (*MetricsCPUEntry) Descriptor added in v0.9.0 

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

func (*MetricsCPUEntry) GetTotalUsage added in v0.9.0 

func (m *MetricsCPUEntry) GetTotalUsage() float64

func (*MetricsCPUEntry) GetUsageInKernelMode added in v0.9.0 

func (m *MetricsCPUEntry) GetUsageInKernelMode() float64

func (*MetricsCPUEntry) GetUsageInUserMode added in v0.9.0 

func (m *MetricsCPUEntry) GetUsageInUserMode() float64

func (*MetricsCPUEntry) ProtoMessage added in v0.9.0 

func (*MetricsCPUEntry) ProtoMessage()

func (*MetricsCPUEntry) Reset added in v0.9.0 

func (m *MetricsCPUEntry) Reset()

func (*MetricsCPUEntry) String added in v0.9.0 

func (m *MetricsCPUEntry) String() string

type MetricsEntry added in v0.9.0 

type MetricsEntry struct {
	Timestamp          string            `protobuf:"bytes,1,opt,name=timestamp" json:"timestamp,omitempty"`
	ContainerId        string            `protobuf:"bytes,2,opt,name=container_id,json=containerId" json:"container_id,omitempty"`
	ContainerName      string            `protobuf:"bytes,3,opt,name=container_name,json=containerName" json:"container_name,omitempty"`
	ContainerShortName string            `protobuf:"bytes,4,opt,name=container_short_name,json=containerShortName" json:"container_short_name,omitempty"`
	ContainerState     string            `protobuf:"bytes,5,opt,name=container_state,json=containerState" json:"container_state,omitempty"`
	ServiceName        string            `protobuf:"bytes,6,opt,name=service_name,json=serviceName" json:"service_name,omitempty"`
	ServiceId          string            `protobuf:"bytes,7,opt,name=service_id,json=serviceId" json:"service_id,omitempty"`
	TaskId             string            `protobuf:"bytes,8,opt,name=task_id,json=taskId" json:"task_id,omitempty"`
	TaskSlot           int32             `protobuf:"varint,9,opt,name=task_slot,json=taskSlot" json:"task_slot,omitempty"`
	StackName          string            `protobuf:"bytes,10,opt,name=stack_name,json=stackName" json:"stack_name,omitempty"`
	NodeId             string            `protobuf:"bytes,11,opt,name=node_id,json=nodeId" json:"node_id,omitempty"`
	TimeId             string            `protobuf:"bytes,12,opt,name=time_id,json=timeId" json:"time_id,omitempty"`
	Labels             map[string]string `` /* 133-byte string literal not displayed */
	Group              string            `protobuf:"bytes,14,opt,name=group" json:"group,omitempty"`
	Sgroup             string            `protobuf:"bytes,15,opt,name=sgroup" json:"sgroup,omitempty"`
	Cpu                *MetricsCPUEntry  `protobuf:"bytes,16,opt,name=cpu" json:"cpu,omitempty"`
	Io                 *MetricsIOEntry   `protobuf:"bytes,17,opt,name=io" json:"io,omitempty"`
	Mem                *MetricsMemEntry  `protobuf:"bytes,18,opt,name=mem" json:"mem,omitempty"`
	Net                *MetricsNetEntry  `protobuf:"bytes,19,opt,name=net" json:"net,omitempty"`
}

func (*MetricsEntry) Descriptor added in v0.9.0 

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

func (*MetricsEntry) GetContainerId added in v0.9.0 

func (m *MetricsEntry) GetContainerId() string

func (*MetricsEntry) GetContainerName added in v0.9.0 

func (m *MetricsEntry) GetContainerName() string

func (*MetricsEntry) GetContainerShortName added in v0.9.0 

func (m *MetricsEntry) GetContainerShortName() string

func (*MetricsEntry) GetContainerState added in v0.9.0 

func (m *MetricsEntry) GetContainerState() string

func (*MetricsEntry) GetCpu added in v0.9.0 

func (m *MetricsEntry) GetCpu() *MetricsCPUEntry

func (*MetricsEntry) GetGroup added in v0.9.0 

func (m *MetricsEntry) GetGroup() string

func (*MetricsEntry) GetIo added in v0.9.0 

func (m *MetricsEntry) GetIo() *MetricsIOEntry

func (*MetricsEntry) GetLabels added in v0.9.0 

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

func (*MetricsEntry) GetMem added in v0.9.0 

func (m *MetricsEntry) GetMem() *MetricsMemEntry

func (*MetricsEntry) GetNet added in v0.9.0 

func (m *MetricsEntry) GetNet() *MetricsNetEntry

func (*MetricsEntry) GetNodeId added in v0.9.0 

func (m *MetricsEntry) GetNodeId() string

func (*MetricsEntry) GetServiceId added in v0.9.0 

func (m *MetricsEntry) GetServiceId() string

func (*MetricsEntry) GetServiceName added in v0.9.0 

func (m *MetricsEntry) GetServiceName() string

func (*MetricsEntry) GetSgroup added in v0.11.0 

func (m *MetricsEntry) GetSgroup() string

func (*MetricsEntry) GetStackName added in v0.9.0 

func (m *MetricsEntry) GetStackName() string

func (*MetricsEntry) GetTaskId added in v0.9.0 

func (m *MetricsEntry) GetTaskId() string

func (*MetricsEntry) GetTaskSlot added in v0.12.0 

func (m *MetricsEntry) GetTaskSlot() int32

func (*MetricsEntry) GetTimeId added in v0.12.0 

func (m *MetricsEntry) GetTimeId() string

func (*MetricsEntry) GetTimestamp added in v0.9.0 

func (m *MetricsEntry) GetTimestamp() string

func (*MetricsEntry) ProtoMessage added in v0.9.0 

func (*MetricsEntry) ProtoMessage()

func (*MetricsEntry) Reset added in v0.9.0 

func (m *MetricsEntry) Reset()

func (*MetricsEntry) String added in v0.9.0 

func (m *MetricsEntry) String() string

type MetricsIOEntry added in v0.9.0 

type MetricsIOEntry struct {
	Read  int64 `protobuf:"varint,1,opt,name=read" json:"read,omitempty"`
	Write int64 `protobuf:"varint,2,opt,name=write" json:"write,omitempty"`
	Total int64 `protobuf:"varint,3,opt,name=total" json:"total,omitempty"`
}

func (*MetricsIOEntry) Descriptor added in v0.9.0 

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

func (*MetricsIOEntry) GetRead added in v0.9.0 

func (m *MetricsIOEntry) GetRead() int64

func (*MetricsIOEntry) GetTotal added in v0.9.0 

func (m *MetricsIOEntry) GetTotal() int64

func (*MetricsIOEntry) GetWrite added in v0.9.0 

func (m *MetricsIOEntry) GetWrite() int64

func (*MetricsIOEntry) ProtoMessage added in v0.9.0 

func (*MetricsIOEntry) ProtoMessage()

func (*MetricsIOEntry) Reset added in v0.9.0 

func (m *MetricsIOEntry) Reset()

func (*MetricsIOEntry) String added in v0.9.0 

func (m *MetricsIOEntry) String() string

type MetricsMemEntry added in v0.9.0 

type MetricsMemEntry struct {
	Failcnt  int64   `protobuf:"varint,1,opt,name=failcnt" json:"failcnt,omitempty"`
	Limit    int64   `protobuf:"varint,2,opt,name=limit" json:"limit,omitempty"`
	Maxusage int64   `protobuf:"varint,3,opt,name=maxusage" json:"maxusage,omitempty"`
	Usage    int64   `protobuf:"varint,4,opt,name=usage" json:"usage,omitempty"`
	UsageP   float64 `protobuf:"fixed64,5,opt,name=usage_p,json=usageP" json:"usage_p,omitempty"`
}

func (*MetricsMemEntry) Descriptor added in v0.9.0 

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

func (*MetricsMemEntry) GetFailcnt added in v0.9.0 

func (m *MetricsMemEntry) GetFailcnt() int64

func (*MetricsMemEntry) GetLimit added in v0.9.0 

func (m *MetricsMemEntry) GetLimit() int64

func (*MetricsMemEntry) GetMaxusage added in v0.9.0 

func (m *MetricsMemEntry) GetMaxusage() int64

func (*MetricsMemEntry) GetUsage added in v0.9.0 

func (m *MetricsMemEntry) GetUsage() int64

func (*MetricsMemEntry) GetUsageP added in v0.9.0 

func (m *MetricsMemEntry) GetUsageP() float64

func (*MetricsMemEntry) ProtoMessage added in v0.9.0 

func (*MetricsMemEntry) ProtoMessage()

func (*MetricsMemEntry) Reset added in v0.9.0 

func (m *MetricsMemEntry) Reset()

func (*MetricsMemEntry) String added in v0.9.0 

func (m *MetricsMemEntry) String() string

type MetricsNetEntry added in v0.9.0 

type MetricsNetEntry struct {
	TotalBytes int64 `protobuf:"varint,1,opt,name=total_bytes,json=totalBytes" json:"total_bytes,omitempty"`
	RxBytes    int64 `protobuf:"varint,2,opt,name=rx_bytes,json=rxBytes" json:"rx_bytes,omitempty"`
	RxDropped  int64 `protobuf:"varint,3,opt,name=rx_dropped,json=rxDropped" json:"rx_dropped,omitempty"`
	RxErrors   int64 `protobuf:"varint,4,opt,name=rx_errors,json=rxErrors" json:"rx_errors,omitempty"`
	RxPackets  int64 `protobuf:"varint,5,opt,name=rx_packets,json=rxPackets" json:"rx_packets,omitempty"`
	TxBytes    int64 `protobuf:"varint,6,opt,name=tx_bytes,json=txBytes" json:"tx_bytes,omitempty"`
	TxDropped  int64 `protobuf:"varint,7,opt,name=tx_dropped,json=txDropped" json:"tx_dropped,omitempty"`
	TxErrors   int64 `protobuf:"varint,8,opt,name=tx_errors,json=txErrors" json:"tx_errors,omitempty"`
	TxPackets  int64 `protobuf:"varint,9,opt,name=tx_packets,json=txPackets" json:"tx_packets,omitempty"`
}

func (*MetricsNetEntry) Descriptor added in v0.9.0 

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

func (*MetricsNetEntry) GetRxBytes added in v0.9.0 

func (m *MetricsNetEntry) GetRxBytes() int64

func (*MetricsNetEntry) GetRxDropped added in v0.9.0 

func (m *MetricsNetEntry) GetRxDropped() int64

func (*MetricsNetEntry) GetRxErrors added in v0.9.0 

func (m *MetricsNetEntry) GetRxErrors() int64

func (*MetricsNetEntry) GetRxPackets added in v0.9.0 

func (m *MetricsNetEntry) GetRxPackets() int64

func (*MetricsNetEntry) GetTotalBytes added in v0.9.0 

func (m *MetricsNetEntry) GetTotalBytes() int64

func (*MetricsNetEntry) GetTxBytes added in v0.9.0 

func (m *MetricsNetEntry) GetTxBytes() int64

func (*MetricsNetEntry) GetTxDropped added in v0.9.0 

func (m *MetricsNetEntry) GetTxDropped() int64

func (*MetricsNetEntry) GetTxErrors added in v0.9.0 

func (m *MetricsNetEntry) GetTxErrors() int64

func (*MetricsNetEntry) GetTxPackets added in v0.9.0 

func (m *MetricsNetEntry) GetTxPackets() int64

func (*MetricsNetEntry) ProtoMessage added in v0.9.0 

func (*MetricsNetEntry) ProtoMessage()

func (*MetricsNetEntry) Reset added in v0.9.0 

func (m *MetricsNetEntry) Reset()

func (*MetricsNetEntry) String added in v0.9.0 

func (m *MetricsNetEntry) String() string

type Stats 

type Stats struct {
	ES *elasticsearch.Elasticsearch
}

Stats structure to implement StatsServer interface

func (*Stats) StatsQuery 

func (s *Stats) StatsQuery(ctx context.Context, req *StatsRequest) (*StatsReply, error)

StatsQuery extracts stat information according to StatsRequest

type StatsClient 

type StatsClient interface {
	StatsQuery(ctx context.Context, in *StatsRequest, opts ...grpc.CallOption) (*StatsReply, error)
}

func NewStatsClient 

func NewStatsClient(cc *grpc.ClientConn) StatsClient

type StatsReply 

type StatsReply struct {
	Entries []*MetricsEntry `protobuf:"bytes,1,rep,name=entries" json:"entries,omitempty"`
}

func (*StatsReply) Descriptor 

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

func (*StatsReply) GetEntries 

func (m *StatsReply) GetEntries() []*MetricsEntry

func (*StatsReply) ProtoMessage 

func (*StatsReply) ProtoMessage()

func (*StatsReply) Reset 

func (m *StatsReply) Reset()

func (*StatsReply) String 

func (m *StatsReply) String() string

type StatsRequest 

type StatsRequest struct {
	StatsCpu                 bool   `protobuf:"varint,1,opt,name=stats_cpu,json=statsCpu" json:"stats_cpu,omitempty"`
	StatsMem                 bool   `protobuf:"varint,2,opt,name=stats_mem,json=statsMem" json:"stats_mem,omitempty"`
	StatsIo                  bool   `protobuf:"varint,3,opt,name=stats_io,json=statsIo" json:"stats_io,omitempty"`
	StatsNet                 bool   `protobuf:"varint,4,opt,name=stats_net,json=statsNet" json:"stats_net,omitempty"`
	Group                    string `protobuf:"bytes,5,opt,name=group" json:"group,omitempty"`
	FilterContainerId        string `protobuf:"bytes,6,opt,name=filter_container_id,json=filterContainerId" json:"filter_container_id,omitempty"`
	FilterContainerName      string `protobuf:"bytes,7,opt,name=filter_container_name,json=filterContainerName" json:"filter_container_name,omitempty"`
	FilterContainerShortName string `` /* 130-byte string literal not displayed */
	FilterContainerState     string `protobuf:"bytes,9,opt,name=filter_container_state,json=filterContainerState" json:"filter_container_state,omitempty"`
	FilterServiceName        string `protobuf:"bytes,10,opt,name=filter_service_name,json=filterServiceName" json:"filter_service_name,omitempty"`
	FilterServiceId          string `protobuf:"bytes,11,opt,name=filter_service_id,json=filterServiceId" json:"filter_service_id,omitempty"`
	FilterTaskId             string `protobuf:"bytes,12,opt,name=filter_task_id,json=filterTaskId" json:"filter_task_id,omitempty"`
	FilterStackName          string `protobuf:"bytes,13,opt,name=filter_stack_name,json=filterStackName" json:"filter_stack_name,omitempty"`
	FilterNodeId             string `protobuf:"bytes,14,opt,name=filter_node_id,json=filterNodeId" json:"filter_node_id,omitempty"`
	Since                    string `protobuf:"bytes,15,opt,name=since" json:"since,omitempty"`
	Until                    string `protobuf:"bytes,16,opt,name=until" json:"until,omitempty"`
	Period                   string `protobuf:"bytes,17,opt,name=period" json:"period,omitempty"`
	TimeGroup                string `protobuf:"bytes,18,opt,name=time_group,json=timeGroup" json:"time_group,omitempty"`
	TimeZone                 string `protobuf:"bytes,19,opt,name=time_zone,json=timeZone" json:"time_zone,omitempty"`
	Avg                      bool   `protobuf:"varint,20,opt,name=avg" json:"avg,omitempty"`
	AllowsInfra              bool   `protobuf:"varint,21,opt,name=allows_infra,json=allowsInfra" json:"allows_infra,omitempty"`
}

func (*StatsRequest) Descriptor 

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

func (*StatsRequest) GetAllowsInfra added in v0.12.0 

func (m *StatsRequest) GetAllowsInfra() bool

func (*StatsRequest) GetAvg added in v0.12.0 

func (m *StatsRequest) GetAvg() bool

func (*StatsRequest) GetFilterContainerId added in v0.4.0 

func (m *StatsRequest) GetFilterContainerId() string

func (*StatsRequest) GetFilterContainerName added in v0.4.0 

func (m *StatsRequest) GetFilterContainerName() string

func (*StatsRequest) GetFilterContainerShortName added in v0.9.0 

func (m *StatsRequest) GetFilterContainerShortName() string

func (*StatsRequest) GetFilterContainerState added in v0.9.0 

func (m *StatsRequest) GetFilterContainerState() string

func (*StatsRequest) GetFilterNodeId added in v0.4.0 

func (m *StatsRequest) GetFilterNodeId() string

func (*StatsRequest) GetFilterServiceId added in v0.4.0 

func (m *StatsRequest) GetFilterServiceId() string

func (*StatsRequest) GetFilterServiceName added in v0.4.0 

func (m *StatsRequest) GetFilterServiceName() string

func (*StatsRequest) GetFilterStackName added in v0.9.0 

func (m *StatsRequest) GetFilterStackName() string

func (*StatsRequest) GetFilterTaskId added in v0.4.0 

func (m *StatsRequest) GetFilterTaskId() string

func (*StatsRequest) GetGroup added in v0.9.0 

func (m *StatsRequest) GetGroup() string

func (*StatsRequest) GetPeriod added in v0.4.0 

func (m *StatsRequest) GetPeriod() string

func (*StatsRequest) GetSince added in v0.4.0 

func (m *StatsRequest) GetSince() string

func (*StatsRequest) GetStatsCpu added in v0.4.0 

func (m *StatsRequest) GetStatsCpu() bool

func (*StatsRequest) GetStatsIo added in v0.4.0 

func (m *StatsRequest) GetStatsIo() bool

func (*StatsRequest) GetStatsMem added in v0.4.0 

func (m *StatsRequest) GetStatsMem() bool

func (*StatsRequest) GetStatsNet added in v0.4.0 

func (m *StatsRequest) GetStatsNet() bool

func (*StatsRequest) GetTimeGroup added in v0.4.0 

func (m *StatsRequest) GetTimeGroup() string

func (*StatsRequest) GetTimeZone added in v0.9.0 

func (m *StatsRequest) GetTimeZone() string

func (*StatsRequest) GetUntil added in v0.4.0 

func (m *StatsRequest) GetUntil() string

func (*StatsRequest) ProtoMessage 

func (*StatsRequest) ProtoMessage()

func (*StatsRequest) Reset 

func (m *StatsRequest) Reset()

func (*StatsRequest) String 

func (m *StatsRequest) String() string

type StatsServer 

type StatsServer interface {
	StatsQuery(context.Context, *StatsRequest) (*StatsReply, 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.