grpc

Documentation

Index

• func RegisterGRPCBeeHandler(s *grpc.Server)
• type Server
  • func NewServer() *Server
  • func (s *Server) Execute(stream pb.RemoteRPC_ExecuteServer) error
  • func (s *Server) Get(req *pb.GetRequest, stream pb.RemoteRPC_GetServer) error
  • func (s *Server) Put(stream pb.RemoteRPC_PutServer) error
  • func (s *Server) Stat(ctx context.Context, req *pb.StatRequest) (*pb.StatResponse, error)

Functions

func RegisterGRPCBeeHandler

func RegisterGRPCBeeHandler(s *grpc.Server)

Types

type Server

type Server struct{}

func NewServer

func NewServer() *Server

func (*Server) Execute

func (s *Server) Execute(stream pb.RemoteRPC_ExecuteServer) error

func (*Server) Get

func (s *Server) Get(req *pb.GetRequest, stream pb.RemoteRPC_GetServer) error

func (*Server) Put

func (s *Server) Put(stream pb.RemoteRPC_PutServer) error

func (*Server) Stat

func (s *Server) Stat(ctx context.Context, req *pb.StatRequest) (*pb.StatResponse, error)