metrics

package
v0.0.0-...-211e212 Latest Latest
Warning

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

 Go to latest Published: Dec 28, 2021 License: GPL-3.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	OverallStatus_name = map[int32]string{
		0: "UnknownStatus",
		1: "Ready",
		2: "Initializing",
		3: "Degraded",
		4: "Unavailable",
	}
	OverallStatus_value = map[string]int32{
		"UnknownStatus": 0,
		"Ready":         1,
		"Initializing":  2,
		"Degraded":      3,
		"Unavailable":   4,
	}
)

Enum value maps for OverallStatus.

View Source 
var (
	StatusConditions_name = map[int32]string{
		0: "NoConditions",
		1: "Pending",
		2: "MissingOptionalComponent",
		3: "MissingCriticalComponent",
		4: "InvalidConfiguration",
		5: "InternalError",
	}
	StatusConditions_value = map[string]int32{
		"NoConditions":             0,
		"Pending":                  1,
		"MissingOptionalComponent": 2,
		"MissingCriticalComponent": 3,
		"InvalidConfiguration":     4,
		"InternalError":            5,
	}
)

Enum value maps for StatusConditions.

View Source 
var File_pkg_metrics_metrics_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AgentCount 

type AgentCount struct {
	Count int64 `protobuf:"varint,1,opt,name=Count,proto3" json:"Count,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentCount) Descriptor deprecated 

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

Deprecated: Use AgentCount.ProtoReflect.Descriptor instead.

func (*AgentCount) GetCount 

func (x *AgentCount) GetCount() int64

func (*AgentCount) MarshalLogObject 

func (a *AgentCount) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*AgentCount) ProtoMessage 

func (*AgentCount) ProtoMessage()

func (*AgentCount) ProtoReflect 

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

func (*AgentCount) Reset 

func (x *AgentCount) Reset()

func (*AgentCount) String 

func (x *AgentCount) String() string

type AgentInfo 

type AgentInfo struct {
	Node      string `protobuf:"bytes,4,opt,name=Node,proto3" json:"Node,omitempty"`
	Pod       string `protobuf:"bytes,5,opt,name=Pod,proto3" json:"Pod,omitempty"`
	Namespace string `protobuf:"bytes,6,opt,name=Namespace,proto3" json:"Namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentInfo) Descriptor deprecated 

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

Deprecated: Use AgentInfo.ProtoReflect.Descriptor instead.

func (*AgentInfo) GetNamespace 

func (x *AgentInfo) GetNamespace() string

func (*AgentInfo) GetNode 

func (x *AgentInfo) GetNode() string

func (*AgentInfo) GetPod 

func (x *AgentInfo) GetPod() string

func (*AgentInfo) MarshalLogObject 

func (a *AgentInfo) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*AgentInfo) ProtoMessage 

func (*AgentInfo) ProtoMessage()

func (*AgentInfo) ProtoReflect 

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

func (*AgentInfo) Reset 

func (x *AgentInfo) Reset()

func (*AgentInfo) String 

func (x *AgentInfo) String() string

type AgentTasksTotal 

type AgentTasksTotal struct {
	UUID  string `protobuf:"bytes,1,opt,name=UUID,proto3" json:"UUID,omitempty"`
	Total int64  `protobuf:"varint,2,opt,name=Total,proto3" json:"Total,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentTasksTotal) Descriptor deprecated 

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

Deprecated: Use AgentTasksTotal.ProtoReflect.Descriptor instead.

func (*AgentTasksTotal) GetTotal 

func (x *AgentTasksTotal) GetTotal() int64

func (*AgentTasksTotal) GetUUID 

func (x *AgentTasksTotal) GetUUID() string

func (*AgentTasksTotal) MarshalLogObject 

func (a *AgentTasksTotal) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*AgentTasksTotal) ProtoMessage 

func (*AgentTasksTotal) ProtoMessage()

func (*AgentTasksTotal) ProtoReflect 

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

func (*AgentTasksTotal) Reset 

func (x *AgentTasksTotal) Reset()

func (*AgentTasksTotal) String 

func (x *AgentTasksTotal) String() string

type BucketSpec 

type BucketSpec struct {
	Name string                `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Data map[string]*anypb.Any `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*BucketSpec) Descriptor deprecated 

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

Deprecated: Use BucketSpec.ProtoReflect.Descriptor instead.

func (*BucketSpec) GetData 

func (x *BucketSpec) GetData() map[string]*anypb.Any

func (*BucketSpec) GetName 

func (x *BucketSpec) GetName() string

func (*BucketSpec) MarshalLogObject 

func (a *BucketSpec) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*BucketSpec) ProtoMessage 

func (*BucketSpec) ProtoMessage()

func (*BucketSpec) ProtoReflect 

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

func (*BucketSpec) Reset 

func (x *BucketSpec) Reset()

func (*BucketSpec) String 

func (x *BucketSpec) String() string

type CacheHits 

type CacheHits struct {
	CacheHitsTotal   int64   `protobuf:"varint,1,opt,name=CacheHitsTotal,proto3" json:"CacheHitsTotal,omitempty"`
	CacheMissesTotal int64   `protobuf:"varint,2,opt,name=CacheMissesTotal,proto3" json:"CacheMissesTotal,omitempty"`
	CacheHitPercent  float64 `protobuf:"fixed64,3,opt,name=CacheHitPercent,proto3" json:"CacheHitPercent,omitempty"`
	// contains filtered or unexported fields
}

func (*CacheHits) Descriptor deprecated 

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

Deprecated: Use CacheHits.ProtoReflect.Descriptor instead.

func (*CacheHits) GetCacheHitPercent 

func (x *CacheHits) GetCacheHitPercent() float64

func (*CacheHits) GetCacheHitsTotal 

func (x *CacheHits) GetCacheHitsTotal() int64

func (*CacheHits) GetCacheMissesTotal 

func (x *CacheHits) GetCacheMissesTotal() int64

func (*CacheHits) MarshalLogObject 

func (a *CacheHits) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*CacheHits) ProtoMessage 

func (*CacheHits) ProtoMessage()

func (*CacheHits) ProtoReflect 

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

func (*CacheHits) Reset 

func (x *CacheHits) Reset()

func (*CacheHits) String 

func (x *CacheHits) String() string

type CacheUsage 

type CacheUsage struct {
	ObjectCount  int64   `protobuf:"varint,1,opt,name=ObjectCount,proto3" json:"ObjectCount,omitempty"`
	TotalSize    int64   `protobuf:"varint,2,opt,name=TotalSize,proto3" json:"TotalSize,omitempty"`
	UsagePercent float64 `protobuf:"fixed64,3,opt,name=UsagePercent,proto3" json:"UsagePercent,omitempty"`
	// contains filtered or unexported fields
}

func (*CacheUsage) Descriptor deprecated 

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

Deprecated: Use CacheUsage.ProtoReflect.Descriptor instead.

func (*CacheUsage) GetObjectCount 

func (x *CacheUsage) GetObjectCount() int64

func (*CacheUsage) GetTotalSize 

func (x *CacheUsage) GetTotalSize() int64

func (*CacheUsage) GetUsagePercent 

func (x *CacheUsage) GetUsagePercent() float64

func (*CacheUsage) MarshalLogObject 

func (a *CacheUsage) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*CacheUsage) ProtoMessage 

func (*CacheUsage) ProtoMessage()

func (*CacheUsage) ProtoReflect 

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

func (*CacheUsage) Reset 

func (x *CacheUsage) Reset()

func (*CacheUsage) String 

func (x *CacheUsage) String() string

type ConsumerdCount 

type ConsumerdCount struct {
	Count int64 `protobuf:"varint,1,opt,name=Count,proto3" json:"Count,omitempty"`
	// contains filtered or unexported fields
}

func (*ConsumerdCount) Descriptor deprecated 

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

Deprecated: Use ConsumerdCount.ProtoReflect.Descriptor instead.

func (*ConsumerdCount) GetCount 

func (x *ConsumerdCount) GetCount() int64

func (*ConsumerdCount) MarshalLogObject 

func (a *ConsumerdCount) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ConsumerdCount) ProtoMessage 

func (*ConsumerdCount) ProtoMessage()

func (*ConsumerdCount) ProtoReflect 

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

func (*ConsumerdCount) Reset 

func (x *ConsumerdCount) Reset()

func (*ConsumerdCount) String 

func (x *ConsumerdCount) String() string

type ConsumerdTasksTotal 

type ConsumerdTasksTotal struct {
	UUID  string `protobuf:"bytes,1,opt,name=UUID,proto3" json:"UUID,omitempty"`
	Total int64  `protobuf:"varint,2,opt,name=Total,proto3" json:"Total,omitempty"`
	// contains filtered or unexported fields
}

func (*ConsumerdTasksTotal) Descriptor deprecated 

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

Deprecated: Use ConsumerdTasksTotal.ProtoReflect.Descriptor instead.

func (*ConsumerdTasksTotal) GetTotal 

func (x *ConsumerdTasksTotal) GetTotal() int64

func (*ConsumerdTasksTotal) GetUUID 

func (x *ConsumerdTasksTotal) GetUUID() string

func (*ConsumerdTasksTotal) MarshalLogObject 

func (a *ConsumerdTasksTotal) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ConsumerdTasksTotal) ProtoMessage 

func (*ConsumerdTasksTotal) ProtoMessage()

func (*ConsumerdTasksTotal) ProtoReflect 

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

func (*ConsumerdTasksTotal) Reset 

func (x *ConsumerdTasksTotal) Reset()

func (*ConsumerdTasksTotal) String 

func (x *ConsumerdTasksTotal) String() string

type CpuStats 

type CpuStats struct {
	WallTime       uint64          `protobuf:"varint,1,opt,name=WallTime,proto3" json:"WallTime,omitempty"`
	CpuUsage       *CpuUsage       `protobuf:"bytes,2,opt,name=CpuUsage,proto3" json:"CpuUsage,omitempty"`
	ThrottlingData *ThrottlingData `protobuf:"bytes,3,opt,name=ThrottlingData,proto3" json:"ThrottlingData,omitempty"`
	// contains filtered or unexported fields
}

func (*CpuStats) Descriptor deprecated 

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

Deprecated: Use CpuStats.ProtoReflect.Descriptor instead.

func (*CpuStats) GetCpuUsage 

func (x *CpuStats) GetCpuUsage() *CpuUsage

func (*CpuStats) GetThrottlingData 

func (x *CpuStats) GetThrottlingData() *ThrottlingData

func (*CpuStats) GetWallTime 

func (x *CpuStats) GetWallTime() uint64

func (*CpuStats) MarshalLogObject 

func (a *CpuStats) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*CpuStats) ProtoMessage 

func (*CpuStats) ProtoMessage()

func (*CpuStats) ProtoReflect 

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

func (*CpuStats) Reset 

func (x *CpuStats) Reset()

func (*CpuStats) String 

func (x *CpuStats) String() string

type CpuUsage 

type CpuUsage struct {
	CfsQuota   int64  `protobuf:"varint,1,opt,name=CfsQuota,proto3" json:"CfsQuota,omitempty"`
	CfsPeriod  int64  `protobuf:"varint,2,opt,name=CfsPeriod,proto3" json:"CfsPeriod,omitempty"`
	TotalUsage uint64 `protobuf:"varint,3,opt,name=TotalUsage,proto3" json:"TotalUsage,omitempty"`
	// contains filtered or unexported fields
}

func (*CpuUsage) Descriptor deprecated 

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

Deprecated: Use CpuUsage.ProtoReflect.Descriptor instead.

func (*CpuUsage) GetCfsPeriod 

func (x *CpuUsage) GetCfsPeriod() int64

func (*CpuUsage) GetCfsQuota 

func (x *CpuUsage) GetCfsQuota() int64

func (*CpuUsage) GetTotalUsage 

func (x *CpuUsage) GetTotalUsage() uint64

func (*CpuUsage) MarshalLogObject 

func (a *CpuUsage) MarshalLogObject(enc zapcore.ObjectEncoder) error

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 DelegatedTasksCompleted 

type DelegatedTasksCompleted struct {
	Total int64 `protobuf:"varint,1,opt,name=Total,proto3" json:"Total,omitempty"`
	// contains filtered or unexported fields
}

func (*DelegatedTasksCompleted) Descriptor deprecated 

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

Deprecated: Use DelegatedTasksCompleted.ProtoReflect.Descriptor instead.

func (*DelegatedTasksCompleted) GetTotal 

func (x *DelegatedTasksCompleted) GetTotal() int64

func (*DelegatedTasksCompleted) MarshalLogObject 

func (a *DelegatedTasksCompleted) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*DelegatedTasksCompleted) ProtoMessage 

func (*DelegatedTasksCompleted) ProtoMessage()

func (*DelegatedTasksCompleted) ProtoReflect 

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

func (*DelegatedTasksCompleted) Reset 

func (x *DelegatedTasksCompleted) Reset()

func (*DelegatedTasksCompleted) String 

func (x *DelegatedTasksCompleted) String() string

type Deleter 

type Deleter struct {
	Key string `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
	// contains filtered or unexported fields
}

