package v1beta2

import "k8s.io/kubernetes/pkg/kubelet/pluginmanager/pluginwatcher/example_plugin_apis/v1beta2"

Index ¶

• Constants
• Variables
• func RegisterExampleServer(s grpc.ServiceRegistrar, srv ExampleServer)
• type ExampleClient
• func NewExampleClient(cc grpc.ClientConnInterface) ExampleClient
• type ExampleRequest
• func (*ExampleRequest) Descriptor() ([]byte, []int)
• func (x *ExampleRequest) GetRequest() string
• func (x *ExampleRequest) GetV1Beta2Field() string
• func (*ExampleRequest) ProtoMessage()
• func (x *ExampleRequest) ProtoReflect() protoreflect.Message
• func (x *ExampleRequest) Reset()
• func (x *ExampleRequest) String() string
• type ExampleResponse
• func (*ExampleResponse) Descriptor() ([]byte, []int)
• func (x *ExampleResponse) GetError() string
• func (*ExampleResponse) ProtoMessage()
• func (x *ExampleResponse) ProtoReflect() protoreflect.Message
• func (x *ExampleResponse) Reset()
• func (x *ExampleResponse) String() string
• type ExampleServer
• type UnimplementedExampleServer
• func (UnimplementedExampleServer) GetExampleInfo(context.Context, *ExampleRequest) (*ExampleResponse, error)
• type UnsafeExampleServer

Constants ¶

const (
	Example_GetExampleInfo_FullMethodName = "/v1beta2.Example/GetExampleInfo"
)

Variables ¶

var Example_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v1beta2.Example",
	HandlerType: (*ExampleServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetExampleInfo",
			Handler:    _Example_GetExampleInfo_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/kubelet/pluginmanager/pluginwatcher/example_plugin_apis/v1beta2/api.proto",
}

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

var File_pkg_kubelet_pluginmanager_pluginwatcher_example_plugin_apis_v1beta2_api_proto protoreflect.FileDescriptor

Functions ¶

func RegisterExampleServer ¶

func RegisterExampleServer(s grpc.ServiceRegistrar, srv ExampleServer)

Types ¶

type ExampleClient ¶

type ExampleClient interface {
	GetExampleInfo(ctx context.Context, in *ExampleRequest, opts ...grpc.CallOption) (*ExampleResponse, error)
}

ExampleClient is the client API for Example 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.

Example is a simple example service for general reference on the recommended kubelet plugin model and plugin watcher testing.

func NewExampleClient ¶

func NewExampleClient(cc grpc.ClientConnInterface) ExampleClient

type ExampleRequest ¶

type ExampleRequest struct {
	Request      string `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	V1Beta2Field string `protobuf:"bytes,2,opt,name=v1beta2_field,json=v1beta2Field,proto3" json:"v1beta2_field,omitempty"`
	// contains filtered or unexported fields
}

Renames a field from v1beta1 ExampleRequest.

func (*ExampleRequest) Descriptor ¶

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

Deprecated: Use ExampleRequest.ProtoReflect.Descriptor instead.

func (*ExampleRequest) GetRequest ¶

func (x *ExampleRequest) GetRequest() string

func (*ExampleRequest) GetV1Beta2Field ¶

func (x *ExampleRequest) GetV1Beta2Field() string

func (*ExampleRequest) ProtoMessage ¶

func (*ExampleRequest) ProtoMessage()

func (*ExampleRequest) ProtoReflect ¶

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

func (*ExampleRequest) Reset ¶

func (x *ExampleRequest) Reset()

func (*ExampleRequest) String ¶

func (x *ExampleRequest) String() string

type ExampleResponse ¶

type ExampleResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ExampleResponse) Descriptor ¶

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

Deprecated: Use ExampleResponse.ProtoReflect.Descriptor instead.

func (*ExampleResponse) GetError ¶

func (x *ExampleResponse) GetError() string

func (*ExampleResponse) ProtoMessage ¶

func (*ExampleResponse) ProtoMessage()

func (*ExampleResponse) ProtoReflect ¶

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

func (*ExampleResponse) Reset ¶

func (x *ExampleResponse) Reset()

func (*ExampleResponse) String ¶

func (x *ExampleResponse) String() string

type ExampleServer ¶

type ExampleServer interface {
	GetExampleInfo(context.Context, *ExampleRequest) (*ExampleResponse, error)
	// contains filtered or unexported methods
}

ExampleServer is the server API for Example service. All implementations must embed UnimplementedExampleServer for forward compatibility.

Example is a simple example service for general reference on the recommended kubelet plugin model and plugin watcher testing.

type UnimplementedExampleServer ¶

type UnimplementedExampleServer struct{}

UnimplementedExampleServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedExampleServer) GetExampleInfo ¶

func (UnimplementedExampleServer) GetExampleInfo(context.Context, *ExampleRequest) (*ExampleResponse, error)

type UnsafeExampleServer ¶

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

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

Source Files ¶

api.pb.go api_grpc.pb.go