scheduler

package
v0.0.0-...-d03d5e3 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_pkg_proto_configuration_scheduler_scheduler_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ActionRouterConfiguration 

type ActionRouterConfiguration struct {

	// Types that are assignable to Kind:
	//
	//	*ActionRouterConfiguration_Simple
	//	*ActionRouterConfiguration_Demultiplexing
	Kind isActionRouterConfiguration_Kind `protobuf_oneof:"kind"`
	// contains filtered or unexported fields
}

func (*ActionRouterConfiguration) Descriptor deprecated 

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

Deprecated: Use ActionRouterConfiguration.ProtoReflect.Descriptor instead.

func (*ActionRouterConfiguration) GetDemultiplexing 

func (x *ActionRouterConfiguration) GetDemultiplexing() *DemultiplexingActionRouterConfiguration

func (*ActionRouterConfiguration) GetKind 

func (m *ActionRouterConfiguration) GetKind() isActionRouterConfiguration_Kind

func (*ActionRouterConfiguration) GetSimple 

func (x *ActionRouterConfiguration) GetSimple() *SimpleActionRouterConfiguration

func (*ActionRouterConfiguration) ProtoMessage 

func (*ActionRouterConfiguration) ProtoMessage()

func (*ActionRouterConfiguration) ProtoReflect 

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

func (*ActionRouterConfiguration) Reset 

func (x *ActionRouterConfiguration) Reset()

func (*ActionRouterConfiguration) String 

func (x *ActionRouterConfiguration) String() string

type ActionRouterConfiguration_Demultiplexing 

type ActionRouterConfiguration_Demultiplexing struct {
	Demultiplexing *DemultiplexingActionRouterConfiguration `protobuf:"bytes,2,opt,name=demultiplexing,proto3,oneof"`
}

type ActionRouterConfiguration_Simple 

type ActionRouterConfiguration_Simple struct {
	Simple *SimpleActionRouterConfiguration `protobuf:"bytes,1,opt,name=simple,proto3,oneof"`
}

type DemultiplexingActionRouterConfiguration 

type DemultiplexingActionRouterConfiguration struct {
	PlatformKeyExtractor *PlatformKeyExtractorConfiguration                 `protobuf:"bytes,1,opt,name=platform_key_extractor,json=platformKeyExtractor,proto3" json:"platform_key_extractor,omitempty"`
	Backends             []*DemultiplexingActionRouterConfiguration_Backend `protobuf:"bytes,2,rep,name=backends,proto3" json:"backends,omitempty"`
	DefaultActionRouter  *ActionRouterConfiguration                         `protobuf:"bytes,3,opt,name=default_action_router,json=defaultActionRouter,proto3" json:"default_action_router,omitempty"`
	// contains filtered or unexported fields
}

func (*DemultiplexingActionRouterConfiguration) Descriptor deprecated 

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

Deprecated: Use DemultiplexingActionRouterConfiguration.ProtoReflect.Descriptor instead.

func (*DemultiplexingActionRouterConfiguration) GetBackends 

func (x *DemultiplexingActionRouterConfiguration) GetBackends() []*DemultiplexingActionRouterConfiguration_Backend

func (*DemultiplexingActionRouterConfiguration) GetDefaultActionRouter 

func (x *DemultiplexingActionRouterConfiguration) GetDefaultActionRouter() *ActionRouterConfiguration

func (*DemultiplexingActionRouterConfiguration) GetPlatformKeyExtractor 

func (x *DemultiplexingActionRouterConfiguration) GetPlatformKeyExtractor() *PlatformKeyExtractorConfiguration

func (*DemultiplexingActionRouterConfiguration) ProtoMessage 

func (*DemultiplexingActionRouterConfiguration) ProtoMessage()

func (*DemultiplexingActionRouterConfiguration) ProtoReflect 

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

func (*DemultiplexingActionRouterConfiguration) Reset 

func (x *DemultiplexingActionRouterConfiguration) Reset()

func (*DemultiplexingActionRouterConfiguration) String 

func (x *DemultiplexingActionRouterConfiguration) String() string

type DemultiplexingActionRouterConfiguration_Backend 

type DemultiplexingActionRouterConfiguration_Backend struct {
	InstanceNamePrefix string                     `protobuf:"bytes,1,opt,name=instance_name_prefix,json=instanceNamePrefix,proto3" json:"instance_name_prefix,omitempty"`
	Platform           *v2.Platform               `protobuf:"bytes,2,opt,name=platform,proto3" json:"platform,omitempty"`
	ActionRouter       *ActionRouterConfiguration `protobuf:"bytes,3,opt,name=action_router,json=actionRouter,proto3" json:"action_router,omitempty"`
	// contains filtered or unexported fields
}

func (*DemultiplexingActionRouterConfiguration_Backend) Descriptor deprecated 

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

Deprecated: Use DemultiplexingActionRouterConfiguration_Backend.ProtoReflect.Descriptor instead.

func (*DemultiplexingActionRouterConfiguration_Backend) GetActionRouter 

func (x *DemultiplexingActionRouterConfiguration_Backend) GetActionRouter() *ActionRouterConfiguration

func (*DemultiplexingActionRouterConfiguration_Backend) GetInstanceNamePrefix 

func (x *DemultiplexingActionRouterConfiguration_Backend) GetInstanceNamePrefix() string

func (*DemultiplexingActionRouterConfiguration_Backend) GetPlatform 

func (x *DemultiplexingActionRouterConfiguration_Backend) GetPlatform() *v2.Platform

func (*DemultiplexingActionRouterConfiguration_Backend) ProtoMessage 

func (*DemultiplexingActionRouterConfiguration_Backend) ProtoMessage()

func (*DemultiplexingActionRouterConfiguration_Backend) ProtoReflect 

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

func (*DemultiplexingActionRouterConfiguration_Backend) Reset 

func (x *DemultiplexingActionRouterConfiguration_Backend) Reset()

func (*DemultiplexingActionRouterConfiguration_Backend) String 

func (x *DemultiplexingActionRouterConfiguration_Backend) String() string

type InitialSizeClassAnalyzerConfiguration 

type InitialSizeClassAnalyzerConfiguration struct {
	DefaultExecutionTimeout *durationpb.Duration                                 `` /* 132-byte string literal not displayed */
	MaximumExecutionTimeout *durationpb.Duration                                 `` /* 132-byte string literal not displayed */
	FeedbackDriven          *InitialSizeClassFeedbackDrivenAnalyzerConfiguration `protobuf:"bytes,3,opt,name=feedback_driven,json=feedbackDriven,proto3" json:"feedback_driven,omitempty"`
	// contains filtered or unexported fields
}

func (*InitialSizeClassAnalyzerConfiguration) Descriptor deprecated 

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

Deprecated: Use InitialSizeClassAnalyzerConfiguration.ProtoReflect.Descriptor instead.

func (*InitialSizeClassAnalyzerConfiguration) GetDefaultExecutionTimeout 

func (x *InitialSizeClassAnalyzerConfiguration) GetDefaultExecutionTimeout() *durationpb.Duration

func (*InitialSizeClassAnalyzerConfiguration) GetFeedbackDriven 

func (x *InitialSizeClassAnalyzerConfiguration) GetFeedbackDriven() *InitialSizeClassFeedbackDrivenAnalyzerConfiguration

func (*InitialSizeClassAnalyzerConfiguration) GetMaximumExecutionTimeout 

func (x *InitialSizeClassAnalyzerConfiguration) GetMaximumExecutionTimeout() *durationpb.Duration

func (*InitialSizeClassAnalyzerConfiguration) ProtoMessage 

func (*InitialSizeClassAnalyzerConfiguration) ProtoMessage()

func (*InitialSizeClassAnalyzerConfiguration) ProtoReflect 

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

func (*InitialSizeClassAnalyzerConfiguration) Reset 

func (x *InitialSizeClassAnalyzerConfiguration) Reset()

func (*InitialSizeClassAnalyzerConfiguration) String 

func (x *InitialSizeClassAnalyzerConfiguration) String() string

type InitialSizeClassFeedbackDrivenAnalyzerConfiguration 

type InitialSizeClassFeedbackDrivenAnalyzerConfiguration struct {
	FailureCacheDuration *durationpb.Duration                                     `protobuf:"bytes,1,opt,name=failure_cache_duration,json=failureCacheDuration,proto3" json:"failure_cache_duration,omitempty"`
	HistorySize          int32                                                    `protobuf:"varint,6,opt,name=history_size,json=historySize,proto3" json:"history_size,omitempty"`
	PageRank             *InitialSizeClassPageRankStrategyCalculatorConfiguration `protobuf:"bytes,7,opt,name=page_rank,json=pageRank,proto3" json:"page_rank,omitempty"`
	// contains filtered or unexported fields
}

func (*InitialSizeClassFeedbackDrivenAnalyzerConfiguration) Descriptor deprecated 

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

Deprecated: Use InitialSizeClassFeedbackDrivenAnalyzerConfiguration.ProtoReflect.Descriptor instead.

func (*InitialSizeClassFeedbackDrivenAnalyzerConfiguration) GetFailureCacheDuration 

func (x *InitialSizeClassFeedbackDrivenAnalyzerConfiguration) GetFailureCacheDuration() *durationpb.Duration

func (*InitialSizeClassFeedbackDrivenAnalyzerConfiguration) GetHistorySize 

func (x *InitialSizeClassFeedbackDrivenAnalyzerConfiguration) GetHistorySize() int32

func (*InitialSizeClassFeedbackDrivenAnalyzerConfiguration) GetPageRank 

func (x *InitialSizeClassFeedbackDrivenAnalyzerConfiguration) GetPageRank() *InitialSizeClassPageRankStrategyCalculatorConfiguration

func (*InitialSizeClassFeedbackDrivenAnalyzerConfiguration) ProtoMessage 

func (*InitialSizeClassFeedbackDrivenAnalyzerConfiguration) ProtoMessage()

func (*InitialSizeClassFeedbackDrivenAnalyzerConfiguration) ProtoReflect 

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

func (*InitialSizeClassFeedbackDrivenAnalyzerConfiguration) Reset 

func (x *InitialSizeClassFeedbackDrivenAnalyzerConfiguration) Reset()

func (*InitialSizeClassFeedbackDrivenAnalyzerConfiguration) String 

func (x *InitialSizeClassFeedbackDrivenAnalyzerConfiguration) String() string

type InitialSizeClassPageRankStrategyCalculatorConfiguration 

type InitialSizeClassPageRankStrategyCalculatorConfiguration struct {
	AcceptableExecutionTimeIncreaseExponent    float64              `` /* 186-byte string literal not displayed */
	SmallerSizeClassExecutionTimeoutMultiplier float64              `` /* 197-byte string literal not displayed */
	MinimumExecutionTimeout                    *durationpb.Duration `` /* 132-byte string literal not displayed */
	MaximumConvergenceError                    float64              `` /* 134-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*InitialSizeClassPageRankStrategyCalculatorConfiguration) Descriptor deprecated 

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

Deprecated: Use InitialSizeClassPageRankStrategyCalculatorConfiguration.ProtoReflect.Descriptor instead.

func (*InitialSizeClassPageRankStrategyCalculatorConfiguration) GetAcceptableExecutionTimeIncreaseExponent 

func (x *InitialSizeClassPageRankStrategyCalculatorConfiguration) GetAcceptableExecutionTimeIncreaseExponent() float64

func (*InitialSizeClassPageRankStrategyCalculatorConfiguration) GetMaximumConvergenceError 

func (x *InitialSizeClassPageRankStrategyCalculatorConfiguration) GetMaximumConvergenceError() float64

func (*InitialSizeClassPageRankStrategyCalculatorConfiguration) GetMinimumExecutionTimeout 

func (x *InitialSizeClassPageRankStrategyCalculatorConfiguration) GetMinimumExecutionTimeout() *durationpb.Duration

func (*InitialSizeClassPageRankStrategyCalculatorConfiguration) GetSmallerSizeClassExecutionTimeoutMultiplier 

func (x *InitialSizeClassPageRankStrategyCalculatorConfiguration) GetSmallerSizeClassExecutionTimeoutMultiplier() float64

func (*InitialSizeClassPageRankStrategyCalculatorConfiguration) ProtoMessage 

func (*InitialSizeClassPageRankStrategyCalculatorConfiguration) ProtoMessage()

func (*InitialSizeClassPageRankStrategyCalculatorConfiguration) ProtoReflect 

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

func (*InitialSizeClassPageRankStrategyCalculatorConfiguration) Reset 

func (x *InitialSizeClassPageRankStrategyCalculatorConfiguration) Reset()

func (*InitialSizeClassPageRankStrategyCalculatorConfiguration) String 

func (x *InitialSizeClassPageRankStrategyCalculatorConfiguration) String() string

type InvocationKeyExtractorConfiguration 

type InvocationKeyExtractorConfiguration struct {

	// Types that are assignable to Kind:
	//
	//	*InvocationKeyExtractorConfiguration_ToolInvocationId
	//	*InvocationKeyExtractorConfiguration_CorrelatedInvocationsId
	//	*InvocationKeyExtractorConfiguration_AuthenticationMetadata
	Kind isInvocationKeyExtractorConfiguration_Kind `protobuf_oneof:"kind"`
	// contains filtered or unexported fields
}

func (*InvocationKeyExtractorConfiguration) Descriptor deprecated 

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

Deprecated: Use InvocationKeyExtractorConfiguration.ProtoReflect.Descriptor instead.

func (*InvocationKeyExtractorConfiguration) GetAuthenticationMetadata 

func (x *InvocationKeyExtractorConfiguration) GetAuthenticationMetadata() *emptypb.Empty

func (*InvocationKeyExtractorConfiguration) GetCorrelatedInvocationsId 

func (x *InvocationKeyExtractorConfiguration) GetCorrelatedInvocationsId() *emptypb.Empty

func (*InvocationKeyExtractorConfiguration) GetKind 

func (m *InvocationKeyExtractorConfiguration) GetKind() isInvocationKeyExtractorConfiguration_Kind

func (*InvocationKeyExtractorConfiguration) GetToolInvocationId 

func (x *InvocationKeyExtractorConfiguration) GetToolInvocationId() *emptypb.Empty

func (*InvocationKeyExtractorConfiguration) ProtoMessage 

func (*InvocationKeyExtractorConfiguration) ProtoMessage()

func (*InvocationKeyExtractorConfiguration) ProtoReflect 

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

func (*InvocationKeyExtractorConfiguration) Reset 

func (x *InvocationKeyExtractorConfiguration) Reset()

func (*InvocationKeyExtractorConfiguration) String 

func (x *InvocationKeyExtractorConfiguration) String() string

type InvocationKeyExtractorConfiguration_AuthenticationMetadata 

type InvocationKeyExtractorConfiguration_AuthenticationMetadata struct {
	AuthenticationMetadata *emptypb.Empty `protobuf:"bytes,4,opt,name=authentication_metadata,json=authenticationMetadata,proto3,oneof"`
}

type InvocationKeyExtractorConfiguration_CorrelatedInvocationsId 

type InvocationKeyExtractorConfiguration_CorrelatedInvocationsId struct {
	CorrelatedInvocationsId *emptypb.Empty `protobuf:"bytes,3,opt,name=correlated_invocations_id,json=correlatedInvocationsId,proto3,oneof"`
}

type InvocationKeyExtractorConfiguration_ToolInvocationId 

type InvocationKeyExtractorConfiguration_ToolInvocationId struct {
	ToolInvocationId *emptypb.Empty `protobuf:"bytes,2,opt,name=tool_invocation_id,json=toolInvocationId,proto3,oneof"`
}

type PlatformKeyExtractorConfiguration 

type PlatformKeyExtractorConfiguration struct {

	// Types that are assignable to Kind:
	//
	//	*PlatformKeyExtractorConfiguration_Action
	//	*PlatformKeyExtractorConfiguration_ActionAndCommand
	//	*PlatformKeyExtractorConfiguration_Static
	Kind isPlatformKeyExtractorConfiguration_Kind `protobuf_oneof:"kind"`
	// contains filtered or unexported fields
}

func (*PlatformKeyExtractorConfiguration) Descriptor deprecated 

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

Deprecated: Use PlatformKeyExtractorConfiguration.ProtoReflect.Descriptor instead.

func (*PlatformKeyExtractorConfiguration) GetAction 

func (x *PlatformKeyExtractorConfiguration) GetAction() *emptypb.Empty

func (*PlatformKeyExtractorConfiguration) GetActionAndCommand 

func (x *PlatformKeyExtractorConfiguration) GetActionAndCommand() *emptypb.Empty

func (*PlatformKeyExtractorConfiguration) GetKind 

func (m *PlatformKeyExtractorConfiguration) GetKind() isPlatformKeyExtractorConfiguration_Kind

func (*PlatformKeyExtractorConfiguration) GetStatic 

func (x *PlatformKeyExtractorConfiguration) GetStatic() *v2.Platform

func (*PlatformKeyExtractorConfiguration) ProtoMessage 

func (*PlatformKeyExtractorConfiguration) ProtoMessage()

func (*PlatformKeyExtractorConfiguration) ProtoReflect 

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

func (*PlatformKeyExtractorConfiguration) Reset 

func (x *PlatformKeyExtractorConfiguration) Reset()

func (*PlatformKeyExtractorConfiguration) String 

func (x *PlatformKeyExtractorConfiguration) String() string

type PlatformKeyExtractorConfiguration_Action 

type PlatformKeyExtractorConfiguration_Action struct {
	Action *emptypb.Empty `protobuf:"bytes,1,opt,name=action,proto3,oneof"`
}

type PlatformKeyExtractorConfiguration_ActionAndCommand 

type PlatformKeyExtractorConfiguration_ActionAndCommand struct {
	ActionAndCommand *emptypb.Empty `protobuf:"bytes,2,opt,name=action_and_command,json=actionAndCommand,proto3,oneof"`
}

type PlatformKeyExtractorConfiguration_Static 

type PlatformKeyExtractorConfiguration_Static struct {
	Static *v2.Platform `protobuf:"bytes,3,opt,name=static,proto3,oneof"`
}

type SimpleActionRouterConfiguration 

type SimpleActionRouterConfiguration struct {
	PlatformKeyExtractor     *PlatformKeyExtractorConfiguration     `protobuf:"bytes,1,opt,name=platform_key_extractor,json=platformKeyExtractor,proto3" json:"platform_key_extractor,omitempty"`
	InvocationKeyExtractors  []*InvocationKeyExtractorConfiguration `` /* 132-byte string literal not displayed */
	InitialSizeClassAnalyzer *InitialSizeClassAnalyzerConfiguration `` /* 137-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SimpleActionRouterConfiguration) Descriptor deprecated 

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

Deprecated: Use SimpleActionRouterConfiguration.ProtoReflect.Descriptor instead.

func (*SimpleActionRouterConfiguration) GetInitialSizeClassAnalyzer 

func (x *SimpleActionRouterConfiguration) GetInitialSizeClassAnalyzer() *InitialSizeClassAnalyzerConfiguration

func (*SimpleActionRouterConfiguration) GetInvocationKeyExtractors 

func (x *SimpleActionRouterConfiguration) GetInvocationKeyExtractors() []*InvocationKeyExtractorConfiguration

func (*SimpleActionRouterConfiguration) GetPlatformKeyExtractor 

func (x *SimpleActionRouterConfiguration) GetPlatformKeyExtractor() *PlatformKeyExtractorConfiguration

func (*SimpleActionRouterConfiguration) ProtoMessage 

func (*SimpleActionRouterConfiguration) ProtoMessage()

func (*SimpleActionRouterConfiguration) ProtoReflect 

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

func (*SimpleActionRouterConfiguration) Reset 

func (x *SimpleActionRouterConfiguration) Reset()

func (*SimpleActionRouterConfiguration) String 

func (x *SimpleActionRouterConfiguration) String() string

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.