func (*Deleter) Descriptor deprecated 

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

Deprecated: Use Deleter.ProtoReflect.Descriptor instead.

func (*Deleter) GetKey 

func (x *Deleter) GetKey() string

func (*Deleter) ProtoMessage 

func (*Deleter) ProtoMessage()

func (*Deleter) ProtoReflect 

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

func (*Deleter) Reset 

func (x *Deleter) Reset()

func (*Deleter) String 

func (x *Deleter) String() string

type Health 

type Health struct {
	Status   OverallStatus `protobuf:"varint,1,opt,name=Status,proto3,enum=metrics.OverallStatus" json:"Status,omitempty"`
	Messages []string      `protobuf:"bytes,3,rep,name=Messages,proto3" json:"Messages,omitempty"`
	// contains filtered or unexported fields
}

func (*Health) Descriptor deprecated 

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

Deprecated: Use Health.ProtoReflect.Descriptor instead.

func (*Health) GetMessages 

func (x *Health) GetMessages() []string

func (*Health) GetStatus 

func (x *Health) GetStatus() OverallStatus

func (*Health) MarshalLogObject 

func (a *Health) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*Health) ProtoMessage 

func (*Health) ProtoMessage()

func (*Health) ProtoReflect 

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

func (*Health) Reset 

func (x *Health) Reset()

