proto

Documentation

Index

• Variables
• func RegisterTargetPluginServiceServer(s *grpc.Server, srv TargetPluginServiceServer)
• type ScaleRequest
  • func (*ScaleRequest) Descriptor() ([]byte, []int)
  • func (x *ScaleRequest) GetAction() *v1.ScalingAction
  • func (x *ScaleRequest) GetConfig() map[string]string
  • func (*ScaleRequest) ProtoMessage()
  • func (x *ScaleRequest) ProtoReflect() protoreflect.Message
  • func (x *ScaleRequest) Reset()
  • func (x *ScaleRequest) String() string
• type ScaleResponse
  • func (*ScaleResponse) Descriptor() ([]byte, []int)
  • func (*ScaleResponse) ProtoMessage()
  • func (x *ScaleResponse) ProtoReflect() protoreflect.Message
  • func (x *ScaleResponse) Reset()
  • func (x *ScaleResponse) String() string
• type StatusRequest
  • func (*StatusRequest) Descriptor() ([]byte, []int)
  • func (x *StatusRequest) GetConfig() map[string]string
  • func (*StatusRequest) ProtoMessage()
  • func (x *StatusRequest) ProtoReflect() protoreflect.Message
  • func (x *StatusRequest) Reset()
  • func (x *StatusRequest) String() string
• type StatusResponse
  • func (*StatusResponse) Descriptor() ([]byte, []int)
  • func (x *StatusResponse) GetCount() int64
  • func (x *StatusResponse) GetMeta() map[string]string
  • func (x *StatusResponse) GetReady() bool
  • func (*StatusResponse) ProtoMessage()
  • func (x *StatusResponse) ProtoReflect() protoreflect.Message
  • func (x *StatusResponse) Reset()
  • func (x *StatusResponse) String() string
• type TargetPluginServiceClient
  • func NewTargetPluginServiceClient(cc grpc.ClientConnInterface) TargetPluginServiceClient
• type TargetPluginServiceServer
• type UnimplementedTargetPluginServiceServer
  • func (*UnimplementedTargetPluginServiceServer) Scale(context.Context, *ScaleRequest) (*ScaleResponse, error)
  • func (*UnimplementedTargetPluginServiceServer) Status(context.Context, *StatusRequest) (*StatusResponse, error)

Variables

var File_plugins_target_proto_v1_target_proto protoreflect.FileDescriptor

Functions

func RegisterTargetPluginServiceServer

func RegisterTargetPluginServiceServer(s *grpc.Server, srv TargetPluginServiceServer)

Types

type ScaleRequest

type ScaleRequest struct {
	Action *v1.ScalingAction `protobuf:"bytes,1,opt,name=action,proto3" json:"action,omitempty"`
	Config map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ScaleRequest) Descriptor

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

Deprecated: Use ScaleRequest.ProtoReflect.Descriptor instead.

func (*ScaleRequest) GetAction

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

func (*ScaleRequest) GetConfig

func (x *ScaleRequest) GetConfig() map[string]string

func (*ScaleRequest) ProtoMessage

func (*ScaleRequest) ProtoMessage()

func (*ScaleRequest) ProtoReflect

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

func (*ScaleRequest) Reset

func (x *ScaleRequest) Reset()

func (*ScaleRequest) String

func (x *ScaleRequest) String() string

type ScaleResponse

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

func (*ScaleResponse) Descriptor

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

Deprecated: Use ScaleResponse.ProtoReflect.Descriptor instead.

func (*ScaleResponse) ProtoMessage

func (*ScaleResponse) ProtoMessage()

func (*ScaleResponse) ProtoReflect

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

func (*ScaleResponse) Reset

func (x *ScaleResponse) Reset()

func (*ScaleResponse) String

func (x *ScaleResponse) String() string

type StatusRequest

type StatusRequest struct {
	Config map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StatusRequest) Descriptor

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

Deprecated: Use StatusRequest.ProtoReflect.Descriptor instead.

func (*StatusRequest) GetConfig

func (x *StatusRequest) GetConfig() map[string]string

func (*StatusRequest) ProtoMessage

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) ProtoReflect

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

func (*StatusRequest) Reset

func (x *StatusRequest) Reset()

func (*StatusRequest) String

func (x *StatusRequest) String() string

type StatusResponse

type StatusResponse struct {
	Ready bool              `protobuf:"varint,1,opt,name=ready,proto3" json:"ready,omitempty"`
	Count int64             `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	Meta  map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StatusResponse) Descriptor

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

Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.

func (*StatusResponse) GetCount

func (x *StatusResponse) GetCount() int64

func (*StatusResponse) GetMeta

func (x *StatusResponse) GetMeta() map[string]string

func (*StatusResponse) GetReady

func (x *StatusResponse) GetReady() bool

func (*StatusResponse) ProtoMessage

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) ProtoReflect

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

func (*StatusResponse) Reset

func (x *StatusResponse) Reset()

func (*StatusResponse) String

func (x *StatusResponse) String() string

type TargetPluginServiceClient

type TargetPluginServiceClient interface {
	Scale(ctx context.Context, in *ScaleRequest, opts ...grpc.CallOption) (*ScaleResponse, error)
	Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
}

TargetPluginServiceClient is the client API for TargetPluginService service.

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

func NewTargetPluginServiceClient

func NewTargetPluginServiceClient(cc grpc.ClientConnInterface) TargetPluginServiceClient

type TargetPluginServiceServer

type TargetPluginServiceServer interface {
	Scale(context.Context, *ScaleRequest) (*ScaleResponse, error)
	Status(context.Context, *StatusRequest) (*StatusResponse, error)
}

TargetPluginServiceServer is the server API for TargetPluginService service.

type UnimplementedTargetPluginServiceServer

type UnimplementedTargetPluginServiceServer struct {
}

UnimplementedTargetPluginServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedTargetPluginServiceServer) Scale

func (*UnimplementedTargetPluginServiceServer) Scale(context.Context, *ScaleRequest) (*ScaleResponse, error)

func (*UnimplementedTargetPluginServiceServer) Status

func (*UnimplementedTargetPluginServiceServer) Status(context.Context, *StatusRequest) (*StatusResponse, error)