Documentation
¶
Index ¶
- type Client
- 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 (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) History(request *pb.HistoryRequest, stream pb.Frames_HistoryServer) error
- func (s *Server) Read(request *pb.ReadRequest, stream pb.Frames_ReadServer) error
- func (s *Server) Start() error
- func (s *Server) Version(ctx context.Context, _ *pb.VersionRequest) (*pb.VersionResponse, error)
- func (s *Server) Write(stream pb.Frames_WriteServer) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client is frames 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) 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, historyServer *utils.HistoryServer, version string) (*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) History ¶ added in v0.7.6
func (s *Server) History(request *pb.HistoryRequest, stream pb.Frames_HistoryServer) error
History returns framesd history logs
func (*Server) Read ¶
func (s *Server) Read(request *pb.ReadRequest, stream pb.Frames_ReadServer) error
func (*Server) Version ¶ added in v0.8.6
func (s *Server) Version(ctx context.Context, _ *pb.VersionRequest) (*pb.VersionResponse, error)
Version return server version
Source Files
Click to show internal directories.
Click to hide internal directories.