func (*Health) String 

func (x *Health) String() string

type Identifier 

type Identifier struct {
	UUID string `protobuf:"bytes,1,opt,name=UUID,proto3" json:"UUID,omitempty"`
	// contains filtered or unexported fields
}

func (*Identifier) Descriptor deprecated 

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

Deprecated: Use Identifier.ProtoReflect.Descriptor instead.

func (*Identifier) GetUUID 

func (x *Identifier) GetUUID() string

func (*Identifier) MarshalLogObject 

func (a *Identifier) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*Identifier) ProtoMessage 

func (*Identifier) ProtoMessage()

func (*Identifier) ProtoReflect 

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

func (*Identifier) Reset 

func (x *Identifier) Reset()

func (*Identifier) String 

func (x *Identifier) String() string

type ListenerCount 

type ListenerCount struct {
	Count int32 `protobuf:"varint,1,opt,name=Count,proto3" json:"Count,omitempty"`
	// contains filtered or unexported fields
}

func (*ListenerCount) Descriptor deprecated 

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

Deprecated: Use ListenerCount.ProtoReflect.Descriptor instead.

func (*ListenerCount) GetCount 

func (x *ListenerCount) GetCount() int32

func (*ListenerCount) MarshalLogObject 

func (a *ListenerCount) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ListenerCount) ProtoMessage 

func (*ListenerCount) ProtoMessage()

func (*ListenerCount) ProtoReflect 

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

func (*ListenerCount) Reset 

func (x *ListenerCount) Reset()

func (*ListenerCount) String 

func (x *ListenerCount) String() string

type LocalTasksCompleted 

type LocalTasksCompleted struct {
	Total int64 `protobuf:"varint,1,opt,name=Total,proto3" json:"Total,omitempty"`
	// contains filtered or unexported fields
}

