testplugin

Documentation

Index

• type Server
  • func New() *Server
  • func (s *Server) Capabilities(_ context.Context, _ *pluginv1alpha.CapabilitiesRequest) (*pluginv1alpha.CapabilitiesResponse, error)
  • func (s *Server) Cleanup()
  • func (s *Server) CopyIn(...) error
  • func (s *Server) CopyOut(req *pluginv1alpha.CopyOutRequest, ...) error
  • func (s *Server) Create(_ context.Context, req *pluginv1alpha.CreateRequest) (*pluginv1alpha.CreateResponse, error)
  • func (s *Server) Exec(req *pluginv1alpha.ExecRequest, ...) error
  • func (s *Server) Register(grpcServer *grpc.Server)
  • func (s *Server) Remove(_ context.Context, req *pluginv1alpha.RemoveRequest) (*pluginv1alpha.RemoveResponse, error)
  • func (s *Server) Start(req *pluginv1alpha.StartRequest, ...) error

Types

type Server

type Server struct {
	pluginv1alpha.UnimplementedBackendPluginServer
	// contains filtered or unexported fields
}

func New

func New() *Server

func (*Server) Capabilities

func (s *Server) Capabilities(_ context.Context, _ *pluginv1alpha.CapabilitiesRequest) (*pluginv1alpha.CapabilitiesResponse, error)

func (*Server) Cleanup

func (s *Server) Cleanup()

func (*Server) CopyIn

func (s *Server) CopyIn(stream grpc.ClientStreamingServer[pluginv1alpha.CopyInChunk, pluginv1alpha.CopyInResponse]) error

func (*Server) CopyOut

func (s *Server) CopyOut(req *pluginv1alpha.CopyOutRequest, stream grpc.ServerStreamingServer[pluginv1alpha.CopyOutChunk]) error

func (*Server) Create

func (s *Server) Create(_ context.Context, req *pluginv1alpha.CreateRequest) (*pluginv1alpha.CreateResponse, error)

func (*Server) Exec

func (s *Server) Exec(req *pluginv1alpha.ExecRequest, stream grpc.ServerStreamingServer[pluginv1alpha.ExecOutput]) error

func (*Server) Register

func (s *Server) Register(grpcServer *grpc.Server)

Register wires this server plus a SERVING grpc.health.v1 onto grpcServer.

func (*Server) Remove

func (s *Server) Remove(_ context.Context, req *pluginv1alpha.RemoveRequest) (*pluginv1alpha.RemoveResponse, error)

func (*Server) Start

func (s *Server) Start(req *pluginv1alpha.StartRequest, stream grpc.ServerStreamingServer[pluginv1alpha.StartOutput]) error