externalscaler

package
v0.3.0 Latest Latest
Warning

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

 Go to latest Published: May 26, 2023 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ExternalScaler_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "externalscaler.ExternalScaler",
	HandlerType: (*ExternalScalerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "IsActive",
			Handler:    _ExternalScaler_IsActive_Handler,
		},
		{
			MethodName: "GetMetricSpec",
			Handler:    _ExternalScaler_GetMetricSpec_Handler,
		},
		{
			MethodName: "GetMetrics",
			Handler:    _ExternalScaler_GetMetrics_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamIsActive",
			Handler:       _ExternalScaler_StreamIsActive_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "externalscaler.proto",
}

ExternalScaler_ServiceDesc is the grpc.ServiceDesc for ExternalScaler service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_externalscaler_proto protoreflect.FileDescriptor

Functions

func RegisterExternalScalerServer 

func RegisterExternalScalerServer(s grpc.ServiceRegistrar, srv ExternalScalerServer)

Types

type ExternalScaler 

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

func NewExternalScaler 

func NewExternalScaler(client client.Client) *ExternalScaler

func (*ExternalScaler) GetMetricSpec 

func (e *ExternalScaler) GetMetricSpec(ctx context.Context, scaledObjectRef *ScaledObjectRef) (*GetMetricSpecResponse, error)

func (*ExternalScaler) GetMetrics 

func (e *ExternalScaler) GetMetrics(ctx context.Context, metricRequest *GetMetricsRequest) (*GetMetricsResponse, error)

func (*ExternalScaler) IsActive 

func (e *ExternalScaler) IsActive(ctx context.Context, scaledObject *ScaledObjectRef) (*IsActiveResponse, error)

func (*ExternalScaler) StreamIsActive 

func (e *ExternalScaler) StreamIsActive(scaledObject *ScaledObjectRef, epsServer ExternalScaler_StreamIsActiveServer) error

type ExternalScalerClient 

type ExternalScalerClient interface {
	IsActive(ctx context.Context, in *ScaledObjectRef, opts ...grpc.CallOption) (*IsActiveResponse, error)
	StreamIsActive(ctx context.Context, in *ScaledObjectRef, opts ...grpc.CallOption) (ExternalScaler_StreamIsActiveClient, error)
	GetMetricSpec(ctx context.Context, in *ScaledObjectRef, opts ...grpc.CallOption) (*GetMetricSpecResponse, error)
	GetMetrics(ctx context.Context, in *GetMetricsRequest, opts ...grpc.CallOption) (*GetMetricsResponse, error)
}

ExternalScalerClient is the client API for ExternalScaler service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewExternalScalerClient 

func NewExternalScalerClient(cc grpc.ClientConnInterface) ExternalScalerClient

type ExternalScalerServer 

type ExternalScalerServer interface {
	IsActive(context.Context, *ScaledObjectRef) (*IsActiveResponse, error)
	StreamIsActive(*ScaledObjectRef, ExternalScaler_StreamIsActiveServer) error
	GetMetricSpec(context.Context, *ScaledObjectRef) (*GetMetricSpecResponse, error)
	GetMetrics(context.Context, *GetMetricsRequest) (*GetMetricsResponse, error)
	// contains filtered or unexported methods
}

ExternalScalerServer is the server API for ExternalScaler service. All implementations must embed UnimplementedExternalScalerServer for forward compatibility

type ExternalScaler_StreamIsActiveClient 

type ExternalScaler_StreamIsActiveClient interface {
	Recv() (*IsActiveResponse, error)
	grpc.ClientStream
}

type ExternalScaler_StreamIsActiveServer 

type ExternalScaler_StreamIsActiveServer interface {
	Send(*IsActiveResponse) error
	grpc.ServerStream
}

type GetMetricSpecResponse 

type GetMetricSpecResponse struct {
	MetricSpecs []*MetricSpec `protobuf:"bytes,1,rep,name=metricSpecs,proto3" json:"metricSpecs,omitempty"`
	// contains filtered or unexported fields
}

func (*GetMetricSpecResponse) Descriptor deprecated 

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

Deprecated: Use GetMetricSpecResponse.ProtoReflect.Descriptor instead.

func (*GetMetricSpecResponse) GetMetricSpecs 

func (x *GetMetricSpecResponse) GetMetricSpecs() []*MetricSpec

func (*GetMetricSpecResponse) ProtoMessage 

func (*GetMetricSpecResponse) ProtoMessage()

func (*GetMetricSpecResponse) ProtoReflect 

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

func (*GetMetricSpecResponse) Reset 

func (x *GetMetricSpecResponse) Reset()

func (*GetMetricSpecResponse) String 

func (x *GetMetricSpecResponse) String() string

type GetMetricsRequest 

type GetMetricsRequest struct {
	ScaledObjectRef *ScaledObjectRef `protobuf:"bytes,1,opt,name=scaledObjectRef,proto3" json:"scaledObjectRef,omitempty"`
	MetricName      string           `protobuf:"bytes,2,opt,name=metricName,proto3" json:"metricName,omitempty"`
	// contains filtered or unexported fields
}

func (*GetMetricsRequest) Descriptor deprecated 

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

Deprecated: Use GetMetricsRequest.ProtoReflect.Descriptor instead.

func (*GetMetricsRequest) GetMetricName 

func (x *GetMetricsRequest) GetMetricName() string

func (*GetMetricsRequest) GetScaledObjectRef 

func (x *GetMetricsRequest) GetScaledObjectRef() *ScaledObjectRef

func (*GetMetricsRequest) ProtoMessage 

func (*GetMetricsRequest) ProtoMessage()

func (*GetMetricsRequest) ProtoReflect 

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