func (*LocalTasksCompleted) Descriptor deprecated 

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

Deprecated: Use LocalTasksCompleted.ProtoReflect.Descriptor instead.

func (*LocalTasksCompleted) GetTotal 

func (x *LocalTasksCompleted) GetTotal() int64

func (*LocalTasksCompleted) MarshalLogObject 

func (a *LocalTasksCompleted) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*LocalTasksCompleted) ProtoMessage 

func (*LocalTasksCompleted) ProtoMessage()

func (*LocalTasksCompleted) ProtoReflect 

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

func (*LocalTasksCompleted) Reset 

func (x *LocalTasksCompleted) Reset()

func (*LocalTasksCompleted) String 

func (x *LocalTasksCompleted) String() string

type MetricsPostedTotal 

type MetricsPostedTotal struct {
	Total int64 `protobuf:"varint,1,opt,name=Total,proto3" json:"Total,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricsPostedTotal) Descriptor deprecated 

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

Deprecated: Use MetricsPostedTotal.ProtoReflect.Descriptor instead.

func (*MetricsPostedTotal) GetTotal 

func (x *MetricsPostedTotal) GetTotal() int64

func (*MetricsPostedTotal) MarshalLogObject 

func (a *MetricsPostedTotal) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*MetricsPostedTotal) ProtoMessage 

func (*MetricsPostedTotal) ProtoMessage()

func (*MetricsPostedTotal) ProtoReflect 

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

func (*MetricsPostedTotal) Reset 

func (x *MetricsPostedTotal) Reset()

func (*MetricsPostedTotal) String 

func (x *MetricsPostedTotal) String() string

type OverallStatus 

type OverallStatus int32
const (
	OverallStatus_UnknownStatus OverallStatus = 0
	OverallStatus_Ready         OverallStatus = 1
	OverallStatus_Initializing  OverallStatus = 2
	OverallStatus_Degraded      OverallStatus = 3
	OverallStatus_Unavailable   OverallStatus = 4
)

func (OverallStatus) Descriptor 

func (OverallStatus) Descriptor() protoreflect.EnumDescriptor

func (OverallStatus) Enum 

func (x OverallStatus) Enum() *OverallStatus

func (OverallStatus) EnumDescriptor deprecated 

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

Deprecated: Use OverallStatus.Descriptor instead.

func (OverallStatus) Number 

func (x OverallStatus) Number() protoreflect.EnumNumber

func (OverallStatus) String 

func (x OverallStatus) String() string

func (OverallStatus) Type 

func (OverallStatus) Type() protoreflect.EnumType

type PreferredUsageLimits 

type PreferredUsageLimits struct {
	ConcurrentProcessLimit int64 `protobuf:"varint,1,opt,name=ConcurrentProcessLimit,proto3" json:"ConcurrentProcessLimit,omitempty"`
	// contains filtered or unexported fields
}

func (*PreferredUsageLimits) Descriptor deprecated 

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

Deprecated: Use PreferredUsageLimits.ProtoReflect.Descriptor instead.

func (*PreferredUsageLimits) GetConcurrentProcessLimit 

func (x *PreferredUsageLimits) GetConcurrentProcessLimit() int64

func (*PreferredUsageLimits) MarshalLogObject 

func (a *PreferredUsageLimits) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*PreferredUsageLimits) ProtoMessage 

func (*PreferredUsageLimits) ProtoMessage()

func (*PreferredUsageLimits) ProtoReflect 

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

func (*PreferredUsageLimits) Reset 

func (x *PreferredUsageLimits) Reset()

func (*PreferredUsageLimits) String 

func (x *PreferredUsageLimits) String() string

type ProviderCount 

type ProviderCount struct {
	Count int32 `protobuf:"varint,1,opt,name=Count,proto3" json:"Count,omitempty"`
	// contains filtered or unexported fields
}

func (*ProviderCount) Descriptor deprecated 

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

Deprecated: Use ProviderCount.ProtoReflect.Descriptor instead.

func (*ProviderCount) GetCount 

func (x *ProviderCount) GetCount() int32

func (*ProviderCount) MarshalLogObject 

func (a *ProviderCount) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ProviderCount) ProtoMessage 

func (*ProviderCount) ProtoMessage()

func (*ProviderCount) ProtoReflect 

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

func (*ProviderCount) Reset 

func (x *ProviderCount) Reset()

func (*ProviderCount) String 

func (x *ProviderCount) String() string

type ProviderInfo 

type ProviderInfo struct {
	UUID      string          `protobuf:"bytes,1,opt,name=UUID,proto3" json:"UUID,omitempty"`
	Component types.Component `protobuf:"varint,2,opt,name=Component,proto3,enum=types.Component" json:"Component,omitempty"`
	Address   string          `protobuf:"bytes,3,opt,name=Address,proto3" json:"Address,omitempty"`
	// contains filtered or unexported fields
}

func (*ProviderInfo) Descriptor deprecated 

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

Deprecated: Use ProviderInfo.ProtoReflect.Descriptor instead.

func (*ProviderInfo) GetAddress 

func (x *ProviderInfo) GetAddress() string

func (*ProviderInfo) GetComponent 

func (x *ProviderInfo) GetComponent() types.Component

func (*ProviderInfo) GetUUID 

func (x *ProviderInfo) GetUUID() string

func (*ProviderInfo) MarshalLogObject 

func (a *ProviderInfo) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ProviderInfo) ProtoMessage 

func (*ProviderInfo) ProtoMessage()

func (*ProviderInfo) ProtoReflect 

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

func (*ProviderInfo) Reset 

func (x *ProviderInfo) Reset()

func (*ProviderInfo) String 

func (x *ProviderInfo) String() string

type Providers 

type Providers struct {
	Items map[string]*ProviderInfo `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Providers) Descriptor deprecated 

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

