Lines Matching defs:server

92 type server struct {  struct
93 	logf Logger
95 	db    database
96 	start time.Time
98 	mu       sync.Mutex
99 	sessions map[string]*session
100 	lros     map[string]*lro
104 	adminpb.DatabaseAdminServer
105 	spannerpb.SpannerServer
106 	lropb.OperationsServer
241 …rver) GetOperation(ctx context.Context, req *lropb.GetOperationRequest) (*lropb.Operation, error) {
255 …ver) GetDatabase(ctx context.Context, req *adminpb.GetDatabaseRequest) (*adminpb.Database, error) {
280 …DatabaseDdl(ctx context.Context, req *adminpb.UpdateDatabaseDdlRequest) (*lropb.Operation, error) {
329 func (s *server) runOneDDL(ctx context.Context, stmt spansql.DDLStmt) *status.Status {
333 …ctx context.Context, req *adminpb.GetDatabaseDdlRequest) (*adminpb.GetDatabaseDdlResponse, error) {
343 …eateSession(ctx context.Context, req *spannerpb.CreateSessionRequest) (*spannerpb.Session, error) {
348 func (s *server) newSession() *spannerpb.Session {
366 …ntext, req *spannerpb.BatchCreateSessionsRequest) (*spannerpb.BatchCreateSessionsResponse, error) {
377 …er) GetSession(ctx context.Context, req *spannerpb.GetSessionRequest) (*spannerpb.Session, error) {
392 …) DeleteSession(ctx context.Context, req *spannerpb.DeleteSessionRequest) (*emptypb.Empty, error) {
413 func (s *server) popTx(sessionID, tid string) (tx *transaction, err error) {
438 …session string, tsel *spannerpb.TransactionSelector) (tx *transaction, cleanup func(), err error) {
487 …) ExecuteSql(ctx context.Context, req *spannerpb.ExecuteSqlRequest) (*spannerpb.ResultSet, error) {
533 …ngSql(req *spannerpb.ExecuteSqlRequest, stream spannerpb.Spanner_ExecuteStreamingSqlServer) error {
547 func (s *server) executeQuery(req *spannerpb.ExecuteSqlRequest) (ri rowIter, err error) {
569 …er) StreamingRead(req *spannerpb.ReadRequest, stream spannerpb.Spanner_StreamingReadServer) error {
608 func (s *server) resultSet(ri rowIter) (*spannerpb.ResultSet, error) {
637 …context.Context, tx *transaction, send func(*spannerpb.PartialResultSet) error, ri rowIter) error {
675 func (s *server) buildResultSetMetadata(ri rowIter) (*spannerpb.ResultSetMetadata, error) {
694 …tion(ctx context.Context, req *spannerpb.BeginTransactionRequest) (*spannerpb.Transaction, error) {
724 …it(ctx context.Context, req *spannerpb.CommitRequest) (resp *spannerpb.CommitResponse, err error) {
788 …(s *server) Rollback(ctx context.Context, req *spannerpb.RollbackRequest) (*emptypb.Empty, error) {