Lines Matching defs:server

91 type server struct {  struct
92 	logf Logger
94 	db    database
95 	start time.Time
97 	mu       sync.Mutex
98 	sessions map[string]*session
99 	lros     map[string]*lro
103 	adminpb.DatabaseAdminServer
104 	spannerpb.SpannerServer
105 	lropb.OperationsServer
223 …rver) GetOperation(ctx context.Context, req *lropb.GetOperationRequest) (*lropb.Operation, error) {
239 …ver) GetDatabase(ctx context.Context, req *adminpb.GetDatabaseRequest) (*adminpb.Database, error) {
264 …DatabaseDdl(ctx context.Context, req *adminpb.UpdateDatabaseDdlRequest) (*lropb.Operation, error) {
319 func (s *server) runOneDDL(ctx context.Context, stmt spansql.DDLStmt) *status.Status {
323 …ctx context.Context, req *adminpb.GetDatabaseDdlRequest) (*adminpb.GetDatabaseDdlResponse, error) {
333 …eateSession(ctx context.Context, req *spannerpb.CreateSessionRequest) (*spannerpb.Session, error) {
338 func (s *server) newSession() *spannerpb.Session {
356 …ntext, req *spannerpb.BatchCreateSessionsRequest) (*spannerpb.BatchCreateSessionsResponse, error) {
367 …er) GetSession(ctx context.Context, req *spannerpb.GetSessionRequest) (*spannerpb.Session, error) {
382 …) DeleteSession(ctx context.Context, req *spannerpb.DeleteSessionRequest) (*emptypb.Empty, error) {
403 func (s *server) popTx(sessionID, tid string) (tx *transaction, err error) {
428 …session string, tsel *spannerpb.TransactionSelector) (tx *transaction, cleanup func(), err error) {
477 …) ExecuteSql(ctx context.Context, req *spannerpb.ExecuteSqlRequest) (*spannerpb.ResultSet, error) {
513 …ngSql(req *spannerpb.ExecuteSqlRequest, stream spannerpb.Spanner_ExecuteStreamingSqlServer) error {
545 …er) StreamingRead(req *spannerpb.ReadRequest, stream spannerpb.Spanner_StreamingReadServer) error {
584 …context.Context, tx *transaction, send func(*spannerpb.PartialResultSet) error, ri rowIter) error {
633 …tion(ctx context.Context, req *spannerpb.BeginTransactionRequest) (*spannerpb.Transaction, error) {
663 …it(ctx context.Context, req *spannerpb.CommitRequest) (resp *spannerpb.CommitResponse, err error) {
727 …(s *server) Rollback(ctx context.Context, req *spannerpb.RollbackRequest) (*emptypb.Empty, error) {