grpc

Documentation

Index

• type Client
  • func NewClient(address string, session *frames.Session, logger logger.Logger) (*Client, error)
  • func (c *Client) Create(request *pb.CreateRequest) error
  • func (c *Client) Delete(request *pb.DeleteRequest) error
  • func (c *Client) Exec(request *pb.ExecRequest) (frames.Frame, error)
  • func (c *Client) Read(request *pb.ReadRequest) (frames.FrameIterator, error)
  • func (c *Client) Write(request *frames.WriteRequest) (frames.FrameAppender, error)
• type Server
  • func NewServer(config *frames.Config, addr string, logger logger.Logger) (*Server, error)
  • func (s *Server) Create(ctx context.Context, req *pb.CreateRequest) (*pb.CreateResponse, error)
  • func (s *Server) Delete(ctx context.Context, req *pb.DeleteRequest) (*pb.DeleteResponse, error)
  • func (s *Server) Exec(ctx context.Context, req *pb.ExecRequest) (*pb.ExecResponse, error)
  • func (s *Server) Read(request *pb.ReadRequest, stream pb.Frames_ReadServer) error
  • func (s *Server) Start() error
  • func (s *Server) Write(stream pb.Frames_WriteServer) error

Types

type Client

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

Client is frames gRPC client

func NewClient

func NewClient(address string, session *frames.Session, logger logger.Logger) (*Client, error)

NewClient returns a new gRPC client

func (*Client) Create

func (c *Client) Create(request *pb.CreateRequest) error

Create creates a table

func (*Client) Delete

func (c *Client) Delete(request *pb.DeleteRequest) error

Delete deletes data or table

func (*Client) Exec

func (c *Client) Exec(request *pb.ExecRequest) (frames.Frame, error)

Exec executes a command on the backend

func (*Client) Read

func (c *Client) Read(request *pb.ReadRequest) (frames.FrameIterator, error)

func (*Client) Write

func (c *Client) Write(request *frames.WriteRequest) (frames.FrameAppender, error)

type Server

type Server struct {
	frames.ServerBase
	// contains filtered or unexported fields
}

Server is a frames gRPC server

func NewServer

func NewServer(config *frames.Config, addr string, logger logger.Logger) (*Server, error)

NewServer returns a new gRPC server

func (*Server) Create

func (s *Server) Create(ctx context.Context, req *pb.CreateRequest) (*pb.CreateResponse, error)

Create creates a table

func (*Server) Delete

func (s *Server) Delete(ctx context.Context, req *pb.DeleteRequest) (*pb.DeleteResponse, error)

Delete deletes a table

func (*Server) Exec

func (s *Server) Exec(ctx context.Context, req *pb.ExecRequest) (*pb.ExecResponse, error)

Exec executes a command

func (*Server) Read

func (s *Server) Read(request *pb.ReadRequest, stream pb.Frames_ReadServer) error

func (*Server) Start

func (s *Server) Start() error

Start starts the server

func (*Server) Write

func (s *Server) Write(stream pb.Frames_WriteServer) error

Write write data to table