k8s

Documentation

Index

• Variables
• func RegisterK8SCaptureServiceServer(s grpc.ServiceRegistrar, srv K8SCaptureServiceServer)
• type K8SCaptureServiceClient
  • func NewK8SCaptureServiceClient(cc grpc.ClientConnInterface) K8SCaptureServiceClient
• type K8SCaptureServiceServer
• type K8SCaptureService_CaptureClient
• type K8SCaptureService_CaptureServer
• type UnimplementedK8SCaptureServiceServer
  • func (UnimplementedK8SCaptureServiceServer) Capture(*types.K8SCapture, K8SCaptureService_CaptureServer) error
• type UnsafeK8SCaptureServiceServer

Variables

var File_services_k8s_k8s_proto protoreflect.FileDescriptor

var K8SCaptureService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "service.K8sCaptureService",
	HandlerType: (*K8SCaptureServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Capture",
			Handler:       _K8SCaptureService_Capture_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "services/k8s/k8s.proto",
}

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

Functions

func RegisterK8SCaptureServiceServer

func RegisterK8SCaptureServiceServer(s grpc.ServiceRegistrar, srv K8SCaptureServiceServer)

Types

type K8SCaptureServiceClient

type K8SCaptureServiceClient interface {
	Capture(ctx context.Context, in *types.K8SCapture, opts ...grpc.CallOption) (K8SCaptureService_CaptureClient, error)
}

K8SCaptureServiceClient is the client API for K8SCaptureService 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 NewK8SCaptureServiceClient

func NewK8SCaptureServiceClient(cc grpc.ClientConnInterface) K8SCaptureServiceClient

type K8SCaptureServiceServer

type K8SCaptureServiceServer interface {
	Capture(*types.K8SCapture, K8SCaptureService_CaptureServer) error
	// contains filtered or unexported methods
}

K8SCaptureServiceServer is the server API for K8SCaptureService service. All implementations must embed UnimplementedK8SCaptureServiceServer for forward compatibility

type K8SCaptureService_CaptureClient

type K8SCaptureService_CaptureClient interface {
	Recv() (*types.Packet, error)
	grpc.ClientStream
}

type K8SCaptureService_CaptureServer

type K8SCaptureService_CaptureServer interface {
	Send(*types.Packet) error
	grpc.ServerStream
}

type UnimplementedK8SCaptureServiceServer

type UnimplementedK8SCaptureServiceServer struct {
}

UnimplementedK8SCaptureServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedK8SCaptureServiceServer) Capture

func (UnimplementedK8SCaptureServiceServer) Capture(*types.K8SCapture, K8SCaptureService_CaptureServer) error

type UnsafeK8SCaptureServiceServer

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

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