Deprecated: Use Providers.ProtoReflect.Descriptor instead.

func (*Providers) GetItems 

func (x *Providers) GetItems() map[string]*ProviderInfo

func (*Providers) MarshalLogObject 

func (a *Providers) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*Providers) ProtoMessage 

func (*Providers) ProtoMessage()

func (*Providers) ProtoReflect 

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

func (*Providers) Reset 

func (x *Providers) Reset()

func (*Providers) String 

func (x *Providers) String() string

type SchedulingRequestsTotal 

type SchedulingRequestsTotal struct {
	Total int64 `protobuf:"varint,1,opt,name=Total,proto3" json:"Total,omitempty"`
	// contains filtered or unexported fields
}

func (*SchedulingRequestsTotal) Descriptor deprecated 

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

Deprecated: Use SchedulingRequestsTotal.ProtoReflect.Descriptor instead.

func (*SchedulingRequestsTotal) GetTotal 

func (x *SchedulingRequestsTotal) GetTotal() int64

func (*SchedulingRequestsTotal) MarshalLogObject 

func (a *SchedulingRequestsTotal) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*SchedulingRequestsTotal) ProtoMessage 

func (*SchedulingRequestsTotal) ProtoMessage()

func (*SchedulingRequestsTotal) ProtoReflect 

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

func (*SchedulingRequestsTotal) Reset 

func (x *SchedulingRequestsTotal) Reset()

func (*SchedulingRequestsTotal) String 

func (x *SchedulingRequestsTotal) String() string

type StatusConditions 

type StatusConditions int32
const (
	StatusConditions_NoConditions             StatusConditions = 0
	StatusConditions_Pending                  StatusConditions = 1
	StatusConditions_MissingOptionalComponent StatusConditions = 2
	StatusConditions_MissingCriticalComponent StatusConditions = 3
	StatusConditions_InvalidConfiguration     StatusConditions = 4
	StatusConditions_InternalError            StatusConditions = 5
)

func (StatusConditions) Descriptor 

func (StatusConditions) Descriptor() protoreflect.EnumDescriptor

func (StatusConditions) Enum 

func (x StatusConditions) Enum() *StatusConditions

func (StatusConditions) EnumDescriptor deprecated 

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

Deprecated: Use StatusConditions.Descriptor instead.

func (StatusConditions) Format 

