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) Enum

func (x OverallStatus) Enum() *OverallStatus

func (OverallStatus) EnumDescriptor deprecated

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

Deprecated: Use OverallStatus.Descriptor instead.

func (OverallStatus) Number

func (OverallStatus) String

func (x OverallStatus) String() string

func (OverallStatus) Type

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) Enum

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 (StatusConditions) String

func (x StatusConditions) String() string

func (StatusConditions) Type

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)
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL