scheduler

package
v0.0.0-...-ea22f37 Latest Latest
Warning

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

Go to latest
Published: Apr 1, 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 (*ActionRouterConfiguration) GetKind

func (m *ActionRouterConfiguration) GetKind() isActionRouterConfiguration_Kind

func (*ActionRouterConfiguration) GetSimple

func (*ActionRouterConfiguration) ProtoMessage

func (*ActionRouterConfiguration) ProtoMessage()

func (*ActionRouterConfiguration) ProtoReflect

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 (*DemultiplexingActionRouterConfiguration) GetDefaultActionRouter

func (*DemultiplexingActionRouterConfiguration) GetPlatformKeyExtractor

func (*DemultiplexingActionRouterConfiguration) ProtoMessage

func (*DemultiplexingActionRouterConfiguration) ProtoReflect

func (*DemultiplexingActionRouterConfiguration) Reset

func (*DemultiplexingActionRouterConfiguration) 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

Deprecated: Use DemultiplexingActionRouterConfiguration_Backend.ProtoReflect.Descriptor instead.

func (*DemultiplexingActionRouterConfiguration_Backend) GetActionRouter

func (*DemultiplexingActionRouterConfiguration_Backend) GetInstanceNamePrefix

func (x *DemultiplexingActionRouterConfiguration_Backend) GetInstanceNamePrefix() string

func (*DemultiplexingActionRouterConfiguration_Backend) GetPlatform

func (*DemultiplexingActionRouterConfiguration_Backend) ProtoMessage

func (*DemultiplexingActionRouterConfiguration_Backend) ProtoReflect

func (*DemultiplexingActionRouterConfiguration_Backend) Reset

func (*DemultiplexingActionRouterConfiguration_Backend) 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 (*InitialSizeClassAnalyzerConfiguration) GetMaximumExecutionTimeout

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

func (*InitialSizeClassAnalyzerConfiguration) ProtoMessage

func (*InitialSizeClassAnalyzerConfiguration) ProtoMessage()

func (*InitialSizeClassAnalyzerConfiguration) ProtoReflect

func (*InitialSizeClassAnalyzerConfiguration) Reset

func (*InitialSizeClassAnalyzerConfiguration) 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

Deprecated: Use InitialSizeClassFeedbackDrivenAnalyzerConfiguration.ProtoReflect.Descriptor instead.

func (*InitialSizeClassFeedbackDrivenAnalyzerConfiguration) GetFailureCacheDuration

func (*InitialSizeClassFeedbackDrivenAnalyzerConfiguration) GetHistorySize

func (*InitialSizeClassFeedbackDrivenAnalyzerConfiguration) GetPageRank

func (*InitialSizeClassFeedbackDrivenAnalyzerConfiguration) ProtoMessage

func (*InitialSizeClassFeedbackDrivenAnalyzerConfiguration) ProtoReflect

func (*InitialSizeClassFeedbackDrivenAnalyzerConfiguration) Reset

func (*InitialSizeClassFeedbackDrivenAnalyzerConfiguration) 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

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 (*InitialSizeClassPageRankStrategyCalculatorConfiguration) GetSmallerSizeClassExecutionTimeoutMultiplier

func (x *InitialSizeClassPageRankStrategyCalculatorConfiguration) GetSmallerSizeClassExecutionTimeoutMultiplier() float64

func (*InitialSizeClassPageRankStrategyCalculatorConfiguration) ProtoMessage

func (*InitialSizeClassPageRankStrategyCalculatorConfiguration) ProtoReflect

func (*InitialSizeClassPageRankStrategyCalculatorConfiguration) Reset

func (*InitialSizeClassPageRankStrategyCalculatorConfiguration) 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 (*InvocationKeyExtractorConfiguration) Reset

func (*InvocationKeyExtractorConfiguration) 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 (*PlatformKeyExtractorConfiguration) GetActionAndCommand

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

func (*PlatformKeyExtractorConfiguration) GetKind

func (m *PlatformKeyExtractorConfiguration) GetKind() isPlatformKeyExtractorConfiguration_Kind

func (*PlatformKeyExtractorConfiguration) GetStatic

func (*PlatformKeyExtractorConfiguration) ProtoMessage

func (*PlatformKeyExtractorConfiguration) ProtoMessage()

func (*PlatformKeyExtractorConfiguration) ProtoReflect

func (*PlatformKeyExtractorConfiguration) Reset

func (*PlatformKeyExtractorConfiguration) 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 (*SimpleActionRouterConfiguration) GetInvocationKeyExtractors

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

func (*SimpleActionRouterConfiguration) GetPlatformKeyExtractor

func (*SimpleActionRouterConfiguration) ProtoMessage

func (*SimpleActionRouterConfiguration) ProtoMessage()

func (*SimpleActionRouterConfiguration) ProtoReflect

func (*SimpleActionRouterConfiguration) Reset

func (*SimpleActionRouterConfiguration) String

Jump to

Keyboard shortcuts

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