var requestID … type grpcServer … type registerService … type endpoint … // startGRPCServer sets up the GRPC server on a Unix domain socket and spawns a goroutine // which handles requests for arbitrary services. // // The context is only used for additional values, cancellation is ignored. func startGRPCServer(valueCtx context.Context, grpcVerbosity int, unaryInterceptors []grpc.UnaryServerInterceptor, streamInterceptors []grpc.StreamServerInterceptor, endpoint endpoint, services ...registerService) (*grpcServer, error) { … } // unaryContextInterceptor injects values from the context into the context // used by the call chain. func unaryContextInterceptor(valueCtx context.Context) grpc.UnaryServerInterceptor { … } // streamContextInterceptor does the same as UnaryContextInterceptor for streams. func streamContextInterceptor(valueCtx context.Context) grpc.StreamServerInterceptor { … } type mergeServerStream … func (m mergeServerStream) Context() context.Context { … } // mergeContexts creates a new context where cancellation is handled by the // root context. The values stored by the value context are used as fallback if // the root context doesn't have a certain value. func mergeContexts(rootCtx, valueCtx context.Context) context.Context { … } type mergeCtx … func (m mergeCtx) Value(i interface{ … } // interceptor is called for each request. It creates a logger with a unique, // sequentially increasing request ID and adds that logger to the context. It // also logs request and response. func (s *grpcServer) interceptor(ctx context.Context, req interface{ … } func (s *grpcServer) streamInterceptor(server interface{ … } type logStream … func (l logStream) Context() context.Context { … } func (l logStream) SendMsg(msg interface{ … } // stop ensures that the server is not running anymore and cleans up all resources. // It is idempotent and may be called with a nil pointer. func (s *grpcServer) stop() { … }
Codebase Browser
kubernetes