server

Documentation

Index

• type Server
  • func New(manager *connections.Manager) *Server
  • func (s *Server) Callback(cbs pb.SqliteOG_CallbackServer) error
  • func (s *Server) Close(ctx context.Context, in *pb.ConnectionId) (*pb.Empty, error)
  • func (s *Server) Connection(ctx context.Context, in *pb.ConnectionRequest) (*pb.ConnectionId, error)
  • func (s *Server) Execute(ctx context.Context, in *pb.Statement) (*pb.ExecuteResult, error)
  • func (s *Server) ExecuteOrQuery(ctx context.Context, in *pb.Statement) (*pb.ExecuteOrQueryResult, error)
  • func (s *Server) IsValid(ctx context.Context, in *pb.ConnectionId) (*pb.Empty, error)
  • func (s *Server) Ping(ctx context.Context, _ *pb.Empty) (*pb.Empty, error)
  • func (s *Server) Query(ctx context.Context, in *pb.Statement) (*pb.QueryResult, error)
  • func (s *Server) ResetSession(ctx context.Context, in *pb.ConnectionId) (*pb.ConnectionId, error)

Types

type Server

type Server struct {
	pb.UnimplementedSqliteOGServer
	Manager *connections.Manager
}

func New

func New(manager *connections.Manager) *Server

func (*Server) Callback

func (s *Server) Callback(cbs pb.SqliteOG_CallbackServer) error

func (*Server) Close

func (s *Server) Close(ctx context.Context, in *pb.ConnectionId) (*pb.Empty, error)

func (*Server) Connection

func (s *Server) Connection(ctx context.Context, in *pb.ConnectionRequest) (*pb.ConnectionId, error)

func (*Server) Execute

func (s *Server) Execute(ctx context.Context, in *pb.Statement) (*pb.ExecuteResult, error)

func (*Server) ExecuteOrQuery

func (s *Server) ExecuteOrQuery(ctx context.Context, in *pb.Statement) (*pb.ExecuteOrQueryResult, error)

func (*Server) IsValid

func (s *Server) IsValid(ctx context.Context, in *pb.ConnectionId) (*pb.Empty, error)

func (*Server) Ping

func (s *Server) Ping(ctx context.Context, _ *pb.Empty) (*pb.Empty, error)

func (*Server) Query

func (s *Server) Query(ctx context.Context, in *pb.Statement) (*pb.QueryResult, error)

func (*Server) ResetSession

func (s *Server) ResetSession(ctx context.Context, in *pb.ConnectionId) (*pb.ConnectionId, error)