ksrapi

package
v3.3.3+incompatible Latest Latest
Warning

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

 Go to latest Published: Nov 14, 2019 License: Apache-2.0 Imports: 4 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Key 

func Key(metric string) string

Key returns the key under which a status metric is stored in Etcd.

Types

type KsrStats 

type KsrStats struct {
	// Number of add operations.
	Adds uint64 `protobuf:"varint,1,opt,name=Adds,proto3" json:"Adds,omitempty"`
	// Number of delete operations.
	Updates uint64 `protobuf:"varint,2,opt,name=Updates,proto3" json:"Updates,omitempty"`
	// Number of delete operations.
	Deletes uint64 `protobuf:"varint,3,opt,name=Deletes,proto3" json:"Deletes,omitempty"`
	// Number of data store resync runs.
	Resyncs uint64 `protobuf:"varint,4,opt,name=Resyncs,proto3" json:"Resyncs,omitempty"`
	// Number of add operation errors.
	AddErrors uint64 `protobuf:"varint,5,opt,name=AddErrors,proto3" json:"AddErrors,omitempty"`
	// Number of delete operation errors.
	UpdErrors uint64 `protobuf:"varint,6,opt,name=UpdErrors,proto3" json:"UpdErrors,omitempty"`
	// Number of delete operation errors.
	DelErrors uint64 `protobuf:"varint,7,opt,name=DelErrors,proto3" json:"DelErrors,omitempty"`
	// Number of operations where one or more arguments were invalid.
	ArgErrors uint64 `protobuf:"varint,8,opt,name=ArgErrors,proto3" json:"ArgErrors,omitempty"`
	// Number of of data store resync errors.
	ResErrors            uint64   `protobuf:"varint,9,opt,name=ResErrors,proto3" json:"ResErrors,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

KsrStats holds statistics for an individual KSR type

func (*KsrStats) Descriptor 

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

func (*KsrStats) GetAddErrors 

func (m *KsrStats) GetAddErrors() uint64

func (*KsrStats) GetAdds 

func (m *KsrStats) GetAdds() uint64

func (*KsrStats) GetArgErrors 

func (m *KsrStats) GetArgErrors() uint64

func (*KsrStats) GetDelErrors 

func (m *KsrStats) GetDelErrors() uint64

func (*KsrStats) GetDeletes 

func (m *KsrStats) GetDeletes() uint64

func (*KsrStats) GetResErrors 

func (m *KsrStats) GetResErrors() uint64

func (*KsrStats) GetResyncs 

func (m *KsrStats) GetResyncs() uint64

func (*KsrStats) GetUpdErrors 

func (m *KsrStats) GetUpdErrors() uint64

func (*KsrStats) GetUpdates 

func (m *KsrStats) GetUpdates() uint64

func (*KsrStats) ProtoMessage 

func (*KsrStats) ProtoMessage()

func (*KsrStats) Reset 

func (m *KsrStats) Reset()

func (*KsrStats) String 

func (m *KsrStats) String() string

func (*KsrStats) XXX_DiscardUnknown 

func (m *KsrStats) XXX_DiscardUnknown()

func (*KsrStats) XXX_Marshal 

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

func (*KsrStats) XXX_Merge 

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

func (*KsrStats) XXX_Size 

func (m *KsrStats) XXX_Size() int

func (*KsrStats) XXX_Unmarshal 

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

type Stats 

type Stats struct {
	// Statistics for the Namespace Reflector
	NamespaceStats *KsrStats `protobuf:"bytes,1,opt,name=namespaceStats,proto3" json:"namespaceStats,omitempty"`
	// Statistics for the Pod Reflector
	PodStats *KsrStats `protobuf:"bytes,2,opt,name=podStats,proto3" json:"podStats,omitempty"`
	// Statistics for the Network Policy Reflector
	PolicyStats *KsrStats `protobuf:"bytes,3,opt,name=policyStats,proto3" json:"policyStats,omitempty"`
	// Statistics for the Endpoints Reflector
	EndpointsStats *KsrStats `protobuf:"bytes,4,opt,name=endpointsStats,proto3" json:"endpointsStats,omitempty"`
	// Statistics for the Service Reflector
	ServiceStats *KsrStats `protobuf:"bytes,5,opt,name=serviceStats,proto3" json:"serviceStats,omitempty"`
	// Statistics for the Node Reflector
	NodeStats *KsrStats `protobuf:"bytes,6,opt,name=nodeStats,proto3" json:"nodeStats,omitempty"`
	// Statistics for the SfcPod Reflector
	SfcPodStats          *KsrStats `protobuf:"bytes,7,opt,name=sfcPodStats,proto3" json:"sfcPodStats,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

Stats holds aggregated statistics for all KSR types in the KSR process.

func (*Stats) Descriptor 

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

func (*Stats) GetEndpointsStats 

func (m *Stats) GetEndpointsStats() *KsrStats

func (*Stats) GetNamespaceStats 

func (m *Stats) GetNamespaceStats() *KsrStats

func (*Stats) GetNodeStats 

func (m *Stats) GetNodeStats() *KsrStats

func (*Stats) GetPodStats 

func (m *Stats) GetPodStats() *KsrStats

func (*Stats) GetPolicyStats 

func (m *Stats) GetPolicyStats() *KsrStats

func (*Stats) GetServiceStats 

func (m *Stats) GetServiceStats() *KsrStats

func (*Stats) GetSfcPodStats added in v1.4.0 

func (m *Stats) GetSfcPodStats() *KsrStats

func (*Stats) ProtoMessage 

func (*Stats) ProtoMessage()

func (*Stats) Reset 

func (m *Stats) Reset()

func (*Stats) String 

func (m *Stats) String() string

func (*Stats) XXX_DiscardUnknown 

func (m *Stats) XXX_DiscardUnknown()

func (*Stats) XXX_Marshal 

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

func (*Stats) XXX_Merge 

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

func (*Stats) XXX_Size 

func (m *Stats) XXX_Size() int

func (*Stats) XXX_Unmarshal 

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