func (sc StatusConditions) Format(msg string) string

func (StatusConditions) FormatAll 

func (sc StatusConditions) FormatAll(msgs ...string) []string

func (StatusConditions) Number 

func (x StatusConditions) Number() protoreflect.EnumNumber

func (StatusConditions) String 

func (x StatusConditions) String() string

func (StatusConditions) Type 

func (StatusConditions) Type() protoreflect.EnumType

type StatusController 

type StatusController struct {
	// contains filtered or unexported fields
}

func (*StatusController) ApplyCondition 

func (sm *StatusController) ApplyCondition(
	while context.Context,
	cond StatusConditions,
	msgs ...string,
)

func (*StatusController) BeginInitialize 

func (sm *StatusController) BeginInitialize(srvCtx context.Context)

func (*StatusController) EndInitialize 

func (sm *StatusController) EndInitialize()

func (*StatusController) GetHealth 

func (sm *StatusController) GetHealth() *Health

func (*StatusController) StreamHealthUpdates 

func (sm *StatusController) StreamHealthUpdates() chan *Health

func (*StatusController) WaitForStatusChanged 

func (sm *StatusController) WaitForStatusChanged()

type TaskStatus 

type TaskStatus struct {
	NumRunning   int32 `protobuf:"varint,1,opt,name=NumRunning,proto3" json:"NumRunning,omitempty"`
	NumQueued    int32 `protobuf:"varint,2,opt,name=NumQueued,proto3" json:"NumQueued,omitempty"`
	NumDelegated int32 `protobuf:"varint,3,opt,name=NumDelegated,proto3" json:"NumDelegated,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskStatus) Descriptor deprecated 

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

Deprecated: Use TaskStatus.ProtoReflect.Descriptor instead.

func (*TaskStatus) GetNumDelegated 

func (x *TaskStatus) GetNumDelegated() int32

func (*TaskStatus) GetNumQueued 

func (x *TaskStatus) GetNumQueued() int32

func (*TaskStatus) GetNumRunning 

func (x *TaskStatus) GetNumRunning() int32

func (*TaskStatus) MarshalLogObject 

func (a *TaskStatus) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*TaskStatus) ProtoMessage 

func (*TaskStatus) ProtoMessage()

func (*TaskStatus) ProtoReflect 

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

func (*TaskStatus) Reset 

func (x *TaskStatus) Reset()

func (*TaskStatus) String 

func (x *TaskStatus) String() string

type TaskStatusCompleter 

type TaskStatusCompleter interface {
	CompleteTaskStatus(*TaskStatus)
}

type TasksCompletedCompleter 

type TasksCompletedCompleter interface {
	CompleteLocalTasksCompleted(*LocalTasksCompleted)
	CompleteDelegatedTasksCompleted(*DelegatedTasksCompleted)
}

type TasksCompletedTotal 

type TasksCompletedTotal struct {
	Total int64 `protobuf:"varint,1,opt,name=Total,proto3" json:"Total,omitempty"`
	// contains filtered or unexported fields
}

func (*TasksCompletedTotal) Descriptor deprecated 

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

Deprecated: Use TasksCompletedTotal.ProtoReflect.Descriptor instead.

func (*TasksCompletedTotal) GetTotal 

func (x *TasksCompletedTotal) GetTotal() int64

func (*TasksCompletedTotal) MarshalLogObject 

func (a *TasksCompletedTotal) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*TasksCompletedTotal) ProtoMessage 

func (*TasksCompletedTotal) ProtoMessage()

func (*TasksCompletedTotal) ProtoReflect 

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

func (*TasksCompletedTotal) Reset 

func (x *TasksCompletedTotal) Reset()

func (*TasksCompletedTotal) String 

func (x *TasksCompletedTotal) String() string

type TasksFailedTotal 

type TasksFailedTotal struct {
	Total int64 `protobuf:"varint,1,opt,name=Total,proto3" json:"Total,omitempty"`
	// contains filtered or unexported fields
}

func (*TasksFailedTotal) Descriptor deprecated 

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

Deprecated: Use TasksFailedTotal.ProtoReflect.Descriptor instead.

func (*TasksFailedTotal) GetTotal 

func (x *TasksFailedTotal) GetTotal() int64

func (*TasksFailedTotal) MarshalLogObject 

func (a *TasksFailedTotal) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*TasksFailedTotal) ProtoMessage 

func (*TasksFailedTotal) ProtoMessage()

func (*TasksFailedTotal) ProtoReflect 

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

func (*TasksFailedTotal) Reset 

func (x *TasksFailedTotal) Reset()

func (*TasksFailedTotal) String 

func (x *TasksFailedTotal) String() string

type ThrottlingData 

type ThrottlingData struct {
	Periods          uint64 `protobuf:"varint,1,opt,name=Periods,proto3" json:"Periods,omitempty"`
	ThrottledPeriods uint64 `protobuf:"varint,2,opt,name=ThrottledPeriods,proto3" json:"ThrottledPeriods,omitempty"`
	ThrottledTime    uint64 `protobuf:"varint,3,opt,name=ThrottledTime,proto3" json:"ThrottledTime,omitempty"`
	// contains filtered or unexported fields
}

func (*ThrottlingData) Descriptor deprecated 

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

Deprecated: Use ThrottlingData.ProtoReflect.Descriptor instead.

func (*ThrottlingData) GetPeriods 

func (x *ThrottlingData) GetPeriods() uint64

func (*ThrottlingData) GetThrottledPeriods 

func (x *ThrottlingData) GetThrottledPeriods() uint64

func (*ThrottlingData) GetThrottledTime 

func (x *ThrottlingData) GetThrottledTime() uint64

func (*ThrottlingData) MarshalLogObject 

func (a *ThrottlingData) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ThrottlingData) ProtoMessage 

func (*ThrottlingData) ProtoMessage()

func (*ThrottlingData) ProtoReflect 

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

func (*ThrottlingData) Reset 

func (x *ThrottlingData) Reset()

func (*ThrottlingData) String 

func (x *ThrottlingData) String() string

type Toolchains 

type Toolchains struct {
	Items []*types.Toolchain `protobuf:"bytes,1,rep,name=Items,proto3" json:"Items,omitempty"`
	// contains filtered or unexported fields
}

func (*Toolchains) Descriptor deprecated 

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

Deprecated: Use Toolchains.ProtoReflect.Descriptor instead.

func (*Toolchains) GetItems 

func (x *Toolchains) GetItems() []*types.Toolchain

func (*Toolchains) MarshalLogObject 

func (a *Toolchains) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*Toolchains) ProtoMessage 

func (*Toolchains) ProtoMessage()

func (*Toolchains) ProtoReflect 

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

func (*Toolchains) Reset 

func (x *Toolchains) Reset()

func (*Toolchains) String 

func (x *Toolchains) String() string

type UsageLimits 

type UsageLimits struct {
	ConcurrentProcessLimit int32 `protobuf:"varint,1,opt,name=ConcurrentProcessLimit,proto3" json:"ConcurrentProcessLimit,omitempty"`
	DelegatedTaskLimit     int32 `protobuf:"varint,2,opt,name=DelegatedTaskLimit,proto3" json:"DelegatedTaskLimit,omitempty"`
	// contains filtered or unexported fields
}

func (*UsageLimits) Descriptor deprecated 

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

Deprecated: Use UsageLimits.ProtoReflect.Descriptor instead.

func (*UsageLimits) GetConcurrentProcessLimit 

func (x *UsageLimits) GetConcurrentProcessLimit() int32

func (*UsageLimits) GetDelegatedTaskLimit 

func (x *UsageLimits) GetDelegatedTaskLimit() int32

func (*UsageLimits) MarshalLogObject 

func (a *UsageLimits) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*UsageLimits) ProtoMessage 

func (*UsageLimits) ProtoMessage()

func (*UsageLimits) ProtoReflect 

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

func (*UsageLimits) Reset 

func (x *UsageLimits) Reset()

func (*UsageLimits) String 

func (x *UsageLimits) String() string

type UsageLimitsCompleter 

type UsageLimitsCompleter interface {
	CompleteUsageLimits(*UsageLimits)
}

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.