proto

Documentation

Index

• Variables
• func RegisterStrategyPluginServiceServer(s *grpc.Server, srv StrategyPluginServiceServer)
• type RunRequest
  • func (*RunRequest) Descriptor() ([]byte, []int)
  • func (x *RunRequest) GetAction() *v1.ScalingAction
  • func (x *RunRequest) GetCheck() *v1.ScalingPolicyCheck
  • func (x *RunRequest) GetCount() int64
  • func (x *RunRequest) GetTimestampedMetric() []*v1.TimestampedMetric
  • func (*RunRequest) ProtoMessage()
  • func (x *RunRequest) ProtoReflect() protoreflect.Message
  • func (x *RunRequest) Reset()
  • func (x *RunRequest) String() string
• type RunResponse
  • func (*RunResponse) Descriptor() ([]byte, []int)
  • func (x *RunResponse) GetAction() *v1.ScalingAction
  • func (x *RunResponse) GetCheck() *v1.ScalingPolicyCheck
  • func (x *RunResponse) GetTimestampedMetric() []*v1.TimestampedMetric
  • func (*RunResponse) ProtoMessage()
  • func (x *RunResponse) ProtoReflect() protoreflect.Message
  • func (x *RunResponse) Reset()
  • func (x *RunResponse) String() string
• type StrategyPluginServiceClient
  • func NewStrategyPluginServiceClient(cc grpc.ClientConnInterface) StrategyPluginServiceClient
• type StrategyPluginServiceServer
• type UnimplementedStrategyPluginServiceServer
  • func (*UnimplementedStrategyPluginServiceServer) Run(context.Context, *RunRequest) (*RunResponse, error)

Variables

var File_plugins_strategy_proto_v1_strategy_proto protoreflect.FileDescriptor

Functions

func RegisterStrategyPluginServiceServer

func RegisterStrategyPluginServiceServer(s *grpc.Server, srv StrategyPluginServiceServer)

Types

type RunRequest

type RunRequest struct {
	Action            *v1.ScalingAction       `protobuf:"bytes,1,opt,name=action,proto3" json:"action,omitempty"`
	Check             *v1.ScalingPolicyCheck  `protobuf:"bytes,2,opt,name=check,proto3" json:"check,omitempty"`
	TimestampedMetric []*v1.TimestampedMetric `protobuf:"bytes,3,rep,name=timestamped_metric,json=timestampedMetric,proto3" json:"timestamped_metric,omitempty"`
	Count             int64                   `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*RunRequest) Descriptor

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

Deprecated: Use RunRequest.ProtoReflect.Descriptor instead.

func (*RunRequest) GetAction

func (x *RunRequest) GetAction() *v1.ScalingAction

func (*RunRequest) GetCheck

func (x *RunRequest) GetCheck() *v1.ScalingPolicyCheck

func (*RunRequest) GetCount

func (x *RunRequest) GetCount() int64

func (*RunRequest) GetTimestampedMetric

func (x *RunRequest) GetTimestampedMetric() []*v1.TimestampedMetric

func (*RunRequest) ProtoMessage

func (*RunRequest) ProtoMessage()

func (*RunRequest) ProtoReflect

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

func (*RunRequest) Reset

func (x *RunRequest) Reset()

func (*RunRequest) String

func (x *RunRequest) String() string

type RunResponse

type RunResponse struct {
	Action            *v1.ScalingAction       `protobuf:"bytes,1,opt,name=action,proto3" json:"action,omitempty"`
	Check             *v1.ScalingPolicyCheck  `protobuf:"bytes,2,opt,name=check,proto3" json:"check,omitempty"`
	TimestampedMetric []*v1.TimestampedMetric `protobuf:"bytes,3,rep,name=timestamped_metric,json=timestampedMetric,proto3" json:"timestamped_metric,omitempty"`
	// contains filtered or unexported fields
}

func (*RunResponse) Descriptor

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

Deprecated: Use RunResponse.ProtoReflect.Descriptor instead.

func (*RunResponse) GetAction

func (x *RunResponse) GetAction() *v1.ScalingAction

func (*RunResponse) GetCheck

func (x *RunResponse) GetCheck() *v1.ScalingPolicyCheck

func (*RunResponse) GetTimestampedMetric

func (x *RunResponse) GetTimestampedMetric() []*v1.TimestampedMetric

func (*RunResponse) ProtoMessage

func (*RunResponse) ProtoMessage()

func (*RunResponse) ProtoReflect

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

func (*RunResponse) Reset

func (x *RunResponse) Reset()

func (*RunResponse) String

func (x *RunResponse) String() string

type StrategyPluginServiceClient

type StrategyPluginServiceClient interface {
	Run(ctx context.Context, in *RunRequest, opts ...grpc.CallOption) (*RunResponse, error)
}

StrategyPluginServiceClient is the client API for StrategyPluginService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewStrategyPluginServiceClient

func NewStrategyPluginServiceClient(cc grpc.ClientConnInterface) StrategyPluginServiceClient

type StrategyPluginServiceServer

type StrategyPluginServiceServer interface {
	Run(context.Context, *RunRequest) (*RunResponse, error)
}

StrategyPluginServiceServer is the server API for StrategyPluginService service.

type UnimplementedStrategyPluginServiceServer

type UnimplementedStrategyPluginServiceServer struct {
}

UnimplementedStrategyPluginServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedStrategyPluginServiceServer) Run

func (*UnimplementedStrategyPluginServiceServer) Run(context.Context, *RunRequest) (*RunResponse, error)