Documentation
¶
Index ¶
- func RegisterExternalScalerServer(s *grpc.Server, srv ExternalScalerServer)
- type ExternalScalerClient
- type ExternalScalerServer
- type ExternalScaler_StreamIsActiveClient
- type ExternalScaler_StreamIsActiveServer
- type GetMetricSpecResponse
- func (*GetMetricSpecResponse) Descriptor() ([]byte, []int)
- func (m *GetMetricSpecResponse) GetMetricSpecs() []*MetricSpec
- func (*GetMetricSpecResponse) ProtoMessage()
- func (m *GetMetricSpecResponse) Reset()
- func (m *GetMetricSpecResponse) String() string
- func (m *GetMetricSpecResponse) XXX_DiscardUnknown()
- func (m *GetMetricSpecResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetMetricSpecResponse) XXX_Merge(src proto.Message)
- func (m *GetMetricSpecResponse) XXX_Size() int
- func (m *GetMetricSpecResponse) XXX_Unmarshal(b []byte) error
- type GetMetricsRequest
- func (*GetMetricsRequest) Descriptor() ([]byte, []int)
- func (m *GetMetricsRequest) GetMetricName() string
- func (m *GetMetricsRequest) GetScaledObjectRef() *ScaledObjectRef
- func (*GetMetricsRequest) ProtoMessage()
- func (m *GetMetricsRequest) Reset()
- func (m *GetMetricsRequest) String() string
- func (m *GetMetricsRequest) XXX_DiscardUnknown()
- func (m *GetMetricsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetMetricsRequest) XXX_Merge(src proto.Message)
- func (m *GetMetricsRequest) XXX_Size() int
- func (m *GetMetricsRequest) XXX_Unmarshal(b []byte) error
- type GetMetricsResponse
- func (*GetMetricsResponse) Descriptor() ([]byte, []int)
- func (m *GetMetricsResponse) GetMetricValues() []*MetricValue
- func (*GetMetricsResponse) ProtoMessage()
- func (m *GetMetricsResponse) Reset()
- func (m *GetMetricsResponse) String() string
- func (m *GetMetricsResponse) XXX_DiscardUnknown()
- func (m *GetMetricsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetMetricsResponse) XXX_Merge(src proto.Message)
- func (m *GetMetricsResponse) XXX_Size() int
- func (m *GetMetricsResponse) XXX_Unmarshal(b []byte) error
- type IsActiveResponse
- func (*IsActiveResponse) Descriptor() ([]byte, []int)
- func (m *IsActiveResponse) GetResult() bool
- func (*IsActiveResponse) ProtoMessage()
- func (m *IsActiveResponse) Reset()
- func (m *IsActiveResponse) String() string
- func (m *IsActiveResponse) XXX_DiscardUnknown()
- func (m *IsActiveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IsActiveResponse) XXX_Merge(src proto.Message)
- func (m *IsActiveResponse) XXX_Size() int
- func (m *IsActiveResponse) XXX_Unmarshal(b []byte) error
- type MetricSpec
- func (*MetricSpec) Descriptor() ([]byte, []int)
- func (m *MetricSpec) GetMetricName() string
- func (m *MetricSpec) GetTargetSize() int64
- func (*MetricSpec) ProtoMessage()
- func (m *MetricSpec) Reset()
- func (m *MetricSpec) String() string
- func (m *MetricSpec) XXX_DiscardUnknown()
- func (m *MetricSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MetricSpec) XXX_Merge(src proto.Message)
- func (m *MetricSpec) XXX_Size() int
- func (m *MetricSpec) XXX_Unmarshal(b []byte) error
- type MetricValue
- func (*MetricValue) Descriptor() ([]byte, []int)
- func (m *MetricValue) GetMetricName() string
- func (m *MetricValue) GetMetricValue() int64
- func (*MetricValue) ProtoMessage()
- func (m *MetricValue) Reset()
- func (m *MetricValue) String() string
- func (m *MetricValue) XXX_DiscardUnknown()
- func (m *MetricValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MetricValue) XXX_Merge(src proto.Message)
- func (m *MetricValue) XXX_Size() int
- func (m *MetricValue) XXX_Unmarshal(b []byte) error
- type ScaledObjectRef
- func (*ScaledObjectRef) Descriptor() ([]byte, []int)
- func (m *ScaledObjectRef) GetName() string
- func (m *ScaledObjectRef) GetNamespace() string
- func (m *ScaledObjectRef) GetScalerMetadata() map[string]string
- func (*ScaledObjectRef) ProtoMessage()
- func (m *ScaledObjectRef) Reset()
- func (m *ScaledObjectRef) String() string
- func (m *ScaledObjectRef) XXX_DiscardUnknown()
- func (m *ScaledObjectRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ScaledObjectRef) XXX_Merge(src proto.Message)
- func (m *ScaledObjectRef) XXX_Size() int
- func (m *ScaledObjectRef) XXX_Unmarshal(b []byte) error
- type UnimplementedExternalScalerServer
- func (*UnimplementedExternalScalerServer) GetMetricSpec(ctx context.Context, req *ScaledObjectRef) (*GetMetricSpecResponse, error)
- func (*UnimplementedExternalScalerServer) GetMetrics(ctx context.Context, req *GetMetricsRequest) (*GetMetricsResponse, error)
- func (*UnimplementedExternalScalerServer) IsActive(ctx context.Context, req *ScaledObjectRef) (*IsActiveResponse, error)
- func (*UnimplementedExternalScalerServer) StreamIsActive(req *ScaledObjectRef, srv ExternalScaler_StreamIsActiveServer) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterExternalScalerServer ¶
func RegisterExternalScalerServer(s *grpc.Server, srv ExternalScalerServer)
Types ¶
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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewExternalScalerClient ¶
func NewExternalScalerClient(cc *grpc.ClientConn) 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) }
ExternalScalerServer is the server API for ExternalScaler service.
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetMetricSpecResponse) Descriptor ¶
func (*GetMetricSpecResponse) Descriptor() ([]byte, []int)
func (*GetMetricSpecResponse) GetMetricSpecs ¶
func (m *GetMetricSpecResponse) GetMetricSpecs() []*MetricSpec
func (*GetMetricSpecResponse) ProtoMessage ¶
func (*GetMetricSpecResponse) ProtoMessage()
func (*GetMetricSpecResponse) Reset ¶
func (m *GetMetricSpecResponse) Reset()
func (*GetMetricSpecResponse) String ¶
func (m *GetMetricSpecResponse) String() string
func (*GetMetricSpecResponse) XXX_DiscardUnknown ¶
func (m *GetMetricSpecResponse) XXX_DiscardUnknown()
func (*GetMetricSpecResponse) XXX_Marshal ¶
func (m *GetMetricSpecResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetMetricSpecResponse) XXX_Merge ¶
func (m *GetMetricSpecResponse) XXX_Merge(src proto.Message)
func (*GetMetricSpecResponse) XXX_Size ¶
func (m *GetMetricSpecResponse) XXX_Size() int
func (*GetMetricSpecResponse) XXX_Unmarshal ¶
func (m *GetMetricSpecResponse) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetMetricsRequest) Descriptor ¶
func (*GetMetricsRequest) Descriptor() ([]byte, []int)
func (*GetMetricsRequest) GetMetricName ¶
func (m *GetMetricsRequest) GetMetricName() string
func (*GetMetricsRequest) GetScaledObjectRef ¶
func (m *GetMetricsRequest) GetScaledObjectRef() *ScaledObjectRef
func (*GetMetricsRequest) ProtoMessage ¶
func (*GetMetricsRequest) ProtoMessage()
func (*GetMetricsRequest) Reset ¶
func (m *GetMetricsRequest) Reset()
func (*GetMetricsRequest) String ¶
func (m *GetMetricsRequest) String() string
func (*GetMetricsRequest) XXX_DiscardUnknown ¶
func (m *GetMetricsRequest) XXX_DiscardUnknown()
func (*GetMetricsRequest) XXX_Marshal ¶
func (m *GetMetricsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetMetricsRequest) XXX_Merge ¶
func (m *GetMetricsRequest) XXX_Merge(src proto.Message)
func (*GetMetricsRequest) XXX_Size ¶
func (m *GetMetricsRequest) XXX_Size() int
func (*GetMetricsRequest) XXX_Unmarshal ¶
func (m *GetMetricsRequest) XXX_Unmarshal(b []byte) error
type GetMetricsResponse ¶
type GetMetricsResponse struct { MetricValues []*MetricValue `protobuf:"bytes,1,rep,name=metricValues,proto3" json:"metricValues,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetMetricsResponse) Descriptor ¶
func (*GetMetricsResponse) Descriptor() ([]byte, []int)
func (*GetMetricsResponse) GetMetricValues ¶
func (m *GetMetricsResponse) GetMetricValues() []*MetricValue
func (*GetMetricsResponse) ProtoMessage ¶
func (*GetMetricsResponse) ProtoMessage()
func (*GetMetricsResponse) Reset ¶
func (m *GetMetricsResponse) Reset()
func (*GetMetricsResponse) String ¶
func (m *GetMetricsResponse) String() string
func (*GetMetricsResponse) XXX_DiscardUnknown ¶
func (m *GetMetricsResponse) XXX_DiscardUnknown()
func (*GetMetricsResponse) XXX_Marshal ¶
func (m *GetMetricsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetMetricsResponse) XXX_Merge ¶
func (m *GetMetricsResponse) XXX_Merge(src proto.Message)
func (*GetMetricsResponse) XXX_Size ¶
func (m *GetMetricsResponse) XXX_Size() int
func (*GetMetricsResponse) XXX_Unmarshal ¶
func (m *GetMetricsResponse) XXX_Unmarshal(b []byte) error
type IsActiveResponse ¶
type IsActiveResponse struct { Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*IsActiveResponse) Descriptor ¶
func (*IsActiveResponse) Descriptor() ([]byte, []int)
func (*IsActiveResponse) GetResult ¶
func (m *IsActiveResponse) GetResult() bool
func (*IsActiveResponse) ProtoMessage ¶
func (*IsActiveResponse) ProtoMessage()
func (*IsActiveResponse) Reset ¶
func (m *IsActiveResponse) Reset()
func (*IsActiveResponse) String ¶
func (m *IsActiveResponse) String() string
func (*IsActiveResponse) XXX_DiscardUnknown ¶
func (m *IsActiveResponse) XXX_DiscardUnknown()
func (*IsActiveResponse) XXX_Marshal ¶
func (m *IsActiveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*IsActiveResponse) XXX_Merge ¶
func (m *IsActiveResponse) XXX_Merge(src proto.Message)
func (*IsActiveResponse) XXX_Size ¶
func (m *IsActiveResponse) XXX_Size() int
func (*IsActiveResponse) XXX_Unmarshal ¶
func (m *IsActiveResponse) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*MetricSpec) Descriptor ¶
func (*MetricSpec) Descriptor() ([]byte, []int)
func (*MetricSpec) GetMetricName ¶
func (m *MetricSpec) GetMetricName() string
func (*MetricSpec) GetTargetSize ¶
func (m *MetricSpec) GetTargetSize() int64
func (*MetricSpec) ProtoMessage ¶
func (*MetricSpec) ProtoMessage()
func (*MetricSpec) Reset ¶
func (m *MetricSpec) Reset()
func (*MetricSpec) String ¶
func (m *MetricSpec) String() string
func (*MetricSpec) XXX_DiscardUnknown ¶
func (m *MetricSpec) XXX_DiscardUnknown()
func (*MetricSpec) XXX_Marshal ¶
func (m *MetricSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MetricSpec) XXX_Merge ¶
func (m *MetricSpec) XXX_Merge(src proto.Message)
func (*MetricSpec) XXX_Size ¶
func (m *MetricSpec) XXX_Size() int
func (*MetricSpec) XXX_Unmarshal ¶
func (m *MetricSpec) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*MetricValue) Descriptor ¶
func (*MetricValue) Descriptor() ([]byte, []int)
func (*MetricValue) GetMetricName ¶
func (m *MetricValue) GetMetricName() string
func (*MetricValue) GetMetricValue ¶
func (m *MetricValue) GetMetricValue() int64
func (*MetricValue) ProtoMessage ¶
func (*MetricValue) ProtoMessage()
func (*MetricValue) Reset ¶
func (m *MetricValue) Reset()
func (*MetricValue) String ¶
func (m *MetricValue) String() string
func (*MetricValue) XXX_DiscardUnknown ¶
func (m *MetricValue) XXX_DiscardUnknown()
func (*MetricValue) XXX_Marshal ¶
func (m *MetricValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MetricValue) XXX_Merge ¶
func (m *MetricValue) XXX_Merge(src proto.Message)
func (*MetricValue) XXX_Size ¶
func (m *MetricValue) XXX_Size() int
func (*MetricValue) XXX_Unmarshal ¶
func (m *MetricValue) XXX_Unmarshal(b []byte) error
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 */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ScaledObjectRef) Descriptor ¶
func (*ScaledObjectRef) Descriptor() ([]byte, []int)
func (*ScaledObjectRef) GetName ¶
func (m *ScaledObjectRef) GetName() string
func (*ScaledObjectRef) GetNamespace ¶
func (m *ScaledObjectRef) GetNamespace() string
func (*ScaledObjectRef) GetScalerMetadata ¶
func (m *ScaledObjectRef) GetScalerMetadata() map[string]string
func (*ScaledObjectRef) ProtoMessage ¶
func (*ScaledObjectRef) ProtoMessage()
func (*ScaledObjectRef) Reset ¶
func (m *ScaledObjectRef) Reset()
func (*ScaledObjectRef) String ¶
func (m *ScaledObjectRef) String() string
func (*ScaledObjectRef) XXX_DiscardUnknown ¶
func (m *ScaledObjectRef) XXX_DiscardUnknown()
func (*ScaledObjectRef) XXX_Marshal ¶
func (m *ScaledObjectRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ScaledObjectRef) XXX_Merge ¶
func (m *ScaledObjectRef) XXX_Merge(src proto.Message)
func (*ScaledObjectRef) XXX_Size ¶
func (m *ScaledObjectRef) XXX_Size() int
func (*ScaledObjectRef) XXX_Unmarshal ¶
func (m *ScaledObjectRef) XXX_Unmarshal(b []byte) error
type UnimplementedExternalScalerServer ¶
type UnimplementedExternalScalerServer struct { }
UnimplementedExternalScalerServer can be embedded to have forward compatible implementations.
func (*UnimplementedExternalScalerServer) GetMetricSpec ¶
func (*UnimplementedExternalScalerServer) GetMetricSpec(ctx context.Context, req *ScaledObjectRef) (*GetMetricSpecResponse, error)
func (*UnimplementedExternalScalerServer) GetMetrics ¶
func (*UnimplementedExternalScalerServer) GetMetrics(ctx context.Context, req *GetMetricsRequest) (*GetMetricsResponse, error)
func (*UnimplementedExternalScalerServer) IsActive ¶
func (*UnimplementedExternalScalerServer) IsActive(ctx context.Context, req *ScaledObjectRef) (*IsActiveResponse, error)
func (*UnimplementedExternalScalerServer) StreamIsActive ¶
func (*UnimplementedExternalScalerServer) StreamIsActive(req *ScaledObjectRef, srv ExternalScaler_StreamIsActiveServer) error
Click to show internal directories.
Click to hide internal directories.