func (*GetMetricsRequest) Reset 

func (x *GetMetricsRequest) Reset()

func (*GetMetricsRequest) String 

func (x *GetMetricsRequest) String() string

type GetMetricsResponse 

type GetMetricsResponse struct {
	MetricValues []*MetricValue `protobuf:"bytes,1,rep,name=metricValues,proto3" json:"metricValues,omitempty"`
	// contains filtered or unexported fields
}

func (*GetMetricsResponse) Descriptor deprecated 

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

Deprecated: Use GetMetricsResponse.ProtoReflect.Descriptor instead.

func (*GetMetricsResponse) GetMetricValues 

func (x *GetMetricsResponse) GetMetricValues() []*MetricValue

func (*GetMetricsResponse) ProtoMessage 

func (*GetMetricsResponse) ProtoMessage()

func (*GetMetricsResponse) ProtoReflect 

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

func (*GetMetricsResponse) Reset 

func (x *GetMetricsResponse) Reset()

func (*GetMetricsResponse) String 

func (x *GetMetricsResponse) String() string

type IsActiveResponse 

type IsActiveResponse struct {
	Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*IsActiveResponse) Descriptor deprecated 

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

Deprecated: Use IsActiveResponse.ProtoReflect.Descriptor instead.

func (*IsActiveResponse) GetResult 

func (x *IsActiveResponse) GetResult() bool

func (*IsActiveResponse) ProtoMessage 

func (*IsActiveResponse) ProtoMessage()

func (*IsActiveResponse) ProtoReflect 

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

func (*IsActiveResponse) Reset 

func (x *IsActiveResponse) Reset()

func (*IsActiveResponse) String 

func (x *IsActiveResponse) String() string

type MetricSpec 

type MetricSpec struct {
	MetricName string `protobuf:"bytes,1,opt,name=metricName,proto3" json:"metricName,omitempty"`
	TargetSize int64  `protobuf:"varint,2,opt,name=targetSize,proto3" json:"targetSize,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricSpec) Descriptor deprecated 

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

Deprecated: Use MetricSpec.ProtoReflect.Descriptor instead.

func (*MetricSpec) GetMetricName 

func (x *MetricSpec) GetMetricName() string

func (*MetricSpec) GetTargetSize 

func (x *MetricSpec) GetTargetSize() int64

func (*MetricSpec) ProtoMessage 

func (*MetricSpec) ProtoMessage()

func (*MetricSpec) ProtoReflect 

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

func (*MetricSpec) Reset 

func (x *MetricSpec) Reset()

func (*MetricSpec) String 

func (x *MetricSpec) String() string

type MetricValue 

type MetricValue struct {
	MetricName  string `protobuf:"bytes,1,opt,name=metricName,proto3" json:"metricName,omitempty"`
	MetricValue int64  `protobuf:"varint,2,opt,name=metricValue,proto3" json:"metricValue,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricValue) Descriptor deprecated 

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

Deprecated: Use MetricValue.ProtoReflect.Descriptor instead.

func (*MetricValue) GetMetricName 

func (x *MetricValue) GetMetricName() string

func (*MetricValue) GetMetricValue 

func (x *MetricValue) GetMetricValue() int64

func (*MetricValue) ProtoMessage 

func (*MetricValue) ProtoMessage()

func (*MetricValue) ProtoReflect 

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

func (*MetricValue) Reset 

func (x *MetricValue) Reset()

func (*MetricValue) String 

func (x *MetricValue) String() string

type ScaledObjectRef 

type ScaledObjectRef struct {
	Name           string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace      string            `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	ScalerMetadata map[string]string `` /* 169-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ScaledObjectRef) Descriptor deprecated 

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

Deprecated: Use ScaledObjectRef.ProtoReflect.Descriptor instead.

func (*ScaledObjectRef) GetName 

func (x *ScaledObjectRef) GetName() string

func (*ScaledObjectRef) GetNamespace 

func (x *ScaledObjectRef) GetNamespace() string

func (*ScaledObjectRef) GetScalerMetadata 

func (x *ScaledObjectRef) GetScalerMetadata() map[string]string

func (*ScaledObjectRef) ProtoMessage 

func (*ScaledObjectRef) ProtoMessage()

func (*ScaledObjectRef) ProtoReflect 

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

func (*ScaledObjectRef) Reset 

func (x *ScaledObjectRef) Reset()

func (*ScaledObjectRef) String 

func (x *ScaledObjectRef) String() string

type UnimplementedExternalScalerServer 

type UnimplementedExternalScalerServer struct {
}

UnimplementedExternalScalerServer must be embedded to have forward compatible implementations.

func (UnimplementedExternalScalerServer) GetMetricSpec 

func (UnimplementedExternalScalerServer) GetMetricSpec(context.Context, *ScaledObjectRef) (*GetMetricSpecResponse, error)

func (UnimplementedExternalScalerServer) GetMetrics 

func (UnimplementedExternalScalerServer) GetMetrics(context.Context, *GetMetricsRequest) (*GetMetricsResponse, error)

func (UnimplementedExternalScalerServer) IsActive 

func (UnimplementedExternalScalerServer) IsActive(context.Context, *ScaledObjectRef) (*IsActiveResponse, error)

func (UnimplementedExternalScalerServer) StreamIsActive 

func (UnimplementedExternalScalerServer) StreamIsActive(*ScaledObjectRef, ExternalScaler_StreamIsActiveServer) error

type UnsafeExternalScalerServer 

type UnsafeExternalScalerServer interface {
	// contains filtered or unexported methods
}

UnsafeExternalScalerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ExternalScalerServer will result in compilation errors.

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.