Lines Matching defs:server

89 type server struct {  struct
90 	logf Logger
92 	db database
94 	mu       sync.Mutex
95 	sessions map[string]*session
96 	lros     map[string]*lro
100 	adminpb.DatabaseAdminServer
101 	spannerpb.SpannerServer
102 	lropb.OperationsServer
219 …rver) GetOperation(ctx context.Context, req *lropb.GetOperationRequest) (*lropb.Operation, error) {
250 …DatabaseDdl(ctx context.Context, req *adminpb.UpdateDatabaseDdlRequest) (*lropb.Operation, error) {
305 func (s *server) runOneDDL(ctx context.Context, stmt spansql.DDLStmt) *status.Status {
309 …ctx context.Context, req *adminpb.GetDatabaseDdlRequest) (*adminpb.GetDatabaseDdlResponse, error) {
319 …eateSession(ctx context.Context, req *spannerpb.CreateSessionRequest) (*spannerpb.Session, error) {
324 func (s *server) newSession() *spannerpb.Session {
342 …ntext, req *spannerpb.BatchCreateSessionsRequest) (*spannerpb.BatchCreateSessionsResponse, error) {
353 …er) GetSession(ctx context.Context, req *spannerpb.GetSessionRequest) (*spannerpb.Session, error) {
368 …) DeleteSession(ctx context.Context, req *spannerpb.DeleteSessionRequest) (*emptypb.Empty, error) {
389 func (s *server) popTx(sessionID, tid string) (tx *transaction, err error) {
414 …session string, tsel *spannerpb.TransactionSelector) (tx *transaction, cleanup func(), err error) {
463 …) ExecuteSql(ctx context.Context, req *spannerpb.ExecuteSqlRequest) (*spannerpb.ResultSet, error) {
499 …ngSql(req *spannerpb.ExecuteSqlRequest, stream spannerpb.Spanner_ExecuteStreamingSqlServer) error {
531 …er) StreamingRead(req *spannerpb.ReadRequest, stream spannerpb.Spanner_StreamingReadServer) error {
570 …context.Context, tx *transaction, send func(*spannerpb.PartialResultSet) error, ri rowIter) error {
619 …tion(ctx context.Context, req *spannerpb.BeginTransactionRequest) (*spannerpb.Transaction, error) {
649 …it(ctx context.Context, req *spannerpb.CommitRequest) (resp *spannerpb.CommitResponse, err error) {
713 …(s *server) Rollback(ctx context.Context, req *spannerpb.RollbackRequest) (*emptypb.Empty, error) {